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

Выставляем тело сообщения с учётом данных, подготовленных предобработчиком (для POST - в тело, для GET - в запрос URL)

Browse Source
This commit is contained in:
Mikhail Chechnev 2018-12-29 20:07:03 +03:00
parent cb95f45913
commit cb6345f5c7
1 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
core/out_queue_processor.js
View File

@ -146,6 +146,15 @@ const appProcess = async prms => {
nQueueId: prms.queue.nId, nQueueId: prms.queue.nId,
blMsg: prms.queue.blMsg blMsg: prms.queue.blMsg
}); });
if (prms.service.sFnPrmsType == objServiceFnSchema.NFN_PRMS_TYPE_POST) {
options.body = prms.queue.blMsg;
} else {
options.url = buildURL({
sSrvRoot: prms.service.sSrvRoot,
sFnURL: prms.function.sFnURL,
sQuery: prms.queue.blMsg.toString()
});
}
} }
if (!_.isUndefined(resBefore.context)) prms.service.context = _.cloneDeep(resBefore.context); if (!_.isUndefined(resBefore.context)) prms.service.context = _.cloneDeep(resBefore.context);
} else { } else {
@ -156,7 +165,12 @@ const appProcess = async prms => {
} }
//Отправляем сообщение удалённому серверу //Отправляем сообщение удалённому серверу
let serverResp = await rqp(options); let serverResp = await rqp(options);
//Сохраняем полученный ответ
_.extend(prms, { serverResp }); _.extend(prms, { serverResp });
await dbConn.setQueueResp({
nQueueId: prms.queue.nId,
blResp: new Buffer(prms.serverResp)
});
//Выполняем обработчик "После" (если он есть) //Выполняем обработчик "После" (если он есть)
if (prms.function.sAppSrvAfter) { if (prms.function.sAppSrvAfter) {
const fnAfter = getAppSrvFunction(prms.function.sAppSrvAfter); const fnAfter = getAppSrvFunction(prms.function.sAppSrvAfter);
@ -167,7 +181,7 @@ const appProcess = async prms => {
} catch (e) { } catch (e) {
throw new ServerError(SERR_APP_SERVER_AFTER, e.message); throw new ServerError(SERR_APP_SERVER_AFTER, e.message);
} }
//Проверяем структуру ответа функции предобработки //Проверяем структуру ответа функции постобработки
if (resAfter) { if (resAfter) {
let sCheckResult = validateObject( let sCheckResult = validateObject(
resAfter, resAfter,