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-20 21:58:11 +03:00
parent 229dc60517
commit 3855aad2c9
1 changed files with 21 additions and 156 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

171
test.js
View File

@ -3,164 +3,29 @@
Песочница для тестов Песочница для тестов
*/ */
//----------------------
// Подключение библиотек
//----------------------
require("module-alias/register"); require("module-alias/register");
const cfg = require("./config.js"); const srvModel = require("./models/service");
const { Logger } = require("./core/logger.js"); const db = require("./core/db_connector.js"); //Взаимодействие с БД
const db = require("./core/db_connector.js"); const cfg = require("./config.js"); //Настройки сервера приложений
const { ServerError } = require("./core/server_errors.js");
const utls = require("./core/utils.js");
//------------ //const errors = srvModel.schema.validate({ nId: 123, sCode: "", nSrvType: "", sSrvType: "" });
// Тело модуля //errors.forEach(e => {
//------------ //console.log(e.message);
//});
const tests = async () => { const dbConn = new db.DBConnector(cfg.dbConnect);
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;
}
};
tests() const test = async () => {
.then(r => { await dbConn.connect();
if (r) console.log(r); let r = await dbConn.getOutgoing({ nPortionSize: 123 });
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); console.log(r);
let rr = await dbConn.setQueueState({
nQueueId: 94568140,
nExecState: 1,
sExecMsg: "Обработано сервером приложений"
}); });
} else { console.log(rr);
console.log("NO MESSAGES IN QUEUE!!!"); await dbConn.disconnect();
}
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 => { test();
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");
*/