1.5.9 dev

.github/workflows/main.yml

@@ -8,7 +8,7 @@ on:
     branches: ["main"]
 
 env:
-  VERSION: "1.5.7"
+  VERSION: "1.5.8"
 
 jobs:
   docker:

cmd/server/main.go

@@ -12,6 +12,7 @@ func main() {
 		os.Getenv("DATA_PATH"),
 		os.Getenv("LOG_LEVEL"),
 		os.Getenv("SSL_ENABLED"),
+		os.Getenv("STALENESS_CHECK"),
 	)
 	s.Run(os.Getenv("BIND_ADDRESS"))
 }

pkg/agent/agent.go

@@ -21,19 +21,23 @@ var (
 	logLevel string
 	wsUrl string
 	token string
+	stalenessCheck string = "ON"
 )
 
 func Main() {
  	parseArgs()
 	setLogLevel(logLevel)
-	go dockerapi.ContainerScheduleRefreshStaleStatus()
+	if stalenessCheck != "OFF" {
+		go dockerapi.ContainerScheduleRefreshStaleStatus()
+	}
 	listen()
 }
 
 func parseArgs() {
 	logLevel = os.Getenv("LOG_LEVEL")
 	serverUrl := os.Getenv("SERVER_URL")
 	token = os.Getenv("TOKEN")
+	stalenessCheck = os.Getenv("STALENESS_CHECK")
 
 	serverScheme := "ws"
 	if strings.HasPrefix(serverUrl, "https") {

pkg/common/common.go

@@ -1,3 +1,3 @@
 package common
 
-const Version = "1.5.7"
+const Version = "1.5.8"

pkg/dockerapi/compose.go

@@ -195,27 +195,43 @@ func ComposeLogs(req *DockerComposeLogs, ws *websocket.Conn) error {
 	return nil
 }
 
-func createTempComposeFile(projectName string, definition string) (string, string, error) {
+func createTempComposeFile(projectName string, definition string, variables map[string]store.VariableValue) (string, string, string, error) {
 	dir, err := os.MkdirTemp("", projectName)
 	if err != nil {
 		log.Error().Err(err).Msg("Error while creating temp directory for compose")
-		return "", "", err
+		return "", "", "", err
 	}
 
-	filename := filepath.Join(dir, "compose.yaml")
-	composeFile, err := os.Create(filename)
+	composeFilename := filepath.Join(dir, "compose.yaml")
+	composeFile, err := os.Create(composeFilename)
 	if err != nil {
 		log.Error().Err(err).Msg("Error while creating temp compose file")
-		return "", "", err
+		return "", "", "", err
 	}
 
 	_ , err = composeFile.WriteString(definition)
 	if err != nil {
 		log.Error().Err(err).Msg("Error while writing to temp compose file")
-		return "", "", err
+		return "", "", "", err
 	}
 
-	return dir, filename, nil
+	envFilename := filepath.Join(dir, ".env")
+	envFile, err := os.Create(envFilename)
+	if err != nil {
+		log.Error().Err(err).Msg("Error while creating temp compose file")
+		return "", "", "", err
+	}
+
+	envVars := toEnvFormat(variables)
+	for _, v := range envVars {
+		_ , err = envFile.WriteString(v + "\r\n")
+		if err != nil {
+			log.Error().Err(err).Msg("Error while writing to temp .env file")
+			return "", "", "", err
+		}
+	}
+
+	return dir, composeFilename, envFilename, nil
 }
 
 func toEnvFormat(variables map[string]store.VariableValue) ([]string) {
@@ -230,8 +246,7 @@ func toEnvFormat(variables map[string]store.VariableValue) ([]string) {
 	return ret
 }
 
-func processVars(cmd *exec.Cmd, variables map[string]store.VariableValue, ws *websocket.Conn, print bool) {
-	cmd.Env = os.Environ()
+func logVars(cmd *exec.Cmd, variables map[string]store.VariableValue, ws *websocket.Conn, print bool) {
 	if print {
 		ws.WriteMessage(websocket.TextMessage, []byte("*** SETTING BELOW VARIABLES: ***\n\n"))
 	}
@@ -251,35 +266,31 @@ func processVars(cmd *exec.Cmd, variables map[string]store.VariableValue, ws *we
 			ws.WriteMessage(websocket.TextMessage, []byte(fmt.Sprintf("%s=%s\n", k, val)))
 		}
 	}
-
-	for _, v := range toEnvFormat(variables) {
-		cmd.Env = append(cmd.Env, v)
-	}
 }
 
 func performComposeAction(action string, projectName string, definition string, variables map[string]store.VariableValue, ws *websocket.Conn, printVars bool) error {
-	dir, file, err := createTempComposeFile(projectName, definition)
-	log.Debug().Str("fileName", file).Msg("Created temporary compose file")
+	dir, composefile, envfile, err := createTempComposeFile(projectName, definition, variables)
+	log.Debug().Str("composeFileName", composefile).Str("envFileName", envfile).Msg("Created temporary compose file and .env file")
 	if err != nil {
 		return err
 	}
 	defer func() { 
-		log.Debug().Str("fileName", file).Msg("Deleting temporary compose file")
+		log.Debug().Str("fileName", composefile).Msg("Deleting temporary compose file and .env file")
 		os.RemoveAll(dir) 
 	}()
 
 	var cmd *exec.Cmd
 	switch action {
 	case "up":
-		cmd = exec.Command("docker-compose", "-p", projectName, "-f", file, action, "-d")
+		cmd = exec.Command("docker-compose", "-p", projectName, "--env-file", envfile, "-f", composefile, action, "-d")
 	case "down":
-		cmd = exec.Command("docker-compose", "-p", projectName, action)
+		cmd = exec.Command("docker-compose", "-p", projectName, "--env-file", envfile, action)
 	case "pull":
-		cmd = exec.Command("docker-compose", "-p", projectName, "-f", file, action)
+		cmd = exec.Command("docker-compose", "-p", projectName, "--env-file", envfile, "-f", composefile, action)
 	default:
 		panic(fmt.Errorf("unknown compose action %s", action))
 	}
-	processVars(cmd, variables, ws, printVars)
+	logVars(cmd, variables, ws, printVars)
 
 	ws.WriteMessage(websocket.TextMessage, []byte(fmt.Sprintf("\n*** STARTING ACTION: %s ***\n\n", action)))
 	f, err := pty.Start(cmd)

pkg/dockerapi/container_stale_check.go

@@ -43,7 +43,7 @@ func ContainerScheduleRefreshStaleStatus() {
 	for {
 		log.Info().Msg("Refreshing container stale status")
 		ContainerRefreshStaleStatus()
-		time.Sleep(1 * time.Hour)
+		time.Sleep(24 * time.Hour)
 	}
 }
 

pkg/dockerapi/image.go

@@ -18,7 +18,7 @@ func ImageList(req *DockerImageList) (*DockerImageListResponse, error) {
 		return nil, err
 	}
 
-	dcontainers, err := cli.ContainerList(context.Background(), types.ContainerListOptions{All: req.All})
+	dcontainers, err := cli.ContainerList(context.Background(), types.ContainerListOptions{All: true})
 	if err != nil {
 		return nil, err
 	}

pkg/dockerapi/models.go

@@ -102,8 +102,9 @@ type DockerVolumeList struct {
 }
 
 type Volume struct {
-	Driver string `json:"driver"`
-	Name string `json:"name"`
+	Driver 	string `json:"driver"`
+	Name 	string `json:"name"`
+	InUse   bool   `json:"inUse"`
 }
 
 type DockerVolumeListResponse struct {
@@ -131,6 +132,7 @@ type Network struct {
 	Name string `json:"name"`
 	Driver string `json:"driver"`
 	Scope string `json:"scope"`
+	InUse   bool   `json:"inUse"`
 }
 
 type DockerNetworkListResponse struct {

pkg/dockerapi/network.go

@@ -15,18 +15,34 @@ func NetworkList(req *DockerNetworkList) (*DockerNetworkListResponse, error) {
 		return nil, err
 	}
 
+	dcontainers, err := cli.ContainerList(context.Background(), types.ContainerListOptions{All: true})
+	if err != nil {
+		return nil, err
+	}
+
+	usedNetworks := make(map[string]interface{}, 0)
+	for _, c := range dcontainers {
+		if c.NetworkSettings != nil {
+			for _, n := range c.NetworkSettings.Networks {
+				usedNetworks[n.NetworkID] = nil
+			}	
+		}
+	}
+
 	dnetworks, err := cli.NetworkList(context.Background(), types.NetworkListOptions{})
 	if err != nil {
 		return nil, err
 	}
 
 	networks := make([]Network, len(dnetworks))
 	for i, item := range dnetworks {
+		_, inUse := usedNetworks[item.ID]
 		networks[i] = Network{
 			Id:		item.ID,
 			Name: 	item.Name,
 			Driver: item.Driver,
 			Scope: 	item.Scope,
+			InUse: 	inUse,
 		}
 	}
 

pkg/dockerapi/volume.go

@@ -4,7 +4,9 @@ import (
 	"context"
 	"sort"
 
+	"github.com/docker/docker/api/types"
 	"github.com/docker/docker/api/types/filters"
+	"github.com/docker/docker/api/types/mount"
 	"github.com/docker/docker/api/types/volume"
 	"github.com/docker/docker/client"
 )
@@ -15,16 +17,32 @@ func VolumeList(req *DockerVolumeList) (*DockerVolumeListResponse, error) {
 		return nil, err
 	}
 
+	dcontainers, err := cli.ContainerList(context.Background(), types.ContainerListOptions{All: true})
+	if err != nil {
+		return nil, err
+	}
+
+	usedVolumes := make(map[string]interface{}, 0)
+	for _, c := range dcontainers {
+		for _, m := range c.Mounts {
+			if m.Type == mount.TypeVolume {
+				usedVolumes[m.Name] = nil
+			}
+		}
+	}
+
 	dvolumes, err := cli.VolumeList(context.Background(), volume.ListOptions{})
 	if err != nil {
 		return nil, err
 	}
 
 	volumes := make([]Volume, len(dvolumes.Volumes))
 	for i, item := range dvolumes.Volumes {
+		_, inUse := usedVolumes[item.Name]
 		volumes[i] = Volume{
 			Driver: item.Driver,
 			Name: item.Name,
+			InUse: inUse,
 		}
 	}
 
@@ -56,7 +74,7 @@ func VolumesPrune(req *DockerVolumesPrune) (*DockerVolumesPruneResponse, error)
 	}
 
 	all := "true"
-	if req.All {
+	if !req.All {
 		all = "false"
 	}
 	allFilter := filters.KeyValuePair{Key: "all", Value: all}

pkg/server/handler/request_docker.go

@@ -78,7 +78,7 @@ func (r *dockerContainerRemoveRequest) bind(c echo.Context, m *dockerapi.DockerC
 
 type dockerImageRemoveRequest struct {
 	Id      string  `json:"id" validate:"required,max=100"`
-	Force   bool	`json:"force" validate:"required"`
+	Force   bool	`json:"force"`
 }
 
 func (r *dockerImageRemoveRequest) bind(c echo.Context, m *dockerapi.DockerImageRemove) error {

pkg/server/server.go

@@ -35,7 +35,7 @@ type Server struct {
 	sslEnabled bool
 }
 
-func NewServer(dbConnectionString string, dataPath string, logLevel string, sslEnabled string) (*Server) {
+func NewServer(dbConnectionString string, dataPath string, logLevel string, sslEnabled string, stalenessCheck string) (*Server) {
 	s := Server{}
 
 	setLogLevel(logLevel)
@@ -82,7 +82,9 @@ func NewServer(dbConnectionString string, dataPath string, logLevel string, sslE
 		log.Error().Err(err).Msg("Error while updating old version data")
 	}
 
-	go dockerapi.ContainerScheduleRefreshStaleStatus()
+	if stalenessCheck != "OFF" {
+		go dockerapi.ContainerScheduleRefreshStaleStatus()
+	}
 
 	// Web Server
 	s.handler = h

web/src/app/images/image-list.tsx

@@ -52,7 +52,7 @@ export default function ImageList() {
       {
         method: "POST",
         headers: { "Content-Type": "application/json" },
-        body: JSON.stringify({ id: image?.id, force: true }),
+        body: JSON.stringify({ id: image?.id, force: false }),
       }
     )
     if (!response.ok) {
@@ -162,12 +162,14 @@ export default function ImageList() {
                   <TableCell>{item.inUse ? "In use" : "Unused"}</TableCell>
                   <TableCell>{convertByteToMb(item.size)}</TableCell>
                   <TableCell className="text-right">
-                    <TableButtonDelete
-                      onClick={(e) => {
-                        e.stopPropagation()
-                        handleDeleteImageConfirmation(item)
-                      }}
-                    />
+                    {!item.inUse && (
+                      <TableButtonDelete
+                        onClick={(e) => {
+                          e.stopPropagation()
+                          handleDeleteImageConfirmation(item)
+                        }}
+                      />
+                    )}
                   </TableCell>
                 </TableRow>
               ))}

web/src/app/networks/network-list.tsx

@@ -28,6 +28,15 @@ import { toastFailed, toastSuccess } from "@/lib/utils"
 import apiBaseUrl from "@/lib/api-base-url"
 import DeleteDialog from "@/components/delete-dialog"
 
+const systemNetwoks = [
+  "none",
+  "bridge",
+  "host",
+  "ingress",
+  "docker_gwbridge",
+  "docker_volumes-backup-extension-desktop-extension_default",
+]
+
 export default function NetworkList() {
   const { nodeId } = useParams()
   const { nodeHead } = useNodeHead(nodeId!)
@@ -137,6 +146,7 @@ export default function NetworkList() {
               <TableHead scope="col">Name</TableHead>
               <TableHead scope="col">Driver</TableHead>
               <TableHead scope="col">Scope</TableHead>
+              <TableHead scope="col">Status</TableHead>
               <TableHead scope="col">
                 <span className="sr-only">Actions</span>
               </TableHead>
@@ -151,13 +161,16 @@ export default function NetworkList() {
                   <TableCell>{item.name}</TableCell>
                   <TableCell>{item.driver}</TableCell>
                   <TableCell>{item.scope}</TableCell>
+                  <TableCell>{item.inUse ? "In use" : "Unused"}</TableCell>
                   <TableCell className="text-right">
-                    <TableButtonDelete
-                      onClick={(e) => {
-                        e.stopPropagation()
-                        handleDeleteNetworkConfirmation(item)
-                      }}
-                    />
+                    {!systemNetwoks.includes(item.name) && !item.inUse && (
+                      <TableButtonDelete
+                        onClick={(e) => {
+                          e.stopPropagation()
+                          handleDeleteNetworkConfirmation(item)
+                        }}
+                      />
+                    )}
                   </TableCell>
                 </TableRow>
               ))}