feat: default integration/notifier files

internal/cmdconfig/init.go

@@ -3,10 +3,15 @@ package cmdconfig
 import (
 	"maps"
 	"os"
+	"path/filepath"
+	"time"
 
 	"github.com/spf13/cobra"
 	"github.com/spf13/viper"
+	con "github.com/turbot/flowpipe/internal/constants"
 	"github.com/turbot/flowpipe/internal/log"
+	"github.com/turbot/go-kit/files"
+	"github.com/turbot/pipe-fittings/app_specific"
 	"github.com/turbot/pipe-fittings/cmdconfig"
 	"github.com/turbot/pipe-fittings/constants"
 	"github.com/turbot/pipe-fittings/error_helpers"
@@ -16,6 +21,9 @@ import (
 )
 
 func initGlobalConfig() *flowpipeconfig.FlowpipeConfig {
+	// check defaults prior to loading into workspace
+	defaultIntegrationNotifierFiles()
+
 	// load workspace profile from the configured install dir
 	loader, err := cmdconfig.GetWorkspaceProfileLoader[*modconfig.FlowpipeWorkspaceProfile]()
 	error_helpers.FailOnError(err)
@@ -77,3 +85,23 @@ func getConfigDefaults(cmd *cobra.Command) map[string]any {
 	}
 	return res
 }
+
+func defaultIntegrationNotifierFiles() {
+	installPath := app_specific.DefaultInstallDir
+	// configPath := strings.Split(app_specific.DefaultConfigPath, ":")[len(strings.Split(app_specific.DefaultConfigPath, ":"))-1]
+	configPath := filepath.Join(installPath, "config")
+	internalStateFile := filepath.Join(installPath, "internal", ".webform_initialized")
+	integrationFile := filepath.Join(configPath, "integrations.fpc")
+	notifierFile := filepath.Join(configPath, "notifiers.fpc")
+	if !files.FileExists(internalStateFile) {
+		if !files.FileExists(integrationFile) {
+			_ = os.WriteFile(integrationFile, []byte(con.DefaultFlowpipeIntegrationContent), 0755)
+		}
+		if !files.FileExists(notifierFile) {
+			_ = os.WriteFile(notifierFile, []byte(con.DefaultFlowpipeNotifierContent), 0755)
+		}
+
+		ts := time.Now().Format(time.RFC3339)
+		_ = os.WriteFile(internalStateFile, []byte(ts), 0755)
+	}
+}

internal/constants/constants.go

@@ -14,3 +14,15 @@ const (
 
 	MaxScanSize = bufio.MaxScanTokenSize * 40
 )
+
+const DefaultFlowpipeIntegrationContent = `
+integration "webform" "default" {}
+`
+
+const DefaultFlowpipeNotifierContent = `
+notifier "default" {
+  integration "default" {
+    base = integration.webform.default 
+  }
+}
+`