Send early empty success response in OTelIngest to prevent timeouts

OneUptime · Dec 4, 2024 · 4029d72 · 4029d72
1 parent 8d2cf50
commit 4029d72
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/OpenTelemetryIngest/API/OTelIngest.ts b/OpenTelemetryIngest/API/OTelIngest.ts
@@ -125,6 +125,8 @@ router.post(
         );
       }
 
+      Response.sendEmptySuccessResponse(req, res); // send empty response to client early to avoid timeouts.
+
       const traceData: JSONObject = req.body.toJSON
         ? req.body.toJSON()
         : req.body;
@@ -408,8 +410,6 @@ router.post(
       }).catch((err: Error) => {
         logger.error(err);
       });
-
-      return Response.sendEmptySuccessResponse(req, res);
     } catch (err) {
       return next(err);
     }
@@ -432,6 +432,8 @@ router.post(
         );
       }
 
+      Response.sendEmptySuccessResponse(req, res); // send empty response to client early to avoid timeouts.
+
       req.body = req.body.toJSON ? req.body.toJSON() : req.body;
 
       const resourceMetrics: JSONArray = req.body[
@@ -687,8 +689,6 @@ router.post(
       }).catch((err: Error) => {
         logger.error(err);
       });
-
-      return Response.sendEmptySuccessResponse(req, res);
     } catch (err) {
       return next(err);
     }
@@ -711,6 +711,8 @@ router.post(
         );
       }
 
+      Response.sendEmptySuccessResponse(req, res); // send empty response to client early to avoid timeouts.
+
       req.body = req.body.toJSON ? req.body.toJSON() : req.body;
 
       const resourceLogs: JSONArray = req.body["resourceLogs"] as JSONArray;
@@ -912,8 +914,6 @@ router.post(
       }).catch((err: Error) => {
         logger.error(err);
       });
-
-      return Response.sendEmptySuccessResponse(req, res);
     } catch (err) {
       return next(err);
     }