api: implemented list subreddit api

.air.toml

@@ -7,7 +7,7 @@ args_bin = ["serve"]
 bin = "./tmp/main"
 cmd = "go build -o ./tmp/main ."
 delay = 1000
-exclude_dir = ["assets", "tmp", "vendor", "testdata"]
+exclude_dir = ["assets", "tmp", "vendor", "testdata", "node_modules"]
 exclude_file = []
 exclude_regex = ["_test.go", "db/queries/.*\\.go", "_templ.go"]
 exclude_unchanged = false

api/api.go

@@ -0,0 +1,12 @@
+package api
+
+import (
+	"database/sql"
+
+	"github.com/tigorlazuardi/redmage/db/queries"
+)
+
+type API struct {
+	Queries *queries.Queries
+	DB      *sql.DB
+}

api/subreddits/list_subreddits.go

@@ -1 +0,0 @@
-package subreddits

api/subreddits/subreddits.go

@@ -1,9 +0,0 @@
-package subreddits
-
-import (
-	subredditsDB "github.com/tigorlazuardi/redmage/db/queries/subreddits"
-)
-
-type API struct {
-	SubredditDB *subredditsDB.Queries
-}

api/subreddits_list.go

@@ -0,0 +1,54 @@
+package api
+
+import (
+	"context"
+
+	"github.com/tigorlazuardi/redmage/db/queries"
+	"github.com/tigorlazuardi/redmage/pkg/errs"
+)
+
+type ListSubredditsParams struct {
+	Name   string `json:"name"`
+	Limit  int64  `json:"limit"`
+	Offset int64  `json:"offset"`
+}
+
+type ListSubredditsResult struct {
+	Total int64
+	Data  []queries.Subreddit
+}
+
+func (api *API) ListSubreddits(ctx context.Context, arg ListSubredditsParams) (result ListSubredditsResult, err error) {
+	if arg.Name != "" {
+		result.Data, err = api.Queries.SubredditsSearch(ctx, queries.SubredditsSearchParams{
+			Name:   "%" + arg.Name + "%",
+			Limit:  arg.Limit,
+			Offset: arg.Offset,
+		})
+		if err != nil {
+			return result, errs.Wrapw(err, "failed to search subreddit", "query", arg)
+		}
+		result.Total, err = api.Queries.SubredditsSearchCount(ctx, queries.SubredditsSearchCountParams{
+			Name:   "%" + arg.Name + "%",
+			Limit:  arg.Limit,
+			Offset: arg.Offset,
+		})
+		if err != nil {
+			return result, errs.Wrapw(err, "failed to count subreddit search", "query", arg)
+		}
+		return result, err
+	}
+
+	result.Data, err = api.Queries.SubredditsList(ctx, queries.SubredditsListParams{
+		Limit:  arg.Limit,
+		Offset: arg.Offset,
+	})
+	if err != nil {
+		return result, errs.Wrapw(err, "failed to list subreddit", "query", arg)
+	}
+	result.Total, err = api.Queries.SubredditsListCount(ctx)
+	if err != nil {
+		return result, errs.Wrapw(err, "failed to count subreddit list", "query", arg)
+	}
+	return result, err
+}

db/queries/subreddits.sql

@@ -1,9 +1,24 @@
--- name: ListSubreddits :many
+-- name: SubredditsList :many
 SELECT * FROM subreddits
 ORDER BY name
-LIMIT ?;
+LIMIT ? OFFSET ?;
 
--- name: CreateSubreddit :one
+-- name: SubredditsListCount :one
+SELECT COUNT(*) From subreddits;
+
+-- name: SubredditsSearch :many
+SELECT * FROM subreddits
+WHERE name LIKE ?
+ORDER BY name
+LIMIT ? OFFSET ?;
+
+-- name: SubredditsSearchCount :one
+SELECT COUNT(*) FROM subreddits
+WHERE name LIKE ?
+ORDER BY name
+LIMIT ? OFFSET ?;
+
+-- name: SubredditCreate :one
 INSERT INTO subreddits (name, subtype, schedule)
 VALUES (?, ?, ?)
 RETURNING *;

server/routes/api/subreddits_list.go

@@ -4,13 +4,15 @@ import (
 	"encoding/json"
 	"fmt"
 	"net/http"
+	"strconv"
 
+	"github.com/tigorlazuardi/redmage/db/queries/subreddits"
 	"github.com/tigorlazuardi/redmage/pkg/log"
 )
 
 func (api *API) ListSubreddits(rw http.ResponseWriter, r *http.Request) {
 	rw.Header().Add("Content-Type", "application/json")
-	subs, err := api.Subreddits.ListSubreddits(r.Context(), 10)
+	subs, err := api.Subreddits.ListSubreddits(r.Context(), parseListSubredditsQuery(r))
 	if err != nil {
 		rw.WriteHeader(http.StatusInternalServerError)
 		msg := fmt.Sprintf("failed to list subreddits: %s", err)
@@ -22,3 +24,17 @@ func (api *API) ListSubreddits(rw http.ResponseWriter, r *http.Request) {
 		log.New(r.Context()).Err(err).Error("failed to list subreddits")
 	}
 }
+
+func parseListSubredditsQuery(r *http.Request) subreddits.ListSubredditsParams {
+	params := subreddits.ListSubredditsParams{}
+	params.Limit, _ = strconv.ParseInt(r.URL.Query().Get("limit"), 10, 64)
+	params.Offset, _ = strconv.ParseInt(r.URL.Query().Get("offset"), 10, 64)
+
+	if params.Limit < 1 {
+		params.Limit = 10
+	} else if params.Limit > 100 {
+		params.Limit = 100
+	}
+
+	return params
+}

server/routes/www/www.go

@@ -36,6 +36,7 @@ func (www *WWW) Register(router chi.Router) {
 
 	router.Group(func(r chi.Router) {
 		r.Use(chimiddleware.RequestLogger(middleware.ChiLogger{}))
+		r.Use(chimiddleware.SetHeader("Content-Type", "text/html; utf-8"))
 		r.Get("/", www.Home)
 	})
 }

sqlc.yaml

@@ -2,12 +2,12 @@ version: "2"
 
 sql:
   - engine: sqlite
-    queries: "db/queries/subreddits.sql"
+    queries: "db/queries"
     schema: "db/migrations"
     gen:
       go:
-        package: subreddits
+        package: queries
-        out: "db/queries/subreddits"
+        out: "db/queries"
         emit_empty_slices: true
         emit_sql_as_comment: true
         emit_json_tags: true