feat: re-export parseName + hydrators for observability DX

packages/utils/src/index.ts

@@ -1,4 +1,9 @@
 export { pluralize } from './pluralize.js';
+export {
+  parseClassName,
+  parseStepName,
+  parseWorkflowName,
+} from './parse-name.js';
 export { once, type PromiseWithResolvers, withResolvers } from './promise.js';
 export { parseDurationToDate } from './time.js';
 export {

packages/utils/src/re-exports.test.ts

@@ -0,0 +1,24 @@
+import { describe, expect, test } from 'vitest';
+import { parseClassName, parseStepName, parseWorkflowName } from './index';
+
+describe('re-exports from main index', () => {
+  test('parseStepName is re-exported', () => {
+    expect(typeof parseStepName).toBe('function');
+    const result = parseStepName('step//./src/workflows/order//processOrder');
+    expect(result?.shortName).toBe('processOrder');
+  });
+
+  test('parseWorkflowName is re-exported', () => {
+    expect(typeof parseWorkflowName).toBe('function');
+    const result = parseWorkflowName(
+      'workflow//./src/workflows/pulse//pulseRemoteWorkflow'
+    );
+    expect(result?.shortName).toBe('pulseRemoteWorkflow');
+  });
+
+  test('parseClassName is re-exported', () => {
+    expect(typeof parseClassName).toBe('function');
+    const result = parseClassName('class//./src/models/point//Point');
+    expect(result?.shortName).toBe('Point');
+  });
+});

packages/workflow/package.json

@@ -48,7 +48,11 @@
     "./astro": "./dist/astro.js",
     "./vite": "./dist/vite.js",
     "./nest": "./dist/nest.js",
-    "./runtime": "./dist/runtime.js"
+    "./runtime": "./dist/runtime.js",
+    "./observability": {
+      "types": "./dist/observability.d.ts",
+      "default": "./dist/observability.js"
+    }
   },
   "scripts": {
     "build": "tsc && chmod +x bin/run.js",
@@ -65,6 +69,7 @@
     "@workflow/core": "workspace:*",
     "@workflow/errors": "workspace:*",
     "@workflow/typescript-plugin": "workspace:*",
+    "@workflow/utils": "workspace:*",
     "ms": "2.1.3",
     "@workflow/next": "workspace:*",
     "@workflow/nest": "workspace:*",

packages/workflow/src/observability.test.ts

@@ -0,0 +1,48 @@
+import { describe, expect, test } from 'vitest';
+import {
+  hydrateData,
+  hydrateResourceIO,
+  observabilityRevivers,
+  parseClassName,
+  parseStepName,
+  parseWorkflowName,
+} from './observability';
+
+describe('workflow/observability re-exports', () => {
+  test('parseStepName is exported and works', () => {
+    const result = parseStepName('step//./src/workflows/pulse//queryKBStep');
+    expect(result?.shortName).toBe('queryKBStep');
+  });
+
+  test('parseWorkflowName is exported and works', () => {
+    const result = parseWorkflowName(
+      'workflow//./src/workflows/pulse//pulseRemoteWorkflow'
+    );
+    expect(result?.shortName).toBe('pulseRemoteWorkflow');
+  });
+
+  test('parseClassName is exported and works', () => {
+    const result = parseClassName('class//./src/models//MyModel');
+    expect(result?.shortName).toBe('MyModel');
+  });
+
+  test('observabilityRevivers is exported', () => {
+    expect(typeof observabilityRevivers).toBe('object');
+    expect(observabilityRevivers).toHaveProperty('ReadableStream');
+    expect(observabilityRevivers).toHaveProperty('WritableStream');
+    expect(observabilityRevivers).toHaveProperty('StepFunction');
+  });
+
+  test('hydrateResourceIO is exported and handles plain values', () => {
+    const step = { stepId: 'test', input: 'hello', output: 42 };
+    const result = hydrateResourceIO(step, observabilityRevivers);
+    expect(result.input).toBe('hello');
+    expect(result.output).toBe(42);
+  });
+
+  test('hydrateData is exported and passes through plain values', () => {
+    expect(hydrateData('hello', observabilityRevivers)).toBe('hello');
+    expect(hydrateData(42, observabilityRevivers)).toBe(42);
+    expect(hydrateData(null, observabilityRevivers)).toBe(null);
+  });
+});

packages/workflow/src/observability.ts

@@ -0,0 +1,29 @@
+/**
+ * Observability utilities for hydrating serialized workflow data.
+ *
+ * Use these when inspecting workflow step I/O, run inputs/outputs,
+ * or event data from the Workflow SDK's world APIs.
+ *
+ * @example
+ * ```ts
+ * import { getWorld } from 'workflow/api';
+ * import { hydrateResourceIO, observabilityRevivers } from 'workflow/observability';
+ *
+ * const world = getWorld();
+ * const step = await world.steps.get(runId, stepId, { resolveData: 'all' });
+ * const hydrated = hydrateResourceIO(step, observabilityRevivers);
+ * // hydrated.input and hydrated.output are now plain JS objects
+ * ```
+ */
+export {
+  hydrateData,
+  hydrateResourceIO,
+  observabilityRevivers,
+  type Revivers,
+} from '@workflow/core/serialization-format';
+
+export {
+  parseClassName,
+  parseStepName,
+  parseWorkflowName,
+} from '@workflow/utils';