feat: stream some components of the site

internal/pkg/common/consts/consts.go

···
+package consts
+
+const TokenCookieName string = "TOKEN"

internal/pkg/common/utils/streaming.go

···
+package utils
+
+// StreamArray turns a given array into a receive-only chan that can be used to
+// stream data to client.
+func StreamArray[T any](array []T) <-chan T {
+	ch := make(chan T, len(array))
+
+	go func() {
+		defer close(ch)
+
+		for _, element := range array {
+			ch <- element
+		}
+	}()
+
+	return ch
+}

internal/pkg/routes/api/v1/api_router.go

···
 import "net/http"
 
 func Router() *http.ServeMux {
-	r := http.NewServeMux()
+	mux := http.NewServeMux()
 
-	r.Handle("/github/", http.StripPrefix("/github", GithubAPI()))
-	r.Handle("/blog/", http.StripPrefix("/blog", BlogAPI()))
+	mux.Handle("/github/", http.StripPrefix("/github", GithubAPI()))
+	mux.Handle("/blog/", http.StripPrefix("/blog", BlogAPI()))
 
-	return r
+	return mux
 }

internal/pkg/routes/api/v1/github_api.go

···
 	"net/http"
 	"os"
 
+	"github.com/a-h/templ"
 	gh "github.com/shurcooL/githubv4"
 	"golang.org/x/oauth2"
 
