Function refreshAccessToken

packages/filesystem/auth.ts:79–117

(
  netDiskType: NetDiskType,
  token: Token,
  invalid: boolean | undefined,
  key: string,
  localStorageDAO: LocalStorageDAO
)

const authTokenPromises: Partial<Record<NetDiskType, Promise<Token>>> = {};

function refreshAccessToken(
  netDiskType: NetDiskType,
  token: Token,
  invalid: boolean | undefined,
  key: string,
  localStorageDAO: LocalStorageDAO
) {
  if (refreshTokenPromises[netDiskType]) {
    return refreshTokenPromises[netDiskType];
  }

  const refreshPromiseFn = async () => {
    const resp = await RefreshToken(netDiskType, token.refreshToken);
    if (resp.code !== 0) {
      await localStorageDAO.delete(key);
      // 刷新失败,并且标记失效,尝试重新获取token
      if (invalid) {
        return await AuthVerify(netDiskType);
      }
      throw new WarpTokenError(new Error(resp.msg));
    }
    const newToken = {
      accessToken: resp.data.token.access_token,
      refreshToken: resp.data.token.refresh_token,
      createtime: Date.now(),
    };
    // 更新token
    await localStorageDAO.saveValue(key, newToken);
    return newToken.accessToken;
  };
  const refreshPromise: Promise<string> = refreshPromiseFn().finally(() => {
    if (refreshTokenPromises[netDiskType] === refreshPromise) {
      delete refreshTokenPromises[netDiskType];
    }
  });

  refreshTokenPromises[netDiskType] = refreshPromise;
  return refreshPromise;
}

export async function AuthVerify(netDiskType: NetDiskType, invalid?: boolean) {
  let token: Token | undefined = undefined;