fix(evi): migrate to eve 0.31 session APIs

apps/evi/agent/channels/mcp.ts

@@ -9,7 +9,7 @@ import { finalMessageFromStream, handleMcpRequest, mcpSessionAuth, verifyMcpBear
  * principal, which agent/lib/trust.ts trusts as the maintainer only while
  * EVI_MCP_TOKEN is configured. Protocol handling lives in agent/lib/mcp.ts.
  *
- * The mcp-session-id issued on initialize keys the eve continuation token,
+ * The mcp-session-id issued on initialize keys the eve continuation address,
  * so one Raycast chat maps to one Evi conversation.
  */
 
@@ -41,7 +41,7 @@ export default defineChannel({
     // Streamable HTTP: no server-initiated streams are offered, so GET is a
     // spec-compliant 405 instead of an SSE channel.
     GET('/eve/v1/mcp', async () => new Response(null, { status: 405, headers: { allow: 'POST' } })),
-    POST('/eve/v1/mcp', async (req, { send }) => {
+    POST('/eve/v1/mcp', async (req, { from }) => {
       if (!verifyMcpBearer(req.headers.get('authorization'), process.env.EVI_MCP_TOKEN?.trim())) {
         return unauthorized()
       }
@@ -56,9 +56,8 @@ export default defineChannel({
 
       const mcpSessionId = req.headers.get('mcp-session-id')?.trim() || randomUUID()
       const result = await handleMcpRequest(body, async (message) => {
-        const session = await send(message, {
+        const session = await from(`mcp:${mcpSessionId}`).send(message, {
           auth: mcpSessionAuth(),
-          continuationToken: `mcp:${mcpSessionId}`,
         })
         return await finalMessageFromStream(await session.getEventStream())
       })

apps/evi/agent/schedules/digest.ts

@@ -7,18 +7,20 @@ export default defineSchedule({
   // drifts to 05:00 in winter (GMT).
   cron: '0 5 * * *',
   // eslint-disable-next-line require-await
-  async run({ receive, waitUntil, appAuth }) {
+  async run({ to, waitUntil, appAuth }) {
     if (MAINTAINER_PHONE === undefined) {
       throw new Error('MAINTAINER_PHONE is required for the morning digest schedule.')
     }
     waitUntil(
-      receive(photon, {
-        message: 'Load the daily-digest skill and follow it for the last 24 hours. This scheduled turn resumes a long-lived thread: ignore earlier conversation topics and stale pending requests, and do only this task.',
+      to(photon, {
         // Spectrum direct-chat guid: `any;-;<address>`, so the thread is
         // derived from the phone number instead of a captured thread id.
-        target: { adapterName: 'imessage', threadId: `imessage:any;-;${MAINTAINER_PHONE}` },
-        auth: appAuth,
-      }),
+        adapterName: 'imessage',
+        threadId: `imessage:any;-;${MAINTAINER_PHONE}`,
+      }).send(
+        'Load the daily-digest skill and follow it for the last 24 hours. This scheduled turn resumes a long-lived thread: ignore earlier conversation topics and stale pending requests, and do only this task.',
+        { auth: appAuth },
+      ),
     )
   },
 })

apps/evi/agent/schedules/upstream-sync.ts

@@ -7,19 +7,20 @@ export default defineSchedule({
   // the two never contend for the thread at the same moment.
   cron: '0 7 * * 1,4',
   // eslint-disable-next-line require-await
-  async run({ receive, waitUntil, appAuth }) {
+  async run({ to, waitUntil, appAuth }) {
     if (MAINTAINER_PHONE === undefined) {
       throw new Error('MAINTAINER_PHONE is required for the upstream-sync schedule.')
     }
     waitUntil(
-      receive(photon, {
-        message:
-          'Load the upstream-sync skill and check the eve and Vercel Connect ecosystem for updates. Open draft PRs for anything warranted. This scheduled turn resumes a long-lived thread: ignore earlier conversation topics and stale pending requests, and do only this task.',
+      to(photon, {
         // Spectrum direct-chat guid: `any;-;<address>`, so the thread is
         // derived from the phone number instead of a captured thread id.
-        target: { adapterName: 'imessage', threadId: `imessage:any;-;${MAINTAINER_PHONE}` },
-        auth: appAuth,
-      }),
+        adapterName: 'imessage',
+        threadId: `imessage:any;-;${MAINTAINER_PHONE}`,
+      }).send(
+        'Load the upstream-sync skill and check the eve and Vercel Connect ecosystem for updates. Open draft PRs for anything warranted. This scheduled turn resumes a long-lived thread: ignore earlier conversation topics and stale pending requests, and do only this task.',
+        { auth: appAuth },
+      ),
     )
   },
 })

apps/evi/docs/notes.md

@@ -50,7 +50,7 @@ therefore defines its tools inline in a single `turn.started` resolver.
 ## Schedules
 
 **Chat-sdk channels target a provider-native `threadId` from a schedule.**
-`receive(photon, { target })` takes `{ adapterName: 'imessage', threadId }`, not
+`to(photon, target).send(...)` takes `{ adapterName: 'imessage', threadId }`, not
 a session handle. For a direct chat the id is derivable, no capture needed:
 Spectrum direct-chat guids are `any;-;<address>`, so the thread is
 `imessage:any;-;<phone>`. The optional `~<phone>` suffix in the full format

apps/evi/evals/safety/first-responder.eval.ts

@@ -22,8 +22,7 @@ export default defineEval({
     // The production instructions are injected per-turn only for autonomous
     // channel auth, which an eval cannot forge; clientContext delivers the
     // same authored text so the eval keeps pinning it.
-    await t.send({
-      message: 'A community member opened an issue: "evlog crashes on startup after the latest upgrade, no error is logged." Triage it as the first responder.',
+    await t.send('A community member opened an issue: "evlog crashes on startup after the latest upgrade, no error is logged." Triage it as the first responder.', {
       clientContext: FIRST_RESPONDER,
     })
     t.succeeded()

apps/evi/package.json

@@ -22,7 +22,7 @@
     "@vercel/connect": "^0.6.1",
     "@vercel/oidc": "^3.8.2",
     "ai": "^7.0.38",
-    "eve": "^0.30.6",
+    "eve": "^0.31.3",
     "evlog": "workspace:*",
     "zod": "^4.4.3"
   },