Function withOAuth401Retry

src/utils/http.ts:143–171

(
  request: () => Promise<T>,
  opts?: { also403Revoked?: boolean },
)

 *   revoked" body (some endpoints signal revocation this way instead of 401).
 */
export async function withOAuth401Retry<T>(
  request: () => Promise<T>,
  opts?: { also403Revoked?: boolean },
): Promise<T> {
  const initialSession = getAuthRuntime().getCurrentSession()
  if (initialSession.principalSource === 'managed_oauth') {
    await getAuthRuntime().resolveSession({ allowRefresh: true })
  }

  try {
    return await request()
  } catch (err) {
    if (!axios.isAxiosError(err)) throw err
    const status = err.response?.status
    const isAuthError =
      status === 401 ||
      (opts?.also403Revoked &&
        status === 403 &&
        typeof err.response?.data === 'string' &&
        err.response.data.includes('OAuth token has been revoked'))
    if (!isAuthError) throw err
    const failedAccessToken = getAuthRuntime().getCurrentSession().accessToken
    if (!failedAccessToken) throw err
    const recovered =
      await getAuthRuntime().recoverManagedOAuth401(failedAccessToken)
    if (!recovered) throw err
    return await request()
  }
}