feat: add getFollowers and getFollows endpoints with corresponding lexicons and types; update xrpc routes to handle requests

__generated__/index.ts

···
 import * as SocialGrainGalleryGetGalleryThread from './types/social/grain/gallery/getGalleryThread.ts'
 import * as SocialGrainGalleryGetActorGalleries from './types/social/grain/gallery/getActorGalleries.ts'
 import * as SocialGrainGalleryGetGallery from './types/social/grain/gallery/getGallery.ts'
+import * as SocialGrainGraphGetFollowers from './types/social/grain/graph/getFollowers.ts'
+import * as SocialGrainGraphGetFollows from './types/social/grain/graph/getFollows.ts'
 import * as SocialGrainFeedGetTimeline from './types/social/grain/feed/getTimeline.ts'
 import * as SocialGrainActorGetProfile from './types/social/grain/actor/getProfile.ts'
 import * as SocialGrainActorSearchActors from './types/social/grain/actor/searchActors.ts'
···
 
   constructor(server: Server) {
     this._server = server
+  }
+
+  getFollowers<AV extends AuthVerifier>(
+    cfg: ConfigOf<
+      AV,
+      SocialGrainGraphGetFollowers.Handler<ExtractAuth<AV>>,
+      SocialGrainGraphGetFollowers.HandlerReqCtx<ExtractAuth<AV>>
+    >,
+  ) {
+    const nsid = 'social.grain.graph.getFollowers' // @ts-ignore
+    return this._server.xrpc.method(nsid, cfg)
+  }
+
+  getFollows<AV extends AuthVerifier>(
+    cfg: ConfigOf<
+      AV,
+      SocialGrainGraphGetFollows.Handler<ExtractAuth<AV>>,
+      SocialGrainGraphGetFollows.HandlerReqCtx<ExtractAuth<AV>>
+    >,
+  ) {
+    const nsid = 'social.grain.graph.getFollows' // @ts-ignore
+    return this._server.xrpc.method(nsid, cfg)
   }
 }
 

__generated__/lexicons.ts

···
       },
     },
   },
