update dtmcli for dtm-cases/cache

dtmcli/logger/log.go

@@ -6,6 +6,7 @@ import (
 	"log"
 	"net/url"
 	"os"
+	"runtime/debug"
 	"strings"
 
 	"github.com/natefinch/lumberjack"
@@ -124,6 +125,7 @@ func FatalfIf(cond bool, fmt string, args ...interface{}) {
 	if !cond {
 		return
 	}
+	debug.PrintStack()
 	log.Fatalf(fmt, args...)
 }
 

dtmcli/types.go

@@ -82,16 +82,24 @@ func SetPassthroughHeaders(headers []string) {
 	dtmimp.PassthroughHeaders = headers
 }
 
-// Result2HttpCode return the http code for the result
+// Result2HttpJson return the http code and json result
 // if result is error, the return proper code, else return StatusOK
-func Result2HttpCode(result interface{}) int {
+func Result2HttpJson(result interface{}) (code int, res interface{}) {
 	err, _ := result.(error)
-	if errors.Is(err, ErrFailure) {
+	if err == nil {
-		return http.StatusConflict
+		code = http.StatusOK
-	} else if errors.Is(err, ErrOngoing) {
+		res = result
-		return http.StatusTooEarly
+	} else {
-	} else if err != nil {
+		res = map[string]string{
-		return http.StatusInternalServerError
+			"error": err.Error(),
+		}
+		if errors.Is(err, ErrFailure) {
+			code = http.StatusConflict
+		} else if errors.Is(err, ErrOngoing) {
+			code = http.StatusTooEarly
+		} else if err != nil {
+			code = http.StatusInternalServerError
+		}
 	}
-	return http.StatusOK
+	return
 }

dtmutil/utils.go

@@ -52,15 +52,15 @@ func WrapHandler(fn func(*gin.Context) interface{}) gin.HandlerFunc {
 	return func(c *gin.Context) {
 		began := time.Now()
 		ret := fn(c)
-		status := dtmcli.Result2HttpCode(ret)
+		status, res := dtmcli.Result2HttpJson(ret)
 
-		b, _ := json.Marshal(ret)
+		b, _ := json.Marshal(res)
 		if status == http.StatusOK || status == http.StatusTooEarly {
 			logger.Infof("%2dms %d %s %s %s", time.Since(began).Milliseconds(), status, c.Request.Method, c.Request.RequestURI, string(b))
 		} else {
 			logger.Errorf("%2dms %d %s %s %s", time.Since(began).Milliseconds(), status, c.Request.Method, c.Request.RequestURI, string(b))
 		}
-		c.JSON(status, ret)
+		c.JSON(status, res)
 	}
 }