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

persist jset, jdel to aof. fixes #98

This commit is contained in:
Josh Baker 2016-12-14 07:37:02 -07:00
parent 44cf149325
commit bf0fee122d
1 changed files with 17 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
controller/json.go
View File

@ -178,8 +178,15 @@ func (c *Controller) cmdJset(msg *server.Message) (res string, d commandDetailsT
if createcol { if createcol {
c.setCol(key, col) c.setCol(key, col)
} }
d.key = key
d.id = id
d.obj = geojson.String(json)
d.timestamp = time.Now()
d.updated = true
c.clearIDExpires(key, id) c.clearIDExpires(key, id)
col.ReplaceOrInsert(id, geojson.String(json), nil, nil) col.ReplaceOrInsert(d.id, d.obj, nil, nil)
switch msg.OutputType { switch msg.OutputType {
case server.JSON: case server.JSON:
var buf bytes.Buffer var buf bytes.Buffer
@ -244,8 +251,15 @@ func (c *Controller) cmdJdel(msg *server.Message) (res string, d commandDetailsT
// SET key id OBJECT json // SET key id OBJECT json
return c.cmdSet(&nmsg) return c.cmdSet(&nmsg)
} }
c.clearIDExpires(key, id)
col.ReplaceOrInsert(id, geojson.String(json), nil, nil) d.key = key
d.id = id
d.obj = geojson.String(json)
d.timestamp = time.Now()
d.updated = true
c.clearIDExpires(d.key, d.id)
col.ReplaceOrInsert(d.id, d.obj, nil, nil)
switch msg.OutputType { switch msg.OutputType {
case server.JSON: case server.JSON:
var buf bytes.Buffer var buf bytes.Buffer