mev-engine 0.1.1

A mev-engine for starknet
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
63

use std::sync::Arc;

use starknet::{core::types::Felt, providers::Provider};

use super::pool::TenkSwapPool;
use crate::errors::AMMError;
use crate::utils::call_contract;

pub async fn get_pool_info<P>(
    pool_address: Felt,
    provider: Arc<P>,
) -> Result<TenkSwapPool, AMMError>
where
    P: Provider + Send + Sync,
{
    let token0 = call_contract(provider.clone(), pool_address, "token0", vec![])
        .await
        .unwrap();
    let token_0_address = token0[0];
    // println!("Token 0 {:?}", token_0_address);

    tracing::info!(?token_0_address, "UniswapV2 sync");

    let token1 = call_contract(provider.clone(), pool_address, "token1", vec![])
        .await
        .unwrap();
    let token_1_address = token1[0];
    // println!("Token 1 {:?}", token_1_address);

    let token0_decimals = call_contract(provider.clone(), token_0_address, "decimals", vec![])
        .await
        .unwrap()[0];
    let token0_decimals_parsed =
        u8::from_le_bytes(token0_decimals.to_bytes_le()[0..1].try_into().unwrap());
    // println!("token 0 decimals {:?}", token0_decimals_parsed);

    let token1_decimals = call_contract(provider.clone(), token_1_address, "decimals", vec![])
        .await
        .unwrap()[0];

    let token1_decimals_parsed =
        u8::from_le_bytes(token1_decimals.to_bytes_le()[0..1].try_into().unwrap());
    // println!("token 1 decimals {:?}", token1_decimals_parsed);

    let reserves_result = call_contract(provider.clone(), pool_address, "getReserves", vec![])
        .await
        .unwrap();
    // println!("Reserve result {:?}", reserves_result);

    let reserve_a = Felt::from_bytes_le(&reserves_result[0].to_bytes_le());
    let reserve_b = Felt::from_bytes_le(&reserves_result[1].to_bytes_le());

    Ok(TenkSwapPool::new(
        pool_address,
        token_0_address,
        token_1_address,
        token0_decimals_parsed,
        token1_decimals_parsed,
        reserve_a,
        reserve_b,
        0u32,
    ))
}