Handtekening controleren

import { createHmac, timingSafeEqual } from 'node:crypto';

// geheim: het volledige geheim van het adres, inclusief whsec_
// ruweBody: de body precies zoals ontvangen, als tekst
// header: de waarde van x-leadforge-signature
export function klopt(geheim, ruweBody, header) {
	let t = null;
	const handtekeningen = [];
	for (const deel of (header ?? '').split(',')) {
		const [sleutel, waarde] = deel.trim().split('=');
		if (sleutel === 't') t = waarde;
		if (sleutel === 'v1' && waarde) handtekeningen.push(waarde);
	}
	if (!t || !handtekeningen.length) return false;

	const verwacht = createHmac('sha256', geheim).update(`${t}.${ruweBody}`, 'utf8').digest('hex');
	const b = Buffer.from(verwacht);
	return handtekeningen.some((v) => {
		const a = Buffer.from(v);
		return a.length === b.length && timingSafeEqual(a, b);
	});
}

// Voorbeeld met Express: lees de body als tekst, niet als JSON.
// app.post('/leadforge', express.text({ type: 'application/json' }), (req, res) => {
// 	if (!klopt(geheim, req.body, req.get('x-leadforge-signature'))) return res.sendStatus(401);
// 	const gebeurtenis = JSON.parse(req.body);
// 	res.sendStatus(200);
// });

import hashlib
import hmac


def klopt(geheim: str, ruwe_body: bytes, header: str) -> bool:
    """geheim: het volledige geheim inclusief whsec_; ruwe_body: de body zoals ontvangen."""
    t = None
    handtekeningen = []
    for deel in (header or "").split(","):
        sleutel, _, waarde = deel.strip().partition("=")
        if sleutel == "t":
            t = waarde
        if sleutel == "v1" and waarde:
            handtekeningen.append(waarde)
    if not t or not handtekeningen:
        return False

    bericht = t.encode() + b"." + ruwe_body
    verwacht = hmac.new(geheim.encode(), bericht, hashlib.sha256).hexdigest()
    return any(hmac.compare_digest(v, verwacht) for v in handtekeningen)


# Voorbeeld met Flask:
# @app.post("/leadforge")
# def leadforge():
#     if not klopt(geheim, request.get_data(), request.headers.get("x-leadforge-signature", "")):
#         return "", 401
#     gebeurtenis = request.get_json()
#     return "", 200