Function fetchViewerForSocket

keyserver/src/session/cookies.js:380–428

(
  req: $Request,
  clientMessage: InitialClientSocketMessage,
)

}

async function fetchViewerForSocket(
  req: $Request,
  clientMessage: InitialClientSocketMessage,
): Promise<Viewer> {
  assertSecureRequest(req);
  const { sessionIdentification } = clientMessage.payload;
  const { sessionID } = sessionIdentification;
  const sessionParameterInfo = {
    isSocket: true,
    sessionID,
    sessionIdentifierType:
      sessionID !== undefined
        ? sessionIdentifierTypes.BODY_SESSION_ID
        : sessionIdentifierTypes.COOKIE_ID,
    ipAddress: getRequestIPAddress(req),
    userAgent: req.get('User-Agent'),
  };

  const result = await fetchViewerFromRequestBody(
    clientMessage.payload.sessionIdentification,
    sessionParameterInfo,
  );
  if (result.type === 'valid') {
    return result.viewer;
  }

  const anonymousViewerDataPromise: Promise<AnonymousViewerData> =
    (async () => {
      const platformDetails =
        result.type === 'invalidated' ? result.platformDetails : null;
      const deviceToken =
        result.type === 'invalidated' ? result.deviceToken : null;
      return await createNewAnonymousCookie({
        platformDetails,
        deviceToken,
      });
    })();
  const deleteCookiePromise = (async () => {
    if (result.type === 'invalidated') {
      await deleteCookie(result.cookieID);
    }
  })();
  const [anonymousViewerData] = await Promise.all([
    anonymousViewerDataPromise,
    deleteCookiePromise,
  ]);

  return createViewerForInvalidFetchViewerResult(result, anonymousViewerData);
}

async function handleFetchViewerResult(
  result: FetchViewerResult,