Simple Webhook Sender and Receiver with Node.js

// --- Webhook Receiver (Node.js with Express) ---
const express = require('express');
const app = express();
const PORT = 3000;

app.use(express.json()); // Middleware to parse JSON request bodies

app.post('/webhook-endpoint', (req, res) => {
  console.log('--- Webhook Received ---');
  console.log('Headers:', req.headers);
  console.log('Body:', req.body);

  // In a real application, you would process the webhook payload here.
  // e.g., update a database, send an email, trigger another process.
  if (req.body && req.body.eventType === 'user.created') {
    console.log(`New user created: ${req.body.data.username}`);
  } else {
    console.log('Unknown event type or malformed body.');
  }

  res.status(200).send('Webhook received successfully!');
});

app.listen(PORT, () => {
  console.log(`Webhook receiver listening on http://localhost:${PORT}`);
  console.log(`Send POST requests to http://localhost:${PORT}/webhook-endpoint`);
});


// --- Webhook Sender (JavaScript - can be client-side or server-side) ---
async function sendWebhook(url, payload) {
  try {
    const response = await fetch(url, {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
        // 'X-Custom-Signature': 'some-hashed-signature' // For production, add security like signature verification
      },
      body: JSON.stringify(payload)
    });

    if (!response.ok) {
      const errorText = await response.text();
      throw new Error(`Failed to send webhook: ${response.status} ${response.statusText} - ${errorText}`);
    }

    console.log('Webhook sent successfully!', await response.text());
  } catch (error) {
    console.error('Error sending webhook:', error);
  }
}

// Example usage for sending a webhook:
// This would typically be triggered by an event in your application
const webhookPayload = {
  eventType: 'user.created',
  timestamp: new Date().toISOString(),
  data: {
    userId: 'abc-123',
    username: 'john.doe',
    email: '[email protected]'
  }
};

// Call this function when an event occurs, e.g., after a user registers
// sendWebhook('http://localhost:3000/webhook-endpoint', webhookPayload);