+  SocialGrainGraphGetFollowers: {
+    lexicon: 1,
+    id: 'social.grain.graph.getFollowers',
+    defs: {
+      main: {
+        type: 'query',
+        description:
+          'Enumerates accounts which follow a specified account (actor).',
+        parameters: {
+          type: 'params',
+          required: ['actor'],
+          properties: {
+            actor: {
+              type: 'string',
+              format: 'at-identifier',
+            },
+            limit: {
+              type: 'integer',
+              minimum: 1,
+              maximum: 100,
+              default: 50,
+            },
+            cursor: {
+              type: 'string',
+            },
+          },
+        },
+        output: {
+          encoding: 'application/json',
+          schema: {
+            type: 'object',
+            required: ['subject', 'followers'],
+            properties: {
+              subject: {
+                type: 'ref',
+                ref: 'lex:social.grain.actor.defs#profileView',
+              },
+              cursor: {
+                type: 'string',
+              },
+              followers: {
+                type: 'array',
+                items: {
+                  type: 'ref',
+                  ref: 'lex:social.grain.actor.defs#profileView',
+                },
+              },
+            },
+          },
+        },
+      },
+    },
+  },
+  SocialGrainGraphGetFollows: {
+    lexicon: 1,
+    id: 'social.grain.graph.getFollows',
+    defs: {
+      main: {
+        type: 'query',
+        description:
+          'Enumerates accounts which a specified account (actor) follows.',
+        parameters: {
+          type: 'params',
+          required: ['actor'],
+          properties: {
+            actor: {
+              type: 'string',
+              format: 'at-identifier',
+            },
+            limit: {
+              type: 'integer',
+              minimum: 1,
+              maximum: 100,
+              default: 50,
+            },
+            cursor: {
+              type: 'string',
+            },
+          },
+        },
+        output: {
+          encoding: 'application/json',
+          schema: {
+            type: 'object',
+            required: ['subject', 'follows'],
+            properties: {
+              subject: {
+                type: 'ref',
+                ref: 'lex:social.grain.actor.defs#profileView',
+              },
+              cursor: {
+                type: 'string',
+              },
+              follows: {
+                type: 'array',
+                items: {
+                  type: 'ref',
+                  ref: 'lex:social.grain.actor.defs#profileView',
+                },
+              },
+            },
+          },
+        },
+      },
+    },
+  },
   SocialGrainLabelerDefs: {
     lexicon: 1,
     id: 'social.grain.labeler.defs',
···
   SocialGrainGalleryGetActorGalleries: 'social.grain.gallery.getActorGalleries',
   SocialGrainGalleryGetGallery: 'social.grain.gallery.getGallery',
   SocialGrainGraphFollow: 'social.grain.graph.follow',
+  SocialGrainGraphGetFollowers: 'social.grain.graph.getFollowers',
+  SocialGrainGraphGetFollows: 'social.grain.graph.getFollows',
   SocialGrainLabelerDefs: 'social.grain.labeler.defs',
   SocialGrainLabelerService: 'social.grain.labeler.service',
   SocialGrainFeedGetTimeline: 'social.grain.feed.getTimeline',

__generated__/types/social/grain/graph/getFollowers.ts

···
+/**
+ * GENERATED CODE - DO NOT MODIFY
+ */
+import { HandlerAuth, HandlerPipeThrough } from "npm:@atproto/xrpc-server";
+import express from "npm:express";
+import { validate as _validate } from "../../../../lexicons.ts";
+import { is$typed as _is$typed } from "../../../../util.ts";
+import type * as SocialGrainActorDefs from "../actor/defs.ts";
+
+const is$typed = _is$typed,
+  validate = _validate;
+const id = "social.grain.graph.getFollowers";
+
+export interface QueryParams {
+  actor: string;
+  limit: number;
+  cursor?: string;
+}
+
+export type InputSchema = undefined;
+
+export interface OutputSchema {
+  subject: SocialGrainActorDefs.ProfileView;
+  cursor?: string;
+  followers: SocialGrainActorDefs.ProfileView[];
+}
+
+export type HandlerInput = undefined;
+
+export interface HandlerSuccess {
+  encoding: "application/json";
+  body: OutputSchema;
+  headers?: { [key: string]: string };
+}
+
+export interface HandlerError {
+  status: number;
+  message?: string;
+}
+
+export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough;
+export type HandlerReqCtx<HA extends HandlerAuth = never> = {
+  auth: HA;
+  params: QueryParams;
+  input: HandlerInput;
+  req: express.Request;
+  res: express.Response;
+  resetRouteRateLimits: () => Promise<void>;
+};
+export type Handler<HA extends HandlerAuth = never> = (
+  ctx: HandlerReqCtx<HA>,
+) => Promise<HandlerOutput> | HandlerOutput;

__generated__/types/social/grain/graph/getFollows.ts

···
+/**
+ * GENERATED CODE - DO NOT MODIFY
+ */
+import { HandlerAuth, HandlerPipeThrough } from "npm:@atproto/xrpc-server";
+import express from "npm:express";
+import { validate as _validate } from "../../../../lexicons.ts";
+import { is$typed as _is$typed } from "../../../../util.ts";
+import type * as SocialGrainActorDefs from "../actor/defs.ts";
+
+const is$typed = _is$typed,
+  validate = _validate;
+const id = "social.grain.graph.getFollows";
+
+export interface QueryParams {
+  actor: string;
+  limit: number;
+  cursor?: string;
+}
+
+export type InputSchema = undefined;
+
+export interface OutputSchema {
+  subject: SocialGrainActorDefs.ProfileView;
+  cursor?: string;
+  follows: SocialGrainActorDefs.ProfileView[];
+}
+
+export type HandlerInput = undefined;
+
+export interface HandlerSuccess {
+  encoding: "application/json";
+  body: OutputSchema;
+  headers?: { [key: string]: string };
+}
+
+export interface HandlerError {
+  status: number;
+  message?: string;
+}
+
+export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough;
+export type HandlerReqCtx<HA extends HandlerAuth = never> = {
+  auth: HA;
+  params: QueryParams;
+  input: HandlerInput;
+  req: express.Request;
+  res: express.Response;
+  resetRouteRateLimits: () => Promise<void>;
+};
+export type Handler<HA extends HandlerAuth = never> = (
+  ctx: HandlerReqCtx<HA>,
+) => Promise<HandlerOutput> | HandlerOutput;

lexicons/social/grain/graph/getFollowers.json

···
+{
+  "lexicon": 1,
+  "id": "social.grain.graph.getFollowers",
+  "defs": {
+    "main": {
+      "type": "query",
+      "description": "Enumerates accounts which follow a specified account (actor).",
+      "parameters": {
+        "type": "params",
+        "required": ["actor"],
+        "properties": {
+          "actor": { "type": "string", "format": "at-identifier" },
+          "limit": {
+            "type": "integer",
+            "minimum": 1,
+            "maximum": 100,
+            "default": 50
+          },
+          "cursor": { "type": "string" }
+        }
+      },
+      "output": {
+        "encoding": "application/json",
+        "schema": {
+          "type": "object",
+          "required": ["subject", "followers"],
+          "properties": {
+            "subject": {
+              "type": "ref",
+              "ref": "social.grain.actor.defs#profileView"
+            },
+            "cursor": { "type": "string" },
+            "followers": {
+              "type": "array",
+              "items": {
+                "type": "ref",
+                "ref": "social.grain.actor.defs#profileView"
+              }
+            }
+          }
+        }
+      }
+    }
+  }
+}

lexicons/social/grain/graph/getFollows.json

···
+{
+  "lexicon": 1,
+  "id": "social.grain.graph.getFollows",
+  "defs": {
+    "main": {
+      "type": "query",
+      "description": "Enumerates accounts which a specified account (actor) follows.",
+      "parameters": {
+        "type": "params",
+        "required": ["actor"],
+        "properties": {
+          "actor": { "type": "string", "format": "at-identifier" },
+          "limit": {
+            "type": "integer",
+            "minimum": 1,
+            "maximum": 100,
+            "default": 50
+          },
+          "cursor": { "type": "string" }
+        }
+      },
+      "output": {
+        "encoding": "application/json",
+        "schema": {
+          "type": "object",
+          "required": ["subject", "follows"],
+          "properties": {
+            "subject": {
+              "type": "ref",
+              "ref": "social.grain.actor.defs#profileView"
+            },
+            "cursor": { "type": "string" },
+            "follows": {
+              "type": "array",
+              "items": {
+                "type": "ref",
+                "ref": "social.grain.actor.defs#profileView"
+              }
+            }
+          }
+        }
+      }
+    }
+  }
+}

src/api/mod.ts

···
   QueryParams as GetGalleryThreadQueryParams,
 } from "$lexicon/types/social/grain/gallery/getGalleryThread.ts";
 import {
+  OutputSchema as GetFollowersOutputSchema,
+  QueryParams as GetFollowersQueryParams,
+} from "$lexicon/types/social/grain/graph/getFollowers.ts";
+import {
+  OutputSchema as GetFollowsOutputSchema,
+  QueryParams as GetFollowsQueryParams,
+} from "$lexicon/types/social/grain/graph/getFollows.ts";
+import {
   OutputSchema as GetNotificationsOutputSchema,
 } from "$lexicon/types/social/grain/notification/getNotifications.ts";
