Function createLocalExecutorLayer

apps/local/src/executor.ts:145–249

(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();

      const owned = 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,
        onIntegrationChange: (event) =>
          localAnalytics.record(
            event.kind === "added" ? "integration_added" : "integration_removed",
            { plugin_key: event.pluginKey },