-
Notifications
You must be signed in to change notification settings - Fork 4
/
Copy pathhandlers.go
66 lines (57 loc) · 1.54 KB
/
handlers.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
package main
import (
"crypto/md5"
"encoding/json"
"fmt"
"io/ioutil"
"log"
"net/http"
)
type GrafanaImage struct {
Url string `json:"imageUrl"`
}
func GrafanaImagesHandler(imageHost string, imagePath string) http.HandlerFunc {
return func(w http.ResponseWriter, req *http.Request) {
var image GrafanaImage
if req.Method != "POST" {
http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
w.Header().Set("Allow", "POST")
return
}
if err := json.NewDecoder(req.Body).Decode(&image); err != nil {
http.Error(w, "Error parsing JSON", http.StatusBadRequest)
return
}
token := req.Header.Get("Authorization")
log.Println("received request:", image.Url, "token:", token)
// Fetch image
var client = http.Client{}
req, err := http.NewRequest("GET", image.Url, nil)
req.Header.Add("Accept", "application/json")
req.Header.Add("Authorization", token)
resp, err := client.Do(req)
if err != nil {
log.Fatalf("http.Get -> %v", err)
w.WriteHeader(500)
return
}
data, err := ioutil.ReadAll(resp.Body)
if err != nil {
log.Fatalf("ioutil.ReadAll -> %v", err)
w.WriteHeader(500)
return
}
// Save image
fileName := fmt.Sprintf("%x.png", md5.Sum(data))
resp.Body.Close()
err = ioutil.WriteFile(fmt.Sprintf("%s/%s", imagePath, fileName), data, 0666)
if err != nil {
log.Fatalf("ioutil.WriteFile -> %v", err)
w.WriteHeader(500)
return
}
// Return image location
w.Header().Set("Content-Type", "application/json")
fmt.Fprintf(w, "{\"pubImg\":\"%s/%s\"}", imageHost, fileName)
}
}