From 108452284dbdce01e939167bf6f5d6b21071b48a Mon Sep 17 00:00:00 2001
From: Mikhail Chechnev <mim_@mail.ru>
Date: Sat, 15 Dec 2018 23:57:48 +0300
Subject: [PATCH] =?UTF-8?q?=D0=93=D0=BB=D1=83=D0=B1=D0=BE=D0=BA=D0=BE?=
 =?UTF-8?q?=D0=B5=20=D0=BA=D0=BE=D0=BF=D0=B8=D1=80=D0=BE=D0=B2=D0=B0=D0=BD?=
 =?UTF-8?q?=D0=B8=D0=B5=20=D0=BB=D0=BE=D0=BA=D0=B0=D0=BB=D1=8C=D0=BD=D0=BE?=
 =?UTF-8?q?=D0=B3=D0=BE=20=D0=BE=D0=B1=D1=8A=D0=B5=D0=BA=D1=82=D0=B0=20?=
 =?UTF-8?q?=D0=BF=D0=B0=D1=80=D0=B0=D0=BC=D0=B5=D1=82=D1=80=D0=BE=D0=B2=20?=
 =?UTF-8?q?=D0=BF=D0=B5=D1=80=D0=B5=D0=B4=20=D0=BF=D0=B5=D1=80=D0=B5=D0=B4?=
 =?UTF-8?q?=D0=B0=D1=87=D0=B5=D0=B9=20=D0=BF=D0=BE=D0=BB=D1=8C=D0=B7=D0=BE?=
 =?UTF-8?q?=D0=B2=D0=B0=D1=82=D0=B5=D0=BB=D1=8C=D1=81=D0=BA=D0=BE=D0=BC?=
 =?UTF-8?q?=D1=83=20=D0=BE=D0=B1=D1=80=D0=B0=D0=B1=D0=BE=D1=82=D1=87=D0=B8?=
 =?UTF-8?q?=D0=BA=D1=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 core/in_queue.js            | 18 ++++++++++--------
 core/out_queue_processor.js |  6 ++++--
 2 files changed, 14 insertions(+), 10 deletions(-)

diff --git a/core/in_queue.js b/core/in_queue.js
index ea34152..704240a 100644
--- a/core/in_queue.js
+++ b/core/in_queue.js
@@ -122,10 +122,11 @@ class InQueue extends EventEmitter {
                     const fnBefore = getAppSrvFunction(prms.function.sAppSrvBefore);
                     let resBefore = null;
                     try {
-                        prms.queue = q;
-                        prms.queue.blMsg = blMsg;
-                        prms.queue.blResp = blResp;
-                        resBefore = await fnBefore(prms);
+                        let resBeforePrms = _.cloneDeep(prms);
+                        resBeforePrms.queue = _.cloneDeep(q);
+                        resBeforePrms.queue.blMsg = blMsg;
+                        resBeforePrms.queue.blResp = blResp;
+                        resBefore = await fnBefore(resBeforePrms);
                     } catch (e) {
                         throw new ServerError(SERR_APP_SERVER_BEFORE, e.message);
                     }
@@ -193,10 +194,11 @@ class InQueue extends EventEmitter {
                     const fnAfter = getAppSrvFunction(prms.function.sAppSrvAfter);
                     let resAfter = null;
                     try {
-                        prms.queue = q;
-                        prms.queue.blMsg = blMsg;
-                        prms.queue.blResp = blResp;
-                        resAfter = await fnAfter(prms);
+                        let resAfterPrms = _.cloneDeep(prms);
+                        resAfterPrms.queue = _.cloneDeep(q);
+                        resAfterPrms.queue.blMsg = blMsg;
+                        resAfterPrms.queue.blResp = blResp;
+                        resAfter = await fnAfter(resAfterPrms);
                     } catch (e) {
                         throw new ServerError(SERR_APP_SERVER_AFTER, e.message);
                     }
diff --git a/core/out_queue_processor.js b/core/out_queue_processor.js
index 7ff4b21..a96450c 100644
--- a/core/out_queue_processor.js
+++ b/core/out_queue_processor.js
@@ -110,7 +110,8 @@ const appProcess = async prms => {
                 const fnBefore = getAppSrvFunction(prms.function.sAppSrvBefore);
                 let resBefore = null;
                 try {
-                    resBefore = await fnBefore(prms);
+                    let resBeforePrms = _.cloneDeep(prms);
+                    resBefore = await fnBefore(resBeforePrms);
                 } catch (e) {
                     throw new ServerError(SERR_APP_SERVER_BEFORE, e.message);
                 }
@@ -140,7 +141,8 @@ const appProcess = async prms => {
                 const fnAfter = getAppSrvFunction(prms.function.sAppSrvAfter);
                 let resAfter = null;
                 try {
-                    resAfter = await fnAfter(prms);
+                    let resAfterPrms = _.cloneDeep(prms);
+                    resAfter = await fnAfter(resAfterPrms);
                 } catch (e) {
                     throw new ServerError(SERR_APP_SERVER_AFTER, e.message);
                 }