Merge pull request #73 from fedify-dev/feat/obj-api

Create `Object` API (`Note`/`Article` only for now)

Author: sij411

.gitignore

@@ -6,6 +6,7 @@ __generated__/
 
 .pgdata/
 
+mise.local.toml
 node_modules/
 packages/*/dist/
 

.oxlintrc.json

@@ -33,7 +33,7 @@
     "eslint/max-lines": "off",
     "eslint/id-length": ["warn", { "exceptionPatterns": ["^_", "^[Tertv]$"] }],
     "eslint/init-declarations": "off",
-    "eslint/max-params": ["warn", { "max": 4 }],
+    "eslint/max-params": "off",
     "eslint/max-statements": ["warn", { "max": 20 }],
     "eslint/no-console": "warn",
     "eslint/no-use-before-define": "off",

AI_POLICY.md

@@ -102,6 +102,7 @@ Assisted-by: OpenCode:qwen3.6-plus
 Assisted-by: Claude Code:claude-sonnet-5
 Assisted-by: Antigravity:gemini-3.7-flash
 Assisted-by: Codex:gpt-5.6-sol
+Assisted-by: Codex:gpt-6-astra
 ~~~~
 
 If multiple AI tools were used, include one `Assisted-by` line per tool.

CONTRIBUTING.md

@@ -237,6 +237,16 @@ Use existing dependencies and patterns before adding new ones.  In particular:
 Formatting is handled by [Oxfmt] and [Hongdown].  Do not hand-align code in a
 way that fights those tools.
 
+When you leave a `FIXME` comment, open a GitHub issue that describes the
+problem and the intended change, and put only the issue URL in the comment:
+
+~~~~ ts
+// FIXME: https://github.com/fedify-dev/drfed/issues/35
+~~~~
+
+Keep the details in the issue rather than in the comment, and update the issue
+when the plan changes.
+
 [Optique]: https://optique.dev/
 [srvx]: https://srvx.h3.dev/
 [Drizzle ORM]: https://orm.drizzle.team/

packages/drfed/src/seed.ts

@@ -26,7 +26,7 @@ const sessionId = "00000000-0000-4000-8000-000000000000";
 const accountId = "00000000-0000-4000-8000-000000000001";
 const memberId = "00000000-0000-4000-8000-000000000002";
 const pendingMemberId = "00000000-0000-4000-8000-000000000003";
-const created = new Date("2026-06-24T00:00:00.000Z");
+const created = Temporal.Instant.from("2026-06-24T00:00:00.000Z");
 const tokenHash = "dev-token-hash";
 
 async function seedAccounts(db: Database): Promise<void> {

packages/drfed/src/serving.test.ts

@@ -22,13 +22,12 @@ import {
   warnAboutStrandedInstances,
 } from "@drfed/drfed/serving";
 import { migrate, relations, schema } from "@drfed/models";
-import { uuidV7 } from "@drfed/models/uuid";
+import { uuidV7 as uuid } from "@drfed/models/uuid";
 import { PGlite } from "@electric-sql/pglite";
 import { describe, it } from "@logtape/testing-node/autoload";
 import { drizzle } from "drizzle-orm/pglite";
 
 const rootOrigin = new URL("https://drfed.net");
-const dayInMilliseconds = 86_400_000;
 
 /**
  * A stand-in for the request object a server adapter hands the handler, whose
@@ -204,10 +203,10 @@ describe("findStrandedInstances()", () => {
         // the stored host is consulted.
         { host: "999.1.1.1", slug: "unparseable", local: true },
       ];
-      const expires = new Date(Date.now() + dayInMilliseconds);
+      const expires = Temporal.Now.instant().add({ hours: 24 });
       const seeded = rows.map(({ host, slug, local }) => ({
         host,
-        localId: local ? uuidV7() : null,
+        localId: local ? uuid() : null,
         slug,
       }));
       await db
@@ -220,7 +219,7 @@ describe("findStrandedInstances()", () => {
       await db
         .insert(schema.instances)
         .values(
-          seeded.map(({ host, localId }) => ({ id: uuidV7(), localId, host })),
+          seeded.map(({ host, localId }) => ({ id: uuid(), localId, host })),
         );
 
       const stranded = await findStrandedInstances(db, rootOrigin);

packages/graphql/package.json

@@ -58,6 +58,10 @@
       "types": "./dist/builder.d.mts",
       "default": "./dist/builder.mjs"
     },
+    "./classification": {
+      "types": "./dist/classification.d.mts",
+      "default": "./dist/classification.mjs"
+    },
     "./federation": {
       "types": "./dist/federation.d.mts",
       "default": "./dist/federation.mjs"
@@ -70,6 +74,10 @@
       "types": "./dist/schema.d.mts",
       "default": "./dist/schema.mjs"
     },
+    "./object": {
+      "types": "./dist/object.d.mts",
+      "default": "./dist/object.mjs"
+    },
     "./origin": {
       "types": "./dist/origin.d.mts",
       "default": "./dist/origin.mjs"
@@ -85,9 +93,11 @@
       "src/account.ts",
       "src/actor.ts",
       "src/builder.ts",
+      "src/classification.ts",
       "src/federation.ts",
       "src/instance.ts",
       "src/schema.ts",
+      "src/object.ts",
       "src/origin.ts"
     ],
     "dts": {

packages/graphql/src/account.test.ts

@@ -22,9 +22,9 @@ import { describe, it } from "@logtape/testing-node/autoload";
 
 import { withTestHarness } from "./harness.test.ts";
 
-const accepted = new Date("2026-06-24T00:00:00.000Z");
-const created = new Date("2026-06-24T00:00:00.000Z");
-const expires = new Date("2026-07-24T00:00:00.000Z");
+const accepted = Temporal.Instant.from("2026-06-24T00:00:00.000Z");
+const created = Temporal.Instant.from("2026-06-24T00:00:00.000Z");
+const expires = Temporal.Instant.from("2026-07-24T00:00:00.000Z");
 const ok = 200;
 
 const accountId = "00000000-0000-4000-8000-000000000001";
@@ -116,8 +116,8 @@ const accountInstancesResponse = {
         totalCount: 1,
         edges: [
           {
-            created: "2026-06-24T00:00:00.000Z",
-            accepted: "2026-06-24T00:00:00.000Z",
+            created: created.toString(),
+            accepted: accepted.toString(),
             admin: true,
             node: {
               uuid: acceptedInstanceId,
@@ -463,3 +463,54 @@ async function seedLocalInstances(db: Database): Promise<void> {
     },
   ]);
 }
+
+// Cursor requests depend on the preceding page.
+// oxlint-disable no-await-in-loop
+it("paginates both membership connections with identical microsecond timestamps", async () => {
+  await withTestHarness(async ({ db, post }) => {
+    await seedMembershipGraph(db);
+    await db.update(schema.instanceMembers).set({
+      accepted,
+      created: Temporal.Instant.from("2026-09-14T12:00:00.123456Z"),
+    });
+    const auth = await createSession(db);
+    for (const scenario of [
+      {
+        type: "Account",
+        id: accountId,
+        field: "instances",
+        ids: [pendingInstanceId, acceptedInstanceId],
+      },
+      {
+        type: "Instance",
+        id: acceptedInstanceId,
+        field: "members",
+        ids: [pendingMemberId, memberId, accountId],
+      },
+    ]) {
+      const seen: string[] = [];
+      let after: string | null = null;
+      for (const expected of scenario.ids) {
+        const response = await post(
+          {
+            query: `query($id: ID!, $after: String) { node(id: $id) { ... on ${scenario.type} { ${scenario.field}(first: 1, after: $after) { edges { cursor node { uuid } } pageInfo { hasNextPage } } } } }`,
+            variables: { id: btoa(`${scenario.type}:${scenario.id}`), after },
+          },
+          auth,
+        );
+        const body = await response.json();
+        assert.equal(body.errors, undefined);
+        const connection = body.data.node[scenario.field];
+        assert.equal(connection.edges.length, 1);
+        assert.equal(connection.edges[0].node.uuid, expected);
+        seen.push(connection.edges[0].node.uuid);
+        assert.equal(
+          connection.pageInfo.hasNextPage,
+          seen.length < scenario.ids.length,
+        );
+        after = connection.edges[0].cursor;
+      }
+      assert.deepEqual(seen, scenario.ids);
+    }
+  });
+});

packages/graphql/src/account.ts

@@ -90,16 +90,13 @@ const accountInstancesConnection = drizzleConnectionHelpers(
   "instanceMembers",
   {
     query: {
-      orderBy: { created: "desc" },
+      orderBy: { created: "desc", instanceId: "desc" },
     },
     select(nestedSelection) {
       return {
         with: {
           instance: nestedSelection(),
         },
-        where: {
-          accepted: { isNotNull: true },
-        },
       };
     },
     resolveNode(instanceMember) {
@@ -211,16 +208,13 @@ const instanceMembersConnection = drizzleConnectionHelpers(
   "instanceMembers",
   {
     query: {
-      orderBy: { created: "desc" },
+      orderBy: { created: "desc", accountId: "desc" },
     },
     select(nestedSelection) {
       return {
         with: {
           account: nestedSelection(),
         },
-        where: {
-          accepted: { isNotNull: true },
-        },
       };
     },
     resolveNode(instanceMember) {