veION UI

.github/workflows/package-contracts-test.yaml

@@ -117,4 +117,4 @@ jobs:
 
       - name: Run forge tests locally
         run: yarn workspace @ionicprotocol/contracts forge test -vv --no-match-contract '${{ env.EXCLUDE_TESTS }}|${{ env.FLAKY_TESTS }}|${{ env.SLOW_TESTS }}'
-        continue-on-error: true  # Skip the job on test failure
+        continue-on-error: true  # Skip the job on test failure

.gitmodules

@@ -1,30 +1,30 @@
-[submodule "packages/contracts/lib/forge-std"]
-path = packages/contracts/lib/forge-std
-url = https://github.com/brockelmore/forge-std
-[submodule "packages/contracts/lib/openzeppelin-contracts-upgradeable"]
-path = packages/contracts/lib/openzeppelin-contracts-upgradeable
-url = https://github.com/OpenZeppelin/openzeppelin-contracts-upgradeable
-[submodule "packages/contracts/lib/solmate"]
-path = packages/contracts/lib/solmate
-url = https://github.com/rari-capital/solmate
-[submodule "packages/contracts/lib/openzeppelin-contracts"]
-path = packages/contracts/lib/openzeppelin-contracts
-url = https://github.com/OpenZeppelin/openzeppelin-contracts
-[submodule "packages/contracts/lib/pyth-sdk-solidity"]
-path = packages/contracts/lib/pyth-sdk-solidity
-url = https://github.com/pyth-network/pyth-sdk-solidity
-[submodule "packages/contracts/lib/solidity-bytes-utils"]
-path = packages/contracts/lib/solidity-bytes-utils
-url = https://github.com/GNSPS/solidity-bytes-utils
-[submodule "packages/contracts/lib/ops"]
-path = packages/contracts/lib/ops
-url = https://github.com/gelatodigital/ops
-[submodule "packages/contracts/lib/adrastia-periphery"]
-path = packages/contracts/lib/adrastia-periphery
-url = https://github.com/adrastia-oracle/adrastia-periphery
-[submodule "packages/contracts/lib/devtools"]
-	path = packages/contracts/lib/devtools
-	url = https://github.com/LayerZero-Labs/devtools
-[submodule "packages/contracts/lib/layerzero-v2"]
-	path = packages/contracts/lib/layerzero-v2
-	url = https://github.com/LayerZero-Labs/layerzero-v2
+[submodule "packages/contracts/lib/forge-std"]
+path = packages/contracts/lib/forge-std
+url = https://github.com/brockelmore/forge-std
+[submodule "packages/contracts/lib/openzeppelin-contracts-upgradeable"]
+path = packages/contracts/lib/openzeppelin-contracts-upgradeable
+url = https://github.com/OpenZeppelin/openzeppelin-contracts-upgradeable
+[submodule "packages/contracts/lib/solmate"]
+path = packages/contracts/lib/solmate
+url = https://github.com/rari-capital/solmate
+[submodule "packages/contracts/lib/openzeppelin-contracts"]
+path = packages/contracts/lib/openzeppelin-contracts
+url = https://github.com/OpenZeppelin/openzeppelin-contracts
+[submodule "packages/contracts/lib/pyth-sdk-solidity"]
+path = packages/contracts/lib/pyth-sdk-solidity
+url = https://github.com/pyth-network/pyth-sdk-solidity
+[submodule "packages/contracts/lib/solidity-bytes-utils"]
+path = packages/contracts/lib/solidity-bytes-utils
+url = https://github.com/GNSPS/solidity-bytes-utils
+[submodule "packages/contracts/lib/ops"]
+path = packages/contracts/lib/ops
+url = https://github.com/gelatodigital/ops
+[submodule "packages/contracts/lib/adrastia-periphery"]
+path = packages/contracts/lib/adrastia-periphery
+url = https://github.com/adrastia-oracle/adrastia-periphery
+[submodule "packages/contracts/lib/devtools"]
+	path = packages/contracts/lib/devtools
+	url = https://github.com/LayerZero-Labs/devtools
+[submodule "packages/contracts/lib/layerzero-v2"]
+	path = packages/contracts/lib/layerzero-v2
+	url = https://github.com/LayerZero-Labs/layerzero-v2

cache/solidity-files-cache.json

