Compressing files

[mtsewrs]

I cannot get compression working when stream files, using the code from VideoStreamer.js like so

let stream = fs.createReadStream(name);
const gzip = createGzip()
stream = stream.pipe(gzip)
pipeStreamOverResponse(res, stream, totalSize);

using the fs.stat to get size of the file but since it will be compressed the content length is wrong and I get a Parse Error: Expected HTTP/

Has anyone got compression working with streaming?

[Wyzix33]

I was having the same problem, try this:

function toArrayBuffer(buffer) {
  return buffer.buffer.slice(buffer.byteOffset, buffer.byteOffset + buffer.byteLength);
 },
let readStream;
let path = req.getUrl();
const acceptEncoding = req.getHeader('accept-encoding');
const contentType = require('./contentType')(path);
// require('./contentType')(path) is
// a simple function that gets the extension of the requested file and returns the content type we must use
// let extension = path.split('.').pop();
// switch (extension) {
//  case 'js':
//   contentType = 'text/javascript';
//   break;

// at this point you need a way to get the requested file and catch errors if the file does not exist:
const fileName = paths.join(rootDirectory, folder, path); // i have some DANGEROUS_PATH_PATTERN test on the path var you must make sure it's safe
try {
 readStream = toArrayBuffer(fs.readFileSync(fileName)); // toArrayBuffer is a function i got from examples
} catch (err) {
 readStream = 'Error reading file.. or something'; 
}

readStream = toArrayBuffer(fs.readFileSync(fileName));
// setting headers and responding: res.aborted must be present
res.onAborted(() => {
 res.aborted = true;
});
// write the headers and respond
res.cork(() => {
 res.writeHeader('Content-Type', contentType);
 for (let i = 0; i < securityHeaders.length; i++) res.writeHeader(securityHeaders[i].name, securityHeaders[i].value);
 if (!acceptEncoding) acceptEncoding = '';
 if (/\bgzip\b/.test(acceptEncoding)) {
  res.writeHeader('Content-Encoding', 'gzip');
  readStream = zlib.gzipSync(readStream);
 } else if (/\bdeflate\b/.test(acceptEncoding)) {
  res.writeHeader('Content-Encoding', 'deflate');
  readStream = zlib.deflateSync(readStream);
 }
 if (!res.aborted) res.end(readStream);
});

Hope it helps anyone
i'm not sure if if (!res.aborted) is necessary but i found some info somewhere used like this and i don't mind it...