add teams runtime

docs/src/content/docs/reference/cli/commands.md

@@ -38,6 +38,7 @@ Options:
   -prc, --pull-request-comment [string]      create comment on a pull request with a unique id (defaults to script id)
   -prd, --pull-request-description [string]  create comment on a pull request description with a unique id (defaults to script id)
   -prr, --pull-request-reviews               create pull request reviews from annotations
+  -tm, --teams-message                       Posts a message to the teams channel
   -j, --json                                 emit full JSON response to output
   -y, --yaml                                 emit full YAML response to output
   -fe, --fail-on-errors                      fails on detected annotation error

package.json

@@ -77,7 +77,7 @@
         "genai:docify": "node packages/cli/built/genaiscript.cjs run docify",
         "gcm": "node packages/cli/built/genaiscript.cjs run gcm --model github:gpt-4o",
         "prd": "node packages/cli/built/genaiscript.cjs run prd -prd --model github:gpt-4o",
-        "prr": "node packages/cli/built/genaiscript.cjs run prr -prc --model github:gpt-4o",
+        "prr": "node packages/cli/built/genaiscript.cjs run prr -prr --model github:gpt-4o-mini",
         "genai": "node packages/cli/built/genaiscript.cjs run",
         "genai:convert": "node packages/cli/built/genaiscript.cjs convert",
         "genai:debug": "yarn compile-debug && node packages/cli/built/genaiscript.cjs run",

packages/cli/src/cli.ts

@@ -145,6 +145,10 @@ export async function cli() {
             "-prr, --pull-request-reviews",
             "create pull request reviews from annotations"
         )
+        .option(
+            "-tm, --teams-message",
+            "Posts a message to the teams channel"
+        )
         .option("-j, --json", "emit full JSON response to output")
         .option("-y, --yaml", "emit full YAML response to output")
         .option(`-fe, --fail-on-errors`, `fails on detected annotation error`)

packages/cli/src/nodehost.ts

