diff --git a/test.js b/test.js index be524eb..366b47a 100644 --- a/test.js +++ b/test.js @@ -3,164 +3,29 @@ Песочница для тестов */ -//---------------------- -// Подключение библиотек -//---------------------- - require("module-alias/register"); -const cfg = require("./config.js"); -const { Logger } = require("./core/logger.js"); -const db = require("./core/db_connector.js"); -const { ServerError } = require("./core/server_errors.js"); -const utls = require("./core/utils.js"); +const srvModel = require("./models/service"); +const db = require("./core/db_connector.js"); //Взаимодействие с БД +const cfg = require("./config.js"); //Настройки сервера приложений -//------------ -// Тело модуля -//------------ +//const errors = srvModel.schema.validate({ nId: 123, sCode: "", nSrvType: "", sSrvType: "" }); +//errors.forEach(e => { +//console.log(e.message); +//}); -const tests = async () => { - let a = new db.DBConnector(cfg.dbConnect); - let l = new Logger(); - l.setDBConnector(a); - try { - //await l.warn("CONNECTING..."); - await a.connect(); - for (i = 0; i <= 1000; i++) await l.info(i); - //await l.info("CONNECTED!"); - //await l.warn("READING SERVICES..."); - //let srv = await a.getServices(); - //await l.info(srv); - console.log("1"); - await l.warn("DISCONNECTING..."); - console.log("2"); - await a.disconnect(); - console.log("3"); - await l.error("DISCONNECTED!"); - console.log("4"); - } catch (e) { - await l.error("DISCONNECTING ON ERROR: " + e.message + "..."); - await a.disconnect(); - await l.error("DISCONNECTED!"); - throw e; - } +const dbConn = new db.DBConnector(cfg.dbConnect); + +const test = async () => { + await dbConn.connect(); + let r = await dbConn.getOutgoing({ nPortionSize: 123 }); + console.log(r); + let rr = await dbConn.setQueueState({ + nQueueId: 94568140, + nExecState: 1, + sExecMsg: "Обработано сервером приложений" + }); + console.log(rr); + await dbConn.disconnect(); }; -tests() - .then(r => { - if (r) console.log(r); - else console.log("SUCCESS!!!"); - }) - .catch(e => { - if (e instanceof ServerError) { - console.log("ServerError ERROR: " + e.sMessage); - } else { - console.log("ERROR: " + e.message); - } - }); -/* -try { - let a = new db.DBConnector(cfg.dbConnect); - a.connect() - .then(res => { - console.log("CONNECTED"); - a.getOutgoing({ nPortionSize: cfg.outgoing.nPortionSize }) - .then(res => { - if (res.length > 0) { - res.map(r => { - console.log(r); - }); - } else { - console.log("NO MESSAGES IN QUEUE!!!"); - } - a.putLogErr() - .then(res => { - console.log(res); - setTimeout(() => { - a.disconnect() - .then(res => { - console.log("DISCONNECTED"); - }) - .catch(e => { - console.log(e.code + ": " + e.message); - }); - }, 10000); - }) - .catch(e => { - console.log(e.code + ": " + e.message); - setTimeout(() => { - a.disconnect() - .then(res => { - console.log("DISCONNECTED"); - }) - .catch(e => { - console.log(e.code + ": " + e.message); - }); - }, 10000); - }); - }) - .catch(e => { - console.log(e.code + ": " + e.message); - a.disconnect() - .then(res => { - console.log("DISCONNECTED"); - }) - .catch(e => { - console.log(e.code + ": " + e.message); - }); - }); - }) - .catch(e => { - console.log(e.code + ": " + e.message); - }); -} catch (e) { - console.log(e.code + ": " + e.message); -} - -/* - -const log = new Logger(); -log.error("Это ошибка"); -log.warn("Предупреждение это"); -log.info("Просто информация"); - - - -const test = async prms => { - return new Promise((resolve, reject) => { - if (prms == 0) { - reject(new ServerError(1234, "Ошибка!")); - } else { - setTimeout(() => { - resolve(prms + 1); - }, 1000); - } - }); -}; - -const callTest = async prms => { - try { - console.log("in async before"); - let a = await test(prms); - console.log("in async after " + a); - return a; - } catch (e) { - console.log("in async I'm here: " + e.code + " - " + e.message); - throw e; - } -}; - -process.on("unhandledRejection", err => { - console.error("PROCESS ERROR: " + err.code + " - " + err.message); - process.exit(0); -}); - -console.log("BEFORE"); -callTest(0) - .then(result => { - console.log("MAIN RESULT: " + result); - }) - .catch(err => { - console.error("MAIN ERROR: " + err.code + " - " + err.message); - }); -console.log("AFTER"); -*/ +test();