fix(chainlib): skip WS relay signature verification for static providers (#2153)

Use ConsumerSessionManager static-provider flag (no bech32 heuristic) and add helper IsStaticProvider().

Author: AnnaR-prog

protocol/chainlib/consumer_ws_subscription_manager.go

@@ -561,13 +561,23 @@ func (cwsm *ConsumerWSSubscriptionManager) verifySubscriptionMessage(hashedParam
 	lavaprotocol.UpdateRequestedBlock(request.RelayData, reply) // update relay request requestedBlock to the provided one in case it was arbitrary
 	filteredHeaders, _, ignoredHeaders := cwsm.chainParser.HandleHeaders(reply.Metadata, chainMessage.GetApiCollection(), spectypes.Header_pass_reply)
 	reply.Metadata = filteredHeaders
-	err := lavaprotocol.VerifyRelayReply(context.Background(), reply, request, providerAddr)
-	if err != nil {
-		return utils.LavaFormatError("Failed VerifyRelayReply on subscription message", err,
-			utils.LogAttr("subscriptionMsg", reply.Data),
-			utils.LogAttr("hashedParams", hashedParams),
-			utils.LogAttr("originalRequest", request),
-		)
+
+	// For static providers, skip signature verification (similar to regular RPC calls)
+	// Use the explicit flag from the session manager rather than heuristics based on address formatting.
+	isStaticProvider := false
+	if cwsm.consumerSessionManager != nil {
+		isStaticProvider = cwsm.consumerSessionManager.IsStaticProvider(providerAddr)
+	}
+
+	if !isStaticProvider {
+		err := lavaprotocol.VerifyRelayReply(context.Background(), reply, request, providerAddr)
+		if err != nil {
+			return utils.LavaFormatError("Failed VerifyRelayReply on subscription message", err,
+				utils.LogAttr("subscriptionMsg", reply.Data),
+				utils.LogAttr("hashedParams", hashedParams),
+				utils.LogAttr("originalRequest", request),
+			)
+		}
 	}
 
 	reply.Metadata = append(reply.Metadata, ignoredHeaders...)

protocol/lavasession/consumer_session_manager.go

@@ -1630,6 +1630,24 @@ func NewConsumerSessionManager(
 	return csm
 }
 
+// IsStaticProvider returns true if the given provider address belongs to a static provider in the current session manager state.
+// If the provider is unknown, it returns false.
+func (csm *ConsumerSessionManager) IsStaticProvider(providerAddress string) bool {
+	csm.lock.RLock()
+	defer csm.lock.RUnlock()
+
+	if cswp, ok := csm.pairing[providerAddress]; ok {
+		return cswp.StaticProvider
+	}
+	if cswp, ok := csm.backupProviders[providerAddress]; ok {
+		return cswp.StaticProvider
+	}
+	if cswp, ok := csm.pairingPurge[providerAddress]; ok {
+		return cswp.StaticProvider
+	}
+	return false
+}
+
 // SetLavaBlockHeightCallback sets the callback function to get current Lava blockchain block height
 // This must be called after creating the ConsumerSessionManager
 func (csm *ConsumerSessionManager) SetLavaBlockHeightCallback(getLavaBlockHeight func() int64) {