refactor(micro): replace D1/Drizzle with R2 JSONL and HTTP API

Replace the D1 database and Drizzle ORM with a JSONL file stored in a
new R2 bucket named "micro". All R2 and syndication logic moves to the
Astro site; the micro CLI becomes a thin HTTP client.

- Create `micro` R2 bucket and bind as MICRO_BUCKET in wrangler.toml
- Add src/lib/micro-r2.ts: createMicroStorage(bucket) with read/write/
  add/update/delete using read-modify-write on micro-posts.jsonl
- Add src/lib/micro-syndicate.ts: syndication logic (moved from micro pkg)
- Add src/env.d.ts: typed Worker env for MICRO_BUCKET, MICRO_SECRET,
  and syndication credential bindings
- POST /micro (Authorization: Bearer): creates post + syndicates
- GET /micro (Authorization + Accept: application/json): returns JSON list
- DELETE /micro/:id (Authorization: Bearer): deletes post from R2
- Update micro-loader to use createMicroStorage + getPlatformProxy directly
- Slim micro CLI to HTTP fetch calls using MICRO_SECRET + MICRO_SITE_URL
- Remove drizzle-orm, drizzle-kit, wrangler, @atproto/api, twitter-api-v2
  from micro package; move atproto/twitter deps to root package.json
- Delete schema.ts, db.ts, drizzle.config.ts, migrations, syndicate.ts,
  loader-db.ts, r2.ts from micro package
- Remove micro:db:generate, micro:db:migrate, deploy:micro mise tasks

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: just-be-dev

bun.lock

@@ -93,17 +93,3 @@ description = "Preview release notes for a package version"
 run = "bun packages/micro/index.ts"
 description = "Micro blog CLI (browse posts or create new ones)"
 raw = true
-
-[tasks."micro:db:generate"]
-dir = "packages/micro"
-run = "bun run db:generate"
-description = "Generate drizzle migrations for micro blog"
-
-[tasks."micro:db:migrate"]
-dir = "packages/micro"
-run = "bun run db:migrate"
-description = "Apply drizzle migrations for micro blog"
-
-[tasks."deploy:micro"]
-run = "wrangler d1 migrations apply micro-blog --remote"
-description = "Apply D1 migrations to remote micro-blog database"

mise.toml

@@ -33,6 +33,7 @@
     "@astrojs/mdx": "5.0.0",
     "@astrojs/rss": "4.0.17",
     "@astrojs/sitemap": "3.7.1",
+    "@atproto/api": "^0.15.3",
     "@iconify-json/pixel": "^1.2.1",
     "@types/p5": "^1.7.6",
     "@unocss/reset": "^66.6.0",
@@ -45,6 +46,7 @@
     "p5": "^1.11.3",
     "remark-mdc": "^3.9.0",
     "sharp": "^0.34.3",
+    "twitter-api-v2": "^1.17.3",
     "unist-util-visit": "^5.0.0",
     "zod": "^4.1.13"
   },

package.json

@@ -19,28 +19,17 @@
   },
   "files": [
     "index.ts",
-    "src",
-    "db"
+    "src"
   ],
   "type": "module",
   "exports": {
-    ".": "./index.ts",
-    "./loader-db": "./src/loader-db.ts"
+    ".": "./index.ts"
   },
   "publishConfig": {
     "access": "public"
   },
