feat: If not already existant, create ftl-project.toml and/or module config or secret

common/configuration/manager_test.go

@@ -8,6 +8,7 @@ import (
 	"testing"
 
 	"github.com/alecthomas/assert/v2"
+	"github.com/alecthomas/types/optional"
 	"github.com/zalando/go-keyring"
 
 	"github.com/TBD54566975/ftl/internal/log"
@@ -54,6 +55,7 @@ func TestManager(t *testing.T) {
 			{Ref: Ref{Name: "baz"}, Accessor: URL("envar://baz")},
 			{Ref: Ref{Name: "foo"}, Accessor: URL("inline://ImJhciI")},
 			{Ref: Ref{Name: "mutable"}, Accessor: URL("inline://ImhlbGxvIg")},
+			{Ref: Ref{Module: optional.Some[string]("echo"), Name: "default"}, Accessor: URL("inline://ImFub255bW91cyI")},
 		})
 	})
 }

common/configuration/projectconfig_resolver.go

@@ -101,9 +101,9 @@ func (p ProjectConfigResolver[R]) getMapping(config pc.Config, module optional.O
 	get := func(dest pc.ConfigAndSecrets) map[string]*pc.URL {
 		switch any(k).(type) {
 		case Configuration:
-			return dest.Config
+			return emptyMapIfNil(dest.Config)
 		case Secrets:
-			return dest.Secrets
+			return emptyMapIfNil(dest.Secrets)
 		default:
 			panic("unsupported kind")
 		}
@@ -121,6 +121,13 @@ func (p ProjectConfigResolver[R]) getMapping(config pc.Config, module optional.O
 	return mapping, nil
 }
 
+func emptyMapIfNil(mapping map[string]*pc.URL) map[string]*pc.URL {
+	if mapping == nil {
+		return map[string]*pc.URL{}
+	}
+	return mapping
+}
+
 func (p ProjectConfigResolver[R]) setMapping(config pc.Config, module optional.Option[string], mapping map[string]*pc.URL) error {
 	var k R
 	set := func(dest *pc.ConfigAndSecrets, mapping map[string]*pc.URL) {
@@ -143,5 +150,8 @@ func (p ProjectConfigResolver[R]) setMapping(config pc.Config, module optional.O
 		set(&config.Global, mapping)
 	}
 	configPaths := pc.ConfigPaths(p.Config)
+	if len(configPaths) == 0 {
+		return pc.CreateAndSave(config)
+	}
 	return pc.Save(configPaths[len(configPaths)-1], config)
 }

common/configuration/projectconfig_resolver_test.go

@@ -0,0 +1,60 @@
+package configuration
+
+import (
+	"context"
+	"net/url"
+	"os"
+	"path/filepath"
+	"testing"
+
+	"github.com/alecthomas/assert/v2"
+	"github.com/alecthomas/types/optional"
+
+	"github.com/TBD54566975/ftl/common/projectconfig"
+	"github.com/TBD54566975/ftl/internal/log"
+)
+
+func TestSet(t *testing.T) {
+	defaultPath := projectconfig.GetDefaultConfigPath()
+	origConfigBytes, err := os.ReadFile(defaultPath)
+	assert.NoError(t, err)
+
+	config := filepath.Join(t.TempDir(), "ftl-project.toml")
+	existing, err := os.ReadFile("testdata/ftl-project.toml")
+	assert.NoError(t, err)
+	err = os.WriteFile(config, existing, 0600)
+	assert.NoError(t, err)
+
+	t.Run("ExistingModule", func(t *testing.T) {
+		setAndAssert(t, "echo", []string{config})
+	})
+	t.Run("NewModule", func(t *testing.T) {
+		setAndAssert(t, "echooo", []string{config})
+	})
+	t.Run("MissingTOMLFile", func(t *testing.T) {
+		err := os.Remove(config)
+		assert.NoError(t, err)
+		setAndAssert(t, "echooooo", []string{})
+		err = os.WriteFile(defaultPath, origConfigBytes, 0600)
+		assert.NoError(t, err)
+	})
+}
+
+func setAndAssert(t *testing.T, module string, config []string) {
+	ctx := log.ContextWithNewDefaultLogger(context.Background())
+
+	cf, err := New(ctx,
+		ProjectConfigResolver[Configuration]{Config: config},
+		[]Provider[Configuration]{
+			EnvarProvider[Configuration]{},
+			InlineProvider[Configuration]{Inline: true}, // Writer
+		})
+	assert.NoError(t, err)
+
+	var got *url.URL
+	want := URL("inline://asdfasdf")
+	cf.Set(ctx, Ref{Module: optional.Some[string](module), Name: "default"}, want)
+	err = cf.Get(ctx, Ref{Module: optional.Some[string](module), Name: "default"}, &got)
+	assert.NoError(t, err)
+	assert.Equal(t, want, got)
+}

common/configuration/testdata/ftl-project.toml

@@ -8,3 +8,8 @@ mutable = "keychain://mutable"
 baz = "envar://baz"
 foo = "inline://ImJhciI"
 mutable = "inline://ImhlbGxvIg"
+
+[modules]
+  [modules.echo]
+    [modules.echo.configuration]
+      default = "inline://ImFub255bW91cyI"

common/projectconfig/projectconfig.go

@@ -2,6 +2,7 @@ package projectconfig
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"os"
 	"path/filepath"
@@ -42,14 +43,18 @@ func ConfigPaths(input []string) []string {
 	if len(input) > 0 {
 		return input
 	}
-	path := filepath.Join(internal.GitRoot(""), "ftl-project.toml")
+	path := GetDefaultConfigPath()
 	_, err := os.Stat(path)
 	if err == nil {
 		return []string{path}
 	}
 	return []string{}
 }
 
+func GetDefaultConfigPath() string {
+	return filepath.Join(internal.GitRoot(""), "ftl-project.toml")
+}
+
 func LoadConfig(ctx context.Context, input []string) (Config, error) {
 	logger := log.FromContext(ctx)
 	configPaths := ConfigPaths(input)
@@ -92,6 +97,21 @@ func loadFile(path string) (Config, error) {
 	return config, nil
 }
 
+func CreateAndSave(config Config) error {
+	path := GetDefaultConfigPath()
+	_, err := os.Stat(path)
+	// Only create a new file if there isn't one already defined at this location
+	if err != nil && errors.Is(err, os.ErrNotExist) {
+		if err = os.WriteFile(path, []byte{}, 0600); err != nil {
+			return fmt.Errorf("failed to create file at path %q due to error: %w", path, err)
+		}
+	}
+	if err != nil {
+		return fmt.Errorf("failed to create file at path %q due to error: %w", path, err)
+	}
+	return Save(path, config)
+}
+
 // Save project config atomically to a file.
 func Save(path string, config Config) error {
 	w, err := os.CreateTemp(filepath.Dir(path), filepath.Base(path))