Релиз 2026.02.10

Reviewed-on: #14

config.js

@@ -7,16 +7,6 @@
 // Тело модуля
 //------------
 
-//Переменные окружения
-/*
-    Только для СУБД Oracle.
-    1. NODE_ORACLE_DB_THIN_MODE - Установите значение "1", чтобы использовать режим "тонкого клиента" (Thin-режим)
-        при подключении к БД (не требует установки Oracle Client).
-    2. ORACLE_CLIENT_LIB_DIR - Путь к директории с библиотеками Oracle Client,
-        используется только для работы в режиме "толстого клиента" (Thick-режим), если значение не указано,
-        то будет использоваться значение из переменной операционной системы PATH.
-*/
-
 //Общие параметры
 let common = {
     //Наименование сервера приложений
@@ -24,7 +14,7 @@ let common = {
     //Версия сервера приложений
     sVersion: "8.5.6.1",
     //Релиз сервера приложений
-    sRelease: "2025.12.24",
+    sRelease: "2026.02.10",
     //Таймаут останова сервера (мс)
     nTerminateTimeout: 60000,
     //Контролировать версию Системы

core/constants.js

@@ -8,9 +8,9 @@
 //-----------------
 
 //Путь к модулям
-exports.SMODULES_PATH_CORE = "."; //Модули ядра
-exports.SMODULES_PATH_MODULES = "../modules"; //Дополнительные пользовательские модули
-exports.SMODULES_PATH_MODELS = "../models"; //Модели данных и схемы валидации
+exports.SMODULES_PATH_CORE = "@core"; //Модули ядра
+exports.SMODULES_PATH_MODULES = "@modules"; //Дополнительные пользовательские модули
+exports.SMODULES_PATH_MODELS = "@models"; //Модели данных и схемы валидации
 
 //Типовые коды ошибок
 exports.SERR_COMMON = "ERR_COMMON"; //Общая ошибка

core/db_connector.js

@@ -7,9 +7,10 @@
 // Подключение библиотек
 //----------------------
 
+const _ = require("lodash"); //Работа с массивами и объектами
 const EventEmitter = require("events"); //Обработчик пользовательских событий
 const { ServerError } = require("./server_errors"); //Типовая ошибка
-const { makeModuleFullPath, validateObject, deepClone } = require("./utils"); //Вспомогательные функции
+const { makeModuleFullPath, validateObject } = require("./utils"); //Вспомогательные функции
 const prmsDBConnectorSchema = require("../models/prms_db_connector"); //Схемы валидации параметров функций модуля
 const intfDBConnectorModuleSchema = require("../models/intf_db_connector_module"); //Схема валидации интерфейса модуля взаимодействия с БД
 const objServiceSchema = require("../models/obj_service"); //Схема валидации сервиса
@@ -68,7 +69,7 @@ class DBConnector extends EventEmitter {
                     throw new ServerError(SERR_MODULES_BAD_INTERFACE, sCheckResult);
                 }
                 //Всё успешно - сохраним настройки подключения
-                this.connectSettings = deepClone(prms.connectSettings);
+                this.connectSettings = _.cloneDeep(prms.connectSettings);
                 //Инициализируем остальные свойства
                 this.connection = null;
                 this.bConnected = false;
@@ -175,7 +176,7 @@ class DBConnector extends EventEmitter {
                     //Забираем для каждого из сервисов список его функций
                     let srvsFuncs = srvs.map(async srv => {
                         const response = await this.getServiceFunctions({ nServiceId: srv.nId });
-                        let tmp = deepClone(srv);
+                        let tmp = _.cloneDeep(srv);
                         response.forEach(f => {
                             tmp.functions.push(f);
                         });
@@ -210,7 +211,7 @@ class DBConnector extends EventEmitter {
             if (!sCheckResult) {
                 try {
                     //Подготовим параметры для передачи в БД
-                    let getServiceFunctionsData = deepClone(prms);
+                    let getServiceFunctionsData = _.cloneDeep(prms);
                     getServiceFunctionsData.connection = this.connection;
                     //И выполним считывание функций сервиса
                     let res = await this.connector.getServiceFunctions(getServiceFunctionsData);
@@ -239,7 +240,7 @@ class DBConnector extends EventEmitter {
             if (!sCheckResult) {
                 try {
                     //Подготовим параметры для передачи в БД
-                    let getServiceContextData = deepClone(prms);
+                    let getServiceContextData = _.cloneDeep(prms);
                     getServiceContextData.connection = this.connection;
                     //И выполним считывание контекста сервиса
                     let res = await this.connector.getServiceContext(getServiceContextData);
@@ -268,7 +269,7 @@ class DBConnector extends EventEmitter {
             if (!sCheckResult) {
                 try {
                     //Подготовим параметры для передачи в БД
-                    let setServiceContextData = deepClone(prms);
+                    let setServiceContextData = _.cloneDeep(prms);
                     setServiceContextData.connection = this.connection;
                     //И выполним установку контекста сервиса
                     await this.connector.setServiceContext(setServiceContextData);
@@ -294,7 +295,7 @@ class DBConnector extends EventEmitter {
             if (!sCheckResult) {
                 try {
                     //Подготовим параметры для передачи в БД
-                    let clearServiceContextData = deepClone(prms);
+                    let clearServiceContextData = _.cloneDeep(prms);
                     clearServiceContextData.connection = this.connection;
                     //И выполним очистку контекста сервиса
                     await this.connector.clearServiceContext(clearServiceContextData);
@@ -320,7 +321,7 @@ class DBConnector extends EventEmitter {
             if (!sCheckResult) {
                 try {
                     //Подготовим параметры для передачи в БД
-                    let isServiceAuthData = deepClone(prms);
+                    let isServiceAuthData = _.cloneDeep(prms);
                     isServiceAuthData.connection = this.connection;
                     //И выполним проверку атентифицированности сервиса
                     let res = await this.connector.isServiceAuth(isServiceAuthData);
@@ -353,7 +354,7 @@ class DBConnector extends EventEmitter {
             if (!sCheckResult) {
                 try {
                     //Подготовим параметры для передачи в БД
-                    let putServiceAuthInQueueData = deepClone(prms);
+                    let putServiceAuthInQueueData = _.cloneDeep(prms);
                     putServiceAuthInQueueData.connection = this.connection;
                     //И выполним постановку в очередь задания на аутентификацию сервиса
                     await this.connector.putServiceAuthInQueue(putServiceAuthInQueueData);
@@ -383,7 +384,7 @@ class DBConnector extends EventEmitter {
             if (!sCheckResult) {
                 try {
                     //Подготовим параметры для передачи в БД
-                    let getServiceExpiredQueueInfoData = deepClone(prms);
+                    let getServiceExpiredQueueInfoData = _.cloneDeep(prms);
                     getServiceExpiredQueueInfoData.connection = this.connection;
                     //И выполним получение информации о просроченных сообщениях
                     let res = await this.connector.getServiceExpiredQueueInfo(getServiceExpiredQueueInfoData);
@@ -412,7 +413,7 @@ class DBConnector extends EventEmitter {
             if (!sCheckResult) {
                 try {
                     //Подготовим параметры для передачи в БД
-                    let logData = deepClone(prms);
+                    let logData = _.cloneDeep(prms);
                     logData.connection = this.connection;
                     logData.nExsSrv = this.nExsSrv;
                     //И выполним запись в журнал
@@ -435,7 +436,7 @@ class DBConnector extends EventEmitter {
     //Запись информации в журнал работы
     async putLogInf(sMsg, prms) {
         //Подготовим параметры для передачи в БД
-        let logData = deepClone(prms);
+        let logData = _.cloneDeep(prms);
         //Выставим сообщение и тип записи журнала
         logData.nLogState = objLogSchema.NLOG_STATE_INF;
         logData.sMsg = sMsg;
@@ -451,7 +452,7 @@ class DBConnector extends EventEmitter {
     //Запись предупреждения в журнал работы
     async putLogWrn(sMsg, prms) {
         //Подготовим параметры для передачи в БД
-        let logData = deepClone(prms);
+        let logData = _.cloneDeep(prms);
         //Выставим сообщение и тип записи журнала
         logData.nLogState = objLogSchema.NLOG_STATE_WRN;
         logData.sMsg = sMsg;
@@ -467,7 +468,7 @@ class DBConnector extends EventEmitter {
     //Запись ошибки в журнал работы
     async putLogErr(sMsg, prms) {
         //Подготовим параметры для передачи в БД
-        let logData = deepClone(prms);
+        let logData = _.cloneDeep(prms);
         //Выставим сообщение и тип записи журнала
         logData.nLogState = objLogSchema.NLOG_STATE_ERR;
         logData.sMsg = sMsg;
@@ -488,7 +489,7 @@ class DBConnector extends EventEmitter {
             //Если структура объекта в норме
             if (!sCheckResult) {
                 //Подготовим параметры
-                let getQueueData = deepClone(prms);
+                let getQueueData = _.cloneDeep(prms);
                 getQueueData.connection = this.connection;
                 try {
                     //Исполняем действие в БД
@@ -517,9 +518,10 @@ class DBConnector extends EventEmitter {
             //Если структура объекта в норме
             if (!sCheckResult) {
                 //Подготовим параметры
-                let putQueueData = deepClone(prms);
+                let putQueueData = _.cloneDeep(prms);
                 putQueueData.blMsg = prms.blMsg ? prms.blMsg : Buffer.from("");
                 putQueueData.connection = this.connection;
+                putQueueData.nExsSrv = this.nExsSrv;
                 //Исполняем действие в БД
                 try {
                     let res = await this.connector.putQueue(putQueueData);
@@ -548,7 +550,7 @@ class DBConnector extends EventEmitter {
             if (!sCheckResult) {
                 try {
                     //Подготовим параметры для передачи в БД
-                    let getQueueOutgoingData = deepClone(prms);
+                    let getQueueOutgoingData = _.cloneDeep(prms);
                     getQueueOutgoingData.connection = this.connection;
                     getQueueOutgoingData.nExsSrv = this.nExsSrv;
                     //Выполняем считывание из БД
@@ -576,7 +578,7 @@ class DBConnector extends EventEmitter {
             //Если структура объекта в норме
             if (!sCheckResult) {
                 //Подготовим параметры
-                let setStateData = deepClone(prms);
+                let setStateData = _.cloneDeep(prms);
                 setStateData.connection = this.connection;
                 try {
                     //Исполняем действие в БД
@@ -609,7 +611,7 @@ class DBConnector extends EventEmitter {
             //Если структура объекта в норме
             if (!sCheckResult) {
                 //Подготовим параметры
-                let getQueueMsgData = deepClone(prms);
+                let getQueueMsgData = _.cloneDeep(prms);
                 getQueueMsgData.connection = this.connection;
                 //Исполняем действие в БД
                 try {
@@ -642,7 +644,7 @@ class DBConnector extends EventEmitter {
             //Если структура объекта в норме
             if (!sCheckResult) {
                 //Подготовим параметры
-                let setQueueMsgData = deepClone(prms);
+                let setQueueMsgData = _.cloneDeep(prms);
                 if (!setQueueMsgData.blMsg) setQueueMsgData.blMsg = Buffer.from("");
                 setQueueMsgData.connection = this.connection;
                 //Исполняем действие в БД
@@ -676,7 +678,7 @@ class DBConnector extends EventEmitter {
             //Если структура объекта в норме
             if (!sCheckResult) {
                 //Подготовим параметры
-                let setQueueOptionsData = deepClone(prms);
+                let setQueueOptionsData = _.cloneDeep(prms);
                 setQueueOptionsData.connection = this.connection;
                 //Исполняем действие в БД
                 try {
@@ -709,7 +711,7 @@ class DBConnector extends EventEmitter {
             //Если структура объекта в норме
             if (!sCheckResult) {
                 //Подготовим параметры
-                let getQueueRespData = deepClone(prms);
+                let getQueueRespData = _.cloneDeep(prms);
                 getQueueRespData.connection = this.connection;
                 //Исполняем действие в БД
                 try {
@@ -742,7 +744,7 @@ class DBConnector extends EventEmitter {
             //Если структура объекта в норме
             if (!sCheckResult) {
                 //Подготовим параметры
-                let setQueueRespData = deepClone(prms);
+                let setQueueRespData = _.cloneDeep(prms);
                 if (!setQueueRespData.blResp) setQueueRespData.blResp = Buffer.from("");
                 setQueueRespData.connection = this.connection;
                 //Исполняем действие в БД
@@ -776,7 +778,7 @@ class DBConnector extends EventEmitter {
             //Если структура объекта в норме
             if (!sCheckResult) {
                 //Подготовим параметры
-                let setQueueOptionsRespData = deepClone(prms);
+                let setQueueOptionsRespData = _.cloneDeep(prms);
                 setQueueOptionsRespData.connection = this.connection;
                 //Исполняем действие в БД
                 try {
@@ -834,7 +836,7 @@ class DBConnector extends EventEmitter {
                 //Исполняем действие в БД
                 try {
                     //Подготовим параметры для передачи в БД
-                    let execQueuePrcData = deepClone(prms);
+                    let execQueuePrcData = _.cloneDeep(prms);
                     execQueuePrcData.connection = this.connection;
                     //И выполним обработчик со стороны БД
                     let res = await this.connector.execQueuePrc(execQueuePrcData);

core/http_client.js

@@ -1,614 +0,0 @@
-/*
-  Сервис интеграции ПП Парус 8 с WEB API    
-  Модуль ядра: работа с HTTP/HTTPS запросами
-*/
-
-//------------------------------
-// Подключение внешних библиотек
-//------------------------------
-
-const http = require("http");
-const https = require("https");
-const { URL } = require("url");
-const { Socket } = require("net");
-
-//--------------------------
-// Локальные идентификаторы
-//--------------------------
-
-const DEFAULT_TIMEOUT = 30000; //Таймаут по умолчанию
-
-//Ошибка HTTP-запроса
-class HttpError extends Error {
-    constructor(message, response) {
-        super(message);
-        this.name = "HttpError";
-        this.response = response;
-    }
-}
-
-//Обработка ответа (парсинг JSON, форматирование для совместимости с request-promise)
-const processResponse = (result, options) => {
-    let processedBody = result.body;
-
-    //Если запрошен автоматический парсинг JSON
-    if (options.json === true && processedBody) {
-        try {
-            const text = processedBody.toString(options.encoding || "utf8");
-            processedBody = text ? JSON.parse(text) : null;
-        } catch (e) {
-            //Если не удалось распарсить JSON, возвращаем как есть
-            processedBody = processedBody.toString(options.encoding || "utf8");
-        }
-    } else if (options.encoding && processedBody) {
-        //Если указана кодировка, конвертируем в строку
-        processedBody = processedBody.toString(options.encoding);
-    }
-
-    //Формируем результат в зависимости от resolveWithFullResponse
-    if (options.resolveWithFullResponse) {
-        return {
-            statusCode: result.statusCode,
-            statusMessage: result.statusMessage || "",
-            headers: result.headers,
-            body: processedBody,
-            url: result.url
-        };
-    } else {
-        //Если json: true, возвращаем распарсенный объект, иначе Buffer/string
-        return processedBody;
-    }
-};
-
-//Выполнение HTTP/HTTPS запроса через встроенные модули (для прокси и TLS)
-const httpRequestNative = (options, url, headers, body) => {
-    return new Promise((resolve, reject) => {
-        const urlObj = new URL(url);
-        const isHttps = urlObj.protocol === "https:";
-        const httpModule = isHttps ? https : http;
-
-        //Настройки TLS
-        const tlsOptions = {};
-        if (options.ca) {
-            tlsOptions.ca = Array.isArray(options.ca) ? options.ca : [options.ca];
-        }
-        if (options.cert) {
-            tlsOptions.cert = options.cert;
-        }
-        if (options.key) {
-            tlsOptions.key = options.key;
-        }
-        if (options.passphrase) {
-            tlsOptions.passphrase = options.passphrase;
-        }
-        if (options.rejectUnauthorized !== undefined) {
-            tlsOptions.rejectUnauthorized = options.rejectUnauthorized;
-        }
-
-        //Настройки прокси
-        let proxyUrl = null;
-        let proxyAuth = null;
-        if (options.proxy) {
-            try {
-                proxyUrl = new URL(options.proxy);
-                if (proxyUrl.username || proxyUrl.password) {
-                    proxyAuth = `Basic ${Buffer.from(`${decodeURIComponent(proxyUrl.username || "")}:${decodeURIComponent(proxyUrl.password || "")}`).toString("base64")}`;
-                }
-            } catch (e) {
-                return reject(new Error(`Некорректный URL прокси: ${e.message}`));
-            }
-        }
-
-        //Параметры запроса
-        const requestOptions = {
-            hostname: proxyUrl ? proxyUrl.hostname : urlObj.hostname,
-            port: proxyUrl ? proxyUrl.port || (proxyUrl.protocol === "https:" ? 443 : 80) : urlObj.port || (isHttps ? 443 : 80),
-            path: proxyUrl ? url : urlObj.pathname + urlObj.search,
-            method: options.method,
-            headers: Object.fromEntries(headers),
-            timeout: options.timeout || DEFAULT_TIMEOUT
-        };
-
-        //Добавляем авторизацию прокси в заголовки
-        if (proxyAuth) {
-            requestOptions.headers["Proxy-Authorization"] = proxyAuth;
-        }
-
-        //Для HTTPS добавляем TLS опции
-        if (isHttps && Object.keys(tlsOptions).length > 0) {
-            Object.assign(requestOptions, tlsOptions);
-        }
-
-        //Если используется прокси, нужно использовать CONNECT метод для HTTPS
-        if (proxyUrl && isHttps) {
-            //Для HTTPS через прокси используем туннелирование
-            return httpRequestThroughProxy(requestOptions, urlObj, headers, body, proxyUrl, proxyAuth, tlsOptions, options)
-                .then(result => resolve(processResponse(result, options)))
-                .catch(reject);
-        }
-
-        //Обычный запрос (с прокси для HTTP или без прокси)
-        const req = httpModule.request(requestOptions, res => {
-            const chunks = [];
-            res.on("data", chunk => {
-                chunks.push(chunk);
-            });
-            res.on("end", () => {
-                const responseBody = Buffer.concat(chunks);
-                const result = {
-                    statusCode: res.statusCode,
-                    statusMessage: res.statusMessage || "",
-                    headers: res.headers,
-                    body: responseBody,
-                    ok: res.statusCode >= 200 && res.statusCode < 300,
-                    url: url
-                };
-
-                if (options.throwOnErrorStatus && !result.ok) {
-                    const error = new HttpError(`Запрос не выполнен со статусом ${result.statusCode}`, result);
-                    const httpError = new Error(error.message);
-                    httpError.response = result;
-                    httpError.statusCode = result.statusCode;
-                    return reject(httpError);
-                }
-
-                resolve(processResponse(result, options));
-            });
-        });
-
-        req.on("error", err => {
-            const error = new Error(err.message);
-            error.code = err.code;
-            error.error = { code: err.code };
-            reject(error);
-        });
-
-        req.on("timeout", () => {
-            req.destroy();
-            const timeoutError = new Error(`Время ожидания выполнения запроса истекло после ${options.timeout || DEFAULT_TIMEOUT} мс`);
-            timeoutError.code = "ETIMEDOUT";
-            timeoutError.error = { code: "ETIMEDOUT" };
-            reject(timeoutError);
-        });
-
-        //Отправляем тело запроса
-        if (body) {
-            if (Buffer.isBuffer(body)) {
-                req.write(body);
-            } else if (typeof body === "string") {
-                req.write(Buffer.from(body));
-            } else {
-                req.write(Buffer.from(JSON.stringify(body)));
-            }
-        }
-
-        req.end();
-    });
-};
-
-//Выполнение HTTPS запроса через HTTP прокси (туннелирование)
-const httpRequestThroughProxy = (requestOptions, targetUrl, headers, body, proxyUrl, proxyAuth, tlsOptions, options) => {
-    const timeout = options.timeout || DEFAULT_TIMEOUT;
-    return new Promise((resolve, reject) => {
-        const proxyHost = proxyUrl.hostname;
-        const proxyPort = parseInt(proxyUrl.port || (proxyUrl.protocol === "https:" ? 443 : 80), 10);
-        const targetHost = targetUrl.hostname;
-        const targetPort = parseInt(targetUrl.port || 443, 10);
-
-        //Создаем соединение с прокси
-        const proxySocket = new Socket();
-        let connected = false;
-        let requestSent = false;
-
-        const connectTimeout = setTimeout(() => {
-            if (!connected || !requestSent) {
-                proxySocket.destroy();
-                reject(new Error(`Время ожидания подключения к прокси истекло после ${timeout} мс`));
-            }
-        }, timeout);
-
-        proxySocket.setTimeout(timeout);
-        proxySocket.on("timeout", () => {
-            proxySocket.destroy();
-            reject(new Error(`Время ожидания выполнения запроса истекло после ${timeout} мс`));
-        });
-
-        proxySocket.connect(proxyPort, proxyHost, () => {
-            connected = true;
-
-            //Отправляем CONNECT запрос
-            const connectRequest = `CONNECT ${targetHost}:${targetPort} HTTP/1.1\r\nHost: ${targetHost}:${targetPort}\r\n`;
-            const authHeader = proxyAuth ? `Proxy-Authorization: ${proxyAuth}\r\n` : "";
-            const connectHeaders = connectRequest + authHeader + "\r\n";
-
-            proxySocket.write(connectHeaders);
-
-            let connectResponse = "";
-            const onConnectData = chunk => {
-                connectResponse += chunk.toString();
-                const headerEnd = connectResponse.indexOf("\r\n\r\n");
-                if (headerEnd !== -1) {
-                    proxySocket.removeListener("data", onConnectData);
-                    clearTimeout(connectTimeout);
-
-                    //Проверяем ответ на CONNECT
-                    const statusLine = connectResponse.substring(0, connectResponse.indexOf("\r\n"));
-                    if (statusLine.includes("200")) {
-                        //Успешное подключение, создаем TLS соединение
-                        const tls = require("tls");
-                        const secureSocket = tls.connect(
-                            {
-                                socket: proxySocket,
-                                host: targetHost,
-                                servername: targetHost,
-                                ...tlsOptions
-                            },
-                            () => {
-                                requestSent = true;
-                                clearTimeout(connectTimeout);
-
-                                //Отправляем HTTP запрос через TLS
-                                const path = targetUrl.pathname + targetUrl.search;
-                                const requestLine = `${requestOptions.method} ${path} HTTP/1.1\r\n`;
-                                const hostHeader = `Host: ${targetHost}${targetPort !== 443 ? `:${targetPort}` : ""}\r\n`;
-                                const requestHeaders = Array.from(headers.entries())
-                                    .map(([key, value]) => `${key}: ${value}\r\n`)
-                                    .join("");
-                                const httpRequest = requestLine + hostHeader + requestHeaders + "\r\n";
-
-                                secureSocket.write(httpRequest);
-
-                                if (body) {
-                                    const bodyBuffer = Buffer.isBuffer(body)
-                                        ? body
-                                        : typeof body === "string"
-                                          ? Buffer.from(body)
-                                          : Buffer.from(JSON.stringify(body));
-                                    secureSocket.write(bodyBuffer);
-                                }
-
-                                //Читаем ответ
-                                let responseBuffer = Buffer.alloc(0);
-                                let responseHeaders = {};
-                                let statusCode = 200;
-                                let headerParsed = false;
-                                let contentLength = -1;
-
-                                const onSecureData = chunk => {
-                                    responseBuffer = Buffer.concat([responseBuffer, chunk]);
-
-                                    if (!headerParsed) {
-                                        const headerEnd = responseBuffer.indexOf("\r\n\r\n");
-                                        if (headerEnd !== -1) {
-                                            const headerText = responseBuffer.subarray(0, headerEnd).toString();
-                                            const bodyStart = headerEnd + 4;
-                                            responseBuffer = responseBuffer.subarray(bodyStart);
-
-                                            //Парсим заголовки
-                                            const lines = headerText.split("\r\n");
-                                            const statusLine = lines[0];
-                                            const statusMatch = statusLine.match(/HTTP\/[\d.]+\s+(\d+)/);
-                                            if (statusMatch) {
-                                                statusCode = parseInt(statusMatch[1], 10);
-                                            }
-
-                                            for (let i = 1; i < lines.length; i++) {
-                                                const line = lines[i];
-                                                const colonIndex = line.indexOf(":");
-                                                if (colonIndex !== -1) {
-                                                    const key = line.substring(0, colonIndex).trim().toLowerCase();
-                                                    const value = line.substring(colonIndex + 1).trim();
-                                                    responseHeaders[key] = value;
-                                                    if (key === "content-length") {
-                                                        contentLength = parseInt(value, 10);
-                                                    }
-                                                }
-                                            }
-
-                                            headerParsed = true;
-
-                                            //Если есть Content-Length и мы уже получили все данные
-                                            if (contentLength >= 0 && responseBuffer.length >= contentLength) {
-                                                secureSocket.removeListener("data", onSecureData);
-                                                secureSocket.end();
-                                            }
-                                        }
-                                    } else {
-                                        //Проверяем, получили ли мы все данные
-                                        if (contentLength >= 0 && responseBuffer.length >= contentLength) {
-                                            secureSocket.removeListener("data", onSecureData);
-                                            secureSocket.end();
-                                        } else if (contentLength < 0) {
-                                            //Нет Content-Length, читаем до конца
-                                            //Будем ждать закрытия соединения
-                                        }
-                                    }
-                                };
-
-                                secureSocket.on("data", onSecureData);
-
-                                secureSocket.on("end", () => {
-                                    const result = {
-                                        statusCode: statusCode,
-                                        statusMessage: "",
-                                        headers: responseHeaders,
-                                        body: responseBuffer,
-                                        ok: statusCode >= 200 && statusCode < 300,
-                                        url: targetUrl.toString()
-                                    };
-
-                                    if (options.throwOnErrorStatus && !result.ok) {
-                                        const error = new HttpError(`Запрос не выполнен со статусом ${result.statusCode}`, result);
-                                        const httpError = new Error(error.message);
-                                        httpError.response = result;
-                                        httpError.statusCode = result.statusCode;
-                                        return reject(httpError);
-                                    }
-
-                                    resolve(processResponse(result, options));
-                                });
-
-                                secureSocket.on("error", err => {
-                                    reject(err);
-                                });
-                            }
-                        );
-
-                        secureSocket.on("error", err => {
-                            reject(err);
-                        });
-                    } else {
-                        proxySocket.destroy();
-                        reject(new Error(`Прокси вернул ошибку: ${statusLine}`));
-                    }
-                }
-            };
-
-            proxySocket.on("data", onConnectData);
-        });
-
-        proxySocket.on("error", err => {
-            clearTimeout(connectTimeout);
-            reject(err);
-        });
-    });
-};
-
-//Выполнение HTTP/HTTPS запроса
-const httpRequest = async (rawOptions = {}) => {
-    try {
-        //Нормализуем параметры запроса
-        const options = normalizeOptions(rawOptions);
-        //Сформируем ссылку
-        const url = buildURL(options.url, options.query);
-        //Подготовим заголовки и тело запроса
-        const headers = prepareHeaders(options.headers);
-        const { body, contentLength, isStream } = prepareBody({
-            body: options.body,
-            jsonRequest: options.jsonRequest,
-            headers
-        });
-        //Если не указан размер тела
-        if (contentLength !== undefined && !headers.has("content-length")) {
-            //Установим размер тела в заголовок
-            headers.set("content-length", String(contentLength));
-        }
-
-        //Если есть поток, читаем его
-        let requestBody = body;
-        if (isStream && body && typeof body.pipe === "function") {
-            const chunks = [];
-            try {
-                for await (const chunk of body) {
-                    chunks.push(Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk));
-                }
-                requestBody = chunks.length > 0 ? Buffer.concat(chunks) : undefined;
-            } catch (streamError) {
-                throw new Error(`Ошибка чтения потока: ${streamError.message}`);
-            }
-        }
-
-        //Если нужен прокси или специальные TLS настройки, используем встроенные модули
-        if (options.proxy || options.ca || options.cert || options.key || options.passphrase || options.rejectUnauthorized === false) {
-            return await httpRequestNative(options, url.toString(), headers, requestBody);
-        }
-
-        //Для простых запросов используем встроенный fetch
-        const fetchImpl = globalThis.fetch;
-        if (typeof fetchImpl !== "function") {
-            throw new Error("globalThis.fetch недоступен. Используйте Node.js >= 18.");
-        }
-
-        const timeoutController = new AbortController();
-        const signals = [];
-
-        if (options.signal && options.signal instanceof AbortSignal) {
-            signals.push(options.signal);
-        }
-        signals.push(timeoutController.signal);
-
-        const combinedSignal = AbortSignal.any(signals);
-
-        const timeoutId =
-            options.timeout > 0
-                ? setTimeout(
-                      () => timeoutController.abort(new Error(`Время ожидания выполнения запроса истекло после ${options.timeout} мс`)),
-                      options.timeout
-                  )
-                : null;
-
-        try {
-            const fetchOptions = {
-                method: options.method,
-                headers: Object.fromEntries(headers),
-                body: requestBody,
-                signal: combinedSignal,
-                redirect: options.followRedirects ? "follow" : "manual"
-            };
-            const response = await fetchImpl(url.toString(), fetchOptions);
-            const responseBody = Buffer.from(await response.arrayBuffer());
-            const result = {
-                statusCode: response.status,
-                statusMessage: response.statusText || "",
-                headers: Object.fromEntries(response.headers.entries()),
-                body: responseBody,
-                ok: response.ok,
-                url: response.url
-            };
-
-            if (options.throwOnErrorStatus && !result.ok) {
-                const error = new HttpError(`Запрос не выполнен со статусом ${result.statusCode}`, result);
-                const httpError = new Error(error.message);
-                httpError.response = result;
-                httpError.statusCode = result.statusCode;
-                throw httpError;
-            }
-
-            return processResponse(result, options);
-        } finally {
-            if (timeoutId) clearTimeout(timeoutId);
-        }
-    } catch (e) {
-        //Преобразуем ошибки для совместимости с request-promise
-        if (e.name === "AbortError" || e.message.includes("время ожидания")) {
-            const timeoutError = new Error(e.message);
-            timeoutError.code = "ETIMEDOUT";
-            timeoutError.error = { code: "ETIMEDOUT" };
-            throw timeoutError;
-        }
-        //Если ошибка уже имеет response (из httpRequestNative или fetch), пробрасываем как есть
-        if (e.response) {
-            throw e;
-        }
-        if (e instanceof HttpError) {
-            const httpError = new Error(e.message);
-            httpError.response = e.response;
-            httpError.statusCode = e.response.statusCode;
-            throw httpError;
-        }
-        //Для других ошибок добавляем поле error для совместимости
-        if (e.code) {
-            e.error = { code: e.code };
-        }
-        throw e;
-    }
-};
-
-//Нормализация параметров запроса
-const normalizeOptions = options => {
-    if (!options || typeof options !== "object") {
-        throw new TypeError("options должен быть объектом");
-    }
-
-    //Поддержка параметра uri (как в request-promise)
-    const url = options.uri || options.url;
-    if (!url) throw new Error("options.url или options.uri обязателен");
-
-    //Обработаем JSON
-    const hasJsonOption = Object.prototype.hasOwnProperty.call(options, "json");
-    const jsonOption = options.json;
-
-    let body = options.body;
-    let jsonRequest = false;
-    let json = false;
-
-    if (hasJsonOption) {
-        if (jsonOption === true) {
-            json = true;
-        } else if (jsonOption && typeof jsonOption === "object") {
-            if (body === undefined) {
-                body = jsonOption;
-                jsonRequest = true;
-            }
-            json = true;
-        }
-    }
-
-    //Определяем HTTP-метод
-    let method = options.method;
-    if (!method) {
-        const hasRequestBody = body != null;
-        method = hasRequestBody ? "POST" : "GET";
-    }
-
-    return {
-        method: String(method).toUpperCase(),
-        url,
-        headers: options.headers || {},
-        query: options.query || options.qs || {},
-        body,
-        json,
-        jsonRequest,
-        timeout: options.timeout ?? DEFAULT_TIMEOUT,
-        followRedirects: options.followRedirects ?? true,
-        proxy: options.proxy || null,
-        ca: options.ca,
-        cert: options.cert,
-        key: options.key,
-        passphrase: options.passphrase,
-        rejectUnauthorized: options.rejectUnauthorized !== undefined ? options.rejectUnauthorized : true,
-        throwOnErrorStatus: options.throwOnErrorStatus ?? options.simple !== false,
-        signal: options.signal || null,
-        resolveWithFullResponse: options.resolveWithFullResponse || false,
-        encoding: options.encoding || null
-    };
-};
-
-//Формирование ссылки
-const buildURL = (base, query = {}) => {
-    const url = new URL(base);
-    Object.entries(query).forEach(([key, value]) => {
-        if (value === undefined || value === null) return;
-        url.searchParams.append(key, String(value));
-    });
-    return url;
-};
-
-//Подготовка заголовков запроса
-const prepareHeaders = (inputHeaders = {}) => {
-    const headers = new Map();
-    Object.entries(inputHeaders).forEach(([key, value]) => {
-        if (value === undefined || value === null) return;
-        headers.set(String(key).toLowerCase(), String(value));
-    });
-    return headers;
-};
-
-//Подготовка тела запроса
-const prepareBody = ({ body, jsonRequest, headers }) => {
-    if (body === undefined || body === null) {
-        return { body: undefined, contentLength: undefined, isStream: false };
-    }
-
-    //Явно указано, что тело нужно сериализовать как JSON
-    if (jsonRequest) {
-        const payload = Buffer.from(JSON.stringify(body));
-        if (!headers.has("content-type")) headers.set("content-type", "application/json; charset=utf-8");
-        return { body: payload, contentLength: payload.length, isStream: false };
-    }
-
-    if (Buffer.isBuffer(body) || body instanceof Uint8Array) {
-        return { body, contentLength: body.length, isStream: false };
-    }
-    if (typeof body === "string") {
-        const payload = Buffer.from(body);
-        return { body: payload, contentLength: payload.length, isStream: false };
-    }
-    if (typeof body.pipe === "function") {
-        return { body, contentLength: undefined, isStream: true };
-    }
-
-    //По умолчанию объектное тело сериализуем в JSON
-    if (typeof body === "object") {
-        const payload = Buffer.from(JSON.stringify(body));
-        if (!headers.has("content-type")) headers.set("content-type", "application/json; charset=utf-8");
-        return { body: payload, contentLength: payload.length, isStream: false };
-    }
-
-    //Фолбэк для прочих типов
-    const payload = Buffer.from(String(body));
-    return { body: payload, contentLength: payload.length, isStream: false };
-};
-
-exports.httpRequest = httpRequest;
-exports.HttpError = HttpError;

core/in_queue.js

@@ -7,9 +7,11 @@
 // Подключение внешних библиотек
 //------------------------------
 
+const _ = require("lodash"); //Работа с массивами и коллекциями
 const EventEmitter = require("events"); //Обработчик пользовательских событий
 const express = require("express"); //WEB-сервер Express
 const cors = require("cors"); //Управление заголовками безопасности для WEB-сервера Express
+const bodyParser = require("body-parser"); //Модуль для Express (разбор тела входящего запроса)
 const { ServerError } = require("./server_errors"); //Типовая ошибка
 const {
     makeErrorText,
@@ -21,7 +23,6 @@ const {
     deepMerge,
     deepCopyObject,
     isUndefined,
-    deepClone,
     getKafkaConnectionSettings,
     getMQTTConnectionSettings,
     getURLProtocol
@@ -66,13 +67,13 @@ class InQueue extends EventEmitter {
         //Если структура объекта в норме
         if (!sCheckResult) {
             //Общие параметры сервера приложений
-            this.common = deepClone(prms.common);
+            this.common = _.cloneDeep(prms.common);
             //Список обслуживаемых сервисов
             this.services = null;
             //Признак функционирования обработчика
             this.bWorking = false;
             //Параметры очереди
-            this.inComing = deepClone(prms.inComing);
+            this.inComing = _.cloneDeep(prms.inComing);
             //Запомним подключение к БД
             this.dbConn = prms.dbConn;
             //Запомним логгер
@@ -81,8 +82,8 @@ class InQueue extends EventEmitter {
             this.notifier = prms.notifier;
             //WEB-приложение
             this.webApp = express();
-            // Глобально разрешаем CORS для всех маршрутов и методов.
             this.webApp.use(cors());
+            this.webApp.options("*", cors());
             //WEB-сервер
             this.srv = null;
             //Параметры подключения к Kafka
@@ -123,34 +124,22 @@ class InQueue extends EventEmitter {
                 let optionsResp = {};
                 //Флаг прекращения обработки сообщения
                 let bStopPropagation = false;
-                //Нормализация сообщения
-                const toMessageBuffer = body => {
-                    if (body === undefined || body === null) return null;
-                    if (Buffer.isBuffer(body)) return body.length ? body : null;
-                    if (body instanceof Uint8Array) return body.length ? Buffer.from(body) : null;
-                    if (typeof body === "string") return body.length ? Buffer.from(body, "utf8") : null;
-                    if (typeof body === "object") {
-                        if (Object.keys(body).length === 0) return null;
-                        return Buffer.from(JSON.stringify(body));
-                    }
-                    return Buffer.from(String(body));
-                };
                 //Определимся с телом сообщения - для POST, PATCH и PUT сообщений - это тело запроса
                 if (
                     [objServiceFnSchema.NFN_PRMS_TYPE_POST, objServiceFnSchema.NFN_PRMS_TYPE_PATCH, objServiceFnSchema.NFN_PRMS_TYPE_PUT].includes(
                         prms.function.nFnPrmsType
                     )
                 ) {
-                    blMsg = toMessageBuffer(prms.req.body);
+                    blMsg = prms.req.body && !_.isEmpty(prms.req.body) ? prms.req.body : null;
                 } else {
                     //Для GET, HEAD, DELETE, CONNECT, OPTIONS и TRACE - параметры запроса
-                    if (!(Object.keys(prms.req.query ?? {}).length === 0)) blMsg = Buffer.from(JSON.stringify(prms.req.query));
+                    if (!_.isEmpty(prms.req.query)) blMsg = Buffer.from(JSON.stringify(prms.req.query));
                 }
                 //Определимся с параметрами сообщения полученными от внешней системы
                 options = {
                     method: prms.req.method,
-                    qs: deepClone(prms.req.query),
-                    headers: deepClone(prms.req.headers),
+                    qs: _.cloneDeep(prms.req.query),
+                    headers: _.cloneDeep(prms.req.headers),
                     ip: prms.req.ip,
                     hostName: prms.req.hostname,
                     protocol: prms.req.protocol,
@@ -184,11 +173,11 @@ class InQueue extends EventEmitter {
                     const fnBefore = getAppSrvFunction(prms.function.sAppSrvBefore);
                     let resBefore = null;
                     try {
-                        let resBeforePrms = deepClone(prms);
-                        resBeforePrms.queue = deepClone(q);
+                        let resBeforePrms = _.cloneDeep(prms);
+                        resBeforePrms.queue = _.cloneDeep(q);
                         resBeforePrms.queue.blMsg = blMsg;
                         resBeforePrms.queue.blResp = blResp;
-                        resBeforePrms.options = deepClone(options);
+                        resBeforePrms.options = _.cloneDeep(options);
                         resBeforePrms.dbConn = this.dbConn;
                         resBeforePrms.notifier = this.notifier;
                         resBeforePrms.res = prms.res;
@@ -211,7 +200,7 @@ class InQueue extends EventEmitter {
                                 nExecState: objQueueSchema.NQUEUE_EXEC_STATE_APP_OK
                             });
                             //Фиксируем результат исполнения "До" - обработанный запрос внешней системы
-                            if (resBefore.blMsg !== undefined) {
+                            if (!_.isUndefined(resBefore.blMsg)) {
                                 blMsg = resBefore.blMsg;
                                 q = await this.dbConn.setQueueMsg({
                                     nQueueId: q.nId,
@@ -219,7 +208,7 @@ class InQueue extends EventEmitter {
                                 });
                             }
                             //Фиксируем результат исполнения "До" - ответ на запрос
-                            if (resBefore.blResp !== undefined) {
+                            if (!_.isUndefined(resBefore.blResp)) {
                                 blResp = resBefore.blResp;
                                 q = await this.dbConn.setQueueResp({
                                     nQueueId: q.nId,
@@ -228,16 +217,16 @@ class InQueue extends EventEmitter {
                                 });
                             }
                             //Фиксируем результат исполнения "До" - параметры ответа на запрос
-                            if (resBefore.optionsResp !== undefined) {
+                            if (!_.isUndefined(resBefore.optionsResp)) {
                                 optionsResp = deepMerge(optionsResp, resBefore.optionsResp);
                                 let sOptionsResp = buildOptionsXML({ options: optionsResp });
                                 q = await this.dbConn.setQueueOptionsResp({ nQueueId: q.nId, sOptionsResp });
                             }
                             //Фиксируем результат исполнения "До" - флаг ошибочной аутентификации - если он поднят, то это ошибка, дальше ничего не делаем
-                            if (resBefore.bUnAuth !== undefined && resBefore.bUnAuth === true)
+                            if (!_.isUndefined(resBefore.bUnAuth) && resBefore.bUnAuth === true)
                                 throw new ServerError(SERR_UNAUTH, "Нет аутентификации");
                             //Фиксируем результат исполнения "До" - флаг прекращения дальнейшей обработки сообщения - если он поднят, то дальше обработку сообщения прекращаем
-                            if (resBefore.bStopPropagation !== undefined && resBefore.bStopPropagation === true) bStopPropagation = true;
+                            if (!_.isUndefined(resBefore.bStopPropagation) && resBefore.bStopPropagation === true) bStopPropagation = true;
                         } else {
                             //Или расскажем об ошибке
                             throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult);
@@ -292,12 +281,12 @@ class InQueue extends EventEmitter {
                     const fnAfter = getAppSrvFunction(prms.function.sAppSrvAfter);
                     let resAfter = null;
                     try {
-                        let resAfterPrms = deepClone(prms);
-                        resAfterPrms.queue = deepClone(q);
+                        let resAfterPrms = _.cloneDeep(prms);
+                        resAfterPrms.queue = _.cloneDeep(q);
                         resAfterPrms.queue.blMsg = blMsg;
                         resAfterPrms.queue.blResp = blResp;
-                        resAfterPrms.options = deepClone(options);
-                        resAfterPrms.optionsResp = deepClone(optionsResp);
+                        resAfterPrms.options = _.cloneDeep(options);
+                        resAfterPrms.optionsResp = _.cloneDeep(optionsResp);
                         resAfterPrms.dbConn = this.dbConn;
                         resAfterPrms.notifier = this.notifier;
                         resAfter = await fnAfter(resAfterPrms);
@@ -319,7 +308,7 @@ class InQueue extends EventEmitter {
                                 nExecState: objQueueSchema.NQUEUE_EXEC_STATE_APP_OK
                             });
                             //Фиксируем результат исполнения "После" - ответ системы
-                            if (resAfter.blResp !== undefined) {
+                            if (!_.isUndefined(resAfter.blResp)) {
                                 blResp = resAfter.blResp;
                                 q = await this.dbConn.setQueueResp({
                                     nQueueId: q.nId,
@@ -328,13 +317,13 @@ class InQueue extends EventEmitter {
                                 });
                             }
                             //Фиксируем результат исполнения "После" - параметры ответа на запрос
-                            if (resAfter.optionsResp !== undefined) {
+                            if (!_.isUndefined(resAfter.optionsResp)) {
                                 optionsResp = deepMerge(optionsResp, resAfter.optionsResp);
                                 let sOptionsResp = buildOptionsXML({ options: optionsResp });
                                 q = await this.dbConn.setQueueOptionsResp({ nQueueId: q.nId, sOptionsResp });
                             }
                             //Если пришел флаг ошибочной аутентификации и он положительный - то это ошибка, дальше ничего не делаем
-                            if (resAfter.bUnAuth !== undefined)
+                            if (!_.isUndefined(resAfter.bUnAuth))
                                 if (resAfter.bUnAuth === true) throw new ServerError(SERR_UNAUTH, "Нет аутентификации");
                         } else {
                             //Или расскажем об ошибке
@@ -587,18 +576,16 @@ class InQueue extends EventEmitter {
                 next();
             });
             //Конфигурируем сервер - обработка тела сообщения
-            this.webApp.use(express.json());
-            this.webApp.use(express.urlencoded({ extended: true }));
-            this.webApp.use(express.raw({ limit: `${this.inComing.nMsgMaxSize}mb`, type: "*/*" }));
+            this.webApp.use(bodyParser.raw({ limit: `${this.inComing.nMsgMaxSize}mb`, type: "*/*" }));
             //Конфигурируем сервер - обходим все сервисы, работающие на приём сообщений
-            this.services
-                .filter(srv => {
+            _.forEach(
+                _.filter(this.services, srv => {
                     return (
                         srv.nSrvType === objServiceSchema.NSRV_TYPE_RECIVE &&
                         [objServiceSchema.SPROTOCOL_HTTP, objServiceSchema.SPROTOCOL_HTTPS].includes(getURLProtocol(srv.sSrvRoot))
                     );
-                })
-                .forEach(srvs => {
+                }),
+                srvs => {
                     //Для любых запросов к корневому адресу сервиса - ответ о том, что это за сервис, и что он работает
                     this.webApp.all(srvs.sSrvRoot, (req, res) => {
                         res.status(200).send(
@@ -606,18 +593,19 @@ class InQueue extends EventEmitter {
                         );
                     });
                     //Для всех статических функций сервиса...
-                    srvs.functions
-                        .filter(fn => fn.sFnURL.startsWith("@"))
-                        .forEach(fn => {
+                    _.forEach(
+                        _.filter(srvs.functions, fn => fn.sFnURL.startsWith("@")),
+                        fn => {
                             this.webApp.use(
                                 buildURL({ sSrvRoot: srvs.sSrvRoot, sFnURL: fn.sFnURL.substr(1) }),
                                 express.static(`${this.inComing.sStaticDir}/${fn.sFnURL.substr(1)}`)
                             );
-                        });
+                        }
+                    );
                     //Для всех функций сервиса (кроме статических)...
-                    srvs.functions
-                        .filter(fn => !fn.sFnURL.startsWith("@"))
-                        .forEach(fn => {
+                    _.forEach(
+                        _.filter(srvs.functions, fn => !fn.sFnURL.startsWith("@")),
+                        fn => {
                             //...собственный обработчик, в зависимости от указанного способа передачи параметров
                             this.webApp[fn.sFnPrmsType.toLowerCase()](buildURL({ sSrvRoot: srvs.sSrvRoot, sFnURL: fn.sFnURL }), async (req, res) => {
                                 try {
@@ -647,8 +635,10 @@ class InQueue extends EventEmitter {
                                 //Отправим ошибку клиенту
                                 res.status(err.status || 500).send(makeErrorText(new ServerError(SERR_WEB_SERVER, err.message)));
                             });
-                        });
-                });
+                        }
+                    );
+                }
+            );
             //Инициализируем настройки подключения
             let connectionSettings = null;
             //Считываем прием сообщений по Kafka
@@ -723,7 +713,7 @@ class InQueue extends EventEmitter {
                 }
             }
             //Запросы на адреса, не входящие в состав объявленных сервисов - 404 NOT FOUND
-            this.webApp.use((req, res) => {
+            this.webApp.use("*", (req, res) => {
                 res.status(404).send(
                     `<html><body><center><br><h1>Сервер приложений ПП Парус 8<br>(${this.common.sVersion} релиз ${this.common.sRelease})</h1><h3>Запрошенный адрес не найден</h3></center></body></html>`
                 );

core/logger.js

@@ -7,9 +7,14 @@
 // Подключение библиотек
 //----------------------
 
-const { validateObject, getNowString, deepClone } = require("./utils"); //Вспомогательные функции
+const _ = require("lodash"); //Работа с массивами и объектами
+const { validateObject, getNowString } = require("./utils"); //Вспомогательные функции
 const db = require("./db_connector"); //Модуль взаимодействия с БД
-const { SCONSOLE_LOG_COLOR_PATTERN_ERR, SCONSOLE_LOG_COLOR_PATTERN_WRN, SCONSOLE_LOG_COLOR_PATTERN_INF } = require("./constants"); //Общие константы
+const {
+    SCONSOLE_LOG_COLOR_PATTERN_ERR,
+    SCONSOLE_LOG_COLOR_PATTERN_WRN,
+    SCONSOLE_LOG_COLOR_PATTERN_INF
+} = require("./constants"); //Общие константы
 const { NLOG_STATE_INF, NLOG_STATE_WRN, NLOG_STATE_ERR } = require("../models/obj_log"); //Схемы валидации записи журнала работы сервиса обмена
 const prmsLoggerSchema = require("../models/prms_logger"); //Схемы валидации параметров функций модуля
 
@@ -92,7 +97,8 @@ class Logger {
     //Протоколирование ошибки
     async error(sMsg, prms) {
         //Подготовим параметры для протоколирования
-        let logData = prms ? deepClone(prms) : {};
+        let logData = {};
+        if (prms) logData = _.cloneDeep(prms);
         //Выставим сообщение и тип записи журнала
         logData.nLogState = NLOG_STATE_ERR;
         logData.sMsg = sMsg;
@@ -102,7 +108,8 @@ class Logger {
     //Протоколирование предупреждения
     async warn(sMsg, prms) {
         //Подготовим параметры для протоколирования
-        let logData = prms ? deepClone(prms) : {};
+        let logData = {};
+        if (prms) logData = _.cloneDeep(prms);
         //Выставим сообщение и тип записи журнала
         logData.nLogState = NLOG_STATE_WRN;
         logData.sMsg = sMsg;
@@ -112,7 +119,8 @@ class Logger {
     //Протоколирование информации
     async info(sMsg, prms) {
         //Подготовим параметры для протоколирования
-        let logData = prms ? deepClone(prms) : {};
+        let logData = {};
+        if (prms) logData = _.cloneDeep(prms);
         //Выставим сообщение и тип записи журнала
         logData.nLogState = NLOG_STATE_INF;
         logData.sMsg = sMsg;

core/notifier.js

@@ -7,10 +7,11 @@
 // Подключение внешних библиотек
 //------------------------------
 
+const _ = require("lodash"); //Работа с массивами и коллекциями
 const EventEmitter = require("events"); //Обработчик пользовательских событий
 const { ServerError } = require("./server_errors"); //Типовая ошибка
 const { SERR_OBJECT_BAD_INTERFACE, SERR_MAIL_FAILED } = require("./constants"); //Общесистемные константы
-const { makeErrorText, validateObject, sendMail, deepClone } = require("./utils"); //Вспомогательные функции
+const { makeErrorText, validateObject, sendMail } = require("./utils"); //Вспомогательные функции
 const prmsNotifierSchema = require("../models/prms_notifier"); //Схемы валидации параметров функций класса
 
 //--------------------------
@@ -64,15 +65,21 @@ class Notifier extends EventEmitter {
     //Добавление уведомления в очередь отправки
     async addMessage(prms) {
         //Проверяем структуру переданного объекта для старта
-        let sCheckResult = validateObject(prms, prmsNotifierSchema.addMessage, "Параметры функции добавления уведомления в очередь отправки");
+        let sCheckResult = validateObject(
+            prms,
+            prmsNotifierSchema.addMessage,
+            "Параметры функции добавления уведомления в очередь отправки"
+        );
         //Если структура объекта в норме
         if (!sCheckResult) {
-            let tmp = deepClone(prms);
+            let tmp = _.cloneDeep(prms);
             tmp.bSent = false;
             this.messages.push(tmp);
         } else {
             await this.logger.error(
-                `Ошибка добавления уведомления в очередь: ${makeErrorText(new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult))}`
+                `Ошибка добавления уведомления в очередь: ${makeErrorText(
+                    new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult)
+                )}`
             );
         }
     }
@@ -106,13 +113,7 @@ class Notifier extends EventEmitter {
             if (!message.bSent) {
                 try {
                     //Если всё в порядке с настройками
-                    if (
-                        this.mail.sHost &&
-                        this.mail.nPort &&
-                        this.mail.sFrom &&
-                        this.mail.hasOwnProperty("bSecure") &&
-                        this.mail.hasOwnProperty("bRejectUnauthorized")
-                    ) {
+                    if (this.mail.sHost && this.mail.nPort && this.mail.sFrom && this.mail.hasOwnProperty('bSecure') && this.mail.hasOwnProperty('bRejectUnauthorized')) {
                         //Отправляем
                         await sendMail({
                             mail: this.mail,
@@ -134,12 +135,16 @@ class Notifier extends EventEmitter {
                         );
                     }
                 } catch (e) {
-                    await this.logger.error(`Ошибка отправки сообщения с темой "${message.sSubject}" для ${message.sTo}: ${makeErrorText(e)}`);
+                    await this.logger.error(
+                        `Ошибка отправки сообщения с темой "${message.sSubject}" для ${message.sTo}: ${makeErrorText(
+                            e
+                        )}`
+                    );
                 }
             }
         }
         //Подчищаем очередь - удалим уже отправленные
-        this.messages = this.messages.filter(msg => !msg.bSent);
+        _.remove(this.messages, { bSent: true });
         //Выставим флаг - цикл опроса неактивен
         this.bInSendLoop = false;
         //Перезапускаем опрос

core/out_queue.js

@@ -7,11 +7,12 @@
 // Подключение внешних библиотек
 //------------------------------
 
+const _ = require("lodash"); //Работа с массивами и коллекциями
 const EventEmitter = require("events"); //Обработчик пользовательских событий
 const ChildProcess = require("child_process"); //Работа с дочерними процессами
 const { ServerError } = require("./server_errors"); //Типовая ошибка
 const { SERR_OBJECT_BAD_INTERFACE } = require("./constants"); //Общесистемные константы
-const { makeErrorText, validateObject, deepClone } = require("./utils"); //Вспомогательные функции
+const { makeErrorText, validateObject } = require("./utils"); //Вспомогательные функции
 const { NINC_EXEC_CNT_YES, NINC_EXEC_CNT_NO } = require("../models/prms_db_connector"); //Схемы валидации параметров функций модуля взаимодействия с БД
 const objOutQueueProcessorSchema = require("../models/obj_out_queue_processor"); //Схемы валидации сообщений обмена с обработчиком сообщения очереди
 const { NFORCE_YES } = require("../models/common"); //Общие константы и схемы валидации
@@ -52,7 +53,7 @@ class OutQueue extends EventEmitter {
             //Признак функционирования обработчика
             this.bWorking = false;
             //Параметры очереди
-            this.outGoing = deepClone(prms.outGoing);
+            this.outGoing = _.cloneDeep(prms.outGoing);
             //Количество доступных обработчиков
             this.nWorkersLeft = this.outGoing.nMaxWorkers;
             //Идентификатор таймера проверки очереди
@@ -149,8 +150,6 @@ class OutQueue extends EventEmitter {
         if (!sCheckResult) {
             //Добавляем идентификатор позиции очереди в список обрабатываемых
             this.addInProgress({ nQueueId: prms.queue.nId });
-            //Найдем сервис
-            const service = this.services.find(s => s.nId === prms.queue.nServiceId);
             //Отдаём команду дочернему процессу обработчика на старт исполнения
             prms.proc.send({
                 nQueueId: prms.queue.nId,
@@ -160,8 +159,10 @@ class OutQueue extends EventEmitter {
                     nPoolMax: this.outGoing.nPoolMax,
                     nPoolIncrement: this.outGoing.nPoolIncrement
                 },
-                service: service,
-                function: service?.functions.find(f => f.nId === prms.queue.nServiceFnId),
+                service: _.find(this.services, { nId: prms.queue.nServiceId }),
+                function: _.find(_.find(this.services, { nId: prms.queue.nServiceId }).functions, {
+                    nId: prms.queue.nServiceFnId
+                }),
                 sProxy: this.sProxy,
                 kafka: this.kafka,
                 mqtt: this.mqtt
@@ -200,8 +201,10 @@ class OutQueue extends EventEmitter {
             //Если структура объекта в норме
             if (!sCheckResult) {
                 //Найдем сервис и функцию, исполнявшие данное сообщение
-                let service = this.services.find(s => s.nId === prms.queue.nServiceId);
-                let func = service?.functions.find(f => f.nId === prms.queue.nServiceFnId);
+                let service = _.find(this.services, { nId: prms.queue.nServiceId });
+                let func = _.find(_.find(this.services, { nId: prms.queue.nServiceId }).functions, {
+                    nId: prms.queue.nServiceFnId
+                });
                 //Если нашли и для функции-обработчика указан признак необходимости оповещения об ошибках
                 if (service && func && func.nErrNtfSign == objServiceFnSchema.NERR_NTF_SIGN_YES)
                     //Отправим уведомление об ошибке отработки в почту

core/out_queue_processor.js

@@ -7,7 +7,9 @@
 // Подключение библиотек
 //----------------------
 
-const { httpRequest } = require("./http_client"); //Работа с HTTP/HTTPS запросами
+require("module-alias/register"); //Поддержка псевонимов при подключении модулей
+const _ = require("lodash"); //Работа с массивами и объектами
+const rqp = require("request-promise"); //Работа с HTTP/HTTPS запросами
 const lg = require("./logger"); //Протоколирование работы
 const db = require("./db_connector"); //Взаимодействие с БД
 const {
@@ -18,7 +20,6 @@ const {
     parseOptionsXML,
     buildOptionsXML,
     deepMerge,
-    deepClone,
     getKafkaConnectionSettings,
     getMQTTConnectionSettings,
     getKafkaBroker,
@@ -136,9 +137,9 @@ const appProcess = async prms => {
                 //Флаг установленности контекста для функции начала сеанса
                 let bCtxIsSet = false;
                 //Кладём данные тела в объект сообщения и инициализируем поле для ответа
-                Object.assign(prms.queue, { blMsg: qData.blMsg, blResp: null });
+                _.extend(prms.queue, { blMsg: qData.blMsg, blResp: null });
                 //Кладём данные контекста в сервис
-                Object.assign(prms.service, serviceCtx);
+                _.extend(prms.service, serviceCtx);
                 //Собираем параметры для передачи серверу
                 let options = { method: prms.function.sFnPrmsType, encoding: null };
                 //Инициализируем параметры ответа сервера
@@ -237,8 +238,8 @@ const appProcess = async prms => {
                     const fnBefore = getAppSrvFunction(prms.function.sAppSrvBefore);
                     let resBefore = null;
                     try {
-                        let resBeforePrms = deepClone(prms);
-                        resBeforePrms.options = deepClone(options);
+                        let resBeforePrms = _.cloneDeep(prms);
+                        resBeforePrms.options = _.cloneDeep(options);
                         resBeforePrms.dbConn = dbConn;
                         resBefore = await fnBefore(resBeforePrms);
                     } catch (e) {
@@ -254,7 +255,7 @@ const appProcess = async prms => {
                         //Если структура ответа в норме
                         if (!sCheckResult) {
                             //Применим ответ "До" - обработанное сообщение очереди
-                            if (resBefore.blMsg !== undefined) {
+                            if (!_.isUndefined(resBefore.blMsg)) {
                                 prms.queue.blMsg = resBefore.blMsg;
                                 await dbConn.setQueueMsg({
                                     nQueueId: prms.queue.nId,
@@ -280,14 +281,14 @@ const appProcess = async prms => {
                                 }
                             }
                             //Применим ответ "До" - параметры отправки сообщения удаленному серверу
-                            if (resBefore.options !== undefined) options = deepMerge(options, resBefore.options);
+                            if (!_.isUndefined(resBefore.options)) options = deepMerge(options, resBefore.options);
                             //Применим ответ "До" - флаг отсуствия аутентификации
-                            if (resBefore.bUnAuth !== undefined)
+                            if (!_.isUndefined(resBefore.bUnAuth))
                                 if (resBefore.bUnAuth === true) {
                                     throw new ServerError(SERR_UNAUTH, "Нет аутентификации");
                                 }
                             //Применим ответ "До" - контекст работы сервиса
-                            if (resBefore.sCtx !== undefined)
+                            if (!_.isUndefined(resBefore.sCtx))
                                 if (prms.function.nFnType == objServiceFnSchema.NFN_TYPE_LOGIN) {
                                     prms.service.sCtx = resBefore.sCtx;
                                     prms.service.dCtxExp = resBefore.dCtxExp;
@@ -299,7 +300,7 @@ const appProcess = async prms => {
                                     bCtxIsSet = true;
                                 }
                             //Применим ответ "До" - флаг прекращения дальнейшей обработки сообщения - если он поднят, то дальше обработку сообщения прекращаем
-                            if (resBefore.bStopPropagation !== undefined && resBefore.bStopPropagation === true) bStopPropagation = true;
+                            if (!_.isUndefined(resBefore.bStopPropagation) && resBefore.bStopPropagation === true) bStopPropagation = true;
                         } else {
                             //Или расскажем об ошибке в структуре ответа
                             throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult);
@@ -316,7 +317,7 @@ const appProcess = async prms => {
                     try {
                         //Сохраняем параметры с которыми уходило сообщение
                         try {
-                            let tmpOptions = deepClone(options);
+                            let tmpOptions = _.cloneDeep(options);
                             //Исключим из параметров заведомо бинарные поля (их сохранение не предусмотрено)
                             delete tmpOptions.body;
                             delete tmpOptions.cert;
@@ -365,13 +366,8 @@ const appProcess = async prms => {
                                 if (prms.function.nTimeoutConn && !options.timeout) options.timeout = prms.function.nTimeoutConn;
                                 //Отправляем запрос
                                 serverResp = prms.function.nTimeoutAsynch
-                                    ? await wrapPromiseTimeout(prms.function.nTimeoutAsynch, signal =>
-                                          httpRequest({
-                                              ...options,
-                                              signal
-                                          })
-                                      )
-                                    : await httpRequest(options);
+                                    ? await wrapPromiseTimeout(prms.function.nTimeoutAsynch, rqp(options))
+                                    : await rqp(options);
                                 break;
                         }
                         //Сохраняем полученный ответ
@@ -382,7 +378,7 @@ const appProcess = async prms => {
                             nIsOriginal: NIS_ORIGINAL_YES
                         });
                         //Сохраняем заголовки ответа и HTTP-статус
-                        optionsResp.headers = deepClone(serverResp.headers);
+                        optionsResp.headers = _.cloneDeep(serverResp.headers);
                         optionsResp.statusCode = serverResp.statusCode;
                         try {
                             let sOptionsResp = buildOptionsXML({ options: optionsResp });
@@ -407,9 +403,9 @@ const appProcess = async prms => {
                         const fnAfter = getAppSrvFunction(prms.function.sAppSrvAfter);
                         let resAfter = null;
                         try {
-                            let resAfterPrms = deepClone(prms);
-                            resAfterPrms.options = deepClone(options);
-                            resAfterPrms.optionsResp = deepClone(optionsResp);
+                            let resAfterPrms = _.cloneDeep(prms);
+                            resAfterPrms.options = _.cloneDeep(options);
+                            resAfterPrms.optionsResp = _.cloneDeep(optionsResp);
                             resAfter = await fnAfter(resAfterPrms);
                         } catch (e) {
                             throw new ServerError(SERR_APP_SERVER_AFTER, e.message);
@@ -424,7 +420,7 @@ const appProcess = async prms => {
                             //Если структура ответа в норме
                             if (!sCheckResult) {
                                 //Применим ответ "После" - обработанный ответ удаленного сервиса
-                                if (resAfter.blResp !== undefined) {
+                                if (!_.isUndefined(resAfter.blResp)) {
                                     prms.queue.blResp = resAfter.blResp;
                                     await dbConn.setQueueResp({
                                         nQueueId: prms.queue.nId,
@@ -433,10 +429,10 @@ const appProcess = async prms => {
                                     });
                                 }
                                 //Применим ответ "После" - флаг утентификации сервиса
-                                if (resAfter.bUnAuth !== undefined)
+                                if (!_.isUndefined(resAfter.bUnAuth))
                                     if (resAfter.bUnAuth === true) throw new ServerError(SERR_UNAUTH, "Нет аутентификации");
                                 //Применим ответ "После" - контекст работы сервиса
-                                if (resAfter.sCtx !== undefined)
+                                if (!_.isUndefined(resAfter.sCtx))
                                     if (prms.function.nFnType == objServiceFnSchema.NFN_TYPE_LOGIN) {
                                         prms.service.sCtx = resAfter.sCtx;
                                         prms.service.dCtxExp = resAfter.dCtxExp;

core/service_available_controller.js

@@ -7,11 +7,12 @@
 // Подключение внешних библиотек
 //------------------------------
 
-const { httpRequest } = require("./http_client"); //Работа с HTTP/HTTPS запросами
+const _ = require("lodash"); //Работа с массивами и коллекциями
+const rqp = require("request-promise"); //Работа с HTTP/HTTPS запросами
 const EventEmitter = require("events"); //Обработчик пользовательских событий
 const { ServerError } = require("./server_errors"); //Типовая ошибка
 const { SERR_SERVICE_UNAVAILABLE, SERR_OBJECT_BAD_INTERFACE } = require("./constants"); //Общесистемные константы
-const { makeErrorText, validateObject, deepClone } = require("./utils"); //Вспомогательные функции
+const { makeErrorText, validateObject } = require("./utils"); //Вспомогательные функции
 const prmsServiceAvailableControllerSchema = require("../models/prms_service_available_controller"); //Схемы валидации параметров функций класса
 const objServiceSchema = require("../models/obj_service"); //Схемы валидации сервисов
 
@@ -106,7 +107,10 @@ class ServiceAvailableController extends EventEmitter {
                 //Обходим список сервисов для проверки
                 for (let service of this.services) {
                     //Если сервис надо проверять на доступность и это сервис для отправки исходящих сообщений
-                    if (service.nUnavlblNtfSign == objServiceSchema.NUNAVLBL_NTF_SIGN_YES && service.nSrvType == objServiceSchema.NSRV_TYPE_SEND) {
+                    if (
+                        service.nUnavlblNtfSign == objServiceSchema.NUNAVLBL_NTF_SIGN_YES &&
+                        service.nSrvType == objServiceSchema.NSRV_TYPE_SEND
+                    ) {
                         try {
                             // Инициализируем параметры запроса
                             let options = {};
@@ -119,7 +123,7 @@ class ServiceAvailableController extends EventEmitter {
                                 options.proxy = service.sProxyURL ?? this.sProxy;
                             }
                             //Отправляем проверочный запрос
-                            await httpRequest(options);
+                            await rqp(options);
                             //Запрос прошел - фиксируем дату доступности и сбрасываем дату недоступности
                             service.dAvailable = new Date();
                             service.dUnAvailable = null;
@@ -189,9 +193,10 @@ class ServiceAvailableController extends EventEmitter {
                                 });
                             }
                         } catch (e) {
-                            await this.logger.error(`При проверке просроченных сообщений сервиса ${service.sCode}: ${makeErrorText(e)}`, {
-                                nServiceId: service.nId
-                            });
+                            await this.logger.error(
+                                `При проверке просроченных сообщений сервиса ${service.sCode}: ${makeErrorText(e)}`,
+                                { nServiceId: service.nId }
+                            );
                         }
                     }
                 }
@@ -227,7 +232,7 @@ class ServiceAvailableController extends EventEmitter {
             //Выставляем флаг неактивности (пока) цикла опроса
             this.bInDetectingLoop = false;
             //запоминаем список обслуживаемых сервисов и инициализируем даты доступности и недоступности
-            this.services = deepClone(prms.services);
+            this.services = _.cloneDeep(prms.services);
             this.services.forEach(s => {
                 s.dUnAvailable = null;
                 s.dAvailable = new Date();

core/utils.js

@@ -8,6 +8,7 @@
 //----------------------
 
 const fs = require("fs"); //Работа с файлами
+const _ = require("lodash"); //Работа с массивами и объектами
 const os = require("os"); //Средства операционной системы
 const xml2js = require("xml2js"); //Конвертация XML в JSON
 const Schema = require("validate"); //Схемы валидации
@@ -28,92 +29,6 @@ const { SPROTOCOL_HTTP, SPROTOCOL_KAFKA } = require("../models/obj_service"); //
 // Тело модуля
 //------------
 
-//Глубокое клонирование
-const deepClone = value => {
-    //Клонируем объект в зависимости от его типа, сохраняя прототипы
-    const seen = new WeakMap();
-    const clone = val => {
-        //Примитивы и функции возвращаем как есть
-        if (val === null || typeof val !== "object") return val;
-        if (typeof val === "function") return val;
-        //Защита от циклических ссылок
-        if (seen.has(val)) return seen.get(val);
-        //Специализированные типы
-        if (val instanceof Date) return new Date(val);
-        if (Buffer.isBuffer(val)) return Buffer.from(val);
-        if (ArrayBuffer.isView(val)) return new val.constructor(val);
-        if (val instanceof RegExp) return new RegExp(val);
-        //Ошибки: сохраняем тип, сообщение, стек и пользовательские поля
-        if (val instanceof Error) {
-            const clonedError = new val.constructor(val.message);
-            seen.set(val, clonedError);
-            clonedError.name = val.name;
-            clonedError.stack = val.stack;
-            Reflect.ownKeys(val).forEach(key => {
-                if (key === "name" || key === "message" || key === "stack") return;
-                const desc = Object.getOwnPropertyDescriptor(val, key);
-                if (!desc) return;
-                if ("value" in desc) desc.value = clone(desc.value);
-                try {
-                    Object.defineProperty(clonedError, key, desc);
-                } catch (e) {}
-            });
-            return clonedError;
-        }
-        //Коллекции
-        if (val instanceof Map) {
-            const m = new Map();
-            seen.set(val, m);
-            val.forEach((v, k) => m.set(clone(k), clone(v)));
-            return m;
-        }
-        if (val instanceof Set) {
-            const s = new Set();
-            seen.set(val, s);
-            val.forEach(v => s.add(clone(v)));
-            return s;
-        }
-        //Коллекции, которые невозможно корректно клонировать - возвращаем по ссылке
-        if (val instanceof WeakMap || val instanceof WeakSet || val instanceof Promise) {
-            return val;
-        }
-        //Массивы
-        if (Array.isArray(val)) {
-            const arr = new Array(val.length);
-            seen.set(val, arr);
-            for (let i = 0; i < val.length; i++) {
-                if (Object.prototype.hasOwnProperty.call(val, i)) {
-                    arr[i] = clone(val[i]);
-                }
-            }
-            return arr;
-        }
-        //Общие объекты и пользовательские классы: сохраняем прототип и дескрипторы свойств
-        const proto = Object.getPrototypeOf(val);
-        const obj = Object.create(proto);
-        seen.set(val, obj);
-        Reflect.ownKeys(val).forEach(key => {
-            const desc = Object.getOwnPropertyDescriptor(val, key);
-            if (!desc) return;
-            if ("value" in desc) {
-                desc.value = clone(desc.value);
-            }
-            try {
-                Object.defineProperty(obj, key, desc);
-            } catch (e) {}
-        });
-        return obj;
-    };
-    try {
-        return clone(value);
-    } catch (e) {
-        //В случае непредвиденной ошибки формируем информативное исключение
-        const err = new Error("Ошибка глубокого копирования объекта");
-        err.originalError = e;
-        throw err;
-    }
-};
-
 //Валидация объекта
 const validateObject = (obj, schema, sObjName) => {
     //Объявим результат
@@ -123,7 +38,7 @@ const validateObject = (obj, schema, sObjName) => {
         //И есть что проверять
         if (obj) {
             //Сделаем это
-            const objTmp = deepClone(obj);
+            const objTmp = _.cloneDeep(obj);
             const errors = schema.validate(objTmp, { strip: false });
             //Если есть ошибки
             if (errors && Array.isArray(errors)) {
@@ -132,7 +47,7 @@ const validateObject = (obj, schema, sObjName) => {
                     let a = errors.map(e => {
                         return e.message;
                     });
-                    sRes = `Объект${sObjName ? ` "${sObjName}" ` : " "}имеет некорректный формат: ${Array.from(new Set(a)).join("; ")}`;
+                    sRes = `Объект${sObjName ? ` "${sObjName}" ` : " "}имеет некорректный формат: ${_.uniq(a).join("; ")}`;
                 }
             } else {
                 //Валидатор вернул не то, что мы ожидали
@@ -407,30 +322,11 @@ const getNowString = () => {
 };
 
 //Глубокое слияние объектов
-function deepMerge(...sources) {
-    const isPlainObject = value => Object.prototype.toString.call(value) === "[object Object]";
-
-    const cloneValue = value => {
-        return deepClone(value);
-    };
-
-    const target = {};
-
-    for (const source of sources) {
-        if (!isPlainObject(source)) continue;
-
-        for (const [key, value] of Object.entries(source)) {
-            if (isPlainObject(value)) {
-                if (!isPlainObject(target[key])) target[key] = {};
-                target[key] = deepMerge(target[key], value);
-            } else {
-                target[key] = cloneValue(value);
-            }
-        }
-    }
-
-    return target;
-}
+const deepMerge = (...args) => {
+    let res = {};
+    for (let i = 0; i < args.length; i++) _.merge(res, args[i]);
+    return res;
+};
 
 //Глубокое копирование объекта
 const deepCopyObject = obj => JSON.parse(JSON.stringify(obj));
@@ -507,29 +403,18 @@ const getURLProtocol = sURL => {
     return sURL.substring(0, 1) === "/" ? SPROTOCOL_HTTP : new URL(sURL).protocol.slice(0, -1);
 };
 
-//Wraps async task with timeout and abort support
-const wrapPromiseTimeout = (timeout, executor) => {
-    if (!timeout || typeof executor !== "function") {
-        return executor ? executor() : Promise.resolve();
-    }
-
-    const controller = new AbortController();
-    const sMessage = `Истёк интервал ожидания (${timeout} мс) завершения асинхронного процесса.`;
-    const timeoutError = new Error(sMessage);
-    timeoutError.error = sMessage;
-
+//Обёртывание промиса в таймаут исполнения
+const wrapPromiseTimeout = (timeout, promise, promiseCancellable = true) => {
+    if (!timeout) return promise;
     let timeoutPid;
-
-    const timeoutPromise = new Promise((_, reject) => {
-        timeoutPid = setTimeout(() => {
-            controller.abort(timeoutError);
-            reject(timeoutError);
-        }, timeout);
+    const timeoutPromise = new Promise((resolve, reject) => {
+        const sMessage = `Истёк интервал ожидания (${timeout} мс) завершения асинхронного процесса.`;
+        let e = new Error(sMessage);
+        e.error = sMessage;
+        timeoutPid = setTimeout(() => reject(e), timeout);
     });
-
-    const taskPromise = Promise.resolve(executor(controller.signal));
-
-    return Promise.race([taskPromise, timeoutPromise]).finally(() => {
+    return Promise.race([promise, timeoutPromise]).finally(() => {
+        if (promiseCancellable && promise.promise().isPending()) promise.cancel();
         if (timeoutPid) clearTimeout(timeoutPid);
     });
 };
@@ -552,7 +437,6 @@ exports.parseOptionsXML = parseOptionsXML;
 exports.buildOptionsXML = buildOptionsXML;
 exports.getNowString = getNowString;
 exports.deepMerge = deepMerge;
-exports.deepClone = deepClone;
 exports.deepCopyObject = deepCopyObject;
 exports.isUndefined = isUndefined;
 exports.getKafkaConnectionSettings = getKafkaConnectionSettings;

index.js

@@ -7,6 +7,7 @@
 // Подключение библиотек
 //----------------------
 
+require("module-alias/register"); //Поддержка псевонимов при подключении модулей
 const cfg = require("./config"); //Настройки сервера приложений
 const app = require("./core/app"); //Сервер приложений
 const { makeErrorText, getNowString } = require("./core/utils"); //Вспомогательные функции
@@ -28,7 +29,11 @@ process.env.NODE_TLS_REJECT_UNAUTHORIZED = cfg.outGoing.bValidateSSL === false ?
 //Обработка события "выход" жизненного цикла процесса
 process.on("exit", code => {
     //Сообщим о завершении процесса
-    console.log(SCONSOLE_LOG_COLOR_PATTERN_WRN, `${getNowString()} ПРЕДУПРЕЖДЕНИЕ: `, `Сервер приложений остановлен (код: ${code})`);
+    console.log(
+        SCONSOLE_LOG_COLOR_PATTERN_WRN,
+        `${getNowString()} ПРЕДУПРЕЖДЕНИЕ: `,
+        `Сервер приложений остановлен (код: ${code})`
+    );
 });
 
 //Обработка событий мягкого останова процесса

modules/diadoc.js

@@ -8,7 +8,8 @@
 //------------------------------
 
 const xml2js = require("xml2js"); //Конвертация XML в JSON и JSON в XML
-const { httpRequest } = require("../core/http_client"); //Работа с HTTP/HTTPS запросами
+const _ = require("lodash"); //Работа с коллекциями и объектами
+const rqp = require("request-promise"); //Работа с HTTP/HTTPS запросами
 const config = require("../config"); //Параметры сервера
 const { SDDAUTH_API_CLIENT_ID, SDEPARTMENT_NAME, SDEPARTMENT_ID } = require("./diadoc_config"); //Ключ разработчика
 
@@ -61,7 +62,7 @@ const toArray = (obj, tags) => {
         if (typeof value === "object") {
             obj[prop] = toArray(value, tag);
         }
-        if (tags.indexOf(prop) != -1 && !Array.isArray(obj[prop])) {
+        if (tags.indexOf(prop) != -1 && !_.isArray(obj[prop])) {
             obj[prop] = JSON.parse("[" + JSON.stringify(value) + "]");
         }
     }
@@ -144,18 +145,18 @@ const getOrganizations = (organizations, sNumEdo = null) => {
     //Задан код участника ЭДО
     if (sNumEdo) {
         //Найдем активную организацию не в роуминге
-        organization.Organizations[0] = organizations.Organizations.find(org => org.FnsParticipantId === sNumEdo);
-    }
+        organization.Organizations[0] = organizations.Organizations.find(org => (org.FnsParticipantId === sNumEdo));
+    };
     //Не удалось получить организацию по коду участника ЭДО
     if (!organization.Organizations[0]) {
         //Найдем активную организацию не в роуминге
-        organization.Organizations[0] = organizations.Organizations.find(org => org.IsRoaming === isRoaming && org.IsActive === isActive);
-    }
+        organization.Organizations[0] = organizations.Organizations.find(org => (org.IsRoaming === isRoaming) && (org.IsActive === isActive));
+    };
     //Не удалось получить организацию не в роуминге
     if (!organization.Organizations[0]) {
         //Найдем активную организацию
-        organization.Organizations[0] = organizations.Organizations.find(org => org.IsActive === isActive);
-    }
+        organization.Organizations[0] = organizations.Organizations.find(org => (org.IsActive === isActive));
+    };
     //Если не удалось получить активную организацию
     if (!organization.Organizations[0]) {
         //Если нет организации не в роуминге и найдено более одной организации
@@ -174,10 +175,10 @@ const getOrganizations = (organizations, sNumEdo = null) => {
 //Получение организации по ИНН/КПП контрагента
 const getOrganization = async (sSrvRoot, headers, nInn, nKpp) => {
     //Параметры запроса
-    let httpRequestOptions;
+    let rqpOptions;
     let serverResp;
     //Формируем запрос для получения BoxId
-    httpRequestOptions = {
+    rqpOptions = {
         uri: buildOrganizationURL(sSrvRoot),
         qs: {
             inn: nInn,
@@ -187,18 +188,18 @@ const getOrganization = async (sSrvRoot, headers, nInn, nKpp) => {
         json: true
     };
     //Выполним запрос
-    serverResp = { Organizations: [await httpRequest(httpRequestOptions)] };
+    serverResp = { Organizations: [await rqp(rqpOptions)] };
     return serverResp;
 };
 
 //Получение ящика организации по ИНН/КПП контрагента
 const getOrganizationBoxId = async (sSrvRoot, headers, nInn, nKpp, sNumEdo) => {
     //Параметры запроса
-    let httpRequestOptions;
+    let rqpOptions;
     let serverResp;
     let organization = {};
     //Формируем запрос для получения BoxId по ИНН/КПП
-    httpRequestOptions = {
+    rqpOptions = {
         uri: buildOrganizationsByInnKppURL(sSrvRoot),
         qs: {
             inn: nInn,
@@ -209,21 +210,19 @@ const getOrganizationBoxId = async (sSrvRoot, headers, nInn, nKpp, sNumEdo) => {
     };
     try {
         //Выполним запрос
-        serverResp = await httpRequest(httpRequestOptions);
+        serverResp = await rqp(rqpOptions);
         try {
             //Получим организацию не в роуминге (или единственную организацию в роуминге)
             serverResp = getOrganizations(serverResp, sNumEdo);
             if (!serverResp?.Organizations[0]) {
-                throw Error(
-                    `Не удалось получить ящик получателя для контрагента с ${sNumEdo ? `кодом участника ЭДО: ${sNumEdo}, ` : ""}ИНН: ${nInn} и КПП: ${nKpp}`
-                );
+                throw Error(`Не удалось получить ящик получателя для контрагента с ${sNumEdo ? `кодом участника ЭДО: ${sNumEdo}, ` : ""}ИНН: ${nInn} и КПП: ${nKpp}`);
             }
         } catch (e) {
             //Получим головную организацию по ИНН/КПП
             serverResp = await getOrganization(sSrvRoot, headers, nInn, nKpp);
-        }
+        };
         //Проверим соответствие КПП организации
-        if (serverResp?.Organizations[0]?.Kpp != nKpp && serverResp?.Organizations[0]) {
+        if ((serverResp?.Organizations[0]?.Kpp != nKpp) && (serverResp?.Organizations[0])) {
             //Если КПП не соответстует заданному - проверим, что в полученной организации есть департамент с заданным КПП
             for (let i in serverResp.Organizations[0].Departments) {
                 //Если найден подходящий департамент - запомним идентификатор и выходим из цикла
@@ -231,25 +230,23 @@ const getOrganizationBoxId = async (sSrvRoot, headers, nInn, nKpp, sNumEdo) => {
                     //Сохраняем полученный ответ
                     organization.DepartmentId = serverResp.Organizations[0].Departments[i].DepartmentId;
                     break;
-                }
-            }
-        }
+                };
+            };
+        };
         //Не удалось получить ящик получателя или полученая организация не соответствует заданному ИНН
-        if (!serverResp?.Organizations[0]?.Boxes[0]?.BoxId || serverResp?.Organizations[0]?.Inn != nInn) {
+        if ((!serverResp?.Organizations[0]?.Boxes[0]?.BoxId) || (serverResp?.Organizations[0]?.Inn != nInn)) {
             throw new Error(`Не удалось получить ящик получателя для контрагента с ИНН: ${nInn} и КПП: ${nKpp}`);
         }
         //Не удалось получить департаментом с соответствующим КПП
-        if (serverResp?.Organizations[0]?.Kpp != nKpp && !organization?.DepartmentId) {
-            throw new Error(
-                `Не удалось получить ящик получателя для контрагента с ИНН: ${nInn} и КПП: ${nKpp}, у головной организации отсутствует подразделение с КПП: ${nKpp}`
-            );
+        if ((serverResp?.Organizations[0]?.Kpp != nKpp) && (!organization?.DepartmentId)) {
+            throw new Error(`Не удалось получить ящик получателя для контрагента с ИНН: ${nInn} и КПП: ${nKpp}, у головной организации отсутствует подразделение с КПП: ${nKpp}`);
         }
         //Сохраняем полученный ответ
         organization.BoxId = serverResp.Organizations[0].Boxes[0].BoxId;
         return organization;
     } catch (e) {
         throw Error(`Ошибка при получении ящика получателя:  ${e.message}`);
-    }
+    };
 };
 
 //Обработчик "До" подключения к сервису
@@ -312,7 +309,7 @@ const beforeMessagePost = async prms => {
         //Конвертируем XML из "Парус 8" в JSON
         let obj = await toJSON(prms.queue.blMsg.toString());
         //Формируем запрос для получения FromBoxId
-        let httpRequestOptions = {
+        let rqpOptions = {
             uri: buildMyOrganizationURL(prms.service.sSrvRoot),
             headers: buildHeaders(sAPIClientId, sToken),
             json: true
@@ -322,7 +319,7 @@ const beforeMessagePost = async prms => {
         let organization;
         try {
             //Выполним запрос
-            serverResp = await httpRequest(httpRequestOptions);
+            serverResp = await rqp(rqpOptions);
             //Получим идентификатор организации по ИНН/КПП поставщика документа
             for (let i in serverResp.Organizations) {
                 //Если найдена подходящая организация - запомним идентификатор и выходим из цикла
@@ -340,18 +337,12 @@ const beforeMessagePost = async prms => {
             throw Error(`Ошибка при получении ящика текущей организации:  ${e.message}`);
         }
         //Получим ящик получателя
-        organization = await getOrganizationBoxId(
-            prms.service.sSrvRoot,
-            buildHeaders(sAPIClientId, sToken),
-            optionsData.inn_cs,
-            optionsData.kpp_cs,
-            optionsData.num_cs
-        );
+        organization = await getOrganizationBoxId(prms.service.sSrvRoot, buildHeaders(sAPIClientId, sToken), optionsData.inn_cs, optionsData.kpp_cs, optionsData.num_cs);
         obj.ToBoxId = organization.BoxId;
         //Если не заполнен идентификатор подразделения и при получении ящика удалось его подобрать
-        if (!obj.ToDepartmentId && organization.DepartmentId) {
+        if ((!obj.ToDepartmentId) && (organization.DepartmentId)) {
             obj.ToDepartmentId = organization.DepartmentId;
-        }
+        };
         //Если пришел ответ
         if (prms.queue.blResp && serverResp.statusCode == 200) {
             //Вернем загруженный документ
@@ -476,14 +467,14 @@ const beforeEvent = async prms => {
         //Получим параметры запроса
         const optionsData = await toJSON(prms.queue.sOptions);
         //Формируем запрос для получения BoxId
-        let httpRequestOptions = {
+        let rqpOptions = {
             uri: buildMyOrganizationURL(prms.service.sSrvRoot),
             headers: buildHeaders(sAPIClientId, sToken),
             json: true
         };
         try {
             //Выполним запрос
-            serverResp = await httpRequest(httpRequestOptions);
+            serverResp = await rqp(rqpOptions);
             //Получим идентификатор организации по ИНН/КПП контрагента организации
             for (let i in serverResp.Organizations) {
                 //Если найдена подходящая организация - запомним идентификатор и выходим из цикла
@@ -560,7 +551,7 @@ const afterEvent = async prms => {
     let sAPIClientId = null; //Ключ разработчика
     let sToken = null; //Токен доступа
     let resu = null; //Ответ сервера
-    let httpRequestOptions = null; //Параметры для запроса информации по ящику
+    let rqpOptions = null; //Параметры для запроса информации по ящику
     let serverResp; //Результат запроса информации по организации
     let resp = null; //Ответ сервера
     let box = null; //Информация ящика
@@ -576,10 +567,10 @@ const afterEvent = async prms => {
         //Получим список уникальных ящиков
         for (let i in resp.Events) {
             if (resp.Events[i]?.Message) {
-                if (!boxIds.boxIds.find(box => box.boxId === resp.Events[i]?.Message.FromBoxId) && resp.Events[i]?.Message.FromBoxId) {
+                if ((!boxIds.boxIds.find(box => box.boxId === resp.Events[i]?.Message.FromBoxId)) && (resp.Events[i]?.Message.FromBoxId)) {
                     boxIds.boxIds.push({ boxId: resp.Events[i]?.Message.FromBoxId });
                 }
-                if (!boxIds.boxIds.find(box => box.boxId === resp.Events[i]?.Message.ToBoxId) && resp.Events[i]?.Message.ToBoxId) {
+                if ((!boxIds.boxIds.find(box => box.boxId === resp.Events[i]?.Message.ToBoxId)) && (resp.Events[i]?.Message.ToBoxId)) {
                     boxIds.boxIds.push({ boxId: resp.Events[i]?.Message.ToBoxId });
                 }
             }
@@ -593,9 +584,9 @@ const afterEvent = async prms => {
             //Если не достали из контекста токен доступа - значит нет аутентификации на сервере
             if (!sToken) return { bUnAuth: true };
             for (let i in boxIds.boxIds) {
-                httpRequestOptions = null;
+                rqpOptions = null;
                 //Формируем запрос для получения BoxId
-                httpRequestOptions = {
+                rqpOptions = {
                     uri: buildOrganizationBoxIdURL(prms.service.sSrvRoot),
                     headers: buildHeaders(sAPIClientId, sToken),
                     qs: {
@@ -605,7 +596,7 @@ const afterEvent = async prms => {
                 };
                 try {
                     //Выполним запрос
-                    serverResp = await httpRequest(httpRequestOptions);
+                    serverResp = await rqp(rqpOptions);
                     if (serverResp?.Organization) {
                         //Запишем полученную информацию о контрагенте
                         boxIds.boxIds[i].Inn = serverResp?.Organization?.Inn;
@@ -719,7 +710,7 @@ const beforeDocLoad = async prms => {
         surl = `${surl}?${msgId}${prms.options.smsgid}&${entId}${prms.options.sentid}`;
         let obj;
         let rblMsg;
-        if (prms.queue.blMsg && prms.options.type != 5 && prms.options.type != 6) {
+        if (prms.queue.blMsg && (prms.options.type != 5) && (prms.options.type != 6)) {
             //Конвертируем XML из "Парус 8" в понятный "ДИАДОК" JSON
             obj = await toJSON(prms.queue.blMsg.toString());
             rblMsg = Buffer.from(JSON.stringify(obj));
@@ -768,7 +759,7 @@ const afterDocLoad = async prms => {
                         await new Promise(resolve => setTimeout(resolve, 2000));
                     }
                     //Выполним повторный запрос
-                    serverResp = await httpRequest(prms.options);
+                    serverResp = await rqp(prms.options);
                     //Сохраняем полученный ответ
                     prms.queue.blResp = Buffer.from(serverResp.body || "");
                     prms.optionsResp.statusCode = serverResp.statusCode;
@@ -863,9 +854,7 @@ const afterDepartmentIdGet = async prms => {
                 //Получим организацию не в роуминге (или единственную организацию в роуминге)
                 organization = getOrganizations(JSON.parse(prms.queue.blResp.toString()), optionsData.sNumEdo);
                 if (!organization) {
-                    throw Error(
-                        `Не удалось получить ящик для контрагента с ${optionsData.sNumEdo ? `кодом участника ЭДО: ${optionsData.sNumEdo}, ` : ""}ИНН: ${optionsData.nINN} и КПП: ${optionsData.nKPP}`
-                    );
+                    throw Error(`Не удалось получить ящик для контрагента с ${optionsData.sNumEdo ? `кодом участника ЭДО: ${optionsData.sNumEdo}, ` : ""}ИНН: ${optionsData.nINN} и КПП: ${optionsData.nKPP}`);
                 }
             } catch (e) {
                 //Получим ключ разработчика
@@ -874,7 +863,7 @@ const afterDepartmentIdGet = async prms => {
                 let sToken = prms.service.sCtx;
                 //Получим головную организацию по ИНН/КПП
                 organization = await getOrganization(prms.service.sSrvRoot, buildHeaders(sAPIClientId, sToken), optionsData.nINN, optionsData.nKPP);
-            }
+            };
             //Преобразуем JSON ответ сервиса "ДИАДОК" в XML, понятный "Парус 8"
             resu = toXML({ root: organization });
         } catch (e) {

modules/gar_utils/import.js

@@ -14,24 +14,6 @@ const { WRK_MSG_TYPE, logInf, logErr, makeTaskOKResult, makeTaskErrResult, makeS
 const { PARSERS, findModelByFileName } = require("./parsers"); //Модели и парсеры
 const sax = require("./node_modules/sax"); //Событийный XML-парсер
 
-//---------------------------
-// Инициализация Thick-режима
-//---------------------------
-
-//Инициализируем Thick-режим до любых подключений к БД
-try {
-    if (typeof oracledb.initOracleClient === "function" && !(process.env.NODE_ORACLE_DB_THIN_MODE === 1)) {
-        const libDir = process.env.ORACLE_CLIENT_LIB_DIR;
-        if (libDir) {
-            oracledb.initOracleClient({ libDir });
-        } else {
-            oracledb.initOracleClient();
-        }
-    }
-} catch (e) {
-    throw new Error(`Не удалось инициализировать Oracle Client (Thick-режим): ${makeErrorText(e)}`);
-}
-
 //--------------------------
 // Глобальные идентификаторы
 //--------------------------

modules/parus_oracle_db.js

@@ -8,25 +8,6 @@
 //----------------------
 
 const oracledb = require("oracledb"); //Работа с СУБД Oracle
-const { makeErrorText } = require("../core/utils"); //Вспомогательные функции
-
-//---------------------------
-// Инициализация Thick-режима
-//---------------------------
-
-//Инициализируем Thick-режим до любых подключений к БД
-try {
-    if (typeof oracledb.initOracleClient === "function" && !(process.env.NODE_ORACLE_DB_THIN_MODE === 1)) {
-        const libDir = process.env.ORACLE_CLIENT_LIB_DIR;
-        if (libDir) {
-            oracledb.initOracleClient({ libDir });
-        } else {
-            oracledb.initOracleClient();
-        }
-    }
-} catch (e) {
-    throw new Error(`Не удалось инициализировать Oracle Client (Thick-режим): ${makeErrorText(e)}`);
-}
 
 //--------------------------
 // Глобальные идентификаторы
@@ -392,6 +373,7 @@ const putQueue = async prms => {
         inPrms: {
             NEXSSERVICEFN: prms.nServiceFnId,
             BMSG: prms.blMsg,
+            NEXSSRV: prms.nExsSrv,
             NEXSQUEUE: prms.nQueueId,
             NLNK_COMPANY: prms.nLnkCompanyId,
             NLNK_DOCUMENT: prms.nLnkDocumentId,

modules/parus_pg_db.js

@@ -361,6 +361,7 @@ const putQueue = async prms => {
         inPrms: {
             NEXSSERVICEFN: prms.nServiceFnId,
             BMSG: prms.blMsg,
+            NEXSSRV: prms.nExsSrv,
             NEXSQUEUE: prms.nQueueId,
             NLNK_COMPANY: prms.nLnkCompanyId,
             NLNK_DOCUMENT: prms.nLnkDocumentId,

modules/pws.js

@@ -8,7 +8,7 @@
 //------------------------------
 
 const xml2js = require("xml2js"); //Конвертация XML в JSON и JSON в XML
-const { deepClone } = require("../core/utils"); //Вспомогательные функции
+const _ = require("lodash"); //Работа с коллекциями и объектами
 
 //---------------------
 // Глобальные константы
@@ -48,23 +48,24 @@ const converXMLArraysToJSON = (obj, arrayKey) => {
             let tmp = [];
             let itemKey = obj[key][arrayKey];
             if (obj[key][itemKey]) {
-                if (Array.isArray(obj[key][itemKey])) {
+                if (_.isArray(obj[key][itemKey])) {
                     for (let i = 0; i < obj[key][itemKey].length; i++) {
                         let buf = {};
-                        buf[itemKey] = deepClone(obj[key][itemKey][i]);
+                        buf[itemKey] = _.cloneDeep(obj[key][itemKey][i]);
                         tmp.push(buf);
                     }
                 } else {
                     let buf = {};
-                    buf[itemKey] = deepClone(obj[key][itemKey]);
+                    buf[itemKey] = _.cloneDeep(obj[key][itemKey]);
                     tmp.push(buf);
                 }
             }
             obj[key] = tmp;
             converXMLArraysToJSON(obj[key], arrayKey);
         } else {
-            if (typeof obj[key] === "object" && obj[key] !== null && !Array.isArray(obj[key])) converXMLArraysToJSON(obj[key], arrayKey);
-            if (Array.isArray(obj[key])) for (let i = 0; i < obj[key].length; i++) converXMLArraysToJSON(obj[key][i], arrayKey);
+            if (_.isObject(obj[key])) converXMLArraysToJSON(obj[key], arrayKey);
+            if (_.isArray(obj[key]))
+                for (let i = 0; i < obj[key].length; i++) converXMLArraysToJSON(obj[key][i], arrayKey);
         }
     }
 };
@@ -72,7 +73,10 @@ const converXMLArraysToJSON = (obj, arrayKey) => {
 //Обработчик "До" для полученного сообщения
 const before = async prms => {
     //Если пришел запрос в JSON
-    if (prms.options.headers["content-type"] && prms.options.headers["content-type"].startsWith(SHEADER_REQ_CONTENT_TYPE_JSON)) {
+    if (
+        prms.options.headers["content-type"] &&
+        prms.options.headers["content-type"].startsWith(SHEADER_REQ_CONTENT_TYPE_JSON)
+    ) {
         //Конвертируем полученный в JSON-запрос в XML, понятный серверной части
         let requestXML = "";
         try {
@@ -98,8 +102,11 @@ const after = async prms => {
             prms.options.qs[SQUERY_RESP_CT] &&
             prms.options.qs[SQUERY_RESP_CT].startsWith(SHEADER_REQ_CONTENT_TYPE_JSON)) ||
         (prms.function.sCode != SFNC_UPLOAD &&
-            ((prms.options.headers["content-type"] && prms.options.headers["content-type"].startsWith(SHEADER_REQ_CONTENT_TYPE_JSON)) ||
-                (prms.options.qs && prms.options.qs[SQUERY_RESP_CT] && prms.options.qs[SQUERY_RESP_CT].startsWith(SHEADER_REQ_CONTENT_TYPE_JSON))))
+            ((prms.options.headers["content-type"] &&
+                prms.options.headers["content-type"].startsWith(SHEADER_REQ_CONTENT_TYPE_JSON)) ||
+                (prms.options.qs &&
+                    prms.options.qs[SQUERY_RESP_CT] &&
+                    prms.options.qs[SQUERY_RESP_CT].startsWith(SHEADER_REQ_CONTENT_TYPE_JSON))))
     ) {
         //Буфер для конвертации
         let parseRes = "";

modules/sbis.js

@@ -8,7 +8,8 @@
 //------------------------------
 
 const xml2js = require("xml2js"); //Конвертация XML в JSON и JSON в XML
-const { httpRequest } = require("../core/http_client"); //Работа с HTTP/HTTPS запросами
+const _ = require("lodash"); //Работа с коллекциями и объектами
+const rqp = require("request-promise"); //Работа с HTTP/HTTPS запросами
 const { SMCHD_STORAGE_SYSTEM } = require("./sbis_config"); //Система хранения МЧД
 
 //---------------------
@@ -32,7 +33,7 @@ const tag = [
 // Список имен тегов для замены ([Старое значение], [Новое значение])
 const replaceTags = [
     ['"Иные получатели":', '"ИныеПолучатели":'],
-    ['"Создатель документа":', '"СоздательДокумента":']
+    ['"Создатель документа":', '"СоздательДокумента":'],
 ];
 
 //------------
@@ -40,9 +41,9 @@ const replaceTags = [
 //------------
 
 //Замена наименований тегов (для корректной работы toXML)
-const replaceTag = obj => {
+const replaceTag = (obj) => {
     for (let value of replaceTags) {
-        obj = obj.replace(new RegExp(value[0], "g"), value[1]);
+        obj = obj.replace(new RegExp(value[0], 'g'), value[1]);
     }
     return obj;
 };
@@ -51,7 +52,7 @@ const replaceTag = obj => {
 const toArray = (obj, tags) => {
     for (const prop in obj) {
         const value = obj[prop];
-        if (tags.indexOf(prop) != -1 && !Array.isArray(obj[prop])) {
+        if (tags.indexOf(prop) != -1 && !_.isArray(obj[prop])) {
             obj[prop] = JSON.parse("[" + JSON.stringify(value) + "]");
         }
         if (typeof value === "object") {
@@ -254,7 +255,7 @@ const afterAttParse = async prms => {
                 if (prms.optionsResp.statusCode != 200) {
                     //Выполним повторный запрос
                     await new Promise(resolve => setTimeout(resolve, 2000));
-                    let serverResp = await httpRequest(prms.options);
+                    let serverResp = await rqp(prms.options);
                     //Сохраняем полученный ответ
                     prms.queue.blResp = Buffer.from(serverResp.body || "");
                     prms.optionsResp.statusCode = serverResp.statusCode;

package.json

@@ -18,17 +18,24 @@
     },
     "homepage": "https://git.citpb.ru/CITKParus/P8-ExchangeService/",
     "dependencies": {
+        "body-parser": "^1.19.0",
         "cors": "^2.8.5",
-        "express": "^5.2.1",
+        "express": "^4.17.1",
         "kafkajs": "^2.2.4",
+        "lodash": "^4.17.19",
+        "module-alias": "^2.2.2",
         "mqtt": "^5.10.1",
-        "nodemailer": "^6.9.16",
-        "oracledb": "^6.6.0",
+        "nodemailer": "^6.4.11",
+        "oracledb": "^4.2.0",
         "pg": "^8.13.1",
+        "request": "^2.88.2",
+        "request-promise": "^4.2.6",
         "validate": "^5.1.0",
-        "xml2js": "^0.6.2"
+        "xml2js": "^0.4.23"
     },
-    "engines": {
-        "node": ">=22"
+    "_moduleAliases": {
+        "@core": "core",
+        "@modules": "modules",
+        "@models": "models"
     }
 }