Adding kv pairs to metadata now only happens if client is in grpc mode

smartcontractkit · Jun 11, 2024 · bd6865b · bd6865b
1 parent e6773d3
commit bd6865b
Showing 1 changed file with 12 additions and 8 deletions.
diff --git a/core/services/relay/evm/mercury/wsrpc/client.go b/core/services/relay/evm/mercury/wsrpc/client.go
@@ -384,11 +384,13 @@ func (w *client) Transmit(ctx context.Context, req *pb.TransmitRequest) (resp *p
 		return nil, errors.Wrap(err, "Transmit call failed")
 	}
 
-	signature, err := w.Sign(req)
-	if err != nil {
-		return nil, errors.Wrap(err, "Transmit call failed")
+	if w.tlsCertFile != nil {
+		signature, err := w.Sign(req)
+		if err != nil {
+			return nil, errors.Wrap(err, "Transmit call failed")
+		}
+		ctx = metadata.AppendToOutgoingContext(ctx, "csa-key", w.csaKey.PublicKeyString(), "signature", signature)
 	}
-	ctx = metadata.AppendToOutgoingContext(ctx, "csa-key", w.csaKey.PublicKeyString(), "signature", signature)
 	resp, err = w.rawClient.Transmit(ctx, req)
 	w.handleTimeout(err)
 	if err != nil {
@@ -442,11 +444,13 @@ func (w *client) LatestReport(ctx context.Context, req *pb.LatestReportRequest)
 		return nil, errors.Wrap(err, "LatestReport failed")
 	}
 
-	signature, err := w.Sign(req)
-	if err != nil {
-		return nil, errors.Wrap(err, "Transmit call failed")
+	if w.tlsCertFile != nil {
+		signature, err := w.Sign(req)
+		if err != nil {
+			return nil, errors.Wrap(err, "Transmit call failed")
+		}
+		ctx = metadata.AppendToOutgoingContext(ctx, "csa-key", w.csaKey.PublicKeyString(), "signature", signature)
 	}
-	ctx = metadata.AppendToOutgoingContext(ctx, "csa-key", w.csaKey.PublicKeyString(), "signature", signature)
 	var cached bool
 	if w.cache == nil {
 		resp, err = w.rawClient.LatestReport(ctx, req)