fix: files messages stack

Author: cotovanu-cristian

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "uipath-langchain"
-version = "0.4.21"
+version = "0.4.22"
 description = "Python SDK that enables developers to build and deploy LangGraph agents to the UiPath Cloud Platform"
 readme = { file = "README.md", content-type = "text/markdown" }
 requires-python = ">=3.11"

…chain/agent/react/multimodal/__init__.py …h_langchain/agent/multimodal/__init__.pysrc/uipath_langchain/agent/react/multimodal/__init__.py renamed to src/uipath_langchain/agent/multimodal/__init__.py src/uipath_langchain/agent/react/multimodal/__init__.py renamed to src/uipath_langchain/agent/multimodal/__init__.py

@@ -1,13 +1,18 @@
 """Multimodal LLM input handling (images, PDFs, etc.)."""
 
-from .invoke import build_file_content_block, llm_call_with_files
+from .invoke import (
+    build_file_content_block,
+    build_file_content_blocks,
+    llm_call_with_files,
+)
 from .types import IMAGE_MIME_TYPES, FileInfo
 from .utils import download_file_base64, is_image, is_pdf, sanitize_filename
 
 __all__ = [
     "FileInfo",
     "IMAGE_MIME_TYPES",
     "build_file_content_block",
+    "build_file_content_blocks",
     "download_file_base64",
     "is_image",
     "is_pdf",

…ngchain/agent/react/multimodal/invoke.py …ath_langchain/agent/multimodal/invoke.pysrc/uipath_langchain/agent/react/multimodal/invoke.py renamed to src/uipath_langchain/agent/multimodal/invoke.py src/uipath_langchain/agent/react/multimodal/invoke.py renamed to src/uipath_langchain/agent/multimodal/invoke.py

@@ -1,5 +1,6 @@
 """LLM invocation with multimodal file attachments."""
 
+import asyncio
 from typing import Any
 
 from langchain_core.language_models import BaseChatModel
@@ -43,6 +44,24 @@ async def build_file_content_block(
     raise ValueError(f"Unsupported mime_type={file_info.mime_type}")
 
 
+async def build_file_content_blocks(files: list[FileInfo]) -> list[DataContentBlock]:
+    """Build content blocks from file attachments.
+
+    Args:
+        files: List of file information to convert to content blocks
+
+    Returns:
+        List of DataContentBlock instances for the files
+    """
+    if not files:
+        return []
+
+    file_content_blocks: list[DataContentBlock] = await asyncio.gather(
+        *[build_file_content_block(file) for file in files]
+    )
+    return file_content_blocks
+
+
 async def llm_call_with_files(
     messages: list[AnyMessage],
     files: list[FileInfo],

…angchain/agent/react/multimodal/types.py …path_langchain/agent/multimodal/types.pysrc/uipath_langchain/agent/react/multimodal/types.py renamed to src/uipath_langchain/agent/multimodal/types.py src/uipath_langchain/agent/react/multimodal/types.py renamed to src/uipath_langchain/agent/multimodal/types.py

@@ -14,7 +14,7 @@
 from uipath_langchain.agent.tools.structured_tool_with_argument_properties import (
     StructuredToolWithArgumentProperties,
 )
-from uipath_langchain.llm import get_payload_handler
+from uipath_langchain.chat.handlers import get_payload_handler
 
 from ..exceptions import AgentTerminationException
 from .constants import (

…angchain/agent/react/multimodal/utils.py …path_langchain/agent/multimodal/utils.pysrc/uipath_langchain/agent/react/multimodal/utils.py renamed to src/uipath_langchain/agent/multimodal/utils.py src/uipath_langchain/agent/react/multimodal/utils.py renamed to src/uipath_langchain/agent/multimodal/utils.py

@@ -2,7 +2,13 @@
 from typing import Any
 
 from langchain_core.language_models import BaseChatModel
-from langchain_core.messages import AnyMessage, HumanMessage, SystemMessage
+from langchain_core.messages import (
+    AIMessage,
+    AnyMessage,
+    HumanMessage,
+    SystemMessage,
+    TextContentBlock,
+)
 from langchain_core.messages.tool import ToolCall
 from langchain_core.tools import BaseTool, StructuredTool
 from uipath.agent.models.agent import (
@@ -11,18 +17,17 @@
 from uipath.eval.mocks import mockable
 from uipath.platform import UiPath
 
+from uipath_langchain.agent.multimodal import FileInfo, build_file_content_blocks
 from uipath_langchain.agent.react.jsonschema_pydantic_converter import create_model
-from uipath_langchain.agent.react.multimodal import FileInfo, llm_call_with_files
 from uipath_langchain.agent.react.types import AgentGraphState
 from uipath_langchain.agent.tools.static_args import handle_static_args
 from uipath_langchain.agent.tools.structured_tool_with_argument_properties import (
     StructuredToolWithArgumentProperties,
 )
-from uipath_langchain.agent.tools.tool_node import (
-    ToolWrapperReturnType,
-)
+from uipath_langchain.agent.tools.tool_node import ToolWrapperReturnType
 from uipath_langchain.agent.tools.utils import sanitize_tool_name
 from uipath_langchain.agent.wrappers import get_job_attachment_wrapper
+from uipath_langchain.chat.helpers import append_content_blocks_to_message
 
 ANALYZE_FILES_SYSTEM_MESSAGE = (
     "Process the provided files to complete the given task. "
@@ -31,6 +36,41 @@
 )
 
 
+async def add_files_to_message(
+    message: HumanMessage,
+    files: list[FileInfo],
+) -> HumanMessage:
+    """Add file attachments to a HumanMessage."""
+    if not files:
+        return message
+
+    file_content_blocks = await build_file_content_blocks(files)
+    return append_content_blocks_to_message(message, file_content_blocks)
+
+
+def extract_text_content(message: AIMessage) -> str:
+    """Extract text content from an AI message.
+    Handles both simple string content and structured content with multiple parts extracting only the text portions.
+    """
+    content = message.content_blocks
+
+    if isinstance(content, str):
+        return content
+
+    if isinstance(content, list):
+        text_parts: list[str] = []
+        for part in content:
+            if isinstance(part, TextContentBlock):
+                if part.text:
+                    text_parts.append(part.text)
+            elif isinstance(part, str):
+                text_parts.append(part)
+
+        return "\n".join(text_parts)
+
+    return str(content)
+
+
 def create_analyze_file_tool(
     resource: AgentInternalToolResourceConfig, llm: BaseChatModel
 ) -> StructuredTool:
@@ -50,8 +90,8 @@ async def tool_fn(**kwargs: Any):
         if "attachments" not in kwargs:
             raise ValueError("Argument 'attachments' is not available")
 
-        analysisTask = kwargs["analysisTask"]
-        if not analysisTask:
+        analysis_task = kwargs["analysisTask"]
+        if not analysis_task:
             raise ValueError("Argument 'analysisTask' is not available")
 
         attachments = kwargs["attachments"]
@@ -60,12 +100,17 @@ async def tool_fn(**kwargs: Any):
         if not files:
             return {"analysisResult": "No attachments provided to analyze."}
 
+        human_message = HumanMessage(content=analysis_task)
+        human_message_with_files = await add_files_to_message(human_message, files)
+
         messages: list[AnyMessage] = [
             SystemMessage(content=ANALYZE_FILES_SYSTEM_MESSAGE),
-            HumanMessage(content=analysisTask),
+            human_message_with_files,
         ]
-        result = await llm_call_with_files(messages, files, llm)
-        return result
+        result = await llm.ainvoke(messages)
+
+        analysis_result = extract_text_content(result)
+        return analysis_result
 
     job_attachment_wrapper = get_job_attachment_wrapper(output_type=output_model)
 

src/uipath_langchain/agent/react/llm_node.py

@@ -30,7 +30,7 @@ def _create_openai_llm(
     agenthub_config: str,
     byo_connection_id: str | None = None,
 ) -> BaseChatModel:
-    """Create UiPathChatOpenAI for OpenAI models via passthrough."""
+    """Create UiPathChatOpenAI for OpenAI models via LLMGateway."""
     from uipath_langchain.chat.openai import UiPathChatOpenAI
 
     azure_open_ai_latest_api_version = "2025-04-01-preview"
@@ -70,7 +70,7 @@ def _create_bedrock_llm(
     agenthub_config: str,
     byo_connection_id: str | None = None,
 ) -> BaseChatModel:
-    """Create UiPathChatBedrockConverse for Claude models via passthrough."""
+    """Create UiPathChatBedrockConverse for Claude models via LLMGateway."""
     from uipath_langchain.chat.bedrock import (
         UiPathChatBedrock,
         UiPathChatBedrockConverse,
@@ -107,7 +107,7 @@ def _create_vertex_llm(
     agenthub_config: str,
     byo_connection_id: str | None = None,
 ) -> BaseChatModel:
-    """Create UiPathChatVertex for Gemini models via passthrough."""
+    """Create UiPathChatVertex for Gemini models via LLMGateway."""
     from uipath_langchain.chat.vertex import UiPathChatVertex
 
     match api_flavor:
@@ -185,7 +185,7 @@ def get_chat_model(
     agenthub_config: str,
     byo_connection_id: str | None = None,
 ) -> BaseChatModel:
-    """Create and configure LLM instance using passthrough API.
+    """Create and configure LLM instance using LLMGateway API.
 
     Fetches available models from the discovery API and selects the appropriate
     LLM class based on the apiFlavor field from the matching model configuration.

src/uipath_langchain/agent/tools/internal_tools/analyze_files_tool.py

@@ -3,6 +3,7 @@
 from .base import ModelPayloadHandler
 from .bedrock_converse import BedrockConversePayloadHandler
 from .bedrock_invoke import BedrockInvokePayloadHandler
+from .handler_factory import get_payload_handler
 from .openai_completions import OpenAICompletionsPayloadHandler
 from .openai_responses import OpenAIResponsesPayloadHandler
 from .vertex_gemini import VertexGeminiPayloadHandler
@@ -14,4 +15,5 @@
     "OpenAICompletionsPayloadHandler",
     "OpenAIResponsesPayloadHandler",
     "VertexGeminiPayloadHandler",
+    "get_payload_handler",
 ]