kristianjbf/dendrite.daemon
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(repos): use new table name in repo and tests

Browse source
This commit is contained in:
Kristian Borgwarth 2026-04-08 22:14:07 +02:00
parent 75155dc536
commit adba974a4b
4 changed files with 12 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
persistence/migrations/003_link.sql
View file

@ -6,9 +6,9 @@ CREATE TABLE IF NOT EXISTS link (
raw TEXT NOT NULL, raw TEXT NOT NULL,
line INTEGER NOT NULL, line INTEGER NOT NULL,
col INTEGER NOT NULL, col INTEGER NOT NULL,
FOREIGN KEY(from_note_id) REFERENCES note(id) ON DELETE CASCADE, FOREIGN KEY(from_note_id) REFERENCES note(id) ON DELETE CASCADE
); );
CREATE INDEX idx_link_from ON links(from_note_id); CREATE INDEX idx_link_from ON link(from_note_id);
CREATE INDEX idx_link_target ON links(target_slug); CREATE INDEX idx_link_target ON link(target_slug);

2
persistence/repositories/note_repository.go
View file

@ -21,7 +21,7 @@ func NewNoteRepository(tx *sql.Tx) NoteRepository {
func (r *noteRepository) Upsert(ctx context.Context, note *models.Note) error { func (r *noteRepository) Upsert(ctx context.Context, note *models.Note) error {
query := ` query := `
INSERT INTO notes (id, title, path, slug, created_at, updated_at) INSERT INTO note (id, title, path, slug, created_at, updated_at)
VALUES (?, ?, ?, ?, datetime('now'), datetime('now')) VALUES (?, ?, ?, ?, datetime('now'), datetime('now'))
ON CONFLICT (slug) DO UPDATE ON CONFLICT (slug) DO UPDATE
SET title = EXCLUDED.title, SET title = EXCLUDED.title,

6
persistence/repositories/tag_repository.go
View file

@ -35,7 +35,7 @@ func (r *tagRepository) Upsert(ctx context.Context, tags []*models.Tag) error {
args = append(args, tag.ID(), tag.Name()) args = append(args, tag.ID(), tag.Name())
} }
query := "INSERT OR IGNORE INTO tags(id, name) VALUES " + strings.Join(placeholders, ",") query := "INSERT OR IGNORE INTO tag(id, name) VALUES " + strings.Join(placeholders, ",")
_, err := r.Transaction.ExecContext(ctx, query, args...) _, err := r.Transaction.ExecContext(ctx, query, args...)
return err return err
@ -54,7 +54,7 @@ func (r *tagRepository) UpsertNoteTags(ctx context.Context ,noteID string, tagID
args = append(args, noteID, tagID) args = append(args, noteID, tagID)
} }
query := "INSERT OR IGNORE INTO note_tags(note_id, tag_id) VALUES " + strings.Join(placeholders, ",") query := "INSERT OR IGNORE INTO note_tag(note_id, tag_id) VALUES " + strings.Join(placeholders, ",")
_, err := r.Transaction.ExecContext(ctx, query, args...) _, err := r.Transaction.ExecContext(ctx, query, args...)
if err != nil { if err != nil {
@ -77,7 +77,7 @@ func (r *tagRepository) GetByNames(ctx context.Context, names []string) ([]*mode
args = append(args, name) args = append(args, name)
} }
query := "SELECT id, name FROM tags WHERE name IN (" + strings.Join(placeholders, ",") + ")" query := "SELECT id, name FROM tag WHERE name IN (" + strings.Join(placeholders, ",") + ")"
rows, err := r.Transaction.QueryContext(ctx, query, args...) rows, err := r.Transaction.QueryContext(ctx, query, args...)
if err != nil { if err != nil {

10
test/test_integration/create_note_handler_test.go
View file

@ -31,7 +31,7 @@ func TestCreateNoteHandler_NoTemplate_CreatesNoteFileAndReturnsPath(t *testing.T
assert.Equal(t, notePath, result) assert.Equal(t, notePath, result)
var count int var count int
require.NoError(t, Fixture.DB.QueryRow(`SELECT COUNT(*) FROM notes WHERE slug = ?`, "my-note").Scan(&count)) require.NoError(t, Fixture.DB.QueryRow(`SELECT COUNT(*) FROM note WHERE slug = ?`, "my-note").Scan(&count))
assert.Equal(t, 1, count) assert.Equal(t, 1, count)
_, statErr := os.Stat(notePath) _, statErr := os.Stat(notePath)
@ -68,10 +68,10 @@ func TestCreateNoteHandler_WithTemplate_CreatesNoteFileWithTagsAndReturnsPath(t
assert.Equal(t, notePath, result) assert.Equal(t, notePath, result)
var noteCount int var noteCount int
require.NoError(t, Fixture.DB.QueryRow(`SELECT COUNT(*) FROM notes WHERE slug = ?`, "templated-note").Scan(&noteCount)) require.NoError(t, Fixture.DB.QueryRow(`SELECT COUNT(*) FROM note WHERE slug = ?`, "templated-note").Scan(&noteCount))
assert.Equal(t, 1, noteCount) assert.Equal(t, 1, noteCount)
rows, err := Fixture.DB.Query(`SELECT name FROM tags WHERE name IN ('go', 'testing')`) rows, err := Fixture.DB.Query(`SELECT name FROM tag WHERE name IN ('go', 'testing')`)
require.NoError(t, err) require.NoError(t, err)
defer rows.Close() defer rows.Close()
@ -112,12 +112,12 @@ func TestCreateNoteHandler_DuplicateSlug_Upserts(t *testing.T) {
require.NoError(t, err) require.NoError(t, err)
var count int var count int
require.NoError(t, Fixture.DB.QueryRow(`SELECT COUNT(*) FROM notes WHERE slug = ?`, "dup-note").Scan(&count)) require.NoError(t, Fixture.DB.QueryRow(`SELECT COUNT(*) FROM note WHERE slug = ?`, "dup-note").Scan(&count))
assert.Equal(t, 1, count) assert.Equal(t, 1, count)
expectedPath := filepath.Join(vaultPath, subDir2, "dup-note.md") expectedPath := filepath.Join(vaultPath, subDir2, "dup-note.md")
var path string var path string
require.NoError(t, Fixture.DB.QueryRow(`SELECT path FROM notes WHERE slug = ?`, "dup-note").Scan(&path)) require.NoError(t, Fixture.DB.QueryRow(`SELECT path FROM note WHERE slug = ?`, "dup-note").Scan(&path))
assert.Equal(t, expectedPath, path) assert.Equal(t, expectedPath, path)
} }