feat: adopt Mastra signals + background tasks (alpha track)

.npmrc

@@ -0,0 +1 @@
+legacy-peer-deps=true

package.json

@@ -30,7 +30,7 @@
     "esbuild": ">=0.25.0",
     "zod": "4.4.3",
     "postcss": "^8.5.10",
-    "@mastra/core": "1.41.0"
+    "@mastra/core": "1.42.0-alpha.3"
   },
   "devDependencies": {
     "@biomejs/biome": "^2.4.12",

packages/agents/.npmrc

@@ -0,0 +1 @@
+legacy-peer-deps=true

packages/agents/package.json

@@ -47,17 +47,17 @@
     "@chat-adapter/telegram": "^4.28.1",
     "@chat-adapter/whatsapp": "^4.28.1",
     "@hono/node-server": "^1.19.14",
-    "@mastra/ai-sdk": "^1.4.4",
-    "@mastra/core": "^1.41.0",
-    "@mastra/duckdb": "^1.4.1",
-    "@mastra/editor": "^0.11.1",
-    "@mastra/evals": "^1.2.4",
-    "@mastra/loggers": "^1.1.2",
-    "@mastra/memory": "^1.20.2",
-    "@mastra/observability": "^1.14.1",
-    "@mastra/pg": "^1.12.1",
-    "@mastra/rag": "^2.2.1",
-    "@mastra/voice-openai": "^0.12.2",
+    "@mastra/ai-sdk": "1.4.5-alpha.0",
+    "@mastra/core": "1.42.0-alpha.3",
+    "@mastra/duckdb": "1.4.1-alpha.0",
+    "@mastra/editor": "0.11.2-alpha.0",
+    "@mastra/evals": "1.2.4-alpha.0",
+    "@mastra/loggers": "1.1.2-alpha.0",
+    "@mastra/memory": "1.20.2-alpha.0",
+    "@mastra/observability": "1.14.1-alpha.1",
+    "@mastra/pg": "1.13.0-alpha.0",
+    "@mastra/rag": "2.2.1-alpha.0",
+    "@mastra/voice-openai": "0.12.2-alpha.0",
     "@supabase/supabase-js": "^2.105.4",
     "@zapier/zapier-sdk": "^0.69.3",
     "ai": "^6.0.177",
@@ -80,14 +80,14 @@
     "zod": "^4.3.6"
   },
   "optionalDependencies": {
-    "@mastra/deployer-cloudflare": "^1.1.42",
-    "@mastra/deployer-vercel": "^1.1.36"
+    "@mastra/deployer-cloudflare": "1.1.43-alpha.0",
+    "@mastra/deployer-vercel": "1.1.37-alpha.0"
   },
   "devDependencies": {
     "@copilotkit/aimock": "^1.14.3",
     "@types/node": "^20",
     "@zapier/zapier-sdk-cli": "^0.54.3",
-    "mastra": "^1.12.2",
+    "mastra": "1.12.3-alpha.3",
     "typescript": "^5",
     "vitest": "^4.1.4",
     "zlib-sync": "^0.1.10"

packages/agents/src/cron-driver-server.ts

@@ -1,18 +1,33 @@
 /**
- * Standalone entrypoint for the cron driver. Run with:
+ * Standalone entrypoint for the trigger drivers. Run with:
  *   node --env-file=.env.local src/cron-driver-server.ts
  *
  * Keeps a long-lived process that ticks once per minute and fires due
- * `workflow_trigger` rows. Only run a single instance — there is no
- * distributed lock.
+ * `workflow_trigger` rows: the cron driver (schedule matches) and the poll
+ * driver (Zapier read actions returning new records). Only run a single
+ * instance — there is no distributed lock.
  */
+import { getMastra } from "./mastra";
+import { zapierPollProvider } from "./mastra/signals/zapier-poll-provider";
 import { startCronDriver } from "./workflows/cron-driver";
+import { startPollDriver } from "./workflows/poll-driver";
 
-const stop = startCronDriver();
+// Build the Mastra instance here so the foreman agent is constructed in THIS
+// worker process — that connects the SignalProviders (poll/channel) and gives
+// them the notification storage notify() needs. Without it, runDuePolls() fires
+// workflows fine but notifyOwner() is a silent no-op (no connected agent). The
+// provider has no pollInterval, so constructing the agent here doesn't start a
+// second poll loop. (foreman notify-wiring)
+getMastra();
+console.log(`[trigger-driver] poll provider connected: ${zapierPollProvider.isConnected}`);
+
+const stopCron = startCronDriver();
+const stopPoll = startPollDriver();
 
 const shutdown = (sig: string) => {
-  console.log(`[cron-driver] received ${sig}, shutting down`);
-  stop();
+  console.log(`[trigger-driver] received ${sig}, shutting down`);
+  stopCron();
+  stopPoll();
   process.exit(0);
 };
 process.on("SIGINT", () => shutdown("SIGINT"));

packages/agents/src/discord/bot.ts

@@ -123,6 +123,7 @@ export async function getDiscordBot() {
       channel: "discord",
       text: message.text,
       from: message.author.userId,
+      dedupeKey: message.id,
       room: thread.channelId,
     });
     if (fired > 0) return;
@@ -144,6 +145,7 @@ export async function getDiscordBot() {
       channel: "discord",
       text: message.text,
       from: message.author.userId,
+      dedupeKey: message.id,
       room: thread.id,
     });
     if (fired > 0) return;

