feat: add Docker Swarm mode check in event handlers (#510)

Author: kimdre

cmd/doco-cd/http_handler.go

@@ -59,6 +59,8 @@ func getRepoName(cloneURL string) string {
 
 // HandleEvent handles the incoming webhook event.
 func HandleEvent(ctx context.Context, jobLog *slog.Logger, w http.ResponseWriter, appConfig *config.AppConfig, dataMountPoint container.MountPoint, payload webhook.ParsedPayload, customTarget, jobID string, dockerCli command.Cli, dockerClient *client.Client) {
+	var err error
+
 	startTime := time.Now()
 	repoName := getRepoName(payload.CloneURL)
 
@@ -73,6 +75,15 @@ func HandleEvent(ctx context.Context, jobLog *slog.Logger, w http.ResponseWriter
 			slog.String("commit", payload.CommitSHA), slog.String("ref", payload.Ref),
 			slog.String("event", "webhook")))
 
+	if appConfig.DockerSwarmFeatures {
+		// Check if docker host is running in swarm mode
+		docker.SwarmModeEnabled, err = docker.CheckDaemonIsSwarmManager(ctx, dockerCli)
+		if err != nil {
+			jobLog.Error("failed to check if docker host is running in swarm mode")
+			onError(repoName, w, jobLog.With(logger.ErrAttr(err)), "failed to check if docker host is running in swarm mode", err.Error(), jobID, http.StatusInternalServerError)
+		}
+	}
+
 	// Clone the repository
 	jobLog.Debug(
 		"get repository",

cmd/doco-cd/main.go

@@ -1,7 +1,6 @@
 package main
 
 import (
-	"context"
 	"errors"
 	"fmt"
 	"log/slog"
@@ -196,16 +195,6 @@ func main() {
 		return
 	}
 
-	if c.DockerSwarmFeatures {
-		// Check if docker host is running in swarm mode
-		docker.SwarmModeEnabled, err = docker.CheckDaemonIsSwarmManager(context.Background(), dockerCli)
-		if err != nil {
-			log.Critical("failed to check if docker host is running in swarm mode", logger.ErrAttr(err))
-
-			return
-		}
-	}
-
 	log.Debug("negotiated docker versions to use",
 		slog.Group("versions",
 			slog.String("docker_client", dockerClient.ClientVersion()),

cmd/doco-cd/poll_handler.go

@@ -104,12 +104,24 @@ func (h *handlerData) PollHandler(pollJob *config.PollJob) {
 
 // RunPoll deploys compose projects based on the provided configuration.
 func RunPoll(ctx context.Context, pollConfig config.PollConfig, appConfig *config.AppConfig, dataMountPoint container.MountPoint, dockerCli command.Cli, dockerClient *client.Client, logger *slog.Logger) error {
+	var err error
+
 	startTime := time.Now()
 	cloneUrl := string(pollConfig.CloneUrl)
 	jobID := uuid.Must(uuid.NewRandom()).String()
 	repoName := getRepoName(cloneUrl)
 	jobLog := logger.With(slog.String("job_id", jobID))
 
+	if appConfig.DockerSwarmFeatures {
+		// Check if docker host is running in swarm mode
+		docker.SwarmModeEnabled, err = docker.CheckDaemonIsSwarmManager(ctx, dockerCli)
+		if err != nil {
+			jobLog.Error("failed to check if docker host is running in swarm mode")
+
+			return fmt.Errorf("failed to check if docker host is running in swarm mode: %w", err)
+		}
+	}
+
 	if strings.Contains(repoName, "..") {
 		jobLog.Error("invalid repository name, contains '..'")