Class Socket

lib/socket/socket.react.js:118–832

  +inflightRequests: ?InflightRequests,
};
class Socket extends React.PureComponent<Props, State> {
  state: State = {
    inflightRequests: null,
  };
  socket: ?CommTransportLayer;
  nextClientMessageID: number = 0;
  listeners: Set<SocketListener> = new Set();
  pingTimeoutID: ?TimeoutID;
  messageLastReceived: ?number;
  reopenConnectionAfterClosing: boolean = false;
  initializedWithUserState: ?PreRequestUserState;
  initFailureCount: number = 0;
  fetchingPendingUpdates: boolean = false;

  openSocket(newStatus: ConnectionStatus) {
    if (
      this.props.frozen ||
      !this.props.cookie ||
      !this.props.cookie.startsWith('user=')
    ) {
      return;
    }
    if (this.socket) {
      const { status } = this.props.connection;
      if (status === 'forcedDisconnecting') {
        this.reopenConnectionAfterClosing = true;
        return;
      } else if (status === 'disconnecting' && this.socket.readyState === 1) {
        this.markSocketInitialized();
        return;
      } else if (
        status === 'connected' ||
        status === 'connecting' ||
        status === 'reconnecting'
      ) {
        return;
      }
      if (this.socket.readyState < 2) {
        this.socket.close();
        console.log(`this.socket seems open, but Redux thinks it's ${status}`);
      }
    }
    this.props.dispatch({
      type: updateConnectionStatusActionType,
      payload: { status: newStatus, keyserverID: this.props.keyserverID },
    });

    const socket = this.props.openSocket();
    const openObject: { initializeMessageSent?: true } = {};
    socket.onopen = () => {
      if (this.socket === socket) {
        void this.initializeSocket();
        openObject.initializeMessageSent = true;
      }
    };
    socket.onmessage = this.receiveMessage;
    socket.onclose = () => {
      if (this.socket === socket) {