Send notification test from ender

dydxprotocol · Aug 13, 2024 · 1034845 · 1034845
1 parent f813892
commit 1034845
Show file tree

Hide file tree

Showing 3 changed files with 20 additions and 1 deletion.
diff --git a/indexer/pnpm-lock.yaml b/indexer/pnpm-lock.yaml
diff --git a/indexer/services/ender/package.json b/indexer/services/ender/package.json
@@ -22,6 +22,7 @@
     "@dydxprotocol-indexer/redis": "workspace:^0.0.1",
     "@dydxprotocol-indexer/v4-proto-parser": "workspace:^0.0.1",
     "@dydxprotocol-indexer/v4-protos": "workspace:^0.0.1",
+    "@dydxprotocol-indexer/notifications": "workspace:^0.0.1",
     "big.js": "^6.0.2",
     "dd-trace": "^3.32.1",
     "dotenv-flow": "^3.2.0",

diff --git a/indexer/services/ender/src/handlers/order-fills/order-handler.ts b/indexer/services/ender/src/handlers/order-fills/order-handler.ts
@@ -1,3 +1,9 @@
+import {
+  sendFirebaseMessage,
+  createNotification,
+  NotificationType,
+  NotificationDynamicFieldKey,
+} from '@dydxprotocol-indexer/notifications';
 import {
   FillFromDatabase,
   FillModel,
@@ -18,7 +24,9 @@ import {
 } from '@dydxprotocol-indexer/postgres';
 import { StateFilledQuantumsCache } from '@dydxprotocol-indexer/redis';
 import { isStatefulOrder } from '@dydxprotocol-indexer/v4-proto-parser';
-import { IndexerOrder, IndexerOrderId, IndexerSubaccountId } from '@dydxprotocol-indexer/v4-protos';
+import {
+  ClobPair, IndexerOrder, IndexerOrderId, IndexerSubaccountId,
+} from '@dydxprotocol-indexer/v4-protos';
 import Long from 'long';
 import * as pg from 'pg';
 
@@ -118,6 +126,14 @@ export class OrderHandler extends AbstractOrderFillHandler<OrderFillWithLiquidit
     // block.
     if (order.status === OrderStatus.FILLED && isStatefulOrder(order.orderFlags)) {
       kafkaEvents.push(this.getOrderRemoveKafkaEvent(orderProto.orderId!));
+
+      const subaccount = await SubaccountTable.findById(order.subaccountId);
+      const notification = createNotification(NotificationType.ORDER_FILLED, {
+        [NotificationDynamicFieldKey.MARKET]: 'BTC/USD',
+        [NotificationDynamicFieldKey.AVERAGE_PRICE]: order.price,
+      });
+
+      await sendFirebaseMessage(subaccount!.address, notification);
     }
 
     if (this.event.liquidity === Liquidity.TAKER) {