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-25 00:19:58 +03:00
parent 2a416b2440
commit db252fb95e
2 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
config.js
View File

@ -14,7 +14,7 @@ let dbConnect = {
//Пароль пользователя БД
sPassword: "parus",
//Строка подключения к БД
sConnectString: "DEMOP_CITKSERV",
sConnectString: "DEMOP_CITKSERV_WAN",
//Наименование модуля (для сессии БД)
sSessionModuleName: "PARUS$ExchangeServer",
//Подключаемый модуль обслуживания БД (низкоуровневые функции работы с СУБД)

14
test.js
View File

@ -8,6 +8,8 @@ const srvsModel = require("./models/obj_services"); //Модель данных
const srvModel = require("./models/obj_service"); //Модель данных сервиса
const srvFnModel = require("./models/obj_service_function"); //Модель данных функции сервиса
const srvFnSModel = require("./models/obj_service_functions"); //Модель данных функции сервиса
const queueModel = require("./models/obj_queue"); //Модель данных позиции очереди обмена
const queuesModel = require("./models/obj_queues"); //Модель данных списка позиций очереди обмена
const dbConnectorModel = require("./models/prms_db_connector"); //Описатели параметров функций модуля подключения к БД
const dbConnectorInterfaceModel = require("./models/intf_db_connector_module"); //Интерфейс модуля взаимодействия с БД
const utl = require("./core/utils"); //Вспомогательные функции
@ -34,19 +36,25 @@ const pDB = require("./modules/parus_oracle_db");
const getServices = async () => {
let d = new db.DBConnector(cfg.dbConnect);
await d.connect();
r = await d.getServices();
let r = await d.getServices();
let q = await d.getOutgoing({ nPortionSize: 1 });
await d.disconnect();
console.log(r);
console.log(q[0].bMsg instanceof Buffer);
let errs = utl.validateObject(r[1], srvModel.Service, "Сервис");
let errs2 = utl.validateObject({ functions: r[1].functions }, srvFnSModel.ServiceFunctions, "Функция сервиса");
let errs3 = utl.validateObject({ services: r }, srvsModel.Services, "Список сервисов");
console.log(r[1].functions[0]);
let errs4 = utl.validateObject(q[0], queueModel.Queue, "Позиция очереди обмена");
let errs5 = utl.validateObject({ queues: q }, queuesModel.Queues, "Очередь сообщений обмена");
if (errs2) console.log(errs2);
else console.log("Нет ошибок в функции сервиса");
if (errs) console.log(errs);
else console.log("Нет ошибок в сервисе");
if (errs3) console.log(errs3);
else console.log("Нет ошибок в списке сервисов");
if (errs4) console.log(errs4);
else console.log("Нет ошибок в сообщении обмена");
if (errs5) console.log(errs5);
else console.log("Нет ошибок в очереди сообщений обмена");
};
getServices();