Revert "GODT-2229: Allow changing cache folder to a non-empty folder."

This reverts commit b19e16e4b8.

internal/bridge/bridge.go

@@ -221,14 +221,8 @@ func newBridge(
 		return nil, fmt.Errorf("failed to get Gluon directory: %w", err)
 	}
 
-	gluonDBDir, err := locator.ProvideGluonDatabasePath()
-	if err != nil {
-		return nil, fmt.Errorf("failed to get Gluon Database directory: %w", err)
-	}
-
 	imapServer, err := newIMAPServer(
 		gluonDir,
-		gluonDBDir,
 		curVersion,
 		tlsConfig,
 		reporter,

internal/bridge/bridge_test.go

@@ -23,7 +23,7 @@ import (
 	"fmt"
 	"net/http"
 	"os"
-	"path/filepath"
+	"runtime"
 	"sync"
 	"testing"
 	"time"
@@ -361,7 +361,7 @@ func TestBridge_MissingGluonDir(t *testing.T) {
 			require.NoError(t, bridge.SetGluonDir(ctx, t.TempDir()))
 
 			// Get the gluon dir.
-			gluonDir = bridge.GetGluonCacheDir()
+			gluonDir = bridge.GetGluonDir()
 		})
 
 		// The user removes the gluon dir while bridge is not running.
@@ -456,11 +456,24 @@ func TestBridge_FactoryReset(t *testing.T) {
 	})
 }
 
