From 86cc9240bd12b551477e958b7b32d23f27bd2b55 Mon Sep 17 00:00:00 2001 From: Bryan Frimin Date: Sat, 19 Apr 2025 20:42:21 -0700 Subject: [PATCH] Add connector request validation Signed-off-by: Bryan Frimin --- pkg/probo/connector_service.go | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/pkg/probo/connector_service.go b/pkg/probo/connector_service.go index 2cd676adc..9decc280f 100644 --- a/pkg/probo/connector_service.go +++ b/pkg/probo/connector_service.go @@ -39,6 +39,22 @@ type ( ) func (s *ConnectorService) CreateOrUpdate(ctx context.Context, req CreateOrUpdateConnectorRequest) (*coredata.Connector, error) { + if req.OrganizationID == gid.Nil { + return nil, fmt.Errorf("organization ID is required") + } + + if req.Name == "" { + return nil, fmt.Errorf("connector name is required") + } + + if req.Type == "" { + return nil, fmt.Errorf("connector type is required") + } + + if req.Connection == nil { + return nil, fmt.Errorf("connection configuration is required") + } + connectorID, err := gid.NewGID(s.svc.scope.GetTenantID(), coredata.ConnectorEntityType) if err != nil { return nil, fmt.Errorf("cannot create connector global id: %w", err)