diff --git a/src/createServer.js b/src/createServer.js
index 1cf1dda..8d789e8 100644
--- a/src/createServer.js
+++ b/src/createServer.js
@@ -1,8 +1,135 @@
'use strict';
+const fs = require('fs');
+const path = require('path');
+const http = require('http');
+const zlib = require('node:zlib');
+const { IncomingForm } = require('formidable');
+
+const compressionTypes = {
+ gzip: {
+ createStream: zlib.createGzip,
+ extension: 'gz',
+ },
+ deflate: {
+ createStream: zlib.createDeflate,
+ extension: 'dfl',
+ },
+ br: {
+ createStream: zlib.createBrotliCompress,
+ extension: 'br',
+ },
+};
+
+function sendHtml(response) {
+ const filePath = path.join(__dirname, 'index.html');
+
+ fs.readFile(filePath, 'utf8', (error, content) => {
+ if (error) {
+ response.writeHead(500, { 'Content-Type': 'text/plain; charset=utf-8' });
+ response.end('Internal Server Error');
+
+ return;
+ }
+
+ response.writeHead(200, { 'Content-Type': 'text/html; charset=utf-8' });
+ response.end(content);
+ });
+}
+
+function sendBadRequest(response) {
+ response.writeHead(400, { 'Content-Type': 'text/plain; charset=utf-8' });
+ response.end('Bad Request');
+}
+
+function sendNotFound(response) {
+ response.writeHead(404, { 'Content-Type': 'text/plain; charset=utf-8' });
+ response.end('Not Found');
+}
+
function createServer() {
- /* Write your code here */
- // Return instance of http.Server class
+ return http.createServer((request, response) => {
+ const { method, url } = request;
+
+ if (method === 'GET' && url === '/') {
+ sendHtml(response);
+
+ return;
+ }
+
+ if (method === 'GET' && url === '/compress') {
+ sendBadRequest(response);
+
+ return;
+ }
+
+ if (method === 'POST' && url === '/compress') {
+ const form = new IncomingForm({ multiples: false });
+
+ form.parse(request, async (error, fields, files) => {
+ if (error) {
+ sendBadRequest(response);
+
+ return;
+ }
+
+ const compressionType = Array.isArray(fields.compressionType)
+ ? fields.compressionType[0]
+ : fields.compressionType;
+ const file = Array.isArray(files.file) ? files.file[0] : files.file;
+
+ if (!file || !compressionType) {
+ sendBadRequest(response);
+
+ return;
+ }
+
+ if (!compressionTypes[compressionType]) {
+ sendBadRequest(response);
+
+ return;
+ }
+
+ const filePath = file.filepath || file.file?.path || file.path;
+ const filename =
+ file.originalFilename ||
+ file.name ||
+ path.basename(filePath || 'unknown');
+
+ if (!filePath || !filename) {
+ sendBadRequest(response);
+
+ return;
+ }
+
+ const { createStream, extension } = compressionTypes[compressionType];
+ const readStream = fs.createReadStream(filePath);
+ const compressStream = createStream();
+
+ const handleStreamError = () => {
+ if (!response.headersSent) {
+ sendBadRequest(response);
+ } else {
+ response.destroy();
+ }
+ };
+
+ readStream.on('error', handleStreamError);
+ compressStream.on('error', handleStreamError);
+
+ response.writeHead(200, {
+ 'Content-Type': 'application/octet-stream',
+ 'Content-Disposition': `attachment; filename=${filename}.${extension}`,
+ });
+
+ readStream.pipe(compressStream).pipe(response);
+ });
+
+ return;
+ }
+
+ sendNotFound(response);
+ });
}
module.exports = {
diff --git a/src/index.html b/src/index.html
new file mode 100644
index 0000000..07d5d1b
--- /dev/null
+++ b/src/index.html
@@ -0,0 +1,28 @@
+
+
+
+
+
+ Compression App
+
+
+ Compress a file
+
+
+