Static pool reward

src/amount.h

@@ -79,6 +79,7 @@ static constexpr CAmount COIN = 100000000;
 static constexpr CAmount CENT = 1000000;
 static constexpr int64_t WEI_IN_GWEI    = 1000000000;
 static constexpr int64_t CAMOUNT_TO_GWEI = 10;
+static constexpr CAmount HIGH_PRECISION_SCALER = COIN * COIN;  // 1,0000,0000,0000,0000
 
 //Converts the given value to decimal format string with COIN precision.
 inline std::string GetDecimalString(CAmount nValue)

src/dfi/loan.h

@@ -328,8 +328,6 @@ inline auto InterestAddition = [](const CInterestAmount &a, const CInterestAmoun
     return interest;
 };
 
-static const CAmount HIGH_PRECISION_SCALER = COIN * COIN;  // 1,0000,0000,0000,0000
-
 CAmount TotalInterest(const CInterestRateV3 &rate, const uint32_t height);
 CInterestAmount TotalInterestCalculation(const CInterestRateV3 &rate, const uint32_t height);
 CAmount CeilInterest(const base_uint<128> &value, uint32_t height);

src/dfi/masternodes.cpp

@@ -969,17 +969,29 @@ bool CCustomCSView::CalculateOwnerRewards(const CScript &owner, uint32_t targetH
             return true;  // no share or target height is before a pool share' one
         }
         auto onLiquidity = [&]() -> CAmount { return GetBalance(owner, poolId).nValue; };
-        auto beginHeight = std::max(*height, balanceHeight);
-        CalculatePoolRewards(
-            poolId, onLiquidity, beginHeight, targetHeight, [&](RewardType, CTokenAmount amount, uint32_t height) {
-                auto res = AddBalance(owner, amount);
-                if (!res) {
-                    LogPrintf("Pool rewards: can't update balance of %s: %s, height %ld\n",
-                              owner.GetHex(),
-                              res.msg,
-                              targetHeight);
-                }
-            });
+        const auto beginHeight = std::max(*height, balanceHeight);
+        auto onReward = [&](RewardType, const CTokenAmount &amount, const uint32_t height) {
+            if (auto res = AddBalance(owner, amount); !res) {
+                LogPrintf(
+                    "Pool rewards: can't update balance of %s: %s, height %ld\n", owner.GetHex(), res.msg, height);
+            }
+        };
+
+        if (beginHeight < Params().GetConsensus().DF24Height) {
+            // Calculate just up to the fork height
+            const auto targetNewHeight = targetHeight >= Params().GetConsensus().DF24Height
+                                             ? Params().GetConsensus().DF24Height - 1
+                                             : targetHeight;
+            CalculatePoolRewards(poolId, onLiquidity, beginHeight, targetNewHeight, onReward);
+        }
+
+        if (targetHeight >= Params().GetConsensus().DF24Height) {
+            // Calculate from the fork height
+            const auto beginNewHeight =
+                beginHeight < Params().GetConsensus().DF24Height ? Params().GetConsensus().DF24Height : beginHeight;
+            CalculateStaticPoolRewards(onLiquidity, onReward, poolId.v, beginNewHeight, targetHeight);
+        }
+
         return true;
     });
 

src/dfi/poolpairs.h

@@ -225,6 +225,36 @@ struct PoolShareKey {
     }
 };
 
+struct TotalRewardPerShareKey {
+    uint32_t height;
+    uint32_t poolID;
+
+    ADD_SERIALIZE_METHODS;
+
+    template <typename Stream, typename Operation>
+    inline void SerializationOp(Stream &s, Operation ser_action) {
+        READWRITE(WrapBigEndian(height));
+        READWRITE(WrapBigEndian(poolID));
+    }
+};
+
+struct TotalCommissionPerShareValue {
+    uint32_t tokenA;
+    uint32_t tokenB;
+    arith_uint256 commissionA;
+    arith_uint256 commissionB;
+
+    ADD_SERIALIZE_METHODS;
+
+    template <typename Stream, typename Operation>
+    inline void SerializationOp(Stream &s, Operation ser_action) {
+        READWRITE(tokenA);
+        READWRITE(tokenB);
+        READWRITE(commissionA);
+        READWRITE(commissionB);
+    }
+};
+
 struct LoanTokenAverageLiquidityKey {
     uint32_t sourceID;
     uint32_t destID;
@@ -320,6 +350,12 @@ class CPoolPairView : public virtual CStorageView {
                               uint32_t end,
                               std::function<void(RewardType, CTokenAmount, uint32_t)> onReward);
 
+    void CalculateStaticPoolRewards(std::function<CAmount()> onLiquidity,
+                                    std::function<void(RewardType, CTokenAmount, uint32_t)> onReward,
+                                    const uint32_t poolID,
+                                    const uint32_t beginHeight,
+                                    const uint32_t endHeight);
+
     Res SetLoanDailyReward(const uint32_t height, const CAmount reward);
     Res SetDailyReward(uint32_t height, CAmount reward);
     Res SetRewardPct(DCT_ID const &poolId, uint32_t height, CAmount rewardPct);
@@ -349,6 +385,17 @@ class CPoolPairView : public virtual CStorageView {
         std::function<bool(const LoanTokenAverageLiquidityKey &key, const uint64_t liquidity)> callback,
         const LoanTokenAverageLiquidityKey start = LoanTokenAverageLiquidityKey{});
 
+    bool SetTotalRewardPerShare(const TotalRewardPerShareKey &key, const arith_uint256 &totalReward);
+    arith_uint256 GetTotalRewardPerShare(const TotalRewardPerShareKey &totalReward) const;
+    bool SetTotalLoanRewardPerShare(const TotalRewardPerShareKey &key, const arith_uint256 &totalReward);
+    arith_uint256 GetTotalLoanRewardPerShare(const TotalRewardPerShareKey &totalReward) const;
+    bool SetTotalCustomRewardPerShare(const TotalRewardPerShareKey &key,
+                                      const std::map<uint32_t, arith_uint256> &customRewards);
+    std::map<uint32_t, arith_uint256> GetTotalCustomRewardPerShare(const TotalRewardPerShareKey &key) const;
+    bool SetTotalCommissionPerShare(const TotalRewardPerShareKey &key,
+                                    const TotalCommissionPerShareValue &totalCommission);
+    TotalCommissionPerShareValue GetTotalCommissionPerShare(const TotalRewardPerShareKey &key) const;
+
     // tags
     struct ByID {
         static constexpr uint8_t prefix() { return 'i'; }
@@ -401,6 +448,21 @@ class CPoolPairView : public virtual CStorageView {
     struct ByLoanTokenLiquidityAverage {
         static constexpr uint8_t prefix() { return '+'; }
     };
+    struct ByTotalRewardPerShare {
+        static constexpr uint8_t prefix() { return '-'; }
+    };
+
+    struct ByTotalLoanRewardPerShare {
+        static constexpr uint8_t prefix() { return '='; }
+    };
+
+    struct ByTotalCustomRewardPerShare {
+        static constexpr uint8_t prefix() { return '_'; }
+    };
+
+    struct ByTotalCommissionPerShare {
+        static constexpr uint8_t prefix() { return '/'; }
+    };
 };
 
 struct CLiquidityMessage {