[dev] initial backend with crud operations

Author: a-shpak

.gitignore

@@ -0,0 +1,6 @@
+.idea
+.vscode
+cheduler-go
+db.sqlite
+application*
+__debug_bin

api/index.go

@@ -0,0 +1,19 @@
+package api
+
+import (
+	remote "github.com/mkozhukh/go-remote"
+
+	"web-widgets/scheduler-go/data"
+)
+
+func BuildAPI(db *data.DAO) *remote.Server {
+	if remote.MaxSocketMessageSize < 32000 {
+		remote.MaxSocketMessageSize = 32000
+	}
+
+	api := remote.NewServer(&remote.ServerConfig{
+		WebSocket: true,
+	})
+
+	return api
+}

common/int.go

@@ -0,0 +1,24 @@
+package common
+
+import (
+	"encoding/json"
+)
+
+const QuotesByte = 34
+
+type FuzzyInt int
+
+func (f *FuzzyInt) UnmarshalJSON(data []byte) error {
+	var err error
+	var temp int
+	if data[0] == QuotesByte {
+		// empty string => 0
+		if len(data) > 2 {
+			err = json.Unmarshal(data[1:len(data)-1], &temp)
+		}
+	} else {
+		err = json.Unmarshal(data, &temp)
+	}
+	*f = FuzzyInt(temp)
+	return err
+}

config.go

@@ -0,0 +1,14 @@
+package main
+
+import "web-widgets/scheduler-go/data"
+
+type ConfigServer struct {
+	URL  string
+	Port string
+	Cors []string
+}
+
+type AppConfig struct {
+	Server ConfigServer
+	DB     data.DBConfig
+}

config.yml

@@ -0,0 +1,8 @@
+db:
+  path: db.sqlite
+  resetonstart: true
+server:
+  url: "http://localhost:3000"
+  port: ":3000"
+  cors:
+    - "*"

data/data.go

@@ -0,0 +1,16 @@
+package data
+
+import (
+	"time"
+)
+
+type Event struct {
+	ID        int        `json:"id"`
+	Name      string     `json:"text"`
+	StartDate *time.Time `json:"start_date"`
+	EndDate   *time.Time `json:"end_date"`
+	Readonly  bool       `json:"readonly"`
+	AllDay    bool       `json:"allDay"`
+	Type      string     `json:"type"`
+	Details   string     `json:"details"`
+}

data/db.go

@@ -0,0 +1,62 @@
+package data
+
+import (
+	"log"
+
+	"gorm.io/driver/sqlite"
+	"gorm.io/gorm"
+	"gorm.io/gorm/logger"
+)
+
+var Debug = 1
+
+func logError(e error) {
+	if e != nil && Debug > 0 {
+		log.Printf("[ERROR]\n%s\n", e)
+	}
+}
+
+type DBConfig struct {
+	Path         string
+	ResetOnStart bool
+}
+
+type DAO struct {
+	db *gorm.DB
+
+	Events *EventsDAO
+}
+
+func (d *DAO) GetDB() *gorm.DB {
+	return d.db
+}
+
+func (d *DAO) mustExec(sql string) {
+	err := d.db.Exec(sql).Error
+	if err != nil {
+		panic(err)
+	}
+}
+
+func NewDAO(config DBConfig, url string) *DAO {
+	db, err := gorm.Open(sqlite.Open(config.Path), &gorm.Config{
+		Logger: logger.Default.LogMode(logger.Error),
+	})
+	if err != nil {
+		panic("failed to connect database")
+	}
+
+	db.AutoMigrate(&Event{})
+
+	dao := &DAO{
+		db:     db,
+		Events: NewEventsDAO(db),
+	}
+
+	if config.ResetOnStart {
+		dataDown(dao)
+		dataUp(dao)
+	}
+
+	return dao
+}

data/demodata.go

@@ -0,0 +1,69 @@
+package data
+
+import (
+	"encoding/json"
+	"io/ioutil"
+	"time"
+	"web-widgets/scheduler-go/common"
+)
+
+type EventDemo struct {
+	ID        common.FuzzyInt `json:"id"`
+	Name      string          `json:"text"`
+	StartDate string          `json:"start_date"`
+	EndDate   string          `json:"end_date"`
+	Readonly  bool            `json:"readonly"`
+	AllDay    bool            `json:"allDay"`
+	Type      string          `json:"type"`
+	Details   string          `json:"details"`
+}
+
+func (d *EventDemo) GetModel() *Event {
+	sDate, _ := time.Parse("2006-01-02 15:04:05", d.StartDate)
+	eDate, _ := time.Parse("2006-01-02 15:04:05", d.EndDate)
+
+	return &Event{
+		ID:        int(d.ID),
+		Name:      d.Name,
+		StartDate: &sDate,
+		EndDate:   &eDate,
+		Readonly:  d.Readonly,
+		AllDay:    d.AllDay,
+		Type:      d.Type,
+		Details:   d.Details,
+	}
+}
+
+func getData() ([]EventDemo, error) {
+	bytes, err := ioutil.ReadFile("./demodata/events.json")
+	if err != nil {
+		logError(err)
+		return nil, err
+	}
+	data := make([]EventDemo, 0)
+	err = json.Unmarshal(bytes, &data)
+
+	return data, err
+}
+
+func dataDown(d *DAO) {
+	d.mustExec("DELETE from events")
+}
+
+func dataUp(d *DAO) error {
+	db := d.GetDB()
+	events, err := getData()
+	if err != nil {
+		logError(err)
+		return err
+	}
+
+	tx := db.Begin()
+	for _, r := range events {
+		err = tx.Create(r.GetModel()).Error
+		if err != nil {
+			return err
+		}
+	}
+	return tx.Commit().Error
+}

data/records.go

@@ -0,0 +1,67 @@
+package data
+
+import (
+	"time"
+	"web-widgets/scheduler-go/common"
+
+	"gorm.io/gorm"
+)
+
+func NewEventsDAO(db *gorm.DB) *EventsDAO {
+	return &EventsDAO{db}
+}
+
+type EventUpdate struct {
+	ID        common.FuzzyInt `json:"id"`
+	Name      string          `json:"text"`
+	StartDate *time.Time      `json:"start_date"`
+	EndDate   *time.Time      `json:"end_date"`
+	Readonly  bool            `json:"readonly"`
+	AllDay    bool            `json:"allDay"`
+	Type      string          `json:"type"`
+	Details   string          `json:"details"`
+}
+
+type EventsDAO struct {
+	db *gorm.DB
+}
+
+func (d *EventsDAO) GetAll() ([]Event, error) {
+	events := make([]Event, 0)
+	err := d.db.Find(&events).Error
+
+	return events, err
+}
+
+func (d *EventsDAO) Add(event *Event) (int, error) {
+	event.ID = 0
+	err := d.db.Save(event).Error
+	return event.ID, err
+}
+
+func (d *EventsDAO) Update(event *Event) error {
+	c := Event{}
+	err := d.db.Find(&c, event.ID).Error
+	if err != nil || c.ID == 0 {
+		return err
+	}
+	err = d.db.Save(&event).Error
+	return err
+}
+
+func (d *EventsDAO) Delete(id int) error {
+	err := d.db.Delete(&Event{}, id).Error
+	return err
+}
+
+func (d *EventUpdate) GetModel() *Event {
+	return &Event{
+		ID:        int(d.ID),
+		Name:      d.Name,
+		StartDate: d.StartDate,
+		EndDate:   d.EndDate,
+		Readonly:  d.Readonly,
+		Type:      d.Type,
+		Details:   d.Details,
+	}
+}