rest.Logger - Code Metrics - Inspection of "docs: changelog" - viasite/planfix-toggl-server - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 7456e0...8eb6db )

by Stanislav

created 2018-03-11 20:26 UTC

rest.Logger F

↳ Parent: app/rest/middleware.go

Complexity

Conditions

Size

Total Lines	58
Code Lines	34

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	16
eloc	34
nop	1
dl	0
loc	58
rs	2.4
c	0
b	0
f	0

How to fix Long Method Complexity

package rest

import (
	"bytes"
	"io/ioutil"
	"log"
	"net/http"
	"net/url"
	"os"
	"regexp"
	"runtime/debug"
	"strings"
	"time"

	"github.com/go-chi/chi/middleware"
	//"github.com/go-chi/render"
)

// JSON is a map alias, just for convenience
type JSON map[string]interface{}

// AppInfo adds custom app-info to the response header
func AppInfo(app string, version string) func(http.Handler) http.Handler {
	f := func(h http.Handler) http.Handler {
		fn := func(w http.ResponseWriter, r *http.Request) {
			w.Header().Set("App-Name", app)
			w.Header().Set("App-Version", version)
			if mhost := os.Getenv("MHOST"); mhost != "" {
				w.Header().Set("Host", mhost)
			}
			h.ServeHTTP(w, r)
		}
		return http.HandlerFunc(fn)
	}
	return f
}

// CORS adds allow origin headers
func CORS(next http.Handler) http.Handler {
	fn := func(w http.ResponseWriter, r *http.Request) {
		w.Header().Set("Access-Control-Allow-Origin", "*")
		w.Header().Set("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept")
		next.ServeHTTP(w, r)
	}
	return http.HandlerFunc(fn)
}

// Ping middleware response with pong to /ping. Stops chain if ping request detected
func Ping(next http.Handler) http.Handler {
	fn := func(w http.ResponseWriter, r *http.Request) {

		if r.Method == "GET" && strings.HasSuffix(strings.ToLower(r.URL.Path), "/ping") {
			w.Header().Set("Content-Type", "text/plain")
			w.WriteHeader(http.StatusOK)
			if _, err := w.Write([]byte("pong")); err != nil {
				log.Printf("[WARN] can't send pong, %s", err)
			}
			return
		}
		next.ServeHTTP(w, r)
	}
	return http.HandlerFunc(fn)
}

// Recoverer is a middleware that recovers from panics, logs the panic and returns a HTTP 500 status if possible.
func Recoverer(next http.Handler) http.Handler {
	fn := func(w http.ResponseWriter, r *http.Request) {
		defer func() {
			if rvr := recover(); rvr != nil {
				log.Printf("[WARN] request panic, %v", rvr)
				debug.PrintStack()
				http.Error(w, http.StatusText(http.StatusInternalServerError), http.StatusInternalServerError)
			}
		}()
		next.ServeHTTP(w, r)
	}
	return http.HandlerFunc(fn)
}

// LoggerFlag type
type LoggerFlag int

// logger flags enum
const (
	LogAll  LoggerFlag = iota
	LogBody
)
const maxBody = 1024

var reMultWhtsp = regexp.MustCompile(`[\s\p{Zs}]{2,}`)

// Logger middleware prints http log. Customized by set of LoggerFlag
func Logger(flags ...LoggerFlag) func(http.Handler) http.Handler {

	inFlags := func(f LoggerFlag) bool {
		for _, flg := range flags {
			if flg == LogAll || flg == f {
				return true
			}
		}
		return false
	}

	f := func(h http.Handler) http.Handler {

		fn := func(w http.ResponseWriter, r *http.Request) {
			ww := middleware.NewWrapResponseWriter(w, 1)

			body := func() (result string) {
				if inFlags(LogBody) {
					if content, err := ioutil.ReadAll(r.Body); err == nil {
						result = string(content)
						r.Body = ioutil.NopCloser(bytes.NewReader(content))

						if len(result) > 0 {
							result = strings.Replace(result, "\n", " ", -1)
							result = reMultWhtsp.ReplaceAllString(result, " ")
						}

						if len(result) > maxBody {
							result = result[:maxBody] + "..."
						}
					}
				}
				return result
			}()

			t1 := time.Now()
			defer func() {
				t2 := time.Now()

				q := r.URL.String()
				if qun, err := url.QueryUnescape(q); err == nil {
					q = qun
				}
				// hide id and pin
				regex := regexp.MustCompile(`favicon\.ico$`)
				if !regex.MatchString(q) {
					log.Printf("[DEBUG] REST %s - %s - %s - %d (%d) - %v %s",
						r.Method, q, strings.Split(r.RemoteAddr, ":")[0],
						ww.Status(), ww.BytesWritten(), t2.Sub(t1), body)
				}
			}()

			h.ServeHTTP(ww, r)
		}
		return http.HandlerFunc(fn)
	}

	return f
}


