fix: fix for Gemini

Author: zensh

agents/anda_assistant/Cargo.toml

@@ -3,7 +3,7 @@ name = "anda_assistant"
 description = "Anda -- an AI Assistant powered by the Knowledge Interaction Protocol (KIP)."
 repository = "https://github.com/ldclabs/anda/tree/main/agents/anda_assistant"
 publish = true
-version = "0.4.3"
+version = "0.4.4"
 edition.workspace = true
 keywords.workspace = true
 categories.workspace = true

anda_engine/Cargo.toml

@@ -3,7 +3,7 @@ name = "anda_engine"
 description = "Agents engine for Anda -- an AI agent framework built with Rust, powered by ICP and TEEs."
 repository = "https://github.com/ldclabs/anda/tree/main/anda_engine"
 publish = true
-version.workspace = true
+version = "0.9.6"
 edition.workspace = true
 keywords.workspace = true
 categories.workspace = true

anda_engine/src/memory.rs

@@ -13,7 +13,7 @@ use anda_db::{
 use anda_db_schema::{AndaDBSchema, FieldEntry, FieldType, Ft, Fv, Json, Schema, SchemaError};
 use anda_db_tfs::jieba_tokenizer;
 use anda_kip::{
-    CommandType, DescribeTarget, KIP_FUNCTION_DEFINITION, KipError, META_SYSTEM_NAME, MetaCommand,
+    CommandType, DescribeTarget, KipError, META_SYSTEM_NAME, MetaCommand,
     PERSON_TYPE, Request, Response,
 };
 use candid::Principal;
@@ -33,8 +33,37 @@ use crate::{
     rfc3339_datetime, rfc3339_datetime_now, unix_ms,
 };
 
-pub static FUNCTION_DEFINITION: LazyLock<FunctionDefinition> =
-    LazyLock::new(|| serde_json::from_value(KIP_FUNCTION_DEFINITION.clone()).unwrap());
+pub static FUNCTION_DEFINITION: LazyLock<FunctionDefinition> = LazyLock::new(|| {
+    serde_json::from_value(json!({
+        "name": "execute_kip",
+        "description": "Executes one or more KIP (Knowledge Interaction Protocol) commands against the Cognitive Nexus to interact with your persistent memory.",
+        "parameters": {
+            "type": "object",
+            "properties": {
+                "command": {
+                    "type": "string",
+                    "description": "A complete, multi-line KIP command (KQL, KML or META) string to be executed. Mutually exclusive with 'commands'."
+                },
+                "commands": {
+                    "type": "array",
+                    "description": "An array of KIP commands for batch execution (reduces round-trips). Mutually exclusive with 'command'. Each element can be a string (uses shared 'parameters') or an object with 'command' and optional 'parameters' (overrides shared parameters). Commands are executed sequentially; execution stops on first error.",
+                    "items": {
+                    "type": "string"
+                    }
+                },
+                "parameters": {
+                    "type": "object",
+                    "description": "An optional JSON object of key-value pairs used for safe substitution of placeholders in the command string(s). Placeholders should start with ':' (e.g., :name, :limit). IMPORTANT: A placeholder must represent a complete JSON value token (e.g., name: :name). Do not embed placeholders inside quoted strings (e.g., \"Hello :name\"), because substitution uses JSON serialization."
+                },
+                "dry_run": {
+                    "type": "boolean",
+                    "description": "If set to true, the command(s) will only be validated for syntactical and logical correctness without being executed.",
+                    "default": false
+                }
+            }
+        }
+    })).unwrap()
+});
 
 #[derive(Debug, Clone, Deserialize, Serialize, AndaDBSchema)]
 pub struct Conversation {
@@ -665,7 +694,7 @@ impl Tool<BaseCtx> for GetResourceContentTool {
             name: self.name(),
             description: self.description(),
             parameters: self.schema.clone(),
-            strict: Some(true),
+            strict: None,
         }
     }
 
@@ -733,7 +762,7 @@ impl Tool<BaseCtx> for ListConversationsTool {
             name: self.name(),
             description: self.description(),
             parameters: self.schema.clone(),
-            strict: Some(true),
+            strict: None,
         }
     }
 
