Oracle valuation implementation

.github/CODEOWNERS

@@ -34,10 +34,10 @@ pallets/pool-registry/* @mustermeiszer
 pallets/pool-system/* @mustermeiszer @branan @offerijns
 
 ## Pallet Pool-System
-pallets/loans/* @mustermeiszer @branan @offerijns
+pallets/loans-ref/* @mustermeiszer @branan @offerijns @lemunozm
 
 ## Pallet Interest-Accrual
-pallets/interest-accrual/* @branan
+pallets/interest-accrual/* @branan @lemunozm
 
 ## Pallet Investments
 pallets/investments/* @mustermeiszer
@@ -48,6 +48,9 @@ pallets/permissions/* @mustermeiszer
 ## Pallet Restricted-Tokens
 pallets/restricted-tokens/* @mustermeiszer
 
+## Pallet Collection-Data-Feed
+pallets/collection-data-feed/* @lemunozm
+
 # Changes to libs
 ## Changes to specific libraries
 
@@ -58,6 +61,9 @@ libs/mock-builder/* @lemunozm
 #### rewards module
 libs/traits/src/rewards.rs @lemunozm
 
+#### rewards module
+libs/traits/src/data.rs @lemunozm
+
 #### ensure module
 libs/traits/src/ops.rs @lemunozm
 

libs/primitives/src/lib.rs

@@ -175,6 +175,9 @@ pub mod types {
 
 	/// A representation of a loan identifier
 	pub type LoanId = u64;
+
+	/// A representation of a price identifier
+	pub type PriceId = u64;
 }
 
 /// Common constants for all runtimes

libs/types/src/adjustments.rs

@@ -10,7 +10,17 @@
 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 // GNU General Public License for more details.
 
+#[derive(Clone, Copy)]
 pub enum Adjustment<Amount> {
 	Increase(Amount),
 	Decrease(Amount),
 }
+
+impl<Amount> Adjustment<Amount> {
+	pub fn abs(self) -> Amount {
+		match self {
+			Adjustment::Increase(amount) => amount,
+			Adjustment::Decrease(amount) => amount,
+		}
+	}
+}

pallets/collection-data-feed/src/lib.rs

@@ -159,10 +159,10 @@ pub mod pallet {
 			// for Data values.
 			for collection_id in Listening::<T>::get(data_id).keys() {
 				Collection::<T>::mutate(collection_id, |collection| {
-					if let Some(value) = collection.get_mut(data_id) {
-						if let Ok(new_value) = Self::get(data_id) {
-							*value = new_value;
-						}
+					if let (Some(value), Ok(new_value)) =
+						(collection.get_mut(data_id), Self::get(data_id))
+					{
+						*value = new_value;
 					}
 				});
 			}

pallets/loans-ref/src/benchmarking.rs

@@ -1,5 +1,18 @@
+// Copyright 2023 Centrifuge Foundation (centrifuge.io).
+// This file is part of Centrifuge chain project.
+
+// Centrifuge is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version (see http://www.gnu.org/licenses).
+
+// Centrifuge is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU General Public License for more details.
+
 use cfg_primitives::CFG;
-use cfg_traits::{InterestAccrual, Permissions, PoolBenchmarkHelper};
+use cfg_traits::{data::DataCollection, InterestAccrual, Permissions, PoolBenchmarkHelper};
 use cfg_types::{
 	adjustments::Adjustment,
 	permissions::{PermissionScope, PoolRole, Role},
@@ -18,10 +31,18 @@ use sp_runtime::traits::{Get, One, Zero};
 use sp_std::{time::Duration, vec};
 
 use super::{
+	loan::LoanInfo,
 	pallet::*,
-	types::{LoanInfo, MaxBorrowAmount},
-	valuation::{DiscountedCashFlow, ValuationMethod},
-	write_off::{WriteOffRule, WriteOffTrigger},
+	pricing::{
+		internal::{InternalPricing, MaxBorrowAmount},
+		Pricing,
+	},
+	types::{
+		policy::{WriteOffRule, WriteOffTrigger},
+		valuation::{DiscountedCashFlow, ValuationMethod},
+		BorrowRestrictions, InterestPayments, LoanRestrictions, Maturity, PayDownSchedule,
+		RepayRestrictions, RepaymentSchedule,
+	},
 };
 
 const OFFSET: Duration = Duration::from_secs(120);
@@ -44,10 +65,13 @@ where
 	T::ItemId: From<u16>,
 	T::Pool:
 		PoolBenchmarkHelper<PoolId = PoolIdOf<T>, AccountId = T::AccountId, Balance = T::Balance>,
+	PriceCollectionOf<T>: DataCollection<T::PriceId, Data = PriceResultOf<T>>,
 {
 	#[cfg(test)]
 	fn config_mocks() {
-		use crate::mock::{MockPermissions, MockPools};
+		use cfg_mocks::pallet_mock_data::util::MockDataCollection;
+
+		use crate::mock::{MockPermissions, MockPools, MockPrices};
 
 		MockPermissions::mock_add(|_, _, _| Ok(()));
 		MockPermissions::mock_has(|_, _, _| true);
@@ -57,6 +81,7 @@ where
 		MockPools::mock_deposit(|_, _, _| Ok(()));
 		MockPools::mock_benchmark_create_pool(|_, _| {});
 		MockPools::mock_benchmark_give_ausd(|_, _| {});
+		MockPrices::mock_collection(|_| MockDataCollection::new(|_| Ok((0, 0))));
 	}
 
 	fn prepare_benchmark() -> PoolIdOf<T> {
@@ -89,27 +114,42 @@ where
 		pool_id
 	}
 
+	fn base_loan(item_id: T::ItemId) -> LoanInfo<T> {
+		LoanInfo {
+			schedule: RepaymentSchedule {
+				maturity: Maturity::Fixed((T::Time::now() + OFFSET).as_secs()),
+				interest_payments: InterestPayments::None,
+				pay_down_schedule: PayDownSchedule::None,
+			},
+			collateral: (COLLECION_ID.into(), item_id),
+			pricing: Pricing::Internal(InternalPricing {
+				collateral_value: COLLATERAL_VALUE.into(),
+				interest_rate: T::Rate::saturating_from_rational(1, 5000),
+				max_borrow_amount: MaxBorrowAmount::UpToOutstandingDebt {
+					advance_rate: T::Rate::one(),
+				},
+				valuation_method: ValuationMethod::DiscountedCashFlow(DiscountedCashFlow {
+					probability_of_default: T::Rate::zero(),
+					loss_given_default: T::Rate::zero(),
+					discount_rate: T::Rate::one(),
+				}),
+			}),
+			restrictions: LoanRestrictions {
+				borrows: BorrowRestrictions::NoWrittenOff,
+				repayments: RepayRestrictions::None,
+			},
+		}
+	}
+
 	fn create_loan(pool_id: PoolIdOf<T>, item_id: T::ItemId) -> T::LoanId {
 		let borrower = account("borrower", 0, 0);
 
-		let collection_id = COLLECION_ID.into();
-		T::NonFungible::mint_into(&collection_id, &item_id, &borrower).unwrap();
+		T::NonFungible::mint_into(&COLLECION_ID.into(), &item_id, &borrower).unwrap();
 
 		Pallet::<T>::create(
 			RawOrigin::Signed(borrower).into(),
 			pool_id,
-			LoanInfo::new((collection_id, item_id))
-				.maturity(T::Time::now() + OFFSET)
-				.interest_rate(T::Rate::saturating_from_rational(1, 5000))
-				.collateral_value((COLLATERAL_VALUE).into())
-				.max_borrow_amount(MaxBorrowAmount::UpToOutstandingDebt {
-					advance_rate: T::Rate::one(),
-				})
-				.valuation_method(ValuationMethod::DiscountedCashFlow(DiscountedCashFlow {
-					probability_of_default: T::Rate::zero(),
-					loss_given_default: T::Rate::zero(),
-					discount_rate: T::Rate::one(),
-				})),
+			Self::base_loan(item_id),
 		)
 		.unwrap();
 
@@ -194,6 +234,7 @@ benchmarks! {
 		T::CollectionId: From<u16>,
 		T::ItemId: From<u16>,
 		T::Pool: PoolBenchmarkHelper<PoolId = PoolIdOf<T>, AccountId = T::AccountId, Balance = T::Balance>,
+		PriceCollectionOf<T>: DataCollection<T::PriceId, Data = PriceResultOf<T>>,
 	}
 
 	create {
@@ -202,8 +243,7 @@ benchmarks! {
 
 		let (collection_id, item_id) = (COLLECION_ID.into(), 1.into());
 		T::NonFungible::mint_into(&collection_id, &item_id, &borrower).unwrap();
-
-		let loan_info = LoanInfo::new((collection_id, item_id)).maturity(T::Time::now() + OFFSET);
+		let loan_info = Helper::<T>::base_loan(item_id);
 
 	}: _(RawOrigin::Signed(borrower), pool_id, loan_info)
 

pallets/loans-ref/src/config.rs

@@ -0,0 +1,54 @@
+// Copyright 2023 Centrifuge Foundation (centrifuge.io).
+// This file is part of Centrifuge chain project.
+
+// Centrifuge is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version (see http://www.gnu.org/licenses).
+
+// Centrifuge is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU General Public License for more details.
+
+use cfg_traits::data::{DataCollection, DataRegistry};
+use sp_runtime::{DispatchError, DispatchResult};
+use sp_std::marker::PhantomData;
+
+use crate::pallet::{Config, PoolIdOf, PriceResultOf};
+
+const DEFAULT_ERR: DispatchError =
+	DispatchError::Other("No configured price registry for pallet-loans");
+
+pub struct NoPriceRegistry<T>(PhantomData<T>);
+
+impl<T: Config> DataRegistry<T::PriceId, PoolIdOf<T>> for NoPriceRegistry<T> {
+	type Collection = NoPriceCollection<T>;
+	type Data = PriceResultOf<T>;
+
+	fn get(_: &T::PriceId) -> Self::Data {
+		Err(DEFAULT_ERR)
+	}
+
+	fn collection(_: &PoolIdOf<T>) -> Self::Collection {
+		NoPriceCollection(PhantomData::default())
+	}
+
+	fn register_id(_: &T::PriceId, _: &PoolIdOf<T>) -> DispatchResult {
+		Err(DEFAULT_ERR)
+	}
+
+	fn unregister_id(_: &T::PriceId, _: &PoolIdOf<T>) -> DispatchResult {
+		Err(DEFAULT_ERR)
+	}
+}
+
+pub struct NoPriceCollection<T>(PhantomData<T>);
+
+impl<T: Config> DataCollection<T::PriceId> for NoPriceCollection<T> {
+	type Data = PriceResultOf<T>;
+
+	fn get(&self, _: &T::PriceId) -> Self::Data {
+		Err(DEFAULT_ERR)
+	}
+}