Как мы СМС-трафик из PERCo-S-20 в e-mail и Telegram отправляли

version: '3.8'

services:
  # Подключеие к БД:


  # Локальный SMPP-приемник, который слушает СКУД PERCo
  smpp-to-webhook:
    image: dockerhub.timeweb.cloud/library/node:18-alpine
    container_name: ai_smpp_receiver
    restart: always
    ports:
      - "3800:3800"
    volumes:
      - "./smpp_server.js:/app/index.js:ro"
    command: node /app/index.js
    depends_on:
      - n8n

  # Платформа автоматизации n8n:
  n8n:
    image: docker.n8n.io/n8nio/n8n:latest
    container_name: ai_n8n
    restart: always
    ports:
      - "5678:5678"
    environment:
      - N8N_HOST=ip_n8n
      - N8N_PORT=5678
      - N8N_PROTOCOL=http
      - N8N_WEBHOOK_URL=http://ip_n8n
      - NODE_ENV=production
      - N8N_SECURE_COOKIE=false
      - N8N_RESTRICT_FILE_ACCESS_TO=""
      - NODES_EXCLUDE=[]
      - NODE_TLS_REJECT_UNAUTHORIZED=0
    volumes:
      - n8n_data:/home/node/.n8n
      - /home/adminllm/security_ai/skud:/home/node/reports
    depends_on:
      - postgres

volumes:
  postgres_data:
  n8n_data:

const net = require('net');
const http = require('http');

net.createServer((socket) => {
    console.log('⚡ PERCo подключилась. Шлем сырой HEX...');
    
    socket.on('data', (data) => {
        if (data.length < 16) return;
        
        const commandId = data.readUInt32BE(4);
        const seqNumber = data.readUInt32BE(12);

        // 1. Bind Transceiver
        if (commandId === 0x00000009) {
            const response = Buffer.alloc(16);
            response.writeUInt32BE(16, 0);
            response.writeUInt32BE(0x80000009, 4);
            response.writeUInt32BE(0, 8);
            response.writeUInt32BE(seqNumber, 12);
            socket.write(response);
            return;
        }

        // 2. Enquire Link
        if (commandId === 0x00000015) {
            const response = Buffer.alloc(16);
            response.writeUInt32BE(16, 0);
            response.writeUInt32BE(0x80000015, 4);
            response.writeUInt32BE(0, 8);
            response.writeUInt32BE(seqNumber, 12);
            socket.write(response);
            return;
        }

        // 3. Submit SM (Пересылка сырого HEX в n8n)
        if (commandId === 0x00000004) {
            // Переводим весь бинарный пакет в верхний регистр HEX
            const rawHex = data.toString('hex').toUpperCase();

            // Отправляем сырые данные в n8n
            const postData = JSON.stringify({ raw_hex: rawHex, source: 'PERCo-SMPP-Raw' });

            const options = {
                hostname: 'ai_n8n',
                port: 5678,
                path: '/webhook/perco-gateway',
                method: 'POST',
                headers: {
                    'Content-Type': 'application/json',
                    'Content-Length': Buffer.byteLength(postData)
                }
            };

            const req = http.request(options, () => {});
            req.on('error', (err) => console.error('❌ Ошибка n8n:', err.message));
            req.write(postData);
            req.end();

            // Отвечаем СКУД
            const response = Buffer.alloc(17);
            response.writeUInt32BE(17, 0);
            response.writeUInt32BE(0x80000004, 4);
            response.writeUInt32BE(0, 8);
            response.writeUInt32BE(seqNumber, 12);
            response.writeUInt8(0, 16);
            socket.write(response);
        }
    });

    socket.on('error', (err) => console.log('Сетевое событие:', err.message));
}).listen(3800, '0.0.0.0', () => console.log('🚀 Транслятор сырого трафика запущен на порту 3800'));

// Забираем сырую строку из правильного пути: body.raw_hex
const hex = $input.first().json.body?.raw_hex || ""; 
const result = [];

if (hex && hex.length >= 32) {
    // Функция для перевода Hex в обычную ASCII строку (с обрезкой null-терминатора)
    function hexToAscii(hexStr) {
        if (!hexStr) return '';
        let str = '';
        for (let i = 0; i < hexStr.length; i += 2) {
            const charCode = parseInt(hexStr.substr(i, 2), 16);
            if (charCode === 0) continue; 
            str += String.fromCharCode(charCode);
        }
        return str;
    }

    // Функция для перевода Hex в UTF-16BE (Big Endian)
    function hexToUtf16BE(hexStr) {
        if (!hexStr) return '';
        let str = '';
        for (let i = 0; i < hexStr.length; i += 4) {
            const charCode = parseInt(hexStr.substr(i, 4), 16);
            if (charCode === 0 || charCode === 0x000D || charCode === 0x000A) continue; 
            str += String.fromCharCode(charCode);
        }
        return str;
    }

    // 1. Ищем маркер data_coding и sm_default_msg_id, которые в пакете PERCo выглядят как "0800"
    const markerIndex = hex.indexOf("0800");

    if (markerIndex !== -1 && markerIndex + 6 <= hex.length) {
        // Байт sm_length (длина текста в байтах) идет сразу за "0800" (это 2 HEX-символа)
        const smLengthHex = hex.substring(markerIndex + 4, markerIndex + 6);
        const smLength = parseInt(smLengthHex, 16);
        
        // Текст начинается сразу после байта длины (индекс маркера + 6 символов)
        // Вырезаем кусок строки длиной smLength * 2 (так как 1 байт = 2 HEX-символа)
        const alertHex = hex.substring(markerIndex + 6, markerIndex + 6 + (smLength * 2));

        // 2. Вычисляем остальные поля по их реальным границам в пакете
        const length = parseInt(hex.substring(0, 8), 16);
        const sequence = parseInt(hex.substring(24, 32), 16);

        // Текстовые блоки до маркера
        const companyHex = hex.substring(38, 56);       // name_company
        const phoneHex = hex.substring(62, 84);         // phone
        const timestampHex = hex.substring(94, 126);    // timestamp

        result.push({
            json: {
                message: hexToUtf16BE(alertHex).trim(), // Наш декодированный текст
                packetLength: length,
                sequenceNumber: sequence,
                company: hexToAscii(companyHex).trim(),
                phoneNumber: hexToAscii(phoneHex).trim(),
                timestampRaw: hexToAscii(timestampHex).trim(),
                original_hex: hex
            }
        });
    } else {
        result.push({
            json: {
                message: "🚨 Ошибка: В HEX-пакете не найден маркер кодировки 0800",
                original_hex: hex
            }
        });
    }
} else {
    result.push({
        json: {
            message: "🚨 Ошибка: Не удалось прочитать raw_hex или пакет слишком короткий",
            original_hex: hex
        }
    });
}

return result;