fix(workflow): rollup transformer issue (#600)

* fix(workflow): rollup transformer issue

* chore: prettier

Author: twlite

apps/website/docs/guide/05-official-plugins/10-commandkit-workflow.mdx

@@ -117,6 +117,14 @@ export const chatInput: ChatInputCommand = async (ctx) => {
 };
 ```
 
+## Using custom Worlds
+
+You can use any world providers from
+[useworkflow.dev/worlds](https://useworkflow.dev/worlds) or create
+your own custom world. Refer to the
+[Building a World](https://useworkflow.dev/docs/deploying/building-a-world)
+documentation for more details.
+
 ## Project structure
 
 Organize your workflows and steps in a clear structure:

packages/workflow/README.md

@@ -67,6 +67,10 @@ export const chatInput: ChatInputCommand = async (ctx) => {
 }
 ```
 
+## Using custom Worlds
+
+You can use any world providers from [useworkflow.dev/worlds](https://useworkflow.dev/worlds) or create your own custom world. Refer to the [Building a World](https://useworkflow.dev/docs/deploying/building-a-world) documentation for more details.
+
 ## Documentation
 https://commandkit.dev/docs/next/api-reference/workflow
 

packages/workflow/package.json

@@ -49,6 +49,7 @@
   "dependencies": {
     "@hono/node-server": "^1.19.6",
     "@workflow/builders": "catalog:workflow",
+    "@workflow/rollup": "catalog:workflow",
     "hono": "^4.10.4"
   }
 }

packages/workflow/src/compiler-plugin.ts

@@ -7,10 +7,19 @@ import {
   TransformedResult,
 } from 'commandkit';
 import { LocalBuilder } from './builder.js';
-import { workflowRollupPlugin } from 'workflow/rollup';
+import { workflowTransformPlugin as workflowRollupPlugin } from '@workflow/rollup';
+
+const USE_WORKFLOW_DIRECTIVE = 'use workflow';
+const USE_STEP_DIRECTIVE = 'use step';
 
 export interface WorkflowCompilerPluginOptions {}
 
+const shouldTransform = (code: string): boolean => {
+  return (
+    code.includes(USE_WORKFLOW_DIRECTIVE) || code.includes(USE_STEP_DIRECTIVE)
+  );
+};
+
 export class WorkflowCompilerPlugin extends CompilerPlugin<WorkflowCompilerPluginOptions> {
   public readonly name = 'WorkflowCompilerPlugin';
   private builder: LocalBuilder | null = null;
@@ -33,7 +42,19 @@ export class WorkflowCompilerPlugin extends CompilerPlugin<WorkflowCompilerPlugi
   public async transform(
     params: PluginTransformParameters,
   ): Promise<MaybeFalsey<TransformedResult>> {
-    if (!/(use workflow)|(use step)/.test(params.code)) return;
-    return this.workflowRollupPlugin?.transform(params.code, params.id);
+    if (!shouldTransform(params.code)) return;
+    if (typeof this.workflowRollupPlugin?.transform !== 'function') return;
+    // @ts-ignore mismatched types
+    const result = await this.workflowRollupPlugin.transform(
+      params.code,
+      params.id,
+    );
+
+    if (!result) return null;
+    if (typeof result === 'string') return { code: result };
+    return {
+      code: result.code,
+      map: typeof result.map === 'string' ? result.map : null,
+    };
   }
 }

packages/workflow/src/handler.ts

@@ -1,7 +1,7 @@
 /* eslint-disable */
 // @ts-nocheck
 import { Hono } from 'hono';
-import { serve } from '@hono/node-server';
+import { serve as nodeServe } from '@hono/node-server';
 import { POST as WebhookPOST } from '{{webhookPath}}';
 import { POST as StepPOST } from '{{stepsPath}}';
 import { POST as FlowPOST } from '{{workflowPath}}';
@@ -24,7 +24,16 @@ if (!port || isNaN(Number(port))) {
   );
 }
 
-serve({
-  fetch: app.fetch,
-  port: Number(port),
-});
+if (typeof Deno !== 'undefined') {
+  Deno.serve({ port: Number(port) }, app.fetch);
+} else if (typeof Bun !== 'undefined') {
+  Bun.serve({
+    fetch: app.fetch,
+    port: Number(port),
+  });
+} else {
+  nodeServe({
+    fetch: app.fetch,
+    port: Number(port),
+  });
+}