Only send message when organization has slack connector
Signed-off-by: Sacha Al Himdani <sacha@getprobo.com>
This commit is contained in:
@@ -240,6 +240,28 @@ func (s *SlackMessageService) QueueSlackNotification(
|
|||||||
return fmt.Errorf("cannot load trust center: %w", err)
|
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)
|
documents, reports, err := s.loadDocumentsAndReportsFromAccesses(ctx, tx, trustCenterAccess.ID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("cannot load documents and reports: %w", err)
|
return fmt.Errorf("cannot load documents and reports: %w", err)
|
||||||
|
|||||||
Reference in New Issue
Block a user