Function produceConnectionTools

packages/core/sdk/src/executor.ts:3775–3799

(
      integrationRow: IntegrationRow,
      ref: ConnectionRef,
      requestedMode: "explicit" | "background" = "explicit",
    )

    }
    const toolProductionInFlight = new Map<string, ToolProductionInFlight>();
    const produceConnectionTools = (
      integrationRow: IntegrationRow,
      ref: ConnectionRef,
      requestedMode: "explicit" | "background" = "explicit",
    ): Effect.Effect<readonly Tool[], ToolProductionError> =>
      Effect.suspend(() => {
        const key = `${ref.owner}:${String(ref.integration)}:${String(ref.name)}`;
        const existing = toolProductionInFlight.get(key);
        if (existing) {
          if (requestedMode === "explicit") existing.mode = "explicit";
          return Deferred.await(existing.deferred);
        }

        const entry: ToolProductionInFlight = {
          deferred: Deferred.makeUnsafe<readonly Tool[], ToolProductionError>(),
          mode: requestedMode,
        };
        toolProductionInFlight.set(key, entry);
        const run = produceConnectionToolsUnshared(integrationRow, ref, () => entry.mode).pipe(
          Effect.exit,
          Effect.flatMap((exit) => Deferred.done(entry.deferred, exit)),
          Effect.ensuring(Effect.sync(() => void toolProductionInFlight.delete(key))),
        );
        return Effect.forkDetach(run).pipe(Effect.andThen(Deferred.await(entry.deferred)));
      });

    // ------------------------------------------------------------------
    // Connections