v_exchanges 0.17.3

Implementations of HTTP/HTTPS/WebSocket API methods for some crypto exchanges, using [crypto-botters](<https://github.com/negi-grass/crypto-botters>) framework
Documentation 
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
51
52
53
54
55
56
57
58
59
60
61
62

mod account;
mod market;

use std::collections::BTreeMap;

use adapters::mexc::{MexcOption, MexcOptions};
use derive_more::derive::{Deref, DerefMut};
use secrecy::SecretString;
use v_exchanges_adapters::{Client, GetOptions};
use v_utils::trades::{Pair, Timeframe};

use crate::{
	ExchangeName, ExchangeResult, Instrument, Symbol,
	core::{ExchangeImpl, Klines, PersonalInfo, RequestRange},
};

#[derive(Clone, Debug, Default, Deref, DerefMut)]
pub struct Mexc(pub Client);

//? currently client ends up importing this from crate::binance, but could it be possible to lift the [Client] reexport up, and still have the ability to call all exchange methods right on it?
#[async_trait::async_trait]
impl ExchangeImpl for Mexc {
	fn name(&self) -> ExchangeName {
		ExchangeName::Mexc
	}

	fn auth(&mut self, pubkey: String, secret: SecretString) {
		self.update_default_option(MexcOption::Pubkey(pubkey));
		self.update_default_option(MexcOption::Secret(secret));
	}

	fn set_recv_window(&mut self, recv_window: std::time::Duration) {
		self.update_default_option(MexcOption::RecvWindow(recv_window));
	}

	fn default_recv_window(&self) -> Option<std::time::Duration> {
		GetOptions::<MexcOptions>::default_options(&**self).recv_window
	}

	async fn prices(&self, _pairs: Option<Vec<Pair>>, instrument: Instrument) -> ExchangeResult<BTreeMap<Pair, f64>> {
		match instrument {
			Instrument::Perp => unimplemented!("Mexc does not have a multi-asset endpoints for futures"),
			_ => unimplemented!(),
		}
	}

	async fn klines(&self, symbol: Symbol, tf: Timeframe, range: RequestRange) -> ExchangeResult<Klines> {
		match symbol.instrument {
			Instrument::Perp => market::klines(self, symbol, tf.try_into()?, range).await,
			_ => unimplemented!(),
		}
	}

	async fn personal_info(&self, instrument: Instrument, recv_window: Option<std::time::Duration>) -> ExchangeResult<PersonalInfo> {
		match instrument {
			Instrument::Perp => account::personal_info(self, recv_window).await,
			_ => unimplemented!(),
		}
	}
}

crate::define_provider_timeframe!(MexcTimeframe, ["1m", "5m", "15m", "30m", "60m", "4h", "1d", "1W", "1M"]);