World postgres - queue driver

.changeset/kind-suns-wonder.md

@@ -0,0 +1,9 @@
+---
+"@workflow/world-postgres": patch
+"@workflow/sveltekit": patch
+"@workflow/builders": patch
+---
+
+- export stepEntrypoint and workflowEntrypoint from build
+- add abstract queue driver to world postgres
+- add execution strategy to world postgres

packages/builders/src/base-builder.ts

@@ -320,11 +320,13 @@ export abstract class BaseBuilder {
 
     const entryContent = `
     // Built in steps
+    import { stepEntrypoint } from 'workflow/runtime';
     import '${builtInSteps}';
     // User steps
     ${imports}
     // API entrypoint
-    export { stepEntrypoint as POST } from 'workflow/runtime';`;
+    export const __wkf_entrypoint = stepEntrypoint;
+    export const POST = stepEntrypoint;`;
 
     // Bundle with esbuild and our custom SWC plugin
     const esbuildCtx = await esbuild.context({
@@ -549,8 +551,8 @@ export abstract class BaseBuilder {
 import { workflowEntrypoint } from 'workflow/runtime';
 
 const workflowCode = \`${workflowBundleCode.replace(/[\\`$]/g, '\\$&')}\`;
-
-export const POST = workflowEntrypoint(workflowCode);`;
+export const __wkf_entrypoint = workflowEntrypoint(workflowCode);
+export const POST = __wkf_entrypoint`;
 
       // we skip the final bundling step for Next.js so it can bundle itself
       if (!bundleFinalOutput) {

packages/sveltekit/src/builder.ts

@@ -92,7 +92,7 @@ export class SvelteKitBuilder extends BaseBuilder {
 
     // Replace the default export with SvelteKit-compatible handler
     stepsRouteContent = stepsRouteContent.replace(
-      /export\s*\{\s*stepEntrypoint\s+as\s+POST\s*\}\s*;?$/m,
+      /export\s*const\s*POST\s*=\s*stepEntrypoint\s*;$/m,
       `${SVELTEKIT_REQUEST_CONVERTER}
 export const POST = async ({request}) => {
   const normalRequest = await convertSvelteKitRequest(request);
@@ -133,11 +133,11 @@ export const POST = async ({request}) => {
 
     // Replace the default export with SvelteKit-compatible handler
     workflowsRouteContent = workflowsRouteContent.replace(
-      /export const POST = workflowEntrypoint\(workflowCode\);?$/m,
+      /export\s*const\s*POST\s*=\s*__wkf_entrypoint\s*;?$/m,
       `${SVELTEKIT_REQUEST_CONVERTER}
 export const POST = async ({request}) => {
   const normalRequest = await convertSvelteKitRequest(request);
-  return workflowEntrypoint(workflowCode)(normalRequest);
+  return __wkf_entrypoint(normalRequest);
 }`
     );
     await writeFile(workflowsRouteFile, workflowsRouteContent);