mirror
/
tile38
mirror of https://github.com/tidwall/tile38.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Verify hook names match for processing

This commit is contained in:
Steven Wolfe 2019-02-22 15:58:13 -07:00
parent b37033d281
commit fd20190bff
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/server/hooks.go
View File

@ -10,6 +10,7 @@ import (
"time" "time"
"github.com/tidwall/buntdb" "github.com/tidwall/buntdb"
"github.com/tidwall/gjson"
"github.com/tidwall/resp" "github.com/tidwall/resp"
"github.com/tidwall/tile38/internal/endpoint" "github.com/tidwall/tile38/internal/endpoint"
"github.com/tidwall/tile38/internal/glob" "github.com/tidwall/tile38/internal/glob"
@ -597,9 +598,12 @@ func (h *Hook) proc() (ok bool) {
err := tx.AscendGreaterOrEqual("hooks", err := tx.AscendGreaterOrEqual("hooks",
h.query, func(key, val string) bool { h.query, func(key, val string) bool {
if strings.HasPrefix(key, hookLogPrefix) { if strings.HasPrefix(key, hookLogPrefix) {
// Verify this hooks name matches the one in the notif
if h.Name == gjson.Get(val, "hook").String() {
keys = append(keys, key) keys = append(keys, key)
vals = append(vals, val) vals = append(vals, val)
} }
}
return true return true
}, },
) )