Apply workflow function transformation in "step" mode (#420)

Author: TooTallNate

.changeset/long-guests-enter.md

@@ -0,0 +1,5 @@
+---
+"@workflow/swc-plugin": patch
+---
+
+Apply workflow function transformation in "step" mode

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

@@ -1,7 +1,7 @@
 // Test anonymous default export workflow
 /**__internal_workflows{"workflows":{"input.js":{"default":{"workflowId":"workflow//input.js//__default"}}}}*/;
-export default async function() {
-    'use workflow';
-    const result = await someStep();
-    return result;
-}
+const __default = async function() {
+    throw new Error("You attempted to execute workflow __default function directly. To start a workflow, use start(__default) from workflow/api");
+};
+__default.workflowId = "workflow//input.js//__default";
+export default __default;

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

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

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

@@ -15,11 +15,6 @@ async function convertToLanguageModelPrompt({ prompt, supportedUrls, download =
     };
 }
 export async function myWorkflow(input) {
-    'use workflow';
-    const result = await convertToLanguageModelPrompt({
-        prompt: input.prompt,
-        supportedUrls: {},
-        download: undefined
-    });
-    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";

packages/swc-plugin-workflow/transform/tests/fixture/default-parameter-usage/output-step.js

@@ -3,9 +3,8 @@
 const __default = "existing variable";
 // Use it to avoid unused variable
 console.log(__default);
-// Anonymous default export should get unique name (__default$1)
-export default async function() {
-    'use workflow';
-    const result = await someStep();
-    return result;
-}
+const __default$1 = async function() {
+    throw new Error("You attempted to execute workflow __default$1 function directly. To start a workflow, use start(__default$1) from workflow/api");
+};
+__default$1.workflowId = "workflow//input.js//__default$1";
+export default __default$1;

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

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

packages/swc-plugin-workflow/transform/tests/fixture/expr-fn-default-workflow/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

@@ -1,14 +1,15 @@
 /**__internal_workflows{"workflows":{"input.js":{"arrowWorkflow":{"workflowId":"workflow//input.js//arrowWorkflow"},"workflow":{"workflowId":"workflow//input.js//workflow"}}}}*/;
-'use workflow';
 async function local(input) {
     return input.foo;
 }
 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";