diff --git a/readme.md b/readme.md
index e3ae78f..b145c80 100644
--- a/readme.md
+++ b/readme.md
@@ -19,4 +19,5 @@ To pass the task you also need to implement a server that:
- respond with 400 status code if trying to compress a file with an unsupported compression type
- respond with 200 status code and compressed file if the form is valid
+
**Read [the guideline](https://github.com/mate-academy/js_task-guideline/blob/master/README.md) before start**
diff --git a/src/createServer.js b/src/createServer.js
index 1cf1dda..2c856fc 100644
--- a/src/createServer.js
+++ b/src/createServer.js
@@ -1,8 +1,128 @@
'use strict';
+const http = require('http');
+const fs = require('fs');
+const path = require('path');
+const { pipeline, Readable } = require('stream');
+const zlib = require('zlib');
+
+const COMPRESSION_TYPES = ['gzip', 'deflate', 'br'];
+
+function sendStatus(res, code) {
+ if (!res.headersSent) {
+ res.writeHead(code);
+ res.end();
+ }
+}
+
function createServer() {
- /* Write your code here */
- // Return instance of http.Server class
+ return http.createServer((req, res) => {
+ const { url, method, headers } = req;
+
+ if (url === '/' && method === 'GET') {
+ const htmlPath = path.join(__dirname, 'index.html');
+ const readStream = fs.createReadStream(htmlPath, 'utf-8');
+
+ res.writeHead(200, { 'Content-Type': 'text/html' });
+
+ pipeline(readStream, res, (err) => {
+ if (err) {
+ sendStatus(res, 500);
+ }
+ });
+
+ return;
+ }
+
+ if (method === 'GET' && url === '/compress') {
+ sendStatus(res, 400);
+
+ return;
+ }
+
+ if (method === 'POST' && url === '/compress') {
+ const contentType = headers['content-type'];
+
+ if (!contentType || !contentType.includes('multipart/form-data')) {
+ return sendStatus(res, 400);
+ }
+
+ const boundary = '--' + contentType.split('boundary=')[1];
+
+ let body = Buffer.alloc(0);
+
+ req.on('data', (chunk) => {
+ body = Buffer.concat([body, chunk]);
+ });
+
+ req.on('end', () => {
+ const parts = body.toString('binary').split(boundary);
+
+ let fileBuffer;
+ let fileName;
+ let compressionType;
+
+ for (const part of parts) {
+ if (part.includes('name="compressionType"')) {
+ compressionType = part.split('\r\n\r\n')[1]?.trim();
+ }
+
+ if (part.includes('name="file"')) {
+ const match = part.match(/filename="(.+?)"/);
+
+ if (match) {
+ fileName = match[1];
+
+ const fileContent = part.split('\r\n\r\n')[1];
+
+ fileBuffer = Buffer.from(
+ fileContent.slice(0, fileContent.lastIndexOf('\r\n')),
+ 'binary',
+ );
+ }
+ }
+ }
+
+ if (!fileBuffer || !fileName || !compressionType) {
+ return sendStatus(res, 400);
+ }
+
+ if (!COMPRESSION_TYPES.includes(compressionType)) {
+ return sendStatus(res, 400);
+ }
+
+ let compressor;
+ let extension;
+
+ if (compressionType === 'gzip') {
+ compressor = zlib.createGzip();
+ extension = '.gzip';
+ }
+
+ if (compressionType === 'deflate') {
+ compressor = zlib.createDeflate();
+ extension = '.deflate';
+ }
+
+ if (compressionType === 'br') {
+ compressor = zlib.createBrotliCompress();
+ extension = '.br';
+ }
+
+ res.writeHead(200, {
+ 'Content-Disposition': `attachment; filename=${fileName}${extension}`,
+ 'Content-Type': 'application/octet-stream',
+ });
+
+ pipeline(Readable.from(fileBuffer), compressor, res, () => {});
+ });
+
+ return;
+ }
+
+ res.statusCode = 404;
+ res.end('Not Found');
+ });
}
module.exports = {
diff --git a/src/index.html b/src/index.html
new file mode 100644
index 0000000..e9e6127
--- /dev/null
+++ b/src/index.html
@@ -0,0 +1,24 @@
+
+
+
+
+
+ Document
+
+
+
+
+