Method _setPeerConnectionHandlers

javascript/src/peerfetch.ts:211–331

(peerConnection: Peer.DataConnection, setupResolve: Function, setupReject: Function)

  }

  private _setPeerConnectionHandlers (peerConnection: Peer.DataConnection, setupResolve: Function, setupReject: Function) {
    // isSetupResolved indicates whether the setupReady promise has been resolved or rejected
    // to ensure that we resolve/reject the promise only once.
    let isSetupResolved = false

    // setup connection progress callbacks
    peerConnection.on('open', () => {
      this._peerConnectionStatus = ConnectionStatus.CONNECTED
      this._dataConnection = peerConnection
      // Map of pending requests awaiting responses
      this._requestMap = new Map()
      // incrementing counter to the next available
      // unused ticket number
      // Each request is assigned a ticket
      // which can be used to claim the response
      this._nextAvailableTicket = 0
      // points to the next ticket assigned to a pending request
      // Requests are processed in FIFO order.
      this._nextTicketInLine = 0
      console.debug('Peer DataConnection is now open.', { peerConnection })
      // Now that a peer connection is established,
      // we can resolve the PeerFetch setup() promise
      isSetupResolved = true
      // Add artificial delay as a workaround for a timing issue with dataconnection open.
      // It needs a moment to be come available after is signals 'open' state.
      setTimeout( () => {
        setupResolve()
        // schedule keepalive pings to prevent
        // routers from closing the NAT holes during persiod of inactivity
        // between peerfetch requests.
        this._schedulePing()
      }, 1000)
    })

    peerConnection.on('close', () => {
      this._peerConnectionStatus = ConnectionStatus.DISCONNECTED
      const msg = 'Peer DataConnection closed.'
      console.debug(msg)
      // if PeerFetch setup() promise has not been resolved yet,
      // then throw an exception to notify any app code awaiting resolution.
      if (!isSetupResolved) {
        isSetupResolved = true
        setupReject(new Error(msg))
      }
      console.debug('Peer connection is now closed.')
      this._stopPing()
    })

    peerConnection.on('error', (err) => {
      this._peerConnectionStatus = ConnectionStatus.ERROR
      const msg = 'Error in connection to remote peer ID: ' + peerConnection.peer
      console.debug(msg)
      if (!isSetupResolved) {
        isSetupResolved = true
        setupReject(new Error(msg))
      }
    })