aboutsummaryrefslogtreecommitdiff
path: root/repository/sessionRepository.go
diff options
context:
space:
mode:
Diffstat (limited to 'repository/sessionRepository.go')
-rw-r--r--repository/sessionRepository.go64
1 files changed, 0 insertions, 64 deletions
diff --git a/repository/sessionRepository.go b/repository/sessionRepository.go
deleted file mode 100644
index cb19f68..0000000
--- a/repository/sessionRepository.go
+++ /dev/null
@@ -1,64 +0,0 @@
-package repository
-
-import (
- "encoding/json"
-
- "bloat/kv"
- "bloat/model"
-)
-
-type sessionRepository struct {
- db *kv.Database
-}
-
-func NewSessionRepository(db *kv.Database) *sessionRepository {
- return &sessionRepository{
- db: db,
- }
-}
-
-func (repo *sessionRepository) Add(s model.Session) (err error) {
- data, err := json.Marshal(s)
- if err != nil {
- return
- }
- err = repo.db.Set(s.ID, data)
- return
-}
-
-func (repo *sessionRepository) Update(id string, accessToken string) (err error) {
- data, err := repo.db.Get(id)
- if err != nil {
- return
- }
-
- var s model.Session
- err = json.Unmarshal(data, &s)
- if err != nil {
- return
- }
-
- s.AccessToken = accessToken
-
- data, err = json.Marshal(s)
- if err != nil {
- return
- }
-
- return repo.db.Set(id, data)
-}
-
-func (repo *sessionRepository) Get(id string) (s model.Session, err error) {
- data, err := repo.db.Get(id)
- if err != nil {
- err = model.ErrSessionNotFound
- return
- }
-
- err = json.Unmarshal(data, &s)
- if err != nil {
- return
- }
-
- return
-}