MCPcopy Create free account
hub / github.com/UsefulSoftwareCo/executor / findConnectionRow

Function findConnectionRow

packages/core/sdk/src/executor.ts:2097–2107  ·  view source on GitHub ↗
(
      ref: ConnectionRef,
    )

Source from the content-addressed store, hash-verified

2095 // ------------------------------------------------------------------
2096
2097 const findConnectionRow = (
2098 ref: ConnectionRef,
2099 ): Effect.Effect<ConnectionRow | null, StorageFailure> =>
2100 core.findFirst("connection", {
2101 where: (b: AnyCb) =>
2102 b.and(
2103 byOwner(ref.owner)(b),
2104 b("integration", "=", String(ref.integration)),
2105 b("name", "=", String(ref.name)),
2106 ),
2107 });
2108
2109 // Key for the shared in-flight refresh gate (`refreshInFlight`, bound at
2110 // the top of `createExecutor`). The tenant leads because the gate spans

Callers 15

stampSyncedWithHealthFunction · 0.85
connectionsCreateFunction · 0.85
mintOAuthConnectionFunction · 0.85
connectionsGetFunction · 0.85
connectionsUpdateFunction · 0.85
connectionsRemoveFunction · 0.85
connectionsRefreshFunction · 0.85
healPersistedHealthOnUseFunction · 0.85
persistProbeHealthResultFunction · 0.85

Calls 1

byOwnerFunction · 0.85

Tested by

no test coverage detected