( retryCount = 0, force = false, )
| 1421 | let pendingRefreshCheck: Promise<boolean> | null = null |
| 1422 | |
| 1423 | export function checkAndRefreshOAuthTokenIfNeeded( |
| 1424 | retryCount = 0, |
| 1425 | force = false, |
| 1426 | ): Promise<boolean> { |
| 1427 | // Deduplicate concurrent non-retry, non-force calls |
| 1428 | if (retryCount === 0 && !force) { |
| 1429 | if (pendingRefreshCheck) { |
| 1430 | return pendingRefreshCheck |
| 1431 | } |
| 1432 | |
| 1433 | const promise = checkAndRefreshOAuthTokenIfNeededImpl(retryCount, force) |
| 1434 | pendingRefreshCheck = promise.finally(() => { |
| 1435 | pendingRefreshCheck = null |
| 1436 | }) |
| 1437 | return pendingRefreshCheck |
| 1438 | } |
| 1439 | |
| 1440 | return checkAndRefreshOAuthTokenIfNeededImpl(retryCount, force) |
| 1441 | } |
| 1442 | |
| 1443 | async function checkAndRefreshOAuthTokenIfNeededImpl( |
| 1444 | retryCount: number, |
no test coverage detected