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

ЦИТК-521 - реализовать возможность управления статусом ответа при обработке входящих сообщений

Browse Source 
ЦИТК-519 - передавать URL входящего запроса JS обработчику и сохранять в OPTIONS
This commit is contained in:
Mikhail Chechnev 2022-09-09 22:42:55 +03:00
parent c1a839f725
commit ca7a634d6b
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
core/in_queue.js
View File

@ -117,7 +117,12 @@ class InQueue extends EventEmitter {
options = { options = {
method: prms.req.method, method: prms.req.method,
qs: _.cloneDeep(prms.req.query), qs: _.cloneDeep(prms.req.query),
headers: _.cloneDeep(prms.req.headers) headers: _.cloneDeep(prms.req.headers),
ip: prms.req.ip,
hostName: prms.req.hostname,
protocol: prms.req.protocol,
originalUrl: prms.req.originalUrl,
path: prms.req.path
}; };
//Кладём сообщение в очередь //Кладём сообщение в очередь
q = await this.dbConn.putQueue({ q = await this.dbConn.putQueue({
@ -305,7 +310,7 @@ class InQueue extends EventEmitter {
//Всё успешно - отдаём результат клиенту //Всё успешно - отдаём результат клиенту
if (bStopPropagation === false) { if (bStopPropagation === false) {
if (optionsResp.headers) prms.res.set(optionsResp.headers); if (optionsResp.headers) prms.res.set(optionsResp.headers);
prms.res.status(200).send(blResp); prms.res.status(optionsResp.statusCode || 200).send(blResp);
} }
//Фиксируем успех обработки - в статусе сообщения //Фиксируем успех обработки - в статусе сообщения
q = await this.dbConn.setQueueState({ q = await this.dbConn.setQueueState({