Function healPersistedHealthOnUse

packages/core/sdk/src/executor.ts:4860–4901

(
      row: ConnectionRow,
      result: unknown,
      values: Record<string, string | null>,
    )

     *  stamp and the heal is a silent no-op. Any newer write is newer
     *  evidence than this invocation. */
    const healPersistedHealthOnUse = (
      row: ConnectionRow,
      result: unknown,
      values: Record<string, string | null>,
    ): Effect.Effect<void> =>
      Effect.suspend(() => {
        if (isToolResult(result) && !result.ok) return Effect.void;
        if (Object.values(values).some((value) => value == null)) return Effect.void;
        const observed = Option.getOrNull(decodeLastHealth(row.last_health));
        if (observed === null || observed.status === "healthy" || observed.status === "unknown") {
          return Effect.void;
        }
        if (isToolSyncHealth(observed)) return Effect.void;
        if (oauthReauthRequiredFromProviderState(row.provider_state) !== null) return Effect.void;
        const ref: ConnectionRef = {
          owner: row.owner as Owner,
          integration: IntegrationSlug.make(row.integration),
          name: ConnectionName.make(row.name),
        };
        return findConnectionRow(ref).pipe(
          Effect.flatMap((fresh) => {
            if (fresh === null) return Effect.void;
            if (oauthReauthRequiredFromProviderState(fresh.provider_state) !== null) {
              return Effect.void;
            }
            const current = Option.getOrNull(decodeLastHealth(fresh.last_health));
            if (
              current === null ||
              current.status !== observed.status ||
              current.checkedAt !== observed.checkedAt
            ) {
              return Effect.void;
            }
            return persistHealthResult(ref, fresh, {
              status: "healthy",
              checkedAt: Date.now(),
              detail: "Tool invocation succeeded.",
            });
          }),
          Effect.ignore,
        );
      });

    const healthFromCredentialResolutionFailure = (
      failure: CredentialResolutionError,