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/package-lock.json b/package-lock.json
index d0b3b95..3650660 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -12,7 +12,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",
@@ -1487,10 +1487,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",
diff --git a/package.json b/package.json
index 1d03d64..8e6392d 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",
diff --git a/src/createServer.js b/src/createServer.js
index 1cf1dda..ebfb880 100644
--- a/src/createServer.js
+++ b/src/createServer.js
@@ -1,8 +1,131 @@
'use strict';
+const http = require('http');
+const zlib = require('zlib');
+const { Readable } = require('stream');
+
function createServer() {
- /* Write your code here */
- // Return instance of http.Server class
+ return http.createServer((request, response) => {
+ if (request.url === '/' && request.method === 'GET') {
+ const htmlString = `
+
+
+
+
+ Form Example
+
+
+
+
+
+ `;
+
+ response.setHeader('Content-Type', 'text/html');
+ response.statusCode = 200;
+ response.end(htmlString);
+ } else if (request.url === '/compress') {
+ if (request.method === 'GET') {
+ response.statusCode = 400;
+ response.end('Bad Request');
+
+ return;
+ }
+
+ if (request.method === 'POST') {
+ const contentType = request.headers['content-type'];
+
+ if (!contentType || !contentType.includes('boundary=')) {
+ response.statusCode = 400;
+ response.end('Bad Request');
+
+ return;
+ }
+
+ const boundary = contentType.split('boundary=')[1];
+
+ const chunks = [];
+
+ request.on('data', (chunk) => {
+ chunks.push(chunk);
+ });
+
+ request.on('end', () => {
+ const fullBuffer = Buffer.concat(chunks);
+ const fileNameMatch = fullBuffer.toString().match(/filename="(.+?)"/);
+ const compressionMatch = fullBuffer
+ .toString()
+ .match(/name="compressionType"\r\n\r\n(.+?)\r\n/);
+
+ if (!fileNameMatch || !compressionMatch) {
+ response.statusCode = 400;
+ response.end('Bad Request');
+
+ return;
+ }
+
+ const fileName = fileNameMatch[1];
+ const compressionType = compressionMatch[1];
+
+ if (!['gzip', 'deflate', 'br'].includes(compressionType)) {
+ response.statusCode = 400;
+ response.end('Invalid Compression Type');
+
+ return;
+ }
+
+ const startFileName = fullBuffer.indexOf('filename="' + fileName);
+ const fileContentStart =
+ fullBuffer.indexOf('\r\n\r\n', startFileName) + 4;
+ const fileContendEnd = fullBuffer.indexOf(
+ '\r\n--' + boundary,
+ fileContentStart,
+ );
+ const fileBuffer = fullBuffer.subarray(
+ fileContentStart,
+ fileContendEnd,
+ );
+
+ const fileStream = Readable.from(fileBuffer);
+
+ let compressedStream;
+ let extension;
+
+ if (compressionType === 'gzip') {
+ compressedStream = zlib.createGzip();
+ extension = 'gz';
+ } else if (compressionType === 'deflate') {
+ compressedStream = zlib.createDeflate();
+ extension = 'dfl';
+ } else if (compressionType === 'br') {
+ compressedStream = zlib.createBrotliCompress();
+ extension = 'br';
+ }
+
+ const newFileName = `${fileName}.${extension}`;
+
+ response.statusCode = 200;
+
+ response.setHeader(
+ 'Content-Disposition',
+ `attachment; filename=${newFileName}`,
+ );
+
+ fileStream.pipe(compressedStream).pipe(response);
+ });
+ }
+ } else {
+ response.statusCode = 404;
+ response.end('Not Found');
+ }
+ });
}
module.exports = {
diff --git a/tests/createServer.test.js b/tests/createServer.test.js
index b53ef15..27b2977 100644
--- a/tests/createServer.test.js
+++ b/tests/createServer.test.js
@@ -29,12 +29,15 @@ function stringToStream(str) {
const compressionTypes = {
gzip: {
decompress: util.promisify(zlib.gunzip),
+ extension: 'gz',
},
deflate: {
decompress: util.promisify(zlib.inflate),
+ extension: 'dfl',
},
br: {
decompress: util.promisify(zlib.brotliDecompress),
+ extension: 'br',
},
};
@@ -96,7 +99,7 @@ describe('createServer', () => {
});
Object.entries(compressionTypes).forEach(
- ([compressionType, { decompress }]) => {
+ ([compressionType, { decompress, extension }]) => {
describe(`compression type "${compressionType}"`, () => {
it('should respond with 200 status code', () => {
expect.assertions(1);
@@ -124,7 +127,7 @@ describe('createServer', () => {
headers: formData.getHeaders(),
})
.then((res) => {
- const expectedHeader = `attachment; filename=${filename}.${compressionType}`;
+ const expectedHeader = `attachment; filename=${filename}.${extension}`;
expect(res.headers['content-disposition']).toBe(
expectedHeader,