add getUrl method to local world and vercel world

Author: adriandlam

packages/core/src/runtime.ts

@@ -585,11 +585,7 @@ export const stepEntrypoint =
                 workflowMetadata: {
                   workflowRunId,
                   workflowStartedAt: new Date(+workflowStartedAt),
-                  // TODO: there should be a getUrl method on the world interface itself. This
-                  // solution only works for vercel + embedded worlds.
-                  url: process.env.VERCEL_URL
-                    ? `https://${process.env.VERCEL_URL}`
-                    : `http://localhost:${process.env.PORT || 3000}`,
+                  url: world.getUrl(),
                 },
               },
               () => stepFn(...args)

packages/world-local/src/queue.ts

@@ -143,5 +143,9 @@ export function createQueue(port?: number): Queue {
     return 'dpl_embedded';
   };
 
-  return { queue, createQueueHandler, getDeploymentId };
+  const getUrl: Queue['getUrl'] = () => {
+    return `http://localhost:${port}`;
+  };
+
+  return { queue, createQueueHandler, getDeploymentId, getUrl };
 }

packages/world-postgres/src/queue.ts

@@ -113,7 +113,13 @@ export function createQueue(
     }
   }
 
+  // TODO: Stub for now, need to implement url.
+  const getUrl: Queue['getUrl'] = () => {
+    return embeddedWorld.getUrl();
+  };
+
   return {
+    getUrl,
     createQueueHandler,
     getDeploymentId,
     queue,

packages/world-vercel/src/queue.ts

@@ -46,5 +46,9 @@ export function createQueue(): Queue {
     return deploymentId;
   };
 
-  return { queue, createQueueHandler, getDeploymentId };
+  const getUrl: Queue['getUrl'] = () => {
+    return `https://${process.env.VERCEL_URL}`;
+  };
+
+  return { queue, createQueueHandler, getDeploymentId, getUrl };
 }

packages/world/src/queue.ts

@@ -45,6 +45,7 @@ export type QueuePayload = z.infer<typeof QueuePayloadSchema>;
 
 export interface Queue {
   getDeploymentId(): Promise<string>;
+  getUrl(): string;
 
   /**
    * Enqueues a message to the specified queue.