summary refs log tree commit diff stats
path: root/handlers.go
diff options
context:
space:
mode:
authorBen Morrison <ben@gbmor.dev>2019-06-05 15:36:23 -0400
committerBen Morrison <ben@gbmor.dev>2019-06-05 15:36:23 -0400
commitfd43c61bd128ad77b22db0537a9a4eb58490b0b5 (patch)
tree4c5fa7b33fadbf7c3e14e69b7d68ce280bc3810a /handlers.go
parent4658fe82be3e9d95e93fa5c7c7ca64a15cf2f1a1 (diff)
downloadgetwtxt-fd43c61bd128ad77b22db0537a9a4eb58490b0b5.tar.gz
moved bulk of code to its own package to clean up source tree
Diffstat (limited to 'handlers.go')
-rw-r--r--handlers.go228
1 files changed, 0 insertions, 228 deletions
diff --git a/handlers.go b/handlers.go
deleted file mode 100644
index 63b8c26..0000000
--- a/handlers.go
+++ /dev/null
@@ -1,228 +0,0 @@
-package main
-
-import (
-	"crypto/sha256"
-	"fmt"
-	"net/http"
-	"strconv"
-	"strings"
-
-	"github.com/getwtxt/registry"
-	"github.com/gorilla/mux"
-)
-
-// handles "/"
-func indexHandler(w http.ResponseWriter, r *http.Request) {
-
-	pingAssets()
-
-	etag := fmt.Sprintf("%x", sha256.Sum256([]byte(staticCache.indexMod.String())))
-
-	// Take the hex-encoded sha256 sum of the index template's mod time
-	// to send as an ETag. If an error occurred when grabbing the file info,
-	// the ETag will be empty.
-	w.Header().Set("ETag", "\""+etag+"\"")
-	w.Header().Set("Content-Type", htmlutf8)
-
-	_, err := w.Write(staticCache.index)
-	if err != nil {
-		log500(w, r, err)
-		return
-	}
-
-	log200(r)
-}
-
-// handles "/api"
-func apiBaseHandler(w http.ResponseWriter, r *http.Request) {
-	indexHandler(w, r)
-}
-
-// handles "/api/plain"
-// maybe add json/xml support later
-func apiFormatHandler(w http.ResponseWriter, r *http.Request) {
-	indexHandler(w, r)
-}
-
-func apiAllTweetsHandler(w http.ResponseWriter, r *http.Request) {
-	out, err := twtxtCache.QueryAllStatuses()
-	if err != nil {
-		log500(w, r, err)
-	}
-
-	data := parseQueryOut(out)
-	if err != nil {
-		data = []byte("")
-	}
-
-	etag := fmt.Sprintf("%x", sha256.Sum256(data))
-	w.Header().Set("ETag", etag)
-	w.Header().Set("Content-Type", txtutf8)
-
-	_, err = w.Write(data)
-	if err != nil {
-		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
-	}
-
-	page := 1
-	pageVal := r.FormValue("page")
-	if pageVal != "" {
-		page, err = strconv.Atoi(pageVal)
-		if err != nil || page == 0 {
-			page = 1
-		}
-	}
-
-	// if there's no query, return everything in
-	// registry for a given endpoint
-	var out []string
-	switch r.URL.Path {
-	case "/api/plain/users":
-		out, err = twtxtCache.QueryUser("")
-		out = registry.ReduceToPage(page, out)
-
-	case "/api/plain/mentions":
-		out, err = twtxtCache.QueryInStatus("@<")
-		out = registry.ReduceToPage(page, out)
-
-	default:
-		out, err = twtxtCache.QueryAllStatuses()
-		out = registry.ReduceToPage(page, out)
-	}
-
-	data := parseQueryOut(out)
-	if err != nil {
-		data = []byte("")
-	}
-
-	etag := fmt.Sprintf("%x", sha256.Sum256(data))
-	w.Header().Set("ETag", etag)
-	w.Header().Set("Content-Type", txtutf8)
-
-	_, err = w.Write(data)
-	if err != nil {
-		log500(w, r, err)
-		return
-	}
-
-	log200(r)
-}
-
-// handles POST for "/api/plain/users"
-func apiEndpointPOSTHandler(w http.ResponseWriter, r *http.Request) {
-	apiPostUser(w, r)
-}
-
-// handles "/api/plain/tags"
-func apiTagsBaseHandler(w http.ResponseWriter, r *http.Request) {
-
-	out, err := twtxtCache.QueryInStatus("#")
-	if err != nil {
-		log500(w, r, err)
-		return
-	}
-
-	out = registry.ReduceToPage(1, out)
-	data := parseQueryOut(out)
-
-	etag := fmt.Sprintf("%x", sha256.Sum256(data))
-	w.Header().Set("ETag", etag)
-	w.Header().Set("Content-Type", txtutf8)
-
-	_, err = w.Write(data)
-	if err != nil {
-		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"]
-
-	tags = strings.ToLower(tags)
-	out, err := twtxtCache.QueryInStatus("#" + tags)
-	if err != nil {
-		log500(w, r, err)
-		return
-	}
-	tags = strings.Title(tags)
-	out2, err := twtxtCache.QueryInStatus("#" + tags)
-	if err != nil {
-		log500(w, r, err)
-		return
-	}
-	tags = strings.ToUpper(tags)
-	out3, err := twtxtCache.QueryInStatus("#" + tags)
-	if err != nil {
-		log500(w, r, err)
-		return
-	}
-
-	out = append(out, out2...)
-	out = append(out, out3...)
-	out = uniq(out)
-
-	out = registry.ReduceToPage(1, out)
-	data := parseQueryOut(out)
-
-	etag := fmt.Sprintf("%x", sha256.Sum256(data))
-	w.Header().Set("ETag", etag)
-	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 in getwtxt.
-func cssHandler(w http.ResponseWriter, r *http.Request) {
-
-	// Sending the sha256 sum of the modtime in hexadecimal for the ETag header
-	etag := fmt.Sprintf("%x", sha256.Sum256([]byte(staticCache.cssMod.String())))
-
-	w.Header().Set("ETag", "\""+etag+"\"")
-	w.Header().Set("Content-Type", cssutf8)
-
-	pingAssets()
-
-	n, err := w.Write(staticCache.css)
-	if err != nil || n == 0 {
-		log500(w, r, err)
-		return
-	}
-
-	log200(r)
-}