Monorepo for Tangled
Something went wrong. Try again.
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221package main
import ( "context" "fmt" "io" "io/fs" "log/slog" "net/http" "os" "path/filepath"
"tangled.org/core/appview/config" "tangled.org/core/appview/pages" "tangled.org/core/blog" "tangled.org/core/idresolver" tlog "tangled.org/core/log")
const ( postsDir = "blog/posts" templatesDir = "blog/templates")
func main() { if len(os.Args) < 2 { fmt.Fprintln(os.Stderr, "usage: blog <build|serve> [flags]") os.Exit(1) }
ctx := context.Background() logger := tlog.New("blog")
switch os.Args[1] { case "build": if err := runBuild(ctx, logger); err != nil { logger.Error("build failed", "err", err) os.Exit(1) } case "serve": addr := "0.0.0.0:3001" if len(os.Args) >= 3 { addr = os.Args[2] } if err := runServe(ctx, logger, addr); err != nil { logger.Error("serve failed", "err", err) os.Exit(1) } default: fmt.Fprintf(os.Stderr, "unknown subcommand: %s\n", os.Args[1]) os.Exit(1) }}
func makePages(ctx context.Context, cfg *config.Config, logger *slog.Logger) (*pages.Pages, error) { resolver := idresolver.DefaultResolver(cfg.Plc.PLCURL) return pages.NewPages(cfg, resolver, nil, nil, logger), nil}
func runBuild(ctx context.Context, logger *slog.Logger) error { cfg, err := config.LoadConfig(ctx) if err != nil { return fmt.Errorf("failed to load config: %w", err) }
p, err := makePages(ctx, cfg, logger) if err != nil { return fmt.Errorf("creating pages: %w", err) }
posts, err := blog.Posts(postsDir) if err != nil { return fmt.Errorf("parsing posts: %w", err) }
outDir := "build" if err := os.MkdirAll(outDir, 0755); err != nil { return err }
// index if err := renderToFile(outDir, "index.html", func(w io.Writer) error { return blog.RenderIndex(p, templatesDir, posts, w) }); err != nil { return fmt.Errorf("rendering index: %w", err) }
for _, post := range posts { postDir := filepath.Join(outDir, post.Meta.Slug) if err := os.MkdirAll(postDir, 0755); err != nil { return err } if err := renderToFile(postDir, "index.html", func(w io.Writer) error { return blog.RenderPost(p, templatesDir, post, w) }); err != nil { return fmt.Errorf("rendering post %s: %w", post.Meta.Slug, err) } }
// atom feed baseURL := "https://blog.tangled.org" atom, err := blog.AtomFeed(posts, baseURL) if err != nil { return fmt.Errorf("generating atom feed: %w", err) } if err := os.WriteFile(filepath.Join(outDir, "feed.xml"), []byte(atom), 0644); err != nil { return fmt.Errorf("writing feed: %w", err) }
// copy embedded static assets into build/static/ so Cloudflare Pages // can serve them from the same origin as the built HTML staticSrc, err := fs.Sub(pages.Files, "static") if err != nil { return fmt.Errorf("accessing embedded static dir: %w", err) } if err := copyFS(staticSrc, filepath.Join(outDir, "static")); err != nil { return fmt.Errorf("copying static assets: %w", err) }
logger.Info("build complete", "dir", outDir) return nil}
// copyFS copies all files from src into destDir, preserving directory structure.func copyFS(src fs.FS, destDir string) error { return fs.WalkDir(src, ".", func(path string, d fs.DirEntry, err error) error { if err != nil { return err } dest := filepath.Join(destDir, path) if d.IsDir() { return os.MkdirAll(dest, 0755) } data, err := fs.ReadFile(src, path) if err != nil { return err } return os.WriteFile(dest, data, 0644) })}
func runServe(ctx context.Context, logger *slog.Logger, addr string) error { cfg, err := config.LoadConfig(ctx) if err != nil { return fmt.Errorf("failed to load config: %w", err) }
p, err := makePages(ctx, cfg, logger) if err != nil { return fmt.Errorf("creating pages: %w", err) }
mux := http.NewServeMux()
// index mux.HandleFunc("GET /", func(w http.ResponseWriter, r *http.Request) { if r.URL.Path != "/" { http.NotFound(w, r) return } posts, err := blog.AllPosts(postsDir) if err != nil { http.Error(w, err.Error(), http.StatusInternalServerError) return } if err := blog.RenderIndex(p, templatesDir, posts, w); err != nil { logger.Error("render index", "err", err) } })
// individual posts directly at /<slug> mux.HandleFunc("GET /{slug}", func(w http.ResponseWriter, r *http.Request) { slug := r.PathValue("slug") posts, err := blog.AllPosts(postsDir) if err != nil { http.Error(w, err.Error(), http.StatusInternalServerError) return } for _, post := range posts { if post.Meta.Slug == slug { if err := blog.RenderPost(p, templatesDir, post, w); err != nil { logger.Error("render post", "err", err) } return } } http.NotFound(w, r) })
// atom feed at /feed.xml mux.HandleFunc("GET /feed.xml", func(w http.ResponseWriter, r *http.Request) { posts, err := blog.Posts(postsDir) if err != nil { http.Error(w, err.Error(), http.StatusInternalServerError) return } atom, err := blog.AtomFeed(posts, "https://blog.tangled.org") if err != nil { http.Error(w, err.Error(), http.StatusInternalServerError) return } w.Header().Set("Content-Type", "application/atom+xml") fmt.Fprint(w, atom) })
// appview static files (tw.css, fonts, icons, logos) mux.Handle("GET /static/", p.Static())
logger.Info("serving", "addr", addr) return http.ListenAndServe(addr, mux)}
func renderToFile(dir, name string, fn func(io.Writer) error) error { f, err := os.Create(filepath.Join(dir, name)) if err != nil { return err } defer f.Close() return fn(f)}