Function checkState

keyserver/src/socket/session-utils.js:313–485

(
  viewer: Viewer,
  status: StateCheckStatus,
)

  checkStateRequest?: ServerCheckStateServerRequest,
};
async function checkState(
  viewer: Viewer,
  status: StateCheckStatus,
): Promise<StateCheckResult> {
  if (status.status === 'state_validated') {
    return { sessionUpdate: { lastValidated: Date.now() } };
  } else if (status.status === 'state_check') {
    const promises = Object.fromEntries(
      values(serverStateSyncSpecs).map(spec => [
        spec.hashKey,
        (async () => {
          if (
            !hasMinCodeVersion(viewer.platformDetails, {
              native: 267,
              web: 32,
            })
          ) {
            const data = await spec.fetch(viewer);
            return hash(data);
          }
          const infosHash = await spec.fetchServerInfosHash(viewer);
          return infosHash;
        })(),
      ]),
    );
    const hashesToCheck = await promiseAll(promises);
    const checkStateRequest = {
      type: serverRequestTypes.CHECK_STATE,
      hashesToCheck,
    };
    return { checkStateRequest };
  }

  const invalidKeys = new Set(status.invalidKeys);

  const shouldFetchAll = Object.fromEntries(
    values(serverStateSyncSpecs).map(spec => [
      spec.hashKey,
      invalidKeys.has(spec.hashKey),
    ]),
  );
  const idsToFetch = Object.fromEntries(
    values(serverStateSyncSpecs)
      .filter(spec => spec.innerHashSpec?.hashKey)
      .map(spec => [spec.innerHashSpec?.hashKey, new Set<string>()]),
  );
  for (const key of invalidKeys) {
    const [innerHashKey, id] = key.split('|');
    if (innerHashKey && id) {
      idsToFetch[innerHashKey]?.add(id);
    }
  }

  const fetchPromises: { [string]: Promise<mixed> } = {};
  for (const spec of values(serverStateSyncSpecs)) {
    if (shouldFetchAll[spec.hashKey]) {
      fetchPromises[spec.hashKey] = spec.fetch(viewer);
    } else if (idsToFetch[spec.innerHashSpec?.hashKey]?.size > 0) {