Function fetchDataForSocketInit

keyserver/src/socket/fetch-data.js:29–141

(
  viewer: Viewer,
  sessionState: SessionState,
)

import { commitSessionUpdate } from '../updaters/session-updaters.js';

async function fetchDataForSocketInit(
  viewer: Viewer,
  sessionState: SessionState,
): Promise<ServerStateSyncSocketPayload> {
  const {
    calendarQuery,
    updatesCurrentAsOf: oldUpdatesCurrentAsOf,
    messagesCurrentAsOf: oldMessagesCurrentAsOf,
    watchedIDs,
  } = sessionState;
  await verifyCalendarQueryThreadIDs(calendarQuery);

  const sessionInitializationResult = await initializeSession(
    viewer,
    calendarQuery,
    oldUpdatesCurrentAsOf,
  );

  const threadCursors: { [string]: null } = {};
  for (const watchedThreadID of watchedIDs) {
    threadCursors[watchedThreadID] = null;
  }
  const messageSelectionCriteria = {
    threadCursors,
    joinedThreads: true,
    newerThan: oldMessagesCurrentAsOf,
  };
  const fetchMessagesResult = await fetchMessageInfosSince(
    viewer,
    messageSelectionCriteria,
    defaultNumberPerThread,
  );
  const messagesResult = {
    rawMessageInfos: fetchMessagesResult.rawMessageInfos,
    truncationStatuses: fetchMessagesResult.truncationStatuses,
    currentAsOf: mostRecentMessageTimestamp(
      fetchMessagesResult.rawMessageInfos,
      oldMessagesCurrentAsOf,
    ),
  };

  if (!sessionInitializationResult.sessionContinued) {
    const promises: { +[string]: Promise<mixed> } = Object.fromEntries(
      values(serverStateSyncSpecs).map(spec => [
        spec.hashKey,
        spec.fetchFullSocketSyncPayload(viewer, [calendarQuery]),
      ]),
    );
    // We have a type error here because Flow doesn't know spec.hashKey
    const castPromises: {
      +threadInfos: Promise<LegacyRawThreadInfos>,
      +currentUserInfo: Promise<CurrentUserInfo>,
      +entryInfos: Promise<$ReadOnlyArray<RawEntryInfo>>,
      +userInfos: Promise<$ReadOnlyArray<UserInfo>>,
    } = (promises: any);
    const results = await promiseAll(castPromises);
    let payload: ServerStateSyncFullSocketPayload = {
      type: stateSyncPayloadTypes.FULL,