From b58ea19a86fc9b1a315745eb9e0fcd8e7e629936 Mon Sep 17 00:00:00 2001
From: yequari <yequari@32bit.cafe>
Date: Sun, 9 Mar 2025 00:02:41 -0700
Subject: [PATCH] remove unused function and get message queue

---
 cmd/web/handlers.go                 | 28 +++++++++++++++++++++++++++
 cmd/web/main.go                     |  4 ----
 internal/models/guestbookcomment.go | 30 ++++++++++++++++++++++++++++-
 3 files changed, 57 insertions(+), 5 deletions(-)

diff --git a/cmd/web/handlers.go b/cmd/web/handlers.go
index 0f628c8..9acca46 100644
--- a/cmd/web/handlers.go
+++ b/cmd/web/handlers.go
@@ -298,8 +298,36 @@ func (app *application) postGuestbookCommentCreate(w http.ResponseWriter, r *htt
     http.Redirect(w, r, fmt.Sprintf("/guestbooks/%s", guestbookSlug), http.StatusSeeOther)
 }
 
+func (app *application) updateGuestbookComment(w http.ResponseWriter, r *http.Request) {
+}
+
 func (app *application) deleteGuestbookComment(w http.ResponseWriter, r *http.Request) {
     // slug := r.PathValue("id")
     // shortId := slugToShortId(slug)
     // app.guestbookComments.Delete(shortId)
 }
+
+func (app *application) getCommentQueue(w http.ResponseWriter, r *http.Request) []models.GuestbookComment {
+    guestbookSlug := r.PathValue("id")
+    guestbook, err := app.guestbooks.Get(slugToShortId(guestbookSlug))
+    if err != nil {
+        if errors.Is(err, models.ErrNoRecord) {
+            http.NotFound(w, r)
+        } else {
+            app.serverError(w, r, err)
+        }
+        return []models.GuestbookComment{}
+    }
+
+    comments, err := app.guestbookComments.GetQueue(guestbook.ID)
+    if err != nil {
+        if errors.Is(err, models.ErrNoRecord) {
+            http.NotFound(w, r)
+        } else {
+            app.serverError(w, r, err)
+        }
+        return []models.GuestbookComment{}
+    }
+
+    return comments
+}
diff --git a/cmd/web/main.go b/cmd/web/main.go
index 0269abe..4e715de 100644
--- a/cmd/web/main.go
+++ b/cmd/web/main.go
@@ -105,7 +105,3 @@ func openDB(dsn string) (*sql.DB, error) {
     }
     return db, nil
 }
-
-func getUserId() int64 {
-    return 1
-}
diff --git a/internal/models/guestbookcomment.go b/internal/models/guestbookcomment.go
index 7a5beb0..6d37450 100644
--- a/internal/models/guestbookcomment.go
+++ b/internal/models/guestbookcomment.go
@@ -55,7 +55,35 @@ func (m *GuestbookCommentModel) Get(shortId uint64) (GuestbookComment, error) {
 
 func (m *GuestbookCommentModel) GetAll(guestbookId int64) ([]GuestbookComment, error) {
     stmt := `SELECT Id, ShortId, GuestbookId, ParentId, AuthorName, AuthorEmail, AuthorSite,
-    CommentText, PageUrl, Created, IsPublished, IsDeleted FROM guestbook_comments WHERE GuestbookId = ? AND IsDeleted = FALSE ORDER BY Created DESC`
+    CommentText, PageUrl, Created, IsPublished, IsDeleted 
+	    FROM guestbook_comments 
+	    WHERE GuestbookId = ? AND IsDeleted = FALSE AND IsPublished = TRUE
+	    ORDER BY Created DESC`
+    rows, err := m.DB.Query(stmt, guestbookId)
+    if err != nil {
+	return nil, err
+    }
+    var comments []GuestbookComment
+    for rows.Next() {
+	var c GuestbookComment
+	err = rows.Scan(&c.ID, &c.ShortId, &c.GuestbookId, &c.ParentId, &c.AuthorName, &c.AuthorEmail, &c.AuthorSite, &c.CommentText, &c.PageUrl, &c.Created, &c.IsPublished, &c.IsDeleted)
+	if err != nil {
+	    return nil, err
+	}
+	comments = append(comments, c)
+    }
+    if err = rows.Err(); err != nil {
+	return nil, err
+    }
+    return comments, nil
+}
+
+func (m *GuestbookCommentModel) GetQueue(guestbookId int64) ([]GuestbookComment, error) {
+    stmt := `SELECT Id, ShortId, GuestbookId, ParentId, AuthorName, AuthorEmail, AuthorSite,
+    CommentText, PageUrl, Created, IsPublished, IsDeleted 
+	    FROM guestbook_comments 
+	    WHERE GuestbookId = ? AND IsDeleted = FALSE AND IsPublished = FALSE
+	    ORDER BY Created DESC`
     rows, err := m.DB.Query(stmt, guestbookId)
     if err != nil {
 	return nil, err