[hooks] fix obj deepclone bug

Saint2078 · Nov 29, 2021 · 434dc75 · 434dc75
1 parent 134d3be
commit 434dc75
Showing 1 changed file with 26 additions and 10 deletions.
diff --git a/plugins/hooks/api/parts/triggers/incoming_data.js b/plugins/hooks/api/parts/triggers/incoming_data.js
@@ -68,19 +68,35 @@ class IncomingDataTrigger {
     register() {
         InternalEvents.forEach((e) => {
             plugins.register(e, (obj) => {
-                const ob = Object.assign({}, obj);
-                console.log(e, ob, "?##33333433");
-                if (e === '/plugins/drill') {
-                    const hooksData = {
-                        params: {...ob.params}
+                try {
+                    const ob = {
+                        params: {
+                            app_user: JSON.parse(JSON.stringify(obj.params.app_user)),
+                            app_id:  common.db.ObjectID(obj.params.app_id.toString()),
+                            req: {
+                                header: JSON.parse(JSON.stringify(obj.params.req.headers||{})),
+                            },
+                            ip_address: obj.params.ip_address,
+                            qstring: JSON.parse(JSON.stringify(obj.params.qstring || {})),
+                        },
+                        events: JSON.parse(JSON.stringify(obj.events || [])),
                     };
-                    if (ob.events) {
-                        hooksData.params.qstring.events = ob.events;
+                    log.d(e, ob, "[Incoming data capture]");
+                    if (e === '/plugins/drill') {
+                        const hooksData = {
+                            params: {...ob.params}
+                        };
+                        if (ob.events) {
+                            hooksData.params.qstring.events = ob.events;
+                        }
+                        this.process(e, hooksData);
+                        return;
                     }
-                    this.process(e, hooksData);
-                    return;
+                    this.process(e, ob);
+                } catch (err) {
+                    console.log(err);
                 }
-                this.process(e, ob);
+
             });
         });
     }