@@ -97,6 +97,7 @@ export class NodeHost implements RuntimeHost {
     readonly userInputQueue = new PLimitPromiseQueue(1)
     readonly azureToken: AzureTokenResolver
     readonly azureServerlessToken: AzureTokenResolver
+    readonly microsoftGraphToken: AzureTokenResolver
 
     constructor(dotEnvPath: string) {
         this.dotEnvPath = dotEnvPath
@@ -110,6 +111,11 @@ export class NodeHost implements RuntimeHost {
             "AZURE_SERVERLESS_OPENAI_TOKEN_SCOPES",
             AZURE_AI_INFERENCE_TOKEN_SCOPES
         )
+        this.microsoftGraphToken = createAzureTokenResolver(
+            "Microsoft Graph",
+            "MICROSOFT_GRAPH_TOKEN_SCOPES",
+            ["https://graph.microsoft.com/.default"]
+        )
     }
 
     get modelAliases(): Readonly<ModelConfigurations> {

packages/cli/src/run.ts

@@ -91,6 +91,7 @@ import { parsePromptScriptMeta } from "../../core/src/template"
 import { Fragment } from "../../core/src/generation"
 import { randomHex } from "../../core/src/crypto"
 import { normalizeFloat, normalizeInt } from "../../core/src/cleaners"
+import { microsoftTeamsChannelPostMessage } from "../../core/src/teams"
 
 function getRunDir(scriptId: string) {
     const runId =
@@ -180,6 +181,7 @@ export async function runScriptInternal(
     const pullRequestComment = options.pullRequestComment
     const pullRequestDescription = options.pullRequestDescription
     const pullRequestReviews = options.pullRequestReviews
+    const teamsMessage = options.teamsMessage
     const outData = options.outData
     const label = options.label
     const temperature = normalizeFloat(options.temperature)
@@ -524,6 +526,21 @@ export async function runScriptInternal(
     }
     let adoInfo: AzureDevOpsEnv = undefined
 
+    if (teamsMessage && result.text) {
+        const ghInfo = await resolveGitHubInfo()
+        const channelURL =
+            process.env.GENAISCRIPT_TEAMS_CHANNEL_URL ||
+            process.env.TEAMS_CHANNEL_URL
+        if (channelURL) {
+            await microsoftTeamsChannelPostMessage(channelURL, result.text, {
+                script,
+                info: ghInfo,
+                cancellationToken,
+                trace,
+            })
+        }
+    }
+
     if (pullRequestReviews && result.annotations?.length) {
         // github action or repo
         const ghInfo = await resolveGitHubInfo()

packages/cli/src/runtime.ts

@@ -6,6 +6,7 @@
 import { delay, uniq, uniqBy, chunk, groupBy } from "es-toolkit"
 import { z } from "zod"
 import { pipeline } from "@huggingface/transformers"
+import { readFile } from "fs/promises"
 
 // symbols exported as is
 export { delay, uniq, uniqBy, z, pipeline, chunk, groupBy }

packages/core/src/file.ts

@@ -196,9 +196,15 @@ ${CSVToMarkdown(tidyData(rows, options))}
  * @returns The Data URI string or undefined if the MIME type cannot be determined.
  */
 export async function resolveFileBytes(
-    filename: string,
+    filename: string | WorkspaceFile,
     options?: TraceOptions
 ): Promise<Uint8Array> {
+    if (typeof filename === "object") {
+        if (filename.encoding === "base64" && filename.content)
+            return fromBase64(filename.content)
+        filename = filename.filename
+    }
+
     if (/^data:/i.test(filename)) {
         const matches = filename.match(/^data:[^;]+;base64,(.*)$/i)
         if (!matches) throw new Error("Invalid data URI format")

packages/core/src/host.ts

@@ -128,7 +128,11 @@ export interface Host {
 export interface RuntimeHost extends Host {
     project: Project
     workspace: Omit<WorkspaceFileSystem, "grep" | "writeCached">
+
     azureToken: AzureTokenResolver
+    azureServerlessToken: AzureTokenResolver
+    microsoftGraphToken: AzureTokenResolver
+
     modelAliases: Readonly<ModelConfigurations>
     clientLanguageModel?: LanguageModel
 

packages/core/src/promptcontext.ts

@@ -30,6 +30,7 @@ import { DOCS_WEB_SEARCH_URL } from "./constants"
 import { fetch, fetchText } from "./fetch"
 import { fileWriteCached } from "./filecache"
 import { join } from "node:path"
+import { createMicrosoftTeamsChannelClient } from "./teams"
 
 /**
  * Creates a prompt context for the given project, variables, trace, options, and model.
@@ -304,6 +305,7 @@ export async function createPromptContext(
             }),
         python: async (options) =>
             await runtimeHost.python({ trace, ...(options || {}) }),
+        teamsChannel: async (url) => createMicrosoftTeamsChannelClient(url),
     })
 
     // Freeze project options to prevent modification

packages/core/src/server/messages.ts

@@ -132,6 +132,7 @@ export interface PromptScriptRunOptions {
     pullRequestComment: string | boolean
     pullRequestDescription: string | boolean
     pullRequestReviews: boolean
+    teamsMessage: boolean
     outData: string
     label: string
     temperature: string | number

packages/core/src/teams.test.ts

@@ -0,0 +1,72 @@
+import { convertMarkdownToTeamsHTML } from "./teams"
+import { describe, test } from "node:test"
+import assert from "node:assert/strict"
+
+describe("convertMarkdownToTeamsHTML", () => {
+    test("converts headers correctly", () => {
+        const markdown =
+            "# Subject\n## Heading 1\n### Heading 2\n#### Heading 3"
+        const result = convertMarkdownToTeamsHTML(markdown)
+        assert.strictEqual(result.subject, "Subject")
+        assert.strictEqual(
+            result.content,
+            "<div>\n<h1>Heading 1</h1>\n<h2>Heading 2</h2>\n<h3>Heading 3</h3></div>"
+        )
+    })
+
+    test("converts bold, italic, code, and strike correctly", () => {
+        const markdown = "**bold** *italic* `code` ~~strike~~"
+        const result = convertMarkdownToTeamsHTML(markdown)
+        assert.strictEqual(
+            result.content,
+            "<div><b>bold</b> <i>italic</i> <code>code</code> <strike>strike</strike></div>"
+        )
+    })
+
+    test("converts blockquotes correctly", () => {
+        const markdown = "> This is a blockquote"
+        const result = convertMarkdownToTeamsHTML(markdown)
+        assert.strictEqual(
+            result.content,
+            "<div><blockquote>This is a blockquote</blockquote>\n</div>"
+        )
+    })
+    test("handles empty markdown string", () => {
+        const markdown = ""
+        const result = convertMarkdownToTeamsHTML(markdown)
+        assert.strictEqual(result.content, "<div></div>")
+        assert.strictEqual(result.subject, undefined)
+    })
+
+    test("handles markdown without subject", () => {
+        const markdown = "## Heading 1\nContent"
+        const result = convertMarkdownToTeamsHTML(markdown)
+        assert.strictEqual(result.subject, undefined)
+        assert.strictEqual(result.content, "<div><h1>Heading 1</h1>\nContent</div>")
+    })
+    test("converts unordered lists correctly", () => {
+        const markdown = "- Item 1\n- Item 2\n- Item 3"
+        const result = convertMarkdownToTeamsHTML(markdown)
+        assert.strictEqual(
+            result.content,
+            "<div><br/>- Item 1\n<br/>- Item 2\n<br/>- Item 3</div>"
+        )
+    })
+
+    test("converts mixed content correctly", () => {
+        const markdown =
+            "# Subject\n## Heading 1\nContent with **bold**, *italic*, `code`, and ~~strike~~.\n- List item 1\n- List item 2\n> Blockquote"
+        const result = convertMarkdownToTeamsHTML(markdown)
+        assert.strictEqual(result.subject, "Subject")
+        assert.strictEqual(
+            result.content,
+            "<div>\n<h1>Heading 1</h1>\nContent with <b>bold</b>, <i>italic</i>, <code>code</code>, and <strike>strike</strike>.\n<br/>- List item 1\n<br/>- List item 2\n<blockquote>Blockquote</blockquote>\n</div>"
+        )
+    })
+
+    test("converts multiple paragraphs correctly", () => {
+        const markdown = "Paragraph 1\n\nParagraph 2"
+        const result = convertMarkdownToTeamsHTML(markdown)
+        assert.strictEqual(result.content, "<div>Paragraph 1\n\nParagraph 2</div>")
+    })
+})