sui-graphql-client: return a tuple of Event, TxDigest when querying e…

…vents (#68)

crates/sui-graphql-client/src/lib.rs

@@ -915,12 +915,12 @@ impl Client {
     // Events API
     // ===========================================================================
 
-    /// Return a page of events based on the (optional) event filter.
+    /// Return a page of tuple (event, transaction digest) based on the (optional) event filter.
     pub async fn events(
         &self,
         filter: Option<EventFilter>,
         pagination_filter: PaginationFilter,
-    ) -> Result<Page<Event>> {
+    ) -> Result<Page<(Event, TransactionDigest)>> {
         let (after, before, first, last) = self.pagination_filter(pagination_filter).await;
 
         let operation = EventsQuery::build(EventsQueryArgs {
@@ -940,17 +940,32 @@ impl Client {
         if let Some(events) = response.data {
             let ec = events.events;
             let page_info = ec.page_info;
-            let nodes = ec
+
+            let events_with_digests = ec
                 .nodes
                 .into_iter()
-                .map(|e| e.bcs.0)
-                .map(|b| base64ct::Base64::decode_vec(&b))
-                .collect::<Result<Vec<_>, base64ct::Error>>()?
-                .iter()
-                .map(|b| bcs::from_bytes::<Event>(b))
-                .collect::<Result<Vec<_>, bcs::Error>>()?;
+                .map(|node| -> Result<(Event, TransactionDigest)> {
+                    let event =
+                        bcs::from_bytes::<Event>(&base64ct::Base64::decode_vec(&node.bcs.0)?)?;
+
+                    let tx_digest = node
+                        .transaction_block
+                        .ok_or_else(Error::empty_response_error)?
+                        .digest
+                        .ok_or_else(|| {
+                            Error::from_error(
+                                Kind::Deserialization,
+                                "Expected a transaction digest for this event, but it is missing.",
+                            )
+                        })?;
+
+                    let tx_digest = TransactionDigest::from_base58(&tx_digest)?;
+
+                    Ok((event, tx_digest))
+                })
+                .collect::<Result<Vec<_>>>()?;
 
-            Ok(Page::new(page_info, nodes))
+            Ok(Page::new(page_info, events_with_digests))
         } else {
             Ok(Page::new_empty())
         }
@@ -961,7 +976,7 @@ impl Client {
         &self,
         filter: Option<EventFilter>,
         streaming_direction: Direction,
-    ) -> impl Stream<Item = Result<Event>> + '_ {
+    ) -> impl Stream<Item = Result<(Event, TransactionDigest)>> + '_ {
         stream_paginated_query(
             move |pag_filter| self.events(filter.clone(), pag_filter),
             streaming_direction,

crates/sui-graphql-client/src/query_types/events.rs

@@ -2,6 +2,7 @@
 // SPDX-License-Identifier: Apache-2.0
 
 use crate::query_types::schema;
+use crate::query_types::transaction::TransactionBlockDigest;
 use crate::query_types::Address;
 use crate::query_types::Base64;
 use crate::query_types::PageInfo;
@@ -54,4 +55,5 @@ pub struct EventFilter {
 #[cynic(schema = "rpc", graphql_type = "Event")]
 pub struct Event {
     pub bcs: Base64,
+    pub transaction_block: Option<TransactionBlockDigest>,
 }

crates/sui-graphql-client/src/query_types/transaction.rs

@@ -91,6 +91,12 @@ pub struct TransactionBlock {
     pub signatures: Option<Vec<Base64>>,
 }
 
+#[derive(cynic::QueryFragment, Debug)]
+#[cynic(schema = "rpc", graphql_type = "TransactionBlock")]
+pub struct TransactionBlockDigest {
+    pub digest: Option<String>,
+}
+
 #[derive(cynic::QueryFragment, Debug)]
 #[cynic(schema = "rpc", graphql_type = "TransactionBlock")]
 pub struct TxBlockEffects {