nexus-sdk 2.1.1

Rust SDK for Nexus protocol types, RPC access, and transaction construction.
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

use {
    crate::sui,
    std::{convert::Infallible, error::Error},
};

/// Defines the Sui request and output conversion for an
/// [`EventIngestor`](crate::sui::events::EventIngestor).
pub trait EventQuery: Send + Sync + 'static {
    /// Event type emitted by the query.
    type Output: Send + 'static;
    /// Error returned while converting a Sui event.
    type Error: Error + Send + Sync + 'static;

    /// Returns the server filter for this query.
    fn filter(&self) -> sui::grpc::EventFilter;

    /// Returns the fields requested by this query.
    fn read_mask(&self) -> sui::grpc::FieldMask;

    /// Converts one Sui event into an optional query result.
    ///
    /// Returning [`None`] intentionally excludes an event accepted by the
    /// server filter.
    fn decode(
        &self,
        event: sui::grpc::Event,
    ) -> impl std::future::Future<Output = Result<Option<Self::Output>, Self::Error>> + Send;
}

/// Query that returns unmodified Sui events.
#[derive(Clone)]
pub struct RawEventQuery {
    filter: sui::grpc::EventFilter,
    read_mask: sui::grpc::FieldMask,
}

impl RawEventQuery {
    /// Creates a query from a server filter and requested fields.
    pub fn new(filter: sui::grpc::EventFilter, read_mask: sui::grpc::FieldMask) -> Self {
        Self { filter, read_mask }
    }
}

impl EventQuery for RawEventQuery {
    type Error = Infallible;
    type Output = sui::grpc::Event;

    fn filter(&self) -> sui::grpc::EventFilter {
        self.filter.clone()
    }

    fn read_mask(&self) -> sui::grpc::FieldMask {
        self.read_mask.clone()
    }

    async fn decode(&self, event: sui::grpc::Event) -> Result<Option<Self::Output>, Self::Error> {
        Ok(Some(event))
    }
}