feat: Update volume endpoints

agent/dns_server.go

@@ -63,7 +63,7 @@ func startDnsServer() {
 		}
 		_ = w.WriteMsg(m)
 	})
-	server := &dns.Server{Addr: "10.0.1.1:53", Net: "udp"}
+	server := &dns.Server{Addr: "127.0.0.1:5353", Net: "udp"}
 	log.Printf("Starting DNS server at %s\n", server.Addr)
 	if err := server.ListenAndServe(); err != nil {
 		log.Fatalf("Failed to start DNS server: %s\n ", err)

agent/volume_dao.go

@@ -45,6 +45,14 @@ func (v *Volume) Create() error {
 	if err := v.Validate(); err != nil {
 		return err
 	}
+	// Check if the volume already exists
+	exists, err := ExistsVolume(v.UUID)
+	if err != nil {
+		return err
+	}
+	if exists {
+		return fmt.Errorf("volume already exists")
+	}
 	// Create the record
 	if err := rwDB.Create(v).Error; err != nil {
 		return err

agent/volume_utils.go

@@ -3,6 +3,7 @@ package main
 import (
 	"context"
 	"fmt"
+	"os"
 	"path/filepath"
 
 	"github.com/docker/docker/api/types/volume"
@@ -11,7 +12,7 @@ import (
 var volumeBindsDefaultPath string
 
 func init() {
-	volumePath, err := filepath.Abs("./volumes")
+	volumePath, err := filepath.Abs("/home/tanmoy/docker-volumes")
 	if err != nil {
 		fmt.Println("Failed to get absolute path for volumes directory")
 		panic(err)
@@ -45,7 +46,7 @@ func (v *Volume) RemoveVolume(deleteDirectory bool) error {
 	// Remove volume directory
 	if v.Type == LocalVolume && deleteDirectory {
 		path := v.LocalVolumeFullPath()
-		RemovePath(path)
+		_ = os.RemoveAll(path)
 	}
 	return nil
 }
@@ -79,7 +80,7 @@ func (v *Volume) Restore(downloadUrl string) error {
 
 func createLocalVolume(v *Volume) error {
 	// create volume directory
-	err := CreateDirectoryWithOptions(v.LocalVolumeFullPath(), false, 0755)
+	err := os.MkdirAll(v.LocalVolumeFullPath(), 0755)
 	if err != nil {
 		return err
 	}
@@ -88,6 +89,7 @@ func createLocalVolume(v *Volume) error {
 		Name:   v.UUID,
 		Driver: "local",
 		DriverOpts: map[string]string{
+			"type":   "volume",
 			"o":      "bind",
 			"device": v.LocalVolumeFullPath(),
 		},