magic-domain-program 0.3.0

Domain registration program for Ephemeral Rollups
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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117

use borsh::BorshDeserialize;
use common::TestEnv;
use mdp::state::{record::ErRecord, status::ErStatus};
use solana_sdk::account::Account;

pub mod common;

#[tokio::test]
async fn test_sync_info() {
    let TestEnv {
        mut banks,
        identity,
        record,
        ..
    } = common::setup().await;
    let pda = record.pda().0;

    let result = common::register(&mut banks, record, &identity).await;
    assert_ok!(result, "error processing register transaction {}");

    let result = banks.get_account(pda).await;

    let acc = assert_ok!(result, "error querying registration PDA from banks {}");
    assert!(matches!(acc, Some(Account { owner: mdp::ID, .. })));
    let acc = acc.unwrap();
    let result = ErRecord::try_from_slice(&acc.data);
    let mut record = assert_ok!(result, "error querying registration PDA from banks {}");

    const NEW_BLOCK_TIME: u16 = 1000;
    const NEW_ADDR: &str = "https://127.145.24.55:9324";

    record.set_block_time_ms(NEW_BLOCK_TIME);
    record.set_addr(NEW_ADDR.to_string());
    record.set_status(ErStatus::Draining);
    record.set_load_average(2_200_000);

    let result = common::sync(&mut banks, &identity, record).await;
    assert_ok!(result, "error processing sync info transaction {}");

    let result = banks.get_account(pda).await;

    let acc = assert_ok!(
        result,
        "error querying registration PDA after modification {}"
    );
    assert!(matches!(acc, Some(Account { owner: mdp::ID, .. })));
    let acc = acc.unwrap();
    let result = ErRecord::try_from_slice(&acc.data);
    let record = assert_ok!(
        result,
        "error querying registration PDA post modification {}"
    );
    assert_eq!(record.addr(), NEW_ADDR);
    assert_eq!(record.block_time_ms(), NEW_BLOCK_TIME);
    assert_eq!(record.status(), ErStatus::Draining);
    assert_eq!(record.load_average(), 2_200_000);

    let result = common::unregister(&mut banks, &identity, pda).await;

    assert_ok!(result, "error processing unregister transaction {}");

    let result = banks.get_account(pda).await;

    let acc = assert_ok!(result, "error querying unregistered PDA from banks {}");
    assert!(
        acc.is_none(),
        "registration PDA hasn't been removed from banks"
    );
}

#[tokio::test]
async fn test_sync_info_with_realloc() {
    let TestEnv {
        mut banks,
        identity,
        record,
        ..
    } = common::setup().await;
    let pda = record.pda().0;

    let result = common::register(&mut banks, record, &identity).await;
    assert_ok!(result, "error processing register transaction {}");

    let result = banks.get_account(pda).await;

    let acc = assert_ok!(result, "error querying registration PDA from banks {}");
    assert!(matches!(acc, Some(Account { owner: mdp::ID, .. })));
    let acc = acc.unwrap();
    let result = ErRecord::try_from_slice(&acc.data);
    let mut record = assert_ok!(result, "error querying registration PDA from banks {}");

    const NEW_BLOCK_TIME: u16 = 1000;
    const NEW_ADDR: &str = "https://very-long-url.address.com:42425";

    record.set_block_time_ms(NEW_BLOCK_TIME);
    record.set_addr(NEW_ADDR.to_string());
    record.set_status(ErStatus::Draining);
    record.set_load_average(2_200_000);

    let result = common::sync(&mut banks, &identity, record).await;
    assert_ok!(result, "error processing sync info transaction {}");

    let result = banks.get_account(pda).await;

    let acc = assert_ok!(
        result,
        "error querying registration PDA after modification {}"
    );
    assert!(matches!(acc, Some(Account { owner: mdp::ID, .. })));
    let acc = acc.unwrap();
    let result = ErRecord::try_from_slice(&acc.data);
    let record = assert_ok!(
        result,
        "error querying registration PDA post modification {}"
    );
    assert_eq!(record.addr(), NEW_ADDR);
}