Message Notification

POST /webhooks/edgeone-pages HTTP/1.1
Host: example.com
Content-Type: application/json
Accept: application/json, text/plain, */*
Accept-Encoding: gzip, compress, deflate, br
Authorization: Bearer xxx
Connection: keep-alive

{
  "eventType": "deployment.created",
  "appId": "app-123",
  "projectId": "project-456",
  "deploymentId": "deploy-789",
  "projectName": "my-project",
  "repoBranch": "main",
  "timestamp": "2024-01-13T12:34:56.789Z"
}

{
  "eventType": "project.created",
  "appId": "app-123",
  "projectId": "project-456",
  "projectName": "my-project",
  "repoUrl": "https://github.com/user/repo",
  "timestamp": "2024-01-13T12:34:56.789Z"
}

{
  "eventType": "domain.added",
  "appId": "app-123",
  "projectId": "project-456",
  "projectName": "my-project",
  "domainName": "example.com",
  "domainId": "domain-789",
  "timestamp": "2024-01-13T12:34:56.789Z"
}

/**
 * API path: /webhooks/demo
 */

/**
 * Verify Bearer Token (optional)
 */
function verifyToken(authHeader, expectedToken) {
  if (!expectedToken) return true; // skip verification if unconfigured
  
  const parts = authHeader?.split(' ');
  if (parts?.length !== 2 || parts[0] !== 'Bearer') return false;
  
  return parts[1] === expectedToken;
}

/**
 * Handle webhook events
 */
function handleEvent(eventType, data) {
  switch (eventType) {
    case 'deployment.created':
      console.log(`🚀 Deployment created: ${data.projectName} (${data.repoBranch})`);
      // Add your business logic herein
      // For example: send notifications, update database
      return { message: 'Deployment event processed', projectName: data.projectName };
      
    case 'project.created':
      console.log(`📁 Project created: ${data.projectName}`);
      return { message: 'Project event processed', projectName: data.projectName };
    // For more events, see supported event types
    default:
      console.log(`⚠️ Unknown event: ${eventType}`);
      return { message: 'Unknown event type', eventType };
  }
}

/**
 * Cloud Function portal
 */
export async function onRequest(context) {
  const { request, env } = context;

  // 1. Health check
  if (request.method === 'GET') {
    return new Response(JSON.stringify({ status: 'ok', message: 'Webhook endpoint is ready' }), {
      headers: { 'Content-Type': 'application/json' }
    });
  }

  // 2. Only POST is accepted
  if (request.method !== 'POST') {
    return new Response(JSON.stringify({ error: 'Method not allowed' }), {
      status: 405,
      headers: { 'Content-Type': 'application/json' }
    });
  }

  try {
    // 3. Verify Bearer Token (optional)
    const authHeader = request.headers.get('authorization');
    const webhookToken = env.WEBHOOK_TOKEN;
    
    if (webhookToken && !verifyToken(authHeader, webhookToken)) {
      return new Response(JSON.stringify({ error: 'Unauthorized' }), {
        status: 401,
        headers: { 'Content-Type': 'application/json' }
      });
    }

    // 4. Parse the request body
    const payload = await request.json();
    const eventType = payload.eventType || payload.type;

    // 5. Event handling
    const result = handleEvent(eventType, payload);

    // 6. Return success response
    return new Response(JSON.stringify({
      success: true,
      eventType,
      result,
      timestamp: new Date().toISOString()
    }), {
      status: 200,
      headers: { 'Content-Type': 'application/json' }
    });

  } catch (error) {
    console.error('Handle error:', error);
    return new Response(JSON.stringify({
      error: 'Internal server error',
      message: error.message
    }), {
      status: 500,
      headers: { 'Content-Type': 'application/json' }
    });
  }
}