From 2af37d47783aac8c650ffd1578e2297b5784c73d Mon Sep 17 00:00:00 2001
From: r <r@freesoftwareextremist.com>
Date: Tue, 28 Jan 2020 17:51:00 +0000
Subject: Refactor everything

---
 repo/appRepo.go     | 42 ++++++++++++++++++++++++++++++++++++++++++
 repo/sessionRepo.go | 42 ++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 84 insertions(+)
 create mode 100644 repo/appRepo.go
 create mode 100644 repo/sessionRepo.go

(limited to 'repo')

diff --git a/repo/appRepo.go b/repo/appRepo.go
new file mode 100644
index 0000000..6338c4a
--- /dev/null
+++ b/repo/appRepo.go
@@ -0,0 +1,42 @@
+package repo
+
+import (
+	"encoding/json"
+
+	"bloat/kv"
+	"bloat/model"
+)
+
+type appRepo struct {
+	db *kv.Database
+}
+
+func NewAppRepo(db *kv.Database) *appRepo {
+	return &appRepo{
+		db: db,
+	}
+}
+
+func (repo *appRepo) Add(a model.App) (err error) {
+	data, err := json.Marshal(a)
+	if err != nil {
+		return
+	}
+	err = repo.db.Set(a.InstanceDomain, data)
+	return
+}
+
+func (repo *appRepo) Get(instanceDomain string) (a model.App, err error) {
+	data, err := repo.db.Get(instanceDomain)
+	if err != nil {
+		err = model.ErrAppNotFound
+		return
+	}
+
+	err = json.Unmarshal(data, &a)
+	if err != nil {
+		return
+	}
+
+	return
+}
diff --git a/repo/sessionRepo.go b/repo/sessionRepo.go
new file mode 100644
index 0000000..ce923b1
--- /dev/null
+++ b/repo/sessionRepo.go
@@ -0,0 +1,42 @@
+package repo
+
+import (
+	"encoding/json"
+
+	"bloat/kv"
+	"bloat/model"
+)
+
+type sessionRepo struct {
+	db *kv.Database
+}
+
+func NewSessionRepo(db *kv.Database) *sessionRepo {
+	return &sessionRepo{
+		db: db,
+	}
+}
+
+func (repo *sessionRepo) 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 *sessionRepo) 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
+}
-- 
cgit v1.2.3