Webhook Payloads

{
    "status": "completed",
    "timestamp": "2026-01-22T12:00:00.000000Z",
    "call": {
        "algorithm_run_id": 12345,
        "algorithm_id": "appointment_scheduling",
        "job_id": 7913,
        "recording_url": "https://storage.example.com/recording.mp3",
        "recording_duration": 120.5,
        "contacted_date": "2026-01-22",
        "contacted_time": "10:30:00",
        "answered_by": "Sofia",
        "insurance_type": "PPO",
        "extracted_source": "Direct",
        "call_sentiment": "Positive",
        "call_sentiment_reason": "Patient scheduled appointment and expressed satisfaction",
        "call_summary": "Patient called to schedule a dental checkup...",
        "call_transcript": "Receptionist: Thank you for calling...",
        "confidence_score": 85.5,
        "annotated_transcript": "Receptionist: Thank you for calling <answered_by>Sofia</answered_by>..."
    },
    "data": [
        {
            "patient": {
                "name": "John Doe",
                "phone": "+15551234567",
                "email": "john@example.com",
                "date_of_birth": "1985-03-15",
                "additional_spellings": ["Jon Doe"]
            },
            "appointment": {
                "patient_type": "New Patient",
                "visit_reason": "General Checkup",
                "scheduled_date": "2026-01-25",
                "scheduled_time": "14:00:00",
                "notes": "Patient prefers afternoon appointments"
            }
        }
    ],
    "confidence": {
        "overall_score": 85.5,
        "flags": ["high_confidence"],
        "breakdown": {
            "call": {
                "answered_by": {
                    "score": 5.0,
                    "max": 5,
                    "confidence": "high",
                    "agreement": 1.0
                }
            },
            "data": [
                {
                    "patient": {
                        "name": {
                            "score": 10.0,
                            "max": 10,
                            "confidence": "high"
                        }
                    }
                }
            ]
        }
    }
}

{
    "annotated_transcript": "Receptionist: Thank you for calling. This is <answered_by>Sofia</answered_by>.\nPatient: Hi, my name is <patient.name data-index=\"0\">John</patient.name>."
}

{
    "annotated_transcript": [
        {
            "name": "Receptionist",
            "text": "Thank you for calling. This is <answered_by>Sofia</answered_by>.",
            "start_time": 0.0
        },
        {
            "name": "Patient",
            "text": "Hi, my name is <patient.name data-index=\"0\">John</patient.name>.",
            "start_time": 2.5
        }
    ]
}

{
    "annotated_transcript": [
        {
            "name": null,
            "text": "Hi, this is <patient.name data-index=\"0\">Sarah</patient.name>. Please call me back.",
            "start_time": null
        }
    ]
}

{
    "annotated_transcript": [
        {
            "name": "Receptionist",
            "text": "Hello, dental office.",
            "start_time": null
        }
    ]
}

{
    "status": "failed",
    "timestamp": "2026-01-22T12:00:00.000000Z",
    "call": {
        "algorithm_run_id": 12346,
        "algorithm_id": "appointment_scheduling",
        "job_id": 7914,
        "recording_url": "https://storage.example.com/recording.mp3",
        "recording_duration": 45.0,
        "contacted_date": "2026-01-22",
        "contacted_time": "11:00:00"
    },
    "error": {
        "stage": "extraction",
        "message": "LLM failed to extract structured data from transcript",
        "code": "EXTRACTION_FAILED"
    }
}

from flask import Flask, request, jsonify

app = Flask(__name__)

@app.route('/webhook', methods=['POST'])
def handle_webhook():
    payload = request.get_json()

    if payload['status'] == 'completed':
        # Process successful extraction
        job_id = payload['call']['job_id']
        algorithm_run_id = payload['call']['algorithm_run_id']
        patients = payload['data']

        for entry in patients:
            patient = entry.get('patient', {})
            appointment = entry.get('appointment', {})
            # ... process extracted data

        return jsonify({'status': 'processed'}), 200

    elif payload['status'] == 'failed':
        # Handle failure notification
        job_id = payload['call']['job_id']
        algorithm_run_id = payload['call']['algorithm_run_id']
        error = payload['error']

        log_error(
            job_id=job_id,
            algorithm_run_id=algorithm_run_id,
            stage=error['stage'],
            code=error['code'],
            message=error['message']
        )

        return jsonify({'status': 'acknowledged'}), 200

    return jsonify({'error': 'Unknown status'}), 400

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

    if (payload.status === 'completed') {
        // Process successful extraction
        const { job_id, algorithm_run_id } = payload.call;
        const patients = payload.data;

        patients.forEach(entry => {
            const { patient, appointment } = entry;
            // ... process extracted data
        });

        res.json({ status: 'processed' });

    } else if (payload.status === 'failed') {
        // Handle failure notification
        const { job_id, algorithm_run_id } = payload.call;
        const { stage, code, message } = payload.error;

        console.error(`Job ${job_id} failed at ${stage}: ${message} (${code})`);

        res.json({ status: 'acknowledged' });
    }
});