chore: add source id to register events request (#915)

Signed-off-by: Alessandro Yuichi Okimoto <yuichijpn@gmail.com>
bucketeer-io · Apr 15, 2024 · d09e2dd · d09e2dd
1 parent f87a0c9
commit d09e2dd
Show file tree

Hide file tree

Showing 6 changed files with 47 additions and 26 deletions.
diff --git a/manifests/bucketeer/charts/api-gateway/values.yaml b/manifests/bucketeer/charts/api-gateway/values.yaml
diff --git a/pkg/gateway/api/api_grpc.go b/pkg/gateway/api/api_grpc.go
@@ -864,6 +864,7 @@ func (s *grpcGatewayService) RegisterEvents(
 			log.FieldsFromImcomingContext(ctx).AddFields(
 				zap.Error(err),
 				zap.Any("events", req.Events),
+				zap.Any("sourceId", req.SourceId),
 				zap.String("sdkVersion", req.SdkVersion),
 			)...,
 		)
@@ -873,6 +874,7 @@ func (s *grpcGatewayService) RegisterEvents(
 		s.logger.Error("Failed to validate RegisterEvents request. Missing events.",
 			log.FieldsFromImcomingContext(ctx).AddFields(
 				zap.Error(err),
+				zap.Any("sourceId", req.SourceId),
 				zap.String("sdkVersion", req.SdkVersion),
 			)...,
 		)

diff --git a/proto/gateway/proto_descriptor.pb b/proto/gateway/proto_descriptor.pb
diff --git a/proto/gateway/service.pb.go b/proto/gateway/service.pb.go
diff --git a/proto/gateway/service.proto b/proto/gateway/service.proto
@@ -64,6 +64,7 @@ message GetEvaluationResponse {
 message RegisterEventsRequest {
   repeated bucketeer.event.client.Event events = 1;
   string sdk_version = 2;
+  bucketeer.event.client.SourceId source_id = 3;
 }
 
 message RegisterEventsResponse {

diff --git a/proto/proto.lock b/proto/proto.lock
@@ -14986,6 +14986,11 @@
                 "id": 2,
                 "name": "sdk_version",
                 "type": "string"
+              },
+              {
+                "id": 3,
+                "name": "source_id",
+                "type": "bucketeer.event.client.SourceId"
               }
             ]
           },