feat!: migrate personas to the relay SDK AgentEvent (Unit C, agents codemod)

cloud-team-implementer/agent.ts

@@ -9,13 +9,13 @@
  * and duplicate PRs for the same issue — so this handler declares no
  * triggers and only logs if cloud ever routes an event to it directly.
  */
-import { defineAgent, type WorkforceCtx, type WorkforceEvent } from '@agentworkforce/runtime';
+import { defineAgent, isCronTickEvent, type WorkforceCtx, type WorkforceEvent } from '@agentworkforce/runtime';
 
 export async function handleUnexpectedEvent(ctx: WorkforceCtx, event: WorkforceEvent): Promise<void> {
   ctx.log('warn', 'cloud-team-implementer received a direct event; members are launched by the team dispatcher, not by subscriptions', {
     eventId: event.id,
-    source: event.source,
-    type: 'type' in event ? event.type : undefined
+    source: isCronTickEvent(event) ? 'cron' : event.resource.provider,
+    type: event.type
   });
 }
 

cloud-team-reviewer/agent.ts

@@ -9,13 +9,13 @@
  * and duplicate reviews for the same issue — so this handler declares no
  * triggers and only logs if cloud ever routes an event to it directly.
  */
-import { defineAgent, type WorkforceCtx, type WorkforceEvent } from '@agentworkforce/runtime';
+import { defineAgent, isCronTickEvent, type WorkforceCtx, type WorkforceEvent } from '@agentworkforce/runtime';
 
 export async function handleUnexpectedEvent(ctx: WorkforceCtx, event: WorkforceEvent): Promise<void> {
   ctx.log('warn', 'cloud-team-reviewer received a direct event; members are launched by the team dispatcher, not by subscriptions', {
     eventId: event.id,
-    source: event.source,
-    type: 'type' in event ? event.type : undefined
+    source: isCronTickEvent(event) ? 'cron' : event.resource.provider,
+    type: event.type
   });
 }
 

granola/agent.ts

