feat: expose notifications api

apps/api/src/app/routes/__chainId/markets/__baseTokenAddress-__quoteTokenAddress/slippageTolerance.ts

@@ -7,7 +7,6 @@ import {
   CACHE_CONTROL_HEADER,
   getCacheControlHeaderValue,
 } from '../../../../../utils/cache';
-import { deprecate } from 'util';
 
 const CACHE_SECONDS = 120;
 
@@ -31,6 +30,7 @@ const routeSchema = {
     },
   },
 } as const satisfies JSONSchema;
+
 const successSchema = {
   type: 'object',
   required: ['slippageBps'],

apps/api/src/app/routes/accounts/_account/notifications.ts

@@ -0,0 +1,42 @@
+import {
+  NotificationModel,
+  getNotificationsByAccount,
+} from '@cowprotocol/cms-api';
+import { FastifyPluginAsync } from 'fastify';
+import { FromSchema, JSONSchema } from 'json-schema-to-ts';
+import { ETHEREUM_ADDRESS_PATTERN } from '../../../schemas';
+
+const routeSchema = {
+  type: 'object',
+  required: ['account'],
+  properties: {
+    account: {
+      title: 'account',
+      description: 'Account of the user',
+      type: 'string',
+      pattern: ETHEREUM_ADDRESS_PATTERN,
+    },
+  },
+} as const satisfies JSONSchema;
+
+type RouteSchema = FromSchema<typeof routeSchema>;
+
+type GetNotificationsSchema = RouteSchema;
+
+const accounts: FastifyPluginAsync = async (fastify): Promise<void> => {
+  // GET /accounts/:account/notifications
+  fastify.get<{
+    Params: GetNotificationsSchema;
+    Reply: NotificationModel[];
+  }>(
+    '/notifications',
+    { schema: { params: routeSchema } },
+    async function (request, reply) {
+      const account = request.params.account;
+      const notifications = await getNotificationsByAccount({ account });
+      reply.send(notifications);
+    }
+  );
+};
+
+export default accounts;

libs/cms-api/src/index.ts

@@ -67,7 +67,7 @@ export async function getNotificationsByAccount({
     throw error;
   }
 
-  return data.data;
+  return data;
 }
 
 export async function getAllNotifications(): Promise<CmsNotification[]> {