support new pyth oracles

solendprotocol · Jul 15, 2024 · 99b1866 · 99b1866
1 parent 180046f
commit 99b1866
Show file tree

Hide file tree

Showing 3 changed files with 253 additions and 6 deletions.
diff --git a/solend-lite/package.json b/solend-lite/package.json
@@ -19,6 +19,7 @@
     "@emotion/styled": "^11.10.5",
     "@next/font": "13.0.7",
     "@pythnetwork/client": "^2.12.0",
+    "@pythnetwork/pyth-solana-receiver": "^0.8.0",
     "@solana/spl-token": "^0.3.7",
     "@solana/wallet-adapter-base": "^0.9.20",
     "@solana/wallet-adapter-react": "^0.15.28",

diff --git a/solend-sdk/src/core/utils/prices.ts b/solend-sdk/src/core/utils/prices.ts
@@ -1,8 +1,10 @@
-import { Connection, PublicKey } from "@solana/web3.js";
+import { Connection, Keypair, PublicKey } from "@solana/web3.js";
 import { parsePriceData } from "@pythnetwork/client";
 import SwitchboardProgram from "@switchboard-xyz/sbv2-lite";
+import { PythSolanaReceiver } from '@pythnetwork/pyth-solana-receiver';
 import { getBatchMultipleAccountsInfo } from "./utils";
 import { Reserve } from "../../state";
+import NodeWallet from "@coral-xyz/anchor/dist/cjs/nodewallet";
 
 const SBV2_MAINNET = "SW1TCH7qEPTdLsDHRgPuMQjbQxKdH2aBStViMFnt64f";
 
@@ -20,6 +22,7 @@ export async function fetchPrices(
     );
 
   const priceAccounts = await getBatchMultipleAccountsInfo(oracles, connection);
+  const pythSolanaReceiver = new PythSolanaReceiver({ connection, wallet: new NodeWallet(Keypair.fromSeed(new Uint8Array(32).fill(1))) });
 
   return parsedReserves.reduce((acc, reserve, i) => {
     const pythOracleData = priceAccounts[i];
@@ -33,6 +36,29 @@ export async function fetchPrices(
       | undefined;
 
     if (pythOracleData) {
+      if (
+        pythOracleData.owner.toBase58() ===
+        pythSolanaReceiver.receiver.programId.toBase58()
+      ) {
+        // pythData = pythSolanaReceiver.receiver.coder.accounts.decode(
+        //   'priceUpdateV2',
+        //   pythOracleData.data,
+        // );
+        const priceUpdate =
+          pythSolanaReceiver.receiver.account.priceUpdateV2.coder.accounts.decode(
+            'priceUpdateV2',
+            pythOracleData.data,
+          );
+        const exponent = 10 ** priceUpdate.priceMessage.exponent;
+        const spotPrice = priceUpdate.priceMessage.price.toNumber() * exponent;
+        const emaPrice = priceUpdate.priceMessage.emaPrice.toNumber() * exponent;
+
+        priceData = {
+          spotPrice,
+          emaPrice,
+        };
+
+      } else {
       const { price, previousPrice, emaPrice } = parsePriceData(
         pythOracleData.data as Buffer
       );
@@ -45,6 +71,7 @@ export async function fetchPrices(
         };
       }
     }
+    }
 
     // Only attempt to fetch from switchboard if not already available from pyth
     if (!priceData) {