chore: handle other error use-cases in reddit

rudderlabs · Aug 29, 2024 · 359a8f3 · 359a8f3
1 parent 965e7f0
commit 359a8f3
Showing 1 changed file with 13 additions and 4 deletions.
diff --git a/src/v0/destinations/reddit/networkHandler.js b/src/v0/destinations/reddit/networkHandler.js
@@ -1,11 +1,13 @@
-const { RetryableError } = require('@rudderstack/integrations-lib');
+const { RetryableError, TAG_NAMES, NetworkError } = require('@rudderstack/integrations-lib');
 const isString = require('lodash/isString');
 const { prepareProxyRequest, proxyRequest } = require('../../../adapters/network');
 const { isHttpStatusSuccess } = require('../../util/index');
 const { REFRESH_TOKEN } = require('../../../adapters/networkhandler/authConstants');
-const logger = require('../../../logger');
 
-const { processAxiosResponse } = require('../../../adapters/utils/networkUtils');
+const {
+  processAxiosResponse,
+  getDynamicErrorType,
+} = require('../../../adapters/utils/networkUtils');
 
 const redditRespHandler = (destResponse) => {
   const { status, response } = destResponse;
@@ -30,7 +32,14 @@ const redditRespHandler = (destResponse) => {
       authErrorCategory,
     );
   }
-  logger.error(`Error in Reddit response transformation: ${JSON.stringify(destResponse)}`);
+  throw new NetworkError(
+    `${JSON.stringify(response)} during reddit response transformation`,
+    status,
+    {
+      [TAG_NAMES.ERROR_TYPE]: getDynamicErrorType(status),
+    },
+    destResponse,
+  );
 };
 const responseHandler = (responseParams) => {
   const { destinationResponse } = responseParams;