From df50c4a16cea5eac808acb25494d8ef64e779fd3 Mon Sep 17 00:00:00 2001
From: 60RSH <nikitabedenko@gmail.com>
Date: Thu, 16 Apr 2026 02:14:22 +0300
Subject: [PATCH 1/2] add solution

---
 src/createServer.js | 133 +++++++++++++++++++++++++++++++++++++++++++-
 src/index.html      |  28 ++++++++++
 2 files changed, 159 insertions(+), 2 deletions(-)
 create mode 100644 src/index.html

diff --git a/src/createServer.js b/src/createServer.js
index 1cf1dda..84b2422 100644
--- a/src/createServer.js
+++ b/src/createServer.js
@@ -1,8 +1,137 @@
 '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: {
+    compress: zlib.gzip,
+    extension: 'gz',
+  },
+  deflate: {
+    compress: zlib.deflate,
+    extension: 'dfl',
+  },
+  br: {
+    compress: zlib.brotliCompress,
+    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;
+        }
+
+        fs.readFile(filePath, (readError, fileBuffer) => {
+          if (readError) {
+            sendBadRequest(response);
+
+            return;
+          }
+
+          const { compress, extension } = compressionTypes[compressionType];
+
+          compress(fileBuffer, (compressError, compressed) => {
+            if (compressError) {
+              sendBadRequest(response);
+
+              return;
+            }
+
+            response.writeHead(200, {
+              'Content-Type': 'application/octet-stream',
+              'Content-Disposition': `attachment; filename=${filename}.${extension}`,
+            });
+            response.end(compressed);
+          });
+        });
+      });
+
+      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 @@
+<!DOCTYPE html>
+<html lang="en">
+  <head>
+    <meta charset="UTF-8" />
+    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
+    <title>Compression App</title>
+  </head>
+  <body>
+    <h1>Compress a file</h1>
+    <form action="/compress" method="post" enctype="multipart/form-data">
+      <label>
+        Choose file:
+        <input type="file" name="file" required />
+      </label>
+      <br />
+      <label>
+        Compression type:
+        <select name="compressionType" required>
+          <option value="gzip">gzip</option>
+          <option value="deflate">deflate</option>
+          <option value="br">br</option>
+        </select>
+      </label>
+      <br />
+      <button type="submit">Compress</button>
+    </form>
+  </body>
+</html>

From 5eaaf2ae69471abb483842348c23710241ad6bda Mon Sep 17 00:00:00 2001
From: 60RSH <nikitabedenko@gmail.com>
Date: Thu, 16 Apr 2026 18:47:18 +0300
Subject: [PATCH 2/2] fix review issue

---
 src/createServer.js | 40 +++++++++++++++++++---------------------
 1 file changed, 19 insertions(+), 21 deletions(-)

diff --git a/src/createServer.js b/src/createServer.js
index 84b2422..8d789e8 100644
--- a/src/createServer.js
+++ b/src/createServer.js
@@ -8,15 +8,15 @@ const { IncomingForm } = require('formidable');
 
 const compressionTypes = {
   gzip: {
-    compress: zlib.gzip,
+    createStream: zlib.createGzip,
     extension: 'gz',
   },
   deflate: {
-    compress: zlib.deflate,
+    createStream: zlib.createDeflate,
     extension: 'dfl',
   },
   br: {
-    compress: zlib.brotliCompress,
+    createStream: zlib.createBrotliCompress,
     extension: 'br',
   },
 };
@@ -102,29 +102,27 @@ function createServer() {
           return;
         }
 
-        fs.readFile(filePath, (readError, fileBuffer) => {
-          if (readError) {
-            sendBadRequest(response);
+        const { createStream, extension } = compressionTypes[compressionType];
+        const readStream = fs.createReadStream(filePath);
+        const compressStream = createStream();
 
-            return;
+        const handleStreamError = () => {
+          if (!response.headersSent) {
+            sendBadRequest(response);
+          } else {
+            response.destroy();
           }
+        };
 
-          const { compress, extension } = compressionTypes[compressionType];
-
-          compress(fileBuffer, (compressError, compressed) => {
-            if (compressError) {
-              sendBadRequest(response);
+        readStream.on('error', handleStreamError);
+        compressStream.on('error', handleStreamError);
 
-              return;
-            }
-
-            response.writeHead(200, {
-              'Content-Type': 'application/octet-stream',
-              'Content-Disposition': `attachment; filename=${filename}.${extension}`,
-            });
-            response.end(compressed);
-          });
+        response.writeHead(200, {
+          'Content-Type': 'application/octet-stream',
+          'Content-Disposition': `attachment; filename=${filename}.${extension}`,
         });
+
+        readStream.pipe(compressStream).pipe(response);
       });
 
       return;