Feat: Optimistic writes

packages/frontpage/app/(app)/_components/post-card.tsx

@@ -1,10 +1,9 @@
 import Link from "next/link";
-import { createVote, deleteVote } from "@/lib/data/atproto/vote";
 import { getVoteForPost } from "@/lib/data/db/vote";
 import { ensureUser, getUser } from "@/lib/data/user";
 import { TimeAgo } from "@/lib/components/time-ago";
 import { VoteButton } from "./vote-button";
-import { PostCollection, deletePost } from "@/lib/data/atproto/post";
+import { PostCollection } from "@/lib/data/atproto/post";
 import { getVerifiedHandle } from "@/lib/data/atproto/identity";
 import { UserHoverCard } from "@/lib/components/user-hover-card";
 import type { DID } from "@/lib/data/atproto/did";
@@ -15,6 +14,8 @@ import { revalidatePath } from "next/cache";
 import { ReportDialogDropdownButton } from "./report-dialog";
 import { DeleteButton } from "./delete-button";
 import { ShareDropdownButton } from "./share-button";
+import { createVote, deleteVote } from "@/lib/api/vote";
+import { deletePost } from "@/lib/api/post";
 
 type PostProps = {
   id: number;
@@ -54,24 +55,27 @@ export async function PostCard({
         <VoteButton
           voteAction={async () => {
             "use server";
-            await ensureUser();
+            const user = await ensureUser();
             await createVote({
-              subjectAuthorDid: author,
-              subjectCid: cid,
-              subjectRkey: rkey,
-              subjectCollection: PostCollection,
+              authorDid: user.did,
+              subject: {
+                rkey,
+                cid,
+                authorDid: author,
+                collection: PostCollection,
+              },
             });
           }}
           unvoteAction={async () => {
             "use server";
-            await ensureUser();
+            const user = await ensureUser();
             const vote = await getVoteForPost(id);
             if (!vote) {
               // TODO: Show error notification
               console.error("Vote not found for post", id);
               return;
             }
-            await deleteVote(vote.rkey);
+            await deleteVote({ authorDid: user.did, rkey: vote.rkey });
           }}
           initialState={
             (await getUser())?.did === author
@@ -130,6 +134,7 @@ export async function PostCard({
                     author,
                   })}
                 />
+                {/* TODO: there's a bug here where delete shows on deleted posts */}
                 {user?.did === author ? (
                   <DeleteButton
                     deleteAction={deletePostAction.bind(null, rkey)}
@@ -146,8 +151,8 @@ export async function PostCard({
 
 export async function deletePostAction(rkey: string) {
   "use server";
-  await ensureUser();
-  await deletePost(rkey);
+  const user = await ensureUser();
+  await deletePost({ authorDid: user.did, rkey });
 
   revalidatePath("/");
 }

packages/frontpage/app/(app)/post/[postAuthor]/[postRkey]/_lib/actions.tsx

@@ -1,19 +1,16 @@
 "use server";
 
-import {
-  CommentCollection,
-  createComment,
-  deleteComment,
-} from "@/lib/data/atproto/comment";
+import { CommentCollection } from "@/lib/data/atproto/comment";
 import { DID } from "@/lib/data/atproto/did";
-import { createVote, deleteVote } from "@/lib/data/atproto/vote";
-import { getComment, uncached_doesCommentExist } from "@/lib/data/db/comment";
+import { getComment } from "@/lib/data/db/comment";
 import { getPost } from "@/lib/data/db/post";
 import { parseReportForm } from "@/lib/data/db/report-shared";
 import { createReport } from "@/lib/data/db/report";
 import { getVoteForComment } from "@/lib/data/db/vote";
 import { ensureUser } from "@/lib/data/user";
 import { revalidatePath } from "next/cache";
+import { createComment, deleteComment } from "@/lib/api/comment";
+import { createVote, deleteVote } from "@/lib/api/vote";
 
 export async function createCommentAction(
   input: { parentRkey?: string; postRkey: string; postAuthorDid: DID },
@@ -41,32 +38,19 @@ export async function createCommentAction(
     throw new Error(`[naughty] Cannot comment on deleted post. ${user.did}`);
   }
 
-  const { rkey } = await createComment({
-    content,
-    post,
+  await createComment({
     parent: comment,
+    post,
+    content,
+    authorDid: user.did,
   });
-  await waitForComment(rkey);
-  revalidatePath(`/post`);
-}
 
-const MAX_POLLS = 15;
-async function waitForComment(rkey: string) {
-  let exists = false;
-  let polls = 0;
-  while (!exists && polls < MAX_POLLS) {
-    exists = await uncached_doesCommentExist(rkey);
-    await new Promise((resolve) => setTimeout(resolve, 250));
-    polls++;
-  }
-  if (!exists) {
-    throw new Error(`Comment not found after polling: ${rkey}`);
-  }
+  revalidatePath(`/post`);
 }
 
 export async function deleteCommentAction(rkey: string) {
-  await ensureUser();
-  await deleteComment(rkey);
+  const user = await ensureUser();
+  await deleteComment({ rkey, authorDid: user.did });
   revalidatePath("/post");
 }
 
@@ -99,22 +83,25 @@ export async function commentVoteAction(input: {
   rkey: string;
   authorDid: DID;
 }) {
-  await ensureUser();
+  const user = await ensureUser();
   await createVote({
-    subjectAuthorDid: input.authorDid,
-    subjectCid: input.cid,
-    subjectRkey: input.rkey,
-    subjectCollection: CommentCollection,
+    authorDid: user.did,
+    subject: {
+      rkey: input.rkey,
+      cid: input.cid,
+      authorDid: input.authorDid,
+      collection: CommentCollection,
+    },
   });
 }
 
 export async function commentUnvoteAction(commentId: number) {
-  await ensureUser();
-  const vote = await getVoteForComment(commentId);
+  const user = await ensureUser();
+  const vote = await getVoteForComment(commentId, user.did);
   if (!vote) {
     console.error("Vote not found for comment", commentId);
     return;
   }
 
-  await deleteVote(vote.rkey);
+  await deleteVote({ authorDid: user.did, rkey: vote.rkey });
 }

packages/frontpage/app/(app)/post/new/_action.ts

@@ -1,9 +1,7 @@
 "use server";
 
-import { DID } from "@/lib/data/atproto/did";
+import { createPost } from "@/lib/api/post";
 import { getVerifiedHandle } from "@/lib/data/atproto/identity";
-import { createPost } from "@/lib/data/atproto/post";
-import { uncached_doesPostExist } from "@/lib/data/db/post";
 import { DataLayerError } from "@/lib/data/error";
 import { ensureUser } from "@/lib/data/user";
 import { redirect } from "next/navigation";
@@ -27,25 +25,14 @@ export async function newPostAction(_prevState: unknown, formData: FormData) {
   }
 
   try {
-    const { rkey } = await createPost({ title, url });
-    const [handle] = await Promise.all([
+    const [{ rkey }, handle] = await Promise.all([
+      createPost({ authorDid: user.did, title, url }),
       getVerifiedHandle(user.did),
-      waitForPost(user.did, rkey),
     ]);
+
     redirect(`/post/${handle}/${rkey}`);
   } catch (error) {
     if (!(error instanceof DataLayerError)) throw error;
     return { error: "Failed to create post" };
   }
 }
-
-const MAX_POLLS = 10;
-async function waitForPost(authorDid: DID, rkey: string) {
-  let exists = false;
-  let polls = 0;
-  while (!exists && polls < MAX_POLLS) {
-    exists = await uncached_doesPostExist(authorDid, rkey);
-    await new Promise((resolve) => setTimeout(resolve, 250));
-    polls++;
-  }
-}