Enable querying of event stream metadata

src/clients.rs

@@ -5,7 +5,7 @@ use serde::de::DeserializeOwned;
 use tracing::{info, instrument};
 use uuid::Uuid;
 
-use crate::model::{app, run};
+use crate::model::{app, event_stream, run};
 
 pub type ClientResult<T> = Result<T, ClientError>;
 
@@ -28,6 +28,14 @@ impl TiledClient {
     pub async fn run_metadata(&self, id: Uuid) -> ClientResult<run::RunMetadataRoot> {
         self.request(&format!("/api/v1/metadata/{id}")).await
     }
+    pub async fn event_stream_metadata(
+        &self,
+        id: Uuid,
+        stream: String,
+    ) -> ClientResult<event_stream::EventStreamMetadataRoot> {
+        self.request(&format!("/api/v1/metadata/{id}/{stream}"))
+            .await
+    }
 }
 
 #[derive(Debug)]

src/model.rs

@@ -1,5 +1,6 @@
 pub(crate) mod app;
 pub(crate) mod container;
+pub(crate) mod event_stream;
 pub(crate) mod node;
 pub(crate) mod run;
 
@@ -24,6 +25,14 @@ impl TiledQuery {
     ) -> async_graphql::Result<run::RunMetadataRoot, ClientError> {
         self.0.run_metadata(id).await
     }
+    #[instrument(skip(self))]
+    async fn event_stream_metadata(
+        &self,
+        id: Uuid,
+        stream: String,
+    ) -> async_graphql::Result<event_stream::EventStreamMetadataRoot, ClientError> {
+        self.0.event_stream_metadata(id, stream).await
+    }
 }
 
 #[cfg(test)]

src/model/event_stream.rs

@@ -0,0 +1,45 @@
+use std::collections::HashMap;
+
+use async_graphql::SimpleObject;
+use serde::{Deserialize, Serialize};
+use serde_json::Value;
+use uuid::Uuid;
+
+use crate::model::{container, node};
+
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize, SimpleObject)]
+pub struct EventStreamMetadataRoot {
+    pub data: EventStreamData,
+    pub error: Value,
+    pub links: Option<node::Links>,
+    pub meta: Value,
+}
+
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize, SimpleObject)]
+pub struct EventStreamData {
+    pub id: String,
+    pub attributes: EventStreamContainerAttributes,
+    pub links: node::Links,
+    pub meta: Value,
+}
+
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize, SimpleObject)]
+pub struct EventStreamContainerAttributes {
+    pub ancestors: Vec<Value>,
+    pub structure_family: String,
+    pub specs: Vec<container::Specs>,
+    pub metadata: EventStreamMetadata,
+    pub structure: container::Structure,
+    pub access_blob: Value,
+    pub sorting: Option<Vec<container::Sorting>>,
+    pub data_sources: Value,
+}
+
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize, SimpleObject)]
+pub struct EventStreamMetadata {
+    configuration: HashMap<String, HashMap<String, Value>>,
+    data_keys: HashMap<String, HashMap<String, Value>>,
+    time: f64,
+    uid: Uuid,
+    hints: HashMap<String, Value>,
+}