ЦИТК-790: Косметика в комментах

Reviewed-on: CITKParus/P8-ExchangeService#17

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: "2026.02.10",
+    sRelease: "2026.02.12",
     //Таймаут останова сервера (мс)
     nTerminateTimeout: 60000,
     //Контролировать версию Системы
@@ -44,7 +34,11 @@ let dbConnect = {
     //Наименование сервера приложений в сессии БД
     sSessionAppName: "PARUS$ExchangeServer",
     //Подключаемый модуль обслуживания БД (низкоуровневые функции работы с СУБД)
-    sConnectorModule: "parus_oracle_db.js"
+    sConnectorModule: "parus_oracle_db.js",
+    //Применение "тонкого" (Thin) или "толстого" (Thick) режима подключения (false - Thick-режим - работа через установленного клиента СУБД Oracle, true - Thin-режим - не требует установки клиента СУБД Oracle, допустим только для Oracle >= 12.1)
+    bOraUseThinMode: false,
+    //Путь к домашней директории Oracle Client (только для Thick-режима подключения к СУБД Oracle, если значение не указано, то будет использоваться значение из переменной окружения "PATH" ОС)
+    sOraClient: ""
 };
 
 //Параметры обработки очереди исходящих сообщений

core/app.js

@@ -118,7 +118,6 @@ class ParusAppServer {
         await this.logger.info(
             `Обработчик очереди входящих сообщений запущен (порт - ${nPort}, доступные IP - ${sHost === "0.0.0.0" ? getIPs().join("; ") : sHost})`
         );
-        //Запускаем
         //Запускаем модуль отправки уведомлений
         await this.logger.info("Запуск модуля отправки уведомлений...");
         try {

core/utils.js

@@ -30,8 +30,9 @@ 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;
@@ -104,10 +105,12 @@ const deepClone = value => {
         });
         return obj;
     };
