Moved cons_show_room_invite() to console module - profani-tty

about summary refs log tree commit diff stats

diff options

author	James Booth <boothj5@gmail.com>	2013-04-21 01:15:10 +0100
committer	James Booth <boothj5@gmail.com>	2013-04-21 01:15:10 +0100
commit	60acd4778020fac0e0207f242304323e2aa56cb8 (patch)
tree	884a2ef4394c11911525bc2a0a819d7e54ea0081 /src/muc.c
parent	688eea083bd25af39d11b6f993b0d1bf02535959 (diff)
download	profani-tty-60acd4778020fac0e0207f242304323e2aa56cb8.tar.gz

Moved cons_show_room_invite() to console module

Diffstat (limited to 'src/muc.c')

0 files changed, 0 insertions, 0 deletions

files for clarity' href='/gbmor/getwtxt/commit/handlers.go?h=v0.4.10&id=1168570b071d8bb483e4028f3a8c45a222c93ecb'>1168570 ^

90638ac ^

1168570 ^

e9d4a6b ^

6c1b09b ^

e9d4a6b ^

adee7fa ^

3d2994b ^

3da400b ^

adee7fa ^

3d2994b ^

3da400b ^

adee7fa ^

3d2994b ^

1168570 ^

3d2994b ^

a6f47c0 ^

1168570 ^

6c05076 ^

1168570 ^

e9d4a6b ^

adee7fa ^

e9d4a6b ^

e9d4a6b ^

1168570 ^

3d2994b ^

1168570 ^

3d2994b ^

1168570 ^

90638ac ^

824556a ^

90638ac ^

90638ac ^

824556a ^

90638ac ^

1168570 ^

824556a ^

1168570 ^

824556a ^

1168570 ^

824556a ^

90638ac ^

824556a ^

90638ac ^

824556a ^

90638ac ^

505c5d8 ^

37be25f ^

505c5d8 ^

90638ac ^

37be25f ^

4f0847b ^

90638ac ^

37be25f ^

a9d7d11 ^

505c5d8 ^

90638ac ^

a9d7d11 ^

824556a ^

a9d7d11 ^

505c5d8 ^

78f4d8a ^

505c5d8 ^

a6f47c0 ^

dec003b ^

1168570 ^

505c5d8 ^

f4eb1c7 ^

824556a ^

1168570 ^

1168570 ^

df1d1ef ^

1168570 ^

dec003b ^

824556a ^

dec003b ^

1168570 ^

90638ac ^

dec003b ^

a6f47c0 ^

dec003b ^

1168570 ^

dec003b ^

f4eb1c7 ^

824556a ^

1168570 ^

1168570 ^

eca8525 ^

90638ac ^

1168570 ^

a6f47c0 ^

1168570 ^

a6f47c0 ^

eca8525 ^

1168570 ^

824556a ^

1168570 ^

12
13
14

15
16

18
19
20

22
23
24

26
27

28
29
30

32
33

36
37

38
39

65
66

67
68
69

71
72
73

88
89

103
104

116
117
118

119
120

123
124

131
132

137
138
139

140
141

146
147
148

159
160

162
163

166
167

168
169

183
184
185

188
189

190
191

package svc // import "github.com/getwtxt/getwtxt/svc"

import (
	"crypto/sha256"
	"fmt"
	"net/http"
	"strconv"
	"strings"
	"time"

	"github.com/getwtxt/registry"
	"github.com/gorilla/mux"
)

func getEtag(modtime time.Time) string {
	shabytes, err := modtime.MarshalText()
	errLog("", err)
	return fmt.Sprintf("%x", sha256.Sum256(shabytes))
}

func servStatic(w http.ResponseWriter, isCSS bool) error {
	if isCSS {
		etag := getEtag(staticCache.cssMod)
		w.Header().Set("ETag", "\""+etag+"\"")
		w.Header().Set("Content-Type", cssutf8)
		_, err := w.Write(staticCache.css)
		return err
	}
	etag := getEtag(staticCache.indexMod)
	w.Header().Set("ETag", "\""+etag+"\"")
	w.Header().Set("Content-Type", htmlutf8)
	_, err := w.Write(staticCache.index)
	return err
}

// handles "/" and "/css"
func staticHandler(w http.ResponseWriter, r *http.Request) {
	pingAssets()

	// 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.
	staticCache.mu.RLock()
	isCSS := strings.Contains(r.URL.Path, "css")
	err := servStatic(w, isCSS)
	if err != nil {
		staticCache.mu.RUnlock()
		errHTTP(w, r, err, http.StatusInternalServerError)
		return
	}
	staticCache.mu.RUnlock()

	log200(r)
}

// handles "/api"
func apiBaseHandler(w http.ResponseWriter, r *http.Request) {
	staticHandler(w, r)
}

// handles "/api/plain"
// maybe add json/xml support later
func apiFormatHandler(w http.ResponseWriter, r *http.Request) {
	staticHandler(w, r)
}

func apiAllTweetsHandler(w http.ResponseWriter, r *http.Request) {
	out, err := twtxtCache.QueryAllStatuses()
	if err != nil {
		errHTTP(w, r, err, http.StatusInternalServerError)
	}

	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 {
		errHTTP(w, r, err, http.StatusInternalServerError)
		return
	}

	log200(r)
}

// handles "/api/plain/(users|mentions|tweets)"
func apiEndpointHandler(w http.ResponseWriter, r *http.Request) {
	errLog("Error when parsing query values: ", r.ParseForm())

	if r.FormValue("q") != "" || r.FormValue("url") != "" {
		err := apiEndpointQuery(w, r)
		if err != nil {
			errHTTP(w, r, err, http.StatusInternalServerError)
			return
		}
		log200(r)
		return
	}

	var err error
	page := 1
	pageVal := r.FormValue("page")

	switch pageVal {
	case "":
		break
	default:
		page, err = strconv.Atoi(pageVal)
		if err != nil || page < 1 {
			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)

	case "/api/plain/tweets":
		out, err = twtxtCache.QueryAllStatuses()
		out = registry.ReduceToPage(page, out)

	default:
		errHTTP(w, r, fmt.Errorf("endpoint not found"), http.StatusNotFound)
		return
	}
	errLog("", err)

	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 {
		errHTTP(w, r, err, http.StatusInternalServerError)
	} else {
		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 {
		errHTTP(w, r, err, http.StatusInternalServerError)
		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 {
		errHTTP(w, r, err, http.StatusInternalServerError)
		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 := compositeStatusQuery("#"+tags, r)
	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 {
		errHTTP(w, r, err, http.StatusInternalServerError)
		return
	}

	log200(r)
}


context:
space:
mode: