CITKParus/P8-ExchangeService
7
0
Fork 1
Code Issues Pull Requests Projects Releases Wiki Activity

Форматирование (ширина 150)

Browse Source
This commit is contained in:
Mikhail Chechnev 2024-11-13 14:32:08 +03:00
parent 8d3c7b965f
commit bfc937e443
3 changed files with 33 additions and 120 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

112
core/db_connector.js
View File

@ -19,11 +19,7 @@ const objServiceFunctionsSchema = require("../models/obj_service_functions"); //
const objQueueSchema = require("../models/obj_queue"); //Схема валидации сообщения очереди обмена const objQueueSchema = require("../models/obj_queue"); //Схема валидации сообщения очереди обмена
const objQueuesSchema = require("../models/obj_queues"); //Схема валидации списка сообщений очереди обмена const objQueuesSchema = require("../models/obj_queues"); //Схема валидации списка сообщений очереди обмена
const objLogSchema = require("../models/obj_log"); //Схема валидации записи журнала const objLogSchema = require("../models/obj_log"); //Схема валидации записи журнала
const { const { SERR_MODULES_BAD_INTERFACE, SERR_OBJECT_BAD_INTERFACE, SERR_MODULES_NO_MODULE_SPECIFIED } = require("./constants"); //Глобальные константы
SERR_MODULES_BAD_INTERFACE,
SERR_OBJECT_BAD_INTERFACE,
SERR_MODULES_NO_MODULE_SPECIFIED
} = require("./constants"); //Глобальные константы
//---------- //----------
// Константы // Константы
@ -49,11 +45,7 @@ class DBConnector extends EventEmitter {
//создадим экземпляр родительского класса //создадим экземпляр родительского класса
super(); super();
//Проверяем структуру переданного объекта для подключения //Проверяем структуру переданного объекта для подключения
let sCheckResult = validateObject( let sCheckResult = validateObject(prms, prmsDBConnectorSchema.DBConnector, "Параметры конструктора класса DBConnector");
prms,
prmsDBConnectorSchema.DBConnector,
"Параметры конструктора класса DBConnector"
);
//Если структура объекта в норме //Если структура объекта в норме
if (!sCheckResult) { if (!sCheckResult) {
//Проверяем наличие модуля для работы с БД в настройках подключения //Проверяем наличие модуля для работы с БД в настройках подключения
@ -82,10 +74,7 @@ class DBConnector extends EventEmitter {
this.connection = null; this.connection = null;
this.bConnected = false; this.bConnected = false;
} else { } else {
throw new ServerError( throw new ServerError(SERR_MODULES_NO_MODULE_SPECIFIED, "Не указано имя подключаемого модуля-коннектора!");
SERR_MODULES_NO_MODULE_SPECIFIED,
"Не указано имя подключаемого модуля-коннектора!"
);
} }
} else { } else {
throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult); throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult);
@ -175,11 +164,7 @@ class DBConnector extends EventEmitter {
//Работаем только при наличии подключения //Работаем только при наличии подключения
if (this.bConnected) { if (this.bConnected) {
//Проверяем структуру переданного объекта с параметрами для считывания функций сервиса //Проверяем структуру переданного объекта с параметрами для считывания функций сервиса
let sCheckResult = validateObject( let sCheckResult = validateObject(prms, prmsDBConnectorSchema.getServiceFunctions, "Параметры функции считывания функций сервиса");
prms,
prmsDBConnectorSchema.getServiceFunctions,
"Параметры функции считывания функций сервиса"
);
//Если структура объекта в норме //Если структура объекта в норме
if (!sCheckResult) { if (!sCheckResult) {
try { try {
@ -189,11 +174,7 @@ class DBConnector extends EventEmitter {
//И выполним считывание функций сервиса //И выполним считывание функций сервиса
let res = await this.connector.getServiceFunctions(getServiceFunctionsData); let res = await this.connector.getServiceFunctions(getServiceFunctionsData);
//Валидируем полученный ответ //Валидируем полученный ответ
sCheckResult = validateObject( sCheckResult = validateObject({ functions: res }, objServiceFunctionsSchema.ServiceFunctions, "Список функций сервиса");
{ functions: res },
objServiceFunctionsSchema.ServiceFunctions,
"Список функций сервиса"
);
if (sCheckResult) throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult); if (sCheckResult) throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult);
//Успешно - отдаём список функций сервиса //Успешно - отдаём список функций сервиса
return res; return res;
@ -212,11 +193,7 @@ class DBConnector extends EventEmitter {
//Работаем только при наличии подключения //Работаем только при наличии подключения
if (this.bConnected) { if (this.bConnected) {
//Проверяем структуру переданного объекта с параметрами для получения контекста сервиса //Проверяем структуру переданного объекта с параметрами для получения контекста сервиса
let sCheckResult = validateObject( let sCheckResult = validateObject(prms, prmsDBConnectorSchema.getServiceContext, "Параметры функции считывания контекста сервиса");
prms,
prmsDBConnectorSchema.getServiceContext,
"Параметры функции считывания контекста сервиса"
);
//Если структура объекта в норме //Если структура объекта в норме
if (!sCheckResult) { if (!sCheckResult) {
try { try {
@ -245,11 +222,7 @@ class DBConnector extends EventEmitter {
//Работаем только при наличии подключения //Работаем только при наличии подключения
if (this.bConnected) { if (this.bConnected) {
//Проверяем структуру переданного объекта с параметрами для установки контекста сервиса //Проверяем структуру переданного объекта с параметрами для установки контекста сервиса
let sCheckResult = validateObject( let sCheckResult = validateObject(prms, prmsDBConnectorSchema.setServiceContext, "Параметры функции установки контекста сервиса");
prms,
prmsDBConnectorSchema.setServiceContext,
"Параметры функции установки контекста сервиса"
);
//Если структура объекта в норме //Если структура объекта в норме
if (!sCheckResult) { if (!sCheckResult) {
try { try {
@ -275,11 +248,7 @@ class DBConnector extends EventEmitter {
//Работаем только при наличии подключения //Работаем только при наличии подключения
if (this.bConnected) { if (this.bConnected) {
//Проверяем структуру переданного объекта с параметрами для очистки контекста сервиса //Проверяем структуру переданного объекта с параметрами для очистки контекста сервиса
let sCheckResult = validateObject( let sCheckResult = validateObject(prms, prmsDBConnectorSchema.clearServiceContext, "Параметры функции очистки контекста сервиса");
prms,
prmsDBConnectorSchema.clearServiceContext,
"Параметры функции очистки контекста сервиса"
);
//Если структура объекта в норме //Если структура объекта в норме
if (!sCheckResult) { if (!sCheckResult) {
try { try {
@ -305,11 +274,7 @@ class DBConnector extends EventEmitter {
//Работаем только при наличии подключения //Работаем только при наличии подключения
if (this.bConnected) { if (this.bConnected) {
//Проверяем структуру переданного объекта с параметрами для проверки аутентифицированности сервиса //Проверяем структуру переданного объекта с параметрами для проверки аутентифицированности сервиса
let sCheckResult = validateObject( let sCheckResult = validateObject(prms, prmsDBConnectorSchema.isServiceAuth, "Параметры функции проверки аутентифицированности сервиса");
prms,
prmsDBConnectorSchema.isServiceAuth,
"Параметры функции проверки аутентифицированности сервиса"
);
//Если структура объекта в норме //Если структура объекта в норме
if (!sCheckResult) { if (!sCheckResult) {
try { try {
@ -320,10 +285,7 @@ class DBConnector extends EventEmitter {
let res = await this.connector.isServiceAuth(isServiceAuthData); let res = await this.connector.isServiceAuth(isServiceAuthData);
//Валидируем результат //Валидируем результат
if (![objServiceSchema.NIS_AUTH_NO, objServiceSchema.NIS_AUTH_YES].includes(res)) if (![objServiceSchema.NIS_AUTH_NO, objServiceSchema.NIS_AUTH_YES].includes(res))
throw new ServerError( throw new ServerError(SERR_OBJECT_BAD_INTERFACE, "Неожиданный ответ функции проверки аутентифицированности сервиса");
SERR_OBJECT_BAD_INTERFACE,
"Неожиданный ответ функции проверки аутентифицированности сервиса"
);
//Успешно - возвращаем то, что вернула функция проверки //Успешно - возвращаем то, что вернула функция проверки
return res; return res;
} catch (e) { } catch (e) {
@ -385,11 +347,7 @@ class DBConnector extends EventEmitter {
//И выполним получение информации о просроченных сообщениях //И выполним получение информации о просроченных сообщениях
let res = await this.connector.getServiceExpiredQueueInfo(getServiceExpiredQueueInfoData); let res = await this.connector.getServiceExpiredQueueInfo(getServiceExpiredQueueInfoData);
//Валидируем полученный ответ //Валидируем полученный ответ
sCheckResult = validateObject( sCheckResult = validateObject(res, objServiceSchema.ServiceExpiredQueueInfo, "Сведения о просроченных сообщениях обмена сервиса");
res,
objServiceSchema.ServiceExpiredQueueInfo,
"Сведения о просроченных сообщениях обмена сервиса"
);
if (sCheckResult) throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult); if (sCheckResult) throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult);
//Успешно - отдаём полученные сведения о просроченных сообщениях //Успешно - отдаём полученные сведения о просроченных сообщениях
return res; return res;
@ -408,11 +366,7 @@ class DBConnector extends EventEmitter {
//Работаем только при наличии подключения //Работаем только при наличии подключения
if (this.bConnected) { if (this.bConnected) {
//Проверяем структуру переданного объекта с параметрами для записи в журнал //Проверяем структуру переданного объекта с параметрами для записи в журнал
let sCheckResult = validateObject( let sCheckResult = validateObject(prms, prmsDBConnectorSchema.putLog, "Параметры функции записи в журнал работы");
prms,
prmsDBConnectorSchema.putLog,
"Параметры функции записи в журнал работы"
);
//Если структура объекта в норме //Если структура объекта в норме
if (!sCheckResult) { if (!sCheckResult) {
try { try {
@ -488,11 +442,7 @@ class DBConnector extends EventEmitter {
async getQueue(prms) { async getQueue(prms) {
if (this.bConnected) { if (this.bConnected) {
//Проверяем структуру переданных параметров //Проверяем структуру переданных параметров
let sCheckResult = validateObject( let sCheckResult = validateObject(prms, prmsDBConnectorSchema.getQueue, "Параметры функции считывания записи очереди обмена");
prms,
prmsDBConnectorSchema.getQueue,
"Параметры функции считывания записи очереди обмена"
);
//Если структура объекта в норме //Если структура объекта в норме
if (!sCheckResult) { if (!sCheckResult) {
//Подготовим параметры //Подготовим параметры
@ -521,11 +471,7 @@ class DBConnector extends EventEmitter {
async putQueue(prms) { async putQueue(prms) {
if (this.bConnected) { if (this.bConnected) {
//Проверяем структуру переданных параметров //Проверяем структуру переданных параметров
let sCheckResult = validateObject( let sCheckResult = validateObject(prms, prmsDBConnectorSchema.putQueue, "Параметры функции добавления позиции очереди");
prms,
prmsDBConnectorSchema.putQueue,
"Параметры функции добавления позиции очереди"
);
//Если структура объекта в норме //Если структура объекта в норме
if (!sCheckResult) { if (!sCheckResult) {
//Подготовим параметры //Подготовим параметры
@ -555,11 +501,7 @@ class DBConnector extends EventEmitter {
async getOutgoing(prms) { async getOutgoing(prms) {
if (this.bConnected) { if (this.bConnected) {
//Проверяем структуру переданного объекта с параметрами считывания очереди //Проверяем структуру переданного объекта с параметрами считывания очереди
let sCheckResult = validateObject( let sCheckResult = validateObject(prms, prmsDBConnectorSchema.getOutgoing, "Параметры функции считывания очереди");
prms,
prmsDBConnectorSchema.getOutgoing,
"Параметры функции считывания очереди"
);
//Если структура объекта в норме //Если структура объекта в норме
if (!sCheckResult) { if (!sCheckResult) {
try { try {
@ -569,11 +511,7 @@ class DBConnector extends EventEmitter {
//Выполняем считывание из БД //Выполняем считывание из БД
let res = await this.connector.getQueueOutgoing(getQueueOutgoingData); let res = await this.connector.getQueueOutgoing(getQueueOutgoingData);
//Валидируем полученный ответ //Валидируем полученный ответ
sCheckResult = validateObject( sCheckResult = validateObject({ queues: res }, objQueuesSchema.Queues, "Список сообщений очереди обмена");
{ queues: res },
objQueuesSchema.Queues,
"Список сообщений очереди обмена"
);
if (sCheckResult) throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult); if (sCheckResult) throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult);
//Вернём сообщения очереди обмена //Вернём сообщения очереди обмена
return res; return res;
@ -591,11 +529,7 @@ class DBConnector extends EventEmitter {
async setQueueState(prms) { async setQueueState(prms) {
if (this.bConnected) { if (this.bConnected) {
//Проверяем структуру переданных параметров //Проверяем структуру переданных параметров
let sCheckResult = validateObject( let sCheckResult = validateObject(prms, prmsDBConnectorSchema.setQueueState, "Параметры функции установки состояния позиции очереди");
prms,
prmsDBConnectorSchema.setQueueState,
"Параметры функции установки состояния позиции очереди"
);
//Если структура объекта в норме //Если структура объекта в норме
if (!sCheckResult) { if (!sCheckResult) {
//Подготовим параметры //Подготовим параметры
@ -738,11 +672,7 @@ class DBConnector extends EventEmitter {
try { try {
let res = await this.connector.getQueueResp(getQueueRespData); let res = await this.connector.getQueueResp(getQueueRespData);
//Валидируем полученный ответ //Валидируем полученный ответ
sCheckResult = validateObject( sCheckResult = validateObject(res, objQueueSchema.QueueResp, "Данные ответа сообщения очереди обмена");
res,
objQueueSchema.QueueResp,
"Данные ответа сообщения очереди обмена"
);
if (sCheckResult) throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult); if (sCheckResult) throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult);
//Вернём данные ответа на сообщение //Вернём данные ответа на сообщение
return res; return res;
@ -866,11 +796,7 @@ class DBConnector extends EventEmitter {
//И выполним обработчик со стороны БД //И выполним обработчик со стороны БД
let res = await this.connector.execQueuePrc(execQueuePrcData); let res = await this.connector.execQueuePrc(execQueuePrcData);
//Валидируем полученный ответ //Валидируем полученный ответ
sCheckResult = validateObject( sCheckResult = validateObject(res, objQueueSchema.QueuePrcResult, "Результат обработки очереди обмена");
res,
objQueueSchema.QueuePrcResult,
"Результат обработки очереди обмена"
);
if (sCheckResult) throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult); if (sCheckResult) throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult);
//Вернём результат обработки //Вернём результат обработки
return res; return res;

39
models/intf_db_connector_module.js
View File

@ -29,8 +29,7 @@ exports.dbConnectorModule = new Schema({
use: { validateAsyncFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateAsyncFunctionType: path => validateAsyncFunctionType: path => `Функция подключения к БД (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
`Функция подключения к БД (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
required: path => `Не реализована функция подключения к БД (${path})` required: path => `Не реализована функция подключения к БД (${path})`
} }
}, },
@ -39,8 +38,7 @@ exports.dbConnectorModule = new Schema({
use: { validateAsyncFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateAsyncFunctionType: path => validateAsyncFunctionType: path => `Функция отключения от БД (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
`Функция отключения от БД (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
required: path => `Не реализована функция отключения от БД (${path})` required: path => `Не реализована функция отключения от БД (${path})`
} }
}, },
@ -49,8 +47,7 @@ exports.dbConnectorModule = new Schema({
use: { validateAsyncFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateAsyncFunctionType: path => validateAsyncFunctionType: path => `Функция получения списка сервисов (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
`Функция получения списка сервисов (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
required: path => `Не реализована функция получения списка сервисов (${path})` required: path => `Не реализована функция получения списка сервисов (${path})`
} }
}, },
@ -59,8 +56,7 @@ exports.dbConnectorModule = new Schema({
use: { validateAsyncFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateAsyncFunctionType: path => validateAsyncFunctionType: path => `Функция получения списка функций сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
`Функция получения списка функций сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
required: path => `Не реализована функция получения списка функций сервиса (${path})` required: path => `Не реализована функция получения списка функций сервиса (${path})`
} }
}, },
@ -69,8 +65,7 @@ exports.dbConnectorModule = new Schema({
use: { validateAsyncFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateAsyncFunctionType: path => validateAsyncFunctionType: path => `Функция получения контекста сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
`Функция получения контекста сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
required: path => `Не реализована функция получения контекста сервиса (${path})` required: path => `Не реализована функция получения контекста сервиса (${path})`
} }
}, },
@ -79,8 +74,7 @@ exports.dbConnectorModule = new Schema({
use: { validateAsyncFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateAsyncFunctionType: path => validateAsyncFunctionType: path => `Функция установки контекста сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
`Функция установки контекста сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
required: path => `Не реализована функция установки контекста сервиса (${path})` required: path => `Не реализована функция установки контекста сервиса (${path})`
} }
}, },
@ -89,8 +83,7 @@ exports.dbConnectorModule = new Schema({
use: { validateAsyncFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateAsyncFunctionType: path => validateAsyncFunctionType: path => `Функция очистки контекста сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
`Функция очистки контекста сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
required: path => `Не реализована функция очистки контекста сервиса (${path})` required: path => `Не реализована функция очистки контекста сервиса (${path})`
} }
}, },
@ -121,8 +114,7 @@ exports.dbConnectorModule = new Schema({
message: { message: {
validateAsyncFunctionType: path => validateAsyncFunctionType: path =>
`Функция получения информации о просроченных сообщениях обмена сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, `Функция получения информации о просроченных сообщениях обмена сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
required: path => required: path => `Не реализована функция получения информации о просроченных сообщениях обмена сервиса (${path})`
`Не реализована функция получения информации о просроченных сообщениях обмена сервиса (${path})`
} }
}, },
//Протоколирование работы сервиса //Протоколирование работы сервиса
@ -130,8 +122,7 @@ exports.dbConnectorModule = new Schema({
use: { validateAsyncFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateAsyncFunctionType: path => validateAsyncFunctionType: path => `Функция протоколирования работы сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
`Функция протоколирования работы сервиса (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
required: path => `Не реализована функция протоколирования работы сервиса (${path})` required: path => `Не реализована функция протоколирования работы сервиса (${path})`
} }
}, },
@ -140,8 +131,7 @@ exports.dbConnectorModule = new Schema({
use: { validateAsyncFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateAsyncFunctionType: path => validateAsyncFunctionType: path => `Функция считывания записи очереди обмена (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
`Функция считывания записи очереди обмена (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
required: path => `Не реализована функция считывания записи очереди обмена (${path})` required: path => `Не реализована функция считывания записи очереди обмена (${path})`
} }
}, },
@ -150,8 +140,7 @@ exports.dbConnectorModule = new Schema({
use: { validateAsyncFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateAsyncFunctionType: path => validateAsyncFunctionType: path => `Функция добавления сообщения очереди (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
`Функция добавления сообщения очереди (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
required: path => `Не реализована функция добавления сообщения очереди (${path})` required: path => `Не реализована функция добавления сообщения очереди (${path})`
} }
}, },
@ -232,8 +221,7 @@ exports.dbConnectorModule = new Schema({
message: { message: {
validateAsyncFunctionType: path => validateAsyncFunctionType: path =>
`Функция установки параметров результата обработки сообщения очереди (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, `Функция установки параметров результата обработки сообщения очереди (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
required: path => required: path => `Не реализована функция установки параметров результата обработки сообщения очереди (${path})`
`Не реализована функция установки параметров результата обработки сообщения очереди (${path})`
} }
}, },
//Исполнение обработчика со стороны БД для сообщения очереди //Исполнение обработчика со стороны БД для сообщения очереди
@ -243,8 +231,7 @@ exports.dbConnectorModule = new Schema({
message: { message: {
validateAsyncFunctionType: path => validateAsyncFunctionType: path =>
`Функция исполнения обработчика со стороны БД для сообщения очереди (${path}) имеет неверный формат (ожидалось - AsyncFunction)`, `Функция исполнения обработчика со стороны БД для сообщения очереди (${path}) имеет неверный формат (ожидалось - AsyncFunction)`,
required: path => required: path => `Не реализована функция исполнения обработчика со стороны БД для сообщения очереди (${path})`
`Не реализована функция исполнения обработчика со стороны БД для сообщения очереди (${path})`
} }
} }
}); });

2
modules/parus_oracle_db.js
View File

@ -93,7 +93,7 @@ const checkRelease = async prms => {
} }
} }
} }
} };
//Подключение к БД //Подключение к БД
const connect = async prms => { const connect = async prms => {