From 6ad251fc4741b7af3dfd87c1ff796fd0044a4175 Mon Sep 17 00:00:00 2001
From: Grail Finder <wohilas@gmail.com>
Date: Sat, 5 Jul 2025 14:32:48 +0300
Subject: [PATCH] Enha: journal repo [wip]

---
 repos/journal.go | 25 ++++++++++++++++++++++++-
 1 file changed, 24 insertions(+), 1 deletion(-)

diff --git a/repos/journal.go b/repos/journal.go
index b1746c9..801cc02 100644
--- a/repos/journal.go
+++ b/repos/journal.go
@@ -3,10 +3,33 @@ package repos
 import (
 	"context"
 	"gralias/models"
+
+	"github.com/jmoiron/sqlx"
 )
 
 type JournalRepo interface {
 	JournalByRoomID(ctx context.Context, roomID string) ([]models.Journal, error)
-	JournalCreate(ctx context.Context, action *models.Journal) error
+	JournalCreate(ctx context.Context, j *models.Journal) error
 	JournalDeleteByRoomID(ctx context.Context, roomID string) error
 }
+
+func (p *RepoProvider) JournalByRoomID(ctx context.Context, roomID string) ([]models.Journal, error) {
+	journals := []models.Journal{}
+	err := sqlx.SelectContext(ctx, p.DB, &journals, `SELECT id, created_at, entry, username, room_id FROM journal WHERE room_id = ? ORDER BY created_at ASC`, roomID)
+	if err != nil {
+		return nil, err
+	}
+	return journals, nil
+}
+
+func (p *RepoProvider) JournalCreate(ctx context.Context, j *models.Journal) error {
+	db := getDB(ctx, p.DB)
+	_, err := db.ExecContext(ctx, `INSERT INTO journal (entry, username, room_id) VALUES (?, ?, ?)`, j.Entry, j.Username, j.RoomID)
+	return err
+}
+
+func (p *RepoProvider) JournalDeleteByRoomID(ctx context.Context, roomID string) error {
+	db := getDB(ctx, p.DB)
+	_, err := db.ExecContext(ctx, `DELETE FROM journal WHERE room_id = ?`, roomID)
+	return err
+}