chore: v301 updates (#88)

* chore: create test config with v301 market

* feat: helper function for v301 update block based on network of event

* feat: modify BalanceTransfer params based on update block

* feat: use dataSource import for current network

* feat: add mainnet v3 config

* fix: typing of update block check

* feat: add v3 mainnet link

* feat: add v3 mainnet collector

Author: defispartan

README.md

@@ -10,6 +10,7 @@ The Aave Protocol subgraphs index data from the protocol smart contracts, and ex
 
 ### Production networks
 
+- [ETH Mainnet V3](https://thegraph.com/hosted-service/subgraph/aave/protocol-v3)
 - [ETH Mainnet V2](https://thegraph.com/hosted-service/subgraph/aave/protocol-v2)
 - [Polygon V2](https://thegraph.com/hosted-service/subgraph/aave/aave-v2-matic)
 - [Avalanche V2](https://thegraph.com/hosted-service/subgraph/aave/protocol-v2-avalanche)

config/mainnet-v3.json

@@ -0,0 +1,9 @@
+{
+  "network": "mainnet",
+  "AaveOracleAddress": "0x54586bE62E3c3580375aE3723C145253060Ca0C2",
+  "AaveOracleStartBlock": 16291123,
+  "PoolAddressesProviderRegistryAddress": "0xbaA999AC55EAce41CcAE355c77809e68Bb345170",
+  "PoolAddressesProviderRegistryStartBlock": 16291006,
+  "RewardsControllerAddress": "0x8164Cc65827dcFe994AB23944CBC90e0aa80bFcb",
+  "RewardsControllerStartBlock": 16291136
+}

package.json

@@ -9,6 +9,7 @@
     "subgraph:build": "graph build",
     "subgraph:deploy:hosted": "graph deploy $SLUG --ipfs https://api.thegraph.com/ipfs/ --node https://api.thegraph.com/deploy/ --access-token $ACCESS_TOKEN",
     "deploy:hosted:mainnet": "VERSION=v2 BLOCKCHAIN=ethereum NETWORK=mainnet env-cmd npm run prepare:subgraph && SLUG=aave/protocol-v2 env-cmd npm run subgraph:deploy:hosted",
+    "deploy:hosted:mainnet-v3": "VERSION=v3 BLOCKCHAIN=v3 NETWORK=mainnet env-cmd npm run prepare:subgraph && SLUG=aave/protocol-v3 env-cmd npm run subgraph:deploy:hosted",
     "deploy:hosted:goerli-v2": "VERSION=v2 BLOCKCHAIN=ethereum NETWORK=goerli env-cmd npm run prepare:subgraph && SLUG=aave/protocol-v2-goerli env-cmd npm run subgraph:deploy:hosted",
     "deploy:hosted:goerli-v3": "VERSION=v3 BLOCKCHAIN=v3 NETWORK=goerli env-cmd npm run prepare:subgraph && SLUG=aave/protocol-v3-goerli env-cmd npm run subgraph:deploy:hosted",
     "deploy:hosted:mainnet-arc": "VERSION=v2-arc BLOCKCHAIN=ethereum-arc NETWORK=mainnet env-cmd npm run prepare:subgraph && SLUG=aave/aave-arc env-cmd npm run subgraph:deploy:hosted",
@@ -30,7 +31,7 @@
     "deploy:hosted:harmony-v3": "VERSION=v3 BLOCKCHAIN=v3 NETWORK=harmony env-cmd npm run prepare:subgraph && SLUG=aave/protocol-v3-harmony env-cmd npm run subgraph:deploy:hosted",
     "deploy:hosted:v2": "npm run deploy:hosted:mainnet && npm run deploy:hosted:polygon-v2 && npm run deploy:hosted:avalanche-v2",
     "deploy:hosted:v2-testnet": "npm run deploy:hosted:goerli-v2 && npm run deploy:hosted:mumbai-v2 && npm run deploy:hosted:fuji-v2",
-    "deploy:hosted:v3": "npm run deploy:hosted:avalanche-v3 && npm run deploy:hosted:polygon-v3 && npm run deploy:hosted:optimism-v3 && npm run deploy:hosted:fantom-v3 && npm run deploy:hosted:arbitrum-v3 && npm run deploy:hosted:harmony-v3",
+    "deploy:hosted:v3": "npm run deploy:hosted:avalanche-v3 && npm run deploy:hosted:polygon-v3 && npm run deploy:hosted:optimism-v3 && npm run deploy:hosted:fantom-v3 && npm run deploy:hosted:arbitrum-v3 && npm run deploy:hosted:harmony-v3 && npm run deploy:hosted:mainnet-v3",
     "deploy:hosted:v3-testnet": "npm run deploy:hosted:goerli-v3 && npm run deploy:hosted:mumbai-v3 && npm run deploy:hosted:fuji-v3 && npm run deploy:hosted:arbitrum-goerli && npm run deploy:hosted:optimism-goerli && npm run deploy:hosted:fantom-testnet"
   },
   "repository": {

src/mapping/tokenization/tokenization-v3.ts

@@ -33,11 +33,12 @@ import {
   getOrInitReserveParamsHistoryItem,
   getPoolByContract,
 } from '../../helpers/v3/initializers';
-import { zeroBI } from '../../utils/converters';
+import { getUpdateBlock, zeroBI } from '../../utils/converters';
 import { calculateUtilizationRate } from '../../helpers/reserve-logic';
 import { Address, BigInt, Bytes, ethereum, log } from '@graphprotocol/graph-ts';
 import { rayDiv, rayMul } from '../../helpers/math';
 import { getHistoryEntityId } from '../../utils/id-generation';
+import { dataSource } from '@graphprotocol/graph-ts';
 
 // TODO: check if we need to add stuff to history
 function saveUserReserveAHistory(
@@ -170,8 +171,9 @@ function tokenBurn(
   poolReserve.lifetimeWithdrawals = poolReserve.lifetimeWithdrawals.plus(userBalanceChange);
 
   if (userReserve.usageAsCollateralEnabledOnUser) {
-    poolReserve.totalLiquidityAsCollateral =
-      poolReserve.totalLiquidityAsCollateral.minus(userBalanceChange);
+    poolReserve.totalLiquidityAsCollateral = poolReserve.totalLiquidityAsCollateral.minus(
+      userBalanceChange
+    );
   }
   saveReserve(poolReserve, event);
 
@@ -216,7 +218,8 @@ function tokenMint(
     onBehalf.toHexString() != '0xBe85413851D195fC6341619cD68BfDc26a25b928'.toLowerCase() &&
     onBehalf.toHexString() != '0x5ba7fd868c40c16f7aDfAe6CF87121E13FC2F7a0'.toLowerCase() &&
     onBehalf.toHexString() != '0x8A020d92D6B119978582BE4d3EdFdC9F7b28BF31'.toLowerCase() &&
-    onBehalf.toHexString() != '0x053D55f9B5AF8694c503EB288a1B7E552f590710'.toLowerCase()
+    onBehalf.toHexString() != '0x053D55f9B5AF8694c503EB288a1B7E552f590710'.toLowerCase() &&
+    onBehalf.toHexString() != '0x464C71f6c2F760DdA6093dCB91C24c39e5d6e18c'.toLowerCase() 
   ) {
     let userReserve = getOrInitUserReserve(onBehalf, aToken.underlyingAssetAddress, event);
     let calculatedAmount = rayDiv(userBalanceChange, index);
@@ -241,14 +244,16 @@ function tokenMint(
     poolReserve.lifetimeLiquidity = poolReserve.lifetimeLiquidity.plus(userBalanceChange);
 
     if (userReserve.usageAsCollateralEnabledOnUser) {
-      poolReserve.totalLiquidityAsCollateral =
-        poolReserve.totalLiquidityAsCollateral.plus(userBalanceChange);
+      poolReserve.totalLiquidityAsCollateral = poolReserve.totalLiquidityAsCollateral.plus(
+        userBalanceChange
+      );
     }
     saveReserve(poolReserve, event);
     saveUserReserveAHistory(userReserve, event, index);
   } else {
-    poolReserve.lifetimeReserveFactorAccrued =
-      poolReserve.lifetimeReserveFactorAccrued.plus(userBalanceChange);
+    poolReserve.lifetimeReserveFactorAccrued = poolReserve.lifetimeReserveFactorAccrued.plus(
+      userBalanceChange
+    );
     saveReserve(poolReserve, event);
     // log.error('Minting to treasuey {} an amount of: {}', [from.toHexString(), value.toString()]);
   }
@@ -275,8 +280,15 @@ export function handleATokenMint(event: ATokenMint): void {
 }
 
 export function handleBalanceTransfer(event: BalanceTransfer): void {
-  tokenBurn(event, event.params.from, event.params.value, BigInt.fromI32(0), event.params.index);
-  tokenMint(event, event.params.to, event.params.value, BigInt.fromI32(0), event.params.index);
+  let balanceTransferValue = event.params.value;
+  const network = dataSource.network();
+  const v301UpdateBlock = getUpdateBlock(network);
+  if (v301UpdateBlock !== -1 && event.block.number.toU32() > v301UpdateBlock) {
+    balanceTransferValue = balanceTransferValue.times(event.params.index);
+  }
+
+  tokenBurn(event, event.params.from, balanceTransferValue, BigInt.fromI32(0), event.params.index);
+  tokenMint(event, event.params.to, balanceTransferValue, BigInt.fromI32(0), event.params.index);
 
   // TODO: is this really necessary(from v1)? if we transfer aToken we are not moving the collateral (underlying token)
   let aToken = getOrInitSubToken(event.address);
@@ -389,8 +401,9 @@ export function handleVariableTokenMint(event: VTokenMint): void {
   poolReserve.totalScaledVariableDebt = poolReserve.totalScaledVariableDebt.plus(calculatedAmount);
   poolReserve.totalCurrentVariableDebt = rayMul(poolReserve.totalScaledVariableDebt, index);
 
-  poolReserve.lifetimeScaledVariableDebt =
-    poolReserve.lifetimeScaledVariableDebt.plus(calculatedAmount);
+  poolReserve.lifetimeScaledVariableDebt = poolReserve.lifetimeScaledVariableDebt.plus(
+    calculatedAmount
+  );
   poolReserve.lifetimeCurrentVariableDebt = rayMul(poolReserve.lifetimeScaledVariableDebt, index);
 
   poolReserve.availableLiquidity = poolReserve.availableLiquidity.minus(userBalanceChange);

src/utils/converters.ts

@@ -123,7 +123,7 @@ export function byteArrayFromHex(s: string): ByteArray {
     throw new TypeError('Hex string must have an even number of characters');
   }
   let out = new Uint8Array(s.length / 2);
-  for (var i = 0; i < s.length; i += 2) {
+  for (let i = 0; i < s.length; i += 2) {
     out[i / 2] = parseInt(s.substring(i, i + 2), 16) as u32;
   }
 
@@ -191,3 +191,13 @@ export function generateSymbol(description: string): string {
   let symbolArr = description.split(' / ');
   return convertToLowerCase(symbolArr[0] + '-' + symbolArr[1]);
 }
+
+// returns block of market update to v3.0.1, or null if no upgrade
+export function getUpdateBlock(network: string): u32 {
+  let updateBlock = -1;
+  if (network === 'mainnet') {
+    updateBlock = 0;
+  }
+
+  return updateBlock;
+}