Method handleInitialClientSocketMessage

keyserver/src/socket/socket.js:442–508

(
    message: InitialClientSocketMessage,
  )

  }

  async handleInitialClientSocketMessage(
    message: InitialClientSocketMessage,
  ): Promise<ServerServerSocketMessage[]> {
    const { viewer } = this;
    invariant(viewer, 'should be set');

    const responses: Array<ServerServerSocketMessage> = [];

    const { sessionState, clientResponses } = message.payload;

    const payload = await fetchDataForSocketInit(viewer, sessionState);
    responses.push({
      type: serverSocketMessageTypes.STATE_SYNC,
      responseTo: message.id,
      payload,
    });

    const [
      { serverRequests, activityUpdateResult },
      signedIdentityKeysBlobMissing,
      olmNotificationsSessionMissing,
    ] = await Promise.all([
      processClientResponses(viewer, clientResponses),
      isCookieMissingSignedIdentityKeysBlob(viewer.cookieID),
      isCookieMissingOlmNotificationsSession(viewer),
    ]);

    if (signedIdentityKeysBlobMissing) {
      serverRequests.push({
        type: serverRequestTypes.SIGNED_IDENTITY_KEYS_BLOB,
      });
    }

    if (olmNotificationsSessionMissing) {
      serverRequests.push({
        type: serverRequestTypes.INITIAL_NOTIFICATIONS_ENCRYPTED_MESSAGE,
      });
      const { userID, cookieID, sessionID } = viewer;
      const data = { userID, cookieID, sessionID };
      console.log(
        'Sending serverRequestTypes.INITIAL_NOTIFICATIONS_ENCRYPTED_MESSAGE ' +
          JSON.stringify(data),
      );
    }

    if (serverRequests.length > 0 || clientResponses.length > 0) {
      // We send this message first since the STATE_SYNC triggers the client's
      // connection status to shift to "connected", and we want to make sure the
      // client responses are cleared from Redux before that happens
      responses.unshift({
        type: serverSocketMessageTypes.REQUESTS,
        responseTo: message.id,
        payload: { serverRequests },
      });
    }

    if (activityUpdateResult) {
      // Same reason for unshifting as above