From 27e1355a8c4c7e7132fb075def8874c76a1693be Mon Sep 17 00:00:00 2001
From: youkunhuang <youkunhuang@tencent.com>
Date: Tue, 29 May 2018 17:38:58 +0800
Subject: [PATCH] chore(logger): unhandledRejection run with domain

---
 bin/proxy/master.js | 85 ++++++++++++---------------------------------
 1 file changed, 22 insertions(+), 63 deletions(-)

diff --git a/bin/proxy/master.js b/bin/proxy/master.js
index 080ce627..a227fc92 100644
--- a/bin/proxy/master.js
+++ b/bin/proxy/master.js
@@ -22,6 +22,8 @@ const isDeaded = false;
 
 // 阻止进程因异常而退出
 process.on('uncaughtException', function(e) {
+
+    // Mac和linux权限不足时给予提醒
     if (/\blisten EACCES\b/.test(e.message) && config.httpPort < 1024 && (serverOS.isOSX || serverOS.isLinux)) {
         logger.error('This is OSX/Linux, you may need to use "sudo" prefix to start server.\n');
     }
@@ -33,17 +35,10 @@ process.on('uncaughtException', function(e) {
 process.on('warning', function(warning) {
     const key = String(warning);
     const errStr = warning && warning.stack || String(warning);
+    const Content = `<p><strong>错误堆栈</strong></p><p><pre><code>${errStr}</code></pre></p>`;
 
     logger.error(errStr);
 
-    const Content = [
-        '<p><strong>错误堆栈</strong></p>',
-        '<p><pre><code>',
-        errStr,
-        '</code></pre></p>',
-    ].join('');
-
-
     setImmediate(function() {
         require('util/mail/mail.js').SendMail(key, 'js', 600, {
             'Title': key,
@@ -51,65 +46,29 @@ process.on('warning', function(warning) {
             'Content': Content
         });
     });
-
 });
 
 
-process.on('unhandledRejection', (reason = {}, p = {}) => {
-    let errStr = String(reason.stack),
-        mod_act,
-        module,
-        REQUEST;
-
-    const key = String(reason.message);
-
-    if (p && p.domain && p.domain.currentContext) {
-        mod_act = p.domain.currentContext.mod_act;
-        module = p.domain.currentContext.module;
-        REQUEST = p.domain.currentContext.window.request.REQUEST;
-    }
-
-    if (errStr === 'undefined') {
-
-        const reasonStr = JSON.stringify(reason);
-
-        logger.error('unhandledRejection reason: ' + reasonStr);
-
-        if (reasonStr === '{}') {
-            return;
-        }
-
-        errStr = reasonStr;
-    }
-
-    logger.error(errStr);
-
-    let Content = [
-        '<p><strong>错误堆栈</strong></p>',
-        '<p><pre><code>',
-        errStr,
-        '</code></pre></p>',
-    ].join('');
-
-    if (mod_act) {
-        Content += `<p><strong>mod_act： </strong>${mod_act}</p>`;
-    }
-    if (module) {
-        Content += `<p><strong>module： </strong>${module}</p>`;
-    }
-    if (REQUEST) {
-        Content += `<p><strong>url： </strong>${REQUEST.protocol}://${REQUEST.hostname}${REQUEST.href}</p>`;
-    }
-
-    if (serverOS.isWindows) {
-        // return;
+process.on('unhandledRejection', (errorOrReason, currPromise) => {
+    const errStr = String(errorOrReason && errorOrReason.stack || JSON.stringify(errorOrReason));
+    const key = String(errorOrReason && errorOrReason.message);
+    const Content = `<p><strong>错误堆栈</strong></p><p><pre><code>${errStr}</code></pre></p>`;
+
+    // 恢复上下文
+    if (currPromise && currPromise.domain) {
+        currPromise.domain.run(function() {
+            logger.error(`unhandledRejection reason: ${errStr}`);
+            setImmediate(function() {
+                require('util/mail/mail.js').SendMail(key, 'js', 600, {
+                    'Title': key,
+                    'runtimeType': 'warning',
+                    'Content': Content
+                });
+            });
+        });
+    } else {
+        logger.error(`unhandledRejection reason: ${errStr}`);
     }
-
-    require('util/mail/mail.js').SendMail(key, 'js', 600, {
-        'Title': key,
-        'runtimeType': 'unhandledRejection',
-        'Content': Content
-    });
 });
 
 process.noProcessWarnings = true;