feat: add sqlite3, sqlc and queries

cmd/main.go

@@ -1,16 +1,25 @@
 package main
 
 import (
+	"database/sql"
 	"log"
 	"net/http"
 
 	"github.com/flohansen/dasher-server/internal/datastore"
 	"github.com/flohansen/dasher-server/internal/routes"
+	"github.com/pkg/errors"
+
+	_ "github.com/mattn/go-sqlite3"
 )
 
 func run() error {
 	log.Println("listening on port 3000")
-	featureStore := datastore.NewInMem()
+	db, err := sql.Open("sqlite3", "./dasher.db")
+	if err != nil {
+		return errors.Wrap(err, "sql open")
+	}
+
+	featureStore := datastore.NewSQLite(db)
 	return http.ListenAndServe(":3000", routes.New(featureStore))
 }
 

go.mod

@@ -9,6 +9,8 @@ require (
 
 require (
 	github.com/davecgh/go-spew v1.1.1 // indirect
+	github.com/mattn/go-sqlite3 v1.14.22
+	github.com/pkg/errors v0.9.1
 	github.com/pmezard/go-difflib v1.0.0 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
 )

go.sum

@@ -1,5 +1,9 @@
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/mattn/go-sqlite3 v1.14.22 h1:2gZY6PC6kBnID23Tichd1K+Z0oS6nE/XwU+Vz/5o4kU=
+github.com/mattn/go-sqlite3 v1.14.22/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=
+github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
+github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=

internal/datastore/repository.go

@@ -1,18 +1,20 @@
 package datastore
 
 import (
-	"errors"
+	"context"
 
-	"github.com/flohansen/dasher-server/internal/model"
+	"github.com/flohansen/dasher-server/internal/sqlc"
 )
 
-type InMemDatastore struct {
+type SQLiteDatastore struct {
+	q *sqlc.Queries
 }
 
-func NewInMem() *InMemDatastore {
-	return &InMemDatastore{}
+func NewSQLite(db sqlc.DBTX) *SQLiteDatastore {
+	q := sqlc.New(db)
+	return &SQLiteDatastore{q}
 }
 
-func (repo *InMemDatastore) GetAll() ([]model.FeatureData, error) {
-	return nil, errors.New("not implemented")
+func (repo *SQLiteDatastore) GetAll(ctx context.Context) ([]sqlc.Feature, error) {
+	return repo.q.GetAllFeatures(ctx)
 }

internal/routes/features.go

@@ -1,13 +1,14 @@
 package routes
 
 import (
+	"context"
 	"encoding/json"
 	"log"
 	"net/http"
 )
 
 func (routes *Routes) getFeatures(w http.ResponseWriter, r *http.Request) {
-	features, err := routes.featureStore.GetAll()
+	features, err := routes.featureStore.GetAll(context.Background())
 	if err != nil {
 		log.Printf("error while fetching all features: %v", err)
 		w.WriteHeader(http.StatusInternalServerError)

internal/routes/routes.go

@@ -1,13 +1,14 @@
 package routes
 
 import (
+	"context"
 	"net/http"
 
-	"github.com/flohansen/dasher-server/internal/model"
+	"github.com/flohansen/dasher-server/internal/sqlc"
 )
 
 type FeatureStore interface {
-	GetAll() ([]model.FeatureData, error)
+	GetAll(ctx context.Context) ([]sqlc.Feature, error)
 }
 
 type Routes struct {

internal/routes/routes_test.go

@@ -7,8 +7,8 @@ import (
 	"net/http/httptest"
 	"testing"
 
-	"github.com/flohansen/dasher-server/internal/model"
 	"github.com/flohansen/dasher-server/internal/routes/mocks"
+	"github.com/flohansen/dasher-server/internal/sqlc"
 	"github.com/stretchr/testify/assert"
 	"go.uber.org/mock/gomock"
 )
@@ -22,7 +22,7 @@ func TestRoutes(t *testing.T) {
 		t.Run("should return 500 INTERNAL SERVER ERROR", func(t *testing.T) {
 			// given
 			featureStore.EXPECT().
-				GetAll().
+				GetAll(gomock.Any()).
 				Return(nil, errors.New("some error"))
 
 			// when
@@ -37,8 +37,8 @@ func TestRoutes(t *testing.T) {
 		t.Run("should return 200 OK", func(t *testing.T) {
 			// given
 			featureStore.EXPECT().
-				GetAll().
-				Return([]model.FeatureData{}, nil)
+				GetAll(gomock.Any()).
+				Return([]sqlc.Feature{}, nil)
 
 			// when
 			w := httptest.NewRecorder()

migrations/000001_create_features.down.sql

@@ -0,0 +1,5 @@
+begin;
+
+drop table if exists features;
+
+commit;

migrations/000001_create_features.up.sql

@@ -0,0 +1,9 @@
+begin;
+
+create table if not exists features (
+    feature_id text not null primary key,
+    description text,
+    enabled tinyint
+);
+
+commit;

queries/features.sql

@@ -0,0 +1,13 @@
+-- name: GetAllFeatures :many
+select * from features;
+
+-- name: UpsertFeature :exec
+insert into features (feature_id, description, enabled)
+values (?, ?, ?)
+on conflict (feature_id) do update set
+    description = excluded.description,
+    enabled     = excluded.enabled
+returning *;
+
+-- name: DeleteFeature :exec
+delete from features where feature_id = ?;

sqlc.yaml

@@ -0,0 +1,9 @@
+version: "2"
+sql:
+- schema: "migrations"
+  queries: "queries"
+  engine: sqlite
+  gen:
+    go:
+      package: "sqlc"
+      out: "internal/sqlc"