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

Обработка входящих - передача "notifier" и "dbConn" в постобработчик, передача "notifier" в предобработчик

Browse Source
This commit is contained in:
Mikhail Chechnev 2020-10-27 00:39:23 +03:00
parent 7ef582e872
commit 329d168215
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
core/in_queue.js
View File

@ -157,6 +157,7 @@ class InQueue extends EventEmitter {
resBeforePrms.queue.blResp = blResp; resBeforePrms.queue.blResp = blResp;
resBeforePrms.options = _.cloneDeep(options); resBeforePrms.options = _.cloneDeep(options);
resBeforePrms.dbConn = this.dbConn; resBeforePrms.dbConn = this.dbConn;
resBeforePrms.notifier = this.notifier;
resBeforePrms.res = prms.res; resBeforePrms.res = prms.res;
resBefore = await fnBefore(resBeforePrms); resBefore = await fnBefore(resBeforePrms);
} catch (e) { } catch (e) {
@ -267,6 +268,8 @@ class InQueue extends EventEmitter {
resAfterPrms.queue.blResp = blResp; resAfterPrms.queue.blResp = blResp;
resAfterPrms.options = _.cloneDeep(options); resAfterPrms.options = _.cloneDeep(options);
resAfterPrms.optionsResp = _.cloneDeep(optionsResp); resAfterPrms.optionsResp = _.cloneDeep(optionsResp);
resAfterPrms.dbConn = this.dbConn;
resAfterPrms.notifier = this.notifier;
resAfter = await fnAfter(resAfterPrms); resAfter = await fnAfter(resAfterPrms);
} catch (e) { } catch (e) {
throw new ServerError(SERR_APP_SERVER_AFTER, e.message); throw new ServerError(SERR_APP_SERVER_AFTER, e.message);