feat: PRT Block Hash Retry Archive After Redesign Part 2 - Add Archive logic to CRSM

.github/workflows/lava.yml

@@ -305,6 +305,47 @@ jobs:
   #         name: SDK E2E Logs
   #         path: "testutil/e2e/sdkLogs/*"
 
+# This part came from lava_sdk_tests.yml that was removed. just not to lose functionality it moved here.
+# name: Lava SDK Tests
+
+# on: 
+#   pull_request
+
+# jobs:
+#   main:
+#     runs-on: ubuntu-latest
+#     steps:
+#       - name: Checkout code
+#         uses: actions/checkout@v4
+
+#       - name: Cache dependencies
+#         uses: actions/cache@v4
+#         with:
+#           path: ~/.yarn
+#           key: yarn-${{ hashFiles('yarn.lock') }}
+#           restore-keys: yarn-
+
+#       - uses: actions/setup-go@v5
+#         with:
+#           go-version: "1.20.5"
+
+#       - uses: actions/setup-node@v4
+#         with:
+#           node-version: "21.2.0"
+
+#       - name: Init the SDK
+#         run: GOPATH=~/go ./scripts/init_sdk.sh -s
+#         working-directory: ./ecosystem/lava-sdk
+
+#       - name: ESLint
+#         run: ./node_modules/.bin/eslint '**/*.ts'
+#         working-directory: ./ecosystem/lava-sdk
+
+#       - name: Test
+#         run: ./node_modules/.bin/jest ./src --ci
+#         working-directory: ./ecosystem/lava-sdk
+
+
   test-payment-e2e:
     runs-on: ubuntu-latest
     steps:

protocol/chainlib/chainlib.go

@@ -124,7 +124,6 @@ type RelaySender interface {
 		connectionType string,
 		dappID string,
 		consumerIp string,
-		analytics *metrics.RelayMetrics,
 		metadata []pairingtypes.Metadata,
 	) (ProtocolMessage, error)
 	SendParsedRelay(

protocol/chainlib/consumer_websocket_manager.go

@@ -218,7 +218,7 @@ func (cwm *ConsumerWebsocketManager) ListenToMessages() {
 
 		metricsData := metrics.NewRelayAnalytics(dappID, cwm.chainId, cwm.apiInterface)
 
-		protocolMessage, err := cwm.relaySender.ParseRelay(webSocketCtx, "", string(msg), cwm.connectionType, dappID, userIp, metricsData, nil)
+		protocolMessage, err := cwm.relaySender.ParseRelay(webSocketCtx, "", string(msg), cwm.connectionType, dappID, userIp, nil)
 		if err != nil {
 			utils.LavaFormatDebug("ws manager could not parse message", utils.LogAttr("message", msg), utils.LogAttr("err", err))
 			formatterMsg := logger.AnalyzeWebSocketErrorAndGetFormattedMessage(websocketConn.LocalAddr().String(), err, msgSeed, msg, cwm.apiInterface, time.Since(startTime))

protocol/chainlib/consumer_ws_subscription_manager.go

@@ -697,7 +697,7 @@ func (cwsm *ConsumerWSSubscriptionManager) craftUnsubscribeMessage(hashedParams,
 
 	// Craft the unsubscribe chain message
 	ctx := context.Background()
-	protocolMessage, err := cwsm.relaySender.ParseRelay(ctx, "", unsubscribeRequestData, cwsm.connectionType, dappID, consumerIp, metricsData, nil)
+	protocolMessage, err := cwsm.relaySender.ParseRelay(ctx, "", unsubscribeRequestData, cwsm.connectionType, dappID, consumerIp, nil)
 	if err != nil {
 		return nil, utils.LavaFormatError("could not craft unsubscribe chain message", err,
 			utils.LogAttr("hashedParams", utils.ToHexString(hashedParams)),

protocol/chainlib/consumer_ws_subscription_manager_test.go

@@ -88,7 +88,7 @@ func TestConsumerWSSubscriptionManagerParallelSubscriptionsOnSameDappIdIp(t *tes
 
 			relaySender.
 				EXPECT().
-				ParseRelay(gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any()).
+				ParseRelay(gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any()).
 				Return(protocolMessage1, nil).
 				AnyTimes()
 
@@ -244,7 +244,7 @@ func TestConsumerWSSubscriptionManagerParallelSubscriptions(t *testing.T) {
 
 			relaySender.
 				EXPECT().
-				ParseRelay(gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any()).
+				ParseRelay(gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any()).
 				Return(protocolMessage1, nil).
 				AnyTimes()
 
@@ -484,7 +484,7 @@ func TestConsumerWSSubscriptionManager(t *testing.T) {
 					require.True(t, ok)
 					areEqual := reqData == string(play.unsubscribeMessage1)
 					return areEqual
-				}), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any()).
+				}), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any()).
 				Return(unsubscribeProtocolMessage1, nil).
 				AnyTimes()
 
@@ -495,7 +495,7 @@ func TestConsumerWSSubscriptionManager(t *testing.T) {
 					require.True(t, ok)
 					areEqual := reqData == string(play.subscriptionRequestData1)
 					return areEqual
-				}), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any()).
+				}), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any()).
 				Return(subscribeProtocolMessage1, nil).
 				AnyTimes()
 
@@ -600,7 +600,7 @@ func TestConsumerWSSubscriptionManager(t *testing.T) {
 					require.True(t, ok)
 					areEqual := reqData == string(play.unsubscribeMessage2)
 					return areEqual
-				}), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any()).
+				}), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any()).
 				Return(unsubscribeProtocolMessage2, nil).
 				AnyTimes()
 
@@ -611,7 +611,7 @@ func TestConsumerWSSubscriptionManager(t *testing.T) {
 					require.True(t, ok)
 					areEqual := reqData == string(play.subscriptionRequestData2)
 					return areEqual
-				}), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any()).
+				}), gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any()).
 				Return(subscribeProtocolMessage2, nil).
 				AnyTimes()
 

protocol/chainlib/extensionslib/extension_parser.go

@@ -4,6 +4,8 @@ import (
 	spectypes "github.com/lavanet/lava/v4/x/spec/types"
 )
 
+const ArchiveExtension = "archive"
+
 type ExtensionInfo struct {
 	ExtensionOverride    []string
 	LatestBlock          uint64
@@ -84,7 +86,7 @@ func (ep *ExtensionParser) ExtensionParsing(addon string, extensionsChainMessage
 
 func NewExtensionParserRule(extension *spectypes.Extension) ExtensionParserRule {
 	switch extension.Name {
-	case "archive":
+	case ArchiveExtension:
 		return ArchiveParserRule{extension: extension}
 	default:
 		// unsupported rule