build: update bundled dist files

Author: actions-user

dist/index.js

@@ -192,6 +192,15 @@ var init_task_store = __esm({
           conditions.push("workflow_id = ?");
           params.push(filter.workflowId);
         }
+        if (filter.search) {
+          const escaped = filter.search.replace(/[%_\\]/g, "\\$&");
+          conditions.push("request_message LIKE ? ESCAPE '\\'");
+          params.push(`%${escaped}%`);
+        }
+        if (filter.claimedBy) {
+          conditions.push("claimed_by = ?");
+          params.push(filter.claimedBy);
+        }
         const where = conditions.length > 0 ? `WHERE ${conditions.join(" AND ")}` : "";
         return { where, params };
       }
@@ -345,6 +354,32 @@ var init_task_store = __esm({
       // -------------------------------------------------------------------------
       // Cleanup
       // -------------------------------------------------------------------------
+      failStaleTasks(reason) {
+        const db = this.getDb();
+        const now = nowISO();
+        const msg = reason || "Process terminated while task was running";
+        const statusMessage = JSON.stringify({
+          message_id: crypto.randomUUID(),
+          role: "agent",
+          parts: [{ text: msg }]
+        });
+        const result = db.prepare(
+          `UPDATE agent_tasks
+         SET state = 'failed', updated_at = ?, status_message = ?
+         WHERE state = 'working'`
+        ).run(now, statusMessage);
+        return result.changes;
+      }
+      purgeOldTasks(olderThanMs) {
+        const db = this.getDb();
+        const cutoff = new Date(Date.now() - olderThanMs).toISOString();
+        const result = db.prepare(
+          `DELETE FROM agent_tasks
+         WHERE state IN ('completed', 'failed', 'canceled', 'rejected')
+         AND updated_at <= ?`
+        ).run(cutoff);
+        return result.changes;
+      }
       deleteExpiredTasks() {
         const db = this.getDb();
         const now = nowISO();
@@ -1619,4 +1654,4 @@ export {
   messageToWorkflowInput,
   resultToArtifacts
 };
-//# sourceMappingURL=a2a-frontend-GUEGI5SX.mjs.map
+//# sourceMappingURL=a2a-frontend-N4VU3PHW.mjs.map

dist/sdk/a2a-frontend-GUEGI5SX.mjs.map

@@ -1,8 +1,8 @@
 import {
   CheckProviderRegistry,
   init_check_provider_registry
-} from "./chunk-CXA3WUOB.mjs";
-import "./chunk-AVMMKGLQ.mjs";
+} from "./chunk-CNZ7XHLN.mjs";
+import "./chunk-PDQTEBOJ.mjs";
 import "./chunk-YSOIR46P.mjs";
 import "./chunk-LG4AUKHB.mjs";
 import "./chunk-B7BVQM5K.mjs";
@@ -27,4 +27,4 @@ init_check_provider_registry();
 export {
   CheckProviderRegistry
 };
-//# sourceMappingURL=check-provider-registry-ZUU7KSKR.mjs.map
+//# sourceMappingURL=check-provider-registry-4KW2YPZW.mjs.map

dist/sdk/a2a-frontend-GUEGI5SX.mjs dist/sdk/a2a-frontend-N4VU3PHW.mjsdist/sdk/a2a-frontend-GUEGI5SX.mjs renamed to dist/sdk/a2a-frontend-N4VU3PHW.mjs

@@ -2,7 +2,7 @@ import {
   extractFileSections,
   init_markdown,
   replaceFileSections
-} from "./chunk-AVMMKGLQ.mjs";
+} from "./chunk-PDQTEBOJ.mjs";
 import {
   A2AAuthRequiredError,
   A2AInputRequiredError,
@@ -3979,7 +3979,7 @@ async function executeWorkflowAsTool(workflowId, args, context2, argsOverrides)
     ...args,
     ...argsOverrides
   };
-  const { WorkflowCheckProvider: WorkflowCheckProvider2 } = await import("./workflow-check-provider-KQNLEQEY.mjs");
+  const { WorkflowCheckProvider: WorkflowCheckProvider2 } = await import("./workflow-check-provider-O2SIH3PC.mjs");
   const provider = new WorkflowCheckProvider2();
   const checkConfig = {
     type: "workflow",
@@ -13315,7 +13315,7 @@ var init_state_machine_execution_engine = __esm({
           try {
             const map = options?.webhookContext?.webhookData;
             if (map) {
-              const { CheckProviderRegistry: CheckProviderRegistry2 } = await import("./check-provider-registry-ZUU7KSKR.mjs");
+              const { CheckProviderRegistry: CheckProviderRegistry2 } = await import("./check-provider-registry-4KW2YPZW.mjs");
               const reg = CheckProviderRegistry2.getInstance();
               const p = reg.getProvider("http_input");
               if (p && typeof p.setWebhookContext === "function") p.setWebhookContext(map);
@@ -13438,7 +13438,7 @@ var init_state_machine_execution_engine = __esm({
           tag_filter: tagFilter
         } : config;
         try {
-          const { CheckProviderRegistry: CheckProviderRegistry2 } = await import("./check-provider-registry-ZUU7KSKR.mjs");
+          const { CheckProviderRegistry: CheckProviderRegistry2 } = await import("./check-provider-registry-4KW2YPZW.mjs");
           const registry = CheckProviderRegistry2.getInstance();
           registry.setCustomTools(configWithTagFilter.tools || {});
         } catch (error) {
@@ -13502,7 +13502,7 @@ var init_state_machine_execution_engine = __esm({
           try {
             const webhookData = this.executionContext?.webhookContext?.webhookData;
             if (webhookData instanceof Map) {
-              const { extractSlackContext: extractSlackContext2 } = await import("./schedule-tool-handler-XLCSBU3E.mjs");
+              const { extractSlackContext: extractSlackContext2 } = await import("./schedule-tool-handler-DCMMLWLB.mjs");
               const slackCtx = extractSlackContext2(webhookData);
               if (slackCtx) {
                 const payload = Array.from(webhookData.values())[0];
@@ -13531,7 +13531,7 @@ var init_state_machine_execution_engine = __esm({
         if (Array.isArray(configWithTagFilter.frontends) && configWithTagFilter.frontends.length > 0) {
           try {
             const { EventBus } = await import("./event-bus-5K3Y2FCS.mjs");
-            const { FrontendsHost } = await import("./host-A7UNRBQU.mjs");
+            const { FrontendsHost } = await import("./host-DOJQVREK.mjs");
             const bus = new EventBus();
             context2.eventBus = bus;
             frontendsHost = new FrontendsHost(bus, logger);
@@ -41251,8 +41251,8 @@ function buildBuiltinGlobals(opts) {
   const asyncFunctionNames = /* @__PURE__ */ new Set();
   const scheduleFn = async (args = {}) => {
     try {
-      const { handleScheduleAction: handleScheduleAction2, buildScheduleToolContext: buildScheduleToolContext2 } = await import("./schedule-tool-DGVJDHJM.mjs");
-      const { extractSlackContext: extractSlackContext2 } = await import("./schedule-tool-handler-XLCSBU3E.mjs");
+      const { handleScheduleAction: handleScheduleAction2, buildScheduleToolContext: buildScheduleToolContext2 } = await import("./schedule-tool-HCJUIF4H.mjs");
+      const { extractSlackContext: extractSlackContext2 } = await import("./schedule-tool-handler-DCMMLWLB.mjs");
       const parentCtx = opts.sessionInfo?._parentContext;
       const webhookData = parentCtx?.prInfo?.eventContext?.webhookData;
       const visorCfg = parentCtx?.config;
@@ -44807,4 +44807,4 @@ undici/lib/fetch/body.js:
 undici/lib/websocket/frame.js:
   (*! ws. MIT License. Einar Otto Stangvik <einaros@gmail.com> *)
 */
-//# sourceMappingURL=chunk-CXA3WUOB.mjs.map
+//# sourceMappingURL=chunk-CNZ7XHLN.mjs.map

dist/sdk/a2a-frontend-N4VU3PHW.mjs.map

@@ -109,28 +109,27 @@ function replaceMermaidBlocks(text, diagrams, replacement = "_(See diagram above
 }
 function markdownToSlack(text) {
   if (!text || typeof text !== "string") return "";
-  let out = text;
-  out = out.replace(
-    /!\[([^\]]*)\]\(([^)\s]+)(?:\s+"[^"]*")?\)/g,
-    (_m, alt, url) => `<${url}|${alt || "image"}>`
-  );
-  out = out.replace(
-    /\[([^\]]+)\]\(([^)\s]+)(?:\s+"[^"]*")?\)/g,
-    (_m, label, url) => `<${url}|${label}>`
-  );
-  out = out.replace(/\*\*([^*]+)\*\*/g, (_m, inner) => `*${inner}*`);
-  out = out.replace(/__([^_]+)__/g, (_m, inner) => `*${inner}*`);
-  const lines = out.split(/\r?\n/);
+  const lines = text.split(/\r?\n/);
   let inCodeBlock = false;
   for (let i = 0; i < lines.length; i++) {
-    const line = lines[i];
-    const trimmed = line.trimStart();
+    const trimmed = lines[i].trimStart();
     if (/^```/.test(trimmed)) {
       inCodeBlock = !inCodeBlock;
       continue;
     }
     if (inCodeBlock) continue;
-    const headerMatch = /^(#{1,6})\s+(.+)$/.exec(trimmed);
+    let line = lines[i];
+    line = line.replace(
+      /!\[([^\]]*)\]\(([^)\s]+)(?:\s+"[^"]*")?\)/g,
+      (_m, alt, url) => `<${url}|${alt || "image"}>`
+    );
+    line = line.replace(
+      /\[([^\]]+)\]\(([^)\s]+)(?:\s+"[^"]*")?\)/g,
+      (_m, label, url) => `<${url}|${label}>`
+    );
+    line = line.replace(/\*\*([^*]+)\*\*/g, (_m, inner) => `*${inner}*`);
+    line = line.replace(/__([^_]+)__/g, (_m, inner) => `*${inner}*`);
+    const headerMatch = /^(#{1,6})\s+(.+)$/.exec(line.trimStart());
     if (headerMatch) {
       const [, hashes, headerText] = headerMatch;
       const prevLine = i > 0 ? lines[i - 1].trim() : "";
@@ -147,10 +146,11 @@ function markdownToSlack(text) {
     if (bulletMatch) {
       const [, indent, , rest] = bulletMatch;
       lines[i] = `${indent}\u2022 ${rest}`;
+      continue;
     }
+    lines[i] = line;
   }
-  out = lines.join("\n");
-  return out;
+  return lines.join("\n");
 }
 function extractFileSections(text) {
   const sections = [];
@@ -210,4 +210,4 @@ export {
   formatSlackText,
   init_markdown
 };
-//# sourceMappingURL=chunk-AVMMKGLQ.mjs.map
+//# sourceMappingURL=chunk-PDQTEBOJ.mjs.map