1			package rest
2
3			import (
4			"bytes"
5			"io/ioutil"
6			"log"
7			"net/http"
8			"net/url"
9			"os"
10			"regexp"
11			"runtime/debug"
12			"strings"
13			"time"
14
15			"github.com/go-chi/chi/middleware"
16			//"github.com/go-chi/render"
17			)
18
19			// JSON is a map alias, just for convenience
20			type JSON map[string]interface{}
21
22			// AppInfo adds custom app-info to the response header
23			func AppInfo(app string, version string) func(http.Handler) http.Handler {
24			f := func(h http.Handler) http.Handler {
25			fn := func(w http.ResponseWriter, r *http.Request) {
26			w.Header().Set("App-Name", app)
27			w.Header().Set("App-Version", version)
28			if mhost := os.Getenv("MHOST"); mhost != "" {
29			w.Header().Set("Host", mhost)
30			}
31			h.ServeHTTP(w, r)
32			}
33			return http.HandlerFunc(fn)
34			}
35			return f
36			}
37
38			// CORS adds allow origin headers
39			func CORS(next http.Handler) http.Handler {
40			fn := func(w http.ResponseWriter, r *http.Request) {
41			w.Header().Set("Access-Control-Allow-Origin", "*")
42			w.Header().Set("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept")
43			next.ServeHTTP(w, r)
44			}
45			return http.HandlerFunc(fn)
46			}
47
48			// Ping middleware response with pong to /ping. Stops chain if ping request detected
49			func Ping(next http.Handler) http.Handler {
50			fn := func(w http.ResponseWriter, r *http.Request) {
51
52			if r.Method == "GET" && strings.HasSuffix(strings.ToLower(r.URL.Path), "/ping") {
53			w.Header().Set("Content-Type", "text/plain")
54			w.WriteHeader(http.StatusOK)
55			if _, err := w.Write([]byte("pong")); err != nil {
56			log.Printf("[WARN] can't send pong, %s", err)
57			}
58			return
59			}
60			next.ServeHTTP(w, r)
61			}
62			return http.HandlerFunc(fn)
63			}
64
65			// Recoverer is a middleware that recovers from panics, logs the panic and returns a HTTP 500 status if possible.
66			func Recoverer(next http.Handler) http.Handler {
67			fn := func(w http.ResponseWriter, r *http.Request) {
68			defer func() {
69			if rvr := recover(); rvr != nil {
70			log.Printf("[WARN] request panic, %v", rvr)
71			debug.PrintStack()
72			http.Error(w, http.StatusText(http.StatusInternalServerError), http.StatusInternalServerError)
73			}
74			}()
75			next.ServeHTTP(w, r)
76			}
77			return http.HandlerFunc(fn)
78			}
79
80			// LoggerFlag type
81			type LoggerFlag int
82
83			// logger flags enum
84			const (
85			LogAll LoggerFlag = iota
86			LogBody
87			)
88			const maxBody = 1024
89
90			var reMultWhtsp = regexp.MustCompile(`[\s\p{Zs}]{2,}`)
91
92			// Logger middleware prints http log. Customized by set of LoggerFlag
93			func Logger(flags ...LoggerFlag) func(http.Handler) http.Handler {
94
95			inFlags := func(f LoggerFlag) bool {
96			for _, flg := range flags {
97			if flg == LogAll \|\| flg == f {
98			return true
99			}
100			}
101			return false
102			}
103
104			f := func(h http.Handler) http.Handler {
105
106			fn := func(w http.ResponseWriter, r *http.Request) {
107			ww := middleware.NewWrapResponseWriter(w, 1)
108
109			body := func() (result string) {
110			if inFlags(LogBody) {
111			if content, err := ioutil.ReadAll(r.Body); err == nil {
112			result = string(content)
113			r.Body = ioutil.NopCloser(bytes.NewReader(content))
114
115			if len(result) > 0 {
116			result = strings.Replace(result, "\n", " ", -1)
117			result = reMultWhtsp.ReplaceAllString(result, " ")
118			}
119
120			if len(result) > maxBody {
121			result = result[:maxBody] + "..."
122			}
123			}
124			}
125			return result
126			}()
127
128			t1 := time.Now()
129			defer func() {
130			t2 := time.Now()
131
132			q := r.URL.String()
133			if qun, err := url.QueryUnescape(q); err == nil {
134			q = qun
135			}
136			// hide id and pin
137			regex := regexp.MustCompile(`favicon\.ico$`)
138			if !regex.MatchString(q) {
139			log.Printf("[DEBUG] REST %s - %s - %s - %d (%d) - %v %s",
140			r.Method, q, strings.Split(r.RemoteAddr, ":")[0],
141			ww.Status(), ww.BytesWritten(), t2.Sub(t1), body)
142			}
143			}()
144
145			h.ServeHTTP(ww, r)
146			}
147			return http.HandlerFunc(fn)
148			}
149
150			return f
151			}
152

viasite / planfix-toggl-server

Push — master ( 7456e0...8eb6db )

rest.Logger F

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity

Long Method

Complexity

Duplication Side-by-Side

Filter issues like