feat(test): integration test setup

core/handlers/create_note_handler.go

@@ -3,6 +3,7 @@ package handlers
 import (
 	"bytes"
 	"context"
+	"database/sql"
 	"encoding/json"
 	"os"
 
@@ -19,9 +20,7 @@ type createNoteCommand struct {
 }
 
 type CreateNoteHandler struct {
-	uow      repositories.UnitOfWork
-	noteRepo repositories.NoteRepository
-	tagRepo  repositories.TagRepository
+	uow repositories.UnitOfWork
 }
 
 func (h CreateNoteHandler) Handle(ctx context.Context, params []byte) (*rpc.Response, *rpc.Error) {
@@ -46,12 +45,21 @@ func (h CreateNoteHandler) Handle(ctx context.Context, params []byte) (*rpc.Resp
 		return nil, h.ReturnError(err)
 	}
 
-	err = h.tagRepo.Upsert(ctx, tags)
-	if err != nil {
-		return nil, h.ReturnError(err)
-	}
+	err = h.uow.Execute(ctx, func(tx *sql.Tx) error {
+		tagRepo := repositories.NewTagRepository(tx)
+		noteRepo := repositories.NewNoteRepository(tx)
+
+		if err = tagRepo.Upsert(ctx, tags); err != nil {
+			return err
+		}
+
+		if err = noteRepo.Upsert(ctx, cmd.Title, cmd.Path, frontmatter.Slugify(cmd.Title)); err != nil {
+			return err
+		}
+
+		return nil
+	})
 
-	err = h.noteRepo.Upsert(ctx, cmd.Title, cmd.Path, frontmatter.Slugify(cmd.Title))
 	if err != nil {
 		return nil, h.ReturnError(err)
 	}

persistence/repositories/uow.go

@@ -6,9 +6,9 @@ import (
 )
 
 type DBContext interface {
-	ExecContext(ctx context.Context, args ...any) (sql.Result, error)
-	QueryContext(ctx context.Context, args ...any) (*sql.Rows, error)
-	QueryRowContext(ctx context.Context, args ...any) *sql.Row
+	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
+	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
+	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
 }
 
 type UnitOfWork struct {

test/test_integration/create_note_handler_test.go

@@ -0,0 +1,7 @@
+package integration_test
+
+import "testing"
+
+
+func TestCreateNoteHandlerOnSucess(t *testing.T) {
+}

test/test_integration/main_test.go

@@ -0,0 +1,23 @@
+package integration_test
+
+import (
+	"os"
+	"testing"
+	"github.com/KristianJBorgwarth/dendrite.daemon/persistence"
+)
+
+func TestMain(m *testing.M) {
+
+	currentDir := os.TempDir() + "/dendrite_test_vault"
+
+	err := persistence.InitializeIndex(currentDir)
+	if err != nil {
+		panic(err)
+	}
+
+	code := m.Run()
+
+	os.RemoveAll(currentDir)
+
+	os.Exit(code)
+}