Scaffold: FlowpipeConfig filewatcher (#701)

internal/es/db/index.go

@@ -161,7 +161,9 @@ func GetFlowpipeConfig() (*flowpipeconfig.FlowpipeConfig, error) {
 	flowpipeConfigCached, found := cache.GetCache().Get("#flowpipeconfig")
 
 	if !found {
-		return flowpipeconfig.NewFlowpipeConfig(), nil
+		// TODO: if we return an error all our "non mod based test" fail
+		// return nil, perr.BadRequestWithMessage("flowpipe config not found")
+		return &flowpipeconfig.FlowpipeConfig{}, nil
 	}
 
 	flowpipeConfig, ok := flowpipeConfigCached.(*flowpipeconfig.FlowpipeConfig)

internal/service/manager/manager.go

@@ -216,6 +216,20 @@ func (m *Manager) initializeResources() error {
 			cache.GetCache().SetWithTTL("#flowpipeconfig", flowpipeConfig, 24*7*52*99*time.Hour)
 		}
 
+		err = m.cacheConfigData()
+		if err != nil {
+			return err
+		}
+
+		if m.shouldStartAPI() {
+			err := flowpipeConfig.SetupWatcher(context.TODO(), func(c context.Context, e error) {
+
+			})
+			if err != nil {
+				return err
+			}
+		}
+
 		w, errorAndWarning := workspace.LoadWorkspacePromptingForVariables(
 			m.ctx,
 			modLocation,
@@ -275,11 +289,6 @@ func (m *Manager) initializeResources() error {
 		return err
 	}
 
-	err = m.cacheConfigData()
-	if err != nil {
-		return err
-	}
-
 	slog.Info("Pipelines and triggers loaded", "pipelines", len(pipelines), "triggers", len(triggers), "rootMod", rootModName)
 
 	m.RootMod = mod