diff --git a/pkg/trust/slack_message_service.go b/pkg/trust/slack_message_service.go index 180480595..9f2e61043 100644 --- a/pkg/trust/slack_message_service.go +++ b/pkg/trust/slack_message_service.go @@ -240,6 +240,28 @@ func (s *SlackMessageService) QueueSlackNotification( return fmt.Errorf("cannot load trust center: %w", err) } + var connectors coredata.Connectors + if err := connectors.LoadAllByOrganizationIDWithoutDecryptedConnection( + ctx, + tx, + s.svc.scope, + trustCenter.OrganizationID, + ); err != nil { + return fmt.Errorf("cannot load connectors: %w", err) + } + + hasSlackConnector := false + for _, connector := range connectors { + if connector.Provider == coredata.ConnectorProviderSlack { + hasSlackConnector = true + break + } + } + + if !hasSlackConnector { + return fmt.Errorf("no slack connector found for organization") + } + documents, reports, err := s.loadDocumentsAndReportsFromAccesses(ctx, tx, trustCenterAccess.ID) if err != nil { return fmt.Errorf("cannot load documents and reports: %w", err)