From 736ff916995ee4b2cbc13c643936a4098380f828 Mon Sep 17 00:00:00 2001 From: ts0yu <120932697+ts0yu@users.noreply.github.com> Date: Sat, 24 Feb 2024 21:11:10 +0000 Subject: [PATCH] feat: fmt --- src/behaviors/mod.rs | 4 ++-- src/behaviors/price_changer.rs | 23 ++++++++++++----------- 2 files changed, 14 insertions(+), 13 deletions(-) diff --git a/src/behaviors/mod.rs b/src/behaviors/mod.rs index ffb09b5..068dd40 100644 --- a/src/behaviors/mod.rs +++ b/src/behaviors/mod.rs @@ -4,13 +4,13 @@ use serde::{Deserialize, Serialize}; pub mod deployer; pub mod pool_admin; -pub mod token_admin; pub mod price_changer; +pub mod token_admin; use deployer::Deployer; use pool_admin::PoolAdmin; -use token_admin::TokenAdmin; use price_changer::PriceChanger; +use token_admin::TokenAdmin; #[derive(Behaviors, Debug, Serialize, Deserialize)] pub enum Behaviors { diff --git a/src/behaviors/price_changer.rs b/src/behaviors/price_changer.rs index f1a6e25..862b13b 100644 --- a/src/behaviors/price_changer.rs +++ b/src/behaviors/price_changer.rs @@ -1,18 +1,17 @@ -use std::sync::Arc; +use std::{fmt, sync::Arc}; use anyhow::Result; use arbiter_core::middleware::ArbiterMiddleware; use arbiter_engine::messager::{Message, Messager}; use ethers::types::H160; +use RustQuant::{ + models::*, + stochastics::{process::Trajectories, *}, +}; + use super::*; use crate::bindings::liquid_exchange::LiquidExchange; -use RustQuant::stochastics::*; -use RustQuant::models::*; -use RustQuant::stochastics::process::Trajectories; - -use std::fmt; - #[derive(Serialize, Deserialize)] pub struct PriceChanger { #[serde(skip)] @@ -38,8 +37,8 @@ fn trajectory_default() -> Trajectories { #[derive(Debug, Serialize, Deserialize, Default)] pub struct OrnsteinUhlenbeckParams { - mu: f64, - sigma: f64, + mu: f64, + sigma: f64, theta: f64, } @@ -96,10 +95,12 @@ impl Behavior for PriceChanger { if self.cursor >= 99 { self.cursor = 0; self.value = self.current_chunk.paths.clone()[0][self.cursor]; - self.current_chunk = ou.euler_maruyama(self.value, 0.0, 100.0, 100_usize, 1_usize, false); + self.current_chunk = + ou.euler_maruyama(self.value, 0.0, 100.0, 100_usize, 1_usize, false); } - let liquid_exchange = LiquidExchange::new(query.liquid_exchange, self.client.clone().unwrap()); + let liquid_exchange = + LiquidExchange::new(query.liquid_exchange, self.client.clone().unwrap()); let price = self.current_chunk.paths.clone()[0][self.cursor];