Method decodePipe

p2p/client.go:426–469

(bytesC chan []byte)

}

func (c *client) decodePipe(bytesC chan []byte) (replyMsg, receivedMsg chan P2PMessage) {
	replyMsg = make(chan P2PMessage)
	receivedMsg = make(chan P2PMessage)
	go func() {
		defer close(replyMsg)
		defer close(receivedMsg)
		for {
			var msg P2PMessage
			select {
			case <-c.ctx.Done():
				return
			case bytes, ok := <-bytesC:
				if ok {
					if len(bytes) == 0 {
						continue
					}
					pa, ptr, err := decodeBytes(bytes, c.verifyFn)
					if err != nil {
						c.reportError(errors.Errorf("client decodePipe: %w", err))
						continue
					}
					//TODO: Move to other module
					if err := bls.Verify(c.suite, c.remotePubKey, pa.GetAnything().Value, pa.GetSignature()); err != nil {
						c.reportError(errors.Errorf("client decodePipe: %w", err))
						continue
					}
					msg = P2PMessage{Msg: ptr, Sender: pa.GetSender(), RequestNonce: pa.GetRequestNonce()}
					if pa.GetReplyFlag() {
						select {
						case <-c.ctx.Done():
						case replyMsg <- msg:
						}
					} else {
						select {
						case <-c.ctx.Done():
						case receivedMsg <- msg:
						}
					}
				}
			}
		}
	}()
	return
}

func (c *client) readPipe() (out chan []byte) {
	out = make(chan []byte, 10)