.

Author: TooTallNate

packages/swc-plugin-workflow/transform/src/lib.rs

@@ -22,7 +22,7 @@ export async function validStep() {
     return 42;
 }
 export const validWorkflow = async ()=>{
-    'use workflow';
-    return 'test';
+    throw new Error("You attempted to execute workflow validWorkflow function directly. To start a workflow, use start(validWorkflow) from workflow/api");
 };
+validWorkflow.workflowId = "workflow//input.js//validWorkflow";
 registerStepFunction("step//input.js//validStep", validStep);

packages/swc-plugin-workflow/transform/tests/errors/non-async-functions/output-step.js

@@ -7,11 +7,9 @@ async function stepFunctionWithoutExport(a, b) {
     return a - b;
 }
 export async function workflowFunction(a, b) {
-    'use workflow';
-    const result = await stepFunction(a, b);
-    const result2 = await stepFunctionWithoutExport(a, b);
-    return result + result2;
+    throw new Error("You attempted to execute workflow workflowFunction function directly. To start a workflow, use start(workflowFunction) from workflow/api");
 }
+workflowFunction.workflowId = "workflow//input.js//workflowFunction";
 export async function normalFunction(a, b) {
     return a * b;
 }

packages/swc-plugin-workflow/transform/tests/fixture/mixed-functions/output-step.js

@@ -7,8 +7,10 @@ const localArrow = async (input)=>{
     return input.bar;
 };
 export async function workflow(input) {
-    return input.foo;
+    throw new Error("You attempted to execute workflow workflow function directly. To start a workflow, use start(workflow) from workflow/api");
 }
+workflow.workflowId = "workflow//input.js//workflow";
 export const arrowWorkflow = async (input)=>{
-    return input.bar;
+    throw new Error("You attempted to execute workflow arrowWorkflow function directly. To start a workflow, use start(arrowWorkflow) from workflow/api");
 };
+arrowWorkflow.workflowId = "workflow//input.js//arrowWorkflow";

packages/swc-plugin-workflow/transform/tests/fixture/module-level-workflow/output-step.js

@@ -11,25 +11,9 @@ var helpers$objectStep = async (x, y)=>{
     return x + y + 10;
 };
 export async function example(a, b) {
-    "use workflow";
-    const step = example$step;
-    // Arrow function with const
-    const arrowStep = example$arrowStep;
-    // Arrow function with let
-    let letArrowStep = example$letArrowStep;
-    // Arrow function with var
-    var varArrowStep = example$varArrowStep;
-    // Object with step method
-    const helpers = {
-        objectStep: helpers$objectStep
-    };
-    const val = await step(a, b);
-    const val2 = await arrowStep(a, b);
-    const val3 = await letArrowStep(a, b);
-    const val4 = await varArrowStep(a, b);
-    const val5 = await helpers.objectStep(a, b);
-    return val + val2 + val3 + val4 + val5;
+    throw new Error("You attempted to execute workflow example function directly. To start a workflow, use start(example) from workflow/api");
 }
+example.workflowId = "workflow//input.js//example";
 registerStepFunction("step//input.js//example/step", example$step);
 registerStepFunction("step//input.js//example/arrowStep", example$arrowStep);
 registerStepFunction("step//input.js//example/letArrowStep", example$letArrowStep);

packages/swc-plugin-workflow/transform/tests/fixture/nested-step-in-workflow/output-step.js

@@ -80,23 +80,9 @@ const arrowWrapperReturnNamedFunctionVar = (a, b, c)=>{
     return fn;
 };
 export async function wflow() {
-    'use workflow';
-    let count = 42;
-    const namedStepWithClosureVars = wflow$namedStepWithClosureVars;
-    const agent = new DurableAgent({
-        arrowFunctionWithClosureVars: _anonymousStep2,
-        namedFunctionWithClosureVars: _anonymousStep3,
-        methodWithClosureVars: _anonymousStep4
-    });
-    await stepWrapperReturnArrowFunctionVar(1, 2, 3)();
-    await stepWrapperReturnNamedFunction(1, 2, 3)();
-    await stepWrapperReturnArrowFunction(1, 2, 3)();
-    await stepWrapperReturnNamedFunctionVar(1, 2, 3)();
-    await arrowWrapperReturnArrowFunctionVar(1, 2, 3)();
-    await arrowWrapperReturnNamedFunction(1, 2, 3)();
-    await arrowWrapperReturnArrowFunction(1, 2, 3)();
-    await arrowWrapperReturnNamedFunctionVar(1, 2, 3)();
+    throw new Error("You attempted to execute workflow wflow function directly. To start a workflow, use start(wflow) from workflow/api");
 }
