feat: create state file relative to config file

Signed-off-by: Bird <[email protected]>

Author: aFlyBird0

internal/pkg/backend/backend.go

@@ -33,7 +33,7 @@ func GetBackend(state configmanager.State) (Backend, error) {
 
 	switch typeName {
 	case LocalBackend:
-		return local.NewLocal(state.Options.StateFile)
+		return local.NewLocal(state.BaseDir, state.Options.StateFile)
 	case S3Backend:
 		return s3.NewS3Backend(state.Options.Bucket, state.Options.Region, state.Options.Key)
 	case K8sBackend, K8sBackendAlias:

internal/pkg/backend/local/local.go

@@ -18,13 +18,18 @@ type Local struct {
 }
 
 // NewLocal will use DefaultStateFile as statemanager file if filename is not given.
-func NewLocal(filename string) (*Local, error) {
+func NewLocal(baseDir, filename string) (*Local, error) {
 	var lFile = filename
 	if filename == "" {
 		log.Debugf("The stateFile has not been set, default value %s will be used.", DefaultStateFile)
 		lFile = DefaultStateFile
 	}
 
+	// if state file is not absolute path, use baseDir as prefix.
+	if !filepath.IsAbs(lFile) {
+		lFile = filepath.Join(baseDir, lFile)
+	}
+
 	log.Infof("Using local backend. State file: %s.", filename)
 
 	if _, err := os.Stat(lFile); errors.Is(err, os.ErrNotExist) {

internal/pkg/backend/local/local_test.go

@@ -11,19 +11,18 @@ import (
 )
 
 var _ = Describe("NewLocal func", func() {
-	var tFile, tFileLoc, tempDir string
+	var tFile, tempDir string
 
 	BeforeEach(func() {
 		tempDir = GinkgoT().TempDir()
 		tFile = "test_state_file"
-		tFileLoc = filepath.Join(tempDir, tFile)
 	})
 
 	When("input filename", func() {
 		It("should create state file", func() {
-			_, err := local.NewLocal(tFileLoc)
+			_, err := local.NewLocal(tempDir, tFile)
 			Expect(err).Should(Succeed())
-			_, err = os.Stat(tFileLoc)
+			_, err = os.Stat(filepath.Join(tempDir, tFile))
 			Expect(err).Error().ShouldNot(HaveOccurred())
 		})
 	})
@@ -39,8 +38,7 @@ var _ = Describe("Local struct", func() {
 	BeforeEach(func() {
 		tempDir = GinkgoT().TempDir()
 		tFile = "test_state_file"
-		tFileLoc = filepath.Join(tempDir, tFile)
-		tLocal, err = local.NewLocal(tFileLoc)
+		tLocal, err = local.NewLocal(tempDir, tFile)
 		Expect(err).ShouldNot(HaveOccurred())
 	})
 

internal/pkg/configmanager/configmanager.go

@@ -2,6 +2,7 @@ package configmanager
 
 import (
 	"fmt"
+	"path/filepath"
 	"strings"
 
 	"github.com/devstream-io/devstream/pkg/util/file"
@@ -95,6 +96,7 @@ func (m *Manager) getConfigFromFileWithGlobalVars() (*Config, error) {
 	if err != nil {
 		return nil, fmt.Errorf("failed to get coreConfig from config file. Error: %w", err)
 	}
+	coreConfig.State.BaseDir = filepath.Dir(m.ConfigFilePath)
 
 	return &Config{
 		Config: *coreConfig,

internal/pkg/configmanager/coreconfig.go

@@ -9,6 +9,7 @@ type CoreConfig struct {
 type State struct {
 	Backend string             `yaml:"backend"`
 	Options StateConfigOptions `yaml:"options"`
+	BaseDir string             `yaml:"-"` // baseDir is the base directory of the config file
 }
 
 // StateConfigOptions is the struct for reading the options of the state backend.