71 lines
1.2 KiB
Go
71 lines
1.2 KiB
Go
|
package headscale
|
||
|
|
|
||
|
|
import (
|
||
|
|
"errors"
|
||
|
|
|
||
|
|
"github.com/jinzhu/gorm"
|
||
|
|
_ "github.com/jinzhu/gorm/dialects/postgres"
|
||
|
|
)
|
||
|
|
|
||
|
|
const dbVersion = "1"
|
||
|
|
|
||
|
|
type KV struct {
|
||
|
|
Key string
|
||
|
|
Value string
|
||
|
|
}
|
||
|
|
|
||
|
|
func (h *Headscale) initDB() error {
|
||
|
|
db, err := gorm.Open("postgres", h.dbString)
|
||
|
|
if err != nil {
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
db.Exec("create extension if not exists \"uuid-ossp\";")
|
||
|
|
db.AutoMigrate(&Machine{})
|
||
|
|
db.AutoMigrate(&KV{})
|
||
|
|
db.Close()
|
||
|
|
|
||
|
|
h.setValue("db_version", dbVersion)
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (h *Headscale) db() (*gorm.DB, error) {
|
||
|
|
db, err := gorm.Open("postgres", h.dbString)
|
||
|
|
if err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
return db, nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (h *Headscale) getValue(key string) (string, error) {
|
||
|
|
db, err := h.db()
|
||
|
|
if err != nil {
|
||
|
|
return "", err
|
||
|
|
}
|
||
|
|
defer db.Close()
|
||
|
|
var row KV
|
||
|
|
if db.First(&row, "key = ?", key).RecordNotFound() {
|
||
|
|
return "", errors.New("not found")
|
||
|
|
}
|
||
|
|
return row.Value, nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (h *Headscale) setValue(key string, value string) error {
|
||
|
|
kv := KV{
|
||
|
|
Key: key,
|
||
|
|
Value: value,
|
||
|
|
}
|
||
|
|
db, err := h.db()
|
||
|
|
if err != nil {
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
defer db.Close()
|
||
|
|
_, err = h.getValue(key)
|
||
|
|
if err == nil {
|
||
|
|
db.Model(&kv).Where("key = ?", key).Update("value", value)
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
db.Create(kv)
|
||
|
|
return nil
|
||
|
|
}
|