diff --git a/core/db_connector.js b/core/db_connector.js index b41596c..9237f1c 100644 --- a/core/db_connector.js +++ b/core/db_connector.js @@ -19,11 +19,7 @@ const objServiceFunctionsSchema = require("../models/obj_service_functions"); // const objQueueSchema = require("../models/obj_queue"); //Схема валидации сообщения очереди обмена const objQueuesSchema = require("../models/obj_queues"); //Схема валидации списка сообщений очереди обмена const objLogSchema = require("../models/obj_log"); //Схема валидации записи журнала -const { - SERR_MODULES_BAD_INTERFACE, - SERR_OBJECT_BAD_INTERFACE, - SERR_MODULES_NO_MODULE_SPECIFIED -} = require("./constants"); //Глобальные константы +const { SERR_MODULES_BAD_INTERFACE, SERR_OBJECT_BAD_INTERFACE, SERR_MODULES_NO_MODULE_SPECIFIED } = require("./constants"); //Глобальные константы //---------- // Константы @@ -49,11 +45,7 @@ class DBConnector extends EventEmitter { //создадим экземпляр родительского класса super(); //Проверяем структуру переданного объекта для подключения - let sCheckResult = validateObject( - prms, - prmsDBConnectorSchema.DBConnector, - "Параметры конструктора класса DBConnector" - ); + let sCheckResult = validateObject(prms, prmsDBConnectorSchema.DBConnector, "Параметры конструктора класса DBConnector"); //Если структура объекта в норме if (!sCheckResult) { //Проверяем наличие модуля для работы с БД в настройках подключения @@ -82,10 +74,7 @@ class DBConnector extends EventEmitter { this.connection = null; this.bConnected = false; } else { - throw new ServerError( - SERR_MODULES_NO_MODULE_SPECIFIED, - "Не указано имя подключаемого модуля-коннектора!" - ); + throw new ServerError(SERR_MODULES_NO_MODULE_SPECIFIED, "Не указано имя подключаемого модуля-коннектора!"); } } else { throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult); @@ -175,11 +164,7 @@ class DBConnector extends EventEmitter { //Работаем только при наличии подключения if (this.bConnected) { //Проверяем структуру переданного объекта с параметрами для считывания функций сервиса - let sCheckResult = validateObject( - prms, - prmsDBConnectorSchema.getServiceFunctions, - "Параметры функции считывания функций сервиса" - ); + let sCheckResult = validateObject(prms, prmsDBConnectorSchema.getServiceFunctions, "Параметры функции считывания функций сервиса"); //Если структура объекта в норме if (!sCheckResult) { try { @@ -189,11 +174,7 @@ class DBConnector extends EventEmitter { //И выполним считывание функций сервиса let res = await this.connector.getServiceFunctions(getServiceFunctionsData); //Валидируем полученный ответ - sCheckResult = validateObject( - { functions: res }, - objServiceFunctionsSchema.ServiceFunctions, - "Список функций сервиса" - ); + sCheckResult = validateObject({ functions: res }, objServiceFunctionsSchema.ServiceFunctions, "Список функций сервиса"); if (sCheckResult) throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult); //Успешно - отдаём список функций сервиса return res; @@ -212,11 +193,7 @@ class DBConnector extends EventEmitter { //Работаем только при наличии подключения if (this.bConnected) { //Проверяем структуру переданного объекта с параметрами для получения контекста сервиса - let sCheckResult = validateObject( - prms, - prmsDBConnectorSchema.getServiceContext, - "Параметры функции считывания контекста сервиса" - ); + let sCheckResult = validateObject(prms, prmsDBConnectorSchema.getServiceContext, "Параметры функции считывания контекста сервиса"); //Если структура объекта в норме if (!sCheckResult) { try { @@ -245,11 +222,7 @@ class DBConnector extends EventEmitter { //Работаем только при наличии подключения if (this.bConnected) { //Проверяем структуру переданного объекта с параметрами для установки контекста сервиса - let sCheckResult = validateObject( - prms, - prmsDBConnectorSchema.setServiceContext, - "Параметры функции установки контекста сервиса" - ); + let sCheckResult = validateObject(prms, prmsDBConnectorSchema.setServiceContext, "Параметры функции установки контекста сервиса"); //Если структура объекта в норме if (!sCheckResult) { try { @@ -275,11 +248,7 @@ class DBConnector extends EventEmitter { //Работаем только при наличии подключения if (this.bConnected) { //Проверяем структуру переданного объекта с параметрами для очистки контекста сервиса - let sCheckResult = validateObject( - prms, - prmsDBConnectorSchema.clearServiceContext, - "Параметры функции очистки контекста сервиса" - ); + let sCheckResult = validateObject(prms, prmsDBConnectorSchema.clearServiceContext, "Параметры функции очистки контекста сервиса"); //Если структура объекта в норме if (!sCheckResult) { try { @@ -305,11 +274,7 @@ class DBConnector extends EventEmitter { //Работаем только при наличии подключения if (this.bConnected) { //Проверяем структуру переданного объекта с параметрами для проверки аутентифицированности сервиса - let sCheckResult = validateObject( - prms, - prmsDBConnectorSchema.isServiceAuth, - "Параметры функции проверки аутентифицированности сервиса" - ); + let sCheckResult = validateObject(prms, prmsDBConnectorSchema.isServiceAuth, "Параметры функции проверки аутентифицированности сервиса"); //Если структура объекта в норме if (!sCheckResult) { try { @@ -320,10 +285,7 @@ class DBConnector extends EventEmitter { let res = await this.connector.isServiceAuth(isServiceAuthData); //Валидируем результат if (![objServiceSchema.NIS_AUTH_NO, objServiceSchema.NIS_AUTH_YES].includes(res)) - throw new ServerError( - SERR_OBJECT_BAD_INTERFACE, - "Неожиданный ответ функции проверки аутентифицированности сервиса" - ); + throw new ServerError(SERR_OBJECT_BAD_INTERFACE, "Неожиданный ответ функции проверки аутентифицированности сервиса"); //Успешно - возвращаем то, что вернула функция проверки return res; } catch (e) { @@ -385,11 +347,7 @@ class DBConnector extends EventEmitter { //И выполним получение информации о просроченных сообщениях let res = await this.connector.getServiceExpiredQueueInfo(getServiceExpiredQueueInfoData); //Валидируем полученный ответ - sCheckResult = validateObject( - res, - objServiceSchema.ServiceExpiredQueueInfo, - "Сведения о просроченных сообщениях обмена сервиса" - ); + sCheckResult = validateObject(res, objServiceSchema.ServiceExpiredQueueInfo, "Сведения о просроченных сообщениях обмена сервиса"); if (sCheckResult) throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult); //Успешно - отдаём полученные сведения о просроченных сообщениях return res; @@ -408,11 +366,7 @@ class DBConnector extends EventEmitter { //Работаем только при наличии подключения if (this.bConnected) { //Проверяем структуру переданного объекта с параметрами для записи в журнал - let sCheckResult = validateObject( - prms, - prmsDBConnectorSchema.putLog, - "Параметры функции записи в журнал работы" - ); + let sCheckResult = validateObject(prms, prmsDBConnectorSchema.putLog, "Параметры функции записи в журнал работы"); //Если структура объекта в норме if (!sCheckResult) { try { @@ -488,11 +442,7 @@ class DBConnector extends EventEmitter { async getQueue(prms) { if (this.bConnected) { //Проверяем структуру переданных параметров - let sCheckResult = validateObject( - prms, - prmsDBConnectorSchema.getQueue, - "Параметры функции считывания записи очереди обмена" - ); + let sCheckResult = validateObject(prms, prmsDBConnectorSchema.getQueue, "Параметры функции считывания записи очереди обмена"); //Если структура объекта в норме if (!sCheckResult) { //Подготовим параметры @@ -521,11 +471,7 @@ class DBConnector extends EventEmitter { async putQueue(prms) { if (this.bConnected) { //Проверяем структуру переданных параметров - let sCheckResult = validateObject( - prms, - prmsDBConnectorSchema.putQueue, - "Параметры функции добавления позиции очереди" - ); + let sCheckResult = validateObject(prms, prmsDBConnectorSchema.putQueue, "Параметры функции добавления позиции очереди"); //Если структура объекта в норме if (!sCheckResult) { //Подготовим параметры @@ -555,11 +501,7 @@ class DBConnector extends EventEmitter { async getOutgoing(prms) { if (this.bConnected) { //Проверяем структуру переданного объекта с параметрами считывания очереди - let sCheckResult = validateObject( - prms, - prmsDBConnectorSchema.getOutgoing, - "Параметры функции считывания очереди" - ); + let sCheckResult = validateObject(prms, prmsDBConnectorSchema.getOutgoing, "Параметры функции считывания очереди"); //Если структура объекта в норме if (!sCheckResult) { try { @@ -569,11 +511,7 @@ class DBConnector extends EventEmitter { //Выполняем считывание из БД let res = await this.connector.getQueueOutgoing(getQueueOutgoingData); //Валидируем полученный ответ - sCheckResult = validateObject( - { queues: res }, - objQueuesSchema.Queues, - "Список сообщений очереди обмена" - ); + sCheckResult = validateObject({ queues: res }, objQueuesSchema.Queues, "Список сообщений очереди обмена"); if (sCheckResult) throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult); //Вернём сообщения очереди обмена return res; @@ -591,11 +529,7 @@ class DBConnector extends EventEmitter { async setQueueState(prms) { if (this.bConnected) { //Проверяем структуру переданных параметров - let sCheckResult = validateObject( - prms, - prmsDBConnectorSchema.setQueueState, - "Параметры функции установки состояния позиции очереди" - ); + let sCheckResult = validateObject(prms, prmsDBConnectorSchema.setQueueState, "Параметры функции установки состояния позиции очереди"); //Если структура объекта в норме if (!sCheckResult) { //Подготовим параметры @@ -738,11 +672,7 @@ class DBConnector extends EventEmitter { try { let res = await this.connector.getQueueResp(getQueueRespData); //Валидируем полученный ответ - sCheckResult = validateObject( - res, - objQueueSchema.QueueResp, - "Данные ответа сообщения очереди обмена" - ); + sCheckResult = validateObject(res, objQueueSchema.QueueResp, "Данные ответа сообщения очереди обмена"); if (sCheckResult) throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult); //Вернём данные ответа на сообщение return res; @@ -866,11 +796,7 @@ class DBConnector extends EventEmitter { //И выполним обработчик со стороны БД let res = await this.connector.execQueuePrc(execQueuePrcData); //Валидируем полученный ответ - sCheckResult = validateObject( - res, - objQueueSchema.QueuePrcResult, - "Результат обработки очереди обмена" - ); + sCheckResult = validateObject(res, objQueueSchema.QueuePrcResult, "Результат обработки очереди обмена"); if (sCheckResult) throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult); //Вернём результат обработки return res; diff --git a/models/intf_db_connector_module.js b/models/intf_db_connector_module.js index be39898..e2305e1 100644 --- a/models/intf_db_connector_module.js +++ b/models/intf_db_connector_module.js @@ -29,8 +29,7 @@ exports.dbConnectorModule = new Schema({ use: { validateAsyncFunctionType }, required: true, message: { - validateAsyncFunctionType: path => - `Функция подключения к БД (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, + validateAsyncFunctionType: path => `Функция подключения к БД (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, required: path => `Не реализована функция подключения к БД (${path})` } }, @@ -39,8 +38,7 @@ exports.dbConnectorModule = new Schema({ use: { validateAsyncFunctionType }, required: true, message: { - validateAsyncFunctionType: path => - `Функция отключения от БД (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, + validateAsyncFunctionType: path => `Функция отключения от БД (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, required: path => `Не реализована функция отключения от БД (${path})` } }, @@ -49,8 +47,7 @@ exports.dbConnectorModule = new Schema({ use: { validateAsyncFunctionType }, required: true, message: { - validateAsyncFunctionType: path => - `Функция получения списка сервисов (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, + validateAsyncFunctionType: path => `Функция получения списка сервисов (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, required: path => `Не реализована функция получения списка сервисов (${path})` } }, @@ -59,8 +56,7 @@ exports.dbConnectorModule = new Schema({ use: { validateAsyncFunctionType }, required: true, message: { - validateAsyncFunctionType: path => - `Функция получения списка функций сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, + validateAsyncFunctionType: path => `Функция получения списка функций сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, required: path => `Не реализована функция получения списка функций сервиса (${path})` } }, @@ -69,8 +65,7 @@ exports.dbConnectorModule = new Schema({ use: { validateAsyncFunctionType }, required: true, message: { - validateAsyncFunctionType: path => - `Функция получения контекста сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, + validateAsyncFunctionType: path => `Функция получения контекста сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, required: path => `Не реализована функция получения контекста сервиса (${path})` } }, @@ -79,8 +74,7 @@ exports.dbConnectorModule = new Schema({ use: { validateAsyncFunctionType }, required: true, message: { - validateAsyncFunctionType: path => - `Функция установки контекста сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, + validateAsyncFunctionType: path => `Функция установки контекста сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, required: path => `Не реализована функция установки контекста сервиса (${path})` } }, @@ -89,8 +83,7 @@ exports.dbConnectorModule = new Schema({ use: { validateAsyncFunctionType }, required: true, message: { - validateAsyncFunctionType: path => - `Функция очистки контекста сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, + validateAsyncFunctionType: path => `Функция очистки контекста сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, required: path => `Не реализована функция очистки контекста сервиса (${path})` } }, @@ -121,8 +114,7 @@ exports.dbConnectorModule = new Schema({ message: { validateAsyncFunctionType: path => `Функция получения информации о просроченных сообщениях обмена сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, - required: path => - `Не реализована функция получения информации о просроченных сообщениях обмена сервиса (${path})` + required: path => `Не реализована функция получения информации о просроченных сообщениях обмена сервиса (${path})` } }, //Протоколирование работы сервиса @@ -130,8 +122,7 @@ exports.dbConnectorModule = new Schema({ use: { validateAsyncFunctionType }, required: true, message: { - validateAsyncFunctionType: path => - `Функция протоколирования работы сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, + validateAsyncFunctionType: path => `Функция протоколирования работы сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, required: path => `Не реализована функция протоколирования работы сервиса (${path})` } }, @@ -140,8 +131,7 @@ exports.dbConnectorModule = new Schema({ use: { validateAsyncFunctionType }, required: true, message: { - validateAsyncFunctionType: path => - `Функция считывания записи очереди обмена (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, + validateAsyncFunctionType: path => `Функция считывания записи очереди обмена (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, required: path => `Не реализована функция считывания записи очереди обмена (${path})` } }, @@ -150,8 +140,7 @@ exports.dbConnectorModule = new Schema({ use: { validateAsyncFunctionType }, required: true, message: { - validateAsyncFunctionType: path => - `Функция добавления сообщения очереди (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, + validateAsyncFunctionType: path => `Функция добавления сообщения очереди (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, required: path => `Не реализована функция добавления сообщения очереди (${path})` } }, @@ -232,8 +221,7 @@ exports.dbConnectorModule = new Schema({ message: { validateAsyncFunctionType: path => `Функция установки параметров результата обработки сообщения очереди (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, - required: path => - `Не реализована функция установки параметров результата обработки сообщения очереди (${path})` + required: path => `Не реализована функция установки параметров результата обработки сообщения очереди (${path})` } }, //Исполнение обработчика со стороны БД для сообщения очереди @@ -243,8 +231,7 @@ exports.dbConnectorModule = new Schema({ message: { validateAsyncFunctionType: path => `Функция исполнения обработчика со стороны БД для сообщения очереди (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, - required: path => - `Не реализована функция исполнения обработчика со стороны БД для сообщения очереди (${path})` + required: path => `Не реализована функция исполнения обработчика со стороны БД для сообщения очереди (${path})` } } }); diff --git a/modules/parus_oracle_db.js b/modules/parus_oracle_db.js index f032aa3..02ec93e 100644 --- a/modules/parus_oracle_db.js +++ b/modules/parus_oracle_db.js @@ -93,7 +93,7 @@ const checkRelease = async prms => { } } } -} +}; //Подключение к БД const connect = async prms => {