support process message function.

Author: JDOxygen

CHANGELOG.md

@@ -9,6 +9,37 @@ All notable changes to this project will be documented in this file.
 
 ---
 
+## [1.0.9.3] - 2025-12-12
+### Added
+- Added oxy.BaseLLM parameter to support custom multimodal base64 prefixes.
+- Added func_process_message method to the MAS class for unified message processing, refer to [./examples/backend/demo_process_message.py](./examples/backend/demo_process_message.py)
+
+### Fixed
+- When the send_msg_key parameter of the chat_with_agent function is empty, messages will not be sent.
+
+---
+
+## [1.0.9.2] - 2025-12-09
+### Added
+- Added stream_end message as an indicator for the end of streaming messages.
+- Stream messages now support batch storage.
+
+### Changed
+- Modified the structure of the message table, added new fields.
+
+---
+
+## [1.0.9.1] - 2025-12-04
+### Added
+- Added pre-logging of payloads for easier troubleshooting.
+- Standardized SSE message fields: id, event, data.
+- SSEOxyGent now forwards headers transparently.
+
+### Changed
+- When storing in the history table, the answer field in memory is forcibly converted to a string.
+
+---
+
 ## [1.0.8] - 2025-11-14
 
 ### Added

CHANGELOG_zh.md

@@ -9,6 +9,17 @@
 
 ---
 
+## [1.0.9.3] - 2025-12-12
+
+### Added
+- 新增oxy.BaseLLM参数，支持自定义多模态base64前缀
+- MAS类新增func_process_message方法，用于统一处理消息，详见 [./examples/backend/demo_process_message.py](./examples/backend/demo_process_message.py)
+
+### Fixed
+- chat_with_agent函数入参send_msg_key参数为空时，修改为不发送消息
+
+---
+
 ## [1.0.9.2] - 2025-12-09
 
 ### Added
@@ -23,11 +34,13 @@
 ## [1.0.9.1] - 2025-12-04
 
 ### Added
-- 打印payload日志
-- history表存储时，memory的answer字段强转str
+- 前置打印payload日志，便于排除
 - 标准化sse消息字段id、event、data
 - SSEOxyGent透传headers
 
+### Changed
+- history表存储时，memory的answer字段强转str
+
 ---
 
 ## [1.0.8] - 2025-11-14

examples/advanced/demo_multimodal.py

@@ -11,6 +11,7 @@
         model_name=os.getenv("DEFAULT_VLM_MODEL_NAME"),
         is_multimodal_supported=True,  # 设置支持多模态
         is_convert_url_to_base64=True,  # 设置将图片链接转换为base64
+        base64_image_prefix="data:image/jpeg",  # 设置base64图片前缀
     ),
     oxy.ChatAgent(
         name="vision_agent",

examples/backend/demo_process_message.py

@@ -0,0 +1,36 @@
+import asyncio
+import os
+
+from oxygent import MAS, Config, OxyRequest, oxy
+
+Config.set_message_is_show_in_terminal(True)
+
+
+def process_message(dict_message: dict, oxy_request: OxyRequest) -> dict:
+    if dict_message["data"]["type"] == "stream":
+        dict_message["data"]["content"]["delta"] += "-"
+    return dict_message
+
+
+oxy_space = [
+    oxy.HttpLLM(
+        name="default_llm",
+        api_key=os.getenv("DEFAULT_LLM_API_KEY"),
+        base_url=os.getenv("DEFAULT_LLM_BASE_URL"),
+        model_name=os.getenv("DEFAULT_LLM_MODEL_NAME"),
+        llm_params={"stream": True},
+    ),
+    oxy.ChatAgent(
+        name="qa_agent",
+        llm_model="default_llm",
+    ),
+]
+
+
+async def main():
+    async with MAS(oxy_space=oxy_space, func_process_message=process_message) as mas:
+        await mas.start_web_service(first_query="hello")
+
+
+if __name__ == "__main__":
+    asyncio.run(main())

oxygent/mas.py

@@ -98,6 +98,10 @@ class MAS(BaseModel):
         lambda x: None, exclude=True, description="interceptor function"
     )
 
+    func_process_message: Optional[Callable] = Field(
+        lambda x, oxy_request: x, exclude=True, description="process message function"
+    )
+
     routers: list = Field(default_factory=list)
     middlewares: list = Field(default_factory=list)
 

oxygent/schemas/oxy.py

@@ -356,9 +356,12 @@ async def start(self) -> "OxyResponse":
 
     async def send_message(self, message=None, event=None, id=None):
         if self.mas and self.is_send_message:
-            args = {"id": id, "event": event, "data": message}
-            filtered_args = {k: v for k, v in args.items() if v is not None}
-            sse_message = SSEMessage(**filtered_args)
+            dict_message = {"id": id, "event": event, "data": message}
+            dict_message_processed = self.mas.func_process_message(dict_message, self)
+            dict_message_filtered = {
+                k: v for k, v in dict_message_processed.items() if v is not None
+            }
+            sse_message = SSEMessage(**dict_message_filtered)
             redis_key = (
                 f"{self.mas.message_prefix}:{self.mas.name}:{self.current_trace_id}"
             )