diff options
author | Ben Morrison <ben@gbmor.dev> | 2019-05-20 04:22:17 -0400 |
---|---|---|
committer | Ben Morrison <ben@gbmor.dev> | 2019-05-20 04:22:17 -0400 |
commit | 1168570b071d8bb483e4028f3a8c45a222c93ecb (patch) | |
tree | 63d80521492c44a2af1b4918a67ff24e29006196 /handlers.go | |
parent | fc49c5701fde7d0c9dd2fa321ba0ebbff712b08a (diff) | |
download | getwtxt-1168570b071d8bb483e4028f3a8c45a222c93ecb.tar.gz |
renamed files for clarity
Diffstat (limited to 'handlers.go')
-rw-r--r-- | handlers.go | 209 |
1 files changed, 209 insertions, 0 deletions
diff --git a/handlers.go b/handlers.go new file mode 100644 index 0000000..7cf3ad2 --- /dev/null +++ b/handlers.go @@ -0,0 +1,209 @@ +package main + +import ( + "crypto/sha256" + "fmt" + "io/ioutil" + "log" + "net/http" + "os" + "time" + + "github.com/gorilla/mux" +) + +// handles "/" +func indexHandler(w http.ResponseWriter, r *http.Request) { + + // Stat the index template to get the mod time + var etag string + if indextmpl, err := os.Stat("assets/tmpl/index.html"); err != nil { + log.Printf("Couldn't stat index template for ETag ... %v\n", err) + } else { + etag = fmt.Sprintf("%x", sha256.Sum256([]byte(indextmpl.ModTime().String()))) + } + + // Take the hex-encoded sha256 sum of the index template's mod time + // to send as an ETag. If an error occured when grabbing the file info, + // the ETag will be empty. + w.Header().Set("ETag", "\""+etag+"\"") + w.Header().Set("Content-Type", htmlutf8) + + // Pass the confObj.Instance data to the template, + // then send it to the client. + err := tmpls.ExecuteTemplate(w, "index.html", confObj.Instance) + if err != nil { + log500(w, r, err) + return + } + + log200(r) +} + +// handles "/api" +func apiBaseHandler(w http.ResponseWriter, r *http.Request) { + + timerfc3339, err := time.Now().MarshalText() + if err != nil { + log.Printf("Couldn't format time as RFC3339: %v\n", err) + } + + etag := fmt.Sprintf("%x", sha256.Sum256(timerfc3339)) + + w.Header().Set("ETag", etag) + w.Header().Set("Content-Type", txtutf8) + + pathdata := []byte("\n\n" + r.URL.Path) + timerfc3339 = append(timerfc3339, pathdata...) + + n, err := w.Write(timerfc3339) + if err != nil || n == 0 { + log500(w, r, err) + return + } + + log200(r) +} + +// handles "/api/plain" +// maybe add json/xml support later +func apiFormatHandler(w http.ResponseWriter, r *http.Request) { + + vars := mux.Vars(r) + format := vars["format"] + + w.Header().Set("Content-Type", txtutf8) + + n, err := w.Write([]byte(format + "\n")) + if err != nil || n == 0 { + log500(w, r, err) + return + } + + log200(r) +} + +// handles "/api/plain/(users|mentions|tweets)" +func apiEndpointHandler(w http.ResponseWriter, r *http.Request) { + + err := r.ParseForm() + if err != nil { + log500(w, r, err) + return + } + + if r.FormValue("q") != "" || r.FormValue("url") != "" { + err := apiEndpointQuery(w, r) + if err != nil { + log500(w, r, err) + return + } + log200(r) + return + } + + w.Header().Set("Content-Type", htmlutf8) + + n, err := w.Write([]byte(r.URL.String())) + if err != nil || n == 0 { + log500(w, r, err) + return + } + + log200(r) +} + +// handles POST for "/api/plain/users" +func apiEndpointPOSTHandler(w http.ResponseWriter, r *http.Request) { + + vars := mux.Vars(r) + format := vars["format"] + endpoint := vars["endpoint"] + + w.Header().Set("Content-Type", htmlutf8) + + _, err := w.Write([]byte(format + "/" + endpoint)) + if err != nil { + log500(w, r, err) + return + } + + log200(r) +} + +// handles "/api/plain/tags" +func apiTagsBaseHandler(w http.ResponseWriter, r *http.Request) { + + vars := mux.Vars(r) + format := vars["format"] + + w.Header().Set("Content-Type", htmlutf8) + + n, err := w.Write([]byte("api/" + format + "/tags")) + if err != nil || n == 0 { + log500(w, r, err) + return + } + + log200(r) +} + +// handles "/api/plain/tags/[a-zA-Z0-9]+" +func apiTagsHandler(w http.ResponseWriter, r *http.Request) { + + vars := mux.Vars(r) + tags := vars["tags"] + + out, err := twtxtCache.QueryInStatus(tags) + if err != nil { + log500(w, r, err) + return + } + + data := parseQueryOut(out) + + w.Header().Set("Content-Type", txtutf8) + _, err = w.Write(data) + if err != nil { + log500(w, r, err) + return + } + + log200(r) +} + +// Serving the stylesheet virtually because +// files aren't served directly. +func cssHandler(w http.ResponseWriter, r *http.Request) { + + // read the raw bytes of the stylesheet + css, err := ioutil.ReadFile("assets/style.css") + if err != nil { + if os.IsNotExist(err) { + log404(w, r, err) + return + } + log500(w, r, err) + return + } + + // Get the mod time for the etag header + stat, err := os.Stat("assets/style.css") + if err != nil { + log.Printf("Couldn't stat CSS file to send ETag header: %v\n", err) + } + + // Sending the sha256 sum of the modtime in hexadecimal for the ETag header + etag := fmt.Sprintf("%x", sha256.Sum256([]byte(stat.ModTime().String()))) + + w.Header().Set("ETag", "\""+etag+"\"") + w.Header().Set("Content-Type", cssutf8) + + n, err := w.Write(css) + if err != nil || n == 0 { + log500(w, r, err) + return + } + + log200(r) +} |