+    //Выполняем копирование рекурсивно с верхнего уровня
     try {
+        //Возвращаем что получилось
         return clone(value);
     } catch (e) {
-        //В случае непредвиденной ошибки формируем информативное исключение
+        //В случае непредвиденной ошибки формируем исключение
         const err = new Error("Ошибка глубокого копирования объекта");
         err.originalError = e;
         throw err;
@@ -407,30 +410,33 @@ const getNowString = () => {
 };
 
 //Глубокое слияние объектов
-function deepMerge(...sources) {
+const deepMerge = (...sources) => {
+    //Проверка на простой объект (не имеет специального поведения или прототипа)
     const isPlainObject = value => Object.prototype.toString.call(value) === "[object Object]";
-
+    //Клоникарование значения
-    const cloneValue = value => {
+    const cloneValue = value => deepClone(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 deepCopyObject = obj => JSON.parse(JSON.stringify(obj));
@@ -509,27 +515,31 @@ const getURLProtocol = sURL => {
 
 //Обёртывание промиса в таймаут исполнения
 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;
-
+    //Буфер для идентификатора таймера
     let timeoutPid;
-
+    //Создаём промис с взведенным таумером на у казанный таймаут, промис будет "отклонён" по истечении таймера, но перед этим контроллер прерывания выдаст "сигнал" на отмену осинхронного процесса
     const timeoutPromise = new Promise((_, reject) => {
         timeoutPid = setTimeout(() => {
             controller.abort(timeoutError);
             reject(timeoutError);
         }, timeout);
     });
-
+    //Создаём промис с функцией-исполнителем асинхронного процесса
     const taskPromise = Promise.resolve(executor(controller.signal));
-
+    //Запускаем оба промиса в режиме "гонка" - кто "быстрее" исполнится
     return Promise.race([taskPromise, timeoutPromise]).finally(() => {
+        //В любом случае не забываем зачистить взведённый таймер
         if (timeoutPid) clearTimeout(timeoutPid);
     });
 };

index.js

@@ -23,7 +23,13 @@ let appSrv = new app.ParusAppServer(); //Экземпляр сервера пр
 //----------------------------------------
 
 //Разрешение на TLS (Transport Layer Security) без авторизации
-process.env.NODE_TLS_REJECT_UNAUTHORIZED = cfg.outGoing.bValidateSSL === false ? "0" : "1";
+process.env.NODE_TLS_REJECT_UNAUTHORIZED = cfg?.outGoing?.bValidateSSL === false ? "0" : "1";
+
+//Включение "Токого режима" для Oracle
+process.env.NODE_ORACLE_DB_THIN_MODE = cfg?.dbConnect?.bOraUseThinMode === true ? "1" : "0";
+
+//Путь к клиентским библиотекам для Oracle
+process.env.ORACLE_CLIENT_LIB_DIR = cfg?.dbConnect?.sOraClient || "";
 
 //Обработка события "выход" жизненного цикла процесса
 process.on("exit", code => {

models/obj_config.js

@@ -189,6 +189,24 @@ const dbConnect = new Schema({
             type: path => `Наименование подключаемого модуля обслуживания БД (${path}) имеет некорректный тип данных (ожидалось - String)`,
             required: path => `Не указано наименование подключаемого модуля обслуживания БД (${path})`
         }
+    },
+    //Признак применения "тонкого" (Thin) или "толстого" (Thick) режима подключения к БД
+    bOraUseThinMode: {
+        type: Boolean,
+        required: true,
+        message: {
+            type: path => `Признак режима подключения (Thin/Thick) к БД (${path}) имеет некорректный тип данных (ожидалось - Boolean)`,
+            required: path => `Не указан признак режима подключения (Thin/Thick) к БД (${path})`
+        }
+    },
+    //Путь к домашней директории Oracle Client
+    sOraClient: {
+        type: String,
+        required: false,
+        message: {
+            type: path => `Путь к домашней директории Oracle Client (${path}) имеет некорректный тип данных (ожидалось - String)`,
+            required: path => `Не указан путь к домашней директории Oracle Client (${path})`
+        }
     }
 });
 

modules/diadoc.js

@@ -533,6 +533,10 @@ const beforeEvent = async prms => {
             if (prms.options.sdepartment_name && sDepartmentId) {
                 surl = `${surl}&departmentId=${sDepartmentId}`;
             }
+            //Заполним максимальное количество возвращаемых элементов
+            if (prms.options.limit) {
+                surl = `${surl}&limit=${prms.options.limit}`;
+            }
         } else {
             if (prms.queue.blMsg) {
                 //Конвертируем XML из "Парус 8" в понятный "ДИАДОК" JSON

modules/gar_utils/import.js

@@ -20,7 +20,7 @@ const sax = require("./node_modules/sax"); //Событийный XML-парсе
 
 //Инициализируем Thick-режим до любых подключений к БД
 try {
-    if (typeof oracledb.initOracleClient === "function" && !(process.env.NODE_ORACLE_DB_THIN_MODE === 1)) {
+    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 });

modules/parus_oracle_db.js

@@ -16,7 +16,7 @@ const { makeErrorText } = require("../core/utils"); //Вспомогательн
 
 //Инициализируем Thick-режим до любых подключений к БД
 try {
-    if (typeof oracledb.initOracleClient === "function" && !(process.env.NODE_ORACLE_DB_THIN_MODE === 1)) {
+    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 });
@@ -203,9 +203,10 @@ const clearServer = async prms => {
 
 //Подключение к БД
 const connect = async prms => {
+    let pool = null;
     try {
         //Создаем пул подключения
-        let pool = await oracledb.createPool({
+        pool = await oracledb.createPool({
             user: prms.sUser,
             password: prms.sPassword,
             connectString: prms.sConnectString,
@@ -229,8 +230,15 @@ const connect = async prms => {
                     });
             }
         });
+        //Проверяем доступность пула
+        let tstConn = await pool.getConnection();
+        await tstConn.close();
+        //Всё ок - возвращяем его
         return pool;
     } catch (e) {
+        //Закрываем пул, если успели открыть
+        if (pool) pool.close(NPOOL_DRAIN_TIME);
+        //Возвращаем ошибку
         throw new Error(e.message);
     }
 };

modules/sbis.js

@@ -9,7 +9,7 @@
 
 const xml2js = require("xml2js"); //Конвертация XML в JSON и JSON в XML
 const { httpRequest } = require("../core/http_client"); //Работа с HTTP/HTTPS запросами
-const { SMCHD_STORAGE_SYSTEM } = require("./sbis_config"); //Система хранения МЧД
+const { SMCHD_STORAGE_SYSTEM, NCTX_EXP } = require("./sbis_config"); //Параметры работы расширения
 
 //---------------------
 // Глобальные константы
@@ -138,7 +138,7 @@ const afterConnect = async prms => {
         return {
             blResp: Buffer.from(resp.result),
             sCtx: resp.result,
-            dCtxExp: addHours(new Date(), 23)
+            dCtxExp: addHours(new Date(), NCTX_EXP)
         };
     } else {
         throw new Error(`Сервер ЭДО "СБИС" вернул ошибку: ${resp.error.message ? resp.error.message : "Неожиданная ошибка"}`);

modules/sbis_config.js

@@ -9,3 +9,6 @@
 
 //Система хранения МЧД
 exports.SMCHD_STORAGE_SYSTEM = "https://m4d.nalog.gov.ru/EMCHD/check-status";
+
+//Время жизни токена аутентификации (в часах)
+exports.NCTX_EXP = 20;