Function makeExecutor

apps/local/src/mcp-browser-resume.test.ts:79–105

(tmpDir: string)

}));

const makeExecutor = async (tmpDir: string): Promise<Executor> => {
  const plugins = [approvalPlugin()] as const;
  const sqlite = await createSqliteFumaDb({
    tables: collectTables(),
    namespace: "executor_local_browser_resume_test",
    path: join(tmpDir, "data.db"),
  });
  const executor = await Effect.runPromise(
    createExecutor({
      tenant: Tenant.make(`test-${randomBytes(4).toString("hex")}`),
      subject: Subject.make("local"),
      db: sqlite.db,
      plugins,
      onElicitation: "accept-all",
    }),
  );

  const close = executor.close;
  return {
    ...executor,
    close: () =>
      Effect.gen(function* () {
        yield* close();
        yield* Effect.promise(() => sqlite.close());
      }),
  };
};

const makeMcpFetch = (executor: Executor) => {
  const engine = createExecutionEngine({