Add notifications_merged event type for streaming endpoints

Co-authored-by: abraham <3341+abraham@users.noreply.github.com>

Author: Copilot

dist/schema.json

@@ -37108,6 +37108,20 @@
           "payload"
         ]
       },
+      "NotificationsMergedEvent": {
+        "type": "object",
+        "description": "Accepted notification requests have finished merging, and the notifications list should be refreshed. Payload can be ignored.",
+        "properties": {
+          "event": {
+            "type": "string",
+            "description": "The type of event",
+            "$ref": "#/components/schemas/NotificationsMergedEventEventEnum"
+          }
+        },
+        "required": [
+          "event"
+        ]
+      },
       "StreamingEvent": {
         "description": "Server-Sent Event from the Mastodon streaming API. The event field determines the type of payload.",
         "oneOf": [
@@ -37137,6 +37151,9 @@
           },
           {
             "$ref": "#/components/schemas/StatusUpdateEvent"
+          },
+          {
+            "$ref": "#/components/schemas/NotificationsMergedEvent"
           }
         ]
       },
@@ -37166,6 +37183,9 @@
           },
           {
             "$ref": "#/components/schemas/StatusUpdateEvent"
+          },
+          {
+            "$ref": "#/components/schemas/NotificationsMergedEvent"
           }
         ]
       },
@@ -37174,6 +37194,9 @@
         "oneOf": [
           {
             "$ref": "#/components/schemas/NotificationEvent"
+          },
+          {
+            "$ref": "#/components/schemas/NotificationsMergedEvent"
           }
         ]
       },
@@ -37724,6 +37747,12 @@
         "enum": [
           "status.update"
         ]
+      },
+      "NotificationsMergedEventEventEnum": {
+        "type": "string",
+        "enum": [
+          "notifications_merged"
+        ]
       }
     },
     "securitySchemes": {

src/__tests__/generators/StreamingSchemaGenerator.test.ts

@@ -53,6 +53,9 @@ describe('StreamingSchemaGenerator', () => {
         'AnnouncementDeleteEvent'
       );
       expect(spec.components?.schemas).toHaveProperty('StatusUpdateEvent');
+      expect(spec.components?.schemas).toHaveProperty(
+        'NotificationsMergedEvent'
+      );
     });
 
     it('should create combined streaming event schema', () => {
@@ -63,7 +66,7 @@ describe('StreamingSchemaGenerator', () => {
         'StreamingEvent'
       ] as any;
       expect(streamingEvent.oneOf).toBeDefined();
-      expect(streamingEvent.oneOf.length).toBe(9); // All event types
+      expect(streamingEvent.oneOf.length).toBe(10); // All event types including notifications_merged
     });
 
     it('should create endpoint-specific event schemas', () => {
@@ -147,7 +150,7 @@ describe('StreamingSchemaGenerator', () => {
 
       const userEvent = spec.components?.schemas?.['StreamingUserEvent'] as any;
       expect(userEvent.oneOf).toBeDefined();
-      expect(userEvent.oneOf.length).toBe(8); // All user events
+      expect(userEvent.oneOf.length).toBe(9); // All user events including notifications_merged
 
       // Check all expected event types are referenced
       const refs = userEvent.oneOf.map((ref: any) => ref.$ref);
@@ -159,6 +162,7 @@ describe('StreamingSchemaGenerator', () => {
       expect(refs).toContain('#/components/schemas/AnnouncementReactionEvent');
       expect(refs).toContain('#/components/schemas/AnnouncementDeleteEvent');
       expect(refs).toContain('#/components/schemas/StatusUpdateEvent');
+      expect(refs).toContain('#/components/schemas/NotificationsMergedEvent');
     });
 
     it('should create StreamingDirectEvent with only conversation event', () => {

src/generators/StreamingSchemaGenerator.ts

@@ -31,8 +31,12 @@ const STREAMING_ENDPOINT_EVENTS: Record<string, string[]> = {
     'announcement.reaction',
     'announcement.delete',
     'status.update',
+    'notifications_merged',
+  ],
+  '/api/v1/streaming/user/notification': [
+    'notification',
+    'notifications_merged',
   ],
-  '/api/v1/streaming/user/notification': ['notification'],
   '/api/v1/streaming/public': ['update', 'delete', 'status.update'],
   '/api/v1/streaming/public/local': ['update', 'delete', 'status.update'],
   '/api/v1/streaming/public/remote': ['update', 'delete', 'status.update'],
@@ -100,6 +104,12 @@ const STREAMING_EVENTS: StreamingEventDefinition[] = [
     description:
       'A Status has been edited. Payload contains a Status cast to a string.',
   },
+  {
+    eventName: 'notifications_merged',
+    payloadType: 'none',
+    description:
+      'Accepted notification requests have finished merging, and the notifications list should be refreshed. Payload can be ignored.',
+  },
 ];
 
 /**