sour-is/ev
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: msgbus get handler

Browse Source
This commit is contained in:
Jon Lundy 2022-08-15 12:25:50 -06:00
parent 5458d35be0
commit 6033437584
Signed by untrusted user who does not match committer: xuu
GPG Key ID: C63E6D61F3035024
2 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
main.go
View File

@ -49,6 +49,7 @@ func main() {
}
}
func run(ctx context.Context) error {
ctx, span := logz.Span(ctx)
diskstore.Init(ctx)
memstore.Init(ctx)
if err := domain.Init(ctx); err != nil {
@ -98,6 +99,8 @@ func run(ctx context.Context) error {
return s.Shutdown(ctx)
})
span.End()
return g.Wait()
}
func env(name, defaultValue string) string {

11
pkg/msgbus/service.go
View File

@ -83,10 +83,13 @@ func (s *service) get(w http.ResponseWriter, r *http.Request) {
first = lis[0]
}
var pos, count int64 = -1, -99
var pos, count int64 = 0, es.AllEvents
qry := r.URL.Query()
if i, err := strconv.ParseInt(qry.Get("index"), 10, 64); err == nil {
if i, err := strconv.ParseInt(qry.Get("index"), 10, 64); err == nil && i > 1 {
pos = i - 1
}
if i, err := strconv.ParseInt(qry.Get("pos"), 10, 64); err == nil {
pos = i
}
if i, err := strconv.ParseInt(qry.Get("n"), 10, 64); err == nil {
@ -236,10 +239,10 @@ func (s *service) websocket(w http.ResponseWriter, r *http.Request) {
first = lis[0]
}
var pos int64 = -1
var pos int64 = 0
qry := r.URL.Query()
if i, err := strconv.ParseInt(qry.Get("index"), 10, 64); err == nil {
if i, err := strconv.ParseInt(qry.Get("index"), 10, 64); err == nil && i > 0 {
pos = i - 1
}