+func TestBridge_ChangeCacheDirectoryFailsBetweenDifferentVolumes(t *testing.T) {
+	if runtime.GOOS != "windows" {
+		t.Skip("Test only necessary on windows")
+	}
+	withEnv(t, func(ctx context.Context, s *server.Server, netCtl *proton.NetCtl, locator bridge.Locator, vaultKey []byte) {
+		withBridge(ctx, t, s.GetHostURL(), netCtl, locator, vaultKey, func(bridge *bridge.Bridge, mocks *bridge.Mocks) {
+			// Change directory
+			err := bridge.SetGluonDir(ctx, "XX:\\")
+			require.Error(t, err)
+		})
+	})
+}
+
 func TestBridge_ChangeCacheDirectory(t *testing.T) {
 	withEnv(t, func(ctx context.Context, s *server.Server, netCtl *proton.NetCtl, locator bridge.Locator, vaultKey []byte) {
 		withBridge(ctx, t, s.GetHostURL(), netCtl, locator, vaultKey, func(bridge *bridge.Bridge, mocks *bridge.Mocks) {
 			newCacheDir := t.TempDir()
-			currentCacheDir := bridge.GetGluonCacheDir()
+			currentCacheDir := bridge.GetGluonDir()
 
 			// Login the user.
 			userID, err := bridge.LoginFull(ctx, username, password, nil, nil)
@@ -477,7 +490,7 @@ func TestBridge_ChangeCacheDirectory(t *testing.T) {
 			_, err = os.ReadDir(currentCacheDir)
 			require.True(t, os.IsNotExist(err))
 
-			require.Equal(t, filepath.Join(newCacheDir, "gluon"), bridge.GetGluonCacheDir())
+			require.Equal(t, newCacheDir, bridge.GetGluonDir())
 		})
 	})
 }

internal/bridge/files.go

@@ -18,8 +18,6 @@
 package bridge
 
 import (
-	"fmt"
-	"io"
 	"os"
 	"path/filepath"
 )
@@ -64,75 +62,3 @@ func moveFile(from, to string) error {
 
 	return nil
 }
-
-func copyDir(from, to string) error {
-	entries, err := os.ReadDir(from)
-	if err != nil {
-		return err
-	}
-	if err := createIfNotExists(to, 0o700); err != nil {
-		return err
-	}
-	for _, entry := range entries {
-		sourcePath := filepath.Join(from, entry.Name())
-		destPath := filepath.Join(to, entry.Name())
-
-		if entry.IsDir() {
-			if err := copyDir(sourcePath, destPath); err != nil {
-				return err
-			}
-		} else {
-			if err := copyFile(sourcePath, destPath); err != nil {
-				return err
-			}
-		}
-	}
-	return nil
-}
-
-func copyFile(srcFile, dstFile string) error {
-	out, err := os.Create(filepath.Clean(dstFile))
-	defer func(out *os.File) {
-		_ = out.Close()
-	}(out)
-
-	if err != nil {
-		return err
-	}
-
-	in, err := os.Open(filepath.Clean(srcFile))
-	defer func(in *os.File) {
-		_ = in.Close()
-	}(in)
-
-	if err != nil {
-		return err
-	}
-
-	_, err = io.Copy(out, in)
-	if err != nil {
-		return err
-	}
-
-	return nil
-}
-
-func exists(filePath string) bool {
-	if _, err := os.Stat(filePath); os.IsNotExist(err) {
-		return false
-	}
-
-	return true
-}
-
-func createIfNotExists(dir string, perm os.FileMode) error {
-	if exists(dir) {
-		return nil
-	}
-
-	if err := os.MkdirAll(dir, perm); err != nil {
-		return fmt.Errorf("failed to create directory: '%s', error: '%s'", dir, err.Error())
-	}
-
-	return nil
-}

internal/bridge/imap.go

@@ -199,13 +199,13 @@ func (bridge *Bridge) handleIMAPEvent(event imapEvents.Event) {
 }
 
 func getGluonDir(encVault *vault.Vault) (string, error) {
-	empty, exists, err := isEmpty(encVault.GetGluonCacheDir())
+	empty, exists, err := isEmpty(encVault.GetGluonDir())
 	if err != nil {
 		return "", fmt.Errorf("failed to check if gluon dir is empty: %w", err)
 	}
 
 	if !exists {
-		if err := os.MkdirAll(encVault.GetGluonCacheDir(), 0o700); err != nil {
+		if err := os.MkdirAll(encVault.GetGluonDir(), 0o700); err != nil {
 			return "", fmt.Errorf("failed to create gluon dir: %w", err)
 		}
 	}
@@ -218,12 +218,12 @@ func getGluonDir(encVault *vault.Vault) (string, error) {
 		}
 	}
 
-	return encVault.GetGluonCacheDir(), nil
+	return encVault.GetGluonDir(), nil
 }
 
 // nolint:funlen
 func newIMAPServer(
-	gluonDir, gluonDBDir string,
+	gluonDir string,
 	version *semver.Version,
 	tlsConfig *tls.Config,
 	reporter reporter.Reporter,
@@ -264,7 +264,6 @@ func newIMAPServer(
 	imapServer, err := gluon.New(
 		gluon.WithTLS(tlsConfig),
 		gluon.WithDataDir(gluonDir),
-		gluon.WithDatabaseDir(gluonDBDir),
 		gluon.WithStoreBuilder(new(storeBuilder)),
 		gluon.WithLogger(imapClientLog, imapServerLog),
 		getGluonVersionInfo(version),

internal/bridge/settings.go

@@ -21,7 +21,6 @@ import (
 	"context"
 	"fmt"
 	"net"
-	"os"
 	"path/filepath"
 
 	"github.com/Masterminds/semver/v3"
@@ -115,48 +114,38 @@ func (bridge *Bridge) SetSMTPSSL(newSSL bool) error {
 	return bridge.restartSMTP()
 }
 
-func (bridge *Bridge) GetGluonCacheDir() string {
-	return bridge.vault.GetGluonCacheDir()
-}
-
-func (bridge *Bridge) GetGluonConfigDir() (string, error) {
-	return bridge.locator.ProvideGluonDatabasePath()
+func (bridge *Bridge) GetGluonDir() string {
+	return bridge.vault.GetGluonDir()
 }
 
 func (bridge *Bridge) SetGluonDir(ctx context.Context, newGluonDir string) error {
 	return safe.RLockRet(func() error {
-		currentGluonDir := bridge.GetGluonCacheDir()
-		newGluonDir = filepath.Join(newGluonDir, "gluon")
+		currentGluonDir := bridge.GetGluonDir()
 		if newGluonDir == currentGluonDir {
 			return fmt.Errorf("new gluon dir is the same as the old one")
 		}
 
-		if err := bridge.stopEventLoops(); err != nil {
-			return err
-		}
-		defer func() {
-			err := bridge.startEventLoops(ctx)
-			if err != nil {
-				panic(err)
-			}
-		}()
+		currentVolumeName := filepath.VolumeName(currentGluonDir)
+		newVolumeName := filepath.VolumeName(newGluonDir)
 
-		oldGluonDir := bridge.GetGluonCacheDir()
-		if err := bridge.moveGluonCacheDir(oldGluonDir, newGluonDir); err != nil {
-			logrus.WithError(err).Error("failed to move GluonCacheDir")
-			if err := bridge.vault.SetGluonDir(oldGluonDir); err != nil {
-				panic(err)
-			}
+		if currentVolumeName != newVolumeName {
+			return fmt.Errorf("it's currently not possible to move the cache between different volumes")
 		}
 
-		gluonDBDir, err := bridge.GetGluonConfigDir()
-		if err != nil {
-			panic(fmt.Errorf("failed to get Gluon Database directory: %w", err))
+		if err := bridge.closeIMAP(context.Background()); err != nil {
+			return fmt.Errorf("failed to close IMAP: %w", err)
+		}
+
+		if err := moveDir(bridge.GetGluonDir(), newGluonDir); err != nil {
+			return fmt.Errorf("failed to move gluon dir: %w", err)
+		}
+
+		if err := bridge.vault.SetGluonDir(newGluonDir); err != nil {
+			return fmt.Errorf("failed to set new gluon dir: %w", err)
 		}
 
 		imapServer, err := newIMAPServer(
-			bridge.vault.GetGluonCacheDir(),
-			gluonDBDir,
+			bridge.vault.GetGluonDir(),
 			bridge.curVersion,
 			bridge.tlsConfig,
 			bridge.reporter,
@@ -166,58 +155,25 @@ func (bridge *Bridge) SetGluonDir(ctx context.Context, newGluonDir string) error
 			bridge.tasks,
 		)
 		if err != nil {
-			panic(fmt.Errorf("failed to create new IMAP server: %w", err))
+			return fmt.Errorf("failed to create new IMAP server: %w", err)
 		}
 
 		bridge.imapServer = imapServer
 
+		for _, user := range bridge.users {
+			if err := bridge.addIMAPUser(ctx, user); err != nil {
+				return fmt.Errorf("failed to add users to new IMAP server: %w", err)
+			}
+		}
+
+		if err := bridge.serveIMAP(); err != nil {
+			return fmt.Errorf("failed to serve IMAP: %w", err)
+		}
+
 		return nil
 	}, bridge.usersLock)
 }
 
-func (bridge *Bridge) moveGluonCacheDir(oldGluonDir, newGluonDir string) error {
-	if err := copyDir(oldGluonDir, newGluonDir); err != nil {
-		return fmt.Errorf("failed to copy gluon dir: %w", err)
-	}
-
-	if err := bridge.vault.SetGluonDir(newGluonDir); err != nil {
-		return fmt.Errorf("failed to set new gluon dir: %w", err)
-	}
-
-	if err := os.RemoveAll(oldGluonDir); err != nil {
-		logrus.WithError(err).Error("failed to remove old gluon dir")
-	}
-	return nil
-}
-
-func (bridge *Bridge) stopEventLoops() error {
-	if err := bridge.closeIMAP(context.Background()); err != nil {
-		return fmt.Errorf("failed to close IMAP: %w", err)
-	}
-
-	if err := bridge.closeSMTP(); err != nil {
-		return fmt.Errorf("failed to close SMTP: %w", err)
-	}
-	return nil
-}
-
-func (bridge *Bridge) startEventLoops(ctx context.Context) error {
-	for _, user := range bridge.users {
-		if err := bridge.addIMAPUser(ctx, user); err != nil {
-			return fmt.Errorf("failed to add users to new IMAP server: %w", err)
-		}
-	}
-
-	if err := bridge.serveIMAP(); err != nil {
-		panic(fmt.Errorf("failed to serve IMAP: %w", err))
-	}
-
-	if err := bridge.serveSMTP(); err != nil {
-		panic(fmt.Errorf("failed to serve SMTP: %w", err))
-	}
-	return nil
-}
-
 func (bridge *Bridge) GetProxyAllowed() bool {
 	return bridge.vault.GetProxyAllowed()
 }

internal/bridge/types.go

@@ -27,7 +27,6 @@ type Locator interface {
 	ProvideSettingsPath() (string, error)
 	ProvideLogsPath() (string, error)
 	ProvideGluonPath() (string, error)
-	ProvideGluonDatabasePath() (string, error)
 	GetLicenseFilePath() string
 	GetDependencyLicensesLink() string
 	Clear() error