stub out new service

dev/generate

@@ -6,7 +6,7 @@ go generate ./...
 # Generate mocks
 mockery
 rm -rf pkg/proto/**/*.pb.go pkg/proto/**/*.pb.gw.go pkg/proto/**/*.swagger.json
-if ! buf generate https://github.com/xmtp/proto.git#branch=main,subdir=proto; then
+if ! buf generate https://github.com/xmtp/proto.git#branch=nm/add-association-stream,subdir=proto; then
     echo "Failed to generate protobuf definitions"
     exit 1
 fi

pkg/identity/api/v1/identity_service.go

@@ -8,6 +8,8 @@ import (
 	api "github.com/xmtp/xmtp-node-go/pkg/proto/identity/api/v1"
 	identity "github.com/xmtp/xmtp-node-go/pkg/proto/identity/api/v1"
 	"go.uber.org/zap"
+	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/status"
 )
 
 type Service struct {
@@ -102,3 +104,10 @@ func (s *Service) GetInboxIds(ctx context.Context, req *api.GetInboxIdsRequest)
 func (s *Service) VerifySmartContractWalletSignatures(ctx context.Context, req *identity.VerifySmartContractWalletSignaturesRequest) (*identity.VerifySmartContractWalletSignaturesResponse, error) {
 	return s.validationService.VerifySmartContractWalletSignatures(ctx, req)
 }
+
+func (s *Service) SubscribeAssociationChanges(req *identity.SubscribeAssociationChangesRequest, stream identity.IdentityApi_SubscribeAssociationChangesServer) error {
+	log := s.log.Named("subscribe-association-changes")
+	log.Info("subscription started")
+
+	return status.Errorf(codes.Unimplemented, "method SubscribeAssociationChanges not implemented")
+}