1 files changed, 105 insertions, 0 deletions
diff --git a/client/go/cmd/deploy/persist.go b/client/go/cmd/deploy/persist.go
new file mode 100644
index 00000000000..78fe063ea0e
--- /dev/null
+++ b/client/go/cmd/deploy/persist.go
@@ -0,0 +1,105 @@
+// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+// vespa-deploy command
+// Author: arnej
+
+package deploy
+
+import (
+	// "fmt"
+	"os"
+	"path/filepath"
+	"strconv"
+	"strings"
+)
+
+const (
+	cloudconfigDir              = ".cloudconfig"
+	configsourceUrlUsedFileName = "deploy-configsource-url-used"
+	sessionIdFileName           = "deploy-session-id"
+)
+
+func createCloudconfigDir() (string, error) {
+	userHome, err := os.UserHomeDir()
+	if err != nil {
+		return "", err
+	}
+	home := filepath.Join(userHome, cloudconfigDir)
+	if err := os.MkdirAll(home, 0700); err != nil {
+		return "", err
+	}
+	return home, nil
+}
+
+func configsourceUrlUsedFile() string {
+	home, err := createCloudconfigDir()
+	if err != nil {
+		home = "/tmp"
+	}
+	return filepath.Join(home, configsourceUrlUsedFileName)
+}
+
+func createTenantDir(tenant string) string {
+	home, err := createCloudconfigDir()
+	if err != nil {
+		panic(err)
+	}
+	tdir := filepath.Join(home, tenant)
+	if err := os.MkdirAll(tdir, 0700); err != nil {
+		panic(err)
+	}
+	return tdir
+}
+
+func writeConfigsourceUrlUsed(url string) {
+	fn := configsourceUrlUsedFile()
+	os.WriteFile(fn, []byte(url), 0600)
+}
+
+func getConfigsourceUrlUsed() string {
+	fn := configsourceUrlUsedFile()
+	bytes, err := os.ReadFile(fn)
+	if err != nil {
+		return ""
+	}
+	return string(bytes)
+}
+
+func writeSessionIdFromResponseToFile(tenant, response string) {
+	newSessionId := getSessionIdFromResponse(response)
+	writeSessionIdToFile(tenant, newSessionId)
+}
+
+func writeSessionIdToFile(tenant, newSessionId string) {
+	if newSessionId != "" {
+		dir := createTenantDir(tenant)
+		fn := filepath.Join(dir, sessionIdFileName)
+		os.WriteFile(fn, []byte(newSessionId), 0600)
+		// fmt.Printf("wrote %s to %s\n", newSessionId, fn)
+	}
+}
+
+func getSessionIdFromResponse(response string) string {
+	_, after, found := strings.Cut(response, `"session-id":"`)
+	if !found {
+		return ""
+	}
+	digits, _, found := strings.Cut(after, `"`)
+	if !found {
+		return ""
+	}
+	if _, err := strconv.Atoi(digits); err != nil {
+		return ""
+	}
+	return digits
+}
+
+func getSessionIdFromFile(tenant string) string {
+	dir := createTenantDir(tenant)
+	fn := filepath.Join(dir, sessionIdFileName)
+	bytes, err := os.ReadFile(fn)
+	if err == nil {
+		// fmt.Printf("Session-id '%s' found from file %s\n", string(bytes), fn)
+		return string(bytes)
+	}
+	panic("Could not read session id from file, and no session id supplied as argument. Exiting.")
+}