Function createExecutor

packages/core/sdk/src/promise-executor.ts:203–234

(
  config: ExecutorConfig<TPlugins>,
)

// ---------------------------------------------------------------------------

export const createExecutor = async <const TPlugins extends readonly AnyPlugin[] = readonly []>(
  config: ExecutorConfig<TPlugins>,
): Promise<Executor<TPlugins>> => {
  const plugins = (config?.plugins ?? []) as TPlugins;
  const db =
    typeof config.db === "function" ? await config.db({ tables: collectTables() }) : config.db;

  const effectConfig = {
    tenant: Tenant.make(config.tenant ?? "default-tenant"),
    ...(config.subject !== undefined ? { subject: Subject.make(config.subject) } : {}),
    plugins,
    ...(config.providers ? { providers: config.providers } : {}),
    onElicitation: toEffectOnElicitation(config.onElicitation),
    ...(db ? { db } : {}),
  };

  // The SDK has no observability requirement; storage failures surface
  // as raw `StorageError` / `UniqueViolationError` in the typed channel.
  // `Effect.runPromise` turns them into Promise rejections — consumers
  // get the tagged error as the rejected value. See
  // notes/promise-sdk-typed-errors.md for the planned `runPromiseExit`
  // rewrite that exposes the full error union to consumers.
  const effectExecutor = await Effect.runPromise(createEffectExecutor(effectConfig));

  const executor = promisifyDeep(effectExecutor) as Executor<TPlugins>;
  return {
    ...executor,
    close: async () => {
      await Effect.runPromise(effectExecutor.close());
    },
  } as Executor<TPlugins>;
};