ranger - mirror of ranger - a simple, vim-like file manager

about summary refs log tree commit diff stats

diff options

Diffstat (limited to '.gitignore')

0 files changed, 0 insertions, 0 deletions

05-20 03:32:14 -0400 committer Ben Morrison <ben@gbmor.dev> 2019-05-20 04:19:26 -0400 streamlined error handling and misc minor fixes' href='/gbmor/getwtxt/commit/query.go?h=v0.4.15&id=fc49c5701fde7d0c9dd2fa321ba0ebbff712b08a'>fc49c57 ^

efa99ed ^

fc49c57 ^

efa99ed ^

fc49c57 ^

efa99ed ^

37bf8b0 ^

efa99ed ^

fc49c57 ^

efa99ed ^

efa99ed ^

3c5dd59 ^

37be25f ^

37bf8b0 ^

efa99ed ^

37be25f ^

3c5dd59 ^

efa99ed ^

3c5dd59 ^

efa99ed ^

37be25f ^

efa99ed ^

37bf8b0 ^

efa99ed ^

37bf8b0 ^

efa99ed ^

fc49c57 ^

efa99ed ^

fc49c57 ^

efa99ed ^

a6f47c0 ^

efa99ed ^

a6f47c0 ^

efa99ed ^

fc49c57 ^

bce5265 ^

efa99ed ^

1
2
3

17
18
19

34
35

36
37

56
57
58

74
75

78
79
80

81
82
83

90
91
92

94
95
96

111
112

115
116

package main

import (
	"crypto/sha256"
	"fmt"
	"log"
	"net/http"
	"strings"

	"github.com/gorilla/mux"
)

func apiErrCheck(err error, r *http.Request) {
	if err != nil {
		uip := getIPFromCtx(r.Context())
		log.Printf("*** %v :: %v %v :: %v\n", uip, r.Method, r.URL, err)
	}
}

// Takes the output of queries and formats it for
// an HTTP response. Iterates over the string slice,
// appending each entry to a byte slice, and adding
// newlines where appropriate.
func parseQueryOut(out []string) []byte {
	var data []byte

	for _, e := range out {
		data = append(data, []byte(e)...)

		if !strings.HasSuffix(e, "\n") {
			data = append(data, byte('\n'))
		}
	}

	return data
}

// Removes duplicate statuses from query output
func uniq(str []string) []string {
	keys := make(map[string]bool)
	out := []string{}
	for _, e := range str {
		if _, ok := keys[e]; !ok {
			keys[e] = true
			out = append(out, e)
		}
	}
	return out
}

// apiUserQuery is called via apiEndpointHandler when
// the endpoint is "users" and r.FormValue("q") is not empty.
// It queries the registry cache for users or user URLs
// matching the term supplied via r.FormValue("q")
func apiEndpointQuery(w http.ResponseWriter, r *http.Request) error {
	query := r.FormValue("q")
	urls := r.FormValue("url")
	var out []string
	var err error

	vars := mux.Vars(r)
	endpoint := vars["endpoint"]

	// Handle user URL queries first, then nickname queries.
	// Concatenate both outputs if they're both set.
	// Also handle mention queries and status queries.
	// If we made it this far and 'default' is matched,
	// something went very wrong.
	switch endpoint {
	case "users":
		var out2 []string
		if query != "" {
			out, err = twtxtCache.QueryUser(query)
			apiErrCheck(err, r)
		}
		if urls != "" {
			out2, err = twtxtCache.QueryUser(urls)
			apiErrCheck(err, r)
		}

		out = append(out, out2...)
		out = uniq(out)

	case "mentions":
		if urls == "" {
			return fmt.Errorf("missing URL in mention query")
		}
		urls += ">"
		out, err = twtxtCache.QueryInStatus(urls)
		apiErrCheck(err, r)

	case "tweets":
		query = strings.ToLower(query)
		out, err = twtxtCache.QueryInStatus(query)
		apiErrCheck(err, r)

		query = strings.Title(query)
		out2, err := twtxtCache.QueryInStatus(query)
		apiErrCheck(err, r)

		query = strings.ToUpper(query)
		out3, err := twtxtCache.QueryInStatus(query)
		apiErrCheck(err, r)

		out = append(out, out2...)
		out = append(out, out3...)
		out = uniq(out)

	default:
		return fmt.Errorf("endpoint query, no cases match")
	}

	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)

	return err
}


context:
space:
mode: