From c850074d73b5c70ed7b35d98a761af01a17b94cb Mon Sep 17 00:00:00 2001
From: Wing-Kam Wong <wingkwong.code@gmail.com>
Date: Tue, 28 Mar 2023 15:47:00 +0800
Subject: [PATCH] feat(nocodb): insert hook log based on
 NC_AUTOMATION_LOG_LEVEL

---
 .../src/lib/meta/helpers/webhookHelpers.ts    | 98 ++++++++++---------
 packages/nocodb/src/lib/models/HookLog.ts     |  3 +
 2 files changed, 56 insertions(+), 45 deletions(-)

diff --git a/packages/nocodb/src/lib/meta/helpers/webhookHelpers.ts b/packages/nocodb/src/lib/meta/helpers/webhookHelpers.ts
index 49b3b944eb..6f27a3e56a 100644
--- a/packages/nocodb/src/lib/meta/helpers/webhookHelpers.ts
+++ b/packages/nocodb/src/lib/meta/helpers/webhookHelpers.ts
@@ -301,14 +301,16 @@ export async function invokeWebhook(
             subject: parseBody(notification?.payload?.subject, newData),
             html: parseBody(notification?.payload?.body, newData),
           });
-          hookLog = {
-            ...hook,
-            fk_hook_id: hook.id,
-            type: notification.type,
-            payload: JSON.stringify(notification?.payload),
-            response: JSON.stringify(res),
-            triggered_by: user?.email,
-          };
+          if (process.env.NC_AUTOMATION_LOG_LEVEL === 'ALL') {
+            hookLog = {
+              ...hook,
+              fk_hook_id: hook.id,
+              type: notification.type,
+              payload: JSON.stringify(notification?.payload),
+              response: JSON.stringify(res),
+              triggered_by: user?.email,
+            };
+          }
         }
         break;
       case 'URL':
@@ -323,25 +325,27 @@ export async function invokeWebhook(
             newData
           );
 
-          hookLog = {
-            ...hook,
-            fk_hook_id: hook.id,
-            type: notification.type,
-            payload: JSON.stringify(notification?.payload),
-            response: JSON.stringify({
-              status: res.status,
-              statusText: res.statusText,
-              headers: res.headers,
-              config: {
-                url: res.config.url,
-                method: res.config.method,
-                data: res.config.data,
-                headers: res.config.headers,
-                params: res.config.params,
-              },
-            }),
-            triggered_by: user?.email,
-          };
+          if (process.env.NC_AUTOMATION_LOG_LEVEL === 'ALL') {
+            hookLog = {
+              ...hook,
+              fk_hook_id: hook.id,
+              type: notification.type,
+              payload: JSON.stringify(notification?.payload),
+              response: JSON.stringify({
+                status: res.status,
+                statusText: res.statusText,
+                headers: res.headers,
+                config: {
+                  url: res.config.url,
+                  method: res.config.method,
+                  data: res.config.data,
+                  headers: res.config.headers,
+                  params: res.config.params,
+                },
+              }),
+              triggered_by: user?.email,
+            };
+          }
         }
         break;
       default:
@@ -357,29 +361,33 @@ export async function invokeWebhook(
             })
           );
 
-          hookLog = {
-            ...hook,
-            fk_hook_id: hook.id,
-            type: notification.type,
-            payload: JSON.stringify(notification?.payload),
-            response: JSON.stringify(res),
-            triggered_by: user?.email,
-          };
+          if (process.env.NC_AUTOMATION_LOG_LEVEL === 'ALL') {
+            hookLog = {
+              ...hook,
+              fk_hook_id: hook.id,
+              type: notification.type,
+              payload: JSON.stringify(notification?.payload),
+              response: JSON.stringify(res),
+              triggered_by: user?.email,
+            };
+          }
         }
         break;
     }
   } catch (e) {
     console.log(e);
-    hookLog = {
-      ...hook,
-      type: notification.type,
-      payload: JSON.stringify(notification?.payload),
-      fk_hook_id: hook.id,
-      error_code: e.error_code,
-      error_message: e.message,
-      error: JSON.stringify(e),
-      triggered_by: user?.email,
-    };
+    if (['ERROR', 'ALL'].includes(process.env.NC_AUTOMATION_LOG_LEVEL)) {
+      hookLog = {
+        ...hook,
+        type: notification.type,
+        payload: JSON.stringify(notification?.payload),
+        fk_hook_id: hook.id,
+        error_code: e.error_code,
+        error_message: e.message,
+        error: JSON.stringify(e),
+        triggered_by: user?.email,
+      };
+    }
     if (throwErrorOnFailure) throw e;
   } finally {
     if (hookLog) {
diff --git a/packages/nocodb/src/lib/models/HookLog.ts b/packages/nocodb/src/lib/models/HookLog.ts
index b0a077a3af..2b1292907c 100644
--- a/packages/nocodb/src/lib/models/HookLog.ts
+++ b/packages/nocodb/src/lib/models/HookLog.ts
@@ -63,6 +63,9 @@ export default class HookLog implements HookLogType {
   }
 
   public static async insert(hookLog: Partial<HookLog>, ncMeta = Noco.ncMeta) {
+    if (process.env.NC_AUTOMATION_LOG_LEVEL === 'OFF') {
+      return;
+    }
     const insertObj: any = extractProps(hookLog, [
       'base_id',
       'project_id',