webhook-example.ts

// Example implementation of Webhook Management for Strapi MCP

interface WebhookData {
  name: string;
  url: string;
  headers?: Record<string, string>;
  events: string[];
}

/**
 * List all webhooks in Strapi
 */
async function listWebhooks(): Promise<any[]> {
  try {
    console.error("[API] Fetching webhooks from Strapi");
    const response = await makeAdminApiRequest('/webhooks');
    return response || [];
  } catch (error: any) {
    console.error("[Error] Failed to fetch webhooks:", error);
    throw new ExtendedMcpError(ExtendedErrorCode.InternalError, `Failed to fetch webhooks: ${error.message}`);
  }
}

/**
 * Create a new webhook
 */
async function createWebhook(data: WebhookData): Promise<any> {
  try {
    console.error(`[API] Creating webhook: ${data.name}`);
    
    const webhookPayload = {
      name: data.name,
      url: data.url,
      headers: data.headers || {},
      events: data.events
    };
    
    const response = await makeAdminApiRequest('/webhooks', 'post', webhookPayload);
    console.error(`[API] Successfully created webhook: ${data.name}`);
    return response;
  } catch (error: any) {
    console.error(`[Error] Failed to create webhook ${data.name}:`, error);
    throw new ExtendedMcpError(ExtendedErrorCode.InternalError, `Failed to create webhook: ${error.message}`);
  }
}

/**
 * Update an existing webhook
 */
async function updateWebhook(id: string, data: WebhookData): Promise<any> {
  try {
    console.error(`[API] Updating webhook: ${id}`);
    
    const webhookPayload = {
      name: data.name,
      url: data.url,
      headers: data.headers || {},
      events: data.events
    };
    
    const response = await makeAdminApiRequest(`/webhooks/${id}`, 'put', webhookPayload);
    console.error(`[API] Successfully updated webhook: ${id}`);
    return response;
  } catch (error: any) {
    console.error(`[Error] Failed to update webhook ${id}:`, error);
    throw new ExtendedMcpError(ExtendedErrorCode.InternalError, `Failed to update webhook: ${error.message}`);
  }
}

/**
 * Delete a webhook
 */
async function deleteWebhook(id: string): Promise<void> {
  try {
    console.error(`[API] Deleting webhook: ${id}`);
    await makeAdminApiRequest(`/webhooks/${id}`, 'delete');
    console.error(`[API] Successfully deleted webhook: ${id}`);
  } catch (error: any) {
    console.error(`[Error] Failed to delete webhook ${id}:`, error);
    throw new ExtendedMcpError(ExtendedErrorCode.InternalError, `Failed to delete webhook: ${error.message}`);
  }
}

/**
 * Trigger a webhook manually
 */
async function triggerWebhook(id: string): Promise<any> {
  try {
    console.error(`[API] Triggering webhook: ${id}`);
    const response = await makeAdminApiRequest(`/webhooks/${id}/trigger`, 'post');
    console.error(`[API] Successfully triggered webhook: ${id}`);
    return response;
  } catch (error: any) {
    console.error(`[Error] Failed to trigger webhook ${id}:`, error);
    throw new ExtendedMcpError(ExtendedErrorCode.InternalError, `Failed to trigger webhook: ${error.message}`);
  }
}

// Add these to your tool handlers:
/*
case "list_webhooks": {
  const webhooks = await listWebhooks();
  return {
    content: [{
      type: "text",
      text: JSON.stringify(webhooks, null, 2)
    }]
  };
}

case "create_webhook": {
  const webhookData = request.params.arguments as WebhookData;
  if (!webhookData.name || !webhookData.url || !webhookData.events) {
    throw new McpError(ErrorCode.InvalidParams, "name, url, and events are required");
  }
  const webhook = await createWebhook(webhookData);
  return {
    content: [{
      type: "text", 
      text: JSON.stringify(webhook, null, 2)
    }]
  };
}
*/