Add micro blog section with D1 storage and social syndication

bunfig.toml

@@ -16,4 +16,10 @@ minimumReleaseAgeExcludes = [
   "@astrojs/rss",
   "@astrojs/sitemap",
   "@astrojs/underscore-redirects",
+  "workerd",
+  "@cloudflare/workerd-darwin-arm64",
+  "@cloudflare/workerd-darwin-64",
+  "@cloudflare/workerd-linux-arm64",
+  "@cloudflare/workerd-linux-64",
+  "@cloudflare/workerd-windows-64",
 ]

migrations/0001_create_micro_posts.sql

@@ -0,0 +1,7 @@
+CREATE TABLE IF NOT EXISTS micro_posts (
+  id INTEGER PRIMARY KEY AUTOINCREMENT,
+  content TEXT NOT NULL,
+  created_at TEXT NOT NULL DEFAULT (strftime('%Y-%m-%dT%H:%M:%S.000Z', 'now')),
+  updated_at TEXT NOT NULL DEFAULT (strftime('%Y-%m-%dT%H:%M:%S.000Z', 'now')),
+  syndicated_to TEXT NOT NULL DEFAULT '[]'
+);

mise.toml

@@ -81,6 +81,11 @@ description = "Deploy wildcard subdomain service"
 run = "uv run --with openai-whisper python scripts/transcribe.py"
 description = "Generate word-level transcript from audio/video"
 
+[tasks.micro]
+run = "bun packages/micro/index.ts"
+description = "Micro blog CLI (list posts, create, or delete)"
+raw = true
+
 [tasks."changelog:entry"]
 run = "bun scripts/changelog-entry.ts"
 description = "Generate changelog entry for a PR"
@@ -92,3 +97,4 @@ description = "Assemble changelog fragments into CHANGELOG.md"
 [tasks."release-notes"]
 run = "bun scripts/release-notes.ts"
 description = "Preview release notes for a package version"
+

package.json

@@ -34,22 +34,27 @@
     "@astrojs/mdx": "5.0.3",
     "@astrojs/rss": "4.0.18",
     "@astrojs/sitemap": "3.7.2",
+    "@atproto/api": "^0.15.3",
     "@iconify-json/pixel": "^1.2.1",
     "@types/p5": "^1.7.6",
+    "@unocss/reset": "^66.6.0",
     "@webtui/css": "^0.1.5",
     "astro": "6.1.4",
     "beautiful-mermaid": "^1.0.0",
+    "js-yaml": "^4.1.1",
     "marked": "^17.0.1",
     "mdast-util-mdx-jsx": "^3.2.0",
     "p5": "^1.11.3",
     "remark-mdc": "^3.9.0",
     "sharp": "^0.34.3",
+    "twitter-api-v2": "^1.17.3",
     "typescript": "^6.0.2",
     "unist-util-visit": "^5.0.0",
     "zod": "^4.1.13"
   },
   "devDependencies": {
     "@types/bun": "^1.3.6",
+    "@types/js-yaml": "^4.0.9",
     "@unocss/astro": "66.6.0",
     "@unocss/preset-icons": "66.6.0",
     "oxfmt": "^0.43.0",

packages/micro/index.ts

@@ -0,0 +1,61 @@
+#!/usr/bin/env bun
+
+import { deletePost, list } from "./src/browse.ts";
+import { post } from "./src/post.ts";
+
+const PRODUCTION_URL = "https://just-be.dev";
+const WORKER_NAME = "just-be-dev";
+const WORKERS_DEV_SUBDOMAIN = "just-be";
+
+function siteUrlFromBranch(branch: string | undefined): string {
+  if (!branch || branch === "main") return PRODUCTION_URL;
+  const sanitized = branch
+    .toLowerCase()
+    .replace(/[^a-z0-9-]+/g, "-")
+    .replace(/^-+|-+$/g, "");
+  return `https://${sanitized}-${WORKER_NAME}.${WORKERS_DEV_SUBDOMAIN}.workers.dev`;
+}
+
+const rawArgs = process.argv.slice(2);
+let branch: string | undefined;
+const args: string[] = [];
+
+for (let i = 0; i < rawArgs.length; i++) {
+  if ((rawArgs[i] === "--branch" || rawArgs[i] === "-b") && i + 1 < rawArgs.length) {
+    branch = rawArgs[++i];
+  } else {
+    args.push(rawArgs[i]);
+  }
+}
+
+const command = args[0];
+const siteUrl = siteUrlFromBranch(branch);
+
+async function main() {
+  if (!command || command === "list") {
+    await list(siteUrl);
+  } else if (command === "post") {
+    await post(args[1], siteUrl);
+  } else if (command === "delete") {
+    const id = Number(args[1]);
+    if (!args[1] || !Number.isFinite(id)) {
+      console.error("Usage: micro delete <id>");
+      process.exit(1);
+    }
+    await deletePost(id, siteUrl);
+  } else {
+    console.error(`Unknown command: ${command}`);
+    console.log("Usage:");
+    console.log("  micro [list] [--branch <name>]              - List all posts");
+    console.log(
+      '  micro post [--branch <name>] ["text"]       - Create a post (reads stdin if no text)',
+    );
+    console.log("  micro delete [--branch <name>] <id>         - Delete a post");
+    process.exit(1);
+  }
+}
+
+main().catch((error) => {
+  console.error("Error:", error.message);
+  process.exit(1);
+});

packages/micro/package.json

@@ -0,0 +1,33 @@
+{
+  "name": "@just-be/micro",
+  "version": "0.1.0",
+  "description": "CLI tool for creating and managing micro blog posts",
+  "keywords": [
+    "cli",
+    "microblog"
+  ],
+  "license": "MIT",
+  "author": "Justin Bennett",
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/just-be-dev/just-be.dev.git",
+    "directory": "packages/micro"
+  },
+  "bin": {
+    "micro": "index.ts"
+  },
+  "files": [
+    "index.ts",
+    "src"
+  ],
+  "type": "module",
+  "exports": {
+    ".": "./index.ts"
+  },
+  "publishConfig": {
+    "access": "public"
+  },
+  "engines": {
+    "bun": ">=1.0.0"
+  }
+}

