[pull] main from perplexityai:main

.claude-plugin/marketplace.json

@@ -6,14 +6,14 @@
   },
   "metadata": {
     "description": "Official Perplexity AI plugin providing real-time web search, reasoning, and research capabilities",
-    "version": "0.6.2"
+    "version": "0.7.0"
   },
   "plugins": [
     {
       "name": "perplexity",
       "source": "./",
       "description": "Real-time web search, reasoning, and research through Perplexity's API",
-      "version": "0.6.2",
+      "version": "0.7.0",
       "author": {
         "name": "Perplexity AI",
         "email": "api@perplexity.ai"

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@perplexity-ai/mcp-server",
-  "version": "0.6.2",
+  "version": "0.7.0",
   "mcpName": "io.github.perplexityai/mcp-server",
   "description": "Real-time web search, reasoning, and research through Perplexity's API",
   "keywords": [

server.json

@@ -3,12 +3,12 @@
   "name": "io.github.perplexityai/mcp-server",
   "title": "Perplexity API Platform",
   "description": "Real-time web search, reasoning, and research through Perplexity's API",
-  "version": "0.6.2",
+  "version": "0.7.0",
   "packages": [
     {
       "registryType": "npm",
       "identifier": "@perplexity-ai/mcp-server",
-      "version": "0.6.2",
+      "version": "0.7.0",
       "transport": {
         "type": "stdio"
       }

src/index.test.ts

@@ -473,14 +473,35 @@ describe("Perplexity MCP Server", () => {
       const models = ["sonar-pro", "sonar-deep-research", "sonar-reasoning-pro"];
 
       for (const model of models) {
-        const mockResponse = {
-          choices: [{ message: { content: `Response from ${model}` } }],
-        };
-
-        global.fetch = vi.fn().mockResolvedValue({
-          ok: true,
-          json: async () => mockResponse,
-        } as Response);
+        if (model === "sonar-deep-research") {
+          // sonar-deep-research uses streaming, so provide an SSE mock
+          const sseData = [
+            `data: ${JSON.stringify({ choices: [{ delta: { content: "Response " } }] })}\n\n`,
+            `data: ${JSON.stringify({ choices: [{ delta: { content: `from ${model}` } }] })}\n\n`,
+            `data: [DONE]\n\n`,
+          ].join("");
+
+          const stream = new ReadableStream({
+            start(controller) {
+              controller.enqueue(new TextEncoder().encode(sseData));
+              controller.close();
+            },
+          });
+
+          global.fetch = vi.fn().mockResolvedValue({
+            ok: true,
+            body: stream,
+          } as unknown as Response);
+        } else {
+          const mockResponse = {
+            choices: [{ message: { content: `Response from ${model}` } }],
+          };
+
+          global.fetch = vi.fn().mockResolvedValue({
+            ok: true,
+            json: async () => mockResponse,
+          } as Response);
+        }
 
         const messages = [{ role: "user", content: "test" }];
         const result = await performChatCompletion(messages, model);