feat: add support for wBnbBurnConverter

package.json

@@ -59,7 +59,7 @@
     "@venusprotocol/governance-contracts": "2.10.0",
     "@venusprotocol/isolated-pools": "4.2.0-dev.9",
     "@venusprotocol/oracle": "2.9.0",
-    "@venusprotocol/protocol-reserve": "3.1.0",
+    "@venusprotocol/protocol-reserve": "3.4.0-dev.3",
     "@venusprotocol/solidity-utilities": "^2.0.3",
     "@venusprotocol/venus-protocol": "9.6.0",
     "assemblyscript": "0.19.23",
@@ -90,7 +90,7 @@
   "resolutions": {
     "@venusprotocol/governance-contracts": "2.10.0",
     "@venusprotocol/venus-protocol": "9.6.0",
-    "@venusprotocol/protocol-reserve": "3.1.0",
+    "@venusprotocol/protocol-reserve": "3.4.0-dev.3",
     "prettier": "^3.0.3"
   },
   "husky": {

subgraphs/protocol-reserve/config/index.ts

@@ -34,6 +34,8 @@ const main = () => {
       usdtPrimeConverterStartBlock: '0',
       xvsVaultConverterAddress: '0xa779C1D17bC5230c07afdC51376CAC1cb3Dd5314',
       xvsVaultConverterStartBlock: '0',
+      wBnbBurnConverterAddress: '0xa079C1D17bC5230c07afdC51376CAC1cb3Dd5314',
+      wBnbBurnConverterStartBlock: '0',
       riskFundAddress: '0x8d81a3dcd17030cd5f23ac7370e4efb10d2b3ca4',
       protocolShareReserveAddress: '0x70e0bA845a1A0F2DA3359C97E0285013525FFC49',
       protocolShareReserveStartBlock: '0',
@@ -55,6 +57,8 @@ const main = () => {
       usdtPrimeConverterStartBlock: '36750639',
       xvsVaultConverterAddress: chapelDeployments.addresses.XVSVaultConverter,
       xvsVaultConverterStartBlock: '36750678',
+      wBnbBurnConverterAddress: chapelDeployments.addresses.WBNBBurnConverter,
+      wBnbBurnConverterStartBlock: '54160930',
       riskFundAddress: chapelDeployments.addresses.RiskFundV2,
       StartBlock: '36750498',
       protocolShareReserveAddress: chapelDeployments.addresses.ProtocolShareReserve,
@@ -77,6 +81,8 @@ const main = () => {
       usdtPrimeConverterStartBlock: '35140081',
       xvsVaultConverterAddress: bscMainnetDeployments.addresses.XVSVaultConverter,
       xvsVaultConverterStartBlock: '35140090',
+      wBnbBurnConverterAddress: bscMainnetDeployments.addresses.WBNBBurnConverter,
+      wBnbBurnConverterStartBlock: '51144405',
       riskFundAddress: bscMainnetDeployments.addresses.RiskFundV2,
       protocolShareReserveAddress: bscMainnetDeployments.addresses.ProtocolShareReserve,
       protocolShareReserveStartBlock: '32659440',

subgraphs/protocol-reserve/schema.graphql

@@ -38,6 +38,7 @@ type TokenConverter @entity {
     destinationAddress: Bytes!
     baseAsset: Token!
     configs: [TokenConverterConfig!]! @derivedFrom(field: "tokenConverter")
+    destinationAmounts: [DestinationAmount!]! @derivedFrom(field: "tokenConverter")
     paused: Boolean!
     priceOracleAddress: Bytes!
 }
@@ -54,3 +55,14 @@ type TokenConverterConfig @entity {
     access: ConversionAccessibility!
     tokenOutBalance: BigInt!
 }
+
+"""
+Destination Amounts
+"""
+type DestinationAmount @entity {
+    id: Bytes!
+    address: Bytes!
+    tokenConverter: TokenConverter!
+    token: Token!
+    amount: BigInt!
+}

subgraphs/protocol-reserve/src/constants/addresses.ts

@@ -11,6 +11,7 @@ import {
   wbtcPrimeConverterAddress as wbtcPrimeConverterAddressString,
   wethPrimeConverterAddress as wethPrimeConverterAddressString,
   xvsVaultConverterAddress as xvsVaultConverterAddressString,
+  wBnbBurnConverterAddress as wBnbBurnConverterAddressString,
 } from './config';
 
 export const nullAddress = Address.fromString('0x0000000000000000000000000000000000000000');
@@ -31,5 +32,6 @@ export const usdtPrimeConverterAddress = addressFromCleanString(usdtPrimeConvert
 export const xvsVaultConverterAddress = addressFromCleanString(xvsVaultConverterAddressString);
 export const wbtcPrimeConverterAddress = addressFromCleanString(wbtcPrimeConverterAddressString);
 export const wethPrimeConverterAddress = addressFromCleanString(wethPrimeConverterAddressString);
+export const wBnbBurnConverterAddress = addressFromCleanString(wBnbBurnConverterAddressString);
 
 export const riskFundAddress = addressFromCleanString(riskFundAddressString);

subgraphs/protocol-reserve/src/constants/config-template

@@ -8,6 +8,7 @@ export const riskFundConverterAddress = '{{riskFundConverterAddress}}';
 export const usdcPrimeConverterAddress = '{{usdcPrimeConverterAddress}}';
 export const usdtPrimeConverterAddress = '{{usdtPrimeConverterAddress}}';
 export const xvsVaultConverterAddress = '{{xvsVaultConverterAddress}}';
+export const wBnbBurnConverterAddress = '{{wBnbBurnConverterAddress}}';
 export const wbtcPrimeConverterAddress = '{{wbtcPrimeConverterAddress}}';
 export const wethPrimeConverterAddress = '{{wethPrimeConverterAddress}}';
 

subgraphs/protocol-reserve/src/mappings/tokenConverter.ts

@@ -1,7 +1,9 @@
-import { ethereum } from '@graphprotocol/graph-ts';
+import { Address, ethereum } from '@graphprotocol/graph-ts';
 
 import {
+  AssetTransferredToDestination,
   BaseAssetUpdated,
+  ConvertedExactTokens,
   ConversionConfigUpdated,
   ConversionPaused,
   ConversionResumed,
@@ -18,9 +20,10 @@ import {
   wbtcPrimeConverterAddress,
   wethPrimeConverterAddress,
   xvsVaultConverterAddress,
+  wBnbBurnConverterAddress,
 } from '../constants/addresses';
 import { getTokenConverter } from '../operations/get';
-import { getOrCreateTokenConverter } from '../operations/getOrCreate';
+import { getOrCreateDestinationAmount, getOrCreateTokenConverter } from '../operations/getOrCreate';
 import { updateOrCreateTokenConverterConfig } from '../operations/updateOrCreate';
 import { getConverterNetworkId } from '../utilities/ids';
 
@@ -59,6 +62,11 @@ export function handleInitializationWethPrimeConverter(block: ethereum.Block): v
   getOrCreateTokenConverter(wethPrimeConverterAddress);
 }
 
+// eslint-disable-next-line @typescript-eslint/no-unused-vars
+export function handleInitializationWBnbBurnConverter(block: ethereum.Block): void {
+  getOrCreateTokenConverter(wBnbBurnConverterAddress);
+}
+
 export function handleConversionConfigUpdated(event: ConversionConfigUpdated): void {
   getOrCreateTokenConverter(event.address);
   updateOrCreateTokenConverterConfig(event.address, event.params);
@@ -99,3 +107,48 @@ export function handlePriceOracleUpdated(event: PriceOracleUpdated): void {
   tokenConverter.priceOracleAddress = event.params.priceOracle;
   tokenConverter.save();
 }
+
+export function handleConvertedExactTokens(event: ConvertedExactTokens): void {
+  const tokenConverter = getTokenConverter(event.address)!;
+
+  // handle private conversions (conversions between converters)
+  const senderConverter = getTokenConverter(event.params.sender);
+  if (!!senderConverter && senderConverter.address !== riskFundConverterAddress) {
+    const senderDestinationAmount = getOrCreateDestinationAmount(
+      Address.fromBytes(senderConverter.address),
+      Address.fromBytes(senderConverter.destinationAddress),
+      event.params.tokenAddressOut,
+    );
+    senderDestinationAmount.amount = senderDestinationAmount.amount.plus(event.params.amountOut);
+    senderDestinationAmount.save();
+  }
+
+  const destinationAmountEntity = getOrCreateDestinationAmount(
+    event.address,
+    Address.fromBytes(tokenConverter.destinationAddress),
+    event.params.tokenAddressIn,
+  );
+  destinationAmountEntity.amount = destinationAmountEntity.amount.plus(event.params.amountIn);
+  destinationAmountEntity.save();
+}
+
+export function handleConversionEvent(event: ConvertedExactTokens): void {
+  const tokenConverter = getTokenConverter(event.address)!;
+  const destinationAmountEntity = getOrCreateDestinationAmount(
+    event.address,
+    Address.fromBytes(tokenConverter.destinationAddress),
+    event.params.tokenAddressIn,
+  );
+  destinationAmountEntity.amount = destinationAmountEntity.amount.plus(event.params.amountIn);
+  destinationAmountEntity.save();
+}
+
+export function handleAssetTransferredToDestination(event: AssetTransferredToDestination): void {
+  const destinationAmountEntity = getOrCreateDestinationAmount(
+    event.address,
+    event.params.receiver,
+    event.params.asset,
+  );
+  destinationAmountEntity.amount = destinationAmountEntity.amount.plus(event.params.amount);
+  destinationAmountEntity.save();
+}

subgraphs/protocol-reserve/src/operations/getOrCreate.ts

@@ -1,8 +1,13 @@
-import { Address } from '@graphprotocol/graph-ts';
+import { Address, BigInt } from '@graphprotocol/graph-ts';
 
 import { ERC20 } from '../../generated/RiskFundConverter/ERC20';
-import { Token, TokenConverter, TokenConverterConfig } from '../../generated/schema';
-import { getAssetId } from '../utilities/ids';
+import {
+  DestinationAmount,
+  Token,
+  TokenConverter,
+  TokenConverterConfig,
+} from '../../generated/schema';
+import { getAssetId, getDestinationAmountId, getTokenConverterId } from '../utilities/ids';
 import { createTokenConverter, createTokenConverterConfig } from './create';
 import { getTokenConverter, getTokenConverterConfig } from './get';
 
@@ -44,7 +49,7 @@ export function getOrCreateTokenConverterConfig(
 }
 
 /**
- * Creates and Token object with symbol and address
+ * Creates a Token object with symbol and address
  *
  * @param asset Address of the token
  * @returns Token
@@ -62,3 +67,28 @@ export function getOrCreateToken(asset: Address): Token {
   }
   return tokenEntity;
 }
+
+/**
+ * Creates a DestinationAmount object
+ *
+ * @param asset Address of the token
+ * @returns Token
+ */
+export function getOrCreateDestinationAmount(
+  tokenConverterAddress: Address,
+  destinationAddress: Address,
+  tokenAddress: Address,
+): DestinationAmount {
+  const entityId = getDestinationAmountId(tokenConverterAddress, destinationAddress, tokenAddress);
+  let destinationAmountEntity = DestinationAmount.load(entityId);
+
+  if (!destinationAmountEntity) {
+    destinationAmountEntity = new DestinationAmount(entityId);
+    destinationAmountEntity.tokenConverter = getTokenConverterId(tokenConverterAddress);
+    destinationAmountEntity.token = getOrCreateToken(tokenAddress).id;
+    destinationAmountEntity.amount = BigInt.zero();
+    destinationAmountEntity.address = destinationAddress;
+  }
+
+  return destinationAmountEntity;
+}

subgraphs/protocol-reserve/src/utilities/ids.ts

@@ -11,3 +11,9 @@ export const getTokenConverterConfigId = (
 ): Bytes => tokenConverterAddress.concat(tokenAddressIn).concat(tokenAddressOut);
 
 export const getAssetId = (asset: Address): Bytes => asset;
+
+export const getDestinationAmountId = (
+  tokenConverterAddress: Address,
+  destinationAddress: Address,
+  tokenAddress: Address,
+): Bytes => tokenConverterAddress.concat(destinationAddress).concat(tokenAddress);