Webhooks

const express = require('express');
const Imagekit = require('imagekit');

// Webhook configs
const WEBHOOK_ENDPOINT = '/webhook';
const WEBHOOK_SECRET = 'whsec_...'; // Copy from ImageKit dashboard
const WEBHOOK_EXPIRY_DURATION = 60 * 1000; // 60 seconds

const imagekit = new Imagekit({
    publicKey: 'public_...',
    urlEndpoint: 'https://ik.imagekit.io/imagekit_id',
    privateKey: 'private_...',
})

const app = express();

app.post('/webhook', express.raw({ type: 'application/json' }), (req, res) => {
    const signature = req.headers['x-ik-signature'];
    const rawBody = req.body;

    // Verify webhook signature
    let webhookResult;
    try {
        webhookResult = imagekit.verifyWebhookEvent(rawBody, signature, WEBHOOK_SECRET);
    } catch (e) {
        // Failed to verify webhook
        return res.status(401).send(`Webhook error: ${e.message}`);
    }
    const { timestamp, event } = webhookResult;

    // Check if webhook has expired
    if (timestamp + WEBHOOK_EXPIRY_DURATION < Date.now()) {
        // Stall webhook
        return res.status(401).send('Webhook signature expired');
    }

    // Handle webhook
    switch (event.type) {
        case 'video.transformation.accepted':
            // It is triggered when a new video transformation request is accepted for processing. You can use this for debugging purposes.
            break;
        case 'video.transformation.ready':
            // It is triggered when a video encoding is finished and the transformed resource is ready to be served. You should listen to this webhook and update any flag in your database or CMS against that particular asset so your application can start showing it to users.
            break;
        case 'video.transformation.error':
            // It is triggered if an error occurs during encoding. Listen to this webhook to log the reason. You should check your origin and URL endpoint settings if the reason is related to download failure. If the reason seems like an error on the ImageKit side, then raise a support ticket at support@imagekit.io.
            break;
        // ... handle other event types
        default:
            console.log(`Unhandled event type ${event.type}`);
    }

    // Acknowledge webhook is received and processed successfully
    res.status(200).end();
});

app.listen(3000, () => {
    console.log("Server listening on port 3000");
    console.log(
        `Webhook endpoint: 'http://localhost:${PORT}${WEBHOOK_ENDPOINT}'`,
        'Do replace 'localhost' with public endpoint'
    );
});

const fastify = require('fastify');
const fastifyRawBody = require('fastify-raw-body');
const Imagekit = require('imagekit');

// Webhook configs
const WEBHOOK_ENDPOINT = '/webhook';
const WEBHOOK_SECRET = 'whsec_...'; // Copy from ImageKit dashboard
const WEBHOOK_EXPIRY_DURATION = 60 * 1000; // 60 seconds

const imagekit = new Imagekit({
    publicKey: 'public_...',
    urlEndpoint: 'https://ik.imagekit.io/imagekit_id',
    privateKey: 'private_...',
})

const server = fastify();

const startServer = async (port) => {
    // Use 'fastify-raw-body' package to retrive raw request body as utf8 string
    await server.register(fastifyRawBody, { routes: [WEBHOOK_ENDPOINT] });

    // Add webhook endpoint route
    server.route({
        method: 'POST',
        url: WEBHOOK_ENDPOINT,
        handler: (req, res) => {
            // Handle webhook
            const signature = req.raw.headers['x-ik-signature'];
            const rawBody = req.body;

            // Verify webhook signature
            let webhookResult;
            try {
                webhookResult = imagekit.verifyWebhookEvent(rawBody, signature, WEBHOOK_SECRET);
            } catch (e) {
                // Webhook verification failed
                return res.status(401).send(`Webhook error: ${e.message}`);
            }
            const { timestamp, event } = webhookResult;

            // Check if webhook has expired
            if (timestamp + WEBHOOK_EXPIRY_DURATION < Date.now()) {
                // Stall webhook
                return res.status(401).send('Webhook signature expired');
            }

            // Handle webhook
            switch (event.type) {
                case 'video.transformation.accepted':
                    console.log('Video transformation request accepted');
                    break;
                case 'video.transformation.ready':
                    console.log('Video transformation ready');
                    break;
                case 'video.transformation.error':
                    console.log('Video transformation error');
                    break;
            }

            // Acknowledge webhook is received and processed successfully
            res.status(200).send();
        },
    });

    await server.listen({ port });
};

startServer(3000).then(() => {
    console.log("Server listening on port 3000");
    console.log(
        `Webhook endpoint: 'http://localhost:${PORT}${WEBHOOK_ENDPOINT}'`,
        'Do replace 'localhost' with public endpoint'
    );
});

const http = require('http');
const Imagekit = require('imagekit');

// Webhook configs
const WEBHOOK_ENDPOINT = '/webhook';
const WEBHOOK_SECRET = 'whsec_...'; // Copy from ImageKit dashboard
const WEBHOOK_EXPIRY_DURATION = 60 * 1000; // 60 seconds

const imagekit = new Imagekit({
    publicKey: 'public_...',
    urlEndpoint: 'https://ik.imagekit.io/imagekit_id',
    privateKey: 'private_...',
})

const webhookRoute = (req, res) => {
    const signature = req.headers['x-ik-signature'];
    const reqChunks = [];
    req.setEncoding('utf8');
    req.on('data', (chunk) => {
        reqChunks.push(chunk);
    });
    req.on('end', () => {
        const rawBody = reqChunks.join('');

        // Verify webhook signature
        let webhookResult;
        try {
            webhookResult = imagekit.verifyWebhookEvent(rawBody, signature, WEBHOOK_SECRET);
        } catch (e) {
            // Webhook signature verification failed
            res.writeHead(401, `Webhook error: ${e.message}`);
            res.end();
            return;
        }
        const { timestamp, event } = webhookResult;

        // Check if webhook has expired
        if (timestamp + WEBHOOK_EXPIRY_DURATION < Date.now()) {
            // Stall webhook
            res.writeHead(401, 'Webhook signature expired');
            res.end();
            return;
        }

        // Handle webhook
        switch (event.type) {
            case 'video.transformation.accepted':
                console.log('Video transformation request accepted');
                break;
            case 'video.transformation.ready':
                console.log('Video transformation ready');
                break;
            case 'video.transformation.error':
                console.log('Video transformation error');
                break;
        }

        // Acknowledge webhook is received and processed successfully
        res.writeHead(200, 'OK');
        res.end();
    });
};

const server = http.createServer((req, res) => {
    switch (req.url) {
        case WEBHOOK_ENDPOINT:
            webhookRoute(req, res);
            break;
        default: {
            res.writeHead(404);
            res.end();
        }
    }
});

server.listen(3000, () => {
    console.log("Server listening on port 3000");
    console.log(
        `Webhook endpoint: 'http://localhost:${PORT}${WEBHOOK_ENDPOINT}'`,
        'Do replace 'localhost' with public endpoint'
    );
});