feat: add cleanup for devenv files

service/backend/server/router.go

@@ -40,7 +40,7 @@ func NewRouter(docker *service.DockerService, devenvFilesPath string, devenvFile
 	devenvController := controller.NewDevenvController(docker, devenvFilesPath, devenvFilesTmpPath)
 	replController := controller.NewReplController(docker, &replState)
 
-	cleanup := service.Cleanup(docker, &replState)
+	cleanup := service.Cleanup(docker, &replState, devenvFilesPath, devenvFilesTmpPath)
 	cleanup.DoCleanup()
 	cleanup.StartTask()
 

service/backend/service/cleanup.go

@@ -8,14 +8,18 @@ import (
 )
 
 type CleanupService struct {
-	Docker    *DockerService
-	ReplState *ReplStateService
+	Docker             *DockerService
+	ReplState          *ReplStateService
+	DevenvFilesPath    string
+	DevenvFilesTmpPath string
 }
 
-func Cleanup(docker *DockerService, replState *ReplStateService) CleanupService {
+func Cleanup(docker *DockerService, replState *ReplStateService, devenvFilesPath string, devenvFilesTmpPath string) CleanupService {
 	return CleanupService{
-		Docker:    docker,
-		ReplState: replState,
+		Docker:             docker,
+		ReplState:          replState,
+		DevenvFilesPath:    devenvFilesPath,
+		DevenvFilesTmpPath: devenvFilesTmpPath,
 	}
 }
 
@@ -48,6 +52,13 @@ func (cleanup *CleanupService) DoCleanup() {
 	database.DB.Unscoped().Where("created_at < ?", cutoffTime).Delete(&model.Devenv{})
 	database.DB.Unscoped().Where("created_at < ?", cutoffTime).Delete(&model.User{})
 	util.SLogger.Debugf("Cleaning database [%v]", time.Since(start))
+
+	util.SLogger.Debug("Cleaning devenvs starting ..")
+	start = time.Now()
+	util.DeleteDirsOlderThan(cleanup.DevenvFilesPath, cutoffTime)
+	util.DeleteDirsOlderThan(cleanup.DevenvFilesTmpPath, cutoffTime)
+	util.SLogger.Debugf("Cleaning devenvs [%v]", time.Since(start))
+
 }
 
 func (cleanup *CleanupService) StartTask() *chan struct{} {

service/backend/util/files.go

@@ -5,6 +5,7 @@ import (
 	"io/fs"
 	"os"
 	"path/filepath"
+	"time"
 
 	cp "github.com/otiai10/copy"
 )
@@ -84,3 +85,41 @@ func CopyRecurse(src string, target string, perm fs.FileMode) error {
 	})
 }
 
+func GetFileModTime(path string) (time.Time, error) {
+	info, err := os.Stat(path)
+	if err != nil {
+		return time.Time{}, err
+	}
+
+	return info.ModTime(), nil
+}
+
+func DeleteDirsOlderThan(path string, t time.Time) {
+	dir, err := os.Open(path)
+	if err != nil {
+		return
+	}
+	defer dir.Close()
+
+	files, err := dir.Readdir(0)
+	if err != nil {
+		return
+	}
+
+	for _, file := range files {
+		if file.IsDir() {
+			child := filepath.Join(path, file.Name())
+			modTime, err := GetFileModTime(child)
+			if err != nil {
+				continue
+			}
+			if modTime.Before(t) {
+				SLogger.Debugf("Deleting directory %s", child)
+				err = DeleteDir(child)
+				if err != nil {
+					continue
+				}
+			}
+		}
+	}
+}