GitHub Access Token became invalid

It seems like the GitHub access token used for retrieving details about this repository from GitHub became invalid. This might prevent certain types of inspections from being run (in particular, everything related to pull requests).
Please ask an admin of your repository to re-new the access token on this website.
Test Setup Failed
Push — master ( 169bb3...d84165 )
by Amir
01:27
created

httpserver.HTTPServe   A

Complexity

Conditions 1

Size

Total Lines 4
Code Lines 4

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
cc 1
eloc 4
nop 2
dl 0
loc 4
rs 10
c 0
b 0
f 0
1
package httpserver
2
3
import (
4
	"bytes"
5
	"github.com/arazmj/gerdu/cache"
6
	"github.com/gorilla/mux"
7
	"github.com/prometheus/client_golang/prometheus/promhttp"
8
	log "github.com/sirupsen/logrus"
9
	"net/http"
10
)
11
12
func newRouter(gerdu cache.UnImplementedCache) (router *mux.Router) {
13
	router = mux.NewRouter()
14
	router.HandleFunc("/cache/{key}", func(w http.ResponseWriter, r *http.Request) {
15
		getHandler(w, r, gerdu)
16
	}).Methods(http.MethodGet)
17
	router.HandleFunc("/cache/{key}", func(w http.ResponseWriter, r *http.Request) {
18
		putHandler(w, r, gerdu)
19
	}).Methods(http.MethodPut)
20
	router.HandleFunc("/cache/{key}", func(w http.ResponseWriter, r *http.Request) {
21
		deleteHandler(w, r, gerdu)
22
	}).Methods(http.MethodDelete)
23
	router.Handle("/metrics", promhttp.Handler())
24
	return router
25
}
26
27
//HTTPServe start http server in plain text
28
func HTTPServe(host string, gerdu cache.UnImplementedCache) {
29
	router := newRouter(gerdu)
30
	log.Infof("Gerdu started listening HTTP on %s\n", host)
31
	log.Fatal(http.ListenAndServe(host, router))
32
}
33
34
//HTTPServeTLS start HTTP server in secure mode
35
func HTTPServeTLS(host string, tlsCert, tlsKey string, gerdu cache.UnImplementedCache) {
36
	router := newRouter(gerdu)
37
	log.Printf("Gerdu started listening HTTPS TLS on %s\n", host)
38
	log.Fatal(http.ListenAndServeTLS(host, tlsCert, tlsKey, router))
39
}
40
41
func putHandler(w http.ResponseWriter, r *http.Request, gerdu cache.UnImplementedCache) {
42
	vars := mux.Vars(r)
43
	key := vars["key"]
44
	buf := new(bytes.Buffer)
45
	_, err := buf.ReadFrom(r.Body)
46
	if err != nil {
47
		log.Fatal(err.Error())
48
		return
49
	}
50
	value := buf.String()
51
52
	created := gerdu.Put(key, value)
53
	if !created {
54
		log.Printf("HTTP UPDATE Key: %s Value: %s\n", key, value)
55
	} else {
56
		log.Printf("HTTP INSERT Key: %s Value: %s\n", key, value)
57
	}
58
59
	if created {
60
		w.WriteHeader(http.StatusCreated)
61
	} else {
62
		w.WriteHeader(http.StatusNoContent)
63
	}
64
}
65
66
func getHandler(w http.ResponseWriter, r *http.Request, gerdu cache.UnImplementedCache) {
67
	vars := mux.Vars(r)
68
	key := vars["key"]
69
	if value, ok := gerdu.Get(key); ok {
70
		log.Printf("HTTP RETREIVED Key: %s Value: %s\n", key, value)
71
		w.WriteHeader(http.StatusOK)
72
		_, _ = w.Write([]byte(value))
73
	} else {
74
		log.Printf("HTTP MISSED Key: %s \n", key)
75
		w.WriteHeader(http.StatusNotFound)
76
	}
77
}
78
79
func deleteHandler(w http.ResponseWriter, r *http.Request, gerdu cache.UnImplementedCache) {
80
	vars := mux.Vars(r)
81
	key := vars["key"]
82
	if ok := gerdu.Delete(key); ok {
83
		log.Printf("HTTP DELETED Key: %s\n", key)
84
		w.WriteHeader(http.StatusOK)
85
	} else {
86
		log.Printf("HTTP MISSED Key: %s \n", key)
87
		w.WriteHeader(http.StatusNotFound)
88
	}
89
}
90