Apply necessary reviews

Author: 2chanhaeng

examples/nuxt/server/api/events.get.ts

@@ -1,7 +1,7 @@
 import { setResponseHeader } from "h3";
 import { addClient, removeClient } from "../sse";
 
-export default defineEventHandler(async (event) => {
+export default defineEventHandler((event) => {
   setResponseHeader(event, "Content-Type", "text/event-stream");
   setResponseHeader(event, "Cache-Control", "no-cache");
   setResponseHeader(event, "Connection", "keep-alive");

examples/nuxt/server/api/post.post.ts

@@ -1,7 +1,12 @@
 import { Create, Note } from "@fedify/vocab";
-import { readBody, sendRedirect, toWebRequest } from "h3";
-import federation from "../federation";
-import { postStore } from "../store";
+import {
+  defineEventHandler,
+  readBody,
+  sendRedirect,
+  toWebRequest,
+} from "@nuxt/nitro-server/h3";
+import federation from "../federation.ts";
+import { postStore } from "../store.ts";
 
 export default defineEventHandler(async (event) => {
   const body = await readBody(event);
@@ -29,7 +34,7 @@ export default defineEventHandler(async (event) => {
       { identifier },
       "followers",
       new Create({
-        id: new URL("#activity", attribution),
+        id: new URL(`#create/${id}`, attribution),
         object: note,
         actors: note?.attributionIds,
         tos: note?.toIds,

examples/nuxt/server/federation.ts

@@ -15,8 +15,8 @@ import {
   type Recipient,
   Undo,
 } from "@fedify/vocab";
-import { broadcastEvent } from "./sse";
-import { keyPairsStore, postStore, relationStore } from "./store";
+import { broadcastEvent } from "./sse.ts";
+import { keyPairsStore, postStore, relationStore } from "./store.ts";
 
 const federation = createFederation<void>({
   kv: new MemoryKvStore(),
@@ -96,18 +96,15 @@ federation
   })
   .on(Undo, async (context, undo) => {
     const activity = await undo.getObject(context);
-    if (activity instanceof Follow) {
-      if (activity.id == null) {
-        return;
-      }
-      if (undo.actorId == null) {
-        return;
-      }
-      relationStore.delete(undo.actorId.href);
-      broadcastEvent();
-    } else {
+    if (!(activity instanceof Follow)) {
       console.debug(undo);
+      return;
     }
+    if (activity.id == null || undo.actorId == null) return;
+    const demoActorUri = context.getActorUri(IDENTIFIER);
+    if (activity.objectId?.href !== demoActorUri.href) return;
+    relationStore.delete(undo.actorId.href);
+    broadcastEvent();
   });
 
 federation.setObjectDispatcher(