packages/micro/src/browse.ts

@@ -0,0 +1,56 @@
+interface Post {
+  id: number;
+  content: string;
+  createdAt: string;
+  syndicatedTo: Array<{ platform: string; id: string; url: string }>;
+}
+
+function getSecret(): string {
+  const secret = process.env.MICRO_SECRET;
+  if (!secret) {
+    console.error("Error: MICRO_SECRET environment variable not set");
+    process.exit(1);
+  }
+  return secret;
+}
+
+export async function list(siteUrl: string) {
+  const secret = getSecret();
+
+  const res = await fetch(`${siteUrl}/micro`, {
+    headers: {
+      Authorization: `Bearer ${secret}`,
+      Accept: "application/json",
+    },
+  });
+
+  if (!res.ok) throw new Error(`${res.status}: ${await res.text()}`);
+
+  const posts = (await res.json()) as Post[];
+
+  if (posts.length === 0) {
+    console.log("no posts yet");
+    return;
+  }
+
+  for (const post of posts) {
+    const date = new Date(post.createdAt).toLocaleDateString();
+    console.log(`[${post.id}] ${date}  ${post.content}`);
+    if (post.syndicatedTo.length > 0) {
+      console.log(`       syndicated: ${post.syndicatedTo.map((s) => s.platform).join(", ")}`);
+    }
+  }
+}
+
+export async function deletePost(id: number, siteUrl: string) {
+  const secret = getSecret();
+
+  const res = await fetch(`${siteUrl}/micro/${id}`, {
+    method: "DELETE",
+    headers: { Authorization: `Bearer ${secret}` },
+  });
+
+  if (!res.ok) throw new Error(`${res.status}: ${await res.text()}`);
+
+  console.log(`deleted #${id}`);
+}

packages/micro/src/post.ts

@@ -0,0 +1,62 @@
+const MAX_LENGTH = 280;
+
+function getSecret(): string {
+  const secret = process.env.MICRO_SECRET;
+  if (!secret) {
+    console.error("Error: MICRO_SECRET environment variable not set");
+    process.exit(1);
+  }
+  return secret;
+}
+
+export async function post(content: string | undefined, siteUrl: string) {
+  let postContent = content;
+
+  if (!postContent) {
+    const chunks: Buffer[] = [];
+    for await (const chunk of process.stdin) {
+      chunks.push(chunk as Buffer);
+    }
+    postContent = Buffer.concat(chunks).toString("utf8").trim();
+  }
+
+  if (!postContent) {
+    console.error("Error: no content provided (pass as argument or pipe via stdin)");
+    process.exit(1);
+  }
+
+  if (postContent.length > MAX_LENGTH) {
+    console.error(`Error: too long (${postContent.length}/${MAX_LENGTH} characters)`);
+    process.exit(1);
+  }
+
+  const secret = getSecret();
+
+  const res = await fetch(`${siteUrl}/micro`, {
+    method: "POST",
+    headers: {
+      "Content-Type": "application/json",
+      Authorization: `Bearer ${secret}`,
+    },
+    body: JSON.stringify({ content: postContent }),
+  });
+
+  if (!res.ok) {
+    throw new Error(`${res.status}: ${await res.text()}`);
+  }
+
+  const { post: newPost, syndication } = (await res.json()) as {
+    post: { id: number; content: string; createdAt: string };
+    syndication: Array<{ platform: string; success: boolean; url?: string; error?: string }>;
+  };
+
+  console.log(`posted #${newPost.id}`);
+
+  for (const s of syndication) {
+    if (s.success) {
+      console.log(`  ${s.platform}: ${s.url}`);
+    } else {
+      console.error(`  ${s.platform}: ${s.error}`);
+    }
+  }
+}

scripts/gen-codes.ts

@@ -22,6 +22,8 @@ function inferKind(dir: string): Kind {
       return "P";
     case "talks":
       return "T";
+    case "micro":
+      return "M";
     default:
       throw new Error(`Unknown content directory: ${dir}`);
   }