Remove AuthProvider interface from World and associated implementations

.changeset/slimy-hairs-thank.md

@@ -0,0 +1,8 @@
+---
+"@workflow/world-postgres": patch
+"@workflow/world-vercel": patch
+"@workflow/world-local": patch
+"@workflow/world": patch
+---
+
+Remove `AuthProvider` interface from `World` and associated implementations

packages/world-local/src/index.ts

@@ -1,12 +1,11 @@
 import type { World } from '@workflow/world';
-import { auth } from './auth.js';
 import { config } from './config.js';
 import { createQueue } from './queue.js';
 import { createStorage } from './storage.js';
 import { createStreamer } from './streamer.js';
 
 /**
- * Creates an embedded world instance that combines queue, storage, streamer, and authentication functionalities.
+ * Creates an embedded world instance that combines queue, storage, and streamer functionalities.
  *
  * @param dataDir - The directory to use for storage. If not provided, the default data dir will be used.
  * @param port - The port to use for the queue. If not provided, the default port will be used.
@@ -24,6 +23,5 @@ export function createEmbeddedWorld({
     ...createQueue(queuePort),
     ...createStorage(dir),
     ...createStreamer(dir),
-    ...auth,
   };
 }

packages/world-postgres/src/index.ts

@@ -1,4 +1,4 @@
-import type { AuthProvider, Storage, World } from '@workflow/world';
+import type { Storage, World } from '@workflow/world';
 import PgBoss from 'pg-boss';
 import createPostgres from 'postgres';
 import type { PostgresWorldConfig } from './config.js';
@@ -21,45 +21,6 @@ function createStorage(drizzle: Drizzle): Storage {
   };
 }
 
-function createAuthProvider(
-  _config: PostgresWorldConfig,
-  boss: PgBoss
-): AuthProvider {
-  return {
-    async getAuthInfo() {
-      return {
-        environment: 'postgres',
-        ownerId: 'postgres',
-        projectId: 'postgres',
-      };
-    },
-    async checkHealth() {
-      try {
-        if (!(await boss.isInstalled())) {
-          throw new Error('Postgres Boss is not installed properly');
-        }
-      } catch (err) {
-        return {
-          success: false,
-          data: { healthy: false },
-          message:
-            err &&
-            typeof err === 'object' &&
-            'message' in err &&
-            typeof err.message === 'string'
-              ? err.message
-              : String(err),
-        };
-      }
-      return {
-        success: true,
-        message: 'Postgres connection is healthy',
-        data: { healthy: true },
-      };
-    },
-  };
-}
-
 export function createWorld(
   config: PostgresWorldConfig = {
     connectionString:
@@ -79,12 +40,10 @@ export function createWorld(
   const queue = createQueue(boss, config);
   const storage = createStorage(drizzle);
   const streamer = createStreamer(postgres, drizzle);
-  const auth = createAuthProvider(config, boss);
 
   return {
     ...storage,
     ...streamer,
-    ...auth,
     ...queue,
     async start() {
       await queue.start();

packages/world-vercel/src/backend.ts

@@ -1,11 +1,9 @@
-import type { AuthProvider, Storage, Streamer } from '@workflow/world';
+import type { Storage, Streamer } from '@workflow/world';
 import { createStorage } from './storage.js';
 import { createStreamer } from './streamer.js';
 import type { APIConfig } from './utils.js';
 
-export function createVercel(
-  config?: APIConfig
-): Streamer & Storage & AuthProvider {
+export function createVercel(config?: APIConfig): Streamer & Storage {
   const storage = createStorage(config);
   const streamer = createStreamer(config);
 
@@ -15,10 +13,6 @@ export function createVercel(
     closeStream: streamer.closeStream,
     readFromStream: streamer.readFromStream,
 
-    // AuthProvider interface
-    getAuthInfo: storage.getAuthInfo,
-    checkHealth: storage.checkHealth,
-
     // Storage interface with namespaced methods
     runs: storage.runs,
     steps: storage.steps,

packages/world-vercel/src/index.ts

@@ -1,5 +1,4 @@
 import type { World } from '@workflow/world';
-import { createAuth } from './auth.js';
 import { createQueue } from './queue.js';
 import { createStorage } from './storage.js';
 import { createStreamer } from './streamer.js';
@@ -14,7 +13,6 @@ export function createVercelWorld(config?: APIConfig): World {
   return {
     ...createQueue(),
     ...createStorage(config),
-    ...createAuth(config),
     ...createStreamer(config),
   };
 }

packages/world-vercel/src/storage.ts

@@ -1,5 +1,4 @@
-import type { AuthProvider, Storage } from '@workflow/world';
-import { checkHealth, getAuthInfo } from './auth.js';
+import type { Storage } from '@workflow/world';
 import { createWorkflowRunEvent, getWorkflowRunEvents } from './events.js';
 import {
   createHook,
@@ -25,12 +24,8 @@ import {
 } from './steps.js';
 import type { APIConfig } from './utils.js';
 
-export function createStorage(config?: APIConfig): Storage & AuthProvider {
+export function createStorage(config?: APIConfig): Storage {
   return {
-    // AuthProvider interface
-    getAuthInfo: () => getAuthInfo(config),
-    checkHealth: () => checkHealth(config),
-
     // Storage interface with namespaced methods
     runs: {
       create: (data) => createWorkflowRun(data, config),

packages/world/src/index.ts

@@ -1,5 +1,3 @@
-export type * from './auth.js';
-export { AuthInfoSchema, HealthCheckResponseSchema } from './auth.js';
 export type * from './events.js';
 export {
   BaseEventSchema,

packages/world/src/interfaces.ts

@@ -1,4 +1,3 @@
-import type { AuthInfo, HealthCheckResponse } from './auth.js';
 import type {
   CreateEventParams,
   CreateEventRequest,
@@ -44,11 +43,6 @@ export interface Streamer {
   ): Promise<ReadableStream<Uint8Array>>;
 }
 
-export interface AuthProvider {
-  getAuthInfo(): Promise<AuthInfo>;
-  checkHealth(): Promise<HealthCheckResponse>;
-}
-
 export interface Storage {
   runs: {
     create(data: CreateWorkflowRunRequest): Promise<WorkflowRun>;
@@ -104,9 +98,8 @@ export interface Storage {
 
 /**
  * The "World" interface represents how Workflows are able to communicate with the outside world.
- * This means persistence, queuing and serialization.
  */
-export interface World extends Queue, Storage, AuthProvider, Streamer {
+export interface World extends Queue, Storage, Streamer {
   /**
    * A function that will be called to start any background tasks needed by the World implementation.
    * For example, in the case of a queue backed World, this would start the queue processing.