@@ -20,7 +20,7 @@ export default defineAgent({
   handler: async (ctx, event) => {
   // Notes arrive via the Nango sync as storage events (defineAgent narrows
   // `event` to the declared granola trigger, so there's no clock case here).
-  const notePath = readNotePath(event.payload);
+  const notePath = readNotePath((await event.expand('full')).data);
   if (!notePath || !notePath.includes('/granola/notes/')) return; // ignore folders/other writes
 
   const transcript = await readNote(ctx, notePath);

hn-monitor/agent.ts

@@ -7,7 +7,7 @@
  *     → summarize with ctx.llm
  *     → post to Slack
  */
-import { defineAgent, type WorkforceCtx } from '@agentworkforce/runtime';
+import { defineAgent, isCronTickEvent, type WorkforceCtx } from '@agentworkforce/runtime';
 import { slackClient } from '@relayfile/relay-helpers';
 
 export interface Story {
@@ -21,7 +21,7 @@ export default defineAgent({
   // Runs on a clock (09:00 & 17:00), not an event. No triggers needed.
   schedules: [{ name: 'scan', cron: '0 9,17 * * *', tz: 'America/New_York' }],
   handler: async (ctx, event) => {
-  if (event.source !== 'cron') return;
+  if (!isCronTickEvent(event)) return;
 
   const channel = input(ctx, 'SLACK_CHANNEL');
   if (!channel) throw new Error('SLACK_CHANNEL is required');

linear-slack/agent.ts

@@ -23,7 +23,7 @@
 import {
   defineAgent,
   type WorkforceCtx,
-  type WorkforceProviderEvent,
+  type WorkforceEvent,
 } from '@agentworkforce/runtime';
 import { linearClient, slackClient } from '@relayfile/relay-helpers';
 
@@ -115,16 +115,16 @@ export default defineAgent({
 
 export async function handleSlackEvent(
   ctx: WorkforceCtx,
-  event: WorkforceProviderEvent,
+  event: WorkforceEvent,
   slack: SlackClientLike,
   linear: LinearWriteClient,
 ): Promise<void> {
-  if (event.source !== 'slack') {
+  if (!event.type.startsWith('slack.')) {
     logSkip(ctx, event, 'non-slack event source');
     return;
   }
 
-  const msg = readSlackMessage(event.payload);
+  const msg = readSlackMessage((await event.expand('full')).data);
   if (!msg) {
     logSkip(ctx, event, 'unparseable slack payload');
     return;
@@ -412,7 +412,7 @@ function errorMessage(error: unknown): string {
 
 function logSkip(
   ctx: WorkforceCtx,
-  event: WorkforceProviderEvent,
+  event: WorkforceEvent,
   reason: string,
   attrs: Record<string, unknown> = {},
 ): void {

linear/agent.ts

@@ -8,7 +8,7 @@
 import {
   defineAgent,
   type WorkforceCtx,
-  type WorkforceProviderEvent,
+  type WorkforceEvent,
 } from '@agentworkforce/runtime';
 import { linearClient } from '@relayfile/relay-helpers';
 
@@ -73,36 +73,38 @@ export default defineAgent({
 
 export async function handleLinearEvent(
   ctx: WorkforceCtx,
-  event: WorkforceProviderEvent,
+  event: WorkforceEvent,
   linear: LinearClientLike,
 ): Promise<void> {
+  // v4: the provider payload is reached via expand (no sync `event.payload`).
+  const payload = (await event.expand('full')).data;
   ctx.log?.('info', 'linear event', {
     eventId: event.id,
     type: event.type,
-    payloadKeys: payloadKeys(event.payload),
-    recordKeys: payloadKeys(linearRecordPayload(event.payload)),
-    hasIssueId: Boolean(readIssueId(event.payload, event.type)),
-    hasSessionId: Boolean(readSessionId(event.payload)),
+    payloadKeys: payloadKeys(payload),
+    recordKeys: payloadKeys(linearRecordPayload(payload)),
+    hasIssueId: Boolean(readIssueId(payload, event.type)),
+    hasSessionId: Boolean(readSessionId(payload)),
   });
 
-  if (event.source !== 'linear') {
+  if (!event.type.startsWith('linear.')) {
     logSkip(ctx, event, 'non-linear event source');
     return;
   }
 
-  if (isOwnEvent(ctx, event)) {
+  if (isOwnEvent(ctx, event, payload)) {
     logSkip(ctx, event, 'own activity');
     return;
   }
 
-  const eventContext = linearEventContext(event);
+  const eventContext = linearEventContext(event, payload);
   if (!eventContext.issueId) {
     logSkip(ctx, event, 'missing issue id');
     return;
   }
 
   if (eventContext.fallbackComment) {
-    const mention = commentMentionsAgent(ctx, event.payload);
+    const mention = commentMentionsAgent(ctx, payload);
     if (!mention.matched) {
       logSkip(ctx, event, mention.reason, mention.attrs);
       return;
@@ -138,14 +140,16 @@ export async function handleLinearEvent(
   await rememberTurn(ctx, eventContext, 'assistant', intent.reply);
 }
 
-function linearEventContext(event: WorkforceProviderEvent): LinearEventContext {
-  const record = linearRecordPayload(event.payload) as Record<string, unknown>;
+function linearEventContext(event: WorkforceEvent, payload: unknown): LinearEventContext {
+  const record = linearRecordPayload(payload) as Record<string, unknown>;
   return {
     record,
-    issueId: readIssueId(event.payload, event.type),
-    sessionId: readSessionId(event.payload),
-    body: readPromptBody(event.payload),
-    fallbackComment: event.type === 'AppUserNotification.issueCommentMention' || event.type === 'comment.create',
+    issueId: readIssueId(payload, event.type),
+    sessionId: readSessionId(payload),
+    body: readPromptBody(payload),
+    fallbackComment:
+      event.type === 'linear.AppUserNotification.issueCommentMention' ||
+      event.type === 'linear.comment.create',
   };
 }
 
@@ -175,7 +179,7 @@ async function replyToLinear(
 
 async function classifyIntent(
   ctx: WorkforceCtx,
-  event: WorkforceProviderEvent,
+  event: WorkforceEvent,
   eventContext: LinearEventContext,
   issue: LinearIssue,
   history: string[],
@@ -219,7 +223,7 @@ function parseChatIntent(response: string, eventType: string, body: string): Cha
 }
 
 function inferIntent(eventType: string, body: string): ChatIntent['intent'] {
-  if (eventType === 'issue.create') return 'implement';
+  if (eventType === 'linear.issue.create') return 'implement';
   return /\b(implement|fix|ship|code|open\s+(?:a\s+)?pr|pull request)\b/iu.test(body)
     ? 'implement'
     : 'chat';
@@ -369,7 +373,7 @@ function readIssueId(payload: unknown, eventType?: string): string | undefined {
     p?.issueId ??
     p?.issue_id ??
     p?.issue?.id ??
-    (eventType === 'comment.create' ? undefined : p?.data?.id ?? rec?.id)
+    (eventType === 'linear.comment.create' ? undefined : p?.data?.id ?? rec?.id)
   );
 }
 
@@ -430,12 +434,12 @@ function commentBody(payload: unknown): string {
   );
 }
 
-function isOwnEvent(ctx: WorkforceCtx, event: WorkforceProviderEvent): boolean {
-  if (event.type === 'comment.create') {
-    return isOwnComment(ctx, event.payload);
+function isOwnEvent(ctx: WorkforceCtx, event: WorkforceEvent, payload: unknown): boolean {
+  if (event.type === 'linear.comment.create') {
+    return isOwnComment(ctx, payload);
   }
-  const rec = linearRecordPayload(event.payload) as { agentActivity?: unknown } | null;
-  return commentAuthorMatchesAgent(ctx, rec?.agentActivity ?? event.payload);
+  const rec = linearRecordPayload(payload) as { agentActivity?: unknown } | null;
+  return commentAuthorMatchesAgent(ctx, rec?.agentActivity ?? payload);
 }
 
 /** True if a comment event is the agent's own PR-link reply (loop guard). */
@@ -696,7 +700,7 @@ function asRecord(value: unknown): Record<string, unknown> | null {
 
 function logSkip(
   ctx: WorkforceCtx,
-  event: WorkforceProviderEvent,
+  event: WorkforceEvent,
   reason: string,
   attrs: Record<string, unknown> = {},
 ): void {