# Test receiving a webhook event
curl --location 'https://your-server.com/webhook' \
--header 'Content-Type: application/json' \
--data '{
"type": "Course/Published",
"occuredAt": 1508225229,
"body": {
"course": {
"id": 123,
"name": "Advanced JavaScript Course",
"annotation": "Learn advanced JavaScript concepts",
"isDraft": false,
"createdAt": 1507807711,
"updatedAt": 1507808372,
"publishedAt": 1508225229
}
}
}'

# Retrieve last webhook event
curl --location 'https://YOURSITE.konstant.ly/openapi/v1/webhook/course.published/last' \
--header 'X-API-KEY: 1qaz2wsx3edc4rfv1qaz2wsx3edc4rfv'

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

app = Flask(__name__)

@app.route('/webhook', methods=['POST'])
def handle_webhook():
# Get webhook data
event_data = request.json

# Extract common properties
event_type = event_data['type']
occurred_at = event_data['occuredAt']
payload = event_data['body']

# Handle different event types
if event_type == 'Course/Published':
handle_course_published(payload)
elif event_type == 'User/Created':
handle_user_created(payload)
elif event_type == 'Course/Progress':
handle_course_progress(payload)

# Return success quickly
return jsonify({'status': 'success'}), 200

def handle_course_published(payload):
course = payload['course']
print(f"Course published: {course['name']} (ID: {course['id']})")
# Add your course publication handling logic here

def handle_user_created(payload):
user = payload['user']
print(f"New user: {user['name']} (Email: {user['email']})")
# Add your user creation handling logic here

def handle_course_progress(payload):
user = payload['user']
course = payload['course']
progress = payload['progressValue']
print(f"Progress update: User {user['name']} - {progress}% in {course['name']}")
# Add your progress handling logic here

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

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

app.use(express.json());

app.post('/webhook', (req, res) => {
// Get webhook data
const { type, occuredAt, body } = req.body;

// Handle different event types
try {
switch (type) {
case 'Course/Published':
handleCoursePublished(body);
break;
case 'User/Created':
handleUserCreated(body);
break;
case 'Course/Progress':
handleCourseProgress(body);
break;
default:
console.log(`Unhandled event type: ${type}`);
}

// Return success quickly
res.status(200).json({ status: 'success' });
} catch (error) {
console.error('Error processing webhook:', error);
res.status(500).json({ error: 'Internal server error' });
}
});

function handleCoursePublished(payload) {
const { course } = payload;
console.log(`Course published: ${course.name} (ID: ${course.id})`);
// Add your course publication handling logic here
}

function handleUserCreated(payload) {
const { user } = payload;
console.log(`New user: ${user.name} (Email: ${user.email})`);
// Add your user creation handling logic here
}

function handleCourseProgress(payload) {
const { user, course, progressValue } = payload;
console.log(`Progress update: User ${user.name} - ${progressValue}% in ${course.name}`);
// Add your progress handling logic here
}

const PORT = process.env.PORT || 5000;
app.listen(PORT, () => {
console.log(`Webhook server running on port ${PORT}`);
});

<?php

// Webhook handling endpoint
function handleWebhook() {
    // Get webhook data
    $eventData = json_decode(file_get_contents('php://input'), true);

// Extract common properties
$eventType = $eventData['type'];
$occurredAt = $eventData['occuredAt'];
$payload = $eventData['body'];

// Handle different event types
try {
    switch ($eventType) {
        case 'Course/Published':
            handleCoursePublished($payload);
            break;
        case 'User/Created':
            handleUserCreated($payload);
            break;
        case 'Course/Progress':
            handleCourseProgress($payload);
            break;
        default:
            error_log("Unhandled event type: $eventType");
    }

// Return success quickly
http_response_code(200);
echo json_encode(['status' => 'success']);
} catch (Exception $e) {
error_log("Error processing webhook: " . $e->getMessage());
http_response_code(500);
echo json_encode(['error' => 'Internal server error']);
}
}

function handleCoursePublished($payload) {
    $course = $payload['course'];
    error_log("Course published: {$course['name']} (ID: {$course['id']})");
    // Add your course publication handling logic here
}

function handleUserCreated($payload) {
    $user = $payload['user'];
    error_log("New user: {$user['name']} (Email: {$user['email']})");
    // Add your user creation handling logic here
}

function handleCourseProgress($payload) {
    $user = $payload['user'];
    $course = $payload['course'];
    $progress = $payload['progressValue'];
    error_log("Progress update: User {$user['name']} - {$progress}% in {$course['name']}");
    // Add your progress handling logic here
}

// Handle the webhook
handleWebhook();

?>