Webhooks

{
  "requestId": "req_abc123def456",
  "secret": "your-secret-key-here",
  "status": "success",
  "browserWindowId": "window_xyz789",
  "response": {
    "text": "Found 1,234 software engineering job listings in the search results."
  },
  "createdAt": "2024-11-21T10:00:00.000000+00:00",
  "completedAt": "2024-11-21T10:00:45.000000+00:00",
  "usage": {
    "actions": 12,
    "credits": 5
  }
}

const express = require('express');
const app = express();

app.use(express.json());

app.post('/api/narada/webhook', (req, res) => {
  const payload = req.body;

  // Verify the secret if provided
  if (payload.secret !== process.env.NARADA_CALLBACK_SECRET) {
    return res.status(401).json({ error: 'Invalid secret' });
  }

  // Process the webhook payload
  console.log(`Task ${payload.requestId} completed with status: ${payload.status}`);

  if (payload.status === 'success') {
    console.log('Response:', payload.response.text);
    // Handle successful completion
    handleSuccess(payload);
  } else if (payload.status === 'error') {
    console.error('Task failed:', payload.response.text);
    // Handle error
    handleError(payload);
  } else if (payload.status === 'input-required') {
    console.log('Input required:', payload.response.text);
    // Handle input requirement
    handleInputRequired(payload);
  }

  // Always respond with 200 to acknowledge receipt
  res.status(200).json({ received: true });
});

function handleSuccess(payload) {
  // Your success handling logic
  // Store results, trigger next steps, etc.
}

function handleError(payload) {
  // Your error handling logic
  // Log errors, retry tasks, send alerts, etc.
}

function handleInputRequired(payload) {
  // Your input handling logic
  // Notify users, pause workflows, etc.
}

app.listen(3000, () => {
  console.log('Webhook endpoint listening on port 3000');
});