Function markRefreshGrantDead

packages/core/sdk/src/executor.ts:1911–1944

(
      row: ConnectionRow,
      detail: string,
    )

     *  which is what re-arms refresh. Best-effort: a bookkeeping write failure
     *  must not mask the refresh failure being reported. */
    const markRefreshGrantDead = (
      row: ConnectionRow,
      detail: string,
    ): Effect.Effect<void, never> => {
      const existingState = decodeJsonColumn(row.provider_state);
      const mergedState =
        existingState != null && typeof existingState === "object" && !Array.isArray(existingState)
          ? (existingState as Record<string, unknown>)
          : {};
      const health: HealthCheckResult = {
        status: "expired",
        checkedAt: Date.now(),
        detail,
      };
      return core
        .updateMany("connection", {
          where: (b: AnyCb) =>
            b.and(
              byOwner(row.owner as Owner)(b),
              b("integration", "=", String(row.integration)),
              b("name", "=", String(row.name)),
            ),
          set: {
            provider_state: {
              ...mergedState,
              oauthReauthRequiredAt: Date.now(),
              oauthReauthRequiredDetail: detail,
            },
            last_health: health,
            updated_at: new Date(),
          },
        })
        .pipe(Effect.ignore);
    };

    /** Write a re-minted token back: a ROTATED refresh token into the refresh
     *  item, the access token into the connection's primary provider item, and