summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorBrian Picciano <mediocregopher@gmail.com>2021-08-18 17:13:25 -0600
committerBrian Picciano <mediocregopher@gmail.com>2021-08-18 17:13:25 -0600
commitbec64827d19d64aae86ca3d2b26de800b427a540 (patch)
tree43aaf5b4b3681cff8e624819f311d8d36e9bd27f
parenteaccf41563a5696996c0c75ceff1f270e88fc207 (diff)
implement basic chat history endpoint
-rw-r--r--srv/api/api.go2
-rw-r--r--srv/api/chat.go41
-rw-r--r--srv/api/utils.go8
3 files changed, 51 insertions, 0 deletions
diff --git a/srv/api/api.go b/srv/api/api.go
index ae0970b..15627f8 100644
--- a/srv/api/api.go
+++ b/srv/api/api.go
@@ -12,6 +12,7 @@ import (
"os"
"github.com/mediocregopher/blog.mediocregopher.com/srv/cfg"
+ "github.com/mediocregopher/blog.mediocregopher.com/srv/chat"
"github.com/mediocregopher/blog.mediocregopher.com/srv/mailinglist"
"github.com/mediocregopher/blog.mediocregopher.com/srv/pow"
"github.com/mediocregopher/mediocre-go-lib/v2/mctx"
@@ -24,6 +25,7 @@ type Params struct {
Logger *mlog.Logger
PowManager pow.Manager
MailingList mailinglist.MailingList
+ GlobalRoom chat.Room
// ListenProto and ListenAddr are passed into net.Listen to create the
// API's listener. Both "tcp" and "unix" protocols are explicitly
diff --git a/srv/api/chat.go b/srv/api/chat.go
new file mode 100644
index 0000000..84fffde
--- /dev/null
+++ b/srv/api/chat.go
@@ -0,0 +1,41 @@
+package api
+
+import (
+ "errors"
+ "fmt"
+ "net/http"
+
+ "github.com/mediocregopher/blog.mediocregopher.com/srv/chat"
+)
+
+func (a *api) chatHistoryHandler() http.Handler {
+ return http.HandlerFunc(func(rw http.ResponseWriter, r *http.Request) {
+ limit, err := strToInt(r.FormValue("limit"), 0)
+ if err != nil {
+ badRequest(rw, r, fmt.Errorf("invalid limit parameter: %w", err))
+ return
+ }
+
+ cursor := r.FormValue("cursor")
+
+ cursor, msgs, err := a.params.GlobalRoom.History(r.Context(), chat.HistoryOpts{
+ Limit: limit,
+ Cursor: cursor,
+ })
+
+ if argErr := (chat.ErrInvalidArg{}); errors.As(err, &argErr) {
+ badRequest(rw, r, argErr.Err)
+ return
+ } else if err != nil {
+ internalServerError(rw, r, err)
+ }
+
+ jsonResult(rw, r, struct {
+ Cursor string `json:"cursor"`
+ Messages []chat.Message `json:"messages"`
+ }{
+ Cursor: cursor,
+ Messages: msgs,
+ })
+ })
+}
diff --git a/srv/api/utils.go b/srv/api/utils.go
index 8e2a63b..7662e17 100644
--- a/srv/api/utils.go
+++ b/srv/api/utils.go
@@ -4,6 +4,7 @@ import (
"context"
"encoding/json"
"net/http"
+ "strconv"
"github.com/mediocregopher/mediocre-go-lib/v2/mlog"
)
@@ -58,3 +59,10 @@ func internalServerError(rw http.ResponseWriter, r *http.Request, err error) {
Error: "internal server error",
})
}
+
+func strToInt(str string, defaultVal int) (int, error) {
+ if str == "" {
+ return defaultVal, nil
+ }
+ return strconv.Atoi(str)
+}