discretionary_engine 1.0.0

LaTeX of trading
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

use color_eyre::eyre::Result;
use discretionary_engine_macros::ProtocolWrapper;
use tokio::{sync::mpsc, task::JoinSet};
use v_utils::{io::Percent, macros::CompactFormat, trades::Side};

use crate::{
	exchange_apis::{order_types::*, Market, Symbol},
	protocols::{ProtocolOrders, ProtocolTrait, ProtocolType},
};

/// Literally just sends one market order.
#[derive(Debug, Clone, CompactFormat, derive_new::new, Default, ProtocolWrapper)]
pub struct DummyMarket {
	// dummy: String, //? Does CompactFormat correctly work with empty structs?
}

impl ProtocolTrait for DummyMarketWrapper {
	type Params = DummyMarket;

	fn attach(&self, set: &mut JoinSet<Result<()>>, tx_orders: mpsc::Sender<ProtocolOrders>, asset: String, protocol_side: Side) -> Result<()> {
		let symbol = Symbol {
			base: asset,
			quote: "USDT".to_owned(),
			market: Market::BinanceFutures,
		};
		let m = ConceptualMarket::new(Percent(1.0));
		let order = ConceptualOrderPercents::new(ConceptualOrderType::Market(m), symbol.clone(), protocol_side, Percent::new(1.0));

		let protocol_spec = self.0.read().unwrap().to_string();
		let protocol_orders = ProtocolOrders::new(protocol_spec, vec![Some(order)]);
		set.spawn(async move {
			tx_orders.send(protocol_orders).await.unwrap();
			//LOOP: it's a dummy protocol, relax
			loop {
				tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
			}
			#[allow(unreachable_code)]
			Ok(())
		});
		Ok(())
	}

	fn update_params(&self, _params: Self::Params) -> Result<()> {
		unimplemented!()
	}

	fn get_type(&self) -> ProtocolType {
		ProtocolType::StopEntry
	}
}