Merge pull request #21 from oraichain/feat/add-btc-price-feed

Feat/add btc price feed
oraidex · Apr 3, 2024 · 137b50f · 137b50f
2 parents c9d2718 + 7c59bdb
commit 137b50f
Show file tree

Hide file tree

Showing 3 changed files with 71 additions and 19 deletions.
diff --git a/packages/priceFeed/package.json b/packages/priceFeed/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@oraichain/oraimargin-pricefeed",
-  "version": "1.0.2",
+  "version": "1.0.3",
   "main": "build/cli.js",
   "bin": "build/cli.js",
   "license": "MIT",

diff --git a/packages/priceFeed/src/cli.ts b/packages/priceFeed/src/cli.ts
@@ -1,6 +1,11 @@
 import dotenv from "dotenv";
 import { priceFeedHandler, executePriceFeed } from "./index";
-import { UserWallet, decrypt, delay, setupWallet } from "@oraichain/oraitrading-common";
+import {
+  UserWallet,
+  decrypt,
+  delay,
+  setupWallet,
+} from "@oraichain/oraitrading-common";
 import { WebhookClient, time, userMention } from "discord.js";
 
 dotenv.config();
@@ -15,12 +20,12 @@ async function getSender(rpcUrl: string): Promise<UserWallet | string> {
         hdPath: process.env.HD_PATH ?? "m/44'/118'/0'/0/0",
         rpcUrl,
         prefix: "orai",
-        gasPrices: "0.001"
+        gasPrices: "0.001",
       }
     );
     return sender;
   } catch (error: any) {
-    console.log({ error: error.message});
+    console.log({ error: error.message });
     return "Error: " + error.message;
   }
 }
@@ -31,26 +36,22 @@ async function handleExecutePriceFeed(
 ): Promise<string> {
   const date = new Date();
   let result = "";
-  const priceFeed = new priceFeedHandler(sender, engine); 
-  try {  
+  const priceFeed = new priceFeedHandler(sender, engine);
+  try {
     const priceMsg = await executePriceFeed(priceFeed);
     if (priceMsg.length > 0) {
       console.dir(priceMsg, { depth: 4 });
       const res = await priceFeed.executeMultiple(priceMsg);
       if (res !== undefined) {
-        console.log(
-          "appendPrice - txHash:",
-          res.transactionHash
-        );
-        result = `:receipt: BOT: ${sender.address} - appendPrice - txHash: ${res.transactionHash}` + ` at ${time(date)}`;
+        console.log("appendPrice - txHash:", res.transactionHash);
+        result =
+          `:receipt: BOT: ${sender.address} - appendPrice - txHash: ${res.transactionHash}` +
+          ` at ${time(date)}`;
       }
     }
     return result;
   } catch (error) {
-    console.log(
-      "error in processing appendPrice: ",
-      { error }
-    );
+    console.log("error in processing appendPrice: ", { error });
     console.log("Send discord noti: ", error.message);
     return (
       `:red_circle: BOT: ${sender.address} - err ` +

diff --git a/packages/priceFeed/src/index.ts b/packages/priceFeed/src/index.ts
@@ -90,16 +90,67 @@ export class priceFeedHandler {
       },
     ];
   }
+
+  async appendPrice(
+    priceFeed: Addr,
+    key: string,
+    url: string
+  ): Promise<ExecuteInstruction[]> {
+    const decimals = Number((await this.engineClient.config()).decimals);
+    const oraclePrice = Math.round((await getPriceFeed(key, url)) * decimals);
+    if (oraclePrice === 0) {
+      console.log("Oracle price is ZERO!");
+      return [];
+    }
+    console.log({ oraclePrice });
+    let time = Math.floor(Date.now() / 1000) - 12;
+    console.log({ time });
+    const appendPrice = {
+      append_price: {
+        key,
+        price: oraclePrice.toString(),
+        timestamp: time,
+      },
+    } as MarginedPricefeedTypes.ExecuteMsg;
+
+    return [
+      {
+        contractAddress: priceFeed,
+        msg: appendPrice,
+      },
+    ];
+  }
 }
 
 export async function executePriceFeed(
   engineHandler: priceFeedHandler
 ): Promise<ExecuteInstruction[]> {
   const priceFeed = process.env.PRICEFEED_CONTRACT;
   console.log({ priceFeed });
-  const appendOraiPrice = await engineHandler.appendOraiprice(priceFeed);
-  const appendInjPrice = await engineHandler.appendInjprice(priceFeed);
-  let priceMsg: ExecuteInstruction[] = [];
-  priceMsg = priceMsg.concat(appendOraiPrice, appendInjPrice);
+  const [appendOraiPrice, appendInjPrice, appendBTCPrice] = await Promise.all([
+    engineHandler.appendPrice(
+      priceFeed,
+      "ORAI",
+      "https://pricefeed.oraichainlabs.org/"
+    ),
+    engineHandler.appendPrice(
+      priceFeed,
+      "INJ",
+      "https://pricefeed-futures.oraichainlabs.org/inj"
+    ),
+    engineHandler.appendPrice(
+      priceFeed,
+      "BTC",
+      "https://pricefeed-futures.oraichainlabs.org/btc"
+    ),
+  ]);
+
+  const priceMsg: ExecuteInstruction[] = [
+    ...appendOraiPrice,
+    ...appendInjPrice,
+    ...appendBTCPrice,
+  ];
+
+  console.log(priceMsg);
   return priceMsg;
 }