packages/agents/src/gchat/bot.ts

@@ -62,6 +62,7 @@ export async function getGoogleChatBot() {
         channel: "gchat",
         text: message.text,
         from: message.author.userId,
+        dedupeKey: message.id,
         room: thread.channelId,
       });
       if (fired > 0) return;
@@ -88,6 +89,7 @@ export async function getGoogleChatBot() {
         channel: "gchat",
         text: message.text,
         from: message.author.userId,
+        dedupeKey: message.id,
         room: thread.id,
       });
       if (fired > 0) return;

packages/agents/src/github/bot.ts

@@ -65,6 +65,7 @@ export async function getGitHubBot() {
         channel: "github",
         text: message.text,
         from: message.author.userId,
+        dedupeKey: message.id,
         room: thread.channelId,
       });
       if (fired > 0) return;
@@ -91,6 +92,7 @@ export async function getGitHubBot() {
         channel: "github",
         text: message.text,
         from: message.author.userId,
+        dedupeKey: message.id,
         room: thread.id,
       });
       if (fired > 0) return;

packages/agents/src/lib/background.ts

@@ -0,0 +1,22 @@
+/**
+ * Gated background-execution config for agent tools (foreman-7am4).
+ *
+ * Returns `{ background: { enabled: true } }` when FOREMAN_BACKGROUND_TOOLS=1,
+ * else `{}` — spread into a tool's createTool() config to opt it into Mastra
+ * background execution.
+ *
+ * Apply ONLY to simple-schema custom tools. Live verification showed that
+ * backgrounding the generated Zapier SDK tools hangs `mastra dev`: enabling
+ * background makes Mastra inject a `_background` field into the tool's input
+ * schema, and Studio's `toJSONSchema` introspection over the Zapier tools'
+ * (pathologically complex) zod schemas then loops forever — the same failure the
+ * lazy-init-zapier regression test guards. `mastra build` is unaffected (no
+ * Studio introspection), but the dev playground is. Simple schemas (e.g.
+ * search_history's 3 fields) inject + introspect fine.
+ *
+ * Read at call time so tests can toggle the flag. OFF by default — this changes
+ * live tool dispatch and is alpha-unverified end-to-end, so it ships inert.
+ */
+export function backgroundIfEnabled(): { background?: { enabled: true } } {
+  return process.env.FOREMAN_BACKGROUND_TOOLS === "1" ? { background: { enabled: true } } : {};
+}

packages/agents/src/lib/catalog/index.ts

@@ -1,2 +1,3 @@
+export { resolveAppSlug } from "./resolve";
 export { seedCatalog } from "./seed";
 export { ensureCatalogIndex, indexAppCatalog, searchAppCatalog } from "./vector";

packages/agents/src/lib/catalog/resolve.ts

@@ -0,0 +1,37 @@
+import { getSupabase } from "../db";
+
+/**
+ * Resolve any Zapier app identifier to its canonical slug, using the
+ * `app_catalog` table (seeded from `sdk.listApps`) as the source of truth.
+ *
+ * The catalog stores BOTH the Zapier `app_key` (e.g. "GitHubCLIAPI") and the
+ * display `slug` (e.g. "github"), so it knows the correct mapping. This replaces
+ * the string-munging `normalizeAppKey`, which can't reliably derive a slug from
+ * a CamelCase implementation name: "GitHubCLIAPI" → "git-hub" is wrong (the real
+ * slug is "github"), while "GoogleSheetsV2CLIAPI" → "google-sheets" needs the
+ * dash. You can't tell those apart from the string alone — only the catalog can.
+ * (foreman-c8fo)
+ *
+ * Accepts either form (app_key or slug, case-insensitive) and returns the slug.
+ * If the app isn't in the catalog (e.g. an unseeded local DB), the key is
+ * returned UNCHANGED — the Zapier SDK accepts both raw app_keys and slugs, so
+ * passing the original through is safe; only the mangled form ever broke.
+ */
+export async function resolveAppSlug(key: string): Promise<string> {
+  if (!key) return key;
+  // App keys/slugs are simple identifiers; guard the PostgREST `or` filter.
+  if (!/^[\w.-]+$/.test(key)) return key;
+
+  try {
+    const { data } = await getSupabase()
+      .from("app_catalog")
+      .select("slug")
+      .or(`app_key.ilike.${key},slug.ilike.${key}`)
+      .limit(1)
+      .maybeSingle();
+    if (data?.slug) return data.slug;
+  } catch {
+    // catalog unavailable / not seeded — fall through to pass-through
+  }
+  return key;
+}

packages/agents/src/lib/db/database.types.ts

@@ -3429,25 +3429,34 @@ export type Database = {
         Row: {
           completed_at: string | null;
           created_at: string;
+          error_message: string | null;
+          fired_by: string | null;
           id: string;
           inputs: string;
           status: string;
+          trigger_id: string | null;
           workflow_id: string;
         };
         Insert: {
           completed_at?: string | null;
           created_at: string;
+          error_message?: string | null;
+          fired_by?: string | null;
           id: string;
           inputs: string;
           status: string;
+          trigger_id?: string | null;
           workflow_id: string;
         };
         Update: {
           completed_at?: string | null;
           created_at?: string;
+          error_message?: string | null;
+          fired_by?: string | null;
           id?: string;
           inputs?: string;
           status?: string;
+          trigger_id?: string | null;
           workflow_id?: string;
         };
         Relationships: [