Mirrors/kararas_iris
1
0
Fork 0
mirror of https://github.com/kataras/iris.git synced 2026-01-05 11:17:03 +00:00
Code Releases Activity

init go modules but keep the dep files and vendor folder and update badger sessionsdb's dependency to 1.5.4 from 1.5.3

Browse Source 
Former-commit-id: 4f58a9bd0e7eb5f9535953125c27b9c5316ffc0f
This commit is contained in:
Gerasimos (Makis) Maropoulos
2018-10-02 04:05:39 +03:00
parent 2a1f3d4e43
commit 97e96ed6ca
9 changed files with 267 additions and 47 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
sessions/sessiondb/badger/database.go
View File

@@ -7,11 +7,11 @@ import (
"sync/atomic"
"time"
"github.com/kataras/golog"
"github.com/kataras/iris/core/errors"
"github.com/kataras/iris/sessions"
"github.com/dgraph-io/badger"
"github.com/kataras/golog"
)
// DefaultFileMode used as the default database's "fileMode"
@@ -144,7 +144,13 @@ func (db *Database) Get(sid string, key string) (value interface{}) {
if err != nil {
return err
}
// item.ValueCopy
// return item.Value(func(valueBytes []byte) {
// if err := sessions.DefaultTranscoder.Unmarshal(valueBytes, &value); err != nil {
// golog.Error(err)
// }
// })
valueBytes, err := item.Value()
if err != nil {
return err
@@ -173,13 +179,25 @@ func (db *Database) Visit(sid string, cb func(key string, value interface{})) {
for iter.Rewind(); iter.ValidForPrefix(prefix); iter.Next() {
item := iter.Item()
var value interface{}
// err := item.Value(func(valueBytes []byte) {
// if err := sessions.DefaultTranscoder.Unmarshal(valueBytes, &value); err != nil {
// golog.Error(err)
// }
// })
// if err != nil {
// golog.Error(err)
// continue
// }
valueBytes, err := item.Value()
if err != nil {
golog.Error(err)
continue
}
var value interface{}
if err = sessions.DefaultTranscoder.Unmarshal(valueBytes, &value); err != nil {
golog.Error(err)
continue