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

use alloy::{
    providers::{
        fillers::{JoinFill, TxFiller, WalletFiller},
        ProviderBuilder, ProviderLayer, RootProvider,
    },
    signers::local::LocalSigner,
};

use crate::{
    network::Zksync,
    node_bindings::{AnvilZKsync, AnvilZKsyncError},
    provider::layers::anvil_zksync::{AnvilZKsyncLayer, AnvilZKsyncProvider},
    wallet::ZksyncWallet,
};

type AnvilZKsyncProviderResult<T> = Result<T, AnvilZKsyncError>;
type JoinedZksyncWalletFiller<F> = JoinFill<F, WalletFiller<ZksyncWallet>>;

/// ZKsync-specific extensions for the [`ProviderBuilder`](https://docs.rs/alloy/latest/alloy/providers/struct.ProviderBuilder.html).
pub trait ProviderBuilderExt<L, F>: Sized
where
    F: TxFiller<Zksync> + ProviderLayer<L::Provider, Zksync>,
    L: ProviderLayer<AnvilZKsyncProvider<RootProvider<Zksync>>, Zksync>,
{
    /// Build a provider that would spawn `anvil-zksync` instance in background and will use it.
    fn on_anvil_zksync(self) -> F::Provider;

    /// Same as [`on_anvil_zksync`](Self::on_anvil_zksync), but also configures a wallet backed by anvil-zksync keys.
    fn on_anvil_zksync_with_wallet(
        self,
    ) -> <JoinedZksyncWalletFiller<F> as ProviderLayer<L::Provider, Zksync>>::Provider;

    /// Same as [`on_anvil_zksync`](Self::on_anvil_zksync), allows to configure `anvil-zksync`.
    fn on_anvil_zksync_with_config(self, f: impl FnOnce(AnvilZKsync) -> AnvilZKsync)
        -> F::Provider;

    /// Same as [`on_anvil_zksync_with_wallet`](Self::on_anvil_zksync_with_wallet), allows to configure `anvil-zksync`.
    fn on_anvil_zksync_with_wallet_and_config(
        self,
        f: impl FnOnce(AnvilZKsync) -> AnvilZKsync,
    ) -> <JoinedZksyncWalletFiller<F> as ProviderLayer<L::Provider, Zksync>>::Provider;

    /// Fallible version of [`on_anvil_zksync_with_wallet_and_config`](Self::on_anvil_zksync_with_wallet_and_config).
    fn try_on_anvil_zksync_with_wallet_and_config(
        self,
        f: impl FnOnce(AnvilZKsync) -> AnvilZKsync,
    ) -> AnvilZKsyncProviderResult<
        <JoinedZksyncWalletFiller<F> as ProviderLayer<L::Provider, Zksync>>::Provider,
    >;
}

impl<L, F> ProviderBuilderExt<L, F> for ProviderBuilder<L, F, Zksync>
where
    F: TxFiller<Zksync> + ProviderLayer<L::Provider, Zksync>,
    L: ProviderLayer<AnvilZKsyncProvider<RootProvider<Zksync>>, Zksync>,
{
    fn on_anvil_zksync(self) -> F::Provider {
        self.on_anvil_zksync_with_config(std::convert::identity)
    }

    fn on_anvil_zksync_with_wallet(
        self,
    ) -> <JoinedZksyncWalletFiller<F> as ProviderLayer<L::Provider, Zksync>>::Provider {
        self.on_anvil_zksync_with_wallet_and_config(std::convert::identity)
    }

    fn on_anvil_zksync_with_config(
        self,
        f: impl FnOnce(AnvilZKsync) -> AnvilZKsync,
    ) -> F::Provider {
        let anvil_zksync_layer = AnvilZKsyncLayer::from(f(Default::default()));
        let url = anvil_zksync_layer.endpoint_url();

        self.layer(anvil_zksync_layer).on_http(url)
    }

    fn on_anvil_zksync_with_wallet_and_config(
        self,
        f: impl FnOnce(AnvilZKsync) -> AnvilZKsync,
    ) -> <JoinedZksyncWalletFiller<F> as ProviderLayer<L::Provider, Zksync>>::Provider {
        self.try_on_anvil_zksync_with_wallet_and_config(f).unwrap()
    }

    /// Build this provider with anvil-zksync, using an Reqwest HTTP transport. The
    /// given function is used to configure the anvil-zksync instance. This
    /// function configures a wallet backed by anvil-zksync keys, and is intended for
    /// use in tests.
    fn try_on_anvil_zksync_with_wallet_and_config(
        self,
        f: impl FnOnce(AnvilZKsync) -> AnvilZKsync,
    ) -> AnvilZKsyncProviderResult<
        <JoinedZksyncWalletFiller<F> as ProviderLayer<L::Provider, Zksync>>::Provider,
    > {
        use alloy::signers::Signer;

        let anvil_zksync_layer = AnvilZKsyncLayer::from(f(Default::default()));
        let url = anvil_zksync_layer.endpoint_url();

        let default_keys = anvil_zksync_layer.instance().keys().to_vec();
        let (default_key, remaining_keys) = default_keys
            .split_first()
            .ok_or(crate::node_bindings::AnvilZKsyncError::NoKeysAvailable)?;

        let default_signer = LocalSigner::from(default_key.clone())
            .with_chain_id(Some(anvil_zksync_layer.instance().chain_id()));
        let mut wallet = ZksyncWallet::from(default_signer);

        for key in remaining_keys {
            let signer = LocalSigner::from(key.clone());
            wallet.register_signer(signer)
        }

        Ok(self.wallet(wallet).layer(anvil_zksync_layer).on_http(url))
    }
}