Pull latest code-protobuf-api

Author: jeffyanta

go.mod

@@ -5,7 +5,7 @@ go 1.23.0
 require (
 	github.com/aws/aws-sdk-go-v2 v0.17.0
 	github.com/bits-and-blooms/bloom/v3 v3.1.0
-	github.com/code-payments/code-protobuf-api v1.19.1-0.20250409171630-fb01c98ecd86
+	github.com/code-payments/code-protobuf-api v1.19.1-0.20250416185804-64d2132a62f2
 	github.com/code-payments/code-vm-indexer v0.1.11-0.20241028132209-23031e814fba
 	github.com/emirpasic/gods v1.12.0
 	github.com/envoyproxy/protoc-gen-validate v1.2.1

go.sum

@@ -78,8 +78,8 @@ github.com/cncf/udpa/go v0.0.0-20200629203442-efcf912fb354/go.mod h1:WmhPx2Nbnht
 github.com/cncf/udpa/go v0.0.0-20201120205902-5459f2c99403/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk=
 github.com/cockroachdb/apd v1.1.0 h1:3LFP3629v+1aKXU5Q37mxmRxX/pIu1nijXydLShEq5I=
 github.com/cockroachdb/apd v1.1.0/go.mod h1:8Sl8LxpKi29FqWXR16WEFZRNSz3SoPzUzeMeY4+DwBQ=
-github.com/code-payments/code-protobuf-api v1.19.1-0.20250409171630-fb01c98ecd86 h1:Lv+DODC5j/zvzx+CfL8tlpw0GCHXpEwW/ICPXze3jTY=
-github.com/code-payments/code-protobuf-api v1.19.1-0.20250409171630-fb01c98ecd86/go.mod h1:ee6TzKbgMS42ZJgaFEMG3c4R3dGOiffHSu6MrY7WQvs=
+github.com/code-payments/code-protobuf-api v1.19.1-0.20250416185804-64d2132a62f2 h1:L2nVJRDyqbfx9DUUD7B0Es9JICjdwCjrJOdtmxNwAcs=
+github.com/code-payments/code-protobuf-api v1.19.1-0.20250416185804-64d2132a62f2/go.mod h1:ee6TzKbgMS42ZJgaFEMG3c4R3dGOiffHSu6MrY7WQvs=
 github.com/code-payments/code-vm-indexer v0.1.11-0.20241028132209-23031e814fba h1:Bkp+gmeb6Y2PWXfkSCTMBGWkb2P1BujRDSjWeI+0j5I=
 github.com/code-payments/code-vm-indexer v0.1.11-0.20241028132209-23031e814fba/go.mod h1:jSiifpiBpyBQ8q2R0MGEbkSgWC6sbdRTyDBntmW+j1E=
 github.com/containerd/continuity v0.0.0-20190827140505-75bee3e2ccb6 h1:NmTXa/uVnDyp0TY5MKi197+3HWcnYWfnHGyaFthlnGw=

pkg/code/server/messaging/server.go

@@ -497,15 +497,6 @@ func (s *server) OpenMessageStream(req *messagingpb.OpenMessageStreamRequest, st
 				return status.Error(codes.Aborted, "")
 			}
 
-			// Currently only support streams that have short lifespans in terms
-			// of key validity and length of time opened. Current implementation
-			// might be ok, but we should be thoughtful of any additional edge cases
-			// that might arise.
-			switch msg.Kind.(type) {
-			case *messagingpb.Message_AirdropReceived:
-				continue
-			}
-
 			err := streamer.Send(&messagingpb.OpenMessageStreamResponse{
 				Messages: []*messagingpb.Message{msg},
 			})
@@ -698,13 +689,6 @@ func (s *server) SendMessage(ctx context.Context, req *messagingpb.SendMessageRe
 	case *messagingpb.Message_WebhookCalled:
 		return nil, status.Error(codes.InvalidArgument, "message.kind cannot be webhook_called")
 
-	//
-	// Section: Airdrops
-	//
-
-	case *messagingpb.Message_AirdropReceived:
-		return nil, status.Error(codes.InvalidArgument, "message.kind cannot be airdrop_received")
-
 	default:
 		return nil, status.Error(codes.InvalidArgument, "message.kind must be set")
 	}