fix: don't ignore given tags for events

enmand · Jun 21, 2024 · 956cd78 · 956cd78
1 parent 434d8ba
commit 956cd78
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 2 deletions.
diff --git a/crates/dwn-rs-stores/src/stores.rs b/crates/dwn-rs-stores/src/stores.rs
@@ -92,6 +92,7 @@ pub trait EventLog {
         tenant: &str,
         cid: String,
         indexes: MapValue,
+        tags: MapValue,
     ) -> Result<(), EventLogError>;
 
     async fn get_events(

diff --git a/crates/dwn-rs-stores/src/surrealdb/event_log.rs b/crates/dwn-rs-stores/src/surrealdb/event_log.rs
@@ -26,6 +26,7 @@ impl EventLog for SurrealDB {
         tenant: &str,
         cid: String,
         indexes: MapValue,
+        tags: MapValue,
     ) -> Result<(), EventLogError> {
         // get a mutable reference to self.gen
         let watermark = self.gen.lock().await.generate()?;
@@ -37,6 +38,7 @@ impl EventLog for SurrealDB {
                     watermark,
                     cid,
                     indexes,
+                    tags,
                 })
                 .await
                 .map_err(SurrealDBError::from)

diff --git a/crates/dwn-rs-stores/src/surrealdb/models.rs b/crates/dwn-rs-stores/src/surrealdb/models.rs
@@ -68,6 +68,7 @@ pub(crate) struct CreateEvent {
     pub(super) watermark: Ulid,
     #[serde(flatten)]
     pub(super) indexes: MapValue,
+    pub(super) tags: MapValue,
 }
 
 #[derive(Serialize, Deserialize, Debug)]

diff --git a/crates/dwn-rs-wasm/src/surrealdb/event_log.rs b/crates/dwn-rs-wasm/src/surrealdb/event_log.rs
@@ -63,9 +63,9 @@ impl SurrealEventLog {
 
     #[wasm_bindgen]
     pub async fn append(&self, tenant: &str, cid: &str, indexes: IndexMap) -> Result<(), JsError> {
-        let (indexes, _) = indexes.into();
+        let (indexes, tags) = indexes.into();
         self.store
-            .append(tenant, cid.to_string(), indexes)
+            .append(tenant, cid.to_string(), indexes, tags)
             .await
             .map_err(EventLogError::from)
             .map_err(Into::<JsError>::into)?;