-  "scripts": {
-    "db:generate": "drizzle-kit generate",
-    "db:migrate": "drizzle-kit migrate"
-  },
   "dependencies": {
-    "@atproto/api": "^0.15.3",
-    "@clack/prompts": "^0.11.0",
-    "drizzle-kit": "^0.31.9",
-    "drizzle-orm": "^0.45.1",
-    "twitter-api-v2": "^1.17.3",
-    "wrangler": "4.48.0"
+    "@clack/prompts": "^0.11.0"
   },
   "engines": {
     "bun": ">=1.0.0"

packages/micro/db/migrations/0000_red_mother_askani.sql

@@ -1,87 +1,102 @@
 import * as p from "@clack/prompts";
-import { desc, eq } from "drizzle-orm";
-import { getD1Database, microPosts } from "./db.ts";
 
-type Post = typeof microPosts.$inferSelect;
+interface Post {
+  id: number;
+  content: string;
+  createdAt: string;
+  updatedAt: string;
+  syndicatedTo: Array<{ platform: string; id: string; url: string }>;
+}
+
+const DEFAULT_SITE_URL = "https://just-be.dev";
+
+function getConfig() {
+  const secret = process.env.MICRO_SECRET;
+  if (!secret) {
+    console.error("Error: MICRO_SECRET environment variable not set");
+    process.exit(1);
+  }
+  return {
+    secret,
+    siteUrl: process.env.MICRO_SITE_URL ?? DEFAULT_SITE_URL,
+  };
+}
 
 export async function browse() {
   p.intro("Micro Blog Browser");
 
   const spinner = p.spinner();
   spinner.start("Loading posts...");
 
+  const { secret, siteUrl } = getConfig();
+
+  let posts: Post[];
   try {
-    const { db, dispose } = await getD1Database();
+    const res = await fetch(`${siteUrl}/micro`, {
+      headers: {
+        Authorization: `Bearer ${secret}`,
+        Accept: "application/json",
+      },
+    });
+    if (!res.ok) throw new Error(`Server returned ${res.status}`);
+    posts = (await res.json()) as Post[];
+  } catch (error) {
+    spinner.stop("Failed to load posts");
+    throw error;
+  }
 
-    // Fetch all posts, newest first
-    const posts = await db.select().from(microPosts).orderBy(desc(microPosts.createdAt));
+  spinner.stop(`Found ${posts.length} post(s)`);
 
-    spinner.stop(`Found ${posts.length} post(s)`);
+  if (posts.length === 0) {
+    p.note("No posts yet. Create one with 'micro post'", "Empty");
+    return;
+  }
 
-    if (posts.length === 0) {
-      p.note("No posts yet. Create one with 'micro post'", "Empty");
-      await dispose();
-      return;
+  let shouldContinue = true;
+
+  while (shouldContinue) {
+    const options = posts.map((post) => {
+      const preview =
+        post.content.length > 60 ? post.content.substring(0, 60) + "..." : post.content;
+      const date = new Date(post.createdAt).toLocaleDateString();
+      return {
+        value: post.id,
+        label: `[${post.id}] ${preview}`,
+        hint: date,
+      };
+    });
+
+    options.push({ value: -1, label: "Exit", hint: "" });
+
+    const selectedId = await p.select({
+      message: "Select a post to view options",
+      options,
+    });
+
+    if (p.isCancel(selectedId) || selectedId === -1) {
+      shouldContinue = false;
+      continue;
     }
 
-    // Show posts in a loop until user exits
-    let shouldContinue = true;
-
-    while (shouldContinue) {
-      const options = posts.map((post) => {
-        const preview =
-          post.content.length > 60 ? post.content.substring(0, 60) + "..." : post.content;
-        const date = post.createdAt.toLocaleDateString();
-        return {
-          value: post.id,
-          label: `[${post.id}] ${preview}`,
-          hint: date,
-        };
-      });
-
-      options.push({
-        value: -1,
-        label: "Exit",
-        hint: "",
-      });
-
-      const selectedId = await p.select({
-        message: "Select a post to view options",
-        options,
-      });
-
-      if (p.isCancel(selectedId) || selectedId === -1) {
-        shouldContinue = false;
-        continue;
-      }
-
-      const selectedPost = posts.find((p) => p.id === selectedId);
-      if (!selectedPost) continue;
-
-      // Show post details and actions
-      await showPostActions(db, selectedPost, posts);
-    }
+    const selectedPost = posts.find((p) => p.id === selectedId);
+    if (!selectedPost) continue;
 
-    await dispose();
-    p.outro("Goodbye!");
-  } catch (error) {
-    spinner.stop("Failed to load posts");
-    throw error;
+    await showPostActions({ siteUrl, secret }, selectedPost, posts);
   }
+
+  p.outro("Goodbye!");
 }
 
 async function showPostActions(
-  db: ReturnType<typeof getD1Database> extends Promise<{ db: infer D }> ? D : never,
+  config: { siteUrl: string; secret: string },
   post: Post,
   allPosts: Post[],
 ) {
-  const syndicatedData =
-    (post.syndicatedTo as Array<{ platform: string; id: string; url: string }> | null) || [];
-  const syndicatedPlatforms = syndicatedData.map((s) => s.platform);
+  const syndicatedPlatforms = post.syndicatedTo.map((s) => s.platform);
   const syndicatedText = syndicatedPlatforms.length > 0 ? syndicatedPlatforms.join(", ") : "None";
 
   p.note(
-    `${post.content}\n\nCreated: ${post.createdAt.toLocaleString()}\nSyndicated to: ${syndicatedText}`,
+    `${post.content}\n\nCreated: ${new Date(post.createdAt).toLocaleString()}\nSyndicated to: ${syndicatedText}`,
     `Post #${post.id}`,
   );
 
@@ -110,14 +125,13 @@ async function showPostActions(
 
   switch (action) {
     case "open-web": {
-      // Open in browser - construct URL based on post ID
-      const url = `https://just-be.dev/micro#post-${post.id}`;
+      const url = `${config.siteUrl}/micro#post-${post.id}`;
       console.log(`Opening: ${url}`);
       await Bun.spawn(["open", url]);
       break;
     }
     case "open-bluesky": {
-      const blueskyData = syndicatedData.find((s) => s.platform === "bluesky");
+      const blueskyData = post.syndicatedTo.find((s) => s.platform === "bluesky");
       if (!blueskyData) {
         p.note("This post hasn't been syndicated to Bluesky yet", "Not available");
         break;
@@ -127,7 +141,7 @@ async function showPostActions(
       break;
     }
     case "open-twitter": {
-      const twitterData = syndicatedData.find((s) => s.platform === "twitter");
+      const twitterData = post.syndicatedTo.find((s) => s.platform === "twitter");
       if (!twitterData) {
         p.note("This post hasn't been syndicated to Twitter yet", "Not available");
         break;
@@ -150,13 +164,19 @@ async function showPostActions(
       const spinner = p.spinner();
       spinner.start("Deleting post...");
 
-      await db.delete(microPosts).where(eq(microPosts.id, post.id));
+      const res = await fetch(`${config.siteUrl}/micro/${post.id}`, {
+        method: "DELETE",
+        headers: { Authorization: `Bearer ${config.secret}` },
+      });
+
+      if (!res.ok) {
+        spinner.stop("Delete failed");
+        p.log.warn(`Server returned ${res.status}`);
+        break;
+      }
 
-      // Remove from the posts array
       const index = allPosts.findIndex((p) => p.id === post.id);
-      if (index > -1) {
-        allPosts.splice(index, 1);
-      }
+      if (index > -1) allPosts.splice(index, 1);
 
       spinner.stop(`Post #${post.id} deleted successfully`);
       break;