feat: OTC offchain worker

Cargo.toml

@@ -29,6 +29,7 @@ members = [
   'pallets/dynamic-fees',
   'pallets/duster',
   'pallets/otc',
+  'pallets/otc-settlements',
   'pallets/bonds',
   'pallets/lbp',
   'pallets/nft',
@@ -87,6 +88,7 @@ pallet-nft = { path = "pallets/nft", default-features = false }
 pallet-omnipool = { path = "pallets/omnipool", default-features = false }
 pallet-omnipool-liquidity-mining = { path = "pallets/omnipool-liquidity-mining", default-features = false }
 pallet-otc = { path = "pallets/otc", default-features = false}
+pallet-otc-settlements = { path = "pallets/otc-settlements", default-features = false}
 pallet-relaychain-info = { path = "pallets/relaychain-info", default-features = false }
 pallet-route-executor = { path = "pallets/route-executor", default-features = false }
 pallet-stableswap = { path = "pallets/stableswap", default-features = false }

integration-tests/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "runtime-integration-tests"
-version = "1.22.4"
+version = "1.22.5"
 description = "Integration tests"
 authors = ["GalacticCouncil"]
 edition = "2021"
@@ -30,6 +30,7 @@ pallet-duster = { workspace = true }
 pallet-ema-oracle = { workspace = true }
 warehouse-liquidity-mining = { workspace = true }
 pallet-otc = { workspace = true }
+pallet-otc-settlements = { workspace = true }
 pallet-relaychain-info = { workspace = true }
 pallet-route-executor = { workspace = true}
 pallet-dca = { workspace = true}

integration-tests/src/evm_permit.rs

@@ -1141,7 +1141,7 @@ fn dispatch_permit_should_increase_account_nonce_correctly() {
 
 		let hdx_balance = user_acc.balance(HDX);
 		let tx_fee = initial_user_hdx_balance - hdx_balance;
-		assert_eq!(tx_fee, 1_797_526_858_553);
+		assert_eq!(tx_fee, 1_816_997_321_901);
 	})
 }
 

math/Cargo.toml

@@ -6,7 +6,7 @@ license = 'Apache-2.0'
 name = "hydra-dx-math"
 description = "A collection of utilities to make performing liquidity pool calculations more convenient."
 repository = 'https://github.com/galacticcouncil/hydradx-math'
-version = "8.1.1"
+version = "8.1.2"
 
 [dependencies]
 primitive-types = {default-features = false, version = '0.12.0'}

math/src/stableswap/math.rs

@@ -799,7 +799,7 @@ pub fn calculate_spot_price(
 			let mut updated_reserves = asset_reserves.clone();
 			for reserve in updated_reserves.iter_mut() {
 				if reserve.0 == added_asset.0 {
-					reserve.1.amount += added_asset.1;
+					reserve.1.amount = reserve.1.amount.checked_add(added_asset.1)?;
 				}
 			}
 

pallets/dca/src/weights.rs

@@ -36,6 +36,7 @@
 // --pallet=pallet-dca
 // --output=weights/dca.rs
 // --extrinsic=*
+// --extra
 
 #![allow(unused_parens)]
 #![allow(unused_imports)]
@@ -104,7 +105,7 @@ impl WeightInfo for () {
 	/// Proof: `DCA::ScheduleIdsPerBlock` (`max_values`: None, `max_size`: Some(101), added: 2576, mode: `MaxEncodedLen`)
 	fn on_initialize_with_empty_block() -> Weight {
 		// Proof Size summary in bytes:
-		//  Measured:  `1075`
+		//  Measured:  `1113`
 		//  Estimated: `3566`
 		// Minimum execution time: 14_273_000 picoseconds.
 		Weight::from_parts(14_864_000, 3566).saturating_add(RocksDbWeight::get().reads(1_u64))

pallets/lbp/src/benchmarking.rs

@@ -257,6 +257,30 @@ benchmarks! {
 		assert!(<LBP::<T> as TradeExecution<T::RuntimeOrigin, T::AccountId, AssetId, Balance>>::calculate_buy(PoolType::LBP, asset_in, asset_out, amount).is_ok());
 	}
 	verify{}
+
+	calculate_spot_price_with_fee {
+		let caller = funded_account::<T>("caller", 0);
+		let fee_collector = funded_account::<T>("fee_collector", 0);
+		let asset_in: AssetId = ASSET_A_ID;
+		let asset_out: AssetId = ASSET_B_ID;
+		let amount : Balance = 100_000_000;
+		let max_limit: Balance = 1_000_000_000;
+
+		let pool_id = LBP::<T>::pair_account_from_assets(ASSET_A_ID, ASSET_B_ID);
+
+		LBP::<T>::create_pool(RawOrigin::Root.into(), caller.clone(), ASSET_A_ID, ASSET_A_AMOUNT, ASSET_B_ID, ASSET_B_AMOUNT, INITIAL_WEIGHT, FINAL_WEIGHT, WeightCurveType::Linear, DEFAULT_FEE, fee_collector, 0)?;
+		ensure!(PoolData::<T>::contains_key(&pool_id), "Pool does not exist.");
+
+		let start = BlockNumberFor::<T>::from(1u32);
+		let end = BlockNumberFor::<T>::from(11u32);
+
+		LBP::<T>::update_pool_data(RawOrigin::Signed(caller).into(), pool_id, None, Some(start), Some(end), None, None, None, None, None)?;
+
+		frame_system::Pallet::<T>::set_block_number(BlockNumberFor::<T>::from(2u32));
+
+	}: {
+		assert!(<LBP::<T> as TradeExecution<T::RuntimeOrigin, T::AccountId, AssetId, Balance>>::calculate_spot_price_with_fee(PoolType::LBP, asset_in, asset_out).is_ok());
+	}
 }
 
 #[cfg(test)]