Merge pull request #26 from The-Debarghya/main

Fix format errors

Author: tanmoysrt

.github/workflows/go-lint-build.yml

@@ -46,4 +46,4 @@ jobs:
         run: staticcheck ./...
 
       - name: Run format checks
-        run: gofmt -l -d .
+        run: gofmt -l -d -e .

container_manager/image.go

@@ -11,7 +11,7 @@ import (
 
 func (m Manager) CreateImage(dockerfile string, buildargs map[string]string, codepath string, imagename string) (*bufio.Scanner, error) {
 	// Move the dockerfile to the codepath
-	err := os.WriteFile(codepath+"/Dockerfile",[]byte(dockerfile), 0777)
+	err := os.WriteFile(codepath+"/Dockerfile", []byte(dockerfile), 0777)
 	if err != nil {
 		return nil, errors.New("failed to write the dockerfile")
 	}
@@ -32,13 +32,13 @@ func (m Manager) CreateImage(dockerfile string, buildargs map[string]string, cod
 	// Build the image
 	response, err := m.client.ImageBuild(m.ctx, tar, types.ImageBuildOptions{
 		Dockerfile: "Dockerfile",
-		Remove:    true,
-		Tags: 	[]string{imagename},
-		BuildArgs: final_buildargs,
+		Remove:     true,
+		Tags:       []string{imagename},
+		BuildArgs:  final_buildargs,
 	})
 	if err != nil {
 		return nil, errors.New("failed to build the image")
 	}
 	scanner := bufio.NewScanner(response.Body)
 	return scanner, nil
-}
+}

container_manager/network.go

@@ -9,7 +9,7 @@ import (
 // Create a new network
 func (m Manager) CreateNetwork(name string) error {
 	_, err := m.client.NetworkCreate(m.ctx, name, types.NetworkCreate{
-		Driver: "overlay",
+		Driver:     "overlay",
 		Attachable: true,
 	})
 	if err != nil {
@@ -49,4 +49,4 @@ func (m Manager) GatewayNetwork(name string) (string, error) {
 		return "", errors.New("error inspecting network ")
 	}
 	return network.IPAM.Config[0].Gateway, nil
-}
+}

container_manager/ports.go

@@ -28,7 +28,7 @@ func (m Manager) UpdatePublishedHostPorts(service_name string, ports []swarm.Por
 	serviceData.Endpoint.Ports = ports
 	serviceData.Spec.EndpointSpec.Mode = swarm.ResolutionModeVIP
 	serviceData.Spec.EndpointSpec.Ports = ports
-	_, err= m.client.ServiceUpdate(m.ctx, service_name, serviceData.Version, serviceData.Spec, types.ServiceUpdateOptions{})
+	_, err = m.client.ServiceUpdate(m.ctx, service_name, serviceData.Version, serviceData.Spec, types.ServiceUpdateOptions{})
 	if err != nil {
 		return errors.New("error updating service")
 	}

container_manager/service.go

@@ -77,9 +77,9 @@ func (m Manager) StatusService(serviceName string) (ServiceStatus, error) {
 		return ServiceStatus{}, errors.New("error getting service status")
 	}
 
-	var updateStatus ServiceUpdateStatus;
+	var updateStatus ServiceUpdateStatus
 	if serviceData.UpdateStatus != nil {
-		var state ServiceUpdateState;
+		var state ServiceUpdateState
 		switch serviceData.UpdateStatus.State {
 		case swarm.UpdateStateUpdating:
 			state = ServiceUpdateStateUpdating
@@ -97,7 +97,7 @@ func (m Manager) StatusService(serviceName string) (ServiceStatus, error) {
 			state = ServiceUpdateStateUnknown
 		}
 		updateStatus = ServiceUpdateStatus{
-			State: state,
+			State:   state,
 			Message: serviceData.UpdateStatus.Message,
 		}
 	}
@@ -122,9 +122,9 @@ func (m Manager) StatusService(serviceName string) (ServiceStatus, error) {
 		desiredReplicas = int(*serviceData.Spec.Mode.Replicated.Replicas)
 	}
 	return ServiceStatus{
-		DesiredReplicas: desiredReplicas,
-		RunningReplicas: runningReplicas,
-		LastUpdatedAt:   serviceData.UpdatedAt.String(),
+		DesiredReplicas:     desiredReplicas,
+		RunningReplicas:     runningReplicas,
+		LastUpdatedAt:       serviceData.UpdatedAt.String(),
 		ServiceUpdateStatus: updateStatus,
 	}, nil
 }
@@ -134,9 +134,9 @@ func (m Manager) LogsService(serviceName string, since string, until string) (io
 	logs, err := m.client.ServiceLogs(m.ctx, serviceName, types.ContainerLogsOptions{
 		ShowStdout: true,
 		ShowStderr: true,
-		Follow: false,
-		Since: since,
-		Until: until,
+		Follow:     false,
+		Since:      since,
+		Until:      until,
 	})
 	if err != nil {
 		return nil, errors.New("error getting service logs")
@@ -158,7 +158,7 @@ func (m Manager) serviceToServiceSpec(service Service) swarm.ServiceSpec {
 	volumeMounts := []mount.Mount{}
 	for _, volumeMount := range service.VolumeMounts {
 		volumeMounts = append(volumeMounts, mount.Mount{
-			Type: mount.TypeVolume,
+			Type:     mount.TypeVolume,
 			Source:   volumeMount.Source,
 			Target:   volumeMount.Target,
 			ReadOnly: volumeMount.ReadOnly,

container_manager/types.go

@@ -24,27 +24,27 @@ type Service struct {
 }
 
 type ServiceStatus struct {
-	DesiredReplicas  int                 `json:"desiredreplicas"`
-	RunningReplicas  int                 `json:"runningreplicas"`
-	LastUpdatedAt    string              `json:"lastupdatedat"`
+	DesiredReplicas     int                 `json:"desiredreplicas"`
+	RunningReplicas     int                 `json:"runningreplicas"`
+	LastUpdatedAt       string              `json:"lastupdatedat"`
 	ServiceUpdateStatus ServiceUpdateStatus `json:"serviceupdatestatus,omitempty"`
 }
 
 type ServiceUpdateStatus struct {
-	State ServiceUpdateState `json:"state"`
-	Message string `json:"message"`
+	State   ServiceUpdateState `json:"state"`
+	Message string             `json:"message"`
 }
 
 type ServiceUpdateState string
 
 const (
-	ServiceUpdateStateUpdating ServiceUpdateState = "updating"
-	ServiceUpdateStatePaused ServiceUpdateState = "paused"
-	ServiceUpdateStateCompleted ServiceUpdateState = "completed"
-	ServiceUpdateStateRollbackStarted ServiceUpdateState = "rollback_started"
-	ServiceUpdateStateRollbackPaused ServiceUpdateState = "rollback_paused"
+	ServiceUpdateStateUpdating          ServiceUpdateState = "updating"
+	ServiceUpdateStatePaused            ServiceUpdateState = "paused"
+	ServiceUpdateStateCompleted         ServiceUpdateState = "completed"
+	ServiceUpdateStateRollbackStarted   ServiceUpdateState = "rollback_started"
+	ServiceUpdateStateRollbackPaused    ServiceUpdateState = "rollback_paused"
 	ServiceUpdateStateRollbackCompleted ServiceUpdateState = "rollback_completed"
-	ServiceUpdateStateUnknown ServiceUpdateState = "unknown"
+	ServiceUpdateStateUnknown           ServiceUpdateState = "unknown"
 )
 
 // Volume Mount

container_manager/volume.go

@@ -41,8 +41,8 @@ func (m Manager) FetchVolumes() ([]string, error) {
 		return nil, errors.New("error fetching volumes " + err.Error())
 	}
 	var volumeNames []string = make([]string, len(volumes.Volumes))
-	for i , v := range volumes.Volumes {
+	for i, v := range volumes.Volumes {
 		volumeNames[i] = v.Name
 	}
 	return volumeNames, nil
-}
+}

docker_config_generator/constructor.go

@@ -21,9 +21,9 @@ func (m *Manager) Init() error {
 	// Load templates
 	m.DockerTemplates = map[string]string{}
 	for service, template := range m.Config.Templates {
-		data, err := templateFolder.ReadFile("templates/"+template.Name)
+		data, err := templateFolder.ReadFile("templates/" + template.Name)
 		if err != nil {
-			return errors.New("failed to read template : "+template.Name)
+			return errors.New("failed to read template : " + template.Name)
 		}
 		m.DockerTemplates[service] = string(data)
 	}

docker_config_generator/helper.go

@@ -48,7 +48,7 @@ func ExtractTar(tarFile string, destFolder string) error {
 			return err
 		}
 	}
-	
+
 	// Create tar reader
 	tr := tar.NewReader(reader)
 
@@ -100,28 +100,27 @@ func ExtractTar(tarFile string, destFolder string) error {
 }
 
 func createDirectoriesIfNotExist(filePath string) error {
-    dir := filepath.Dir(filePath)
-    return os.MkdirAll(dir, 0755) // 0755 sets the permissions for the new directories
+	dir := filepath.Dir(filePath)
+	return os.MkdirAll(dir, 0755) // 0755 sets the permissions for the new directories
 }
 
 func createFileWithDirectories(filePath string, fileMode os.FileMode) (*os.File, error) {
-    if err := createDirectoriesIfNotExist(filePath); err != nil {
-        return nil, err
-    }
+	if err := createDirectoriesIfNotExist(filePath); err != nil {
+		return nil, err
+	}
 
-    file, err := os.OpenFile(filePath, os.O_CREATE|os.O_RDWR, fileMode)
-    if err != nil {
-        return nil, err
-    }
+	file, err := os.OpenFile(filePath, os.O_CREATE|os.O_RDWR, fileMode)
+	if err != nil {
+		return nil, err
+	}
 
-    return file, nil
+	return file, nil
 }
 
 func deleteDirectory(dir string) {
 	os.RemoveAll(dir)
 }
 
-
 // Check if a file exists in folder
 func existsInFolder(destFolder string, file string) bool {
 	path := filepath.Join(destFolder, file)

docker_config_generator/types.go

@@ -40,7 +40,7 @@ type IdentifierSelector struct {
 
 // DockerFile Config
 type DockerFileConfig struct {
-	DetectedService string `json:"detected_service"`
-	DockerFile string `json:"docker_file"`
-	Variables map[string]Variable `json:"variables"`
-}
+	DetectedService string              `json:"detected_service"`
+	DockerFile      string              `json:"docker_file"`
+	Variables       map[string]Variable `json:"variables"`
+}