Fix hydration of events with dates and of step functions

.changeset/eight-clowns-own.md

@@ -0,0 +1,6 @@
+---
+"@workflow/web-shared": patch
+"@workflow/core": patch
+---
+
+Fix hydration of eventData for sleep calls

packages/core/src/observability.ts

@@ -41,6 +41,7 @@ const streamPrintRevivers: Record<string, (value: any) => any> = {
   ReadableStream: streamToStreamId,
   WritableStream: streamToStreamId,
   TransformStream: streamToStreamId,
+  StepFunction: (value) => `<fn:${value}>`,
 };
 
 const hydrateStepIO = <
@@ -109,7 +110,7 @@ const hydrateEventData = <
       Object.entries(event.eventData).map(([key, value]) => [
         key,
         hydrateStepArguments(
-          value as any,
+          [value] as any,
           [],
           event.runId as string,
           globalThis,

packages/web-shared/src/api/workflow-server-actions.ts

@@ -134,7 +134,15 @@ function getUserFacingMessage(error: Error): string {
   return error.message || 'An unexpected error occurred';
 }
 
+const toJSONCompatible = <T>(data: T): T => {
+  if (data && typeof data === 'object') {
+    return JSON.parse(JSON.stringify(data)) as T;
+  }
+  return data;
+};
+
 const hydrate = <T>(data: T): T => {
+  data = toJSONCompatible(data);
   try {
     return hydrateResourceIO(data as any) as T;
   } catch (error) {
@@ -148,16 +156,7 @@ const hydrate = <T>(data: T): T => {
  * @returns ServerActionResult with success=true and the data
  */
 function createResponse<T>(data: T): ServerActionResult<T> {
-  if (data && typeof data === 'object') {
-    // We can't pass non-serializable objects from client to server. To ensure
-    // we don't accidentally do this, we convert the object to JSON.
-    try {
-      data = JSON.parse(JSON.stringify(data)) as T;
-    } catch {
-      // If we can't serialize the data, we'll leave it to the API layer to
-      // throw an error if the data isn't transportable.
-    }
-  }
+  data = toJSONCompatible(data);
   return {
     success: true,
     data,

workbench/nitro-v2/server/api/trigger.post.ts

@@ -1,7 +1,7 @@
 import { defineEventHandler, getRequestURL, readRawBody } from 'h3';
 import { start } from 'workflow/api';
 import { hydrateWorkflowArguments } from 'workflow/internal/serialization';
-import { allWorkflows } from '../_workflows.js';
+import { allWorkflows } from '../../_workflows.js';
 
 export default defineEventHandler(async (event) => {
   const url = getRequestURL(event);