Получить событие отслеживания

import crypto from 'node:crypto';import express from 'express';const app = express();const secret = process.env.CARGOTIME_WEBHOOK_SECRET;if (!secret) {    throw new Error('CARGOTIME_WEBHOOK_SECRET is not set');}function queueWebhook(payload: unknown): void {    // Здесь можно поставить событие в очередь,    // сохранить его в базе данных или передать внутреннему сервису.    console.log('Cargotime прислал вебхук:', payload);}app.post('/webhooks/cargotime', express.raw({ type: 'application/json' }), (req, res) => {    const timestamp = req.header('x-cargotime-timestamp');    const signature = req.header('x-cargotime-signature');    if (!timestamp || !signature) {        return res.sendStatus(401);    }    const expected =        'sha256=' + crypto.createHmac('sha256', secret).update(timestamp).update('.').update(req.body).digest('hex');    const signatureBuffer = Buffer.from(signature);    const expectedBuffer = Buffer.from(expected);    if (signatureBuffer.length !== expectedBuffer.length || !crypto.timingSafeEqual(signatureBuffer, expectedBuffer)) {        return res.sendStatus(401);    }    const payload = JSON.parse(req.body.toString('utf8'));    queueWebhook(payload);    return res.sendStatus(200);});app.listen(3000, () => {    console.log('Сервер вебхуков запущен на порту 3000');});

import hmacimport hashlibimport osfrom fastapi import FastAPI, Request, HTTPExceptionapp = FastAPI()secret = os.environ["CARGOTIME_WEBHOOK_SECRET"].encode()def enqueue_webhook(payload: dict) -> None:    # Здесь можно поставить событие в очередь,    # сохранить его в базе данных или передать внутреннему сервису.    print("Cargotime прислал вебхук:", payload)@app.post("/webhooks/cargotime")async def cargotime_webhook(request: Request):    body = await request.body()    timestamp = request.headers.get("x-cargotime-timestamp")    signature = request.headers.get("x-cargotime-signature")    if not timestamp or not signature:        raise HTTPException(status_code=401)    digest = hmac.new(        secret,        timestamp.encode() + b"." + body,        hashlib.sha256,    ).hexdigest()    expected = f"sha256={digest}"    if not hmac.compare_digest(signature, expected):        raise HTTPException(status_code=401)    payload = await request.json()    enqueue_webhook(payload)    return {"ok": True}