add a solution

.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

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.2",
     "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"
   }
 }

readme.md

@@ -8,6 +8,7 @@ Implement a page with HTML `form` that allows to:
   - original file: `file.txt`
   - compression type: `gzip`
   - compressed file: `file.txt.gz`
+
 
 To pass the task you also need to implement a server that:
 - use Streams

src/createServer.js

@@ -1,10 +1,160 @@
 'use strict';
 
+const http = require('http');
+const path = require('path');
+const zlib = require('node:zlib');
+const { Readable } = require('stream');
+
+const extMap = { gzip: 'gzip', deflate: 'deflate', br: 'br' };
+
 function createServer() {
-  /* Write your code here */
-  // Return instance of http.Server class
+  return http.createServer(async (req, res) => {
+    if (req.url === '/' && req.method === 'GET') {
+      res.statusCode = 200;
+      res.end('OK');
+
+      return;
+    }
+
+    if (req.url !== '/compress') {
+      res.statusCode = 404;
+      res.end('Not Found');
+
+      return;
+    }
+
+    if (req.method !== 'POST') {
+      res.statusCode = 400;
+      res.end('Incorrect form method');
+
+      return;
+    }
+
+    const ct = req.headers['content-type'];
+
+    if (!ct || !ct.includes('multipart/form-data')) {
+      res.statusCode = 400;
+      res.end('Expected multipart/form-data');
+
+      return;
+    }
+
+    const boundary = ct.split('boundary=')[1]?.replace(/(^"|"$)/g, '');
+
+    if (!boundary) {
+      res.statusCode = 400;
+      res.end('Missing boundary');
+
+      return;
+    }
+
+    const chunks = [];
+
+    for await (const chunk of req) {
+      chunks.push(chunk);
+    }
+
+    const body = Buffer.concat(chunks);
+
+    const boundaryBuf = Buffer.from(`--${boundary}`);
+    let start = 0;
+    const parts = [];
+
+    while (true) {
+      const idx = body.indexOf(boundaryBuf, start);
+
+      if (idx === -1) {
+        break;
+      }
+
+      const nextIdx = body.indexOf(boundaryBuf, idx + boundaryBuf.length);
+      const end = nextIdx !== -1 ? nextIdx : body.length;
+
+      parts.push(body.slice(idx + boundaryBuf.length, end));
+      start = end;
+    }
+
+    let fileBuffer = null;
+    let filename = null;
+    let type = null;
+
+    for (const part of parts) {
+      let p = part;
+
+      if (p.slice(0, 2).toString() === '\r\n') {
+        p = p.slice(2);
+      }
+
+      const delimiter = Buffer.from('\r\n\r\n');
+      const idx = p.indexOf(delimiter);
+
+      if (idx === -1) {
+        continue;
+      }
+
+      const headersBuf = p.slice(0, idx);
+      const bodyBuf = p.slice(idx + delimiter.length);
+      const headersStr = headersBuf.toString('utf8').trim();
+
+      if (headersStr.includes('name="compressionType"')) {
+        type = bodyBuf.toString('utf8').trim().toLowerCase();
+
+        if (!['gzip', 'deflate', 'br'].includes(type)) {
+          res.statusCode = 400;
+          res.end('Unsupported compression type');
+
+          return;
+        }
+      }
+
+      if (headersStr.includes('name="file"')) {
+        const match = headersStr.match(/filename="(.+?)"/);
+
+        filename = match ? match[1] : 'file';
+
+        let endIdx = bodyBuf.length;
+
+        if (bodyBuf.slice(-2).toString() === '\r\n') {
+          endIdx -= 2;
+        }
+        fileBuffer = bodyBuf.slice(0, endIdx);
+      }
+    }
+
+    if (!fileBuffer || !type) {
+      res.statusCode = 400;
+      res.end('Missing file or compressionType');
+
+      return;
+    }
+
+    const compressor =
+      type === 'gzip'
+        ? zlib.createGzip()
+        : type === 'deflate'
+          ? zlib.createDeflate()
+          : zlib.createBrotliCompress();
+
+    const compressedFileName = `${path.basename(filename)}.${extMap[type]}`;
+
+    res.statusCode = 200;
+    res.setHeader('Content-Type', 'application/octet-stream');
+
+    res.setHeader(
+      'Content-Disposition',
+      `attachment; filename=${compressedFileName}`,
+    );
+
+    const stream = Readable.from([fileBuffer]);
+
+    stream
+      .pipe(compressor)
+      .pipe(res)
+      .on('error', () => {
+        res.statusCode = 500;
+        res.end('Compression error');
+      });
+  });
 }
 
-module.exports = {
-  createServer,
-};
+module.exports = { createServer };

src/index.html

@@ -0,0 +1,34 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+  <meta charset="UTF-8">
+  <meta name="viewport" content="width=device-width, initial-scale=1.0">
+  <title>Document</title>
+</head>
+<body>
+  <main>
+    <h1>File Compression</h1>
+
+    <form action="/compress" method="post" enctype="multipart/form-data">
+      <label for="file">Select a file: </label>
+      <input type="file" name="file" id="file" required>
+
+      <br>
+      <br>
+
+      <label for="type">Select a compression type: </label>
+      <select name="compressionType" id="type" required>
+        <option value="gzip">gzip</option>
+        <option value="deflate">deflate</option>
+        <option value="br">br</option>
+      </select>
+
+      <br>
+      <br>
+
+      <button type="submit">Submit</button>
+    </form>
+  </main>
+
+</body>
+</html>