feat: add Olivya's 'Place Call' component (#5917)

* Fixing failed unit tests for Olivya's 'Place Call' component

* Revert "Fixing failed unit tests for Olivya's 'Place Call' component"

This reverts commit abc62c9b9d14129d31b2c73ca0c68b2aba9be0a0.

* Fixing failed unit tests for Olivya's 'Place Call' component

* Update src/backend/base/langflow/components/olivya/olivya.py

Co-authored-by: Gabriel Luiz Freitas Almeida <gabriel@langflow.org>

* Update src/backend/base/langflow/components/olivya/olivya.py

Co-authored-by: Gabriel Luiz Freitas Almeida <gabriel@langflow.org>

* Remove unused logging import in Olivya component

---------

Co-authored-by: Gabriel Luiz Freitas Almeida <gabriel@langflow.org>

src/backend/base/langflow/components/olivya/__init__.py

@@ -0,0 +1,3 @@
+from .olivya import OlivyaComponent
+
+__all__ = ["OlivyaComponent"]

src/backend/base/langflow/components/olivya/olivya.py

@@ -0,0 +1,116 @@
+import json
+
+import httpx
+from loguru import logger
+
+from langflow.custom import Component
+from langflow.io import MessageTextInput, Output
+from langflow.schema import Data
+
+
+class OlivyaComponent(Component):
+    display_name = "Place Call"
+    description = "A component to create an outbound call request from Olivya's platform."
+    documentation: str = "http://docs.langflow.org/components/olivya"
+    icon = "Olivya"
+    name = "OlivyaComponent"
+
+    inputs = [
+        MessageTextInput(
+            name="api_key",
+            display_name="API Key",
+            info="Your API key for authentication",
+            value="",
+            required=True,
+        ),
+        MessageTextInput(
+            name="from_number",
+            display_name="From Number",
+            info="The Agent's phone number",
+            value="",
+            required=True,
+        ),
+        MessageTextInput(
+            name="to_number",
+            display_name="To Number",
+            info="The recipient's phone number",
+            value="",
+            required=True,
+        ),
+        MessageTextInput(
+            name="first_message",
+            display_name="First Message",
+            info="The Agent's introductory message",
+            value="",
+            required=False,
+            tool_mode=True,
+        ),
+        MessageTextInput(
+            name="system_prompt",
+            display_name="System Prompt",
+            info="The system prompt to guide the interaction",
+            value="",
+            required=False,
+        ),
+        MessageTextInput(
+            name="conversation_history",
+            display_name="Conversation History",
+            info="The summary of the conversation",
+            value="",
+            required=False,
+            tool_mode=True,
+        ),
+    ]
+
+    outputs = [
+        Output(display_name="Output", name="output", method="build_output"),
+    ]
+
+    async def build_output(self) -> Data:
+        try:
+            payload = {
+                "variables": {
+                    "first_message": self.first_message.strip() if self.first_message else None,
+                    "system_prompt": self.system_prompt.strip() if self.system_prompt else None,
+                    "conversation_history": self.conversation_history.strip() if self.conversation_history else None,
+                },
+                "from_number": self.from_number.strip(),
+                "to_number": self.to_number.strip(),
+            }
+
+            headers = {
+                "Authorization": self.api_key.strip(),
+                "Content-Type": "application/json",
+            }
+
+            logger.info("Sending POST request with payload: %s", payload)
+
+            # Send the POST request with a timeout
+            async with httpx.AsyncClient() as client:
+                response = await client.post(
+                    "https://phone.olivya.io/create_zap_call",
+                    headers=headers,
+                    json=payload,
+                    timeout=10.0,
+                )
+                response.raise_for_status()
+
+                # Parse and return the successful response
+                response_data = response.json()
+                logger.info("Request successful: %s", response_data)
+
+        except httpx.HTTPStatusError as http_err:
+            logger.exception("HTTP error occurred")
+            response_data = {"error": f"HTTP error occurred: {http_err}", "response_text": response.text}
+        except httpx.RequestError as req_err:
+            logger.exception("Request failed")
+            response_data = {"error": f"Request failed: {req_err}"}
+        except json.JSONDecodeError as json_err:
+            logger.exception("Response parsing failed")
+            response_data = {"error": f"Response parsing failed: {json_err}", "raw_response": response.text}
+        except Exception as e:  # noqa: BLE001
+            logger.exception("An unexpected error occurred")
+            response_data = {"error": f"An unexpected error occurred: {e!s}"}
+
+        # Return the response as part of the output
+        return Data(value=response_data)