feat(sentry): Trim high cardinality strings (#26)

* feat(sentry): Trim high cardinatlity strings

* feat(sentry): Trim high cardinatlity strings

pkg/proto/eth/v1/conversion.go

@@ -25,3 +25,11 @@ func BLSSignatureToString(s *phase0.BLSSignature) string {
 func BytesToString(b []byte) string {
 	return fmt.Sprintf("%#x", b)
 }
+
+func TrimmedString(s string) string {
+	if len(s) <= 12 {
+		return s
+	}
+
+	return s[:5] + "..." + s[len(s)-5:]
+}

pkg/proto/eth/v1/conversion_test.go

@@ -0,0 +1,50 @@
+package v1
+
+import "testing"
+
+func TestTrimmedString(t *testing.T) {
+	tests := []struct {
+		name string
+		s    string
+		want string
+	}{
+		{
+			name: "Empty",
+			s:    "",
+			want: "",
+		},
+		{
+			name: "Short",
+			s:    "abc",
+			want: "abc",
+		},
+		{
+			name: "Long",
+			s:    "abcdefg",
+			want: "abcdefg",
+		},
+		{
+			name: "Longer",
+			s:    "abcdefghijk",
+			want: "abcdefghijk",
+		},
+		{
+			name: "Longer-trimmed",
+			s:    "abcdefghijklmno",
+			want: "abcde...klmno",
+		},
+		{
+			name: "hex-trimmed",
+			s:    "0xfd3963b996723a6055b3323014c4de94345a7b519b17758b386d6b57a1a16b6d",
+			want: "0xfd3...16b6d",
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			if got := TrimmedString(tt.s); got != tt.want {
+				t.Errorf("TrimmedString() = %v, want %v", got, tt.want)
+			}
+		})
+	}
+}

pkg/sentry/event_attestation.go

@@ -58,7 +58,7 @@ func (s *Sentry) handleAttestation(ctx context.Context, event *phase0.Attestatio
 						Root:  xatuethv1.RootAsString(event.Data.Target.Root),
 					},
 				},
-				Signature: fmt.Sprintf("%#x", event.Signature),
+				Signature: xatuethv1.TrimmedString(fmt.Sprintf("%#x", event.Signature)),
 			},
 		},
 	}

pkg/sentry/event_contribution_and_proof.go

@@ -41,15 +41,15 @@ func (s *Sentry) handleContributionAndProof(ctx context.Context, event *altair.S
 		},
 		Data: &xatu.DecoratedEvent_EthV1ContributionAndProof{
 			EthV1ContributionAndProof: &xatuethv1.EventContributionAndProof{
-				Signature: xatuethv1.BLSSignatureToString(&event.Signature),
+				Signature: xatuethv1.TrimmedString(xatuethv1.BLSSignatureToString(&event.Signature)),
 				Message: &xatuethv1.ContributionAndProof{
 					AggregatorIndex: uint64(event.Message.AggregatorIndex),
-					SelectionProof:  xatuethv1.BLSSignatureToString(&event.Message.SelectionProof),
+					SelectionProof:  xatuethv1.TrimmedString(xatuethv1.BLSSignatureToString(&event.Message.SelectionProof)),
 					Contribution: &xatuethv1.ContributionAndProof_SyncCommitteeContribution{
 						Slot:              uint64(event.Message.Contribution.Slot),
 						SubcommitteeIndex: event.Message.Contribution.SubcommitteeIndex,
 						AggregationBits:   xatuethv1.BytesToString(event.Message.Contribution.AggregationBits.Bytes()),
-						Signature:         xatuethv1.BLSSignatureToString(&event.Message.Contribution.Signature),
+						Signature:         xatuethv1.TrimmedString(xatuethv1.BLSSignatureToString(&event.Message.Contribution.Signature)),
 						BeaconBlockRoot:   xatuethv1.RootAsString(event.Message.Contribution.BeaconBlockRoot),
 					},
 				},