refactor(ai_client): _send_gemini_cli_result() returns Result[str]
This commit is contained in:
+4
-4
@@ -1758,13 +1758,13 @@ def _send_gemini_result(md_content: str, user_message: str, base_dir: str,
|
||||
if monitor.enabled: monitor.end_component("ai_client._send_gemini")
|
||||
return Result(data="", errors=[_classify_gemini_error(e, source="ai_client.gemini")])
|
||||
|
||||
def _send_gemini_cli(md_content: str, user_message: str, base_dir: str,
|
||||
def _send_gemini_cli_result(md_content: str, user_message: str, base_dir: str,
|
||||
file_items: list[dict[str, Any]] | None = None,
|
||||
discussion_history: str = "",
|
||||
pre_tool_callback: Optional[Callable[[str, str, Optional[Callable[[str], str]]], Optional[str]]] = None,
|
||||
qa_callback: Optional[Callable[[str], str]] = None,
|
||||
stream_callback: Optional[Callable[[str], None]] = None,
|
||||
patch_callback: Optional[Callable[[str, str], Optional[str]]] = None) -> str:
|
||||
patch_callback: Optional[Callable[[str, str], Optional[str]]] = None) -> Result[str]:
|
||||
from src.openai_compatible import OpenAICompatibleRequest, NormalizedResponse
|
||||
"""
|
||||
[C: src/ai_server.py:_handle_send]
|
||||
@@ -1865,9 +1865,9 @@ def _send_gemini_cli(md_content: str, user_message: str, base_dir: str,
|
||||
send_func=_send, on_pre_dispatch=_pre_dispatch,
|
||||
)
|
||||
final_text = all_text[-1] if all_text else "(No text returned)"
|
||||
return final_text
|
||||
return Result(data=final_text)
|
||||
except Exception as e:
|
||||
raise ProviderError("unknown", "gemini_cli", e)
|
||||
return Result(data="", errors=[ErrorInfo(kind=ErrorKind.INTERNAL, message=str(e), source="ai_client.gemini_cli", original=e)])
|
||||
|
||||
#endregion: Gemini Provider
|
||||
|
||||
|
||||
Reference in New Issue
Block a user