Fix/rust sdk (#56)

* feat(sdk-rust): add end-to-end example for TinyHumansMemoryClient

- Introduced a new example script `example_e2e.rs` demonstrating the usage of the TinyHumansMemoryClient.
- Implemented various steps including memory insertion, job checking, document listing, and querying memory.
- Enhanced logging for better traceability during the execution of the example.
- Updated `list_documents` method to accept parameters for namespace, limit, and offset, improving flexibility in document retrieval.

* fix(sdk-rust): clean up whitespace and ensure newline at end of file

- Removed unnecessary whitespace in `example_e2e.rs` for cleaner code.
- Added a newline at the end of `example_e2e.rs` to adhere to file formatting standards.
- Reformatted error message in `lib.rs` for better readability in validation checks.

* fix(sdk-rust): update example scripts for improved functionality

- Updated `example_e2e.rs` to correctly utilize the document ID in memory operations, ensuring all steps are executed.
- Enhanced `test_routes.rs` to include parameters for the `list_documents` method, allowing for better control over document retrieval.

Author: YellowSnnowmann

packages/sdk-rust/examples/example_e2e.rs

@@ -178,13 +178,13 @@ async fn main() {
         .map(|d| d.as_millis())
         .unwrap_or(0);
     let namespace = "sdk-rust-e2e".to_string();
-    let single_doc_id = format!("sdk-rust-e2e-doc-single-{ts}");
+    let _single_doc_id = format!("sdk-rust-e2e-doc-single-{ts}");
 
     let result = async {
-        // let insert_job_id = step1_insert_memory(&client, &namespace, &single_doc_id).await?;
-        // step2_check_ingestion_job(&client, &insert_job_id).await?;
+        let insert_job_id = step1_insert_memory(&client, &namespace, &single_doc_id).await?;
+        step2_check_ingestion_job(&client, &insert_job_id).await?;
         step3_list_documents(&client, &namespace).await?;
-        // step4_get_document(&client, &namespace, &single_doc_id).await?;
+        step4_get_document(&client, &namespace, &single_doc_id).await?;
 
         if let Err(err) = step5_query_memory(&client, &namespace).await {
             eprintln!("[warn] step5 queryMemory skipped: {err}");

packages/sdk-rust/examples/test_routes.rs

@@ -4,10 +4,10 @@ use std::time::{SystemTime, UNIX_EPOCH};
 
 use tinyhumansai::{
     BatchDocumentItem, BatchInsertDocumentsParams, ChatMessage, DeleteMemoryParams,
-    InsertDocumentParams, InsertMemoryParams, InteractionLevel, MemoryChatParams,
-    MemoryConversationParams, MemoryInteractionsParams, MemoryThoughtsParams, QueryMemoriesParams,
-    QueryMemoryParams, RecallMemoriesContextParams, RecallMemoriesParams, RecallMemoryParams,
-    SourceType, TinyHumanConfig, TinyHumansError, TinyHumansMemoryClient,
+    InsertDocumentParams, InsertMemoryParams, InteractionLevel, ListDocumentsParams,
+    MemoryChatParams, MemoryConversationParams, MemoryInteractionsParams, MemoryThoughtsParams,
+    QueryMemoriesParams, QueryMemoryParams, RecallMemoriesContextParams, RecallMemoriesParams,
+    RecallMemoryParams, SourceType, TinyHumanConfig, TinyHumansError, TinyHumansMemoryClient,
 };
 
 type CheckResults = Vec<(String, bool, String)>;
@@ -294,7 +294,13 @@ async fn main() {
     push_result(
         &mut results,
         "list_documents",
-        client.list_documents().await,
+        client
+            .list_documents(ListDocumentsParams {
+                namespace: Some(namespace.clone()),
+                limit: Some(50.0),
+                offset: Some(0.0),
+            })
+            .await,
         false,
     );