refactor: add integration/notifier to workspace, tidy unused code in …

…input (#637)
turbot · Feb 7, 2024 · e330d56 · e330d56
1 parent 3a4fb9e
commit e330d56
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/internal/primitive/input.go b/internal/primitive/input.go
@@ -28,11 +28,6 @@ import (
 
 type IntegrationType string
 
-const (
-	IntegrationTypeSlack IntegrationType = "slack"
-	IntegrationTypeEmail IntegrationType = "email"
-)
-
 type Input struct {
 	ExecutionID         string
 	PipelineExecutionID string

diff --git a/internal/primitive/input_test.go b/internal/primitive/input_test.go
@@ -54,7 +54,7 @@ func XXXTestIntegrationInputSendEmail(t *testing.T) {
 	input := modconfig.Input(map[string]interface{}{
 		// schema.AttributeTypeSenderName: "Karan",
 
-		schema.AttributeTypeType:       IntegrationTypeEmail,
+		schema.AttributeTypeType:       schema.IntegrationTypeEmail,
 		schema.AttributeTypeUsername:   "[email protected]",
 		schema.AttributeTypePassword:   "xxxxxx",
 		schema.AttributeTypeSmtpServer: "smtp.gmail.com",

diff --git a/internal/service/manager/manager.go b/internal/service/manager/manager.go
@@ -264,7 +264,12 @@ func (m *Manager) initializeResources() error {
 			cache.GetCache().SetWithTTL("#flowpipeconfig", flowpipeConfig, 24*7*52*99*time.Hour)
 		}
 
-		w, errorAndWarning := workspace.LoadWorkspacePromptingForVariables(m.ctx, modLocation, workspace.WithCredentials(flowpipeConfig.Credentials))
+		w, errorAndWarning := workspace.LoadWorkspacePromptingForVariables(
+			m.ctx,
+			modLocation,
+			workspace.WithCredentials(flowpipeConfig.Credentials),
+			workspace.WithIntegrations(flowpipeConfig.Integrations),
+			workspace.WithNotifiers(flowpipeConfig.Notifiers))
 		if errorAndWarning.Error != nil {
 			return errorAndWarning.Error
 		}