feat: add notifications xrpc endpoint

__generated__/index.ts

···
   type StreamAuthVerifier,
 } from "npm:@atproto/xrpc-server"
 import { schemas } from './lexicons.ts'
+import * as SocialGrainNotificationGetNotifications from './types/social/grain/notification/getNotifications.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'
···
 
 export class SocialGrainNS {
   _server: Server
+  notification: SocialGrainNotificationNS
   gallery: SocialGrainGalleryNS
   graph: SocialGrainGraphNS
   labeler: SocialGrainLabelerNS
···
 
   constructor(server: Server) {
     this._server = server
+    this.notification = new SocialGrainNotificationNS(server)
     this.gallery = new SocialGrainGalleryNS(server)
     this.graph = new SocialGrainGraphNS(server)
     this.labeler = new SocialGrainLabelerNS(server)
     this.feed = new SocialGrainFeedNS(server)
     this.actor = new SocialGrainActorNS(server)
     this.photo = new SocialGrainPhotoNS(server)
+  }
+}
+
+export class SocialGrainNotificationNS {
+  _server: Server
+
+  constructor(server: Server) {
+    this._server = server
+  }
+
+  getNotifications<AV extends AuthVerifier>(
+    cfg: ConfigOf<
+      AV,
+      SocialGrainNotificationGetNotifications.Handler<ExtractAuth<AV>>,
+      SocialGrainNotificationGetNotifications.HandlerReqCtx<ExtractAuth<AV>>
+    >,
+  ) {
+    const nsid = 'social.grain.notification.getNotifications' // @ts-ignore
+    return this._server.xrpc.method(nsid, cfg)
   }
 }
 

__generated__/lexicons.ts

···
       },
     },
   },
