feat(parachain): send requests from subsystems

dot/network/service.go

@@ -593,7 +593,7 @@ func (s *Service) SendMessage(to peer.ID, msg NotificationsMessage) error {
 }
 
 func (s *Service) GetRequestResponseProtocol(subprotocol string, requestTimeout time.Duration,
-	maxResponseSize uint64) *RequestResponseProtocol {
+	maxResponseSize uint64) RequestMaker {
 
 	protocolID := s.host.protocolID + protocol.ID(subprotocol)
 	return &RequestResponseProtocol{

dot/parachain/collator-protocol/validator_side.go

@@ -559,7 +559,7 @@ type Network interface {
 		maxSize uint64,
 	) error
 	GetRequestResponseProtocol(subprotocol string, requestTimeout time.Duration,
-		maxResponseSize uint64) *network.RequestResponseProtocol
+		maxResponseSize uint64) network.RequestMaker
 }
 
 type CollationEvent struct {
@@ -574,7 +574,7 @@ type CollatorProtocolValidatorSide struct {
 	SubSystemToOverseer chan<- any
 	unfetchedCollation  chan UnfetchedCollation
 
-	collationFetchingReqResProtocol *network.RequestResponseProtocol
+	collationFetchingReqResProtocol network.RequestMaker
 
 	fetchedCollations []parachaintypes.Collation
 	// track all active collators and their data

dot/parachain/network-bridge/interface.go

@@ -27,7 +27,7 @@ type Network interface {
 		maxSize uint64,
 	) error
 	GetRequestResponseProtocol(subprotocol string, requestTimeout time.Duration,
-		maxResponseSize uint64) *network.RequestResponseProtocol
+		maxResponseSize uint64) network.RequestMaker
 	ReportPeer(change peerset.ReputationChange, p peer.ID)
 	DisconnectPeer(setID int, p peer.ID)
 	GetNetworkEventsChannel() chan *network.NetworkEventInfo

dot/parachain/chunk_fetching.go → dot/parachain/network-bridge/messages/chunk_fetching.go

@@ -1,11 +1,13 @@
 // Copyright 2023 ChainSafe Systems (ON)
 // SPDX-License-Identifier: LGPL-3.0-only
 
-package parachain
+package messages
 
 import (
 	"fmt"
 
+	"github.com/ChainSafe/gossamer/dot/network"
+
 	parachaintypes "github.com/ChainSafe/gossamer/dot/parachain/types"
 	"github.com/ChainSafe/gossamer/pkg/scale"
 )
@@ -24,6 +26,16 @@ func (c ChunkFetchingRequest) Encode() ([]byte, error) {
 	return scale.Marshal(c)
 }
 
+// Protocol returns the sub-protocol ID for this message
+func (c ChunkFetchingRequest) Protocol() ReqProtocolName {
+	return ChunkFetchingV1
+}
+
+// Response returns an instance of the response type for this message, for the purpose of decoding into it.
+func (c ChunkFetchingRequest) Response() network.ResponseMessage {
+	return &ChunkFetchingResponse{}
+}
+
 type ChunkFetchingResponseValues interface {
 	ChunkResponse | NoSuchChunk
 }

dot/parachain/chunk_fetching_test.go → dot/parachain/network-bridge/messages/chunk_fetching_test.go

@@ -1,7 +1,7 @@
 // Copyright 2023 ChainSafe Systems (ON)
 // SPDX-License-Identifier: LGPL-3.0-only
 
-package parachain
+package messages
 
 import (
 	"testing"

dot/parachain/network-bridge/messages/request_response_protocols.go

@@ -0,0 +1,95 @@
+// Copyright 2025 ChainSafe Systems (ON)
+// SPDX-License-Identifier: LGPL-3.0-only
+
+package messages
+
+import (
+	"context"
+
+	"github.com/ChainSafe/gossamer/dot/network"
+	"github.com/libp2p/go-libp2p/core/peer"
+)
+
+type ReqProtocolName uint
+
+const (
+	ChunkFetchingV1 ReqProtocolName = iota
+	CollationFetchingV1
+	PoVFetchingV1
+	AvailableDataFetchingV1
+	StatementFetchingV1
+	DisputeSendingV1
+)
+
+func (n ReqProtocolName) String() string {
+	switch n {
+	case ChunkFetchingV1:
+		return "req_chunk/1"
+	case CollationFetchingV1:
+		return "req_collation/1"
+	case PoVFetchingV1:
+		return "req_pov/1"
+	case AvailableDataFetchingV1:
+		return "req_available_data/1"
+	case StatementFetchingV1:
+		return "req_statement/1"
+	case DisputeSendingV1:
+		return "send_dispute/1"
+	default:
+		panic("unknown protocol")
+	}
+}
+
+// ReqProtocolMessage is a network message that can be sent over a request response protocol.
+type ReqProtocolMessage interface {
+	network.Message
+	// Response returns an instance of the response type for this message, for the purpose of decoding into it.
+	Response() network.ResponseMessage
+	Protocol() ReqProtocolName
+}
+
+// ReqRespResult is the result of sending a request over a request response protocol. It contains either a response
+// message or an error.
+type ReqRespResult struct {
+	Response network.ResponseMessage
+	Error    error
+}
+
+// OutgoingRequest contains all data required to send a request over a request response protocol and receive the result.
+type OutgoingRequest struct {
+	Recipient peer.ID // TODO use a type that can contain either a peer ID or an authority ID
+	Payload   ReqProtocolMessage
+	Result    chan ReqRespResult
+
+	ctx    context.Context
+	cancel context.CancelFunc
+}
+
+// Done returns a channel that is closed when the request is cancelled.
+func (or *OutgoingRequest) Done() <-chan struct{} {
+	return or.ctx.Done()
+}
+
+// Cancel cancels the request.
+func (or *OutgoingRequest) Cancel() {
+	or.cancel()
+}
+
+// IsCancelled returns true if the request has been cancelled.
+func (or *OutgoingRequest) IsCancelled() bool {
+	return or.ctx.Err() != nil
+}
+
+// NewOutgoingRequest creates a new outgoing request.
+func NewOutgoingRequest(recipient peer.ID, payload ReqProtocolMessage) *OutgoingRequest {
+	result := make(chan ReqRespResult, 1)
+	ctx, cancel := context.WithCancel(context.Background())
+
+	return &OutgoingRequest{
+		Recipient: recipient,
+		Payload:   payload,
+		Result:    result,
+		ctx:       ctx,
+		cancel:    cancel,
+	}
+}

dot/parachain/network-bridge/messages/tx_overseer_messages.go

@@ -63,3 +63,16 @@ type ConnectToValidators struct {
 	// authority discovery has Failed to resolve.
 	Failed chan<- uint
 }
+
+type IfDisconnectedBehavior int
+
+const (
+	TryConnect     IfDisconnectedBehavior = iota
+	ImmediateError                        // TODO not implemented
+)
+
+// SendRequests is a subsystem message for sending requests over a request response protocol.
+type SendRequests struct {
+	Requests       []*OutgoingRequest
+	IfDisconnected IfDisconnectedBehavior
+}

dot/parachain/network-bridge/mocks_generate_test.go

@@ -0,0 +1,7 @@
+// Copyright 2025 ChainSafe Systems (ON)
+// SPDX-License-Identifier: LGPL-3.0-only
+
+package networkbridge
+
+//go:generate mockgen -destination=mocks_test.go -package=$GOPACKAGE . Network
+//go:generate mockgen -destination=mock_request_maker_test.go -package=$GOPACKAGE github.com/ChainSafe/gossamer/dot/network RequestMaker