···
 }
 
 func GithubAPI() *http.ServeMux {
-	r := http.NewServeMux()
+	mux := http.NewServeMux()
 
 	token, ok := os.LookupEnv("GITHUB_TOKEN")
 	if !ok {
···
 	c := oauth2.NewClient(context.Background(), src)
 	client := gh.NewClient(c)
 
-	r.HandleFunc("/projects", func(w http.ResponseWriter, r *http.Request) {
+	mux.HandleFunc("/projects", func(w http.ResponseWriter, r *http.Request) {
 		input := gh.LanguageOrder{
 			Field:     gh.LanguageOrderFieldSize,
 			Direction: gh.OrderDirectionDesc,
···
 			repositories[i] = repository
 		}
 
-		_ = components.Repositories(repositories).Render(r.Context(), w)
+		templ.Handler(components.Repositories(repositories), templ.WithStreaming()).ServeHTTP(w, r)
 	})
 
-	return r
+	return mux
 }

internal/pkg/routes/root_router.go

···
 )
 
 func Router(static embed.FS) *http.ServeMux {
-	r := http.NewServeMux()
-	r.Handle("/", middleware.Handlers.Logger(site.Router()))
-	r.Handle("/api/v1/", middleware.Handlers.Logger(http.StripPrefix("/api/v1", v1.Router())))
-	r.Handle("/static/", http.FileServer(http.FS(static)))
+	mux := http.NewServeMux()
+
+	mux.Handle("/", middleware.Handlers.Logger(site.Router()))
+	mux.Handle("/api/v1/", middleware.Handlers.Logger(http.StripPrefix("/api/v1", v1.Router())))
+	mux.Handle("/static/", middleware.Handlers.Logger(http.FileServer(http.FS(static))))
 
-	return r
+	return mux
 }

internal/pkg/routes/site/views/components/post_list_item.templ

···
 package components
 
 import "github.com/STBoyden/go-portfolio/internal/pkg/persistence"
+import "github.com/STBoyden/go-portfolio/internal/pkg/common/utils"
 
-templ PostList(posts []persistence.Post) {
-	if len(posts) == 0 {
+templ PostList(posts []persistence.Post, showEdit bool) {
+	if !showEdit && len(posts) == 0 {
 		<div>
 			No blog posts (yet...)
 		</div>
 	} else {
-		<div></div>
+		<div class="flex flex-row gap-2">
+			for post := range utils.StreamArray(posts) {
+				@templ.Flush() {
+					<span>{ post.Content.Title }</span>
+				}
+			}
+			<button
+				class="btn btn-md btn-info text-info-content"
+				hx-target="#body"
+				hx-get="/blog/admin/new-post"
+				hx-swap="innerHTML"
+			>
+				New post
+			</button>
+		</div>
 	}
 }

internal/pkg/routes/site/views/components/repositories.templ

···
 package components
 
 import "github.com/STBoyden/go-portfolio/internal/pkg/common/types"
+import "github.com/STBoyden/go-portfolio/internal/pkg/common/utils"
 
 templ Repositories(repos []types.Repository) {
 	<script>
···
 		}
 	</script>
 	<div class="flex flex-col lg:grid lg:grid-cols-3 gap-4 justify-center">
-		for _, repo := range repos {
-			<div
-				class="card w-full bg-base-200 hover:bg-base-300 cursor-pointer card-sm shadow-sm"
-				onclick={ templ.JSFuncCall("goToRepo", repo.URL) }
-				title={ repo.URL }
-			>
-				<div class="card-body">
-					<h2 class="card-title">{ repo.Owner + "/"+ repo.Name }</h2>
-					if repo.Description != "" {
-						<p>{ repo.Description }</p>
-					}
-					<div class="justify-left card-actions">
-						for _, language := range repo.Languages {
-							@LanguageTag(language)
+		for repo := range utils.StreamArray(repos) {
+			@templ.Flush() {
+				<div
+					class="card w-full bg-base-200 hover:bg-base-300 cursor-pointer card-sm shadow-sm"
+					onclick={ templ.JSFuncCall("goToRepo", repo.URL) }
+					title={ repo.URL }
+				>
+					<div class="card-body">
+						<h2 class="card-title">{ repo.Owner + "/"+ repo.Name }</h2>
+						if repo.Description != "" {
+							<p>{ repo.Description }</p>
 						}
+						<div class="justify-left card-actions">
+							for _, language := range repo.Languages {
+								@LanguageTag(language)
+							}
+						</div>
 					</div>
 				</div>
-			</div>
+			}
 		}
 	</div>
 }

internal/pkg/routes/site/views/root.templ

···
 		<head>
 			<title>Samuel Boyden</title>
 			<link href="/static/css/styles.css" rel="stylesheet"/>
-			<script src="/static/js/htmx.min.js"></script>
+			<script src="/static/js/htmx.min.js" defer></script>
 			<script src="/static/js/alpinejs.min.js" defer></script>
 			<meta name="viewport" content="width=device-width, initial-scale=1.0"/>
 		</head>

migrations/0004_add_default_value_for_auth_id.down.sql

···
+ALTER TABLE "authorisations"
+ALTER COLUMN "id"
+SET DEFAULT uuid_generate_v4 ();

migrations/0005_install_uuid_extension.down.sql

···
+DROP EXTENSION IF NOT EXISTS "uuid-ossp";

migrations/0005_install_uuid_extension.up.sql

···
+CREATE EXTENSION IF NOT EXISTS "uuid-ossp";

migrations/0006_add_published_field.down.sql

···
+ALTER TABLE "posts"
+DROP COLUMN "published";

migrations/0006_add_published_field.up.sql

···
+-- alter posts table to have published field.
+ALTER TABLE "posts"
+ADD COLUMN "published" BOOLEAN;
+
+-- set all published column values to false
+UPDATE "posts"
+SET
+    "published" = 'f';
+
+-- require all published fields to be non-null (should be ensured by above)
+ALTER TABLE "posts"
+ALTER COLUMN "published"
+SET
+    NOT NULL;
+
+-- set default value for future posts to be FALSE
+ALTER TABLE "posts"
+ALTER COLUMN "published"
+SET DEFAULT FALSE;

queries/auth.sql

···
 -- name: GetExpiredAuths :many
 SELECT * FROM "authorisations" WHERE "expiry" <= current_timestamp;
 
+-- name: GetAuthByToken :one
+SELECT * FROM "authorisations" WHERE "id" = @id::uuid LIMIT 1;
+
 -- name: CheckAuthExists :one
 SELECT EXISTS (SELECT * FROM "authorisations" WHERE "id" = @id::uuid);
 

queries/posts.sql

···
 -- name: CreatePost :one
-INSERT INTO "posts" (slug, content) 
+INSERT INTO "posts" (slug, content)
 VALUES (@slug::text, @content::json)
 RETURNING *;
 
--- name: GetPosts :many
-SELECT * FROM "posts";
+-- name: GetPublishedPosts :many
+SELECT * FROM "posts" WHERE published = TRUE;
+
+-- name: GetPostByID :one
+SELECT * FROM "posts" WHERE id = @id::uuid LIMIT 1;
+
+-- name: GetAllPosts :many
+SELECT * FROM "posts";