config.js

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

core/app.js

@@ -118,6 +118,7 @@ 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,9 +30,8 @@ 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;
@@ -105,12 +104,10 @@ const deepClone = value => {
         });
         return obj;
     };
-    //Выполняем копирование рекурсивно с верхнего уровня
     try {
-        //Возвращаем что получилось
         return clone(value);
     } catch (e) {
-        //В случае непредвиденной ошибки формируем исключение
+        //В случае непредвиденной ошибки формируем информативное исключение
         const err = new Error("Ошибка глубокого копирования объекта");
         err.originalError = e;
         throw err;
@@ -410,33 +407,30 @@ const getNowString = () => {
 };
 
 //Глубокое слияние объектов
-const deepMerge = (...sources) => {
-    //Проверка на простой объект (не имеет специального поведения или прототипа)
+function deepMerge(...sources) {
     const isPlainObject = value => Object.prototype.toString.call(value) === "[object Object]";
-    //Клоникарование значения
-    const cloneValue = value => deepClone(value);
-    //Буфер для результата
+
+    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 deepCopyObject = obj => JSON.parse(JSON.stringify(obj));
@@ -515,31 +509,27 @@ 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,13 +23,7 @@ let appSrv = new app.ParusAppServer(); //Экземпляр сервера пр
 //----------------------------------------
 
 //Разрешение на TLS (Transport Layer Security) без авторизации
-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.env.NODE_TLS_REJECT_UNAUTHORIZED = cfg.outGoing.bValidateSSL === false ? "0" : "1";
 
 //Обработка события "выход" жизненного цикла процесса
 process.on("exit", code => {

models/obj_config.js

@@ -189,24 +189,6 @@ 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/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,10 +203,9 @@ const clearServer = async prms => {
 
 //Подключение к БД
 const connect = async prms => {
-    let pool = null;
     try {
         //Создаем пул подключения
-        pool = await oracledb.createPool({
+        let pool = await oracledb.createPool({
             user: prms.sUser,
             password: prms.sPassword,
             connectString: prms.sConnectString,
@@ -230,15 +229,8 @@ 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, NCTX_EXP } = require("./sbis_config"); //Параметры работы расширения
+const { SMCHD_STORAGE_SYSTEM, NCTX_EXP } = require("./sbis_config"); //Система хранения МЧД
 
 //---------------------
 // Глобальные константы