Revert "fix(gatsby-source-filesystem): fix broken stream with gzipped files (#28913)"

This reverts commit 38c0f42

Author: vladar

packages/gatsby-source-filesystem/package.json

@@ -25,8 +25,7 @@
     "@babel/cli": "^7.12.1",
     "@babel/core": "^7.12.3",
     "babel-preset-gatsby-package": "^0.10.0",
-    "cross-env": "^7.0.3",
-    "msw": "^0.25.0"
+    "cross-env": "^7.0.3"
   },
   "homepage": "https://github.com/gatsbyjs/gatsby/tree/master/packages/gatsby-source-filesystem#readme",
   "keywords": [

packages/gatsby-source-filesystem/src/__tests__/create-remote-file-node-integration.js

@@ -100,7 +100,11 @@ describe(`create-remote-file-node`, () => {
   describe(`valid url`, () => {
     let uuid = 0
 
-    const setup = (args = {}, response = { statusCode: 200 }) => {
+    const setup = (
+      args = {},
+      type = `response`,
+      response = { statusCode: 200 }
+    ) => {
       const url = `https://images.whatever.com/real-image-trust-me-${uuid}.png`
 
       const gotMock = {
@@ -117,21 +121,14 @@ describe(`create-remote-file-node`, () => {
       got.stream.mockReturnValueOnce({
         pipe: jest.fn(() => gotMock),
         on: jest.fn((mockType, mockCallback) => {
-          if (mockType === `response`) {
+          if (mockType === type) {
             // got throws on 404/500 so we mimic this behaviour
             if (response.statusCode === 404) {
               throw new Error(`Response code 404 (Not Found)`)
             }
 
             mockCallback(response)
           }
-          if (mockType === `downloadProgress`) {
-            mockCallback({
-              progress: 1,
-              transferred: 1,
-              total: 1,
-            })
-          }
 
           return gotMock
         }),

packages/gatsby-source-filesystem/src/__tests__/create-remote-file-node.js

@@ -159,14 +159,6 @@ const requestRemoteNode = (url, headers, tmpFilename, httpOpts, attempt = 1) =>
       },
       ...httpOpts,
     })
-
-    let haveAllBytesBeenWritten = false
-    responseStream.on(`downloadProgress`, progress => {
-      if (progress.transferred === progress.total || progress.total === null) {
-        haveAllBytesBeenWritten = true
-      }
-    })
-
     const fsWriteStream = fs.createWriteStream(tmpFilename)
     responseStream.pipe(fsWriteStream)
 
@@ -188,12 +180,12 @@ const requestRemoteNode = (url, headers, tmpFilename, httpOpts, attempt = 1) =>
 
     responseStream.on(`response`, response => {
       resetTimeout()
+      const contentLength =
+        response.headers && Number(response.headers[`content-length`])
 
       fsWriteStream.on(`finish`, () => {
-        fsWriteStream.close()
-
         // We have an incomplete download
-        if (!haveAllBytesBeenWritten) {
+        if (contentLength && contentLength !== fsWriteStream.bytesWritten) {
           fs.removeSync(tmpFilename)
 
           if (attempt < INCOMPLETE_RETRY_LIMIT) {