finish filemanager

bin/file-manager.js

@@ -0,0 +1,27 @@
+import process from 'node:process'
+import { printWelcome } from '../src/utils/printWelcome.js';
+import { getUserName } from '../src/utils/getUserName.js';
+import { commandDispatch, printCommandsPromts } from '../src/utils/commandDispatch.js';
+import { homedir } from 'node:os';
+
+const fileManager = async () => {
+    const [shell, filename, cliUserName] = process.argv
+    const userName = getUserName(cliUserName)
+
+    printWelcome(userName)
+
+    let currentWorkingDir = { path: homedir() }
+    printCommandsPromts(currentWorkingDir.path);
+    process.stdin.on("data", async (input) => {
+        const [command, ...args] = input.toString().trim().split(' ')
+        printCommandsPromts(currentWorkingDir.path);
+        await commandDispatch(command, args, currentWorkingDir, userName);
+    });
+
+    process.on('SIGINT', () => {
+        commandDispatch('SIGINT', '', userName)
+        process.exit(1);
+    })
+}
+
+await fileManager();

package.json

@@ -2,25 +2,12 @@
   "name": "node-nodejs-basics",
   "version": "1.0.0",
   "description": "This repository is the part of nodejs-assignments https://github.com/AlreadyBored/nodejs-assignments",
+  "engines": {
+    "node": ">=20.0.0"
+  },
   "type": "module",
   "scripts": {
-    "cli:args": "node src/cli/args.js --some-arg value1 --other 1337 --arg2 42",
-    "cli:env": "npx cross-env SOME=any RSS_foo=bar RSS_bar=baz node src/cli/env.js",
-    "cp": "node src/cp/cp.js",
-    "fs:copy": "node src/fs/copy.js",
-    "fs:create": "node src/fs/create.js",
-    "fs:delete": "node src/fs/delete.js",
-    "fs:list": "node src/fs/list.js",
-    "fs:read": "node src/fs/read.js",
-    "fs:rename": "node src/fs/rename.js",
-    "hash": "node src/hash/calcHash.js",
-    "modules": "node src/modules/esm.mjs",
-    "streams:read": "node src/streams/read.js",
-    "streams:transform": "node src/streams/transform.js",
-    "streams:write": "node src/streams/write.js",
-    "wt": "node src/wt/main.js",
-    "zip:compress": "node src/zip/compress.js",
-    "zip:decompress": "node src/zip/decompress.js"
+    "start": "node ./bin/file-manager.js"
   },
   "repository": {
     "type": "git",

src/utils/commandDispatch.js

@@ -0,0 +1,94 @@
+import { compressFile } from "./compressFile.js";
+import { createNewFile } from "./createNewFile.js";
+import { decompressFile } from "./decompressFile.js";
+import { deleteFile } from "./deleteFile.js";
+import { getUpperDir } from "./getUpperDir.js";
+import { goToDir } from "./goToDir.js";
+import { moveFile } from "./moveFile.js";
+import { printBye } from "./printBye.js";
+import { printFileContent } from "./printFileContent.js";
+import { printHash } from "./printHash.js";
+import { printListOfFiles } from "./printListOfFiles.js";
+import { printOS } from "./printOS.js";
+import { renameFile } from "./renameFile.js";
+
+const commandList = {
+    ".exit": (_, args, [userName]) => {
+        printBye(userName)
+        process.exit(1);
+    },
+    "SIGINT": (_, args, [userName]) => {
+        printBye(userName)
+        process.exit(1);
+    },
+    "up": async (currentPath) => {
+        currentPath.path = await getUpperDir(currentPath.path);
+
+    },
+    "cd": async (currentPath, [destination]) => {
+        currentPath.path = await goToDisr(currentPath.path, destination);
+    },
+    "ls": async ({ path }) => {
+        await printListOfFiles(path);
+
+    },
+    "cat": async ({ path }, [filepath]) => {
+        await printFileContent(path, filepath);
+    },
+    "add": async ({ path }, [filepath]) => {
+        await createNewFile(path, filepath);
+    },
+    "rn": async ({ path }, [oldpath, newpath]) => {
+        await renameFile(path, oldpath, newpath)
+    },
+    "mv": async ({ path }, [oldpath, newpath]) => {
+        await moveFile(path, oldpath, newpath)
+    },
+    "rm": async ({ path }, [filepath]) => {
+        await deleteFile(path, filepath)
+    },
+    "os": ({ path }, [optionType]) => {
+        printOS(path, optionType)
+    },
+    "hash": async ({ path }, [filepath]) => {
+        await printHash(path, filepath);
+    },
+    "compress": async ({ path }, [oldpath, newpath]) => {
+        await compressFile(path, oldpath, newpath)
+    },
+    "decompress": async ({ path }, [archivepath, decompresspath]) => {
+        await decompressFile(path, archivepath, decompresspath)
+    }
+}
+
+export const commandPrompts = {
+    ".exit": "Exit to File Manager",
+    "up": "Go to parent DIR",
+    "cd": "Go to dirpath <path>",
+    "ls": "Print list of files, from current DIR",
+    "cat": "Print file content by path <filename>",
+    "add": "Create new empty file <filename>, from current DIR",
+    "rn": "Rename file <oldname> <newname>",
+    "mv": "Move file <oldpath> <newpath>",
+    "rm": "Delete file by <filename>",
+    "os": "Print OS information. By setting --EOL, --cpus, --homedir, --username, --architecture",
+    "hash": "Print hash of file by filepath <filepath>",
+    "compress": "Compress file <filepath> <archive_filepath_without_extension>",
+    "decompress": "Decompress file <archfilepath> <decompressfilepath>"
+}
+
+export const printCommandsPromts = (currentWorkingDir) => {
+    const prompts = Object.entries(commandPrompts).map(([command, description]) => `${command} - ${description}`).join('\n')
+    console.log(`\nYou are currently in ${currentWorkingDir}`) 
+
+    console.log('\nAvailable commands list\n');
+    console.log(prompts)
+}
+
+export const commandDispatch = async (command, args, currentWorkingDir = '', usename = '') => {  
+    if (command in commandList) {
+        await commandList[command](currentWorkingDir, args, usename);
+        printCommandsPromts(currentWorkingDir.path)
+    }
+    else console.error('Invalid input')
+}

src/utils/compressFile.js

@@ -0,0 +1,45 @@
+import path from 'node:path'
+import { createReadStream, createWriteStream } from 'node:fs';
+import { pipeline } from "node:stream/promises";
+import { access, stat } from 'fs/promises'
+import { createBrotliCompress } from 'node:zlib';
+
+export const compressFile = async (currentPath, oldname, newpath) => {
+    if (!oldname || !newpath) {
+        console.error('Invalid input')
+        return;
+    }
+
+    const absoldpath = path.resolve(currentPath, oldname)
+    const absnewpath = path.resolve(currentPath, newpath)
+
+    const isCreated = await access(absoldpath).then(() => true).catch(() => false);
+
+    if (!isCreated) {
+        console.error("File doesn't exists")
+        return;
+    }
+
+    const stats = await stat(absoldpath)
+
+    if (stats.isDirectory()) {
+        console.error('It is directory')
+        return
+    }
+
+    const isDestinationUse = await access(absnewpath).then(() => true).catch(() => false);
+
+    if (isDestinationUse) {
+        console.error('New destination already use')
+        return;
+    }
+
+    const brotli = createBrotliCompress();
+    const source = createReadStream(absoldpath);
+    const destination = createWriteStream(absnewpath);
+    try {
+        await pipeline(source, brotli, destination);
+    } catch(_) {
+        console.error('Cannot compress file')
+    }
+}