Switch from in-memory to SQLite storage

store.go

@@ -1,65 +1,144 @@
 package main
 
 import (
-	"errors"
+	"database/sql"
+	_ "embed"
+	"fmt"
+	"os"
+	"strconv"
+	"time"
 )
 
+//go:embed  schema.sql
+var schema string
+
 type store struct {
-	cakes  []cake
-	orders []order
+	db *sql.DB
 }
 
-func NewStore() *store {
+// #todo: implement database persistance
+func NewStore(filename string) (*store, error) {
 	var out store
-	out.cakes = make([]cake, 0)
-	out.orders = make([]order, 0)
-	return &out
+	var err error
+	if filename != ":memory:" {
+		os.Remove(filename)
+	}
+	// #todo: handle the error
+	out.db, err = sql.Open("sqlite3", filename)
+	if err != nil {
+		return nil, err
+	}
+
+	_, err = out.db.Exec(schema)
+	if err != nil {
+		out.db.Close()
+		return nil, err
+	}
+	return &out, nil
 }
 
+// #todo: should return an error
 func (s *store) getCakes() []cake {
-	return s.cakes
-}
-
-func (s *store) saveCake(newCake cake) int {
-	if newCake.ID == -1 {
-		newCake.ID = len(s.cakes)
-		s.cakes = append(s.cakes, newCake)
-		return newCake.ID
+	// #todo: error handling
+	rows, err := s.db.Query("select id, name, price from cake")
+	defer rows.Close()
+	if err != nil {
+		return nil
 	}
-	for i := range s.cakes {
-		if s.cakes[i].ID == newCake.ID {
-			s.cakes[i] = newCake
-			break
+	cakes := make([]cake, 0)
+	for rows.Next() {
+		var c cake
+		err = rows.Scan(&c.ID, &c.Name, &c.Price)
+		c.Amount = 0
+		if err != nil {
+			fmt.Println("error scanning rows into cake: ", err)
 		}
+		cakes = append(cakes, c)
 	}
-	return newCake.ID
+	return cakes
 }
 
+func (s *store) saveCake(newCake cake) (int, error) {
+	query := "insert into cake(name, price) values (?, ?) returning id;"
+	if newCake.ID != -1 {
+		query = "update cake set name = ? , price = ? where id = "
+		query += strconv.Itoa(newCake.ID) + " returning id;"
+	}
+
+	// #todo: error handling
+	row, err := s.db.Query(query, newCake.Name, newCake.Price)
+	if err != nil {
+		return -1, err
+	}
+	defer row.Close()
+
+	// #todo: see if next is required or not to get the first element
+	row.Next()
+	row.Scan(&newCake.ID)
+	return newCake.ID, nil
+}
+
+// #todo: retrieve and save order contents
 func (s *store) getOrder(id int) (order, error) {
-	for _, e := range s.orders {
-		if e.ID == id {
-			return e, nil
-		}
+	var out order
+	// #todo: error handling
+	row, err := s.db.Query("select id, name, surname, phone, location, order_date, delivery_date, status, paid from customer_order where id = ?;", id)
+	defer row.Close()
+	if err != nil {
+		return out, err
 	}
-	return order{}, errors.New("order not found")
+
+	var order_date, delivery_date string
+	row.Next()
+	row.Scan(&out.ID, &out.Name, &out.Surname, &out.Phone, &out.Location, &order_date, &delivery_date, &out.Status, &out.Paid)
+	// #todo: error handling
+	out.Accepted, _ = time.Parse("2006-01-02 15:04", order_date)
+	out.Date, _ = time.Parse("2006-01-02 15:04", delivery_date)
+	return out, nil
 }
 
+// #todo: should return an error
 func (s *store) getOrders() []order {
-	return s.orders
-}
-
-func (s *store) saveOrder(newOrder order) int {
-	if newOrder.ID == -1 {
-		newOrder.ID = len(s.orders)
-		s.orders = append(s.orders, newOrder)
-		return newOrder.ID
+	var out []order
+	// #todo: error handling
+	row, err := s.db.Query("select id, name, surname, phone, location, order_date, delivery_date, status, paid from customer_order;")
+	defer row.Close()
+	if err != nil {
+		return out
 	}
 
-	for i := range s.orders {
-		if s.orders[i].ID == newOrder.ID {
-			s.orders[i] = newOrder
-			break
-		}
+	for row.Next() {
+		var o order
+		var order_date, delivery_date string
+		row.Scan(&o.ID, &o.Name, &o.Surname, &o.Phone, &o.Location, &order_date, &delivery_date, &o.Status, &o.Paid)
+		// #todo: error handling
+		o.Accepted, _ = time.Parse("2006-01-02 15:04", order_date)
+		o.Date, _ = time.Parse("2006-01-02 15:04", delivery_date)
+		out = append(out, o)
 	}
-	return newOrder.ID
+
+	return out
+}
+
+func (s *store) saveOrder(newOrder order) (int, error) {
+	query := "insert into customer_order(name, surname, phone, location, order_date, delivery_date, status, paid) values (?, ?, ?, ?, ?, ?, ?, ?) returning id;"
+	if newOrder.ID != -1 {
+		query = "update customer_order set name = ?, surname = ?, phone = ?, location = ?, order_date = ?, delivery_date = ?, status = ?, paid = ? where id = "
+		query += strconv.Itoa(newOrder.ID) + " returning id;"
+	}
+
+	// #todo: error handling
+	// #todo: date format
+	accepted := newOrder.Accepted.Format("2006-01-02 15:04")
+	date := newOrder.Date.Format("2006-01-02 15:04")
+	row, err := s.db.Query(query, newOrder.Name, newOrder.Surname, newOrder.Phone, newOrder.Location, accepted, date, newOrder.Status, newOrder.Paid)
+	if err != nil {
+		return -1, err
+	}
+	defer row.Close()
+
+	// #todo: see if next is required or not to get the first element
+	row.Next()
+	row.Scan(&newOrder.ID)
+	return newOrder.ID, nil
 }