perplexity-webhooks-events

name	perplexity-webhooks-events
description	Build event-driven architectures around Perplexity Sonar API with streaming, batch pipelines, and scheduled search monitoring. Trigger with phrases like "perplexity streaming", "perplexity events", "perplexity batch search", "perplexity news monitor", "perplexity SSE".
allowed-tools	Read, Write, Edit, Bash(curl:*)
version	1.12.0
license	MIT
author	Jeremy Longshore <[e-mail]>
tags	["saas","perplexity","webhooks"]
compatibility	Designed for Claude Code

Perplexity Events & Async Patterns

Overview

Build event-driven architectures around Perplexity Sonar API. Perplexity does not have webhooks -- all interactions are request/response. Event patterns are built using streaming SSE, job queues for batch processing, and cron-triggered monitoring.

Event Patterns

Pattern	Trigger	Use Case
Streaming SSE	Client request	Real-time search with progressive rendering
Batch queue	Job submission	Research automation, report generation
Scheduled search	Cron job	News monitoring, trend alerts, competitive intel
Citation pipeline	Post-processing	Source verification, link validation

Prerequisites

• openai package installed
• PERPLEXITY_API_KEY set
• Queue system (BullMQ, SQS) for batch patterns
• Cron scheduler for monitoring patterns

Instructions

Step 1: Streaming Search (Server-Sent Events)

import OpenAI from "openai";
import express from "express";

const perplexity = new OpenAI({
  apiKey: process.env.PERPLEXITY_API_KEY!,
  baseURL: "https://api.perplexity.ai",
});

const app = express();
app.use(express.json());

app.post("/api/search/stream", async (req, res) => {
  const { query, model = "sonar" } = req.body;

  res.(, {
    : ,
    : ,
    : ,
  });

   {
     stream =  perplexity...({
      model,
      : [{ : , : query }],
      : ,
      : ,
    });

     fullText = ;
      ( chunk  stream) {
       text = chunk.[]?.?. || ;
      fullText += text;

      res.();

      
       citations = (chunk  ).;
       (citations) {
        res.();
      }
    }

    res.();
  }  (: ) {
    res.();
  }

  res.();
});