fix: Simplify models. Delete Solution and rename Order->Solution

This commit is contained in:
Diana Carvalho
2025-01-14 15:45:58 +00:00
parent 68c5a914eb
commit a25c56e667
4 changed files with 51 additions and 55 deletions

View File

@@ -11,12 +11,9 @@ lazy_static! {
.expect("Invalid ROUTER_ADDRESS"); .expect("Invalid ROUTER_ADDRESS");
} }
#[derive(Clone)]
pub struct Solution { pub struct Solution {
pub orders: Vec<Order>, /// True if the solution is an exact output solution.
}
pub struct Order {
/// True if the order is an exact output order.
pub exact_out: bool, pub exact_out: bool,
/// The token being sold (exact in) or bought (exact out). /// The token being sold (exact in) or bought (exact out).
pub given_token: Bytes, pub given_token: Bytes,
@@ -30,9 +27,9 @@ pub struct Order {
pub sender: Bytes, pub sender: Bytes,
/// Address of the receiver. /// Address of the receiver.
pub receiver: Bytes, pub receiver: Bytes,
/// List of swaps to fulfill the order. /// List of swaps to fulfill the solution.
pub swaps: Vec<Swap>, pub swaps: Vec<Swap>,
/// If set to true, the order will be encoded to be sent directly to the SwapExecutor and skip the router. /// If set to true, the solution will be encoded to be sent directly to the SwapExecutor and skip the router.
/// The user is responsible for managing necessary approvals and token transfers. /// The user is responsible for managing necessary approvals and token transfers.
pub straight_to_pool: bool, pub straight_to_pool: bool,
// if not set, then the Propeller Router will be used // if not set, then the Propeller Router will be used

View File

@@ -1,6 +1,5 @@
use crate::encoding::approvals::interface::{Approval, UserApprovalsManager}; use crate::encoding::approvals::interface::{Approval, UserApprovalsManager};
use crate::encoding::models::{Solution, PROPELLER_ROUTER_ADDRESS}; use crate::encoding::models::{Solution, PROPELLER_ROUTER_ADDRESS};
use crate::encoding::strategy_encoder::StrategyEncoder;
use crate::encoding::strategy_selector::StrategySelector; use crate::encoding::strategy_selector::StrategySelector;
use crate::encoding::utils::{encode_input, ple_encode}; use crate::encoding::utils::{encode_input, ple_encode};
use alloy_sol_types::SolValue; use alloy_sol_types::SolValue;
@@ -17,16 +16,16 @@ impl<S: StrategySelector, A: UserApprovalsManager> RouterEncoder<S, A> {
approvals_manager, approvals_manager,
} }
} }
pub fn encode_router_calldata(&self, solution: Solution) -> Result<Vec<u8>, Error> { pub fn encode_router_calldata(&self, solutions: Vec<Solution>) -> Result<Vec<u8>, Error> {
let approvals_calldata = self.handle_approvals(&solution)?; // TODO: where should we append this? let approvals_calldata = self.handle_approvals(&solutions)?; // TODO: where should we append this?
let mut calldata_list: Vec<Vec<u8>> = Vec::new(); let mut calldata_list: Vec<Vec<u8>> = Vec::new();
let encode_for_batch_execute = solution.orders.len() > 1; let encode_for_batch_execute = solutions.len() > 1;
for order in solution.orders { for solution in solutions.iter() {
let exact_out = order.exact_out.clone(); let exact_out = solution.exact_out.clone();
let straight_to_pool = order.straight_to_pool.clone(); let straight_to_pool = solution.straight_to_pool.clone();
let strategy = self.strategy_selector.select_strategy(&order); let strategy = self.strategy_selector.select_strategy(&solution);
let method_calldata = strategy.encode_strategy(order)?; let method_calldata = strategy.encode_strategy((*solution).clone())?;
let contract_interaction = if encode_for_batch_execute { let contract_interaction = if encode_for_batch_execute {
let args = (strategy.action_type(exact_out) as u16, method_calldata); let args = (strategy.action_type(exact_out) as u16, method_calldata);
@@ -48,17 +47,17 @@ impl<S: StrategySelector, A: UserApprovalsManager> RouterEncoder<S, A> {
} }
} }
fn handle_approvals(&self, solution: &Solution) -> Result<Vec<u8>, Error> { fn handle_approvals(&self, solutions: &Vec<Solution>) -> Result<Vec<u8>, Error> {
let mut approvals = Vec::new(); let mut approvals = Vec::new();
for order in solution.orders.iter() { for solution in solutions.iter() {
approvals.push(Approval { approvals.push(Approval {
token: order.given_token.clone(), token: solution.given_token.clone(),
spender: order spender: solution
.router_address .router_address
.clone() .clone()
.unwrap_or(PROPELLER_ROUTER_ADDRESS.clone()), .unwrap_or(PROPELLER_ROUTER_ADDRESS.clone()),
amount: order.given_amount.clone(), amount: solution.given_amount.clone(),
owner: order.sender.clone(), owner: solution.sender.clone(),
}); });
} }
Ok(self.approvals_manager.encode_approvals(approvals)) Ok(self.approvals_manager.encode_approvals(approvals))

View File

@@ -3,13 +3,13 @@ use anyhow::Error;
use num_bigint::BigUint; use num_bigint::BigUint;
use crate::encoding::models::{ use crate::encoding::models::{
ActionType, EncodingContext, NativeAction, Order, PROPELLER_ROUTER_ADDRESS, ActionType, EncodingContext, NativeAction, Solution, PROPELLER_ROUTER_ADDRESS,
}; };
use crate::encoding::swap_encoder::{get_swap_encoder, get_swap_executor_address}; use crate::encoding::swap_encoder::{get_swap_encoder, get_swap_executor_address};
use crate::encoding::utils::{biguint_to_u256, ple_encode}; use crate::encoding::utils::{biguint_to_u256, ple_encode};
pub trait StrategyEncoder { pub trait StrategyEncoder {
fn encode_strategy(&self, to_encode: Order) -> Result<Vec<u8>, Error>; fn encode_strategy(&self, to_encode: Solution) -> Result<Vec<u8>, Error>;
fn action_type(&self, exact_out: bool) -> ActionType; fn action_type(&self, exact_out: bool) -> ActionType;
fn selector(&self, exact_out: bool) -> &str; fn selector(&self, exact_out: bool) -> &str;
@@ -32,7 +32,7 @@ pub trait StrategyEncoder {
pub struct SingleSwapStrategyEncoder {} pub struct SingleSwapStrategyEncoder {}
impl StrategyEncoder for SingleSwapStrategyEncoder { impl StrategyEncoder for SingleSwapStrategyEncoder {
fn encode_strategy(&self, order: Order) -> Result<Vec<u8>, Error> { fn encode_strategy(&self, solution: Solution) -> Result<Vec<u8>, Error> {
todo!() todo!()
} }
@@ -56,33 +56,33 @@ impl StrategyEncoder for SingleSwapStrategyEncoder {
pub struct SequentialStrategyEncoder {} pub struct SequentialStrategyEncoder {}
impl StrategyEncoder for SequentialStrategyEncoder { impl StrategyEncoder for SequentialStrategyEncoder {
fn encode_strategy(&self, order: Order) -> Result<Vec<u8>, Error> { fn encode_strategy(&self, solution: Solution) -> Result<Vec<u8>, Error> {
let mut check_amount = order.check_amount.clone(); let mut check_amount = solution.check_amount.clone();
if order.slippage.is_some() { if solution.slippage.is_some() {
let one_hundred = BigUint::from(100u32); let one_hundred = BigUint::from(100u32);
let slippage_percent = BigUint::from((order.slippage.unwrap() * 100.0) as u32); let slippage_percent = BigUint::from((solution.slippage.unwrap() * 100.0) as u32);
let multiplier = &one_hundred - slippage_percent; let multiplier = &one_hundred - slippage_percent;
check_amount = (&order.check_amount * multiplier) / one_hundred; check_amount = (&solution.check_amount * multiplier) / one_hundred;
} }
let mut swaps = vec![]; let mut swaps = vec![];
for (index, swap) in order.swaps.iter().enumerate() { for (index, swap) in solution.swaps.iter().enumerate() {
let is_last = index == order.swaps.len() - 1; let is_last = index == solution.swaps.len() - 1;
let protocol_system = swap.component.protocol_system.clone(); let protocol_system = swap.component.protocol_system.clone();
let swap_encoder = get_swap_encoder(&protocol_system); let swap_encoder = get_swap_encoder(&protocol_system);
let router_address = if order.router_address.is_some() { let router_address = if solution.router_address.is_some() {
order.router_address.clone().unwrap() solution.router_address.clone().unwrap()
} else { } else {
PROPELLER_ROUTER_ADDRESS.clone() PROPELLER_ROUTER_ADDRESS.clone()
}; };
let receiver = if is_last { let receiver = if is_last {
order.receiver.clone() solution.receiver.clone()
} else { } else {
router_address.clone() router_address.clone()
}; };
let encoding_context = EncodingContext { let encoding_context = EncodingContext {
receiver, receiver,
exact_out: order.exact_out, exact_out: solution.exact_out,
address_for_approvals: router_address, address_for_approvals: router_address,
}; };
let protocol_data = swap_encoder.encode_swap(swap.clone(), encoding_context)?; let protocol_data = swap_encoder.encode_swap(swap.clone(), encoding_context)?;
@@ -93,8 +93,8 @@ impl StrategyEncoder for SequentialStrategyEncoder {
let encoded_swaps = ple_encode(swaps); let encoded_swaps = ple_encode(swaps);
let (mut unwrap, mut wrap) = (false, false); let (mut unwrap, mut wrap) = (false, false);
if order.native_action.is_some() { if solution.native_action.is_some() {
match order.native_action.unwrap() { match solution.native_action.unwrap() {
NativeAction::Wrap => wrap = true, NativeAction::Wrap => wrap = true,
NativeAction::Unwrap => unwrap = true, NativeAction::Unwrap => unwrap = true,
} }
@@ -102,7 +102,7 @@ impl StrategyEncoder for SequentialStrategyEncoder {
let method_calldata = ( let method_calldata = (
wrap, wrap,
unwrap, unwrap,
biguint_to_u256(&order.given_amount), biguint_to_u256(&solution.given_amount),
biguint_to_u256(&check_amount), biguint_to_u256(&check_amount),
encoded_swaps, encoded_swaps,
) )
@@ -130,7 +130,7 @@ impl StrategyEncoder for SequentialStrategyEncoder {
pub struct SlipSwapStrategyEncoder {} pub struct SlipSwapStrategyEncoder {}
impl StrategyEncoder for SlipSwapStrategyEncoder { impl StrategyEncoder for SlipSwapStrategyEncoder {
fn encode_strategy(&self, order: Order) -> Result<Vec<u8>, Error> { fn encode_strategy(&self, solution: Solution) -> Result<Vec<u8>, Error> {
todo!() todo!()
} }
fn action_type(&self, _exact_out: bool) -> ActionType { fn action_type(&self, _exact_out: bool) -> ActionType {
@@ -142,25 +142,25 @@ impl StrategyEncoder for SlipSwapStrategyEncoder {
} }
} }
/// This strategy encoder is used for orders that are sent directly to the pool. /// This strategy encoder is used for solutions that are sent directly to the pool.
/// Only 1 order with 1 swap is supported. /// Only 1 solution with 1 swap is supported.
pub struct StraightToPoolStrategyEncoder {} pub struct StraightToPoolStrategyEncoder {}
impl StrategyEncoder for StraightToPoolStrategyEncoder { impl StrategyEncoder for StraightToPoolStrategyEncoder {
fn encode_strategy(&self, order: Order) -> Result<Vec<u8>, Error> { fn encode_strategy(&self, solution: Solution) -> Result<Vec<u8>, Error> {
if order.router_address.is_none() { if solution.router_address.is_none() {
return Err(anyhow::anyhow!( return Err(anyhow::anyhow!(
"Router address is required for straight to pool orders" "Router address is required for straight to pool solutions"
)); ));
} }
let swap = order.swaps.first().unwrap(); let swap = solution.swaps.first().unwrap();
let protocol_system = swap.component.protocol_system.clone(); let protocol_system = swap.component.protocol_system.clone();
let swap_encoder = get_swap_encoder(&protocol_system); let swap_encoder = get_swap_encoder(&protocol_system);
let router_address = order.router_address.unwrap(); let router_address = solution.router_address.unwrap();
let encoding_context = EncodingContext { let encoding_context = EncodingContext {
receiver: order.receiver, receiver: solution.receiver,
exact_out: order.exact_out, exact_out: solution.exact_out,
address_for_approvals: router_address, address_for_approvals: router_address,
}; };
let protocol_data = swap_encoder.encode_swap(swap.clone(), encoding_context)?; let protocol_data = swap_encoder.encode_swap(swap.clone(), encoding_context)?;

View File

@@ -1,22 +1,22 @@
use crate::encoding::models::Order; use crate::encoding::models::Solution;
use crate::encoding::strategy_encoder::{ use crate::encoding::strategy_encoder::{
SequentialStrategyEncoder, SingleSwapStrategyEncoder, SlipSwapStrategyEncoder, SequentialStrategyEncoder, SingleSwapStrategyEncoder, SlipSwapStrategyEncoder,
StraightToPoolStrategyEncoder, StrategyEncoder, StraightToPoolStrategyEncoder, StrategyEncoder,
}; };
pub trait StrategySelector { pub trait StrategySelector {
fn select_strategy(&self, order: &Order) -> Box<dyn StrategyEncoder>; fn select_strategy(&self, solution: &Solution) -> Box<dyn StrategyEncoder>;
} }
pub struct DefaultStrategySelector; pub struct DefaultStrategySelector;
impl StrategySelector for DefaultStrategySelector { impl StrategySelector for DefaultStrategySelector {
fn select_strategy(&self, order: &Order) -> Box<dyn StrategyEncoder> { fn select_strategy(&self, solution: &Solution) -> Box<dyn StrategyEncoder> {
if order.straight_to_pool { if solution.straight_to_pool {
Box::new(StraightToPoolStrategyEncoder {}) Box::new(StraightToPoolStrategyEncoder {})
} else if order.swaps.len() == 1 { } else if solution.swaps.len() == 1 {
Box::new(SingleSwapStrategyEncoder {}) Box::new(SingleSwapStrategyEncoder {})
} else if order.swaps.iter().all(|s| s.split == 0.0) { } else if solution.swaps.iter().all(|s| s.split == 0.0) {
Box::new(SequentialStrategyEncoder {}) Box::new(SequentialStrategyEncoder {})
} else { } else {
Box::new(SlipSwapStrategyEncoder {}) Box::new(SlipSwapStrategyEncoder {})