Merge branch 'main' of github.com:karthikscale3/workflow into karthik/improve-dashboard

Author: karthikscale3

.changeset/bitter-ads-hear.md

@@ -0,0 +1,5 @@
+---
+"@workflow/world-vercel": patch
+---
+
+Make queue() call backwardscompatible with zod v3 for codebases that pin zod

.changeset/eleven-roses-enter.md

@@ -0,0 +1,5 @@
+---
+"@workflow/ai": patch
+---
+
+Make `DurableAgent#stream()` return a `messages` array

.changeset/pre.json

@@ -42,6 +42,7 @@
     "all-years-glow",
     "angry-owls-beg",
     "bigint-serialization",
+    "bitter-ads-hear",
     "bitter-trees-rest",
     "breezy-schools-wonder",
     "bumpy-taxis-learn",
@@ -73,6 +74,7 @@
     "easy-donkeys-lie",
     "eight-clowns-own",
     "eight-clubs-refuse",
+    "eleven-roses-enter",
     "evil-mammals-hear",
     "extract-path-helpers",
     "extract-queue-triggers",
@@ -139,10 +141,12 @@
     "real-moose-kick",
     "real-oranges-lick",
     "red-cities-poke",
+    "red-ears-smoke",
     "rude-wings-brush",
     "serious-starfishes-accept",
     "shaggy-falcons-make",
     "shaggy-tigers-attack",
+    "shiny-islands-move",
     "silly-pens-shine",
     "silver-boats-fold",
     "sixty-baboons-wonder",
@@ -182,6 +186,7 @@
     "twenty-gifts-win",
     "two-cooks-unite",
     "two-rabbits-burn",
+    "two-snails-cross",
     "violet-mails-send",
     "violet-taxis-give",
     "warm-files-attack",

.changeset/red-ears-smoke.md

@@ -0,0 +1,6 @@
+---
+"@workflow/world-local": patch
+"@workflow/utils": patch
+---
+
+Fix port detection and base URL resolution for dev servers

.changeset/shiny-islands-move.md

@@ -0,0 +1,5 @@
+---
+"@workflow/world-vercel": patch
+---
+
+Log warning when detecting zod v3

.changeset/two-snails-cross.md

@@ -0,0 +1,5 @@
+---
+"@workflow/ai": patch
+---
+
+Add `onStepFinish` callback to `DurableAgent#stream()`

.gitattributes

@@ -0,0 +1,4 @@
+# Ensure consistent line endings for test input/output files
+# Use LF for all test files to ensure cross-platform consistency
+packages/swc-plugin-workflow/transform/tests/**/*.js text eol=lf
+packages/swc-plugin-workflow/transform/tests/**/*.stderr text eol=lf

.github/workflows/tests.yml

@@ -188,7 +188,7 @@ jobs:
         run: ./scripts/resolve-symlinks.sh workbench/${{ matrix.app.name }}
 
       - name: Run E2E Tests
-        run: cd workbench/${{ matrix.app.name }} && pnpm dev & echo "starting tests in 10 seconds" && sleep 10 && pnpm vitest run packages/core/e2e/dev.test.ts && pnpm run test:e2e
+        run: cd workbench/${{ matrix.app.name }} && pnpm dev & echo "starting tests in 10 seconds" && sleep 10 && pnpm vitest run packages/core/e2e/dev.test.ts && sleep 10 && pnpm run test:e2e
         env:
           APP_NAME: ${{ matrix.app.name }}
           DEPLOYMENT_URL: "http://localhost:${{ matrix.app.name == 'sveltekit' && '5173' || '3000' }}"

docs/content/docs/api-reference/workflow-ai/durable-agent.mdx

@@ -86,6 +86,7 @@ export default DurableAgentStreamOptions;`}
 - Tools can be implemented as workflow steps (using `"use step"` for automatic retries), or as regular workflow-level logic
 - Tools can use core library features like `sleep()` and Hooks within their `execute` functions
 - The agent processes tool calls iteratively until completion
+- The `stream()` method returns `{ messages }` containing the full conversation history, including initial messages, assistant responses, and tool results
 
 ## Examples
 
@@ -180,6 +181,58 @@ async function multiToolAgentWorkflow(userQuery: string) {
 }
 ```
 
+### Multi-turn Conversation
+
+```typescript
+import { DurableAgent } from '@workflow/ai/agent';
+import { z } from 'zod';
+
+async function searchProducts({ query }: { query: string }) {
+  "use step";
+  // Search product database
+  return `Found 3 products matching "${query}"`;
+}
+
+async function multiTurnAgentWorkflow() {
+  'use workflow';
+
+  const agent = new DurableAgent({
+    model: 'anthropic/claude-haiku-4.5',
+    tools: {
+      searchProducts: {
+        description: 'Search for products',
+        inputSchema: z.object({ query: z.string() }),
+        execute: searchProducts,
+      },
+    },
+  });
+
+  const writable = getWritable<UIMessageChunk>();
+
+  // First user message
+  //   - Result is streamed to the provided `writable` stream
+  //   - Message history is returned in `messages` for LLM context
+  let { messages } = await agent.stream({
+    messages: [
+      { role: 'user', content: 'Find me some laptops' }
+    ],
+    writable,
+  });
+
+  // Continue the conversation with the accumulated message history
+  const result = await agent.stream({
+    messages: [
+      ...messages,
+      { role: 'user', content: 'Which one has the best battery life?' }
+    ],
+    writable,
+  });
+
+  // result.messages now contains the complete conversation history
+  return result.messages;
+}
+```
+
 ### Tools with Workflow Library Features
 
 ```typescript

packages/ai/CHANGELOG.md

@@ -1,5 +1,19 @@
 # @workflow/ai
 
+## 4.0.1-beta.21
+
+### Patch Changes
+
+- aba5264: Add `onStepFinish` callback to `DurableAgent#stream()`
+  - [email protected]
+
+## 4.0.1-beta.20
+
+### Patch Changes
+
+- 00e3345: Make `DurableAgent#stream()` return a `messages` array
+  - [email protected]
+
 ## 4.0.1-beta.19
 
 ### Patch Changes