Webhooks Integration

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

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

const WEBHOOK_SECRET = process.env.DB24X7_WEBHOOK_SECRET;

// Verify webhook signature
function verifySignature(payload, signature) {
  const hmac = crypto.createHmac('sha256', WEBHOOK_SECRET);
  const digest = 'sha256=' + hmac.update(payload).digest('hex');
  return crypto.timingSafeEqual(Buffer.from(signature), Buffer.from(digest));
}

app.post('/webhooks/db24x7', (req, res) => {
  const signature = req.headers['x-db24x7-signature'];
  const payload = JSON.stringify(req.body);

  if (!verifySignature(payload, signature)) {
    return res.status(401).send('Invalid signature');
  }

  const event = req.body;
  console.log('Received event:', event.type);

  // Process event
  switch (event.type) {
    case 'alert.critical':
      handleCriticalAlert(event.data);
      break;
    case 'optimization.completed':
      handleOptimizationCompleted(event.data);
      break;
    case 'database.health_check':
      handleHealthCheck(event.data);
      break;
    default:
      console.log('Unhandled event type:', event.type);
  }

  res.status(200).json({ received: true });
});

app.listen(3000);

from flask import Flask, request, jsonify
import hmac
import hashlib
import os

app = Flask(__name__)
WEBHOOK_SECRET = os.environ.get('DB24X7_WEBHOOK_SECRET')

def verify_signature(payload, signature):
    expected_signature = 'sha256=' + hmac.new(
        WEBHOOK_SECRET.encode(),
        payload.encode(),
        hashlib.sha256
    ).hexdigest()
    return hmac.compare_digest(expected_signature, signature)

@app.route('/webhooks/db24x7', methods=['POST'])
def webhook():
    signature = request.headers.get('X-DB24x7-Signature')
    payload = request.get_data(as_text=True)

    if not verify_signature(payload, signature):
        return jsonify({'error': 'Invalid signature'}), 401

    event = request.json
    event_type = event.get('type')

    if event_type == 'alert.critical':
        handle_critical_alert(event['data'])
    elif event_type == 'optimization.completed':
        handle_optimization_completed(event['data'])
    elif event_type == 'database.health_check':
        handle_health_check(event['data'])

    return jsonify({'received': True}), 200

if __name__ == '__main__':
    app.run(port=3000)