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

Function persistProbeHealthResult

packages/core/sdk/src/executor.ts:5135–5146  ·  view source on GitHub ↗
(
      ref: ConnectionRef,
      result: HealthCheckResult,
    )

Source from the content-addressed store, hash-verified

5133 * landing even between the read and the UPDATE wins and the probe
5134 * verdict is a silent no-op. Best-effort, like every verdict write. */
5135 const persistProbeHealthResult = (
5136 ref: ConnectionRef,
5137 result: HealthCheckResult,
5138 ): Effect.Effect<void> =>
5139 findConnectionRow(ref).pipe(
5140 Effect.flatMap((fresh) =>
5141 fresh === null || oauthReauthRequiredFromProviderState(fresh.provider_state) !== null
5142 ? Effect.void
5143 : persistHealthResult(ref, fresh, result),
5144 ),
5145 Effect.ignore,
5146 );
5147
5148 const connectionCheckHealth = (
5149 ref: ConnectionRef,

Callers 1

connectionCheckHealthFunction · 0.85

Calls 3

findConnectionRowFunction · 0.85
persistHealthResultFunction · 0.85

Tested by

no test coverage detected