test(perplexity): add integration tests for all components

Add @pytest.mark.integration-guarded end-to-end tests (sync + async) for:
- PerplexityChatGenerator
- PerplexityDocumentEmbedder
- PerplexityTextEmbedder

PerplexityWebSearch integration tests already exist.

All integration tests are skipped unless PERPLEXITY_API_KEY is set so they
won't impact regular unit-test CI runs.

Author: jliounis

integrations/perplexity/tests/test_perplexity_chat_generator.py

@@ -2,6 +2,7 @@
 #
 # SPDX-License-Identifier: Apache-2.0
 
+import os
 from datetime import datetime, timezone
 from unittest.mock import patch
 
@@ -199,3 +200,27 @@ def test_default_headers_include_perplexity_attribution(self):
         assert component.client.default_headers["test-header"] == "test-value"
         assert component.async_client.default_headers["X-Pplx-Integration"].startswith("haystack/")
         assert component.async_client.default_headers["test-header"] == "test-value"
+
+
+@pytest.mark.skipif(
+    not os.environ.get("PERPLEXITY_API_KEY"),
+    reason="Export PERPLEXITY_API_KEY to run integration tests.",
+)
+@pytest.mark.integration
+class TestPerplexityChatGeneratorInference:
+    def test_live_run(self):
+        chat_messages = [ChatMessage.from_user("What's the capital of France? Reply in one word.")]
+        component = PerplexityChatGenerator()
+        results = component.run(chat_messages)
+        assert len(results["replies"]) == 1
+        message: ChatMessage = results["replies"][0]
+        assert "Paris" in message.text
+
+    @pytest.mark.asyncio
+    async def test_live_run_async(self):
+        chat_messages = [ChatMessage.from_user("What's the capital of France? Reply in one word.")]
+        component = PerplexityChatGenerator()
+        results = await component.run_async(chat_messages)
+        assert len(results["replies"]) == 1
+        message: ChatMessage = results["replies"][0]
+        assert "Paris" in message.text

integrations/perplexity/tests/test_perplexity_document_embedder.py

@@ -3,6 +3,7 @@
 # SPDX-License-Identifier: Apache-2.0
 
 import json
+import os
 
 import httpx
 import pytest
@@ -248,3 +249,40 @@ def test_run_wrong_input_format(self):
             embedder.run(documents=[1, 2, 3])
 
         assert embedder.run(documents=[]) == {"documents": [], "meta": {}}
+
+
+@pytest.mark.skipif(
+    not os.environ.get("PERPLEXITY_API_KEY"),
+    reason="Export PERPLEXITY_API_KEY to run integration tests.",
+)
+@pytest.mark.integration
+class TestPerplexityDocumentEmbedderInference:
+    def test_live_run(self):
+        docs = [
+            Document(content="The capital of France is Paris."),
+            Document(content="The capital of Germany is Berlin."),
+        ]
+        embedder = PerplexityDocumentEmbedder()
+        result = embedder.run(documents=docs)
+
+        embedded_docs = result["documents"]
+        assert len(embedded_docs) == len(docs)
+        for doc in embedded_docs:
+            assert isinstance(doc.embedding, list)
+            assert len(doc.embedding) > 0
+            assert all(isinstance(x, float) for x in doc.embedding)
+
+    @pytest.mark.asyncio
+    async def test_live_run_async(self):
+        docs = [
+            Document(content="The capital of France is Paris."),
+            Document(content="The capital of Germany is Berlin."),
+        ]
+        embedder = PerplexityDocumentEmbedder()
+        result = await embedder.run_async(documents=docs)
+
+        embedded_docs = result["documents"]
+        assert len(embedded_docs) == len(docs)
+        for doc in embedded_docs:
+            assert isinstance(doc.embedding, list)
+            assert len(doc.embedding) > 0

integrations/perplexity/tests/test_perplexity_text_embedder.py

@@ -3,6 +3,7 @@
 # SPDX-License-Identifier: Apache-2.0
 
 import json
+import os
 
 import httpx
 import pytest
@@ -186,3 +187,28 @@ def test_run_wrong_input_format(self):
 
         with pytest.raises(TypeError, match=match_error_msg):
             embedder.run(text=["text_snippet_1", "text_snippet_2"])
+
+
+@pytest.mark.skipif(
+    not os.environ.get("PERPLEXITY_API_KEY"),
+    reason="Export PERPLEXITY_API_KEY to run integration tests.",
+)
+@pytest.mark.integration
+class TestPerplexityTextEmbedderInference:
+    def test_live_run(self):
+        text = "The capital of France is Paris."
+        embedder = PerplexityTextEmbedder()
+        result = embedder.run(text=text)
+
+        assert isinstance(result["embedding"], list)
+        assert len(result["embedding"]) > 0
+        assert all(isinstance(x, float) for x in result["embedding"])
+
+    @pytest.mark.asyncio
+    async def test_live_run_async(self):
+        text = "The capital of France is Paris."
+        embedder = PerplexityTextEmbedder()
+        result = await embedder.run_async(text=text)
+
+        assert isinstance(result["embedding"], list)
+        assert len(result["embedding"]) > 0