fix: don't require &mut self for event appends

wasm-bindgen doesn't deal well with &mut references in some
cases, and this was causing issues across various test suites
with the new ResumableTaskStore

crates/dwn-rs-stores/src/surrealdb/core.rs

@@ -10,7 +10,6 @@ use surrealdb::{
     },
     Surreal,
 };
-use ulid::Generator;
 
 use crate::{surrealdb::auth::Auth, StoreError};
 
@@ -20,8 +19,6 @@ pub struct SurrealDB {
     pub(super) db: Surreal<Any>,
     constr: String,
     invalid: bool,
-
-    pub(super) ulid_generator: Generator,
 }
 
 impl Default for SurrealDB {
@@ -57,8 +54,6 @@ impl SurrealDB {
             db: surrealdb::Surreal::init(),
             constr: String::new(),
             invalid: false,
-
-            ulid_generator: Generator::new(),
         }
     }
 

crates/dwn-rs-stores/src/surrealdb/event_log.rs

@@ -1,6 +1,7 @@
 use async_trait::async_trait;
-use dwn_rs_core::MapValue;
+use dwn_rs_core::{MapValue, Value};
 use surrealdb::sql::{Id, Table, Thing};
+use ulid::Ulid;
 
 use crate::{
     Cursor, EventLog, EventLogError, Filters, MessageWatermark, Pagination, Query, QueryError,
@@ -22,18 +23,17 @@ impl EventLog for SurrealDB {
     }
 
     async fn append(
-        &mut self,
+        &self,
         tenant: &str,
         cid: String,
         indexes: MapValue,
     ) -> Result<(), EventLogError> {
-        let id = Thing::from((EVENTS_TABLE, Id::String(cid.to_string())));
-        let watermark = self.ulid_generator.generate()?.to_string();
+        let watermark = Ulid::new();
+        let res = Thing::from((EVENTS_TABLE, cid.to_string().as_str()));
 
         self.as_tenant(tenant, |db| async move {
-            db.create::<Option<CreateEvent>>(id.clone())
+            db.create::<Option<CreateEvent>>(res)
                 .content(CreateEvent {
-                    id,
                     watermark,
                     cid,
                     indexes,
@@ -79,10 +79,9 @@ impl EventLog for SurrealDB {
             .page(Some(page));
 
         let (mut events, cursor) = qb.query().await?;
-        events.sort_by_key(|e| e.watermark.to_owned());
 
         Ok(QueryReturn {
-            items: events.into_iter().map(|e| e.id.id.to_string()).collect(),
+            items: events.into_iter().map(|e| e.cid.to_string()).collect(),
             cursor,
         })
     }

crates/dwn-rs-wasm/src/surrealdb/event_log.rs

@@ -57,22 +57,20 @@ impl SurrealEventLog {
             .open()
             .await
             .map_err(EventLogError::from)
-            .map_err(Into::into)
+            .map_err(Into::<JsError>::into)?;
+        Ok(())
     }
 
     #[wasm_bindgen]
-    pub async fn append(
-        &mut self,
-        tenant: &str,
-        cid: &str,
-        indexes: IndexMap,
-    ) -> Result<(), JsError> {
+    pub async fn append(&self, tenant: &str, cid: &str, indexes: IndexMap) -> Result<(), JsError> {
         let (indexes, _) = indexes.into();
         self.store
             .append(tenant, cid.to_string(), indexes)
             .await
             .map_err(EventLogError::from)
-            .map_err(Into::into)
+            .map_err(Into::<JsError>::into)?;
+
+        Ok(())
     }
 
     #[wasm_bindgen(js_name = getEvents)]