Merge pull request #554 from bcgov/fix/eccc-swrs-api-node-fetch

Fix: node fetch request pipe
bcgov · May 31, 2024 · a0af102 · a0af102
2 parents 7551fac + 8b72300
commit a0af102
Showing 1 changed file with 15 additions and 1 deletion.
diff --git a/ggircs-app/app/server/routers/api/eccc.js b/ggircs-app/app/server/routers/api/eccc.js
@@ -1,10 +1,15 @@
 require("isomorphic-fetch");
 const express = require("express");
+const dotenv = require("dotenv");
+const { WritableStream } = require("node:stream/web");
 const { isAuthenticated } = require("@bcgov-cas/sso-express/dist/helpers");
 const { getUserGroups } = require("../../helpers/userGroupAuthentication");
 const { getUserGroupLandingRoute } = require("../../../lib/user-groups");
 
+dotenv.config();
+
 const ecccApiRouter = express.Router();
+
 const { ECCC_FILE_BROWSER_HOST, ECCC_FILE_BROWSER_PORT, HOST, PORT } =
   process.env;
 
@@ -83,7 +88,16 @@ ecccApiRouter.get(
     if (contentDispositionHeader)
       res.setHeader("Content-Disposition", contentDispositionHeader);
 
-    ecccApiRes.body.pipe(res);
+    ecccApiRes.body.pipeTo(
+      new WritableStream({
+        write: (chunk) => {
+          res.write(chunk);
+        },
+        close: () => {
+          res.end();
+        },
+      })
+    );
   }
 );