From 7e15aff88ae73abcab1d8b6b4bbc444f5055d7ed Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Andri=C3=AF=20Zakhartchenko?= Date: Thu, 19 Mar 2026 20:27:19 +0100 Subject: [PATCH 1/7] solution --- .github/workflows/test.yml-template | 23 ++++++ index.html | 23 ++++++ package-lock.json | 31 +++++++- package.json | 5 +- src/createServer.js | 116 +++++++++++++++++++++++++++- 5 files changed, 191 insertions(+), 7 deletions(-) create mode 100644 .github/workflows/test.yml-template create mode 100644 index.html diff --git a/.github/workflows/test.yml-template b/.github/workflows/test.yml-template new file mode 100644 index 0000000..bb13dfc --- /dev/null +++ b/.github/workflows/test.yml-template @@ -0,0 +1,23 @@ +name: Test + +on: + pull_request: + branches: [ master ] + +jobs: + build: + + runs-on: ubuntu-latest + + strategy: + matrix: + node-version: [20.x] + + steps: + - uses: actions/checkout@v2 + - name: Use Node.js ${{ matrix.node-version }} + uses: actions/setup-node@v1 + with: + node-version: ${{ matrix.node-version }} + - run: npm install + - run: npm test diff --git a/index.html b/index.html new file mode 100644 index 0000000..597008b --- /dev/null +++ b/index.html @@ -0,0 +1,23 @@ + + + + + + Document + + +
+ + + + +
+ + \ No newline at end of file diff --git a/package-lock.json b/package-lock.json index d0b3b95..7fe4887 100644 --- a/package-lock.json +++ b/package-lock.json @@ -9,10 +9,13 @@ "version": "1.0.0", "hasInstallScript": true, "license": "GPL-3.0", + "dependencies": { + "busboy": "^1.6.0" + }, "devDependencies": { "@faker-js/faker": "^8.4.1", "@mate-academy/eslint-config": "latest", - "@mate-academy/scripts": "^1.8.6", + "@mate-academy/scripts": "^2.1.3", "axios": "^1.7.2", "eslint": "^8.57.0", "eslint-plugin-jest": "^28.6.0", @@ -1487,10 +1490,11 @@ } }, "node_modules/@mate-academy/scripts": { - "version": "1.8.6", - "resolved": "https://registry.npmjs.org/@mate-academy/scripts/-/scripts-1.8.6.tgz", - "integrity": "sha512-b4om/whj4G9emyi84ORE3FRZzCRwRIesr8tJHXa8EvJdOaAPDpzcJ8A0sFfMsWH9NUOVmOwkBtOXDu5eZZ00Ig==", + "version": "2.1.3", + "resolved": "https://registry.npmjs.org/@mate-academy/scripts/-/scripts-2.1.3.tgz", + "integrity": "sha512-a07wHTj/1QUK2Aac5zHad+sGw4rIvcNl5lJmJpAD7OxeSbnCdyI6RXUHwXhjF5MaVo9YHrJ0xVahyERS2IIyBQ==", "dev": true, + "license": "MIT", "dependencies": { "@octokit/rest": "^17.11.2", "@types/get-port": "^4.2.0", @@ -2739,6 +2743,17 @@ "integrity": "sha512-E+XQCRwSbaaiChtv6k6Dwgc+bx+Bs6vuKJHHl5kox/BaKbhiXzqQOwK4cO22yElGp2OCmjwVhT3HmxgyPGnJfQ==", "dev": true }, + "node_modules/busboy": { + "version": "1.6.0", + "resolved": "https://registry.npmjs.org/busboy/-/busboy-1.6.0.tgz", + "integrity": "sha512-8SFQbg/0hQ9xy3UNTB0YEnsNBbWfhf7RtnzpL7TkBiTBRfrQ9Fxcnz7VJsleJpyp6rVLvXiuORqjlHi5q+PYuA==", + "dependencies": { + "streamsearch": "^1.1.0" + }, + "engines": { + "node": ">=10.16.0" + } + }, "node_modules/call-bind": { "version": "1.0.7", "resolved": "https://registry.npmjs.org/call-bind/-/call-bind-1.0.7.tgz", @@ -8040,6 +8055,14 @@ "node": ">=8" } }, + "node_modules/streamsearch": { + "version": "1.1.0", + "resolved": "https://registry.npmjs.org/streamsearch/-/streamsearch-1.1.0.tgz", + "integrity": "sha512-Mcc5wHehp9aXz1ax6bZUyY5afg9u2rv5cqQI3mRrYkGC8rW2hM02jWuwjtL++LS5qinSyhj2QfLyNsuc+VsExg==", + "engines": { + "node": ">=10.0.0" + } + }, "node_modules/string-length": { "version": "4.0.2", "resolved": "https://registry.npmjs.org/string-length/-/string-length-4.0.2.tgz", diff --git a/package.json b/package.json index 1d03d64..9f3cce9 100644 --- a/package.json +++ b/package.json @@ -18,7 +18,7 @@ "devDependencies": { "@faker-js/faker": "^8.4.1", "@mate-academy/eslint-config": "latest", - "@mate-academy/scripts": "^1.8.6", + "@mate-academy/scripts": "^2.1.3", "axios": "^1.7.2", "eslint": "^8.57.0", "eslint-plugin-jest": "^28.6.0", @@ -30,5 +30,8 @@ }, "mateAcademy": { "projectType": "javascript" + }, + "dependencies": { + "busboy": "^1.6.0" } } diff --git a/src/createServer.js b/src/createServer.js index 1cf1dda..6117417 100644 --- a/src/createServer.js +++ b/src/createServer.js @@ -1,8 +1,120 @@ 'use strict'; +const http = require('http'); +const zlib = require('zlib'); +const Busboy = require('busboy'); + function createServer() { - /* Write your code here */ - // Return instance of http.Server class + const server = new http.Server(); + + server.on('request', (req, res) => { + if (req.url === '/' && req.method === 'GET') { + res.statusCode = 200; + + return res.end('OK'); + } + + if (req.url !== '/compress') { + res.statusCode = 404; + + return res.end('Not Found'); + } + + if (req.method !== 'POST') { + res.statusCode = 400; + + return res.end('Only POST allowed!'); + } + + let busboy; + + try { + busboy = Busboy({ headers: req.headers }); + } catch (err) { + res.statusCode = 400; + + return res.end('Invalid Content-Type'); + } + + let filename = ''; + let compressionType = ''; + let filesStream = null; + let gotFile = false; + + busboy.on('field', (name, val) => { + if (name === 'compressionType') { + compressionType = val; + } + }); + + busboy.on('file', (fieldname, stream, info) => { + if (fieldname === 'file') { + gotFile = true; + filename = info.filename; + filesStream = stream; + + stream.on('error', () => { + if (!res.writableEnded) { + res.statusCode = 500; + res.end('File stream error'); + } + }); + } else { + stream.resume(); + } + }); + + busboy.on('finish', () => { + if (!gotFile || !compressionType) { + if (filesStream) { + filesStream.resume(); + } + res.statusCode = 400; + + return res.end('Invalid Form'); + } + + let compressStream; + + if (compressionType === 'gzip') { + compressStream = zlib.createGzip(); + } else if (compressionType === 'deflate') { + compressStream = zlib.createDeflate(); + } else if (compressionType === 'br') { + compressStream = zlib.createBrotliCompress(); + } else { + filesStream.resume(); + res.statusCode = 400; + + return res.end('Unsupported compression type'); + } + + compressStream.on('error', () => { + if (!res.writableEnded) { + res.statusCode = 500; + res.end('Compression error'); + } + }); + + res.writeHead(200, { + 'Content-Disposition': `attachment; filename=${filename}.${compressionType}`, + 'Content-Type': 'application/octet-stream', + }); + + filesStream.pipe(compressStream).pipe(res); + }); + + busboy.on('error', () => { + if (!res.writableEnded) { + res.statusCode = 400; + res.end('Busboy error'); + } + }); + + req.pipe(busboy); + }); + + return server; } module.exports = { From 6daa44c6993a089c93c58360f1ba03959a1b8f44 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Andri=C3=AF=20Zakhartchenko?= Date: Fri, 20 Mar 2026 15:25:39 +0100 Subject: [PATCH 2/7] solution --- src/createServer.js | 149 ++++++++++++++++++++++++++++++++------------ src/file.txt | 1 + src/index.html | 23 +++++++ 3 files changed, 132 insertions(+), 41 deletions(-) create mode 100644 src/file.txt create mode 100644 src/index.html diff --git a/src/createServer.js b/src/createServer.js index 6117417..8a0b427 100644 --- a/src/createServer.js +++ b/src/createServer.js @@ -1,17 +1,37 @@ 'use strict'; +const fs = require('fs'); +const path = require('path'); const http = require('http'); const zlib = require('zlib'); -const Busboy = require('busboy'); +const busboy = require('busboy'); function createServer() { const server = new http.Server(); server.on('request', (req, res) => { + if (req.url === '/favicon.ico') { + res.statusCode = 204; + + return res.end(); + } + if (req.url === '/' && req.method === 'GET') { - res.statusCode = 200; + const filePath = path.resolve(__dirname, 'index.html'); + const stream = fs.createReadStream(filePath); + + stream.on('error', (err) => { + /* eslint-disable no-console */ + console.error('Error reading index.html:', err); + + res.statusCode = 500; + + return res.end('Cannot read index.html'); + }); + + res.writeHead(200, { 'Content-Type': 'text/html' }); - return res.end('OK'); + return stream.pipe(res); } if (req.url !== '/compress') { @@ -26,11 +46,14 @@ function createServer() { return res.end('Only POST allowed!'); } - let busboy; + let bb; try { - busboy = Busboy({ headers: req.headers }); + // console.log('headers:', req.headers); + + bb = busboy({ headers: req.headers }); } catch (err) { + // console.error('Busboy init error:', err); res.statusCode = 400; return res.end('Invalid Content-Type'); @@ -41,17 +64,74 @@ function createServer() { let filesStream = null; let gotFile = false; - busboy.on('field', (name, val) => { + const startCompression = () => { + if (!gotFile || !compressionType || !filesStream || res.headersSent) { + return; + } + + const extensions = { + gzip: 'gz', + deflate: 'dfl', + br: 'br', + }; + const ext = extensions[compressionType]; + + if (!ext) { + res.statusCode = 400; + + return res.end('Unsupported compression type'); + } + + let compressStream; + + if (compressionType === 'gzip') { + compressStream = zlib.createGzip(); + } else if (compressionType === 'deflate') { + compressStream = zlib.createDeflate(); + } else if (compressionType === 'br') { + compressStream = zlib.createBrotliCompress(); + } else { + res.statusCode = 400; + + return res.end('Unsupported compression type'); + } + + const mimeTypes = { + gzip: 'application/gzip', + deflate: 'application/zlib', + br: 'application/brotli', + }; + + res.statusCode = 200; + + res.setHeader( + 'Content-Type', + mimeTypes[compressionType] || 'application/octet-stream', + ); + + res.setHeader( + 'Content-Disposition', + `attachment; filename=${filename}.${ext}`, + ); + + filesStream.pipe(compressStream).pipe(res); + }; + + bb.on('field', (name, val) => { if (name === 'compressionType') { compressionType = val; + // startCompression(); } }); - busboy.on('file', (fieldname, stream, info) => { - if (fieldname === 'file') { + bb.on('file', (fieldname, stream, info) => { + // console.log('Got file:', info.filename); + + if (fieldname === 'file' && compressionType) { gotFile = true; filename = info.filename; filesStream = stream; + startCompression(); stream.on('error', () => { if (!res.writableEnded) { @@ -64,54 +144,41 @@ function createServer() { } }); - busboy.on('finish', () => { + bb.on('close', () => { + // console.log('Request parsing complete.'); + if (!gotFile || !compressionType) { if (filesStream) { filesStream.resume(); } - res.statusCode = 400; - - return res.end('Invalid Form'); - } - let compressStream; - - if (compressionType === 'gzip') { - compressStream = zlib.createGzip(); - } else if (compressionType === 'deflate') { - compressStream = zlib.createDeflate(); - } else if (compressionType === 'br') { - compressStream = zlib.createBrotliCompress(); - } else { - filesStream.resume(); - res.statusCode = 400; - - return res.end('Unsupported compression type'); - } - - compressStream.on('error', () => { if (!res.writableEnded) { - res.statusCode = 500; - res.end('Compression error'); + res.statusCode = 400; + res.end('Invalid Form'); } - }); - - res.writeHead(200, { - 'Content-Disposition': `attachment; filename=${filename}.${compressionType}`, - 'Content-Type': 'application/octet-stream', - }); - - filesStream.pipe(compressStream).pipe(res); + } }); - busboy.on('error', () => { + bb.on('error', () => { if (!res.writableEnded) { res.statusCode = 400; res.end('Busboy error'); } }); - req.pipe(busboy); + req.on('aborted', () => { + if (filesStream) { + filesStream.destroy(); + } + }); + + req.on('error', () => { + if (!res.writableEnded) { + res.statusCode = 500; + res.end('Request error'); + } + }); + req.pipe(bb); }); return server; diff --git a/src/file.txt b/src/file.txt new file mode 100644 index 0000000..d2203f9 --- /dev/null +++ b/src/file.txt @@ -0,0 +1 @@ +sdfsdfsdsdf \ No newline at end of file diff --git a/src/index.html b/src/index.html new file mode 100644 index 0000000..a31e4c2 --- /dev/null +++ b/src/index.html @@ -0,0 +1,23 @@ + + + + + + Document + + +
+ + + + +
+ + \ No newline at end of file From 05c4522e302e60e473951127eb82409160b4e39b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Andri=C3=AF=20Zakhartchenko?= Date: Fri, 20 Mar 2026 15:39:25 +0100 Subject: [PATCH 3/7] solution --- src/createServer.js | 98 +++++++++++---------------------------------- src/index.html | 3 +- 2 files changed, 25 insertions(+), 76 deletions(-) diff --git a/src/createServer.js b/src/createServer.js index 8a0b427..d166740 100644 --- a/src/createServer.js +++ b/src/createServer.js @@ -5,25 +5,17 @@ const path = require('path'); const http = require('http'); const zlib = require('zlib'); const busboy = require('busboy'); +const { PassThrough } = require('stream'); // 👈 ajout function createServer() { const server = new http.Server(); server.on('request', (req, res) => { - if (req.url === '/favicon.ico') { - res.statusCode = 204; - - return res.end(); - } - if (req.url === '/' && req.method === 'GET') { const filePath = path.resolve(__dirname, 'index.html'); const stream = fs.createReadStream(filePath); - stream.on('error', (err) => { - /* eslint-disable no-console */ - console.error('Error reading index.html:', err); - + stream.on('error', () => { res.statusCode = 500; return res.end('Cannot read index.html'); @@ -49,11 +41,8 @@ function createServer() { let bb; try { - // console.log('headers:', req.headers); - bb = busboy({ headers: req.headers }); } catch (err) { - // console.error('Busboy init error:', err); res.statusCode = 400; return res.end('Invalid Content-Type'); @@ -61,7 +50,7 @@ function createServer() { let filename = ''; let compressionType = ''; - let filesStream = null; + let filesStream = null; // sera un PassThrough let gotFile = false; const startCompression = () => { @@ -69,50 +58,28 @@ function createServer() { return; } - const extensions = { - gzip: 'gz', - deflate: 'dfl', - br: 'br', - }; - const ext = extensions[compressionType]; - - if (!ext) { - res.statusCode = 400; - - return res.end('Unsupported compression type'); - } - let compressStream; + let contentType = 'application/octet-stream'; if (compressionType === 'gzip') { compressStream = zlib.createGzip(); + contentType = 'application/gzip'; } else if (compressionType === 'deflate') { compressStream = zlib.createDeflate(); + contentType = 'application/zlib'; } else if (compressionType === 'br') { compressStream = zlib.createBrotliCompress(); + contentType = 'application/brotli'; } else { res.statusCode = 400; return res.end('Unsupported compression type'); } - const mimeTypes = { - gzip: 'application/gzip', - deflate: 'application/zlib', - br: 'application/brotli', - }; - - res.statusCode = 200; - - res.setHeader( - 'Content-Type', - mimeTypes[compressionType] || 'application/octet-stream', - ); - - res.setHeader( - 'Content-Disposition', - `attachment; filename=${filename}.${ext}`, - ); + res.writeHead(200, { + 'Content-Type': contentType, + 'Content-Disposition': `attachment; filename=${filename}.${compressionType}`, + }); filesStream.pipe(compressStream).pipe(res); }; @@ -120,17 +87,20 @@ function createServer() { bb.on('field', (name, val) => { if (name === 'compressionType') { compressionType = val; - // startCompression(); + startCompression(); } }); bb.on('file', (fieldname, stream, info) => { - // console.log('Got file:', info.filename); - - if (fieldname === 'file' && compressionType) { + if (fieldname === 'file') { gotFile = true; filename = info.filename; - filesStream = stream; + + const pass = new PassThrough(); + + stream.pipe(pass); + filesStream = pass; + startCompression(); stream.on('error', () => { @@ -145,17 +115,9 @@ function createServer() { }); bb.on('close', () => { - // console.log('Request parsing complete.'); - - if (!gotFile || !compressionType) { - if (filesStream) { - filesStream.resume(); - } - - if (!res.writableEnded) { - res.statusCode = 400; - res.end('Invalid Form'); - } + if (!res.headersSent) { + res.statusCode = 400; + res.end('Invalid Form'); } }); @@ -166,24 +128,10 @@ function createServer() { } }); - req.on('aborted', () => { - if (filesStream) { - filesStream.destroy(); - } - }); - - req.on('error', () => { - if (!res.writableEnded) { - res.statusCode = 500; - res.end('Request error'); - } - }); req.pipe(bb); }); return server; } -module.exports = { - createServer, -}; +module.exports = { createServer }; diff --git a/src/index.html b/src/index.html index a31e4c2..3244b21 100644 --- a/src/index.html +++ b/src/index.html @@ -10,7 +10,8 @@ method="POST" enctype="multipart/form-data" > - + From 621903ab4ed7bb4514831dcafcbdd99fdc723e55 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Andri=C3=AF=20Zakhartchenko?= Date: Fri, 20 Mar 2026 15:40:03 +0100 Subject: [PATCH 4/7] solution --- src/createServer.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/createServer.js b/src/createServer.js index d166740..4dd5682 100644 --- a/src/createServer.js +++ b/src/createServer.js @@ -5,7 +5,7 @@ const path = require('path'); const http = require('http'); const zlib = require('zlib'); const busboy = require('busboy'); -const { PassThrough } = require('stream'); // 👈 ajout +const { PassThrough } = require('stream'); function createServer() { const server = new http.Server(); @@ -50,7 +50,7 @@ function createServer() { let filename = ''; let compressionType = ''; - let filesStream = null; // sera un PassThrough + let filesStream = null; let gotFile = false; const startCompression = () => { From 72a81c31a6b258a66e0caa2b6dd53f7babad784a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Andri=C3=AF=20Zakhartchenko?= Date: Fri, 20 Mar 2026 15:47:22 +0100 Subject: [PATCH 5/7] solution --- src/createServer.js | 4 ++-- src/index.html | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/createServer.js b/src/createServer.js index 4dd5682..8b57743 100644 --- a/src/createServer.js +++ b/src/createServer.js @@ -61,10 +61,10 @@ function createServer() { let compressStream; let contentType = 'application/octet-stream'; - if (compressionType === 'gzip') { + if (compressionType === 'gz') { compressStream = zlib.createGzip(); contentType = 'application/gzip'; - } else if (compressionType === 'deflate') { + } else if (compressionType === 'fdl') { compressStream = zlib.createDeflate(); contentType = 'application/zlib'; } else if (compressionType === 'br') { diff --git a/src/index.html b/src/index.html index 3244b21..d4c4a9c 100644 --- a/src/index.html +++ b/src/index.html @@ -12,8 +12,8 @@ > From 56064b3ec512fa639c072e08874e97bf74203774 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Andri=C3=AF=20Zakhartchenko?= Date: Fri, 20 Mar 2026 15:54:42 +0100 Subject: [PATCH 6/7] solution --- src/createServer.js | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) diff --git a/src/createServer.js b/src/createServer.js index 8b57743..bec2cca 100644 --- a/src/createServer.js +++ b/src/createServer.js @@ -58,13 +58,20 @@ function createServer() { return; } + const extensionMap = { + // 👈 mapping ajouté + gzip: 'gz', + deflate: 'dfl', + br: 'br', + }; + let compressStream; let contentType = 'application/octet-stream'; - if (compressionType === 'gz') { + if (compressionType === 'gzip') { compressStream = zlib.createGzip(); contentType = 'application/gzip'; - } else if (compressionType === 'fdl') { + } else if (compressionType === 'deflate') { compressStream = zlib.createDeflate(); contentType = 'application/zlib'; } else if (compressionType === 'br') { @@ -76,9 +83,11 @@ function createServer() { return res.end('Unsupported compression type'); } + const ext = extensionMap[compressionType]; // 👈 extension correcte + res.writeHead(200, { 'Content-Type': contentType, - 'Content-Disposition': `attachment; filename=${filename}.${compressionType}`, + 'Content-Disposition': `attachment; filename=${filename}.${ext}`, // 👈 }); filesStream.pipe(compressStream).pipe(res); From 583c47872da0be26e56648251557c2b2a89b9e4d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Andri=C3=AF=20Zakhartchenko?= Date: Fri, 20 Mar 2026 16:00:06 +0100 Subject: [PATCH 7/7] solution --- src/createServer.js | 11 +---------- src/index.html | 6 +++--- 2 files changed, 4 insertions(+), 13 deletions(-) diff --git a/src/createServer.js b/src/createServer.js index bec2cca..4dd5682 100644 --- a/src/createServer.js +++ b/src/createServer.js @@ -58,13 +58,6 @@ function createServer() { return; } - const extensionMap = { - // 👈 mapping ajouté - gzip: 'gz', - deflate: 'dfl', - br: 'br', - }; - let compressStream; let contentType = 'application/octet-stream'; @@ -83,11 +76,9 @@ function createServer() { return res.end('Unsupported compression type'); } - const ext = extensionMap[compressionType]; // 👈 extension correcte - res.writeHead(200, { 'Content-Type': contentType, - 'Content-Disposition': `attachment; filename=${filename}.${ext}`, // 👈 + 'Content-Disposition': `attachment; filename=${filename}.${compressionType}`, }); filesStream.pipe(compressStream).pipe(res); diff --git a/src/index.html b/src/index.html index d4c4a9c..ff44117 100644 --- a/src/index.html +++ b/src/index.html @@ -11,9 +11,9 @@ enctype="multipart/form-data" >