From db252fb95ede9f77c85affccd68e5eb964b0e27e Mon Sep 17 00:00:00 2001
From: Mikhail Chechnev <mim_@mail.ru>
Date: Sun, 25 Nov 2018 00:19:58 +0300
Subject: [PATCH] =?UTF-8?q?=D0=A2=D0=B5=D1=81=D1=82=D1=8B=20=D1=81=D1=85?=
 =?UTF-8?q?=D0=B5=D0=BC=20=D0=B2=D0=B0=D0=BB=D0=B8=D0=B4=D0=B0=D1=86=D0=B8?=
 =?UTF-8?q?=D0=B8=20=D0=BE=D1=87=D0=B5=D1=80=D0=B5=D0=B4=D0=B8=20=D0=B8=20?=
 =?UTF-8?q?=D1=81=D0=BE=D0=BE=D0=B1=D1=89=D0=B5=D0=BD=D0=B8=D0=B9=20=D0=BE?=
 =?UTF-8?q?=D1=87=D0=B5=D1=80=D0=B5=D0=B4=D0=B8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 config.js |  2 +-
 test.js   | 14 +++++++++++---
 2 files changed, 12 insertions(+), 4 deletions(-)

diff --git a/config.js b/config.js
index 49faa60..4b571ce 100644
--- a/config.js
+++ b/config.js
@@ -14,7 +14,7 @@ let dbConnect = {
     //Пароль пользователя БД
     sPassword: "parus",
     //Строка подключения к БД
-    sConnectString: "DEMOP_CITKSERV",
+    sConnectString: "DEMOP_CITKSERV_WAN",
     //Наименование модуля (для сессии БД)
     sSessionModuleName: "PARUS$ExchangeServer",
     //Подключаемый модуль обслуживания БД (низкоуровневые функции работы с СУБД)
diff --git a/test.js b/test.js
index 1eb551e..8a19f8d 100644
--- a/test.js
+++ b/test.js
@@ -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();