Function AuthVerify

packages/filesystem/auth.ts:119–165

(netDiskType: NetDiskType, invalid?: boolean)

}

export async function AuthVerify(netDiskType: NetDiskType, invalid?: boolean) {
  let token: Token | undefined = undefined;
  const localStorageDAO = new LocalStorageDAO();
  const key = `netdisk:token:${netDiskType}`;
  try {
    token = await localStorageDAO.getValue<Token>(key);
  } catch (_) {
    // ignore
  }
  // token不存在,或者没有accessToken,重新获取
  if (!token || !token.accessToken) {
    if (!authTokenPromises[netDiskType]) {
      const authPromise = (async () => {
        // 强制重新获取token
        await NetDisk(netDiskType);
        const resp = await GetNetDiskToken(netDiskType);
        if (resp.code !== 0) {
          throw new WarpTokenError(new Error(resp.msg));
        }
        const newToken = {
          accessToken: resp.data.token.access_token,
          refreshToken: resp.data.token.refresh_token,
          createtime: Date.now(),
        };
        await localStorageDAO.saveValue(key, newToken);
        return newToken;
      })().finally(() => {
        if (authTokenPromises[netDiskType] === authPromise) {
          delete authTokenPromises[netDiskType];
        }
      });
      authTokenPromises[netDiskType] = authPromise;
    }
    token = await authTokenPromises[netDiskType];
    invalid = false;
  }
  // token未过期(一小时内)及有效则保留，不用刷新token
  const unexpired = Date.now() < token.createtime + 3600000;
  if (unexpired && !invalid) return token.accessToken;
  try {
    return await refreshAccessToken(netDiskType, token, invalid, key, localStorageDAO);
  } catch (e) {
    // 已过期或已被服务端判定失效的 token 不能继续回退使用
    console.warn(e);
    throw e;
  }
}

export const netDiskTypeMap: Partial<Record<FileSystemType, NetDiskType>> = {
  "baidu-netdsik": "baidu",