+wflow.workflowId = "workflow//input.js//wflow";
 registerStepFunction("step//input.js//stepWrapperReturnArrowFunctionVar/fn", stepWrapperReturnArrowFunctionVar$fn);
 registerStepFunction("step//input.js//stepWrapperReturnNamedFunction/f", stepWrapperReturnNamedFunction$f);
 registerStepFunction("step//input.js//stepWrapperReturnArrowFunction/_anonymousStep0", stepWrapperReturnArrowFunction$_anonymousStep0);

packages/swc-plugin-workflow/transform/tests/fixture/nested-step-with-closure/output-step.js

@@ -6,27 +6,8 @@ import * as z from 'zod';
 var test$_anonymousStep0 = async ()=>gateway('openai/gpt-5');
 var test$_anonymousStep1 = async ({ location })=>`Weather in ${location}: Sunny, 72°F`;
 export async function test() {
-    'use workflow';
-    const agent = new DurableAgent({
-        model: _anonymousStep0,
-        tools: {
-            getWeather: tool({
-                description: 'Get weather for a location',
-                inputSchema: z.object({
-                    location: z.string()
-                }),
-                execute: _anonymousStep1
-            })
-        }
-    });
-    await agent.stream({
-        messages: [
-            {
-                role: 'user',
-                content: 'What is the weather in San Francisco?'
-            }
-        ]
-    });
+    throw new Error("You attempted to execute workflow test function directly. To start a workflow, use start(test) from workflow/api");
 }
+test.workflowId = "workflow//input.js//test";
 registerStepFunction("step//input.js//test/_anonymousStep0", test$_anonymousStep0);
 registerStepFunction("step//input.js//test/_anonymousStep1", test$_anonymousStep1);

packages/swc-plugin-workflow/transform/tests/fixture/nested-steps-in-object-constructor/output-step.js

@@ -1,5 +1,5 @@
 /**__internal_workflows{"workflows":{"input.js":{"workflow":{"workflowId":"workflow//input.js//workflow"}}}}*/;
 export async function workflow(a, b) {
-    'use workflow';
-    return add(a, b);
+    throw new Error("You attempted to execute workflow workflow function directly. To start a workflow, use start(workflow) from workflow/api");
 }
+workflow.workflowId = "workflow//input.js//workflow";

packages/swc-plugin-workflow/transform/tests/fixture/single-workflow/output-step.js

@@ -1,5 +1,5 @@
 /**__internal_workflows{"workflows":{"input.js":{"processData":{"workflowId":"workflow//input.js//processData"}}}}*/;
 export const processData = async (data)=>{
-    'use workflow';
-    return data.processed;
+    throw new Error("You attempted to execute workflow processData function directly. To start a workflow, use start(processData) from workflow/api");
 };
+processData.workflowId = "workflow//input.js//processData";

packages/swc-plugin-workflow/transform/tests/fixture/workflow-arrow-function/output-step.js

@@ -1,24 +1,23 @@
 // Test workflow functions in client mode
 /**__internal_workflows{"workflows":{"input.js":{"arrowWorkflow":{"workflowId":"workflow//input.js//arrowWorkflow"},"default":{"workflowId":"workflow//input.js//defaultWorkflow"},"internalWorkflow":{"workflowId":"workflow//input.js//internalWorkflow"},"myWorkflow":{"workflowId":"workflow//input.js//myWorkflow"}}}}*/;
 export async function myWorkflow() {
-    'use workflow';
-    const result = await someStep();
-    return result;
+    throw new Error("You attempted to execute workflow myWorkflow function directly. To start a workflow, use start(myWorkflow) from workflow/api");
 }
+myWorkflow.workflowId = "workflow//input.js//myWorkflow";
 export const arrowWorkflow = async ()=>{
-    'use workflow';
-    const data = await fetchData();
-    return data;
+    throw new Error("You attempted to execute workflow arrowWorkflow function directly. To start a workflow, use start(arrowWorkflow) from workflow/api");
 };
+arrowWorkflow.workflowId = "workflow//input.js//arrowWorkflow";
 export default async function defaultWorkflow() {
     'use workflow';
     return await process();
 }
+defaultWorkflow.workflowId = "workflow//input.js//defaultWorkflow";
 // Non-export workflow function
 async function internalWorkflow() {
-    'use workflow';
-    return 'internal';
+    throw new Error("You attempted to execute workflow internalWorkflow function directly. To start a workflow, use start(internalWorkflow) from workflow/api");
 }
+internalWorkflow.workflowId = "workflow//input.js//internalWorkflow";
 // Use the internal workflow to avoid lint warning
 regularFunction(internalWorkflow);
 // Regular function should not be affected