Function provision

packages/core/execution/src/tool-invoker.test.ts:452–477

(
  executor: {
    readonly connections: {
      readonly create: (input: {
        readonly owner: "org";
        readonly name: typeof CONN;
        readonly integration: ReturnType<typeof IntegrationSlug.make>;
        readonly template: typeof TEMPLATE;
        readonly value: string;
      }) => Effect.Effect<unknown, unknown>;
    };
  } & Record<string, { readonly seed: () => Effect.Effect<unknown, unknown> }>,
  specs: readonly { readonly pluginId: string; readonly integration: string }[],
)

// Provision: register each plugin's integration and create one org `main`
// connection so per-connection tools exist and are addressable.
const provision = (
  executor: {
    readonly connections: {
      readonly create: (input: {
        readonly owner: "org";
        readonly name: typeof CONN;
        readonly integration: ReturnType<typeof IntegrationSlug.make>;
        readonly template: typeof TEMPLATE;
        readonly value: string;
      }) => Effect.Effect<unknown, unknown>;
    };
  } & Record<string, { readonly seed: () => Effect.Effect<unknown, unknown> }>,
  specs: readonly { readonly pluginId: string; readonly integration: string }[],
): Effect.Effect<void, unknown> =>
  Effect.gen(function* () {
    for (const spec of specs) {
      yield* executor[spec.pluginId]!.seed();
      yield* executor.connections.create({
        owner: "org",
        name: CONN,
        integration: IntegrationSlug.make(spec.integration),
        template: TEMPLATE,
        value: "token",
      });
    }
  });

const makeExecutorWith = <const TPlugins extends readonly AnyPlugin[]>(plugins: TPlugins) =>
  createExecutor(makeTestConfig({ plugins }));