Mercurial > gemma

comparison pkg/auth/store.go @ 5490:5f47eeea988d logging

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Use own logging package.
author Sascha L. Teichmann <sascha.teichmann@intevation.de>
date Mon, 20 Sep 2021 17:45:39 +0200
parents 866eae1bd888
children
comparison
equal deleted inserted replaced
5488:a726a92ea5c9 5490:5f47eeea988d
14 package auth 14 package auth
15 15
16 import ( 16 import (
17 "bytes" 17 "bytes"
18 "errors" 18 "errors"
19 "log"
20 "time" 19 "time"
21 20
21 bolt "go.etcd.io/bbolt"
22
22 "gemma.intevation.de/gemma/pkg/config" 23 "gemma.intevation.de/gemma/pkg/config"
23 bolt "go.etcd.io/bbolt" 24 "gemma.intevation.de/gemma/pkg/log"
24 ) 25 )
25 26
26 // ErrNoSuchToken is returned if a given token does not 27 // ErrNoSuchToken is returned if a given token does not
27 // exists th the session store. 28 // exists th the session store.
28 var ErrNoSuchToken = errors.New("no such token") 29 var ErrNoSuchToken = errors.New("no such token")
128 err := ss.storage.Update(func(tx *bolt.Tx) error { 129 err := ss.storage.Update(func(tx *bolt.Tx) error {
129 b := tx.Bucket(sessionsBucket) 130 b := tx.Bucket(sessionsBucket)
130 return b.Delete([]byte(token)) 131 return b.Delete([]byte(token))
131 }) 132 })
132 if err != nil { 133 if err != nil {
133 log.Printf("error: %v\n", err) 134 log.Errorf("%v\n", err)
134 } 135 }
135 } 136 }
136 137
137 // Delete removes a session identified by its token from the 138 // Delete removes a session identified by its token from the
138 // session store. Returns true if there was such s session. 139 // session store. Returns true if there was such s session.
161 return err 162 return err
162 } 163 }
163 return b.Put([]byte(token), buf.Bytes()) 164 return b.Put([]byte(token), buf.Bytes())
164 }) 165 })
165 if err != nil { 166 if err != nil {
166 log.Printf("error: %v\n", err) 167 log.Errorf("%v\n", err)
167 } 168 }
168 } 169 }
169 170
170 // Add puts a session into the session store identified by 171 // Add puts a session into the session store identified by
171 // a given token. An old session with the same key will 172 // a given token. An old session with the same key will
250 251
251 // Shutdown closes the session store. 252 // Shutdown closes the session store.
252 // If using the persistent mode the backing session database is closed. 253 // If using the persistent mode the backing session database is closed.
253 func (ss *SessionStore) Shutdown() error { 254 func (ss *SessionStore) Shutdown() error {
254 if db := ss.storage; db != nil { 255 if db := ss.storage; db != nil {
255 log.Println("info: shutdown persistent session store.") 256 log.Infof("shutdown persistent session store.")
256 ss.storage = nil 257 ss.storage = nil
257 return db.Close() 258 return db.Close()
258 } 259 }
259 log.Println("info: shutdown in-memory session store.") 260 log.Infof("shutdown in-memory session store.")
260 return nil 261 return nil
261 } 262 }