@@ -0,0 +1,14 @@
+{
+  "_format": "ethers-rs-sol-cache-3",
+  "paths": {
+    "artifacts": "out",
+    "build_infos": "out\\build-info",
+    "sources": "src",
+    "tests": "test",
+    "scripts": "script",
+    "libraries": [
+      "lib"
+    ]
+  },
+  "files": {}
+}

package.json

@@ -36,6 +36,8 @@
   "dependencies": {
     "@next/react-dev-overlay": "^14.1.4",
     "@resolver-engine/core": "^0.3.3",
+    "@tanstack/react-table": "^8.20.5",
+    "lucide-react": "^0.454.0",
     "next": "^14.2.4"
   },
   "scripts": {

packages/contracts/contracts/EmissionsManager.sol

@@ -0,0 +1,141 @@
+// SPDX-License-Identifier: UNLICENSED
+pragma solidity >=0.8.0;
+
+import { ERC20 } from "solmate/tokens/ERC20.sol";
+import { SafeTransferLib } from "solmate/utils/SafeTransferLib.sol";
+
+import { Ownable2StepUpgradeable } from "openzeppelin-contracts-upgradeable/contracts/access/Ownable2StepUpgradeable.sol";
+import { IonicFlywheelCore } from "./ionic/strategies/flywheel/IonicFlywheelCore.sol";
+import { IonicComptroller } from "./compound/ComptrollerInterface.sol";
+import { BasePriceOracle } from "./oracles/BasePriceOracle.sol";
+import { ICErc20 } from "./compound/CTokenInterfaces.sol";
+import { PoolDirectory } from "./PoolDirectory.sol";
+import {IEmissionsManager} from "./IEmissionsManager.sol";
+import { IveION } from "./veION/interfaces/IveION.sol";
+
+interface Oracle {
+  function getUnderlyingPrice(address) external returns (uint256);
+}
+
+contract EmissionsManager is IEmissionsManager, Ownable2StepUpgradeable {
+  using SafeTransferLib for ERC20;
+
+  address poolLens;
+  address protocalAddress;
+  PoolDirectory public fpd;
+  ERC20 rewardToken;
+  IveION veION;
+  mapping(address => bool) isBlacklisted;
+
+  function initialize(PoolDirectory _fpd, address _protocalAddress, ERC20 _rewardToken) public initializer {
+    __Ownable2Step_init();
+    protocalAddress = _protocalAddress;
+    fpd = _fpd;
+    rewardToken = _rewardToken;
+  }
+
+  function setVeIon(IveION _veIon) external onlyOwner {
+    veION = _veIon;
+  }
+
+  function _getUserTotalCollateral(address _user) internal view returns(uint256) {
+    uint256 totalColateralInETH = 0;
+    (, PoolDirectory.Pool[] memory pools) = fpd.getActivePools();
+    for (uint256 i = 0; i < pools.length; i++) {
+      IonicComptroller comptroller = IonicComptroller(pools[i].comptroller);
+      BasePriceOracle oracle = comptroller.oracle();
+      ICErc20[] memory cTokens = comptroller.getAssetsIn(_user);
+      for (uint256 j = 0; j < cTokens.length; j++) {
+        uint256 supplyBalance = cTokens[j].balanceOfUnderlying(_user);
+        uint256 collateralInETH = supplyBalance * oracle.getUnderlyingPrice(cTokens[j]) / 1e18;
+        totalColateralInETH += collateralInETH;
+      }
+    }
+    return totalColateralInETH;
+  }
+
+  function getUserTotalCollateral(address _user) external view returns(uint256) {
+    return _getUserTotalCollateral(_user);
+  }
+
+  function checkCollateralRatio(address _user) internal view returns(bool) {
+    uint256 userCollateralValue = _getUserTotalCollateral(_user);
+    uint256 userLPValue = veION.getTotalEthValueOfTokens(_user);
+    if (userLPValue * 1000 / userCollateralValue >= 25) {
+      return true;
+    }
+    else return false;
+  }
+
+  function reportUser(address _user) external returns(bool) {
+    if (!checkCollateralRatio(_user)) {
+      isBlacklisted[_user] = true;
+      blacklistUserAndClaimEmissions(_user);
+      return true;
+    }
+    else return false;
+  }
+
+  function whitelistUser(address _user) external returns(bool) {
+    if (checkCollateralRatio(_user)) {
+      isBlacklisted[_user] = false;
+      (, PoolDirectory.Pool[] memory pools) = fpd.getActivePools();
+      for (uint256 i = 0; i < pools.length; i++) {
+        IonicComptroller comptroller = IonicComptroller(pools[i].comptroller);
+        ICErc20[] memory cTokens = comptroller.getAssetsIn(_user);
+        for (uint256 j = 0; j < cTokens.length; j++) {
+          address[] memory flywheelAddresses = comptroller.getAccruingFlywheels();
+          for (uint256 k = 0; k < flywheelAddresses.length; k++) {
+            IonicFlywheelCore flywheel = IonicFlywheelCore(flywheelAddresses[k]);
+            if (address(flywheel.rewardToken()) == address(rewardToken)) {
+              flywheel.whitelistUser(ERC20(address(cTokens[j])), _user);
+              flywheel.accrue(ERC20(address(cTokens[j])), _user);
+            }
+          }
+        }
+      }
+      return true;
+    }
+    else return false;
+  }
+
+  function isUserBlacklisted(address _user) external view returns (bool) {
+    return isBlacklisted[_user];
+  }
+
+  function blacklistUserAndClaimEmissions(address user) public returns (uint256 rewardsClaimed) {
+    uint256 balanceBefore = ERC20(rewardToken).balanceOf(address(this));
+    (, PoolDirectory.Pool[] memory pools) = fpd.getActivePools();
+    for (uint256 i = 0; i < pools.length; i++) {
+      IonicComptroller comptroller = IonicComptroller(pools[i].comptroller);
+      ERC20[] memory markets;
+      {
+        ICErc20[] memory cerc20s = comptroller.getAllMarkets();
+        markets = new ERC20[](cerc20s.length);
+        for (uint256 j = 0; j < cerc20s.length; j++) {
+          markets[j] = ERC20(address(cerc20s[j]));
+        }
+      }
+
+      address[] memory flywheelAddresses = comptroller.getAccruingFlywheels();
+      for (uint256 k = 0; k < flywheelAddresses.length; k++) {
+        IonicFlywheelCore flywheel = IonicFlywheelCore(flywheelAddresses[k]);
+        if (address(flywheel.rewardToken()) == address(rewardToken)) {
+          for (uint256 m = 0; m < markets.length; m++) {
+            flywheel.accrue(markets[m], user);
+            flywheel.updateBlacklistBalances(markets[m], user);
+          }
+          flywheel.takeRewardsFromUser(user, address(this));
+        }
+      }
+    }
+
+    uint256 balanceAfter = ERC20(rewardToken).balanceOf(address(this));
+    uint256 totalClaimed = balanceAfter - balanceBefore;
+    if (totalClaimed > 0) {
+      rewardToken.safeTransferFrom(address(this), msg.sender, totalClaimed * 80 / 100);
+      rewardToken.safeTransferFrom(address(this), protocalAddress, totalClaimed * 20 / 100);
+    }
+    return totalClaimed;
+  }
+} 

packages/contracts/contracts/IEmissionsManager.sol

@@ -0,0 +1,6 @@
+// SPDX-License-Identifier: UNLICENSED
+pragma solidity >=0.8.0;
+
+interface IEmissionsManager {
+    function isUserBlacklisted(address _user) external returns (bool);
+}

packages/contracts/contracts/ionic/strategies/flywheel/IonicFlywheel.sol

@@ -10,12 +10,15 @@ contract IonicFlywheel is IonicFlywheelCore, IIonicFlywheel {
   bool public constant isFlywheel = true;
 
   function flywheelPreSupplierAction(address market, address supplier) external {
+    _updateBlacklistBalances(ERC20(market), supplier);
     accrue(ERC20(market), supplier);
   }
 
   function flywheelPreBorrowerAction(address market, address borrower) external {}
 
   function flywheelPreTransferAction(address market, address src, address dst) external {
+    _updateBlacklistBalances(ERC20(market), src);
+    _updateBlacklistBalances(ERC20(market), dst);
     accrue(ERC20(market), src, dst);
   }
 

packages/contracts/contracts/ionic/strategies/flywheel/IonicFlywheelBorrow.sol

@@ -12,6 +12,7 @@ contract IonicFlywheelBorrow is IonicFlywheelCore, IIonicFlywheel {
   function flywheelPreSupplierAction(address market, address supplier) external {}
 
   function flywheelPreBorrowerAction(address market, address borrower) external {
+    _updateBlacklistBalances(ERC20(market), borrower);
     accrue(ERC20(market), borrower);
   }