Function createLocalExecutorLayer

apps/local/src/executor.ts:159–267

(options: LocalExecutorOptions = {})

  );

const createLocalExecutorLayer = (options: LocalExecutorOptions = {}) => {
  const storage = resolveStorage();

  return Layer.effect(LocalExecutorTag)(
    Effect.gen(function* () {
      const { cwd, plugins } = yield* loadLocalPlugins(options);
      const tenantId = makeTenantId(cwd);
      const tables = collectTables();

      // A borrowed handle is owned by its opener, so it is used as-is and left
      // open on release; only a handle opened here is closed here.
      const owned = options.borrowedDb
        ? options.borrowedDb
        : yield* Effect.acquireRelease(
            Effect.tryPromise({
              try: () =>
                openOwnedLocalDatabase({
                  dataDir: storage.dataDir,
                  tables,
                  namespace: localNamespace,
                  tenantId,
                }),
              catch: (cause) =>
                new LocalExecutorCreateError({
                  message: CREATE_SQLITE_ERROR_MESSAGE,
                  cause,
                }),
            }),
            (database) => Effect.promise(() => database.close()).pipe(Effect.ignore),
          );
      const sqlite = owned.db;
      const migration = owned.migration;

      // Boot-time data migrations: each registry entry runs once and is
      // stamped in the `data_migration` ledger; stamped entries are skipped
      // without touching the data.
      yield* runSqliteDataMigrations(sqlite.client, localDataMigrations).pipe(
        Effect.mapError(
          (cause) =>
            new LocalExecutorCreateError({
              message: CREATE_SQLITE_ERROR_MESSAGE,
              cause,
            }),
        ),
      );

      // webBaseUrl is where the executor's web UI listens — same port as the
      // daemon API since the daemon serves both. Mirrors serve.ts's port
      // resolution so a custom $PORT flows through. EXECUTOR_WEB_BASE_URL
      // overrides entirely for deployments where the UI is on a different host.
      const webBaseUrl =
        process.env.EXECUTOR_WEB_BASE_URL ?? `http://localhost:${process.env.PORT ?? "4788"}`;

      const executor = yield* createExecutor({
        tenant: Tenant.make(tenantId),
        subject: Subject.make(LOCAL_SUBJECT),
        db: sqlite.db,
        plugins,