fix: changed err object input to getter function

core/cmd_connection/docker_create.go

@@ -128,17 +128,17 @@
 	if err != nil {
 		return nil, err
 	}
-	defer func() {
-		helpers.WarnOnErr(
-			d.log,
-			d.cli.ContainerRemove(ctx, exec.ID,
+	defer helpers.WarnOnErr(
+		d.log,
+		func() error {
+			return d.cli.ContainerRemove(ctx, exec.ID,
 				container.RemoveOptions{
 					Force: true,
 				},
-			),
-			"cannot remove the container: %s",
-		)
-	}()
+			)
+		},
+		"cannot remove the container: %s",
+	)
 
 	for {
 		err = d.cli.ContainerStart(
@@ -181,13 +181,13 @@
 	if err != nil {
 		return nil, err
 	}
-	defer func() {
-		helpers.WarnOnErr(
-			d.log,
-			resp.Close(),
-			"cannot close the container's logs: %s",
-		)
-	}()
+	defer helpers.WarnOnErr(
+		d.log,
+		func() error {
+			return resp.Close()
+		},
+		"cannot close the container's logs: %s",
+	)
 
 	writer := bytes.NewBuffer([]byte{})
 	// Print the command output

core/task/command.go

@@ -70,7 +70,13 @@
 		if err := connection.Prepare(cmdCtx, c.task); err != nil {
 			log.Warn("cannot prepare command: ", err)
 			ctx = addFailedConnections(ctx, conn)
-			helpers.WarnOnErr(log, connection.Disconnect(), "Cannot disconnect the command's connection: %s")
+			helpers.WarnOnErr(
+				log,
+				func() error {
+					return connection.Disconnect()
+				},
+				"Cannot disconnect the command's connection: %s",
+			)
 			continue
 		}
 

core/task/get.go

@@ -63,9 +63,13 @@ func (g *Get) Execute(ctx context.Context) (e error) {
 	res, err := client.Do(req)
 	if res != nil {
 		if res.Body != nil {
-			defer func() {
-				helpers.WarnOnErr(log, res.Body.Close(), "cannot close response body: %s")
-			}()
+			defer helpers.WarnOnErr(
+				log,
+				func() error {
+					return res.Body.Close()
+				},
+				"cannot close response body: %s",
+			)
 		}
 		log = log.WithField("status", res.StatusCode)
 		log.Infoln("received response with status: ", res.Status)

core/task/post.go

@@ -83,9 +83,13 @@ func (p *Post) Execute(ctx context.Context) (e error) {
 
 	if res != nil {
 		if res.Body != nil {
-			defer func() {
-				helpers.WarnOnErr(log, res.Body.Close(), "cannot close response body: %s")
-			}()
+			defer helpers.WarnOnErr(
+				log,
+				func() error {
+					return res.Body.Close()
+				},
+				"cannot close response body: %s",
+			)
 		}
 		log = log.WithField("status", res.StatusCode)
 		log.Infoln("received response with status: ", res.Status)

core/webserver/webserver.go

@@ -85,7 +85,13 @@ func (s *WebServer) Serve() {
 	}
 
 	err := engine.Run(fmt.Sprintf("%s:%d", s.address, s.port))
-	helpers.FatalOnErr(s.log, err, "Failed to start webserver: %s")
+	helpers.FatalOnErr(
+		s.log,
+		func() error {
+			return err
+		},
+		"Failed to start webserver: %s",
+	)
 }
 
 func (s *WebServer) formatter(params gin.LogFormatterParams) string {

helpers/err_handlers.go

@@ -5,20 +5,22 @@ import (
 	"github.com/sirupsen/logrus"
 )
 
-func PanicOnErr(log *logrus.Entry, err error, message string) {
-	if err != nil {
+func PanicOnErr(log *logrus.Entry, errorCatcher func() error, message string) {
+	if err := errorCatcher(); err != nil {
 		log.Panicf(message, err)
 	}
 }
 
-func FatalOnErr(log *logrus.Entry, err error, message string) {
-	if err != nil {
+func FatalOnErr(log *logrus.Entry, errorCatcher func() error, message string) {
+	if err := errorCatcher(); err != nil {
 		log.Fatalf(message, err)
 	}
 }
 
-func WarnOnErr(log *logrus.Entry, err error, message string) {
-	if err != nil {
+func WarnOnErr(log *logrus.Entry, errorCatcher func() error, message string) error {
+	if err := errorCatcher(); err != nil {
 		log.Warnf(message, err)
+		return err
 	}
+	return nil
 }