Skip to content

Commit

Permalink
adding comment for wrapping protocol message.
Browse files Browse the repository at this point in the history
  • Loading branch information
ranlavanet committed Aug 25, 2024
1 parent 1a4f687 commit 95cdfc6
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions protocol/rpcconsumer/rpcconsumer_server.go
Original file line number Diff line number Diff line change
Expand Up @@ -1234,6 +1234,7 @@ func (rpccs *RPCConsumerServer) sendDataReliabilityRelayIfApplicable(ctx context
if len(results) < 2 {
userData := chainMessage.GetUserData()
relayRequestData := lavaprotocol.NewRelayData(ctx, relayResult.Request.RelayData.ConnectionType, relayResult.Request.RelayData.ApiUrl, relayResult.Request.RelayData.Data, relayResult.Request.RelayData.SeenBlock, reqBlock, relayResult.Request.RelayData.ApiInterface, chainMessage.GetRPCMessage().GetHeaders(), relayResult.Request.RelayData.Addon, relayResult.Request.RelayData.Extensions)
// We create new protocol message from the old one, but with a new instance of relay request data.
protocolMessage := chainlib.NewProtocolMessage(chainMessage, nil, relayRequestData, userData.DappId, userData.ConsumerIp)
relayProcessorDataReliability := NewRelayProcessor(ctx, relayProcessor.usedProviders, 1, chainMessage, rpccs.consumerConsistency, rpccs.debugRelays, rpccs.rpcConsumerLogs, rpccs, rpccs.disableNodeErrorRetry, rpccs.relayRetriesManager)
err := rpccs.sendRelayToProvider(ctx, protocolMessage, relayProcessorDataReliability, nil)
Expand Down

0 comments on commit 95cdfc6

Please sign in to comment.