Method resolveRequestsForMessage

lib/socket/inflight-requests.js:164–211

(message: ClientServerSocketMessage)

  }

  resolveRequestsForMessage(message: ClientServerSocketMessage) {
    for (const inflightRequest of this.data) {
      if (
        message.responseTo === null ||
        message.responseTo === undefined ||
        inflightRequest.messageID !== message.responseTo
      ) {
        continue;
      }
      if (message.type === serverSocketMessageTypes.ERROR) {
        const error = message.payload
          ? new ServerError(message.message, message.payload)
          : new ServerError(message.message);
        inflightRequest.reject(error);
      } else if (message.type === serverSocketMessageTypes.AUTH_ERROR) {
        inflightRequest.reject(new SocketOffline('auth_error'));
      } else if (
        message.type === serverSocketMessageTypes.STATE_SYNC &&
        inflightRequest.expectedResponseType ===
          serverSocketMessageTypes.STATE_SYNC
      ) {
        inflightRequest.resolve(message);
      } else if (
        message.type === serverSocketMessageTypes.REQUESTS &&
        inflightRequest.expectedResponseType ===
          serverSocketMessageTypes.REQUESTS
      ) {
        inflightRequest.resolve(message);
      } else if (
        message.type === serverSocketMessageTypes.ACTIVITY_UPDATE_RESPONSE &&
        inflightRequest.expectedResponseType ===
          serverSocketMessageTypes.ACTIVITY_UPDATE_RESPONSE
      ) {
        inflightRequest.resolve(message);
      } else if (
        message.type === serverSocketMessageTypes.PONG &&
        inflightRequest.expectedResponseType === serverSocketMessageTypes.PONG
      ) {
        inflightRequest.resolve(message);
      } else if (
        message.type === serverSocketMessageTypes.API_RESPONSE &&
        inflightRequest.expectedResponseType ===
          serverSocketMessageTypes.API_RESPONSE
      ) {
        inflightRequest.resolve(message);
      }
    }
  }

  rejectAll(error: Error) {
    const { data } = this;