32 lines
1.2 KiB
JavaScript
32 lines
1.2 KiB
JavaScript
import express from 'express';
|
|
import { enqueueNatAdd, enqueueNatRemove } from '../services/natQueue.js';
|
|
import { error, info, warn } from '../util/Console.js';
|
|
|
|
const router = express.Router();
|
|
|
|
router.post('/', (req, res) => {
|
|
const sig = req.headers['x-webhook-signature'] || req.headers['x-hook-signature'] || '';
|
|
const secret = process.env.WEBHOOK_SECRET || '';
|
|
if (!sig || sig !== secret) return res.status(403).json({ error: 'invalid signature' });
|
|
|
|
const body = req.body || {};
|
|
const event = body.event || '';
|
|
const data = body || {};
|
|
info(`Webhook: ${event}\n${JSON.stringify(body)}`);
|
|
// return res.status(418).json({ error: 'im a teapot' }); // temporary
|
|
try {
|
|
if (event === 'created: Allocation') {
|
|
enqueueNatAdd(data.ip, data.port, 'tcp');
|
|
} else if (event === 'deleted: Allocation') {
|
|
enqueueNatRemove(data.ip, data.port, 'tcp');
|
|
} else {
|
|
warn(`Unhandled webhook event: ${event}`);
|
|
}
|
|
return res.json({ success: true });
|
|
} catch (err) {
|
|
error(err);
|
|
return res.status(500).json({ error: 'error ocurred' });
|
|
}
|
|
});
|
|
|
|
export default router; |