fix: apply system prompt

Author: L-jasmine

src/ai/mod.rs

@@ -931,6 +931,8 @@ pub struct ResponsesChatRequest<'a> {
     pub model: &'a str,
     #[serde(skip_serializing_if = "str::is_empty")]
     pub previous_response_id: &'a str,
+    #[serde(skip_serializing_if = "str::is_empty")]
+    pub instructions: &'a str,
     pub input: &'a str,
     #[serde(flatten)]
     pub extra: serde_json::Value,
@@ -1220,12 +1222,18 @@ impl ResponsesSession {
 
         let req = ResponsesChatRequest {
             model: &self.model,
+            instructions: &self.instructions,
             previous_response_id: &self.previous_response_id,
             input,
             extra,
             stream: true,
         };
 
+        log::debug!(
+            "#### send to responses llm:\n{}\n#####",
+            serde_json::to_string_pretty(&req)?
+        );
+
         let mut response_builder = reqwest::Client::new().post(&self.url);
         if !self.api_key.is_empty() {
             response_builder = response_builder.bearer_auth(&self.api_key);
@@ -1269,6 +1277,7 @@ impl ResponsesSession {
 
         let req = ResponsesChatRequest {
             model: &self.model,
+            instructions: &self.instructions,
             previous_response_id: &self.previous_response_id,
             input: "",
             extra,

src/config.rs

@@ -72,6 +72,9 @@ pub struct ResponsesConfig {
     pub mcp_server: Vec<MCPServerConfig>,
     #[serde(default)]
     pub extra: Option<serde_json::Value>,
+
+    #[serde(default)]
+    pub sys_prompts: Vec<Content>,
 }
 
 impl ResponsesConfig {

src/services/ws/stable/llm.rs

@@ -318,9 +318,21 @@ impl crate::config::ResponsesConfig {
     pub async fn instructions(&self) -> String {
         let r = regex!(r"\{\{(?P<url>\s*https?://\S+?\s*)\}\}");
 
+        let instructions;
+
+        if let Some(system) = self.sys_prompts.first() {
+            if system.role == crate::ai::llm::Role::System {
+                instructions = &system.message;
+            } else {
+                instructions = &self.instructions;
+            }
+        } else {
+            instructions = &self.instructions;
+        }
+
         let mut urls = vec![];
         let mut contents = HashMap::new();
-        for cap in r.captures_iter(&self.instructions) {
+        for cap in r.captures_iter(&instructions) {
             if let Some(url) = cap.name("url") {
                 let url = url.as_str().trim();
                 urls.push(url.to_string());
@@ -338,7 +350,7 @@ impl crate::config::ResponsesConfig {
             }
         }
 
-        let new_instructions = r.replace_all(&self.instructions, |caps: &lazy_regex::Captures| {
+        let new_instructions = r.replace_all(&instructions, |caps: &lazy_regex::Captures| {
             let url = caps.name("url").unwrap().as_str().trim();
             contents.get(url).cloned().unwrap_or(url.to_string())
         });