dkelly/nkode-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor sqlite repository

Browse Source
This commit is contained in:
Donovan
2025-01-25 14:39:02 -06:00
parent 0a1b8f9457
commit 44bede14e4
4 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
api/nkode_api_test.go
View File

@@ -18,7 +18,7 @@ func TestNKodeAPI(t *testing.T) {
dbPath := os.Getenv("TEST_DB") dbPath := os.Getenv("TEST_DB")
ctx := context.Background() ctx := context.Background()
sqlitedb, err := repository.NewSqliteRepository(dbPath, ctx) sqlitedb, err := repository.NewSqliteRepository(ctx, dbPath)
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
} }

2
cmd/nkode/nkode.go
View File

@@ -29,7 +29,7 @@ func main() {
log.Fatal(err) log.Fatal(err)
} }
ctx := context.Background() ctx := context.Background()
sqliteRepo, err := repository.NewSqliteRepository(*dbPath, ctx) sqliteRepo, err := repository.NewSqliteRepository(ctx, *dbPath)
sqliteRepo.Start() sqliteRepo.Start()
defer func(sqliteRepo *repository.SqliteRepository) { defer func(sqliteRepo *repository.SqliteRepository) {
if err := sqliteRepo.Stop(); err != nil { if err := sqliteRepo.Stop(); err != nil {

2
repository/sqlite_repository.go
View File

@@ -20,7 +20,7 @@ type SqliteRepository struct {
ctx context.Context ctx context.Context
} }
func NewSqliteRepository(dbPath string, ctx context.Context) (*SqliteRepository, error) { func NewSqliteRepository(ctx context.Context, dbPath string) (*SqliteRepository, error) {
sqliteDb, err := sqlc.OpenSqliteDb(dbPath) sqliteDb, err := sqlc.OpenSqliteDb(dbPath)
if err != nil { if err != nil {
return nil, err return nil, err

2
repository/sqlite_repository_test.go
View File

@@ -11,7 +11,7 @@ import (
func TestNewSqliteDB(t *testing.T) { func TestNewSqliteDB(t *testing.T) {
dbPath := os.Getenv("TEST_DB") dbPath := os.Getenv("TEST_DB")
ctx := context.Background() ctx := context.Background()
sqliteDb, err := NewSqliteRepository(dbPath, ctx) sqliteDb, err := NewSqliteRepository(ctx, dbPath)
assert.NoError(t, err) assert.NoError(t, err)
sqliteDb.Start() sqliteDb.Start()
defer func(t *testing.T, sqliteDb *SqliteRepository) { defer func(t *testing.T, sqliteDb *SqliteRepository) {