@@ -804,7 +833,7 @@ impl Tool<BaseCtx> for SearchConversationsTool {
             name: self.name(),
             description: self.description(),
             parameters: self.schema.clone(),
-            strict: Some(true),
+            strict: None,
         }
     }
 
@@ -910,7 +939,7 @@ impl Tool<BaseCtx> for MemoryTool {
             name: self.name(),
             description: self.description(),
             parameters: self.schema.clone(),
-            strict: Some(true),
+            strict: None,
         }
     }
 

anda_engine/src/model/gemini/types.rs

@@ -238,7 +238,7 @@ impl From<ContentPart> for Part {
 }
 
 impl From<Part> for ContentPart {
-    fn from(value: Part) -> Self {
+    fn from(mut value: Part) -> Self {
         match value.data {
             PartKind::Text(text) if value.thought == Some(true) => ContentPart::Reasoning { text },
             PartKind::Text(text) => ContentPart::Text { text },
@@ -270,7 +270,10 @@ impl From<Part> for ContentPart {
                 call_id: id,
                 remote_id: None,
             },
-            _ => ContentPart::Any(json!(value.data)),
+            _ => {
+                value.thought_signature = None;
+                ContentPart::Any(json!(value.data))
+            }
         }
     }
 }
@@ -308,7 +311,7 @@ pub enum PartKind {
         #[serde(skip_serializing_if = "Option::is_none")]
         scheduling: Option<String>,
         #[serde(skip_serializing_if = "Option::is_none")]
-        parts: Option<Vec<Part>>,
+        parts: Option<Vec<Value>>,
     },
     InlineData {
         mime_type: String,
@@ -634,12 +637,15 @@ pub enum BlockReason {
 #[derive(Debug, Serialize, Deserialize, Clone)]
 #[serde(rename_all = "camelCase")]
 pub struct UsageMetadata {
+    #[serde(default)]
     pub prompt_token_count: u32,
 
-    pub candidates_token_count: u32,
-
+    #[serde(default)]
     pub total_token_count: u32,
 
+    #[serde(default)]
+    pub candidates_token_count: u32,
+
     #[serde(default)]
     pub thoughts_token_count: u32,
 }
@@ -654,6 +660,20 @@ pub struct ThinkingConfig {
     /// The number of thoughts tokens that the model should generate.
     #[serde(skip_serializing_if = "Option::is_none")]
     pub thinking_budget: Option<u32>,
+    /// Controls the maximum depth of the model's internal reasoning process before it produces a response. If not specified, the default is HIGH. Recommended for Gemini 3 or later models. Use with earlier models results in an error.
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub thinking_level: Option<ThinkingLevel>,
+}
+
+#[derive(Debug, Serialize, Deserialize, Clone, Default, PartialEq)]
+#[serde(rename_all = "SCREAMING_SNAKE_CASE")]
+pub enum ThinkingLevel {
+    #[default]
+    ThinkingLevelUnspecified,
+    Minimal,
+    Low,
+    Medium,
+    High,
 }
 
 #[derive(Debug, Serialize, Deserialize, Clone, Default, PartialEq)]

anda_engine_server/Cargo.toml

@@ -3,7 +3,7 @@ name = "anda_engine_server"
 description = "A http server to serve multiple Anda engines."
 repository = "https://github.com/ldclabs/anda/tree/main/anda_engine_server"
 publish = true
-version = "0.9.5"
+version = "0.9.6"
 edition.workspace = true
 keywords.workspace = true
 categories.workspace = true

anda_web3_client/Cargo.toml

@@ -3,7 +3,7 @@ name = "anda_web3_client"
 description = "The Rust SDK for Web3 integration in non-TEE environments."
 repository = "https://github.com/ldclabs/anda/tree/main/anda_web3_client"
 publish = true
-version.workspace = true
+version = "0.9.6"
 edition.workspace = true
 keywords.workspace = true
 categories.workspace = true