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

Корректировка сообщений об ошибках валидации в конструкторе и инициализация атрибута для пользовательского модуля взаимодействия с БД

Browse Source
This commit is contained in:
Mikhail Chechnev 2018-11-27 17:13:32 +03:00
parent b36a6ceaa2
commit 03d55b4fb5
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
core/db_connector.js
View File

@ -12,7 +12,7 @@ const EventEmitter = require("events"); //Обработчик пользова
const glConst = require("../core/constants"); //Глобальные константы const glConst = require("../core/constants"); //Глобальные константы
const { ServerError } = require("../core/server_errors"); //Типовая ошибка const { ServerError } = require("../core/server_errors"); //Типовая ошибка
const { makeModuleFullPath, validateObject } = require("../core/utils"); //Вспомогательные функции const { makeModuleFullPath, validateObject } = require("../core/utils"); //Вспомогательные функции
const prmsDBConnectorSchema = require("../models/prms_db_connector"); //Схемы валидации параметров процедур модуля const prmsDBConnectorSchema = require("../models/prms_db_connector"); //Схемы валидации параметров функций модуля
const intfDBConnectorModuleSchema = require("../models/intf_db_connector_module"); //Схема валидации интерфейса модуля взаимодействия с БД const intfDBConnectorModuleSchema = require("../models/intf_db_connector_module"); //Схема валидации интерфейса модуля взаимодействия с БД
const objServicesSchema = require("../models/obj_services"); //Схема валидации списка сервисов const objServicesSchema = require("../models/obj_services"); //Схема валидации списка сервисов
const objQueueSchema = require("../models/obj_queue"); //Схема валидации сообщения очереди обмена const objQueueSchema = require("../models/obj_queue"); //Схема валидации сообщения очереди обмена
@ -43,7 +43,11 @@ class DBConnector extends EventEmitter {
//создадим экземпляр родительского класса //создадим экземпляр родительского класса
super(); super();
//Проверяем структуру переданного объекта для подключения //Проверяем структуру переданного объекта для подключения
let sCheckResult = validateObject(prms, prmsDBConnectorSchema.DBConnector, "Параметры конструктора"); let sCheckResult = validateObject(
prms,
prmsDBConnectorSchema.DBConnector,
"Параметры конструктора класса DBConnector"
);
//Если структура объекта в норме //Если структура объекта в норме
if (!sCheckResult) { if (!sCheckResult) {
//Проверяем наличие модуля для работы с БД в настройках подключения //Проверяем наличие модуля для работы с БД в настройках подключения
@ -62,7 +66,7 @@ class DBConnector extends EventEmitter {
//Всё успешно - сохраним настройки подключения //Всё успешно - сохраним настройки подключения
this.connectSettings = _.cloneDeep(prms); this.connectSettings = _.cloneDeep(prms);
//Инициализируем остальные свойства //Инициализируем остальные свойства
this.connection = {}; this.connection = null;
this.bConnected = false; this.bConnected = false;
} else { } else {
throw new ServerError( throw new ServerError(
@ -100,7 +104,7 @@ class DBConnector extends EventEmitter {
//Отключаемся //Отключаемся
await this.connector.disconnect({ connection: this.connection }); await this.connector.disconnect({ connection: this.connection });
//Забываем подключение и удаляем флаги подключенности //Забываем подключение и удаляем флаги подключенности
this.connection = {}; this.connection = null;
this.bConnected = false; this.bConnected = false;
//Расскажем всем, что отключились //Расскажем всем, что отключились
this.emit(SEVT_DB_CONNECTOR_DISCONNECTED); this.emit(SEVT_DB_CONNECTOR_DISCONNECTED);