vikarti.anatra/safing-portbase
1
0
Fork 0
mirror of https://github.com/safing/portbase synced 2025-09-01 10:09:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix minor issue in database api

Browse source
This commit is contained in:
Daniel 2019-01-11 22:18:46 +01:00
parent 1ef3ceb274
commit a943e3315f
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
api/database.go
View file

@ -329,9 +329,10 @@ func (api *DatabaseAPI) processSub(opID []byte, sub *database.Subscription) {
r.Unlock() r.Unlock()
if err != nil { if err != nil {
api.send(opID, dbMsgTypeWarning, err.Error(), nil) api.send(opID, dbMsgTypeWarning, err.Error(), nil)
continue
} }
// TODO: use upd, new and delete msgTypes // TODO: use upd, new and delete msgTypes
if r.Meta().Deleted > 0 { if r.Meta().IsDeleted() {
api.send(opID, dbMsgTypeDel, r.Key(), nil) api.send(opID, dbMsgTypeDel, r.Key(), nil)
} else { } else {
api.send(opID, dbMsgTypeUpd, r.Key(), data) api.send(opID, dbMsgTypeUpd, r.Key(), data)