dydx 0.1.1

dYdX v4 asynchronous client.
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
64
65
66

mod env;
use env::TestEnv;

use anyhow::Error;
use dydx::node::sequencer::*;
use serial_test::serial;

#[tokio::test]
#[serial]
async fn test_node_sequencer_query() -> Result<(), Error> {
    let mut env = TestEnv::testnet().await?;

    let seqnum_before = env.account.sequence_number();

    // account.sequence_number() holds the correct and next sequence number to be used.
    // We spawn two orders because wallet.account() produces an account with an already
    // correct and updated sequence number.
    // In the first order this value should not change, changing only then in the second order.
    env.spawn_order().await?;
    env.spawn_order().await?;

    let seqnum_after = env.account.sequence_number();

    assert_eq!(seqnum_after, seqnum_before + 1);

    Ok(())
}

#[tokio::test]
#[serial]
async fn test_node_sequencer_incremental() -> Result<(), Error> {
    let mut env = TestEnv::testnet().await?;
    let address = env.account.address().clone();
    let sequencer = IncrementalSequencer::new(&[(address, env.account.sequence_number())]);
    env.node.with_sequencer(sequencer);

    let seqnum_before = env.account.sequence_number();

    env.spawn_order().await?;
    env.spawn_order().await?;

    let seqnum_after = env.account.sequence_number();

    assert_eq!(seqnum_after, seqnum_before + 1);

    Ok(())
}

#[tokio::test]
#[serial]
async fn test_node_sequencer_timestamp() -> Result<(), Error> {
    let mut env = TestEnv::testnet().await?;
    env.node.with_sequencer(TimestamperSequencer);

    let seqnum_before = env.account.sequence_number();

    env.spawn_order().await?;
    env.spawn_order().await?;
    env.spawn_order().await?;

    let seqnum_after = env.account.sequence_number();

    assert!(seqnum_after == seqnum_before);

    Ok(())
}