feat(webserver): Streamed compression of some heavy requests

Hypfer · May 30, 2021 · 0d7d836 · 0d7d836
1 parent 98b2757
commit 0d7d836
Showing 1 changed file with 17 additions and 2 deletions.
diff --git a/backend/lib/webserver/RobotRouter.js b/backend/lib/webserver/RobotRouter.js
@@ -5,6 +5,7 @@ const { Hub, sseHub } = require("expresse");
 const ValetudoRobot = require("../core/ValetudoRobot");
 
 const CapabilitiesRouter = require("./CapabilitiesRouter");
+const {stringifyAndGZip} = require("../utils/streamHelpers");
 
 class RobotRouter {
     /**
@@ -36,7 +37,14 @@ class RobotRouter {
             try {
                 const polledState = await this.robot.pollState();
 
-                res.json(polledState);
+                stringifyAndGZip(polledState).then(data => {
+                    res.header("Content-Type", "application/json; charset=utf-8");
+                    res.header("Content-Encoding", "gzip");
+
+                    res.send(data);
+                }).catch(err => {
+                    throw err;
+                });
             } catch (err) {
                 res.status(500).send(err.toString());
             }
@@ -56,7 +64,14 @@ class RobotRouter {
             try {
                 const polledState = await this.robot.pollState();
 
-                res.json(polledState.map);
+                stringifyAndGZip(polledState.map).then(data => {
+                    res.header("Content-Type", "application/json; charset=utf-8");
+                    res.header("Content-Encoding", "gzip");
+
+                    res.send(data);
+                }).catch(err => {
+                    throw err;
+                });
             } catch (err) {
                 res.status(500).send(err.toString());
             }