+  SocialGrainNotificationGetNotifications: {
+    lexicon: 1,
+    id: 'social.grain.notification.getNotifications',
+    defs: {
+      main: {
+        type: 'query',
+        description:
+          'Enumerate notifications for the requesting account. Requires auth.',
+        parameters: {
+          type: 'params',
+          properties: {
+            limit: {
+              type: 'integer',
+              minimum: 1,
+              maximum: 100,
+              default: 50,
+            },
+            cursor: {
+              type: 'string',
+            },
+          },
+        },
+        output: {
+          encoding: 'application/json',
+          schema: {
+            type: 'object',
+            required: ['notifications'],
+            properties: {
+              cursor: {
+                type: 'string',
+              },
+              notifications: {
+                type: 'array',
+                items: {
+                  type: 'ref',
+                  ref: 'lex:social.grain.notification.defs#notificationView',
+                },
+              },
+              seenAt: {
+                type: 'string',
+                format: 'datetime',
+              },
+            },
+          },
+        },
+      },
+    },
+  },
   SocialGrainCommentDefs: {
     lexicon: 1,
     id: 'social.grain.comment.defs',
···
   ShTangledActorProfile: 'sh.tangled.actor.profile',
   SocialGrainDefs: 'social.grain.defs',
   SocialGrainNotificationDefs: 'social.grain.notification.defs',
+  SocialGrainNotificationGetNotifications:
+    'social.grain.notification.getNotifications',
   SocialGrainCommentDefs: 'social.grain.comment.defs',
   SocialGrainComment: 'social.grain.comment',
   SocialGrainGalleryItem: 'social.grain.gallery.item',

__generated__/types/social/grain/notification/getNotifications.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 SocialGrainNotificationDefs from "./defs.ts";
+
+const is$typed = _is$typed,
+  validate = _validate;
+const id = "social.grain.notification.getNotifications";
+
+export interface QueryParams {
+  limit: number;
+  cursor?: string;
+}
+
+export type InputSchema = undefined;
+
+export interface OutputSchema {
+  cursor?: string;
+  notifications: SocialGrainNotificationDefs.NotificationView[];
+  seenAt?: string;
+}
+
+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;

deno.json

···
     "dev:tailwind": "deno run -A --node-modules-dir npm:@tailwindcss/cli -i ./src/input.css -o ./build/styles.css --watch",
     "dev:fonts": "rm -rf ./build/fonts && cp -r ./static/fonts/. ./build/fonts",
     "sync": "deno run -A --env=.env jsr:@bigmoves/bff-cli@0.3.0-beta.40 sync --collections=social.grain.gallery,social.grain.actor.profile,social.grain.photo,social.grain.favorite,social.grain.gallery.item,social.grain.graph.follow,social.grain.photo.exif,social.grain.comment --external-collections=app.bsky.actor.profile,app.bsky.graph.follow,sh.tangled.graph.follow,sh.tangled.actor.profile --collection-key-map=\"{\\\"social.grain.favorite\\\":[\\\"subject\\\"],\\\"social.grain.graph.follow\\\":[\\\"subject\\\"],\\\"social.grain.gallery.item\\\":[\\\"gallery\\\",\\\"item\\\"],\\\"social.grain.photo.exif\\\":[\\\"photo\\\"],\\\"social.grain.comment\\\":[\\\"subject\\\"]}\"",
-    "codegen": "deno run -A jsr:@bigmoves/bff-cli@0.3.0-beta.40 lexgen"
+    "codegen": "deno run -A jsr:@bigmoves/bff-cli@0.3.0-beta.42 lexgen"
   },
   "compilerOptions": {
     "jsx": "precompile",

lexicons/social/grain/notification/getNotifications.json

···
+{
+  "lexicon": 1,
+  "id": "social.grain.notification.getNotifications",
+  "defs": {
+    "main": {
+      "type": "query",
+      "description": "Enumerate notifications for the requesting account. Requires auth.",
+      "parameters": {
+        "type": "params",
+        "properties": {
+          "limit": {
+            "type": "integer",
+            "minimum": 1,
+            "maximum": 100,
+            "default": 50
+          },
+          "cursor": { "type": "string" }
+        }
+      },
+      "output": {
+        "encoding": "application/json",
+        "schema": {
+          "type": "object",
+          "required": ["notifications"],
+          "properties": {
+            "cursor": { "type": "string" },
+            "notifications": {
+              "type": "array",
+              "items": {
+                "type": "ref",
+                "ref": "social.grain.notification.defs#notificationView"
+              }
+            },
+            "seenAt": { "type": "string", "format": "datetime" }
+          }
+        }
+      }
+    }
+  }
+}

src/api/mod.ts

···
   OutputSchema as GetGalleryThreadOutputSchema,
   QueryParams as GetGalleryThreadQueryParams,
 } from "$lexicon/types/social/grain/gallery/getGalleryThread.ts";
+import {
+  OutputSchema as GetNotificationsOutputSchema,
+} from "$lexicon/types/social/grain/notification/getNotifications.ts";
 import { AtUri } from "@atproto/syntax";
 import { BffMiddleware, OAUTH_ROUTES, route } from "@bigmoves/bff";
 import { getActorGalleries, getActorProfileDetailed } from "../lib/actor.ts";
 import { BadRequestError } from "../lib/errors.ts";
 import { getGallery } from "../lib/gallery.ts";
+import { getNotifications } from "../lib/notifications.ts";
 import { getTimeline } from "../lib/timeline.ts";
 import { getGalleryComments } from "../modules/comments.tsx";
 
···
       { feed: items.map((i) => i.gallery) } as GetTimelineOutputSchema,
     );
   }),
+  route(
+    "/xrpc/social.grain.notification.getNotifications",
+    (_req, _params, ctx) => {
+      // @TODO: this redirects, we should have a json response
+      ctx.requireAuth();
+      const notifications = getNotifications(
+        ctx,
+      );
+      return ctx.json(
+        { notifications } as GetNotificationsOutputSchema,
+      );
+    },
+  ),
 ];
 
 function getProfileQueryParams(url: URL): GetProfileQueryParams {
···
   if (!uri) throw new BadRequestError("Missing uri parameter");
   return { uri };
 }
+
+// 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 getTimelineQueryParams(url: URL): GetTimelineQueryParams {
 //   const algorithm = url.searchParams.get("algorithm") ?? undefined;