Function cloudDbProviderLayer

apps/cloud/src/db/fuma.ts:56–77

(
  tables: FumaTables,
)

// out-of-band, so there is no schema bring-up here, and `close` is a no-op —
// `DbService.Live` owns the postgres connection lifecycle.
export const cloudDbProviderLayer = (
  tables: FumaTables,
): Layer.Layer<DbProvider, never, DbService> =>
  Layer.effect(DbProvider)(
    Effect.map(DbService.asEffect(), ({ db }): ExecutorDbHandle => {
      const fuma = createDrizzleFumaDb({
        db,
        tables,
        namespace: CLOUD_NAMESPACE,
        provider: "postgresql",
      });
      return {
        db: fuma.db,
        fuma: fuma.fuma,
        close: async () => {},
        // Plugin blobs (multi-MB resolved specs) live in R2, not Postgres.
        // Guarded because test workers / local dev may run without the
        // binding — the executor then falls back to the FumaDB `blob` table.
        blobs: env.BLOBS ? makeR2BlobStore(env.BLOBS) : undefined,
      };
    }),
  );