+
 import { AtUri } from "@atproto/syntax";
 import { BffMiddleware, route } from "@bigmoves/bff";
 import {
   getActorGalleries,
   getActorGalleryFavs,
+  getActorProfile,
   getActorProfileDetailed,
   searchActors,
 } from "../lib/actor.ts";
 import { BadRequestError } from "../lib/errors.ts";
+import {
+  getFollowersWithProfiles,
+  getFollowingWithProfiles,
+} from "../lib/follow.ts";
 import { getGalleriesByHashtag, getGallery } from "../lib/gallery.ts";
 import { getNotifications } from "../lib/notifications.ts";
 import { getTimeline } from "../lib/timeline.ts";
···
       );
     },
   ),
+  route("/xrpc/social.grain.graph.getFollows", (req, _params, ctx) => {
+    const url = new URL(req.url);
+    const { actor } = getFollowsQueryParams(url);
+    const subject = getActorProfile(actor, ctx);
+    const follows = getFollowingWithProfiles(actor, ctx);
+    return ctx.json({
+      subject,
+      follows,
+    } as GetFollowsOutputSchema);
+  }),
+  route("/xrpc/social.grain.graph.getFollowers", (req, _params, ctx) => {
+    const url = new URL(req.url);
+    const { actor } = getFollowersQueryParams(url);
+    const subject = getActorProfile(actor, ctx);
+    const followers = getFollowersWithProfiles(actor, ctx);
+    return ctx.json({
+      subject,
+      followers,
+    } as GetFollowersOutputSchema);
+  }),
 ];
 
 function getProfileQueryParams(url: URL): GetProfileQueryParams {
···
   return { q, limit, cursor };
 }
 
-// function getNotificationsQueryParams(url: URL): GetNotificationsQueryParams {
-//   const limit = parseInt(url.searchParams.get("limit") ?? "50", 10);
-//   if (isNaN(limit) || limit <= 0) {
-//     throw new BadRequestError("Invalid limit parameter");
-//   }
-//   const cursor = url.searchParams.get("cursor") ?? undefined;
-//   return { limit, cursor };
-// }
+function getFollowsQueryParams(url: URL): GetFollowsQueryParams {
+  const actor = url.searchParams.get("actor");
+  if (!actor) throw new BadRequestError("Missing actor parameter");
+  const limit = parseInt(url.searchParams.get("limit") ?? "50", 10);
+  if (isNaN(limit) || limit <= 0) {
+    throw new BadRequestError("Invalid limit parameter");
+  }
+  const cursor = url.searchParams.get("cursor") ?? undefined;
+  return { actor, limit, cursor };
+}
+
+function getFollowersQueryParams(url: URL): GetFollowersQueryParams {
+  const actor = url.searchParams.get("actor");
+  if (!actor) throw new BadRequestError("Missing actor parameter");
+  const limit = parseInt(url.searchParams.get("limit") ?? "50", 10);
+  if (isNaN(limit) || limit <= 0) {
+    throw new BadRequestError("Invalid limit parameter");
+  }
+  const cursor = url.searchParams.get("cursor") ?? undefined;
+  return { actor, limit, cursor };
+}
 
 function getTimelineQueryParams(url: URL): GetTimelineQueryParams {
   const algorithm = url.searchParams.get("algorithm") ?? undefined;