Proxy SCW validation requests to our MLS service (#407)

* wip

* finish proxying

pkg/identity/api/v1/identity_service.go

@@ -6,6 +6,7 @@ import (
 	mlsstore "github.com/xmtp/xmtp-node-go/pkg/mls/store"
 	"github.com/xmtp/xmtp-node-go/pkg/mlsvalidate"
 	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"
 )
 
@@ -97,3 +98,7 @@ func (s *Service) GetInboxIds(ctx context.Context, req *api.GetInboxIdsRequest)
 	*/
 	return s.store.GetInboxIds(ctx, req)
 }
+
+func (s *Service) VerifySmartContractWalletSignatures(ctx context.Context, req *identity.VerifySmartContractWalletSignaturesRequest) (*identity.VerifySmartContractWalletSignaturesResponse, error) {
+	return s.validationService.VerifySmartContractWalletSignatures(ctx, req)
+}

pkg/identity/api/v1/identity_service_test.go

@@ -55,6 +55,12 @@ func (m *mockedMLSValidationService) ValidateInboxIdKeyPackages(ctx context.Cont
 	return nil, nil
 }
 
+func (m *mockedMLSValidationService) VerifySmartContractWalletSignatures(ctx context.Context, req *identity.VerifySmartContractWalletSignaturesRequest) (*identity.VerifySmartContractWalletSignaturesResponse, error) {
+	args := m.Called(ctx, req)
+
+	return args.Get(0).(*identity.VerifySmartContractWalletSignaturesResponse), args.Error(1)
+}
+
 func newMockedValidationService() *mockedMLSValidationService {
 	return new(mockedMLSValidationService)
 }

pkg/mlsvalidate/service.go

@@ -45,6 +45,7 @@ type MLSValidationService interface {
 	ValidateV3KeyPackages(ctx context.Context, keyPackages [][]byte) ([]IdentityValidationResult, error)
 	ValidateGroupMessages(ctx context.Context, groupMessages []*mlsv1.GroupMessageInput) ([]GroupMessageValidationResult, error)
 	GetAssociationState(ctx context.Context, oldUpdates []*associations.IdentityUpdate, newUpdates []*associations.IdentityUpdate) (*AssociationStateResult, error)
+	VerifySmartContractWalletSignatures(ctx context.Context, req *identity.VerifySmartContractWalletSignaturesRequest) (*identity.VerifySmartContractWalletSignaturesResponse, error)
 }
 
 type IdentityStore interface {
@@ -178,3 +179,7 @@ func makeValidateGroupMessagesRequest(groupMessages []*mlsv1.GroupMessageInput)
 		GroupMessages: groupMessageRequests,
 	}
 }
+
+func (s *MLSValidationServiceImpl) VerifySmartContractWalletSignatures(ctx context.Context, req *identity.VerifySmartContractWalletSignaturesRequest) (*identity.VerifySmartContractWalletSignaturesResponse, error) {
+	return s.grpcClient.VerifySmartContractWalletSignatures(ctx, req)
+}

pkg/mlsvalidate/service_test.go

@@ -6,6 +6,7 @@ import (
 
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/mock"
+	identity "github.com/xmtp/xmtp-node-go/pkg/proto/identity/api/v1"
 	svc "github.com/xmtp/xmtp-node-go/pkg/proto/mls_validation/v1"
 	"google.golang.org/grpc"
 )
@@ -42,6 +43,12 @@ func (m *MockedGRPCService) ValidateInboxIds(ctx context.Context, req *svc.Valid
 	return args.Get(0).(*svc.ValidateInboxIdsResponse), args.Error(1)
 }
 
+func (m *MockedGRPCService) VerifySmartContractWalletSignatures(ctx context.Context, req *identity.VerifySmartContractWalletSignaturesRequest, opts ...grpc.CallOption) (*identity.VerifySmartContractWalletSignaturesResponse, error) {
+	args := m.Called(ctx, req)
+
+	return args.Get(0).(*identity.VerifySmartContractWalletSignaturesResponse), args.Error(1)
+}
+
 func getMockedService() (*MockedGRPCService, MLSValidationService) {
 	mockService := new(MockedGRPCService)
 	service := &MLSValidationServiceImpl{