Method sendInitialMessage

lib/socket/socket.react.js:546–660

()

  };

  async sendInitialMessage() {
    const { inflightRequests } = this.state;
    invariant(
      inflightRequests,
      'inflightRequests falsey inside sendInitialMessage',
    );
    const messageID = this.nextClientMessageID++;

    const shouldSendInitialPlatformDetails = !_isEqual(
      this.props.lastCommunicatedPlatformDetails,
    )(getConfig().platformDetails);

    const clientResponses: ClientClientResponse[] = [];
    if (shouldSendInitialPlatformDetails) {
      clientResponses.push({
        type: serverRequestTypes.PLATFORM_DETAILS,
        platformDetails: getConfig().platformDetails,
      });
    }

    let activityUpdatePromise;
    const { queuedActivityUpdates } = this.props.connection;
    if (queuedActivityUpdates.length > 0) {
      clientResponses.push({
        type: serverRequestTypes.INITIAL_ACTIVITY_UPDATES,
        activityUpdates: queuedActivityUpdates,
      });
      activityUpdatePromise =
        inflightRequests.fetchResponse<ActivityUpdateResponseServerSocketMessage>(
          messageID,
          serverSocketMessageTypes.ACTIVITY_UPDATE_RESPONSE,
        );
    }

    const sessionState = this.props.sessionStateFunc();
    const { sessionIdentification } = this.props;
    const initialMessage = {
      type: clientSocketMessageTypes.INITIAL,
      id: messageID,
      payload: {
        clientResponses,
        sessionState,
        sessionIdentification,
      },
    };
    this.initializedWithUserState = this.props.preRequestUserState;
    this.sendMessage(initialMessage);

    const stateSyncPromise =
      inflightRequests.fetchResponse<ClientStateSyncServerSocketMessage>(
        messageID,
        serverSocketMessageTypes.STATE_SYNC,
      );

    // https://flow.org/try/#1N4Igxg9gdgZglgcxALlAJwKYEMwBcD6aArlLnALYYrgA2WAzvXGCADQgYAeOBARgJ74AJhhhYiNXClzEM7DFCLl602QF92kEdQb8oYAAQwSeONAMAHNBHJx6GAII0aAHgAqyA8AMBqANoA1hj8nvQycFAIALqetpwYQgZqAHwAFAA6UAYGERZEuJ4AJABK2EIA8lA0-O7JrJkAlJ4ACta29i6F5bwAVgCyWBburAa4-BYYEDAGhVgA7lhwuMnJXpnZkFBhlm12GPQGALwGflEA3OsGm9tB-AfH3T0YeAB0t-SpufkNF1lGEGgDKkaBhcDkjgYAAxncEuAzvF4gyK4AAWMLgPh8DTWfw20BuwQh7z8cHOlzxWzBVhsewhX1wgWCZNxOxp9noLzy9BRqWp7QwP0uaku1zBmHoElw9wM80WYNabIwLywzl5u3Zgr+ooMAgAclhKJ5gH4wmgItFYnB4kI1BDgGpftkYACgSCwXAIdDYfDghykQhUejMdjgOSrviwbcib6Sczstk9QaMIz+FEIeLJfRY46kpdMLgiGgsonKL9hVBMrp9EYTGRzPYoEIAJJQJZwFV9fb0LAIDCpEOXN2jfa4BX8nNwaYZEAojDOCDpEAvMJYNBSgDqSx5i4Ci4aA5ZuBHY9pxxP9he4ogNAAbn2ZEQBTny5dZUtWfynDRUt4j2FzxgSSamobAgHeaBMNA1A3pCLwAEwAIwACwvJCIBqEAA
    // $FlowFixMe fixed in Flow 0.214
    const { stateSyncMessage, activityUpdateMessage } = await promiseAll({
      activityUpdateMessage: activityUpdatePromise,