feat: incentive manager

Cargo.toml

@@ -11,6 +11,7 @@ members = [
   "contracts/liquidity_hub/pool-manager",
   "contracts/liquidity_hub/epoch-manager",
   "contracts/liquidity_hub/vault-manager",
+  "contracts/liquidity_hub/incentive-manager",
 ]
 
 [workspace.package]
@@ -64,6 +65,7 @@ fee-distributor-mock = { path = "./contracts/liquidity_hub/fee-distributor-mock"
 incentive-factory = { path = "./contracts/liquidity_hub/pool-network/incentive_factory" }
 terraswap-token = { path = "./contracts/liquidity_hub/pool-network/terraswap_token" }
 terraswap-pair = { path = "./contracts/liquidity_hub/pool-network/terraswap_pair" }
+epoch-manager = { path = "./contracts/liquidity_hub/epoch-manager" }
 
 [workspace.metadata.dylint]
 libraries = [{ git = "https://github.com/0xFable/cw-lint" }]

contracts/liquidity_hub/epoch-manager/Cargo.toml

@@ -34,3 +34,4 @@ semver.workspace = true
 thiserror.workspace = true
 white-whale-std.workspace = true
 cw-controllers.workspace = true
+cw-utils.workspace = true

contracts/liquidity_hub/epoch-manager/src/commands.rs

@@ -27,7 +27,9 @@ pub(crate) fn remove_hook(
 }
 
 /// Creates a new epoch.
-pub fn create_epoch(deps: DepsMut, env: Env) -> Result<Response, ContractError> {
+pub fn create_epoch(deps: DepsMut, env: Env, info: MessageInfo) -> Result<Response, ContractError> {
+    cw_utils::nonpayable(&info)?;
+
     let mut current_epoch = query_current_epoch(deps.as_ref())?.epoch;
     let config = CONFIG.load(deps.storage)?;
 

contracts/liquidity_hub/epoch-manager/src/contract.rs

@@ -13,7 +13,7 @@ use crate::state::{ADMIN, CONFIG, EPOCHS};
 use crate::{commands, queries};
 
 // version info for migration info
-const CONTRACT_NAME: &str = "white_whale-epoch-manager";
+const CONTRACT_NAME: &str = "white-whale_epoch-manager";
 const CONTRACT_VERSION: &str = env!("CARGO_PKG_VERSION");
 
 #[entry_point]
@@ -69,7 +69,7 @@ pub fn execute(
         ExecuteMsg::RemoveHook { contract_addr } => {
             commands::remove_hook(deps, info, api, &contract_addr)
         }
-        ExecuteMsg::CreateEpoch {} => commands::create_epoch(deps, env),
+        ExecuteMsg::CreateEpoch {} => commands::create_epoch(deps, env, info),
         ExecuteMsg::UpdateConfig {
             owner,
             epoch_config,

contracts/liquidity_hub/epoch-manager/src/error.rs

@@ -1,5 +1,6 @@
 use cosmwasm_std::StdError;
 use cw_controllers::{AdminError, HookError};
+use cw_utils::PaymentError;
 use semver::Version;
 use thiserror::Error;
 
@@ -17,6 +18,9 @@ pub enum ContractError {
     #[error("The epoch id has overflowed.")]
     EpochOverflow,
 
+    #[error("{0}")]
+    PaymentError(#[from] PaymentError),
+
     #[error("Semver parsing error: {0}")]
     SemVer(String),
 

contracts/liquidity_hub/epoch-manager/src/state.rs

@@ -1,8 +1,8 @@
 use cw_controllers::{Admin, Hooks};
 use cw_storage_plus::{Item, Map};
-use white_whale_std::epoch_manager::epoch_manager::{Config, EpochV2};
+use white_whale_std::epoch_manager::epoch_manager::{Config, Epoch};
 
 pub const CONFIG: Item<Config> = Item::new("config");
 pub const ADMIN: Admin = Admin::new("admin");
 pub const HOOKS: Hooks = Hooks::new("hooks");
-pub const EPOCHS: Map<&[u8], EpochV2> = Map::new("epochs");
+pub const EPOCHS: Map<&[u8], Epoch> = Map::new("epochs");

contracts/liquidity_hub/epoch-manager/tests/common.rs

@@ -4,7 +4,7 @@ use cosmwasm_std::{DepsMut, MessageInfo, Response, Uint64};
 use epoch_manager::contract::{execute, instantiate};
 use epoch_manager::ContractError;
 use white_whale_std::epoch_manager::epoch_manager::{
-    EpochConfig, EpochV2, ExecuteMsg, InstantiateMsg,
+    Epoch, EpochConfig, ExecuteMsg, InstantiateMsg,
 };
 
 /// Mocks contract instantiation.
@@ -14,7 +14,7 @@ pub(crate) fn mock_instantiation(
 ) -> Result<Response, ContractError> {
     let current_time = mock_env().block.time;
     let msg = InstantiateMsg {
-        start_epoch: EpochV2 {
+        start_epoch: Epoch {
             id: 123,
             start_time: current_time,
         },

contracts/liquidity_hub/epoch-manager/tests/epoch.rs

@@ -3,7 +3,7 @@ use cosmwasm_std::testing::{mock_env, mock_info};
 
 use epoch_manager::contract::{execute, query};
 use epoch_manager::ContractError;
-use white_whale_std::epoch_manager::epoch_manager::{EpochResponse, EpochV2, ExecuteMsg, QueryMsg};
+use white_whale_std::epoch_manager::epoch_manager::{Epoch, EpochResponse, ExecuteMsg, QueryMsg};
 use white_whale_std::epoch_manager::hooks::EpochChangedHookMsg;
 use white_whale_std::pool_network::mock_querier::mock_dependencies;
 
@@ -29,7 +29,7 @@ fn create_new_epoch_successfully() {
     let query_res = query(deps.as_ref(), mock_env(), QueryMsg::CurrentEpoch {}).unwrap();
     let epoch_response: EpochResponse = from_json(query_res).unwrap();
 
-    let current_epoch = EpochV2 {
+    let current_epoch = Epoch {
         id: 124,
         start_time: next_epoch_time,
     };
@@ -55,7 +55,7 @@ fn create_new_epoch_successfully() {
 
     assert_eq!(
         epoch_response.epoch,
-        EpochV2 {
+        Epoch {
             id: 123,
             start_time: next_epoch_time.minus_nanos(86400),
         }

contracts/liquidity_hub/epoch-manager/tests/instantiate.rs

@@ -4,7 +4,7 @@ use cosmwasm_std::{from_json, Addr, Uint64};
 use epoch_manager::contract::{instantiate, query};
 use epoch_manager::ContractError;
 use white_whale_std::epoch_manager::epoch_manager::{
-    ConfigResponse, EpochConfig, EpochV2, InstantiateMsg, QueryMsg,
+    ConfigResponse, Epoch, EpochConfig, InstantiateMsg, QueryMsg,
 };
 use white_whale_std::pool_network::mock_querier::mock_dependencies;
 
@@ -17,7 +17,7 @@ fn instantiation_successful() {
     let current_time = mock_env().block.time;
     let info = mock_info("owner", &[]);
     let msg = InstantiateMsg {
-        start_epoch: EpochV2 {
+        start_epoch: Epoch {
             id: 123,
             start_time: current_time,
         },
@@ -48,7 +48,7 @@ fn instantiation_unsuccessful() {
     let current_time = mock_env().block.time;
     let info = mock_info("owner", &[]);
     let msg = InstantiateMsg {
-        start_epoch: EpochV2 {
+        start_epoch: Epoch {
             id: 123,
             start_time: current_time.minus_days(1),
         },
@@ -65,7 +65,7 @@ fn instantiation_unsuccessful() {
     }
 
     let msg = InstantiateMsg {
-        start_epoch: EpochV2 {
+        start_epoch: Epoch {
             id: 123,
             start_time: current_time.plus_days(1),
         },

contracts/liquidity_hub/incentive-manager/.cargo/config

@@ -0,0 +1,4 @@
+[alias]
+wasm = "build --release --lib --target wasm32-unknown-unknown"
+unit-test = "test --lib"
+schema = "run --bin schema"

contracts/liquidity_hub/incentive-manager/.editorconfig

@@ -0,0 +1,11 @@
+root = true
+
+[*]
+indent_style = space
+indent_size = 2
+charset = utf-8
+trim_trailing_whitespace = true
+insert_final_newline = true
+
+[*.rs]
+indent_size = 4

contracts/liquidity_hub/incentive-manager/.gitignore

@@ -0,0 +1,16 @@
+# Build results
+/target
+/schema
+
+# Cargo+Git helper file (https://github.com/rust-lang/cargo/blob/0.44.1/src/cargo/sources/git/utils.rs#L320-L327)
+.cargo-ok
+
+# Text file backups
+**/*.rs.bk
+
+# macOS
+.DS_Store
+
+# IDEs
+*.iml
+.idea

contracts/liquidity_hub/incentive-manager/Cargo.toml

@@ -0,0 +1,45 @@
+[package]
+name = "incentive-manager"
+version = "0.1.0"
+authors = ["Kerber0x <[email protected]>"]
+edition.workspace = true
+description = "The Incentive Manager is a contract that allows to manage multiple pool incentives in a single contract."
+license.workspace = true
+repository.workspace = true
+homepage.workspace = true
+documentation.workspace = true
+publish.workspace = true
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[lib]
+crate-type = ["cdylib", "rlib"]
+
+[features]
+injective = ["white-whale-std/injective"]
+token_factory = ["white-whale-std/token_factory"]
+osmosis_token_factory = ["white-whale-std/osmosis_token_factory"]
+# for more explicit tests, cargo test --features=backtraces
+backtraces = ["cosmwasm-std/backtraces"]
+
+[dependencies]
+cosmwasm-schema.workspace = true
+cosmwasm-std.workspace = true
+cw-storage-plus.workspace = true
+cw2.workspace = true
+cw20.workspace = true
+cw20-base.workspace = true
+schemars.workspace = true
+semver.workspace = true
+serde.workspace = true
+thiserror.workspace = true
+white-whale-std.workspace = true
+cw-utils.workspace = true
+cw-ownable.workspace = true
+
+[dev-dependencies]
+cw-multi-test.workspace = true
+white-whale-testing.workspace = true
+epoch-manager.workspace = true
+whale-lair.workspace = true
+anyhow.workspace = true

contracts/liquidity_hub/incentive-manager/README.md

@@ -0,0 +1,4 @@
+# Incentive Manager
+
+The Incentive Manager is the V2 iteration of the original incentives. This is a monolithic contract that handles all
+the incentives-related logic.

contracts/liquidity_hub/incentive-manager/src/bin/schema.rs

@@ -0,0 +1,11 @@
+use cosmwasm_schema::write_api;
+
+use white_whale_std::incentive_manager::{ExecuteMsg, InstantiateMsg, QueryMsg};
+
+fn main() {
+    write_api! {
+        instantiate: InstantiateMsg,
+        execute: ExecuteMsg,
+        query: QueryMsg,
+    }
+}