Marshal to custom message to JSON to see Beholder logs in Loki

Author: skudasov

go.mod

@@ -13,6 +13,7 @@ require (
 	github.com/go-json-experiment/json v0.0.0-20231102232822-2e55bd4e08b0
 	github.com/go-playground/validator/v10 v10.4.1
 	github.com/go-viper/mapstructure/v2 v2.1.0
+	github.com/golang/protobuf v1.5.4
 	github.com/google/go-cmp v0.6.0
 	github.com/google/uuid v1.6.0
 	github.com/grpc-ecosystem/go-grpc-middleware/providers/prometheus v1.0.1
@@ -81,7 +82,6 @@ require (
 	github.com/go-playground/universal-translator v0.17.0 // indirect
 	github.com/goccy/go-json v0.10.3 // indirect
 	github.com/goccy/go-yaml v1.12.0 // indirect
-	github.com/golang/protobuf v1.5.4 // indirect
 	github.com/golang/snappy v0.0.5-0.20220116011046-fa5810519dcb // indirect
 	github.com/google/flatbuffers v24.3.25+incompatible // indirect
 	github.com/grpc-ecosystem/go-grpc-middleware/v2 v2.1.0 // indirect

pkg/custmsg/custom_message.go

@@ -1,12 +1,12 @@
 package custmsg
 
 import (
+	"bytes"
 	"context"
 	"fmt"
 	"maps"
 
-	"google.golang.org/protobuf/proto"
-
+	"github.com/golang/protobuf/jsonpb"
 	"github.com/smartcontractkit/chainlink-common/pkg/beholder"
 	"github.com/smartcontractkit/chainlink-common/pkg/beholder/pb"
 )
@@ -99,18 +99,21 @@ func sendLogAsCustomMessageW(ctx context.Context, msg string, labels map[string]
 	//if err != nil {
 	//	return fmt.Errorf("could not wrap labels to map: %w", err)
 	//}
-
 	// Define a custom protobuf payload to emit
 	payload := &pb.BaseMessage{
 		Msg:    msg,
 		Labels: labels,
 	}
-	payloadBytes, err := proto.Marshal(payload)
+
+	// We marshal to JSON so we can read these messages in Loki
+	marshaler := &jsonpb.Marshaler{}
+	var buf bytes.Buffer
+	err := marshaler.Marshal(&buf, payload)
 	if err != nil {
-		return fmt.Errorf("sending custom message failed to marshal protobuf: %w", err)
+		return fmt.Errorf("sending custom message failed to marshal to JSON: %w", err)
 	}
 
-	err = beholder.GetEmitter().Emit(ctx, payloadBytes,
+	err = beholder.GetEmitter().Emit(ctx, buf.Bytes(),
 		"beholder_data_schema", "/beholder-base-message/versions/1", // required
 		"beholder_domain", "platform", // required
 		"beholder_entity", "BaseMessage", // required