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

//! Layer for `anvil-zksync` wrapper.

use alloy::providers::{Provider, ProviderLayer, RootProvider};
use std::sync::{Arc, OnceLock};
use url::Url;

use crate::{
    network::Zksync,
    node_bindings::{AnvilZKsync, AnvilZKsyncInstance},
};

/// A layer that wraps an [`AnvilZKsync`] config.
///
/// The config will be used to spawn an [`AnvilZKsyncInstance`] when the layer is applied, or when the
/// user requests any information about the anvil node (e.g. via the [`AnvilZKsyncLayer::endpoint_url`]
/// method).
#[derive(Debug, Clone, Default)]
pub struct AnvilZKsyncLayer {
    anvil: AnvilZKsync,
    instance: OnceLock<Arc<AnvilZKsyncInstance>>,
}

impl AnvilZKsyncLayer {
    /// Starts the anvil instance, or gets a reference to the existing instance.
    pub fn instance(&self) -> &Arc<AnvilZKsyncInstance> {
        self.instance
            .get_or_init(|| Arc::new(self.anvil.clone().spawn()))
    }

    /// Get the instance http endpoint.
    #[doc(alias = "http_endpoint_url")]
    pub fn endpoint_url(&self) -> Url {
        self.instance().endpoint_url()
    }
}

impl From<AnvilZKsync> for AnvilZKsyncLayer {
    fn from(anvil: AnvilZKsync) -> Self {
        Self {
            anvil,
            instance: OnceLock::new(),
        }
    }
}

impl<P> ProviderLayer<P, Zksync> for AnvilZKsyncLayer
where
    P: Provider<Zksync>,
{
    type Provider = AnvilZKsyncProvider<P>;

    fn layer(&self, inner: P) -> Self::Provider {
        let anvil = self.instance();
        AnvilZKsyncProvider::new(inner, anvil.clone())
    }
}

/// A provider that wraps an [`AnvilZKsyncInstance`], preventing the instance from
/// being dropped while the provider is in use.
#[derive(Clone, Debug)]
pub struct AnvilZKsyncProvider<P> {
    inner: P,
    _anvil: Arc<AnvilZKsyncInstance>,
}

impl<P> AnvilZKsyncProvider<P>
where
    P: Provider<Zksync>,
{
    /// Creates a new `AnvilZKsyncProvider` with the given inner provider and anvil
    /// instance.
    pub fn new(inner: P, _anvil: Arc<AnvilZKsyncInstance>) -> Self {
        Self { inner, _anvil }
    }
}

impl<P> Provider<Zksync> for AnvilZKsyncProvider<P>
where
    P: Provider<Zksync>,
{
    #[inline(always)]
    fn root(&self) -> &RootProvider<Zksync> {
        self.inner.root()
    }
}