Method _sendNextRequest

javascript/src/peerfetch.ts:528–557

Send next pending request to remote peer. Requests are sent one at a time. Only when a previous request response arrives is the next request sent across the wire. In the future we can look at handling multiple requests and responses in parallel over the same data connection or

()

    even a pool of connections.
  */
  _sendNextRequest () {
    const ticket = this._nextTicketInLine
    let { request, requestSent } = this._requestMap.get(ticket)
    if (requestSent) {
      // A request was sent and is waiting its response.
      // Wait for the full respones before sending another request.
      return
    } else {
      requestSent = true
      this._requestMap.set(ticket, { request, requestSent })
    }
    console.assert(request, 'request cannot be null or empty', { ticket, request })
    const jsonRequest = JSON.stringify(request)
    const requestMap = this._requestMap
    const dataConnection = this._dataConnection
    console.debug('PeerFetch: Sending request to remote peer',
      { requestMap, ticket, request, dataConnection })
    try {
      if (this._dataConnection) {
        this._dataConnection.send(jsonRequest)
      } else {
        const msg = 'No Peer DataConnection available!'
        console.error(msg)
        throw new Error(msg)
      }
      console.debug('PeerFetch: Request sent to remote peer: ', jsonRequest)
    } catch (error) {
      console.error('PeerFetch: Error sending message via Peer DataConnection', { error })
    }
  }

  _processNextTicketInLine () {
    // check if there is a pending ticket