🔔 Webhooks

// routes/web.php
Route::post('/webhooks/extractbill', [WebhookController::class, 'handle']);

// app/Http/Controllers/WebhookController.php
class WebhookController extends Controller
{
    public function handle(Request $request)
    {
        // 1. Verify token
        $token = $request->header('X-ExtractBill-Token');
        if ($token !== config('services.extractbill.webhook_secret')) {
            abort(401, 'Invalid token');
        }

        // 2. Parse payload
        $event = $request->input('event');
        $document = $request->input('document');

        // 3. Handle event
        match ($event) {
            'document.completed' => $this->handleCompleted($document),
            'document.failed' => $this->handleFailed($document),
            default => Log::warning("Unknown webhook event: {$event}"),
        };

        return response()->json(['success' => true]);
    }

    private function handleCompleted(array $document)
    {
        // Save to database, send email, etc.
        Log::info("Document {$document['id']} completed", $document);
    }

    private function handleFailed(array $document)
    {
        // Alert admin, retry, etc.
        Log::error("Document {$document['id']} failed: {$document['error_message']}");
    }
}

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

app.use(express.json());

app.post('/webhooks/extractbill', (req, res) => {
  // 1. Verify token
  const receivedToken = req.headers['x-extractbill-token'];
  const expectedToken = process.env.EXTRACTBILL_WEBHOOK_SECRET;

  if (receivedToken !== expectedToken) {
    return res.status(401).json({ error: 'Invalid token' });
  }

  // 2. Parse payload
  const { event, document } = req.body;

  // 3. Handle event
  switch (event) {
    case 'document.completed':
      handleCompleted(document);
      break;
    case 'document.failed':
      handleFailed(document);
      break;
    default:
      console.warn(`Unknown event: ${event}`);
  }

  res.json({ success: true });
});

function handleCompleted(document) {
  console.log(`Document ${document.id} completed`, document);
  // Save to database, send notification, etc.
}

function handleFailed(document) {
  console.error(`Document ${document.id} failed: ${document.error_message}`);
  // Alert admin, retry, etc.
}

app.listen(3000, () => console.log('Webhook server running on port 3000'));

from flask import Flask, request, jsonify
import os

app = Flask(__name__)

@app.route('/webhooks/extractbill', methods=['POST'])
def handle_webhook():
    # 1. Verify token
    received_token = request.headers.get('X-ExtractBill-Token')
    expected_token = os.getenv('EXTRACTBILL_WEBHOOK_SECRET')

    if received_token != expected_token:
        return jsonify({'error': 'Invalid token'}), 401

    # 2. Parse payload
    data = request.get_json()
    event = data.get('event')
    document = data.get('document')

    # 3. Handle event
    if event == 'document.completed':
        handle_completed(document)
    elif event == 'document.failed':
        handle_failed(document)
    else:
        print(f"Unknown event: {event}")

    return jsonify({'success': True})

def handle_completed(document):
    print(f"Document {document['id']} completed")
    # Save to database, send notification, etc.

def handle_failed(document):
    print(f"Document {document['id']} failed: {document['error_message']}")
    # Alert admin, retry, etc.

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