Update version to 1.1.6, enhance non-blocking behavior in conversation updates.

Author: shenjinti

crates/restsend-wasm/src/conversations.rs

@@ -54,8 +54,8 @@ impl Client {
         let ensureConversationVersion =
             js_sys::Reflect::get(&option, &JsValue::from_str("ensureConversationVersion"))
                 .ok()
-                .map(|v| v.as_bool().unwrap_or(true));
-        
+                .map(|v| v.as_bool().unwrap_or(false));
+
         self.inner
             .sync_chat_logs(
                 topicId,
@@ -66,8 +66,8 @@ impl Client {
             )
             .await
     }
-    
-    pub async fn saveChatLogs(&self, logs:JsValue) -> Result<(), JsValue> {
+
+    pub async fn saveChatLogs(&self, logs: JsValue) -> Result<(), JsValue> {
         let logs = serde_wasm_bindgen::from_value::<Vec<restsend_sdk::models::ChatLog>>(logs)?;
         self.inner.save_chat_logs(&logs).await.map_err(|e| e.into())
     }
@@ -200,14 +200,10 @@ impl Client {
     /// Clear conversation on local storage
     /// #Arguments
     /// * `topicId` - topic id
-    pub async fn clearConversation(
-        &self,
-        topicId: String,
-    ){
+    pub async fn clearConversation(&self, topicId: String) {
         self.inner.clear_conversation(topicId).await.ok();
     }
 
-
     /// Set conversation extra
     /// #Arguments
     /// * `topicId` - topic id

crates/restsend/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "restsend-sdk"
-version = "1.1.5"
+version = "1.1.6"
 edition = "2021"
 
 [lib]

crates/restsend/src/client/conversation.rs

@@ -134,7 +134,7 @@ impl Client {
             .get_conversation(
                 &topic_id,
                 false,
-                ensure_conversation_last_version.unwrap_or(true),
+                ensure_conversation_last_version.unwrap_or(false),
             )
             .await
             .unwrap_or_default();

crates/restsend/src/client/store/conversations.rs

@@ -506,6 +506,10 @@ impl ClientStore {
                             return;
                         }
                     };
+                    if !blocking {
+                        // return if not blocking, just update local conversation
+                        return;
+                    }
                     if let Some(cb) = callback.read().unwrap().as_ref() {
                         cb.on_conversations_updated(vec![c]);
                     };

js/restsend_wasm.d.ts

@@ -847,10 +847,10 @@ export interface InitOutput {
   readonly __wbindgen_export_4: WebAssembly.Table;
   readonly __wbindgen_export_5: WebAssembly.Table;
   readonly __wbindgen_free: (a: number, b: number, c: number) => void;
-  readonly closure587_externref_shim: (a: number, b: number, c: any) => void;
-  readonly _dyn_core__ops__function__FnMut_____Output___R_as_wasm_bindgen__closure__WasmClosure___describe__invoke__he238d3f82a9875d9: (a: number, b: number) => void;
-  readonly closure839_externref_shim: (a: number, b: number, c: any) => void;
-  readonly closure880_externref_shim: (a: number, b: number, c: any, d: any) => void;
+  readonly _dyn_core__ops__function__FnMut_____Output___R_as_wasm_bindgen__closure__WasmClosure___describe__invoke__h18c4b70474f535e4: (a: number, b: number) => void;
+  readonly closure588_externref_shim: (a: number, b: number, c: any) => void;
+  readonly closure840_externref_shim: (a: number, b: number, c: any) => void;
+  readonly closure881_externref_shim: (a: number, b: number, c: any, d: any) => void;
   readonly __wbindgen_start: () => void;
 }
 

js/restsend_wasm.js

@@ -270,20 +270,20 @@ export function logout(endpoint, token) {
     return ret;
 }
 
-function __wbg_adapter_54(arg0, arg1, arg2) {
-    wasm.closure587_externref_shim(arg0, arg1, arg2);
+function __wbg_adapter_54(arg0, arg1) {
+    wasm._dyn_core__ops__function__FnMut_____Output___R_as_wasm_bindgen__closure__WasmClosure___describe__invoke__h18c4b70474f535e4(arg0, arg1);
 }
 
-function __wbg_adapter_57(arg0, arg1) {
-    wasm._dyn_core__ops__function__FnMut_____Output___R_as_wasm_bindgen__closure__WasmClosure___describe__invoke__he238d3f82a9875d9(arg0, arg1);
+function __wbg_adapter_57(arg0, arg1, arg2) {
+    wasm.closure588_externref_shim(arg0, arg1, arg2);
 }
 
 function __wbg_adapter_66(arg0, arg1, arg2) {
-    wasm.closure839_externref_shim(arg0, arg1, arg2);
+    wasm.closure840_externref_shim(arg0, arg1, arg2);
 }
 
 function __wbg_adapter_439(arg0, arg1, arg2, arg3) {
-    wasm.closure880_externref_shim(arg0, arg1, arg2, arg3);
+    wasm.closure881_externref_shim(arg0, arg1, arg2, arg3);
 }
 
 const __wbindgen_enum_BinaryType = ["blob", "arraybuffer"];
@@ -2328,7 +2328,7 @@ function __wbg_get_imports() {
     imports.wbg.__wbg_setRequestHeader_51d371ad5196f6ef = function() { return handleError(function (arg0, arg1, arg2, arg3, arg4) {
         arg0.setRequestHeader(getStringFromWasm0(arg1, arg2), getStringFromWasm0(arg3, arg4));
     }, arguments) };
-    imports.wbg.__wbg_setTimeout_ec4d2ae203c942d7 = function(arg0, arg1) {
+    imports.wbg.__wbg_setTimeout_691d6252a6327657 = function(arg0, arg1) {
         setTimeout(arg0, arg1 >>> 0);
     };
     imports.wbg.__wbg_set_37837023f3d740e8 = function(arg0, arg1, arg2) {
@@ -2532,27 +2532,27 @@ function __wbg_get_imports() {
         return ret;
     };
     imports.wbg.__wbindgen_closure_wrapper1162 = function(arg0, arg1, arg2) {
-        const ret = makeMutClosure(arg0, arg1, 584, __wbg_adapter_54);
+        const ret = makeMutClosure(arg0, arg1, 585, __wbg_adapter_54);
         return ret;
     };
     imports.wbg.__wbindgen_closure_wrapper1163 = function(arg0, arg1, arg2) {
-        const ret = makeMutClosure(arg0, arg1, 584, __wbg_adapter_57);
+        const ret = makeMutClosure(arg0, arg1, 585, __wbg_adapter_57);
         return ret;
     };
     imports.wbg.__wbindgen_closure_wrapper1164 = function(arg0, arg1, arg2) {
-        const ret = makeMutClosure(arg0, arg1, 584, __wbg_adapter_54);
+        const ret = makeMutClosure(arg0, arg1, 585, __wbg_adapter_57);
         return ret;
     };
     imports.wbg.__wbindgen_closure_wrapper1166 = function(arg0, arg1, arg2) {
-        const ret = makeMutClosure(arg0, arg1, 584, __wbg_adapter_54);
+        const ret = makeMutClosure(arg0, arg1, 585, __wbg_adapter_57);
         return ret;
     };
-    imports.wbg.__wbindgen_closure_wrapper1169 = function(arg0, arg1, arg2) {
-        const ret = makeMutClosure(arg0, arg1, 584, __wbg_adapter_54);
+    imports.wbg.__wbindgen_closure_wrapper1170 = function(arg0, arg1, arg2) {
+        const ret = makeMutClosure(arg0, arg1, 585, __wbg_adapter_57);
         return ret;
     };
     imports.wbg.__wbindgen_closure_wrapper2265 = function(arg0, arg1, arg2) {
-        const ret = makeMutClosure(arg0, arg1, 840, __wbg_adapter_66);
+        const ret = makeMutClosure(arg0, arg1, 841, __wbg_adapter_66);
         return ret;
     };
     imports.wbg.__wbindgen_debug_string = function(arg0, arg1) {

js/restsend_wasm_bg.wasm

@@ -102,8 +102,8 @@ export const __externref_table_alloc: () => number;
 export const __wbindgen_export_4: WebAssembly.Table;
 export const __wbindgen_export_5: WebAssembly.Table;
 export const __wbindgen_free: (a: number, b: number, c: number) => void;
-export const closure587_externref_shim: (a: number, b: number, c: any) => void;
-export const _dyn_core__ops__function__FnMut_____Output___R_as_wasm_bindgen__closure__WasmClosure___describe__invoke__he238d3f82a9875d9: (a: number, b: number) => void;
-export const closure839_externref_shim: (a: number, b: number, c: any) => void;
-export const closure880_externref_shim: (a: number, b: number, c: any, d: any) => void;
+export const _dyn_core__ops__function__FnMut_____Output___R_as_wasm_bindgen__closure__WasmClosure___describe__invoke__h18c4b70474f535e4: (a: number, b: number) => void;
+export const closure588_externref_shim: (a: number, b: number, c: any) => void;
+export const closure840_externref_shim: (a: number, b: number, c: any) => void;
+export const closure881_externref_shim: (a: number, b: number, c: any, d: any) => void;
 export const __wbindgen_start: () => void;