about summary refs log tree commit diff stats
path: root/enumerate
diff options
context:
space:
mode:
Diffstat (limited to 'enumerate')
0 files changed, 0 insertions, 0 deletions
 

generated by cgit-pink 1.4.1-2-gfad0 (git 2.36.2.497.gbbea4dcf42) at 2024-11-27 08:33:47 +0000


 


70ff61d3f8a7bb1bed896a913b0999450'>^



fc49c57 ^













efa99ed ^

fc49c57 ^


efa99ed ^


37bf8b0 ^













efa99ed ^




fc49c57 ^

efa99ed ^



efa99ed ^












37be25f ^

37bf8b0 ^

efa99ed ^


37be25f ^

37bf8b0 ^

efa99ed ^




37be25f ^





efa99ed ^



37bf8b0 ^

efa99ed ^



37bf8b0 ^












efa99ed ^

fc49c57 ^

efa99ed ^


fc49c57 ^

efa99ed ^



fc49c57 ^

bce5265 ^

efa99ed ^



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
67
68
69

70

71

72
73

74

75

76
77
78
79

80
81
82
83
84

85
86
87

88

89
90
91

92
93
94
95
96
97
98
99
100
101
102
103

104

105

106
107

108

109
110
111

112

113

114





            
             









                                                
                                                                                


         












                                                       
         

                   

 












                                               



                                                             
                                                                     


                                  











                                                                
                                
                                                              

                                           
                               
                                                             



                                           




                                                                         


                                   
                                              


                                                          











                                                            
                
                                                                   

         
                                  


                                               
 
                  
 
package main

import (
	"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":
		if query != "" {
			out, err = twtxtCache.QueryUser(query)
			apiErrCheck(err, r)
		}
		if urls != "" {
			out, err = twtxtCache.QueryUser(urls)
			apiErrCheck(err, r)
		}

	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)

	w.Header().Set("Content-Type", txtutf8)
	_, err = w.Write(data)

	return err
}