aboutsummaryrefslogtreecommitdiff
path: root/models/persister.go
diff options
context:
space:
mode:
Diffstat (limited to 'models/persister.go')
-rw-r--r--models/persister.go10
1 files changed, 5 insertions, 5 deletions
diff --git a/models/persister.go b/models/persister.go
index 60c25b5..4381008 100644
--- a/models/persister.go
+++ b/models/persister.go
@@ -22,20 +22,20 @@ func NewPersister(log *zap.SugaredLogger, db *badger.DB) *Persister {
}
func (p *Persister) Store(model model) error {
- log := p.log.With("model", model.Name())
- log.Debug("store")
+ log := p.log.With("model", model.Name()).With("DedupKey", model.DedupKey()).With("Key", model.Key())
+ log.Debug("Store()")
err := p.db.View(func(txn *badger.Txn) error {
var getErr error
var updateErr error
- log.With("DedupKey", model.DedupKey()).Debug("checking")
+ log.Debug("checking")
_, getErr = txn.Get([]byte(model.DedupKey()))
if getErr == badger.ErrKeyNotFound {
- log.With("DedupKey", model.DedupKey()).Debug("not found")
+ log.Debug("not found")
updateErr = p.db.Update(model.Save) // stores the outbox item
if updateErr != nil {
return updateErr
}
- log.With("DedupKey", model.DedupKey()).Debug("saving")
+ log.Debug("saving")
updateErr = p.db.Update(model.SaveDedup) // stores the sha256
}
return updateErr