aboutsummaryrefslogtreecommitdiff
path: root/service/transport.go
diff options
context:
space:
mode:
authorr <r@freesoftwareextremist.com>2020-01-28 17:51:00 +0000
committerr <r@freesoftwareextremist.com>2020-01-28 17:58:29 +0000
commit2af37d47783aac8c650ffd1578e2297b5784c73d (patch)
tree7b5c7a4b2fa530285bfaa16324e818d97dd00408 /service/transport.go
parent57d2a4288b02fd1245ee85ae629649798578cf6c (diff)
downloadbloat-2af37d47783aac8c650ffd1578e2297b5784c73d.tar.gz
bloat-2af37d47783aac8c650ffd1578e2297b5784c73d.zip
Refactor everything
Diffstat (limited to 'service/transport.go')
-rw-r--r--service/transport.go650
1 files changed, 346 insertions, 304 deletions
diff --git a/service/transport.go b/service/transport.go
index e878f8d..fbab2e5 100644
--- a/service/transport.go
+++ b/service/transport.go
@@ -15,327 +15,292 @@ import (
"github.com/gorilla/mux"
)
-var (
- ctx = context.Background()
- cookieAge = "31536000"
-)
+func newClient(w io.Writer) *model.Client {
+ return &model.Client{
+ Writer: w,
+ }
+}
+
+func newCtxWithSesion(req *http.Request) context.Context {
+ ctx := context.Background()
+ sessionID, err := req.Cookie("session_id")
+ if err != nil {
+ return ctx
+ }
+ return context.WithValue(ctx, "session_id", sessionID.Value)
+}
+
+func newCtxWithSesionCSRF(req *http.Request, csrfToken string) context.Context {
+ ctx := newCtxWithSesion(req)
+ return context.WithValue(ctx, "csrf_token", csrfToken)
+}
+
+func getMultipartFormValue(mf *multipart.Form, key string) (val string) {
+ vals, ok := mf.Value[key]
+ if !ok {
+ return ""
+ }
+ if len(vals) < 1 {
+ return ""
+ }
+ return vals[0]
+}
+
+func serveJson(w io.Writer, data interface{}) (err error) {
+ var d = make(map[string]interface{})
+ d["data"] = data
+ return json.NewEncoder(w).Encode(d)
+}
func NewHandler(s Service, staticDir string) http.Handler {
r := mux.NewRouter()
- r.PathPrefix("/static").Handler(http.StripPrefix("/static",
- http.FileServer(http.Dir(path.Join(".", staticDir)))))
+ rootPage := func(w http.ResponseWriter, req *http.Request) {
+ sessionID, _ := req.Cookie("session_id")
- r.HandleFunc("/", func(w http.ResponseWriter, req *http.Request) {
location := "/signin"
-
- sessionID, _ := req.Cookie("session_id")
if sessionID != nil && len(sessionID.Value) > 0 {
location = "/timeline/home"
}
w.Header().Add("Location", location)
w.WriteHeader(http.StatusFound)
- }).Methods(http.MethodGet)
-
- r.HandleFunc("/signin", func(w http.ResponseWriter, req *http.Request) {
- err := s.ServeSigninPage(ctx, w)
- if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
- return
- }
- }).Methods(http.MethodGet)
+ }
- r.HandleFunc("/signin", func(w http.ResponseWriter, req *http.Request) {
- instance := req.FormValue("instance")
- url, sessionID, err := s.GetAuthUrl(ctx, instance)
+ signinPage := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := context.Background()
+ err := s.ServeSigninPage(ctx, c)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
+ }
- http.SetCookie(w, &http.Cookie{
- Name: "session_id",
- Value: sessionID,
- Expires: time.Now().Add(365 * 24 * time.Hour),
- })
-
- w.Header().Add("Location", url)
- w.WriteHeader(http.StatusFound)
- }).Methods(http.MethodPost)
+ timelinePage := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesion(req)
+ tType, _ := mux.Vars(req)["type"]
+ maxID := req.URL.Query().Get("max_id")
+ minID := req.URL.Query().Get("min_id")
- r.HandleFunc("/oauth_callback", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
- token := req.URL.Query().Get("code")
- _, err := s.GetUserToken(ctx, "", nil, token)
+ err := s.ServeTimelinePage(ctx, c, tType, maxID, minID)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
+ }
+ timelineOldPage := func(w http.ResponseWriter, req *http.Request) {
w.Header().Add("Location", "/timeline/home")
w.WriteHeader(http.StatusFound)
- }).Methods(http.MethodGet)
-
- r.HandleFunc("/timeline", func(w http.ResponseWriter, req *http.Request) {
- w.Header().Add("Location", "/timeline/home")
- w.WriteHeader(http.StatusFound)
- }).Methods(http.MethodGet)
-
- r.HandleFunc("/timeline/{type}", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
-
- timelineType, _ := mux.Vars(req)["type"]
- maxID := req.URL.Query().Get("max_id")
- sinceID := req.URL.Query().Get("since_id")
- minID := req.URL.Query().Get("min_id")
-
- err := s.ServeTimelinePage(ctx, w, nil, timelineType, maxID, sinceID, minID)
- if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
- return
- }
- }).Methods(http.MethodGet)
+ }
- r.HandleFunc("/thread/{id}", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
+ threadPage := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesion(req)
id, _ := mux.Vars(req)["id"]
reply := req.URL.Query().Get("reply")
- err := s.ServeThreadPage(ctx, w, nil, id, len(reply) > 1)
+
+ err := s.ServeThreadPage(ctx, c, id, len(reply) > 1)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
- }).Methods(http.MethodGet)
+ }
- r.HandleFunc("/likedby/{id}", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
+ likedByPage := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesion(req)
id, _ := mux.Vars(req)["id"]
- err := s.ServeLikedByPage(ctx, w, nil, id)
+ err := s.ServeLikedByPage(ctx, c, id)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
- }).Methods(http.MethodGet)
+ }
- r.HandleFunc("/retweetedby/{id}", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
+ retweetedByPage := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesion(req)
id, _ := mux.Vars(req)["id"]
- err := s.ServeRetweetedByPage(ctx, w, nil, id)
+ err := s.ServeRetweetedByPage(ctx, c, id)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
- }).Methods(http.MethodGet)
-
- r.HandleFunc("/following/{id}", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
+ }
+ followingPage := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesion(req)
id, _ := mux.Vars(req)["id"]
maxID := req.URL.Query().Get("max_id")
minID := req.URL.Query().Get("min_id")
- err := s.ServeFollowingPage(ctx, w, nil, id, maxID, minID)
+ err := s.ServeFollowingPage(ctx, c, id, maxID, minID)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
- }).Methods(http.MethodGet)
-
- r.HandleFunc("/followers/{id}", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
+ }
+ followersPage := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesion(req)
id, _ := mux.Vars(req)["id"]
maxID := req.URL.Query().Get("max_id")
minID := req.URL.Query().Get("min_id")
- err := s.ServeFollowersPage(ctx, w, nil, id, maxID, minID)
+ err := s.ServeFollowersPage(ctx, c, id, maxID, minID)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
- }).Methods(http.MethodGet)
-
- r.HandleFunc("/like/{id}", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
- ctx = context.WithValue(ctx, "csrf_token", req.FormValue("csrf_token"))
+ }
- id, _ := mux.Vars(req)["id"]
- retweetedByID := req.FormValue("retweeted_by_id")
+ notificationsPage := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesion(req)
+ maxID := req.URL.Query().Get("max_id")
+ minID := req.URL.Query().Get("min_id")
- _, err := s.Like(ctx, w, nil, id)
+ err := s.ServeNotificationPage(ctx, c, maxID, minID)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
+ }
- rID := id
- if len(retweetedByID) > 0 {
- rID = retweetedByID
- }
- w.Header().Add("Location", req.Header.Get("Referer")+"#status-"+rID)
- w.WriteHeader(http.StatusFound)
- }).Methods(http.MethodPost)
-
- r.HandleFunc("/unlike/{id}", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
- ctx = context.WithValue(ctx, "csrf_token", req.FormValue("csrf_token"))
-
+ userPage := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesion(req)
id, _ := mux.Vars(req)["id"]
- retweetedByID := req.FormValue("retweeted_by_id")
+ maxID := req.URL.Query().Get("max_id")
+ minID := req.URL.Query().Get("min_id")
- _, err := s.UnLike(ctx, w, nil, id)
+ err := s.ServeUserPage(ctx, c, id, maxID, minID)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
+ }
- rID := id
- if len(retweetedByID) > 0 {
- rID = retweetedByID
- }
- w.Header().Add("Location", req.Header.Get("Referer")+"#status-"+rID)
- w.WriteHeader(http.StatusFound)
- }).Methods(http.MethodPost)
-
- r.HandleFunc("/retweet/{id}", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
- ctx = context.WithValue(ctx, "csrf_token", req.FormValue("csrf_token"))
-
- id, _ := mux.Vars(req)["id"]
- retweetedByID := req.FormValue("retweeted_by_id")
+ aboutPage := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesion(req)
- _, err := s.Retweet(ctx, w, nil, id)
+ err := s.ServeAboutPage(ctx, c)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
+ }
- rID := id
- if len(retweetedByID) > 0 {
- rID = retweetedByID
- }
- w.Header().Add("Location", req.Header.Get("Referer")+"#status-"+rID)
- w.WriteHeader(http.StatusFound)
- }).Methods(http.MethodPost)
-
- r.HandleFunc("/unretweet/{id}", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
- ctx = context.WithValue(ctx, "csrf_token", req.FormValue("csrf_token"))
+ emojisPage := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesion(req)
- id, _ := mux.Vars(req)["id"]
- retweetedByID := req.FormValue("retweeted_by_id")
-
- _, err := s.UnRetweet(ctx, w, nil, id)
+ err := s.ServeEmojiPage(ctx, c)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
+ }
- rID := id
- if len(retweetedByID) > 0 {
- rID = retweetedByID
- }
- w.Header().Add("Location", req.Header.Get("Referer")+"#status-"+rID)
- w.WriteHeader(http.StatusFound)
- }).Methods(http.MethodPost)
-
- r.HandleFunc("/fluoride/like/{id}", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
- ctx = context.WithValue(ctx, "csrf_token", req.FormValue("csrf_token"))
+ searchPage := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesion(req)
+ q := req.URL.Query().Get("q")
+ qType := req.URL.Query().Get("type")
+ offsetStr := req.URL.Query().Get("offset")
- id, _ := mux.Vars(req)["id"]
- count, err := s.Like(ctx, w, nil, id)
- if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
- return
+ var offset int
+ var err error
+ if len(offsetStr) > 1 {
+ offset, err = strconv.Atoi(offsetStr)
+ if err != nil {
+ s.ServeErrorPage(ctx, c, err)
+ return
+ }
}
- err = serveJson(w, count)
+ err = s.ServeSearchPage(ctx, c, q, qType, offset)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
- }).Methods(http.MethodPost)
-
- r.HandleFunc("/fluoride/unlike/{id}", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
- ctx = context.WithValue(ctx, "csrf_token", req.FormValue("csrf_token"))
+ }
- id, _ := mux.Vars(req)["id"]
- count, err := s.UnLike(ctx, w, nil, id)
- if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
- return
- }
+ settingsPage := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesion(req)
- err = serveJson(w, count)
+ err := s.ServeSettingsPage(ctx, c)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
- }).Methods(http.MethodPost)
+ }
- r.HandleFunc("/fluoride/retweet/{id}", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
- ctx = context.WithValue(ctx, "csrf_token", req.FormValue("csrf_token"))
+ signin := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := context.Background()
+ instance := req.FormValue("instance")
- id, _ := mux.Vars(req)["id"]
- count, err := s.Retweet(ctx, w, nil, id)
+ url, sessionID, err := s.NewSession(ctx, instance)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
- err = serveJson(w, count)
- if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
- return
- }
- }).Methods(http.MethodPost)
+ http.SetCookie(w, &http.Cookie{
+ Name: "session_id",
+ Value: sessionID,
+ Expires: time.Now().Add(365 * 24 * time.Hour),
+ })
- r.HandleFunc("/fluoride/unretweet/{id}", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
- ctx = context.WithValue(ctx, "csrf_token", req.FormValue("csrf_token"))
+ w.Header().Add("Location", url)
+ w.WriteHeader(http.StatusFound)
+ }
- id, _ := mux.Vars(req)["id"]
- count, err := s.UnRetweet(ctx, w, nil, id)
- if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
- return
- }
+ oauthCallback := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesion(req)
+ token := req.URL.Query().Get("code")
- err = serveJson(w, count)
+ _, err := s.Signin(ctx, c, "", token)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
- }).Methods(http.MethodPost)
- r.HandleFunc("/post", func(w http.ResponseWriter, req *http.Request) {
+ w.Header().Add("Location", "/timeline/home")
+ w.WriteHeader(http.StatusFound)
+ }
+
+ post := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
err := req.ParseMultipartForm(4 << 20)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(context.Background(), c, err)
return
}
- ctx := getContextWithSession(context.Background(), req)
- ctx = context.WithValue(ctx, "csrf_token",
+ ctx := newCtxWithSesionCSRF(req,
getMultipartFormValue(req.MultipartForm, "csrf_token"))
-
content := getMultipartFormValue(req.MultipartForm, "content")
replyToID := getMultipartFormValue(req.MultipartForm, "reply_to_id")
format := getMultipartFormValue(req.MultipartForm, "format")
visibility := getMultipartFormValue(req.MultipartForm, "visibility")
isNSFW := "on" == getMultipartFormValue(req.MultipartForm, "is_nsfw")
-
files := req.MultipartForm.File["attachments"]
- id, err := s.PostTweet(ctx, w, nil, content, replyToID, format, visibility, isNSFW, files)
+ id, err := s.Post(ctx, c, content, replyToID, format, visibility, isNSFW, files)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
@@ -345,131 +310,129 @@ func NewHandler(s Service, staticDir string) http.Handler {
}
w.Header().Add("Location", location)
w.WriteHeader(http.StatusFound)
- }).Methods(http.MethodPost)
-
- r.HandleFunc("/notifications", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
-
- maxID := req.URL.Query().Get("max_id")
- minID := req.URL.Query().Get("min_id")
-
- err := s.ServeNotificationPage(ctx, w, nil, maxID, minID)
- if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
- return
- }
- }).Methods(http.MethodGet)
-
- r.HandleFunc("/user/{id}", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
+ }
+ like := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesionCSRF(req, req.FormValue("csrf_token"))
id, _ := mux.Vars(req)["id"]
- maxID := req.URL.Query().Get("max_id")
- minID := req.URL.Query().Get("min_id")
+ retweetedByID := req.FormValue("retweeted_by_id")
- err := s.ServeUserPage(ctx, w, nil, id, maxID, minID)
+ _, err := s.Like(ctx, c, id)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
- }).Methods(http.MethodGet)
- r.HandleFunc("/follow/{id}", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
- ctx = context.WithValue(ctx, "csrf_token", req.FormValue("csrf_token"))
+ rID := id
+ if len(retweetedByID) > 0 {
+ rID = retweetedByID
+ }
+ w.Header().Add("Location", req.Header.Get("Referer")+"#status-"+rID)
+ w.WriteHeader(http.StatusFound)
+ }
+ unlike := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesionCSRF(req, req.FormValue("csrf_token"))
id, _ := mux.Vars(req)["id"]
+ retweetedByID := req.FormValue("retweeted_by_id")
- err := s.Follow(ctx, w, nil, id)
+ _, err := s.UnLike(ctx, c, id)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
- w.Header().Add("Location", req.Header.Get("Referer"))
+ rID := id
+ if len(retweetedByID) > 0 {
+ rID = retweetedByID
+ }
+ w.Header().Add("Location", req.Header.Get("Referer")+"#status-"+rID)
w.WriteHeader(http.StatusFound)
- }).Methods(http.MethodPost)
-
- r.HandleFunc("/unfollow/{id}", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
- ctx = context.WithValue(ctx, "csrf_token", req.FormValue("csrf_token"))
+ }
+ retweet := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesionCSRF(req, req.FormValue("csrf_token"))
id, _ := mux.Vars(req)["id"]
+ retweetedByID := req.FormValue("retweeted_by_id")
- err := s.UnFollow(ctx, w, nil, id)
+ _, err := s.Retweet(ctx, c, id)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
- w.Header().Add("Location", req.Header.Get("Referer"))
+ rID := id
+ if len(retweetedByID) > 0 {
+ rID = retweetedByID
+ }
+ w.Header().Add("Location", req.Header.Get("Referer")+"#status-"+rID)
w.WriteHeader(http.StatusFound)
- }).Methods(http.MethodPost)
+ }
- r.HandleFunc("/about", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
+ unretweet := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesionCSRF(req, req.FormValue("csrf_token"))
+ id, _ := mux.Vars(req)["id"]
+ retweetedByID := req.FormValue("retweeted_by_id")
- err := s.ServeAboutPage(ctx, w, nil)
+ _, err := s.UnRetweet(ctx, c, id)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
- }).Methods(http.MethodGet)
- r.HandleFunc("/emojis", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
-
- err := s.ServeEmojiPage(ctx, w, nil)
- if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
- return
+ rID := id
+ if len(retweetedByID) > 0 {
+ rID = retweetedByID
}
- }).Methods(http.MethodGet)
-
- r.HandleFunc("/search", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
- q := req.URL.Query().Get("q")
- qType := req.URL.Query().Get("type")
- offsetStr := req.URL.Query().Get("offset")
+ w.Header().Add("Location", req.Header.Get("Referer")+"#status-"+rID)
+ w.WriteHeader(http.StatusFound)
+ }
- var offset int
- var err error
- if len(offsetStr) > 1 {
- offset, err = strconv.Atoi(offsetStr)
- if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
- return
- }
- }
+ follow := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesionCSRF(req, req.FormValue("csrf_token"))
+ id, _ := mux.Vars(req)["id"]
- err = s.ServeSearchPage(ctx, w, nil, q, qType, offset)
+ err := s.Follow(ctx, c, id)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
- }).Methods(http.MethodGet)
- r.HandleFunc("/settings", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
+ w.Header().Add("Location", req.Header.Get("Referer"))
+ w.WriteHeader(http.StatusFound)
+ }
+
+ unfollow := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesionCSRF(req, req.FormValue("csrf_token"))
+ id, _ := mux.Vars(req)["id"]
- err := s.ServeSettingsPage(ctx, w, nil)
+ err := s.UnFollow(ctx, c, id)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
- }).Methods(http.MethodGet)
- r.HandleFunc("/settings", func(w http.ResponseWriter, req *http.Request) {
- ctx := getContextWithSession(context.Background(), req)
- ctx = context.WithValue(ctx, "csrf_token", req.FormValue("csrf_token"))
+ w.Header().Add("Location", req.Header.Get("Referer"))
+ w.WriteHeader(http.StatusFound)
+ }
+ settings := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesionCSRF(req, req.FormValue("csrf_token"))
visibility := req.FormValue("visibility")
copyScope := req.FormValue("copy_scope") == "true"
threadInNewTab := req.FormValue("thread_in_new_tab") == "true"
maskNSFW := req.FormValue("mask_nsfw") == "true"
fluorideMode := req.FormValue("fluoride_mode") == "true"
darkMode := req.FormValue("dark_mode") == "true"
+
settings := &model.Settings{
DefaultVisibility: visibility,
CopyScope: copyScope,
@@ -479,17 +442,17 @@ func NewHandler(s Service, staticDir string) http.Handler {
DarkMode: darkMode,
}
- err := s.SaveSettings(ctx, w, nil, settings)
+ err := s.SaveSettings(ctx, c, settings)
if err != nil {
- s.ServeErrorPage(ctx, w, nil, err)
+ s.ServeErrorPage(ctx, c, err)
return
}
w.Header().Add("Location", req.Header.Get("Referer"))
w.WriteHeader(http.StatusFound)
- }).Methods(http.MethodPost)
+ }
- r.HandleFunc("/signout", func(w http.ResponseWriter, req *http.Request) {
+ signout := func(w http.ResponseWriter, req *http.Request) {
// TODO remove session from database
http.SetCookie(w, &http.Cookie{
Name: "session_id",
@@ -498,32 +461,111 @@ func NewHandler(s Service, staticDir string) http.Handler {
})
w.Header().Add("Location", "/")
w.WriteHeader(http.StatusFound)
- }).Methods(http.MethodGet)
+ }
- return r
-}
+ fLike := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesionCSRF(req, req.FormValue("csrf_token"))
+ id, _ := mux.Vars(req)["id"]
-func getContextWithSession(ctx context.Context, req *http.Request) context.Context {
- sessionID, err := req.Cookie("session_id")
- if err != nil {
- return ctx
+ count, err := s.Like(ctx, c, id)
+ if err != nil {
+ s.ServeErrorPage(ctx, c, err)
+ return
+ }
+
+ err = serveJson(w, count)
+ if err != nil {
+ s.ServeErrorPage(ctx, c, err)
+ return
+ }
}
- return context.WithValue(ctx, "session_id", sessionID.Value)
-}
-func getMultipartFormValue(mf *multipart.Form, key string) (val string) {
- vals, ok := mf.Value[key]
- if !ok {
- return ""
+ fUnlike := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesionCSRF(req, req.FormValue("csrf_token"))
+ id, _ := mux.Vars(req)["id"]
+ count, err := s.UnLike(ctx, c, id)
+ if err != nil {
+ s.ServeErrorPage(ctx, c, err)
+ return
+ }
+
+ err = serveJson(w, count)
+ if err != nil {
+ s.ServeErrorPage(ctx, c, err)
+ return
+ }
}
- if len(vals) < 1 {
- return ""
+
+ fRetweet := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesionCSRF(req, req.FormValue("csrf_token"))
+ id, _ := mux.Vars(req)["id"]
+
+ count, err := s.Retweet(ctx, c, id)
+ if err != nil {
+ s.ServeErrorPage(ctx, c, err)
+ return
+ }
+
+ err = serveJson(w, count)
+ if err != nil {
+ s.ServeErrorPage(ctx, c, err)
+ return
+ }
}
- return vals[0]
-}
-func serveJson(w io.Writer, data interface{}) (err error) {
- var d = make(map[string]interface{})
- d["data"] = data
- return json.NewEncoder(w).Encode(d)
+ fUnretweet := func(w http.ResponseWriter, req *http.Request) {
+ c := newClient(w)
+ ctx := newCtxWithSesionCSRF(req, req.FormValue("csrf_token"))
+ id, _ := mux.Vars(req)["id"]
+
+ count, err := s.UnRetweet(ctx, c, id)
+ if err != nil {
+ s.ServeErrorPage(ctx, c, err)
+ return
+ }
+
+ err = serveJson(w, count)
+ if err != nil {
+ s.ServeErrorPage(ctx, c, err)
+ return
+ }
+ }
+
+ r.HandleFunc("/", rootPage).Methods(http.MethodGet)
+ r.HandleFunc("/signin", signinPage).Methods(http.MethodGet)
+ r.HandleFunc("/timeline/{type}", timelinePage).Methods(http.MethodGet)
+ r.HandleFunc("/timeline", timelineOldPage).Methods(http.MethodGet)
+ r.HandleFunc("/thread/{id}", threadPage).Methods(http.MethodGet)
+ r.HandleFunc("/likedby/{id}", likedByPage).Methods(http.MethodGet)
+ r.HandleFunc("/retweetedby/{id}", retweetedByPage).Methods(http.MethodGet)
+ r.HandleFunc("/following/{id}", followingPage).Methods(http.MethodGet)
+ r.HandleFunc("/followers/{id}", followersPage).Methods(http.MethodGet)
+ r.HandleFunc("/notifications", notificationsPage).Methods(http.MethodGet)
+ r.HandleFunc("/user/{id}", userPage).Methods(http.MethodGet)
+ r.HandleFunc("/about", aboutPage).Methods(http.MethodGet)
+ r.HandleFunc("/emojis", emojisPage).Methods(http.MethodGet)
+ r.HandleFunc("/search", searchPage).Methods(http.MethodGet)
+ r.HandleFunc("/settings", settingsPage).Methods(http.MethodGet)
+ r.HandleFunc("/signin", signin).Methods(http.MethodPost)
+ r.HandleFunc("/oauth_callback", oauthCallback).Methods(http.MethodGet)
+ r.HandleFunc("/post", post).Methods(http.MethodPost)
+ r.HandleFunc("/like/{id}", like).Methods(http.MethodPost)
+ r.HandleFunc("/unlike/{id}", unlike).Methods(http.MethodPost)
+ r.HandleFunc("/retweet/{id}", retweet).Methods(http.MethodPost)
+ r.HandleFunc("/unretweet/{id}", unretweet).Methods(http.MethodPost)
+ r.HandleFunc("/follow/{id}", follow).Methods(http.MethodPost)
+ r.HandleFunc("/unfollow/{id}", unfollow).Methods(http.MethodPost)
+ r.HandleFunc("/settings", settings).Methods(http.MethodPost)
+ r.HandleFunc("/signout", signout).Methods(http.MethodGet)
+ r.HandleFunc("/fluoride/like/{id}", fLike).Methods(http.MethodPost)
+ r.HandleFunc("/fluoride/unlike/{id}", fUnlike).Methods(http.MethodPost)
+ r.HandleFunc("/fluoride/retweet/{id}", fRetweet).Methods(http.MethodPost)
+ r.HandleFunc("/fluoride/unretweet/{id}", fUnretweet).Methods(http.MethodPost)
+ r.PathPrefix("/static").Handler(http.StripPrefix("/static",
+ http.FileServer(http.Dir(path.Join(".", staticDir)))))
+
+ return r
}