@aori-io/indexers - npm Package Compare versions

Comparing version 0.1.8 to 0.1.9

dist/indexers/HistoricalOrdersTracker.js

@@ -39,5 +39,8 @@ "use strict";
             });
-            this.feedProvider.on(sdk_1.SubscriptionEvents.OrderFulfilled, async ({ makerOrderHash, takerOrderHash, timestamp, matchingHash, transactionHash, blockNumber }) => {
-                await this.storageClient.updateOrder(makerOrderHash || "", { isActive: false, fulfilledAt: timestamp, matchingHash, transactionHash, blockNumber });
-                await this.storageClient.updateOrder(takerOrderHash || "", { isActive: false, fulfilledAt: timestamp, matchingHash, transactionHash, blockNumber });
+            this.feedProvider.on(sdk_1.SubscriptionEvents.OrderFulfilled, async ({ makerOrderHash, takerOrderHash, timestamp, matchingHash, transactionHash, blockNumber, inputChainId, inputToken, inputAmount, outputToken, outputAmount }) => {
+                let inputPrice, outputPrice;
+                await (0, sdk_1.getTokenPrice)(inputChainId, inputToken, inputAmount).then(price => inputPrice = price.amountUSD).catch(console.error);
+                await (0, sdk_1.getTokenPrice)(inputChainId, outputToken, outputAmount).then(price => outputPrice = price.amountUSD).catch(console.error);
+                await this.storageClient.updateOrder(makerOrderHash || "", { isActive: false, fulfilledAt: timestamp, matchingHash, transactionHash, blockNumber, amountUSD: inputPrice });
+                await this.storageClient.updateOrder(takerOrderHash || "", { isActive: false, fulfilledAt: timestamp, matchingHash, transactionHash, blockNumber, amountUSD: outputPrice });
                 console.log("Order fulfilled", makerOrderHash, takerOrderHash);
@@ -44,0 +47,0 @@ });

dist/interfaces.d.ts

@@ -8,2 +8,3 @@ import { DatabaseOrderView } from "@aori-io/sdk";
     timestamp?: number;
+    amountUSD?: number;
 }

package.json

 {
   "name": "@aori-io/indexers",
-  "version": "0.1.8",
+  "version": "0.1.9",
   "description": "",
@@ -14,3 +14,3 @@ "main": "dist/index.js",
   "dependencies": {
-    "@aori-io/sdk": "^0.14.1",
+    "@aori-io/sdk": "^0.14.15",
     "@redis/client": "^1.5.16",
@@ -17,0 +17,0 @@ "@redis/json": "^1.0.6",

src/indexers/HistoricalOrdersTracker.ts

@@ -1,2 +0,2 @@
-import { AoriFeedProvider, SubscriptionEvents, toDatabaseOrderView, toOrderView } from "@aori-io/sdk";
+import { AoriFeedProvider, getTokenPrice, SubscriptionEvents, toDatabaseOrderView, toOrderView } from "@aori-io/sdk";
 import { OrderClient } from "../clients/OrderClient";
@@ -55,6 +55,15 @@
                 transactionHash,
-                blockNumber
+                blockNumber,
+                inputChainId,
+                inputToken,
+                inputAmount,
+                outputToken,
+                outputAmount
             }) => {
-                await this.storageClient.updateOrder(makerOrderHash || "", { isActive: false, fulfilledAt: timestamp, matchingHash, transactionHash, blockNumber });
-                await this.storageClient.updateOrder(takerOrderHash || "", { isActive: false, fulfilledAt: timestamp, matchingHash, transactionHash, blockNumber });
+                let inputPrice: number | undefined, outputPrice: number | undefined;
+                await getTokenPrice(inputChainId, inputToken, inputAmount).then(price => inputPrice = price.amountUSD).catch(console.error);
+                await getTokenPrice(inputChainId, outputToken, outputAmount).then(price => outputPrice = price.amountUSD).catch(console.error);
+
+                await this.storageClient.updateOrder(makerOrderHash || "", { isActive: false, fulfilledAt: timestamp, matchingHash, transactionHash, blockNumber, amountUSD: inputPrice });
+                await this.storageClient.updateOrder(takerOrderHash || "", { isActive: false, fulfilledAt: timestamp, matchingHash, transactionHash, blockNumber, amountUSD: outputPrice });
                 console.log("Order fulfilled", makerOrderHash, takerOrderHash);
@@ -61,0 +70,0 @@ });

src/interfaces.ts

@@ -9,2 +9,3 @@ import { DatabaseOrderView } from "@aori-io/sdk";
     timestamp?: number;
+    amountUSD?: number;
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

42157

increased by2.66%

Lines of code

824

increased by1.6%

Dependency changes

• Updated@aori-io/sdk@^0.14.15