diff --git a/CEO/.idea/jsLibraryMappings.xml b/CEO/.idea/jsLibraryMappings.xml new file mode 100644 index 0000000..d23208f --- /dev/null +++ b/CEO/.idea/jsLibraryMappings.xml @@ -0,0 +1,6 @@ + + + + + + \ No newline at end of file diff --git a/CEO/backupSchemes.json b/CEO/backupSchemes.json new file mode 100644 index 0000000..9e26dfe --- /dev/null +++ b/CEO/backupSchemes.json @@ -0,0 +1 @@ +{} \ No newline at end of file diff --git a/CEO/helpers/http_status.js b/CEO/helpers/http_status.js new file mode 100644 index 0000000..b03796e --- /dev/null +++ b/CEO/helpers/http_status.js @@ -0,0 +1,36 @@ +const httpStatus = { + // Informational + CONTINUE: 100, + SWITCHING_PROTOCOLS: 101, + PROCESSING: 102, + + // Success + OK: 200, + CREATED: 201, + ACCEPTED: 202, + NO_CONTENT: 204, + + // Redirection + MOVED_PERMANENTLY: 301, + FOUND: 302, + SEE_OTHER: 303, + NOT_MODIFIED: 304, + TEMPORARY_REDIRECT: 307, + + // Client Error + BAD_REQUEST: 400, + UNAUTHORIZED: 401, + FORBIDDEN: 403, + NOT_FOUND: 404, + METHOD_NOT_ALLOWED: 405, + CONFLICT: 409, + GONE: 410, + UNSUPPORTED_MEDIA_TYPE: 415, + + // Server Error + INTERNAL_SERVER_ERROR: 500, + NOT_IMPLEMENTED: 501, + SERVICE_UNAVAILABLE: 503 +}; + +module.exports = { httpStatus }; diff --git a/CEO/helpers/lock_mechanism.js b/CEO/helpers/lock_mechanism.js new file mode 100644 index 0000000..2d55fc5 --- /dev/null +++ b/CEO/helpers/lock_mechanism.js @@ -0,0 +1,33 @@ +const lockfile = require('proper-lockfile'); + +async function lockFile(filePath) { + try { + await lockfile.lock(filePath, { + realpath: false, + retries: { + retries: 10, // Number of retries + factor: 2, // The exponential factor + minTimeout: 1000, // The number of milliseconds before starting the first retry + maxTimeout: 5000, // The maximum number of milliseconds between two retries + randomize: true, // Randomizes the timeouts by multiplying with a factor between 1 to 2 + } + }); + console.log(`File locked: ${filePath}`); + } catch (error) { + console.error(`Error locking file ${filePath}: ${error.message}`); + throw error; // Propagate the error if unable to lock after retries + } +} + +async function unlockFile(filePath) { + try { + await lockfile.unlock(filePath); + console.log(`File unlocked: ${filePath}`); + } catch (error) { + console.error(`Error unlocking file ${filePath}: ${error.message}`); + // Decide whether to throw the error or not, based on your error handling strategy + throw error; + } +} + +module.exports = {lockFile, unlockFile} \ No newline at end of file diff --git a/CEO/ipConfig.json b/CEO/ipConfig.json new file mode 100644 index 0000000..adbb4e0 --- /dev/null +++ b/CEO/ipConfig.json @@ -0,0 +1 @@ +/ =9 uDH[ \ No newline at end of file diff --git a/CEO/iv.key b/CEO/iv.key new file mode 100644 index 0000000..a8859e3 --- /dev/null +++ b/CEO/iv.key @@ -0,0 +1 @@ +DZb /@ \ No newline at end of file diff --git a/CEO/jobs/backup.js b/CEO/jobs/backup.js new file mode 100644 index 0000000..3a0c8ae --- /dev/null +++ b/CEO/jobs/backup.js @@ -0,0 +1,365 @@ +const fsPromises = require('fs').promises; // Ensure you use the promise-based API +const fs = require('fs'); +const path = require('path'); +const { decryptFileInPlace, encryptFileInPlace, encryptFileWithKey, decryptFileWithKey} = require("../src/main/aes_encrypt"); +const {lockFile, unlockFile} = require("../helpers/lock_mechanism"); + +async function decryptAndGetServerIP(filePath) { + try { + await lockFile(filePath); + await decryptFileInPlace(filePath); + + const fileContent = await fs.promises.readFile(filePath, 'utf8'); + const jsonData = JSON.parse(fileContent); + const serverIP = jsonData.ip; + + await encryptFileInPlace(filePath) + await unlockFile(filePath); + return serverIP; + } catch (error) { + console.error('An error occurred:', error); + return null; + } +} + +function extractFilePaths(directoryStructure) { + let paths = []; + const traverse = (dir, currentPath) => { + Object.keys(dir).forEach(key => { + if (key === 'files') { + dir[key].forEach(file => paths.push(path.join(currentPath, file))); + } else { + traverse(dir[key], path.join(currentPath, key)); + } + }); + }; + traverse(directoryStructure, ''); + return paths; +} + +async function fetchFiles(ip, filePaths) { + let results = {}; + + for (const filePath of filePaths) { + const url = `http://${ip}:3000/file_path`; + try { + const response = await fetch(url, { + method: 'POST', + headers: { + 'Content-Type': 'application/json' + }, + body: JSON.stringify({ filePath }) + }); + + if (!response.ok) throw new Error(`HTTP status ${response.status}`); + + const arrayBuffer = await response.arrayBuffer(); // Fetch the response as an ArrayBuffer + results[filePath] = Buffer.from(arrayBuffer); + } catch (error) { + console.error(`Error fetching ${filePath}:`, error); + results[filePath] = null; + } + } + + return results; +} + +async function removeDirectory(directoryPath) { + try { + // Check if the directory exists + const stats = await fsPromises.stat(directoryPath); + if (!stats.isDirectory()) { + console.log('The specified path is not a directory.'); + return; + } + + // Read all the contents of the directory + const files = await fsPromises.readdir(directoryPath); + + // Loop through each file/directory and delete them + for (const file of files) { + const currentPath = path.join(directoryPath, file); + const currentStats = await fsPromises.stat(currentPath); + + if (currentStats.isDirectory()) { + // Recursive call for directories + await removeDirectory(currentPath); + } else { + await lockFile(currentPath); + await unlockFile(currentPath); + await fsPromises.unlink(currentPath); + } + } + + // Finally, delete the directory itself + await fsPromises.rmdir(directoryPath); + //console.log(`Directory removed: ${directoryPath}`); + } catch (error) { + console.error(`Error removing directory: ${error.message}`); + } +} + +async function decryptUserSystemConfig() { + const configPath = path.join(__dirname, '..', 'usersInSystem.json'); + await lockFile(configPath); + await decryptFileInPlace(configPath); +} + +async function encryptUserSystemConfig(){ + const configPath = path.join(__dirname, '..', 'usersInSystem.json'); + await encryptFileInPlace(configPath); + await unlockFile(configPath); +} + +async function processBackup() { + const usersConfigPath = path.join(__dirname, '..', 'usersInSystem.json'); + const backupConfigPath = path.join(__dirname, '..', 'backupSchemes.json'); + const baseBackupDirPath = path.join(__dirname, '..', 'backup_directories'); + if(!fs.existsSync(backupConfigPath) || !fs.existsSync(usersConfigPath)){ + console.log('Can\'t start backup system: necessary files missing!'); + return; + } + + await decryptUserSystemConfig(); + + try { + // Read and parse the users configuration + const usersData = await fsPromises.readFile(usersConfigPath, 'utf8'); + const usersConfig = JSON.parse(usersData); + + // Read and parse the backup configuration + const backupData = await fsPromises.readFile(backupConfigPath, 'utf8'); + const jsonData = JSON.parse(backupData); + + for (const key in jsonData) { + const userBackupDir = path.join(baseBackupDirPath, key); + await removeDirectory(userBackupDir); + + const node = jsonData[key]; + const directoryStructure = JSON.parse(node.directoryStructure); + const filePaths = extractFilePaths(directoryStructure); + const files = await fetchFiles(node.ip, filePaths); + + await fsPromises.mkdir(userBackupDir, { recursive: true }); + + // Find the encryption key for the user's department + let encryptionKey = ''; + for (const dept in usersConfig) { + if (usersConfig[dept].users.includes(key)) { + encryptionKey = usersConfig[dept].key; + break; + } + } + + for (const file in files) { + if (files[file]) { + const fullPath = path.join(userBackupDir, file); + await fsPromises.mkdir(path.dirname(fullPath), { recursive: true }); + await fsPromises.writeFile(fullPath, files[file]); // Write the binary data + + // Encrypt the file in place after writing it + if (encryptionKey) { + await encryptFileWithKey(fullPath, encryptionKey); + } + } + } + } + } catch (error) { + console.error('Failed to read or process the JSON file:', error); + } + + await encryptUserSystemConfig(); +} + +async function getAllFilePaths(dirPath) { + let filePaths = []; + async function recurse(currentPath) { + const entries = await fsPromises.readdir(currentPath, { withFileTypes: true }); + // Create promises for each entry and process them in parallel + const entryPromises = entries.map(async (entry) => { + const resolvedPath = path.join(currentPath, entry.name); + if (entry.isDirectory()) { + // If it's a directory, recurse into it + await recurse(resolvedPath); + } else { + // If it's a file, add it to the file paths array + filePaths.push(resolvedPath); + } + }); + // Wait for all promises to complete + await Promise.all(entryPromises); + } + await recurse(dirPath); + return filePaths; +} + +async function decryptBackupFilesToDirectory(destinationDir) { + await decryptUserSystemConfig(); + const usersConfigPath = path.join(__dirname, '..', 'usersInSystem.json'); + + if(!fs.existsSync(usersConfigPath)){ + return false; + } + + const usersConfig = JSON.parse(await fsPromises.readFile(usersConfigPath, 'utf8')); + const sourceDir = path.join(__dirname, '..', 'backup_directories'); + + await removeDirectory(destinationDir); + + try { + for (const department in usersConfig) { + const { key, users } = usersConfig[department]; + for (const userId of users) { + const userDir = path.join(sourceDir, userId); + try { + const files = await getAllFilePaths(userDir); + for (const filePath of files) { + const stats = await fsPromises.stat(filePath); + if (stats.isFile()) { + const relativePath = path.relative(userDir, filePath); + + // Construct the destination file path + const destinationFilePath = path.join(destinationDir, userId, relativePath); + await fsPromises.mkdir(path.dirname(destinationFilePath), { recursive: true }); + await lockFile(filePath); + + // Decrypt the file in its original location + await decryptFileWithKey(filePath, key); + + // Copy the decrypted file to the destination directory + await fsPromises.copyFile(filePath, destinationFilePath); + console.log(`Decrypted file copied to: ${destinationFilePath}`); + + // Re-encrypt the file in its original location (optional) + await encryptFileWithKey(filePath, key); + await unlockFile(filePath); + } + } + } catch (error) { + console.error(`Error processing files for user ${userId}: ${error.message}`); + await encryptUserSystemConfig(); + return false; + } + } + } + } catch (error) { + console.error(`Error processing decryption: ${error.message}`); + await encryptUserSystemConfig(); + return false; + } + + await encryptUserSystemConfig(); + return true; +} + +async function decryptDepartmentFilesToDirectory() { + const dirDepartmentPath = path.join(__dirname, '..', 'dirDepartment.json'); + const loginDataPath = path.join(__dirname, '..', 'loginData.json'); + const usersConfigPath = path.join(__dirname, '..', 'usersInSystem.json'); + const sourceDir = path.join(__dirname, '..', 'backup_directories'); + + if (!fs.existsSync(usersConfigPath) || !fs.existsSync(loginDataPath) || !fs.existsSync(dirDepartmentPath)) { + console.error("Missing one or more essential configuration files."); + return false; + } + + await lockFile(loginDataPath); + await lockFile(usersConfigPath); + + await decryptFileInPlace(loginDataPath); + await decryptFileInPlace(usersConfigPath); + + const { path: destinationDir } = JSON.parse(await fsPromises.readFile(dirDepartmentPath, 'utf8')); + const { department } = JSON.parse(await fsPromises.readFile(loginDataPath, 'utf8')); + const usersConfig = JSON.parse(await fsPromises.readFile(usersConfigPath, 'utf8')); + + // Check if department exists in users configuration + if (!usersConfig[department]) { + console.error(`No configuration found for department: ${department}`); + return false; + } + + const { key, users } = usersConfig[department]; + + await encryptFileInPlace(loginDataPath); + await encryptFileInPlace(usersConfigPath); + + await unlockFile(loginDataPath); + await unlockFile(usersConfigPath); + + await removeDirectory(destinationDir); + + for (const userId of users) { + const userDir = path.join(sourceDir, userId); + + try { + const files = await getAllFilePaths(userDir); + console.log(`Processing files for user ${userId}: ${files}`); + + for (const filePath of files) { + const stats = await fsPromises.stat(filePath); + if (stats.isFile()) { + const relativePath = path.relative(userDir, filePath); + + // Construct the destination file path + const destinationFilePath = path.join(destinationDir, userId, relativePath); + await fsPromises.mkdir(path.dirname(destinationFilePath), { recursive: true }); + + // Decrypt the file in its original location + await decryptFileWithKey(filePath, key); + + // Copy the decrypted file to the destination directory + await fsPromises.copyFile(filePath, destinationFilePath); + console.log(`Decrypted file copied to: ${destinationFilePath}`); + + // Re-encrypt the file in its original location (optional) + await encryptFileWithKey(filePath, key); + } + } + } catch (error) { + console.error(`Error processing files for user ${userId}: ${error.message}`); + return false; + } + } + + console.log("All files processed successfully."); + return true; +} + +let serverIp = null; +decryptAndGetServerIP(path.join(__dirname, '..', 'ipConfig.json')).then(ip => { + serverIp = ip; +}); + +const timeoutInterval = 7 * 60 * 1000 //minutes * seconds * miliseconds + +setInterval(async () => { + await decryptDepartmentFilesToDirectory(); +}, timeoutInterval); + +console.log('backup.js process started!'); +process.on('SIGINT', async () => { + console.log('Shutdown signal received in \'backup.js\'. Cleaning up...'); + + try { + console.log('Performing cleanup tasks...'); + console.log('Cleanup completed successfully.'); + } catch (error) { + console.error('An error occurred during cleanup:', error); + } finally { + console.log('Process terminated'); + process.exit(0); + } +}); + +process.on('message', async (message) => { + if (message.type === 'startBackup') { + console.log('BackupProcess: Received command to start backup.'); + await processBackup() + } + if(message.type === 'decryptBackup'){ + console.log(`BackupProcess: Received command to decrypt backup to ${message.decryptDestPath}`); + console.log(message.decryptDestPath); + await decryptBackupFilesToDirectory(message.decryptDestPath); + } +}); \ No newline at end of file diff --git a/CEO/jobs/external_endpoints.js b/CEO/jobs/external_endpoints.js new file mode 100644 index 0000000..8b12e01 --- /dev/null +++ b/CEO/jobs/external_endpoints.js @@ -0,0 +1,187 @@ +const express = require('express'); +const fs = require('fs'); +const multer = require('multer'); +const fsExtra = require('fs-extra'); +const path = require('path'); +const Joi = require('joi'); +const { httpStatus } = require('../helpers/http_status'); +const {lockFile, unlockFile} = require("../helpers/lock_mechanism"); + +const app = express(); +app.use(express.json()); +app.use('/share_file', express.raw({ type: 'application/octet-stream', limit: 'Infinity' })); + +const server = require('http').createServer(app); +const connections = []; + +// Store active connections to close them on shutdown +server.on('connection', (conn) => { + connections.push(conn); + conn.on('close', () => { + connections.splice(connections.indexOf(conn), 1); + }); +}); + +const filePathSchema = Joi.object({ + filePath: Joi.string().required() +}); + +async function getBaseDirectory() { + const filePath = path.join(__dirname, '..', 'dirBackup.json'); + try { + const data = await fs.promises.readFile(filePath, 'utf8'); + const jsonData = JSON.parse(data); + return jsonData.path; + } catch (error) { + console.error('Error reading the base directory:', error); + throw error; + } +} + +app.post('/file_path', async (req, res) => { + const { error, value } = filePathSchema.validate(req.body); + if (error) { + return res.status(httpStatus.BAD_REQUEST).json({ + message: 'Invalid input', + data: error.details + }); + } + + try { + const basePath = await getBaseDirectory(); + let { filePath } = value; + const baseDirName = path.basename(basePath); + if (filePath.startsWith(baseDirName + path.sep)) { + filePath = filePath.slice(baseDirName.length + 1); + } + const fullPath = path.resolve(basePath, filePath); + + fs.stat(fullPath, (err, stats) => { + if (err) { + if (err.code === 'ENOENT') { + return res.status(httpStatus.NOT_FOUND).json({ + message: 'File not found' + }); + } + return res.status(httpStatus.INTERNAL_SERVER_ERROR).json({ + message: 'Error accessing the file' + }); + } + + if (!stats.isFile()) { + return res.status(httpStatus.BAD_REQUEST).json({ + message: 'Path is not a file' + }); + } + + // Stream the file as binary data + res.writeHead(httpStatus.OK, { + 'Content-Type': 'application/octet-stream', + 'Content-Disposition': `attachment; filename="${path.basename(fullPath)}"` + }); + const fileStream = fs.createReadStream(fullPath); + fileStream.pipe(res); + }); + } catch (error) { + return res.status(httpStatus.INTERNAL_SERVER_ERROR).json({ + message: 'Error processing request' + }); + } +}); + + + +async function addFilePathToJson(filePath) { + const jsonFilePath = path.join(__dirname, '..', 'filesReceived.json'); + + try { + let data = { receivedFiles: [] }; + if (await fsExtra.pathExists(jsonFilePath)) { + await lockFile(jsonFilePath); + data = await fsExtra.readJson(jsonFilePath); + }else{ + await lockFile(jsonFilePath); + } + + data.receivedFiles.push(filePath); + + await fsExtra.writeJson(jsonFilePath, data, { spaces: 2 }); + await unlockFile(jsonFilePath); + console.log('File path added successfully.'); + } catch (error) { + console.error('Error updating JSON file:', error); + throw error; // Rethrow the error for further handling if necessary + } +} + +const shareFileSchema = Joi.object({ + idUser: Joi.string().required(), + nameOfFile: Joi.string().required(), + sizeOfFile: Joi.number().required() +}); + +const storage = multer.diskStorage({ + destination: function (req, file, cb) { + const { error, value } = shareFileSchema.validate(req.body); + if (error) { + cb(error, undefined); + return; + } + + const baseDir = path.join(__dirname, '..', 'uploads', value.idUser); // Temp storage location + fsExtra.ensureDirSync(baseDir); + cb(null, baseDir); + }, + filename: function (req, file, cb) { + cb(null, req.body.nameOfFile); // Using directly assuming it has been validated already + } +}); + +const upload = multer({ storage: storage }).single('file'); + +app.post('/upload', (req, res) => { + upload(req, res, async (err) => { + if (err instanceof multer.MulterError) { + res.status(httpStatus.INTERNAL_SERVER_ERROR).send(`Multer error: ${err.message}`); + return; + } else if (err) { + res.status(httpStatus.BAD_REQUEST).send(`Validation error: ${err.message}`); + return; + } + + try { + const { idUser, nameOfFile } = req.body; + + const dirConfig = await fsExtra.readJson(path.join(__dirname, '..', 'dirShare.json')); + const baseDir = dirConfig.path; + + const finalPath = path.join(baseDir, idUser, nameOfFile); + + await fsExtra.move(req.file.path, finalPath, { overwrite: true }); + await addFilePathToJson(finalPath); + + res.status(httpStatus.OK).json({message: 'Upload successful.'}) + } catch (error) { + console.error('Failed to move file:', error); + res.status(httpStatus.INTERNAL_SERVER_ERROR).json({message: 'Server error while moving the file.'}); + } + }); +}); + + + + +console.log('external_endpoints.json started.'); +const PORT = process.env.PORT || 3000; +server.listen(PORT, () => console.log(`Server running on port ${PORT}`)); + +process.on('SIGINT', () => { + console.log('SIGINT signal received. Shutting down gracefully.'); + server.close(() => { + console.log('Server closed.'); + // Ensure all connections are closed + connections.forEach(conn => conn.end()); + setTimeout(() => connections.forEach(conn => conn.destroy()), 5000); + process.exit(0); + }); +}); diff --git a/CEO/jobs/fetcher.js b/CEO/jobs/fetcher.js new file mode 100644 index 0000000..9d91cc2 --- /dev/null +++ b/CEO/jobs/fetcher.js @@ -0,0 +1,234 @@ +const fsPromises = require('fs').promises; +const fs = require('fs'); +const path = require('path'); +const ip = require('ip'); +const {encryptFileInPlace, decryptFileInPlace} = require('../src/main/aes_encrypt'); +const {lockFile, unlockFile} = require("../helpers/lock_mechanism"); + +async function fetchBackupSchemes(serverIp) { + // Fetching backup schemes from the server + const depResponse = await fetch(`http://${serverIp}/backup_schemes`, { + method: 'GET', + headers: {'x-api-key': 'uc_api'} + }); + const backupSchemesJson = await depResponse.json(); + const backupSchemes = backupSchemesJson['data']; + + // Specify the path where the backup schemes will be saved + const destPath = path.join(__dirname, '..', 'backupSchemes.json'); + + // Write the fetched backup schemes to the specified file + try { + await lockFile(destPath); + await fsPromises.writeFile(destPath, JSON.stringify(backupSchemes, null, 2)); // Use null, 2 for pretty formatting + await unlockFile(destPath); + console.log('Backup schemes saved successfully to', destPath); + } catch (error) { + console.error('Failed to save backup schemes:', error); + } +} + +async function fetchUsersAndDepartments(serverIp) { + try { + console.log('se asteapta depart'); + // Fetch departments + const depResponse = await fetch(`http://${serverIp}/users/departments`, { + method: 'GET', + headers: {'x-api-key': 'uc_api'} + }); + + const departmentsJson = await depResponse.json(); + const departments = departmentsJson['data']; + + console.log('se asteapta users') + // Fetch users + const userResponse = await fetch(`http://${serverIp}/users`, { + method: 'GET', + headers: {'x-api-key': 'uc_api'} + }); + const usersJson = await userResponse.json(); + const users = usersJson['data']; + + // Combine the JSON data + const combinedData = Object.values(departments).reduce((acc, {name, key}) => { + acc[name] = { + key, + users: users.filter(user => user.department === name).map(user => user.id) + }; + return acc; + }, {}); + + // Write combined data to a file + const filePath = path.join(__dirname, '..', 'usersInSystem.json'); + if(!fs.existsSync(filePath)){ + await fsPromises.writeFile(filePath, ''); + } + await lockFile(filePath); + await fsPromises.writeFile(filePath, JSON.stringify(combinedData, null, 2), 'utf8'); + + await encryptFileInPlace(filePath); + await unlockFile(filePath); + console.log('Data has been encrypted and saved.'); + } catch (error) { + console.error('Failed to fetch or process data:', error); + } +} + +async function decryptAndGetServerIP(filePath) { + try { + await lockFile(filePath); + await decryptFileInPlace(filePath); + + const fileContent = await fsPromises.readFile(filePath, 'utf8'); + const jsonData = JSON.parse(fileContent); + const serverIP = jsonData.ip; + + await encryptFileInPlace(filePath) + await unlockFile(filePath); + return serverIP; + } catch (error) { + console.error('An error occurred:', error); + return null; + } +} + +async function getDirectoryStructure(dirPath) { + const baseName = path.basename(dirPath); + const entries = await fsPromises.readdir(dirPath, {withFileTypes: true}); + const result = {}; + result[baseName] = {files: []}; + let totalSize = 0; + + for (let entry of entries) { + const entryPath = path.join(dirPath, entry.name); + if (entry.isDirectory()) { + // Recursively get structure for subdirectories + const {structure, size: subSize} = await getDirectoryStructure(entryPath); + result[baseName][entry.name] = structure[Object.keys(structure)[0]]; // Object.keys to fetch the first key name + totalSize += subSize; + } else { + // Add file name to the 'files' array and calculate total size + const stats = await fsPromises.stat(entryPath); + result[baseName].files.push(entry.name); + totalSize += stats.size; + } + } + return {structure: result, size: totalSize}; +} + +async function createBackupScheme(serverIp, structure, size) { + let filePath = path.join(__dirname, '..', 'loginData.json'); + await lockFile(filePath); + await decryptFileInPlace(filePath); + + const userContent = await fsPromises.readFile(filePath, 'utf8'); + const userJson = JSON.parse(userContent); + + await encryptFileInPlace(filePath) + await unlockFile(filePath); + + // Find the IP address of the machine + const machineIP = ip.address(); + + // Prepare the data to be sent + const dataToSend = { + id: userJson.id, + ip: machineIP, + directoryStructure: JSON.stringify(structure), + totalSize: size + }; + + const response = await fetch(`http://${serverIp}/backup_schemes`, { + method: 'PATCH', + headers: { + 'Content-Type': 'application/json', + 'x-api-key': 'uc_api' + }, + body: JSON.stringify(dataToSend) + }); + + if (response.ok) { + console.log("Backup dir structure submitted.") + } else { + const data = await response.json() + console.log(data.message); + } +} + +async function watchDirectoryChanges(serverIp) { + async function readBackupConfig(filePath) { + await lockFile(filePath); + const fileContent = await fsPromises.readFile(filePath, 'utf8'); + await unlockFile(filePath); + return JSON.parse(fileContent); + } + + async function updateBackupConfig(filePath, structure, size) { + const data = { + path: filePath, + structure: structure, + size: size + }; + await lockFile(filePath); + await fsPromises.writeFile(path.join(__dirname, '..', 'dirBackup.json'), JSON.stringify(data, null, 2)); + await unlockFile(filePath); + } + + const configPath = path.join(__dirname, '..', 'dirBackup.json'); + if(!fs.existsSync(configPath)){ + console.log('backupDir file doesn\'t exists'); + return; + } + const backupConfig = await readBackupConfig(configPath); + const storedStructure = backupConfig.structure; + + const {structure: currentStructure, size: currentSize} = await getDirectoryStructure(backupConfig.path); + + if (JSON.stringify(storedStructure) !== JSON.stringify(currentStructure)) { + console.log("Directory structure has changed. Updating backup..."); + await createBackupScheme(serverIp, currentStructure, currentSize); + + await updateBackupConfig(backupConfig.path, currentStructure, currentSize); + console.log('FetcherProcess: start backup.'); + process.send({type: 'startBackup'}); + } else { + console.log("No changes detected in the directory structure."); + } +} + +let serverIp = null +decryptAndGetServerIP(path.join(__dirname, '..', 'ipConfig.json')).then(ip => { + serverIp = ip; +}); + +const timeoutInterval = 6 * 60 * 1000 //minutes * seconds * miliseconds + +setInterval(() => { + fetchUsersAndDepartments(serverIp); +}, timeoutInterval); + +setInterval(() => { + watchDirectoryChanges(serverIp); +}, timeoutInterval); + +setInterval(() => { + fetchBackupSchemes(serverIp); +}, timeoutInterval); + + +console.log("fetcher.js process started."); + +process.on('SIGINT', async () => { + console.log('Shutdown signal received in \'fetcher.js\'. Cleaning up...'); + + try { + console.log('Performing cleanup tasks...'); + console.log('Cleanup completed successfully.'); + } catch (error) { + console.error('An error occurred during cleanup:', error); + } finally { + console.log('Process terminated'); + process.exit(0); + } +}); + diff --git a/CEO/jobs/send_file.js b/CEO/jobs/send_file.js new file mode 100644 index 0000000..b37520f --- /dev/null +++ b/CEO/jobs/send_file.js @@ -0,0 +1,90 @@ +const fs = require('fs'); +const path = require('path'); +const axios = require('axios'); +const FormData = require('form-data'); +const {lockFile, unlockFile} = require("../helpers/lock_mechanism"); +const {decryptFileInPlace, encryptFileInPlace} = require("../src/main/aes_encrypt"); + +async function decryptAndGetServerIP(filePath) { + try { + await lockFile(filePath); + await decryptFileInPlace(filePath); + + const fileContent = await fs.promises.readFile(filePath, 'utf8'); + const jsonData = JSON.parse(fileContent); + const serverIP = jsonData.ip; + + await encryptFileInPlace(filePath) + await unlockFile(filePath); + return serverIP; + } catch (error) { + console.error('An error occurred:', error); + return null; + } +} + +async function extractId() { + try { + // Path to the JSON file + const jsonFilePath = path.join(__dirname, '..', 'loginData.json'); + + // Read and parse the JSON file + const jsonData = await fs.promises.readFile(jsonFilePath, 'utf-8'); + const { id } = JSON.parse(jsonData); + + return id; + } catch (error) { + console.error('Failed to read file or parse data:', error); + throw error; + } +} + +async function uploadFile(filePath, serverIp) { + try { + const idUser = await extractId(); // Fetch ID from JSON + const nameOfFile = path.basename(filePath); // Extract the file name from the path + + // Ensure the file exists and get its size + if (!fs.existsSync(filePath)) { + console.error("File does not exist: " + filePath); + process.exit(1); + } + const fileSizeInBytes = fs.statSync(filePath).size; + + const form = new FormData(); + form.append('idUser', idUser); + form.append('nameOfFile', nameOfFile); + form.append('sizeOfFile', fileSizeInBytes); + form.append('file', fs.createReadStream(filePath)); + + const response = await axios.post(`http://${serverIp}/upload`, form, { + headers: { + ...form.getHeaders(), + }, + }); + + console.log('File uploaded successfully:', response.data); + process.exit(0); // Exit with status 0 (success) + } catch (error) { + console.error('Error uploading file:', error.message); + process.exit(1); // Exit with status 1 (error) + } +} + +// Command-line argument for file path +if (process.argv.length < 3) { + console.log('Usage: node + - Setup Completion + Sending file
-

SENDING THE FILE!

+

DECRYPTING BACKUP!

PlEASE WAIT

Description of GIF diff --git a/CEO/src/renderer/html/ip_submit.html b/CEO/src/renderer/html/ip_submit.html new file mode 100644 index 0000000..e4c7f0d --- /dev/null +++ b/CEO/src/renderer/html/ip_submit.html @@ -0,0 +1,32 @@ + + + + + + + + + + + + + + IP Submit + + +
+
+
+

IP Config

+
+
+
+ +
+
+ +
+
+
+ + diff --git a/CEO/src/renderer/html/login.html b/CEO/src/renderer/html/login.html index 13753ba..335c50d 100644 --- a/CEO/src/renderer/html/login.html +++ b/CEO/src/renderer/html/login.html @@ -4,12 +4,15 @@ + + + Login - +

DO WE KNOW

@@ -25,7 +28,6 @@
diff --git a/CEO/src/renderer/html/main_menu.html b/CEO/src/renderer/html/main_menu.html index f4e4e94..282b56d 100644 --- a/CEO/src/renderer/html/main_menu.html +++ b/CEO/src/renderer/html/main_menu.html @@ -4,15 +4,17 @@ + + Main Page - +
@@ -26,15 +28,19 @@
+ + +
+
-
-
- + +
+ - +
diff --git a/CEO/src/renderer/html/manage_departments.html b/CEO/src/renderer/html/manage_departments.html index 4b7f6ad..b7915f9 100644 --- a/CEO/src/renderer/html/manage_departments.html +++ b/CEO/src/renderer/html/manage_departments.html @@ -9,12 +9,13 @@ + Manage Departments - +
-
+

CREATE NEW DEPARTMENT

@@ -27,21 +28,14 @@
-
+

SECURITY

LEVELS

    -
  • Department 1
    • -
  • Department 2
    • -
  • Department 3
    • -
  • Department 4
    • -
  • Department 4
    • -
  • Department 4
    • -
  • Department 4
    • - +
diff --git a/CEO/src/renderer/html/manage_users.html b/CEO/src/renderer/html/manage_users.html index 805c166..db47505 100644 --- a/CEO/src/renderer/html/manage_users.html +++ b/CEO/src/renderer/html/manage_users.html @@ -9,31 +9,24 @@ + Manage Users - +
- +
diff --git a/CEO/src/renderer/html/profile.html b/CEO/src/renderer/html/profile.html index e6e2e5c..72c9140 100644 --- a/CEO/src/renderer/html/profile.html +++ b/CEO/src/renderer/html/profile.html @@ -9,10 +9,11 @@ + Profile - +
diff --git a/CEO/src/renderer/html/sending_file_confirmation.html b/CEO/src/renderer/html/sending_file_confirmation.html index 762093c..7774872 100644 --- a/CEO/src/renderer/html/sending_file_confirmation.html +++ b/CEO/src/renderer/html/sending_file_confirmation.html @@ -2,17 +2,63 @@ - - - Setup Completion - + + + + + + + + + + Sending file - +

SENDING THE FILE!

PlEASE WAIT

- Description of GIF + Description of GIF
diff --git a/CEO/src/renderer/html/share_file.html b/CEO/src/renderer/html/share_file.html index fabf9a9..6498a62 100644 --- a/CEO/src/renderer/html/share_file.html +++ b/CEO/src/renderer/html/share_file.html @@ -9,9 +9,10 @@ + Share File - +
diff --git a/CEO/src/renderer/html/sign_up_confirmation.html b/CEO/src/renderer/html/sign_up_confirmation.html deleted file mode 100644 index 0b34001..0000000 --- a/CEO/src/renderer/html/sign_up_confirmation.html +++ /dev/null @@ -1,21 +0,0 @@ - - - - - - - - - - Setup Completion - - -
-
-

ALL THE SETUP IS DONE!

-

LET’S PROCEED TO THE

-

LOGIN PAGE

-
-
- - diff --git a/CEO/src/renderer/html/sign_up_departments.html b/CEO/src/renderer/html/sign_up_departments.html deleted file mode 100644 index 4d2f37b..0000000 --- a/CEO/src/renderer/html/sign_up_departments.html +++ /dev/null @@ -1,37 +0,0 @@ - - - - - - - - - - - - - Department Selection - - -
-
-

TELL ME MORE

-

ABOUT

-

YOUR WORK

-
- - - - - -
- - diff --git a/CEO/src/renderer/html/sign_up_profile.html b/CEO/src/renderer/html/sign_up_profile.html deleted file mode 100644 index 6d23359..0000000 --- a/CEO/src/renderer/html/sign_up_profile.html +++ /dev/null @@ -1,33 +0,0 @@ - - - - - - - - - - Signup - - -
-
-

LET US MEET

-

EACH OTHER

-
- -
\ No newline at end of file diff --git a/CEO/src/renderer/js/ip_submit.js b/CEO/src/renderer/js/ip_submit.js new file mode 100644 index 0000000..7c78d06 --- /dev/null +++ b/CEO/src/renderer/js/ip_submit.js @@ -0,0 +1,33 @@ +document.addEventListener('DOMContentLoaded', async function () { + const submitButton = document.getElementById('submit'); + const ipInput = document.getElementById('ipInput'); + + submitButton.addEventListener('click', async function (e) { + e.preventDefault(); + try { + const ipAddress = ipInput.value.trim(); + if (!ipAddress) { + throw new Error('Please enter an IP address.'); + } + + fetch(`http://${ipAddress}/heartbeat`) + .then(async response => { + if (!response.ok) { + throw new Error('Test failed. Check ip and server.'); + } + + await window.electronAPI.writeFile('ipConfig.json', JSON.stringify({ip: ipAddress})); + fadeOut('login.html'); + }) + .catch(error => { + console.error('Error:', error.message); + throw new Error(error.message); + }); + } catch (error) { + console.error('Error:', error.message); + await window.electronAPI.showAlert(error.message) + .then(() => console.log('Alert window opened')) + .catch(error => console.error('Error showing alert:', error)); + } + }); +}); diff --git a/CEO/src/renderer/js/login.js b/CEO/src/renderer/js/login.js index a199849..76c7bc8 100644 --- a/CEO/src/renderer/js/login.js +++ b/CEO/src/renderer/js/login.js @@ -1,89 +1,91 @@ document.addEventListener('DOMContentLoaded', async function () { - const signinButton = document.getElementById('signin'); const submitButton = document.getElementById('submit'); - await window.electronAPI.readFile('loginData.json') - .then(async result => { - const loginData = JSON.parse(result.content); - const { email, password } = loginData; + const signupDataExists = await window.electronAPI.checkFileExists('signupData.json'); + if (signupDataExists) { + await window.electronAPI.deleteFile('signupData.json'); + } - const response = await fetch('http://localhost:5000/users/login', { - method: 'POST', - headers: { - 'Content-Type': 'application/json', - 'x-api-key': 'uc_api' - }, - body: JSON.stringify({ - email: email, - password: password - }) + let ip = ''; + await window.electronAPI.readFile('ipConfig.json') + .then(result => { + const jsonData = JSON.parse(result.content); + ip = jsonData.ip; + }) + + const fileExists = await window.electronAPI.checkFileExists('loginData.json'); + if (fileExists) { + await window.electronAPI.readFile('loginData.json') + .then(async result => { + const loginData = JSON.parse(result.content); + console.log(loginData); + const {email, password} = loginData; + + await fetch(`http://${ip}/ceo/login`, { + method: 'POST', + headers: { + 'Content-Type': 'application/json', + 'x-api-key': 'uc_api' + }, + body: JSON.stringify({ + email: email, + password: password + }) + }).then(async response => { + if (response.ok) { + await window.electronAPI.killBeforeLogout(); + await window.electronAPI.startMainProcesses(); + fadeOut('main_menu.html'); + } else { + await window.electronAPI.deleteFile('loginData.json'); + } + }).catch(error => { + console.error(error); + }); + }) + .catch(async error => { + console.error('Can\'t read loginData'); + await window.electronAPI.deleteFile('loginData.json'); }); - - if(response.ok) { - window.electronAPI.changeContent('main_menu.html') - .then(() => console.log('Navigated to dashboard')) - .catch(error => console.error('Error navigating:', error)); - } - }).catch(async error => { - console.error('Can\'t read loginData'); - await window.electronAPI.deleteFile('loginData.json') - }); - - signinButton.addEventListener('click', function (e) { - window.electronAPI.changeContent('sign_up_profile.html') - .then(() => console.log('Content changed successfully')) - .catch(error => console.error('Error changing content:', error)); - }); + } submitButton.addEventListener('click', async function (e) { - try { - e.preventDefault(); - console.log('Submit button clicked'); + e.preventDefault(); + console.log('Submit button clicked'); - const form = document.getElementById('loginForm'); - const formData = new FormData(form); + const form = document.getElementById('loginForm'); + const formData = new FormData(form); - const email = formData.get('email'); - const password = formData.get('password'); + const email = formData.get('email'); + const password = formData.get('password'); - if (!email || !password) { - throw new Error('Both email and password are required.'); + await fetch(`http://${ip}/ceo/login`, { + method: 'POST', + headers: { + 'Content-Type': 'application/json', + 'x-api-key': 'uc_api' + }, + body: JSON.stringify({ + email: email, + password: password + }) + }).then(async response => { + if (!response.ok) { + const data = await response.json(); + throw new Error(data.message); } - const response = await fetch('http://localhost:5000/users/login', { - method: 'POST', - headers: { - 'Content-Type': 'application/json', - 'x-api-key': 'uc_api' - }, - body: JSON.stringify({ - email: email, - password: password - }) - }); - - switch (response.status) { - case 401: - throw new Error('Invalid credentials!'); - case 500: - throw new Error('Internal server error. Try again later!'); - } - - const responseBody = await response.json(); - - const result = await window.electronAPI.writeFile('loginData.json', JSON.stringify(responseBody.message, null, 2)); - if (!result.success) { - throw new Error('Error writing to file. Please try again later.'); - } - - window.electronAPI.changeContent('main_menu.html') - .then(() => console.log('Navigated to dashboard')) - .catch(error => console.error('Error navigating:', error)); - - } catch (error) { - await window.electronAPI.showAlert(error.message) - .then(() => console.log('Alert window opened')) - .catch(error => console.error('Error showing alert:', error)); - } + return response.json(); + }).then(async data => { + console.log(data); + await window.electronAPI.writeFile('loginData.json', JSON.stringify(data.data, null, 2)); + await window.electronAPI.startMainProcesses(); + fadeOut('main_menu.html'); + }) + .catch(async error => { + await window.electronAPI.showAlert(error.message) + .then(() => console.log('Alert window opened')) + .catch(error => console.error('Error showing alert:', error)); + }) }); -}); +}); \ No newline at end of file diff --git a/CEO/src/renderer/js/main_menu.js b/CEO/src/renderer/js/main_menu.js index af1d7fd..8335dd0 100644 --- a/CEO/src/renderer/js/main_menu.js +++ b/CEO/src/renderer/js/main_menu.js @@ -1,5 +1,9 @@ document.addEventListener('DOMContentLoaded', async function () { + await insertUsername(); + const backupButton = document.getElementById('backup'); + const shareButton = document.getElementById('share_dir'); + const manageDepartmentButton = document.getElementById('manage_department'); const manageUsersButton = document.getElementById('manage_users'); const changeInfoButton = document.getElementById('change_info'); @@ -7,66 +11,70 @@ document.addEventListener('DOMContentLoaded', async function () { const decryptButton = document.getElementById('decrypt'); const logoutButton = document.getElementById('logout'); - await insertUsername(); + checkDirBackupFileExists() - .then(() => console.log('verificare facuta')); + .then(() => console.log('verificare backupDir facuta')); - - manageUsersButton.addEventListener('click', async function(){ - window.electronAPI.changeContent('manage_users.html') - .then(() => console.log('Navigated to dashboard')) - .catch(error => console.error('Error navigating:', error)); - }); - - manageDepartmentButton.addEventListener('click', async function(){ - window.electronAPI.changeContent('manage_departments.html') - .then(() => console.log('Navigated to dashboard')) - .catch(error => console.error('Error navigating:', error)); - }); + checkShareDirFileExists() + .then(() => console.log('verificare ShareDir facuta')); backupButton.addEventListener('click', function () { console.log('Set backup directory button clicked!'); - window.electronAPI.openBackupDirDialog() + window.electronAPI.openJsonDirConfigDialog('dirBackup.json') .then(() => console.log('Back-up directory set')) .catch(async error => await window.electronAPI.showAlert(error.message) .then(() => console.log('Alert window opened')) .catch(error => console.error('Error showing alert:', error))); }); + shareButton.addEventListener('click', function () { + console.log('Set backup directory button clicked!'); + + window.electronAPI.openJsonDirConfigDialog('dirShare.json') + .then(() => console.log('Back-up directory set')) + .catch(async error => await window.electronAPI.showAlert(error.message) + .then(() => console.log('Alert window opened')) + .catch(error => console.error('Error showing alert:', error))); + }); + + manageUsersButton.addEventListener('click', async function(){ + fadeOut('manage_users.html'); + }); + changeInfoButton.addEventListener('click', function () { console.log('Change your info button clicked!'); + fadeOut('profile.html'); + }); - window.electronAPI.changeContent('profile.html') - .then(() => console.log('Navigated to dashboard')) - .catch(error => console.error('Error navigating:', error)); + decryptButton.addEventListener('click', function () { + fadeOut('decrypting_backup.html'); + }); + + changeInfoButton.addEventListener('click', function () { + console.log('Change your info button clicked!'); + fadeOut('profile.html'); }); shareFileButton.addEventListener('click', function () { console.log('Share a file button clicked!'); - - window.electronAPI.changeContent('share_file.html') - .then(() => console.log('Navigated to dashboard')) - .catch(error => console.error('Error navigating:', error)); + fadeOut('share_file.html'); }); + manageDepartmentButton.addEventListener('click', function() { + fadeOut('manage_departments.html'); + }) + logoutButton.addEventListener('click', async function () { console.log('Logout button clicked!'); - + await window.electronAPI.killBeforeLogout(); await window.electronAPI.deleteFile('loginData.json'); - window.electronAPI.changeContent('login.html') - .then(() => console.log('Navigated to dashboard')) - .catch(error => console.error('Error navigating:', error)); + fadeOut('login.html'); }); decryptButton.addEventListener('click', async function (){ }); - - async function decryptFiles(){ - - } - async function checkDirBackupFileExists() { try { // Make an IPC call to check file existence @@ -78,7 +86,7 @@ document.addEventListener('DOMContentLoaded', async function () { button.id = 'backup_alert'; button.name = 'alert'; button.textContent = 'Set your backup directory!'; - button.addEventListener('click', handleButtonClick); + button.addEventListener('click', handleBackupButtonPressed); notificationsDiv.appendChild(button); } } catch (error) { @@ -86,10 +94,28 @@ document.addEventListener('DOMContentLoaded', async function () { } } - async function handleButtonClick() { + async function checkShareDirFileExists() { + try { + const fileExists = await window.electronAPI.checkFileExists('dirShare.json'); + + if (!fileExists) { + const notificationsDiv = document.getElementById('notifications'); + const button = document.createElement('button'); + button.id = 'share_file_alert'; + button.name = 'alert'; + button.textContent = 'Set your share directory!'; + button.addEventListener('click', handleShareButtonPressed); + notificationsDiv.appendChild(button); + } + } catch (error) { + console.error('Error checking file existence:', error); + } + } + + async function handleBackupButtonPressed() { console.log('Button clicked!'); - await window.electronAPI.openBackupDirDialog() + await window.electronAPI.openJsonDirConfigDialog('dirBackup.json') .then(() => console.log('Back-up directory set')) .catch(async error => await window.electronAPI.showAlert(error.message) .then(() => console.log('Alert window opened')) @@ -99,6 +125,19 @@ document.addEventListener('DOMContentLoaded', async function () { button.remove(); } + async function handleShareButtonPressed() { + console.log('Button clicked!'); + + await window.electronAPI.openJsonDirConfigDialog('dirShare.json') + .then(() => console.log('Share directory set')) + .catch(async error => await window.electronAPI.showAlert(error.message) + .then(() => console.log('Alert window opened')) + .catch(error => console.error('Error showing alert:', error))); + + const button = document.getElementById('backup_alert'); + button.remove(); + } + async function insertUsername() { try { const userData = await window.electronAPI.readFile('loginData.json'); diff --git a/CEO/src/renderer/js/manage_departments.js b/CEO/src/renderer/js/manage_departments.js index c0ac99d..4db7261 100644 --- a/CEO/src/renderer/js/manage_departments.js +++ b/CEO/src/renderer/js/manage_departments.js @@ -1,69 +1,175 @@ -document.addEventListener('DOMContentLoaded', function() { - const list = document.getElementById('security_level_form_content'); - let draggedItem = null; +document.addEventListener('DOMContentLoaded', async function () { + let ip = ''; + await window.electronAPI.readFile('ipConfig.json') + .then(result => { + const jsonData = JSON.parse(result.content); + ip = jsonData.ip; + }) - for (const item of list.querySelectorAll('li')) { - item.setAttribute('draggable', true); + const result = await window.electronAPI.readFile('loginData.json'); + const loginData = JSON.parse(result.content); + const password = loginData.password; - item.addEventListener('dragstart', function(e) { - draggedItem = this; - setTimeout(() => this.classList.add('hide'), 0); - }); + const backButton = document.querySelector('button[name="back"]'); + const createButton = document.querySelector('button[name="create"]'); + const submitButton = document.querySelector('button[name="submit"]'); - item.addEventListener('dragend', function(e) { - setTimeout(() => this.classList.remove('hide'), 0); - }); + backButton.addEventListener('click', function () { + fadeOut('main_menu.html'); + console.log('Back button clicked'); + }); - item.addEventListener('dragover', function(e) { - e.preventDefault(); - }); + createButton.addEventListener('click', async function (e) { + e.preventDefault(); + const departmentName = document.querySelector('input[name="text"]').value; + if (!departmentName) { + await window.electronAPI.showAlert('Department name is required.') + .then(() => console.log('Alert window opened')) + .catch(error => console.error('Error showing alert:', error)); + return; // Exit if no name is provided + } + console.log(`Creating department: ${departmentName}`); - item.addEventListener('dragenter', function(e) { - e.preventDefault(); - this.classList.add('over'); - }); + const url = `http://${ip}/ceo/departments`; + const headers = { + 'Content-Type': 'application/json', + 'x-api-key': 'uc_api', + 'ceo_password': password + }; + console.log(headers); + console.log(password); + const body = JSON.stringify({ name: departmentName }); - item.addEventListener('dragleave', function(e) { - this.classList.remove('over'); - }); + try { + const response = await fetch(url, { + method: 'POST', + headers: headers, + body: body + }); - item.addEventListener('drop', function(e) { - e.preventDefault(); - this.classList.remove('over'); - if (this !== draggedItem) { - const items = Array.from(list.querySelectorAll('li')); - const draggedIndex = items.indexOf(draggedItem); - const droppedIndex = items.indexOf(this); - - if (draggedIndex < droppedIndex) { - this.after(draggedItem); - } else { - this.before(draggedItem); - } + if (response.ok) { + const data = await response.json(); + await window.electronAPI.showAlert(data.message); + document.querySelector('input[name="text"]').value = ''; + fadeOut('manage_departments.html'); + } else { + console.log("eroare"); + const errorData = await response.json(); + await window.electronAPI.showAlert(errorData.message) + .then(() => console.log('Alert window opened')) + .catch(error => console.error('Error showing alert:', error)); } - }); - } -}); + } catch (error) { + console.log("error"); + await window.electronAPI.showAlert(error) + .then(() => console.log('Alert window opened')) + .catch(error => console.error('Error showing alert:', error)); + } + }); -function saveOrder() { - const listItems = document.querySelectorAll('#security_level_form_content li'); - const order = Array.from(listItems).map(item => item.textContent.trim()); - localStorage.setItem('listOrder', JSON.stringify(order)); -} + submitButton.addEventListener('click', function () { + // Handle the "Submit" button functionality here + console.log('Submit button clicked'); + saveOrder(); + }); -function loadOrder() { - const storedOrder = JSON.parse(localStorage.getItem('listOrder')); - if (storedOrder) { + document.addEventListener('DOMContentLoaded', function () { const list = document.getElementById('security_level_form_content'); - list.innerHTML = ''; - storedOrder.forEach(itemText => { - const li = document.createElement('li'); - li.textContent = itemText; - li.setAttribute('draggable', true); - list.appendChild(li); - }); - } -} + let draggedItem = null; -// Call loadOrder to initialize the list with the saved order -loadOrder(); + for (const item of list.querySelectorAll('li')) { + item.setAttribute('draggable', true); + + item.addEventListener('dragstart', function (e) { + draggedItem = this; + setTimeout(() => this.classList.add('hide'), 0); + }); + + item.addEventListener('dragend', function (e) { + setTimeout(() => this.classList.remove('hide'), 0); + }); + + item.addEventListener('dragover', function (e) { + e.preventDefault(); + }); + + item.addEventListener('dragenter', function (e) { + e.preventDefault(); + this.classList.add('over'); + }); + + item.addEventListener('dragleave', function (e) { + this.classList.remove('over'); + }); + + item.addEventListener('drop', function (e) { + e.preventDefault(); + this.classList.remove('over'); + if (this !== draggedItem) { + const items = Array.from(list.querySelectorAll('li')); + const draggedIndex = items.indexOf(draggedItem); + const droppedIndex = items.indexOf(this); + + if (draggedIndex < droppedIndex) { + this.after(draggedItem); + } else { + this.before(draggedItem); + } + } + }); + } + }); + + function saveOrder() { + const listItems = document.querySelectorAll('#security_level_form_content li'); + const order = Array.from(listItems).map(item => item.textContent.trim()); + } + + async function loadOrder() { + const url = `http://${ip}/users/departments`; // Replace {serverip} with the actual IP address of the server + + try { + const response = await fetch(url, { + method: 'GET', + headers: { + 'Content-Type': 'application/json', + 'x-api-key': 'uc_api' + } + }); + + if (response.ok) { + let departments = await response.json(); + const list = document.getElementById('security_level_form_content'); + list.innerHTML = ''; // Clear existing items + departments = departments.data; + + // Check if there's a stored order in localStorage and reorder the departments array accordingly + const storedOrder = JSON.parse(localStorage.getItem('listOrder')); + if (storedOrder) { + storedOrder.forEach(itemKey => { + if (departments[itemKey]) { + appendDepartmentToList(departments[itemKey], list); + } + }); + } else { + Object.keys(departments).forEach(key => { + appendDepartmentToList(departments[key], list);}); + } + } else { + console.error('Failed to fetch departments:', response.status); + } + } catch (error) { + console.error('Error making the request:', error); + } + } + + function appendDepartmentToList(department, list) { + const li = document.createElement('li'); + li.textContent = department.name; + li.id = `department-${department.key}`; // Use a unique ID if possible, here it's prefixed with 'department-' + li.setAttribute('draggable', true); + list.appendChild(li); + } + + await loadOrder(); +}); diff --git a/CEO/src/renderer/js/manage_users.js b/CEO/src/renderer/js/manage_users.js index e69de29..72f49ca 100644 --- a/CEO/src/renderer/js/manage_users.js +++ b/CEO/src/renderer/js/manage_users.js @@ -0,0 +1,94 @@ +document.addEventListener('DOMContentLoaded', async function() { + let ip = ''; + await window.electronAPI.readFile('ipConfig.json') + .then(result => { + const jsonData = JSON.parse(result.content); + ip = jsonData.ip; + }) + + const result = await window.electronAPI.readFile('loginData.json'); + const loginData = JSON.parse(result.content); + const password = loginData.password; + const ceoId = loginData.id; + + const loadUsers = (async () => { + const url = `http://${ip}/users`; + + try { + const response = await fetch(url, { + method: 'GET', + headers: { + 'x-api-key': 'uc_api' + } + }); + if (response.ok) { + let users = await response.json(); + users = users.data; + const formContent = document.querySelector('.signup-form-content'); + formContent.innerHTML = ''; + + users.forEach(user => { + if(user.id !== ceoId) { + const label = document.createElement('label'); + const radioInput = document.createElement('input'); + radioInput.type = 'radio'; + radioInput.name = 'dept'; + radioInput.value = user.id; // Set user ID as value + label.appendChild(radioInput); + label.appendChild(document.createTextNode(user.name)); // User's name for display + formContent.appendChild(label); + } + }); + } else { + console.error('Failed to fetch users:', response.status); + } + } catch (error) { + console.error('Error making the request:', error); + } + }); + + await loadUsers(); + + const deleteButton = document.querySelector('button[name="delete"]'); + deleteButton.addEventListener('click', async function(event) { + event.preventDefault(); // Prevent the default form submission + const selectedUser = document.querySelector('input[type="radio"][name="dept"]:checked'); + + if (!selectedUser) { + await window.electronAPI.showAlert('Please select a user to delete.') + .then(() => console.log('Alert window opened')) + .catch(error => console.error('Error showing alert:', error)); + return; + } + + const userId = selectedUser.value; + const deleteUrl = `http://${ip}/ceo/users/${userId}`; + + try { + const response = await fetch(deleteUrl, { + method: 'DELETE', + headers: { + 'Content-Type': 'application/json', + 'x-api-key': 'uc_api', + 'ceo_password': password + } + }); + const data = await response.json(); + + await window.electronAPI.showAlert(data.message) + .then(() => console.log('Alert window opened')) + .catch(error => console.error('Error showing alert:', error)); + fadeOut('manage_users.html'); + } catch (error) { + await window.electronAPI.showAlert(error.message) + .then(() => console.log('Alert window opened')) + .catch(error => console.error('Error showing alert:', error)); + } + }); + + const backButton = document.querySelector('button[name="back"]'); + backButton.addEventListener('click', function() { + fadeOut('main_menu.html'); + console.log('Back button clicked'); + }); +}); diff --git a/CEO/src/renderer/js/profile.js b/CEO/src/renderer/js/profile.js index c1205ec..f679f7b 100644 --- a/CEO/src/renderer/js/profile.js +++ b/CEO/src/renderer/js/profile.js @@ -1,65 +1,59 @@ document.addEventListener('DOMContentLoaded', async function () { - try { - const result = await window.electronAPI.readFile('loginData.json'); - const loginData = JSON.parse(result.content); - // Set values for the inputs - const emailInput = document.querySelector('input[name="email"]'); - const usernameInput = document.querySelector('input[name="username"]'); + let ip = ''; + await window.electronAPI.readFile('ipConfig.json') + .then(result => { + const jsonData = JSON.parse(result.content); + ip = jsonData.ip; + }) - emailInput.value = loginData.email; - usernameInput.value = loginData.name; + const result = await window.electronAPI.readFile('loginData.json'); + const loginData = JSON.parse(result.content); - } catch (error) { - console.error('Error reading login data:', error); - } + const emailInput = document.querySelector('input[name="email"]'); + const usernameInput = document.querySelector('input[name="username"]'); + + emailInput.value = loginData.email; + usernameInput.value = loginData.name; + const password = loginData.password; const backButton = document.querySelector('button[name="login"]'); const submitButton = document.querySelector('button[name="submit"]'); - // Add event listeners for the back and submit buttons backButton.addEventListener('click', function () { console.log('Back button clicked!'); - - window.electronAPI.changeContent('main_menu.html') - .then(() => console.log('Navigated to dashboard')) - .catch(error => console.error('Error navigating:', error)); + fadeOut('main_menu.html') }); submitButton.addEventListener('click', async function (e) { - try { - e.preventDefault(); - console.log('Submit button clicked!'); + e.preventDefault(); + console.log('Submit button clicked!'); - const emailInput = document.querySelector('input[name="email"]'); - const usernameInput = document.querySelector('input[name="username"]'); + const emailInput = document.querySelector('input[name="email"]'); + const usernameInput = document.querySelector('input[name="username"]'); - const result = await window.electronAPI.readFile('loginData.json'); - const loginData = JSON.parse(result.content); + const result = await window.electronAPI.readFile('loginData.json'); + const loginData = JSON.parse(result.content); - const {id, department} = loginData; - const email = emailInput.value; - const name = usernameInput.value; + const {id, department} = loginData; + const email = emailInput.value; + const name = usernameInput.value; - const response = await fetch(`http://localhost:5000/users/${id}`, { - method: 'PUT', - headers: { - 'Content-Type': 'application/json', - 'x-api-key': 'uc_api' - }, - body: JSON.stringify({ - name: name, - email: email, - }) - }); - - switch (response.status) { - case 400: - throw new Error('Email format invalid!') - case 409: - throw new Error('Email already in system!') - case 500: - throw new Error('Internal server error. Try again later!') + await fetch(`http://${ip}/ceo`, { + method: 'PUT', + headers: { + 'Content-Type': 'application/json', + 'x-api-key': 'uc_api', + 'ceo_password': password + }, + body: JSON.stringify({ + name: name, + email: email, + }) + }).then(async result => { + const data = await result.json(); + if (!result.ok) { + throw new Error(data.message); } await window.electronAPI.writeFile('loginData.json', JSON.stringify({ @@ -70,13 +64,11 @@ document.addEventListener('DOMContentLoaded', async function () { department: department })); - window.electronAPI.changeContent('main_menu.html') - .then(() => console.log('Navigated to dashboard')) - .catch(error => console.error('Error navigating:', error)); - }catch(error) { + fadeOut('main_menu.html'); + }).catch(async error => { await window.electronAPI.showAlert(error.message) .then(() => console.log('Alert window opened')) .catch(error => console.error('Error showing alert:', error)); - } + }) }); }); diff --git a/CEO/src/renderer/js/share_file.js b/CEO/src/renderer/js/share_file.js index 4a64652..aa0d0f6 100644 --- a/CEO/src/renderer/js/share_file.js +++ b/CEO/src/renderer/js/share_file.js @@ -1,5 +1,11 @@ -document.addEventListener("DOMContentLoaded", function() { +document.addEventListener("DOMContentLoaded", async function () { let pathToFile = ''; + let serverIp = ''; + await window.electronAPI.readFile('ipConfig.json') + .then(result => { + const jsonData = JSON.parse(result.content); + ip = jsonData.ip; + }) function updateFileName() { const fileNameElement = document.getElementById('fileName'); @@ -10,7 +16,6 @@ document.addEventListener("DOMContentLoaded", function() { } } - // Call the function to update file name on DOMContentLoaded updateFileName(); async function fetchUsersAndCreateCheckboxes() { @@ -19,7 +24,7 @@ document.addEventListener("DOMContentLoaded", function() { const {id} = loginData; - fetch('http://localhost:5000/users', { + fetch(`http://${serverIp}/users`, { method: 'GET', headers: { 'x-api-key': 'uc_api' @@ -60,45 +65,65 @@ document.addEventListener("DOMContentLoaded", function() { document.getElementById('backButton').addEventListener('click', async function () { console.log('Back button clicked'); - - try { - await window.electronAPI.changeContent('main_menu.html'); - console.log('Content changed successfully'); - } catch (error) { - console.error('Error changing content:', error); - } + fadeOut('main_menu.html'); }); document.getElementById('submitButton').addEventListener('click', async function (event) { event.preventDefault(); console.log('Submit button clicked'); - if (pathToFile === '' || pathToFile.length === 0) { + const fileInput = document.getElementById('fileInput'); + if (!fileInput.files.length) { await window.electronAPI.showAlert('File not chosen!') .then(() => console.log('Alert window opened')) - .catch(error => console.error('Error changing content:', error)); - return + .catch(error => console.error('Error showing alert:', error)); + return; } const form = document.getElementById('userDestForm'); const checkboxes = form.querySelectorAll('input[name="users"]'); - const selectedUserIds = []; + const selectedUserIds = Array.from(checkboxes) + .filter(checkbox => checkbox.checked) + .map(checkbox => checkbox.value); - checkboxes.forEach(checkbox => { - if (checkbox.checked) { - selectedUserIds.push(checkbox.value); - } - }); - - if(selectedUserIds === []){ + if (!selectedUserIds.length) { await window.electronAPI.showAlert('No user selected!') .then(() => console.log('Alert window opened')) - .catch(error => console.error('Error changing content:', error)); + .catch(error => console.error('Error showing alert:', error)); return; } - //TODO: logic to send files + const uploadData = { + filePath: fileInput.files[0].path, + users: [] + }; + + for (const userId of selectedUserIds) { + try { + const ipResponse = await fetch(`http://${serverIp}/backup_schemes/${userId}`); + if (!ipResponse.ok) { + throw new Error(`Failed to fetch IP address for user ${userId}: status ${ipResponse.status}`); + } + const { data: destIp } = await ipResponse.json(); + uploadData.users.push({ + userId, + destIp, + destPort: 3000, // Static destination port + fileName: fileInput.files[0].name + }); + } catch (error) { + console.error('Error fetching user data:', error); + } + } + + window.electronAPI.writeFile('usersDestTemp.json', JSON.stringify(uploadData)) + .then(() => { + console.log('File saved successfully'); + fadeOut('sending_file_confirmation.html'); + }) + .catch(error => console.error('Failed to save file:', error)); }); + fetchUsersAndCreateCheckboxes().then(() => console.log('Page rendered')) }); diff --git a/CEO/src/renderer/js/sign_up_confirmation.js b/CEO/src/renderer/js/sign_up_confirmation.js deleted file mode 100644 index c13607f..0000000 --- a/CEO/src/renderer/js/sign_up_confirmation.js +++ /dev/null @@ -1,7 +0,0 @@ -document.addEventListener('DOMContentLoaded', async function() { - await new Promise(resolve => setTimeout(resolve, 2000)); - - window.electronAPI.changeContent('login.html') - .then(() => console.log('Content changed successfully')) - .catch(error => console.error('Error changing content:', error)); -}); diff --git a/CEO/src/renderer/js/sign_up_departments.js b/CEO/src/renderer/js/sign_up_departments.js deleted file mode 100644 index 4d08d0d..0000000 --- a/CEO/src/renderer/js/sign_up_departments.js +++ /dev/null @@ -1,93 +0,0 @@ -document.addEventListener('DOMContentLoaded', async function() { - try { - // Make API call to fetch department data - const response = await fetch('http://localhost:5000/departments', { - method: 'GET', - headers: { - 'x-api-key': 'uc_api' - } - }); - const res = await response.json(); - const data = res['data']; - - const formContent = document.querySelector('.signup-form-content'); - data.forEach(department => { - const label = document.createElement('label'); - label.innerHTML = `${department.name}`; - formContent.appendChild(label); - }); - } catch (error) { - await window.electronAPI.showAlert(error.message) - .then(() => console.log('Alert window opened')) - .catch(error => console.error('Error changing content:', error)); - } - - document.getElementById('back').addEventListener('click', async function() { - try { - await window.electronAPI.changeContent('sign_up_profile.html'); - console.log('Content changed successfully'); - } catch (error) { - console.error('Error changing content:', error); - } - }); - - // Handler for the continue button - document.getElementById('submit').addEventListener('click', async function(e) { - e.preventDefault(); - - const selectedDept = document.querySelector('input[name="dept"]:checked').value; - - try { - if (!selectedDept) { - throw new Error('No department had been selected!.'); - } - - let result = await window.electronAPI.readFile('signupData.json'); - if (!result.success) { - throw new Error('Error reading the file. Please try again later.'); - } - - const data = JSON.parse(result.content); - - const email = data.email; - const name = data.name; - const password = data.password; - - result = await window.electronAPI.deleteFile('signupData.json'); - if (!result.success) { - throw new Error('Error deleting the file. Please try again later.'); - } - - await fetch('http://localhost:5000/users/register', { - method: 'POST', - headers: { - 'Content-Type': 'application/json', - 'x-api-key': 'uc_api' - }, - body: JSON.stringify({ - name: name, - email: email, - password: password, - department: selectedDept, - }) - }).then(async response => { - if(!response.ok){ - await window.electronAPI.showAlert("Internal server error. Try again later!") - .then(() => console.log('Alert window opened')) - .catch(error => console.error('Error changing content:', error)); - } - - window.electronAPI.changeContent('sign_up_confirmation.html') - .then(() => console.log('Content changed successfully')) - .catch(error => console.error('Error changing content:', error)); - }).catch(error => { - console.error(error); - }); - - } catch (error) { - await window.electronAPI.showAlert(error.message) - .then(() => console.log('Alert window opened')) - .catch(error => console.error('Error changing content:', error)); - } - }); -}); diff --git a/CEO/src/renderer/js/sign_up_profile.js b/CEO/src/renderer/js/sign_up_profile.js deleted file mode 100644 index a9cfb63..0000000 --- a/CEO/src/renderer/js/sign_up_profile.js +++ /dev/null @@ -1,81 +0,0 @@ -document.addEventListener('DOMContentLoaded', function () { - const cancelButton = document.getElementById('login'); - const continueButton = document.getElementById('continue'); - - cancelButton.addEventListener('click', function () { - console.log(`'Login' button clicked!`); - window.electronAPI.changeContent('login.html') - .then(() => console.log('Content changed successfully')) - .catch(error => console.error('Error changing content:', error)); - }); - - continueButton.addEventListener('click', async function (e) { - try { - e.preventDefault(); - console.log('Continue button clicked'); - - const form = document.getElementById('signupForm'); - const formData = new FormData(form); - - const email = formData.get('email'); - const name = formData.get('name'); - const password = formData.get('password'); - - if (!email || !name || !password) { - throw new Error('All fields are required.'); - } - - if(password.length < 8){ - throw new Error('Password must have minimum length 8!'); - } - - let statusFetch = 200; - - await fetch('http://localhost:5000/users/validate_email', { - method: 'POST', - headers: { - 'Content-Type': 'application/json', - 'x-api-key': 'uc_api' - }, - body: JSON.stringify({ - email: email - }) - }).then(async response => { - const responseData = await response.json(); - statusFetch = response.status; - console.error(responseData.message); - }) - .catch(error => { - console.log(error); - }) - - switch(statusFetch){ - case 500: - throw new Error('Internal server error! Try again later'); - case 400: - throw new Error('Not a valid email!'); - case 409: - throw new Error('Email already exists in system!'); - } - - const formDataJSON = {}; - formData.forEach((value, key) => { - formDataJSON[key] = value; - }); - - const result = await window.electronAPI.writeFile('signupData.json', JSON.stringify(formDataJSON)); - if (!result.success) { - throw new Error('Error writing to file. Please try again later.'); - } - - window.electronAPI.changeContent('sign_up_departments.html') - .then(() => console.log('Content changed successfully')) - .catch(error => console.error('Error changing content:', error)); - } - catch (error) { - await window.electronAPI.showAlert(error.message) - .then(() => console.log('Alert window opened')) - .catch(error => console.error('Error changing content:', error));; - } - }); -}); \ No newline at end of file diff --git a/CEO/src/renderer/js/transition.js b/CEO/src/renderer/js/transition.js new file mode 100644 index 0000000..b5cb1c8 --- /dev/null +++ b/CEO/src/renderer/js/transition.js @@ -0,0 +1,16 @@ +function fadeIn() { + document.querySelector('.container').classList.remove('fade-out'); + document.querySelector('.container').classList.add('fade-in'); +} + +function fadeOut(destination) { + const container = document.querySelector('.container'); + container.classList.remove('fade-in'); + container.classList.add('fade-out'); + + container.addEventListener('animationend', async () => { + await window.electronAPI.changeContent(destination) + .then(() => console.log('Navigated to dashboard')) + .catch(error => console.error('Error navigating:', error)); + }); +} \ No newline at end of file diff --git a/CEO/usersInSystem.json b/CEO/usersInSystem.json new file mode 100644 index 0000000..9069ec4 Binary files /dev/null and b/CEO/usersInSystem.json differ diff --git a/UC/backend/src/db/backup_schemes.json b/UC/backend/src/db/backup_schemes.json index 2cb1939..9e26dfe 100644 --- a/UC/backend/src/db/backup_schemes.json +++ b/UC/backend/src/db/backup_schemes.json @@ -1,7 +1 @@ -{ - "4659e71f-9bb4-4902-97d8-097efa138333": { - "ip": "192.168.0.195", - "directoryStructure": "{\"to_backup\":{\"files\":[\"fisier_random.txt\"],\"alte fis\":{\"files\":[\"alt fisier.txt\",\"fisier now.txt\",\"New Microsoft Excel Worksheet.xlsx\"]}}}", - "totalSize": 6197 - } -} \ No newline at end of file +{} \ No newline at end of file diff --git a/UC/backend/src/db/ceo.json b/UC/backend/src/db/ceo.json index f18b767..199d171 100644 --- a/UC/backend/src/db/ceo.json +++ b/UC/backend/src/db/ceo.json @@ -1,6 +1,7 @@ { - "id": "335ae110091d3bc5fbc90d5e3786890e", + "id": "7c0ef9d5-23ed-47a6-bfb4-fdcfce436904", "name": "CEO", "email": "ceo@yourfirm.com", - "password": "335ae110091d3bc5fbc90d5e3786890e" + "password": "b85cfc54e8dda76e72d7bde7b10ce30a", + "department": "CEO" } \ No newline at end of file diff --git a/UC/backend/src/db/departments.json b/UC/backend/src/db/departments.json index 69291c4..4a5578f 100644 --- a/UC/backend/src/db/departments.json +++ b/UC/backend/src/db/departments.json @@ -1,10 +1,10 @@ { "1": { - "name": "HR", - "key": "65388e02b16e1cc530502492384ebd29ee6cda57840235d714d59dd460ae148a" + "name": "CEO", + "key": "6f444243063271cc1ea3ccb3621dfebc352fd40e2f58eb6c97b26b7e34fde7a1" }, "2": { - "name": "Contabili", - "key": "572854d54c42f03ddcbb2beeae574dc4fcd33b251670d4983be49c4242c2d88a" + "name": "HR", + "key": "2c480e5e3fdaca10d4d838b1b16fb44ce0f57238cb4343a839e065f8d6e41dc7" } } \ No newline at end of file diff --git a/UC/backend/src/db/users.json b/UC/backend/src/db/users.json index 276727e..c4f4142 100644 --- a/UC/backend/src/db/users.json +++ b/UC/backend/src/db/users.json @@ -1,9 +1,9 @@ [ { - "id": "4659e71f-9bb4-4902-97d8-097efa138333", + "id": "59c712d9-e6dd-438f-aec9-31ca2ae750e6", "name": "Andrei Cerbu", "email": "a@c.com", "password": "5447045dc3cfaafdb49b365e31dad41eb88616b0b1449930e55fd3a70bd8cee4", - "department": "Contabili" + "department": "HR" } ] \ No newline at end of file diff --git a/UC/backend/src/routes/admin.js b/UC/backend/src/routes/admin.js index 8180b3b..7e71f4b 100644 --- a/UC/backend/src/routes/admin.js +++ b/UC/backend/src/routes/admin.js @@ -26,15 +26,26 @@ router.get('/reset_server', validateBody, (req, res) => { const ceoDB = req.app.get('ceoDB'); usersDB.writeFile([]); - departmentsDB.writeFile([]); + departmentsDB.writeFile({}); backupSchemesDB.writeFile({}); ceoDB.writeFile({ id: uuidv4(), name: "CEO", email: "ceo@yourfirm.com", - password: crypto.randomBytes(16).toString('hex') + password: crypto.randomBytes(16).toString('hex'), + department: "CEO" }); + const ceoDepartment = { + name: "CEO", + key: crypto.randomBytes(32).toString('hex') + + } + + const departmentsJson = departmentsDB.readFile(); + departmentsJson[1] = ceoDepartment; + departmentsDB.writeFile(departmentsJson); + res.status(httpStatus.OK).json({ message: "Resetting the server..." }); }); diff --git a/UC/backend/src/routes/backup_schemes.js b/UC/backend/src/routes/backup_schemes.js index 73cf8e5..ecf3c53 100644 --- a/UC/backend/src/routes/backup_schemes.js +++ b/UC/backend/src/routes/backup_schemes.js @@ -44,6 +44,18 @@ router.get('/', validateBody, (req, res) => { }); }); +router.get('/:userId', (req, res) => { + const userId = req.params.userId; + const backupSchemesDB = req.app.get('backupSchemesDB'); + let backupSchemesJson = backupSchemesDB.readFile(); + const ip = backupSchemesJson[userId].ip; + if (ip) { + res.status(httpStatus.OK).json({message: "IP found", data: ip}); + } else { + res.status(httpStatus.NOT_FOUND).send({message: "IP not found"}); + } +}); + router.use((req, res) => { return res.status(httpStatus.NOT_FOUND).json({message: "Endpoint not found"}); }) diff --git a/UC/backend/src/routes/ceo.js b/UC/backend/src/routes/ceo.js index 32301f6..a17b7f5 100644 --- a/UC/backend/src/routes/ceo.js +++ b/UC/backend/src/routes/ceo.js @@ -59,7 +59,7 @@ router.post('/login', validateBody, (req, res) => { return res.status(httpStatus.UNAUTHORIZED).json({message: 'Invalid credentials.'}); } - return res.status(httpStatus.Ok).json({message: 'Logged in.'}); + return res.status(httpStatus.OK).json({message: 'Logged in.', data: ceoDB.readFile()}); }); router.post('/set_security_levels', validateBody, (req, res) => { @@ -99,13 +99,16 @@ router.delete('/users/:id', validateBody, (req, res) => { const usersDB = req.app.get('usersDB'); const { id } = req.params; - const userIndex = usersDB.findIndexByKeyValueInArray('id', id); - if(userIndex === -1){ + let usersJson = usersDB.readFile(); + + const userIndex = usersJson.findIndex(user => user.id === id); + if (userIndex === -1) { return res.status(httpStatus.NOT_FOUND).json({message: 'User not found in system.'}); } - let usersJson = usersDB.readFile; usersJson.splice(userIndex, 1); + + usersDB.writeFile(usersJson); return res.status(httpStatus.OK).json({ message: 'User deleted successfully.' }); @@ -114,6 +117,7 @@ router.delete('/users/:id', validateBody, (req, res) => { router.post('/departments', validateBody, (req, res) => { const departmentsDB = req.app.get('departmentsDB'); const { name } = req.body; + console.log(name); let jsonDepartments = departmentsDB.readFile(); const nameExists = Object.values(jsonDepartments).some(department => department.name === name); @@ -164,17 +168,18 @@ router.delete('/departments/:name', validateBody, (req, res) => { router.put('/', validateBody, (req, res) => { const ceoDB = req.app.get('ceoDB'); const { name, email } = req.body; - const {id} = ceoDB.readFile() + const {id, department} = ceoDB.readFile() const newCeo = { id: id, name: name, email: email, - password: crypto.randomBytes(16).toString('hex') + password: crypto.randomBytes(16).toString('hex'), + department: department } ceoDB.writeFile(newCeo); - return res.status(httpStatus.OK).json({message: 'Information modified.'}); + return res.status(httpStatus.OK).json({message: 'Information modified.', data: newCeo}); }); router.get('/get_decrypt_keys', (req, res) => { diff --git a/User/backupSchemes.json b/User/backupSchemes.json index 2cb1939..534d971 100644 --- a/User/backupSchemes.json +++ b/User/backupSchemes.json @@ -2,6 +2,6 @@ "4659e71f-9bb4-4902-97d8-097efa138333": { "ip": "192.168.0.195", "directoryStructure": "{\"to_backup\":{\"files\":[\"fisier_random.txt\"],\"alte fis\":{\"files\":[\"alt fisier.txt\",\"fisier now.txt\",\"New Microsoft Excel Worksheet.xlsx\"]}}}", - "totalSize": 6197 + "totalSize": 8482 } } \ No newline at end of file diff --git a/User/dirBackup.json b/User/dirBackup.json index 580e37a..8731abf 100644 --- a/User/dirBackup.json +++ b/User/dirBackup.json @@ -14,5 +14,5 @@ } } }, - "size": 6197 + "size": 8482 } \ No newline at end of file diff --git a/User/dirDepartment.json b/User/dirDepartment.json new file mode 100644 index 0000000..bd927e8 --- /dev/null +++ b/User/dirDepartment.json @@ -0,0 +1,3 @@ +{ + "path": "C:\\Users\\Andrei Cerbu\\Documents\\department_shared_files" +} \ No newline at end of file diff --git a/User/dirShare.json b/User/dirShare.json new file mode 100644 index 0000000..766b39f --- /dev/null +++ b/User/dirShare.json @@ -0,0 +1,3 @@ +{ + "path": "C:\\Users\\Andrei Cerbu\\Documents\\share_directory" +} \ No newline at end of file diff --git a/User/jobs/backup.js b/User/jobs/backup.js index cc342c3..3a0c8ae 100644 --- a/User/jobs/backup.js +++ b/User/jobs/backup.js @@ -1,8 +1,27 @@ -const fs = require('fs').promises; // Ensure you use the promise-based API +const fsPromises = require('fs').promises; // Ensure you use the promise-based API +const fs = require('fs'); const path = require('path'); const { decryptFileInPlace, encryptFileInPlace, encryptFileWithKey, decryptFileWithKey} = require("../src/main/aes_encrypt"); const {lockFile, unlockFile} = require("../helpers/lock_mechanism"); +async function decryptAndGetServerIP(filePath) { + try { + await lockFile(filePath); + await decryptFileInPlace(filePath); + + const fileContent = await fs.promises.readFile(filePath, 'utf8'); + const jsonData = JSON.parse(fileContent); + const serverIP = jsonData.ip; + + await encryptFileInPlace(filePath) + await unlockFile(filePath); + return serverIP; + } catch (error) { + console.error('An error occurred:', error); + return null; + } +} + function extractFilePaths(directoryStructure) { let paths = []; const traverse = (dir, currentPath) => { @@ -48,31 +67,32 @@ async function fetchFiles(ip, filePaths) { async function removeDirectory(directoryPath) { try { // Check if the directory exists - const stats = await fs.stat(directoryPath); + const stats = await fsPromises.stat(directoryPath); if (!stats.isDirectory()) { console.log('The specified path is not a directory.'); return; } // Read all the contents of the directory - const files = await fs.readdir(directoryPath); + const files = await fsPromises.readdir(directoryPath); // Loop through each file/directory and delete them for (const file of files) { const currentPath = path.join(directoryPath, file); - const currentStats = await fs.stat(currentPath); + const currentStats = await fsPromises.stat(currentPath); if (currentStats.isDirectory()) { // Recursive call for directories await removeDirectory(currentPath); } else { - // Delete file - await fs.unlink(currentPath); + await lockFile(currentPath); + await unlockFile(currentPath); + await fsPromises.unlink(currentPath); } } // Finally, delete the directory itself - await fs.rmdir(directoryPath); + await fsPromises.rmdir(directoryPath); //console.log(`Directory removed: ${directoryPath}`); } catch (error) { console.error(`Error removing directory: ${error.message}`); @@ -87,23 +107,28 @@ async function decryptUserSystemConfig() { async function encryptUserSystemConfig(){ const configPath = path.join(__dirname, '..', 'usersInSystem.json'); - await unlockFile(configPath); await encryptFileInPlace(configPath); + await unlockFile(configPath); } async function processBackup() { - await decryptUserSystemConfig(); const usersConfigPath = path.join(__dirname, '..', 'usersInSystem.json'); const backupConfigPath = path.join(__dirname, '..', 'backupSchemes.json'); const baseBackupDirPath = path.join(__dirname, '..', 'backup_directories'); + if(!fs.existsSync(backupConfigPath) || !fs.existsSync(usersConfigPath)){ + console.log('Can\'t start backup system: necessary files missing!'); + return; + } + + await decryptUserSystemConfig(); try { // Read and parse the users configuration - const usersData = await fs.readFile(usersConfigPath, 'utf8'); + const usersData = await fsPromises.readFile(usersConfigPath, 'utf8'); const usersConfig = JSON.parse(usersData); // Read and parse the backup configuration - const backupData = await fs.readFile(backupConfigPath, 'utf8'); + const backupData = await fsPromises.readFile(backupConfigPath, 'utf8'); const jsonData = JSON.parse(backupData); for (const key in jsonData) { @@ -115,7 +140,7 @@ async function processBackup() { const filePaths = extractFilePaths(directoryStructure); const files = await fetchFiles(node.ip, filePaths); - await fs.mkdir(userBackupDir, { recursive: true }); + await fsPromises.mkdir(userBackupDir, { recursive: true }); // Find the encryption key for the user's department let encryptionKey = ''; @@ -129,8 +154,8 @@ async function processBackup() { for (const file in files) { if (files[file]) { const fullPath = path.join(userBackupDir, file); - await fs.mkdir(path.dirname(fullPath), { recursive: true }); - await fs.writeFile(fullPath, files[file]); // Write the binary data + await fsPromises.mkdir(path.dirname(fullPath), { recursive: true }); + await fsPromises.writeFile(fullPath, files[file]); // Write the binary data // Encrypt the file in place after writing it if (encryptionKey) { @@ -149,7 +174,7 @@ async function processBackup() { async function getAllFilePaths(dirPath) { let filePaths = []; async function recurse(currentPath) { - const entries = await fs.readdir(currentPath, { withFileTypes: true }); + const entries = await fsPromises.readdir(currentPath, { withFileTypes: true }); // Create promises for each entry and process them in parallel const entryPromises = entries.map(async (entry) => { const resolvedPath = path.join(currentPath, entry.name); @@ -168,12 +193,19 @@ async function getAllFilePaths(dirPath) { return filePaths; } -async function decryptUserFilesToDirectory(destinationDir) { - await decryptUserSystemConfig(); // Ensure user config is decrypted +async function decryptBackupFilesToDirectory(destinationDir) { + await decryptUserSystemConfig(); const usersConfigPath = path.join(__dirname, '..', 'usersInSystem.json'); - const usersConfig = JSON.parse(await fs.readFile(usersConfigPath, 'utf8')); + + if(!fs.existsSync(usersConfigPath)){ + return false; + } + + const usersConfig = JSON.parse(await fsPromises.readFile(usersConfigPath, 'utf8')); const sourceDir = path.join(__dirname, '..', 'backup_directories'); + await removeDirectory(destinationDir); + try { for (const department in usersConfig) { const { key, users } = usersConfig[department]; @@ -182,36 +214,152 @@ async function decryptUserFilesToDirectory(destinationDir) { try { const files = await getAllFilePaths(userDir); for (const filePath of files) { - const stats = await fs.stat(filePath); + const stats = await fsPromises.stat(filePath); if (stats.isFile()) { - // Extract the part of the file path after the userId const relativePath = path.relative(userDir, filePath); // Construct the destination file path const destinationFilePath = path.join(destinationDir, userId, relativePath); - await fs.mkdir(path.dirname(destinationFilePath), { recursive: true }); + await fsPromises.mkdir(path.dirname(destinationFilePath), { recursive: true }); + await lockFile(filePath); // Decrypt the file in its original location await decryptFileWithKey(filePath, key); // Copy the decrypted file to the destination directory - await fs.copyFile(filePath, destinationFilePath); + await fsPromises.copyFile(filePath, destinationFilePath); console.log(`Decrypted file copied to: ${destinationFilePath}`); // Re-encrypt the file in its original location (optional) await encryptFileWithKey(filePath, key); + await unlockFile(filePath); } } } catch (error) { console.error(`Error processing files for user ${userId}: ${error.message}`); + await encryptUserSystemConfig(); + return false; } } } } catch (error) { console.error(`Error processing decryption: ${error.message}`); + await encryptUserSystemConfig(); + return false; } + + await encryptUserSystemConfig(); + return true; } +async function decryptDepartmentFilesToDirectory() { + const dirDepartmentPath = path.join(__dirname, '..', 'dirDepartment.json'); + const loginDataPath = path.join(__dirname, '..', 'loginData.json'); + const usersConfigPath = path.join(__dirname, '..', 'usersInSystem.json'); + const sourceDir = path.join(__dirname, '..', 'backup_directories'); -processBackup(); -decryptUserFilesToDirectory("C:\\Users\\Andrei Cerbu\\Documents\\decrypted"); + if (!fs.existsSync(usersConfigPath) || !fs.existsSync(loginDataPath) || !fs.existsSync(dirDepartmentPath)) { + console.error("Missing one or more essential configuration files."); + return false; + } + + await lockFile(loginDataPath); + await lockFile(usersConfigPath); + + await decryptFileInPlace(loginDataPath); + await decryptFileInPlace(usersConfigPath); + + const { path: destinationDir } = JSON.parse(await fsPromises.readFile(dirDepartmentPath, 'utf8')); + const { department } = JSON.parse(await fsPromises.readFile(loginDataPath, 'utf8')); + const usersConfig = JSON.parse(await fsPromises.readFile(usersConfigPath, 'utf8')); + + // Check if department exists in users configuration + if (!usersConfig[department]) { + console.error(`No configuration found for department: ${department}`); + return false; + } + + const { key, users } = usersConfig[department]; + + await encryptFileInPlace(loginDataPath); + await encryptFileInPlace(usersConfigPath); + + await unlockFile(loginDataPath); + await unlockFile(usersConfigPath); + + await removeDirectory(destinationDir); + + for (const userId of users) { + const userDir = path.join(sourceDir, userId); + + try { + const files = await getAllFilePaths(userDir); + console.log(`Processing files for user ${userId}: ${files}`); + + for (const filePath of files) { + const stats = await fsPromises.stat(filePath); + if (stats.isFile()) { + const relativePath = path.relative(userDir, filePath); + + // Construct the destination file path + const destinationFilePath = path.join(destinationDir, userId, relativePath); + await fsPromises.mkdir(path.dirname(destinationFilePath), { recursive: true }); + + // Decrypt the file in its original location + await decryptFileWithKey(filePath, key); + + // Copy the decrypted file to the destination directory + await fsPromises.copyFile(filePath, destinationFilePath); + console.log(`Decrypted file copied to: ${destinationFilePath}`); + + // Re-encrypt the file in its original location (optional) + await encryptFileWithKey(filePath, key); + } + } + } catch (error) { + console.error(`Error processing files for user ${userId}: ${error.message}`); + return false; + } + } + + console.log("All files processed successfully."); + return true; +} + +let serverIp = null; +decryptAndGetServerIP(path.join(__dirname, '..', 'ipConfig.json')).then(ip => { + serverIp = ip; +}); + +const timeoutInterval = 7 * 60 * 1000 //minutes * seconds * miliseconds + +setInterval(async () => { + await decryptDepartmentFilesToDirectory(); +}, timeoutInterval); + +console.log('backup.js process started!'); +process.on('SIGINT', async () => { + console.log('Shutdown signal received in \'backup.js\'. Cleaning up...'); + + try { + console.log('Performing cleanup tasks...'); + console.log('Cleanup completed successfully.'); + } catch (error) { + console.error('An error occurred during cleanup:', error); + } finally { + console.log('Process terminated'); + process.exit(0); + } +}); + +process.on('message', async (message) => { + if (message.type === 'startBackup') { + console.log('BackupProcess: Received command to start backup.'); + await processBackup() + } + if(message.type === 'decryptBackup'){ + console.log(`BackupProcess: Received command to decrypt backup to ${message.decryptDestPath}`); + console.log(message.decryptDestPath); + await decryptBackupFilesToDirectory(message.decryptDestPath); + } +}); \ No newline at end of file diff --git a/User/jobs/backup_endpoints.js b/User/jobs/backup_endpoints.js deleted file mode 100644 index ef20e54..0000000 --- a/User/jobs/backup_endpoints.js +++ /dev/null @@ -1,79 +0,0 @@ -const express = require('express'); -const fs = require('fs'); -const path = require('path'); -const Joi = require('joi'); -const fetch = require('node-fetch'); -const { httpStatus } = require('../helpers/http_status'); - -const app = express(); -app.use(express.json()); - -const filePathSchema = Joi.object({ - filePath: Joi.string().required() -}); - -async function getBaseDirectory() { - const filePath = path.join(__dirname, '..', 'dirBackup.json'); - try { - const data = await fs.promises.readFile(filePath, 'utf8'); - const jsonData = JSON.parse(data); - return jsonData.path; - } catch (error) { - console.error('Error reading the base directory:', error); - throw error; - } -} - -app.post('/file_path', async (req, res) => { - const { error, value } = filePathSchema.validate(req.body); - if (error) { - return res.status(httpStatus.BAD_REQUEST).json({ - message: 'Invalid input', - data: error.details - }); - } - - try { - const basePath = await getBaseDirectory(); - let { filePath } = value; - const baseDirName = path.basename(basePath); - if (filePath.startsWith(baseDirName + path.sep)) { - filePath = filePath.slice(baseDirName.length + 1); - } - const fullPath = path.resolve(basePath, filePath); - - fs.stat(fullPath, (err, stats) => { - if (err) { - if (err.code === 'ENOENT') { - return res.status(httpStatus.NOT_FOUND).json({ - message: 'File not found' - }); - } - return res.status(httpStatus.INTERNAL_SERVER_ERROR).json({ - message: 'Error accessing the file' - }); - } - - if (!stats.isFile()) { - return res.status(httpStatus.BAD_REQUEST).json({ - message: 'Path is not a file' - }); - } - - // Stream the file as binary data - res.writeHead(httpStatus.OK, { - 'Content-Type': 'application/octet-stream', - 'Content-Disposition': `attachment; filename="${path.basename(fullPath)}"` - }); - const fileStream = fs.createReadStream(fullPath); - fileStream.pipe(res); - }); - } catch (error) { - return res.status(httpStatus.INTERNAL_SERVER_ERROR).json({ - message: 'Error processing request' - }); - } -}); - -const PORT = process.env.PORT || 3000; -app.listen(PORT, () => console.log(`Server running on port ${PORT}`)); diff --git a/User/jobs/external_endpoints.js b/User/jobs/external_endpoints.js new file mode 100644 index 0000000..8b12e01 --- /dev/null +++ b/User/jobs/external_endpoints.js @@ -0,0 +1,187 @@ +const express = require('express'); +const fs = require('fs'); +const multer = require('multer'); +const fsExtra = require('fs-extra'); +const path = require('path'); +const Joi = require('joi'); +const { httpStatus } = require('../helpers/http_status'); +const {lockFile, unlockFile} = require("../helpers/lock_mechanism"); + +const app = express(); +app.use(express.json()); +app.use('/share_file', express.raw({ type: 'application/octet-stream', limit: 'Infinity' })); + +const server = require('http').createServer(app); +const connections = []; + +// Store active connections to close them on shutdown +server.on('connection', (conn) => { + connections.push(conn); + conn.on('close', () => { + connections.splice(connections.indexOf(conn), 1); + }); +}); + +const filePathSchema = Joi.object({ + filePath: Joi.string().required() +}); + +async function getBaseDirectory() { + const filePath = path.join(__dirname, '..', 'dirBackup.json'); + try { + const data = await fs.promises.readFile(filePath, 'utf8'); + const jsonData = JSON.parse(data); + return jsonData.path; + } catch (error) { + console.error('Error reading the base directory:', error); + throw error; + } +} + +app.post('/file_path', async (req, res) => { + const { error, value } = filePathSchema.validate(req.body); + if (error) { + return res.status(httpStatus.BAD_REQUEST).json({ + message: 'Invalid input', + data: error.details + }); + } + + try { + const basePath = await getBaseDirectory(); + let { filePath } = value; + const baseDirName = path.basename(basePath); + if (filePath.startsWith(baseDirName + path.sep)) { + filePath = filePath.slice(baseDirName.length + 1); + } + const fullPath = path.resolve(basePath, filePath); + + fs.stat(fullPath, (err, stats) => { + if (err) { + if (err.code === 'ENOENT') { + return res.status(httpStatus.NOT_FOUND).json({ + message: 'File not found' + }); + } + return res.status(httpStatus.INTERNAL_SERVER_ERROR).json({ + message: 'Error accessing the file' + }); + } + + if (!stats.isFile()) { + return res.status(httpStatus.BAD_REQUEST).json({ + message: 'Path is not a file' + }); + } + + // Stream the file as binary data + res.writeHead(httpStatus.OK, { + 'Content-Type': 'application/octet-stream', + 'Content-Disposition': `attachment; filename="${path.basename(fullPath)}"` + }); + const fileStream = fs.createReadStream(fullPath); + fileStream.pipe(res); + }); + } catch (error) { + return res.status(httpStatus.INTERNAL_SERVER_ERROR).json({ + message: 'Error processing request' + }); + } +}); + + + +async function addFilePathToJson(filePath) { + const jsonFilePath = path.join(__dirname, '..', 'filesReceived.json'); + + try { + let data = { receivedFiles: [] }; + if (await fsExtra.pathExists(jsonFilePath)) { + await lockFile(jsonFilePath); + data = await fsExtra.readJson(jsonFilePath); + }else{ + await lockFile(jsonFilePath); + } + + data.receivedFiles.push(filePath); + + await fsExtra.writeJson(jsonFilePath, data, { spaces: 2 }); + await unlockFile(jsonFilePath); + console.log('File path added successfully.'); + } catch (error) { + console.error('Error updating JSON file:', error); + throw error; // Rethrow the error for further handling if necessary + } +} + +const shareFileSchema = Joi.object({ + idUser: Joi.string().required(), + nameOfFile: Joi.string().required(), + sizeOfFile: Joi.number().required() +}); + +const storage = multer.diskStorage({ + destination: function (req, file, cb) { + const { error, value } = shareFileSchema.validate(req.body); + if (error) { + cb(error, undefined); + return; + } + + const baseDir = path.join(__dirname, '..', 'uploads', value.idUser); // Temp storage location + fsExtra.ensureDirSync(baseDir); + cb(null, baseDir); + }, + filename: function (req, file, cb) { + cb(null, req.body.nameOfFile); // Using directly assuming it has been validated already + } +}); + +const upload = multer({ storage: storage }).single('file'); + +app.post('/upload', (req, res) => { + upload(req, res, async (err) => { + if (err instanceof multer.MulterError) { + res.status(httpStatus.INTERNAL_SERVER_ERROR).send(`Multer error: ${err.message}`); + return; + } else if (err) { + res.status(httpStatus.BAD_REQUEST).send(`Validation error: ${err.message}`); + return; + } + + try { + const { idUser, nameOfFile } = req.body; + + const dirConfig = await fsExtra.readJson(path.join(__dirname, '..', 'dirShare.json')); + const baseDir = dirConfig.path; + + const finalPath = path.join(baseDir, idUser, nameOfFile); + + await fsExtra.move(req.file.path, finalPath, { overwrite: true }); + await addFilePathToJson(finalPath); + + res.status(httpStatus.OK).json({message: 'Upload successful.'}) + } catch (error) { + console.error('Failed to move file:', error); + res.status(httpStatus.INTERNAL_SERVER_ERROR).json({message: 'Server error while moving the file.'}); + } + }); +}); + + + + +console.log('external_endpoints.json started.'); +const PORT = process.env.PORT || 3000; +server.listen(PORT, () => console.log(`Server running on port ${PORT}`)); + +process.on('SIGINT', () => { + console.log('SIGINT signal received. Shutting down gracefully.'); + server.close(() => { + console.log('Server closed.'); + // Ensure all connections are closed + connections.forEach(conn => conn.end()); + setTimeout(() => connections.forEach(conn => conn.destroy()), 5000); + process.exit(0); + }); +}); diff --git a/User/jobs/fetcher.js b/User/jobs/fetcher.js index f390bf3..9d91cc2 100644 --- a/User/jobs/fetcher.js +++ b/User/jobs/fetcher.js @@ -1,4 +1,5 @@ -const fs = require('fs').promises; +const fsPromises = require('fs').promises; +const fs = require('fs'); const path = require('path'); const ip = require('ip'); const {encryptFileInPlace, decryptFileInPlace} = require('../src/main/aes_encrypt'); @@ -19,7 +20,7 @@ async function fetchBackupSchemes(serverIp) { // Write the fetched backup schemes to the specified file try { await lockFile(destPath); - await fs.writeFile(destPath, JSON.stringify(backupSchemes, null, 2)); // Use null, 2 for pretty formatting + await fsPromises.writeFile(destPath, JSON.stringify(backupSchemes, null, 2)); // Use null, 2 for pretty formatting await unlockFile(destPath); console.log('Backup schemes saved successfully to', destPath); } catch (error) { @@ -29,14 +30,17 @@ async function fetchBackupSchemes(serverIp) { async function fetchUsersAndDepartments(serverIp) { try { + console.log('se asteapta depart'); // Fetch departments const depResponse = await fetch(`http://${serverIp}/users/departments`, { method: 'GET', headers: {'x-api-key': 'uc_api'} }); + const departmentsJson = await depResponse.json(); const departments = departmentsJson['data']; + console.log('se asteapta users') // Fetch users const userResponse = await fetch(`http://${serverIp}/users`, { method: 'GET', @@ -56,8 +60,11 @@ async function fetchUsersAndDepartments(serverIp) { // Write combined data to a file const filePath = path.join(__dirname, '..', 'usersInSystem.json'); + if(!fs.existsSync(filePath)){ + await fsPromises.writeFile(filePath, ''); + } await lockFile(filePath); - await fs.writeFile(filePath, JSON.stringify(combinedData, null, 2), 'utf8'); + await fsPromises.writeFile(filePath, JSON.stringify(combinedData, null, 2), 'utf8'); await encryptFileInPlace(filePath); await unlockFile(filePath); @@ -72,7 +79,7 @@ async function decryptAndGetServerIP(filePath) { await lockFile(filePath); await decryptFileInPlace(filePath); - const fileContent = await fs.readFile(filePath, 'utf8'); + const fileContent = await fsPromises.readFile(filePath, 'utf8'); const jsonData = JSON.parse(fileContent); const serverIP = jsonData.ip; @@ -87,7 +94,7 @@ async function decryptAndGetServerIP(filePath) { async function getDirectoryStructure(dirPath) { const baseName = path.basename(dirPath); - const entries = await fs.readdir(dirPath, {withFileTypes: true}); + const entries = await fsPromises.readdir(dirPath, {withFileTypes: true}); const result = {}; result[baseName] = {files: []}; let totalSize = 0; @@ -101,7 +108,7 @@ async function getDirectoryStructure(dirPath) { totalSize += subSize; } else { // Add file name to the 'files' array and calculate total size - const stats = await fs.stat(entryPath); + const stats = await fsPromises.stat(entryPath); result[baseName].files.push(entry.name); totalSize += stats.size; } @@ -114,7 +121,7 @@ async function createBackupScheme(serverIp, structure, size) { await lockFile(filePath); await decryptFileInPlace(filePath); - const userContent = await fs.readFile(filePath, 'utf8'); + const userContent = await fsPromises.readFile(filePath, 'utf8'); const userJson = JSON.parse(userContent); await encryptFileInPlace(filePath) @@ -151,7 +158,7 @@ async function createBackupScheme(serverIp, structure, size) { async function watchDirectoryChanges(serverIp) { async function readBackupConfig(filePath) { await lockFile(filePath); - const fileContent = await fs.readFile(filePath, 'utf8'); + const fileContent = await fsPromises.readFile(filePath, 'utf8'); await unlockFile(filePath); return JSON.parse(fileContent); } @@ -163,11 +170,15 @@ async function watchDirectoryChanges(serverIp) { size: size }; await lockFile(filePath); - await fs.writeFile(path.join(__dirname, '..', 'dirBackup.json'), JSON.stringify(data, null, 2)); + await fsPromises.writeFile(path.join(__dirname, '..', 'dirBackup.json'), JSON.stringify(data, null, 2)); await unlockFile(filePath); } const configPath = path.join(__dirname, '..', 'dirBackup.json'); + if(!fs.existsSync(configPath)){ + console.log('backupDir file doesn\'t exists'); + return; + } const backupConfig = await readBackupConfig(configPath); const storedStructure = backupConfig.structure; @@ -178,32 +189,46 @@ async function watchDirectoryChanges(serverIp) { await createBackupScheme(serverIp, currentStructure, currentSize); await updateBackupConfig(backupConfig.path, currentStructure, currentSize); + console.log('FetcherProcess: start backup.'); + process.send({type: 'startBackup'}); } else { console.log("No changes detected in the directory structure."); } } -process.on('SIGINT', () => { - console.log('Process terminated'); - process.exit(0); -}); - let serverIp = null decryptAndGetServerIP(path.join(__dirname, '..', 'ipConfig.json')).then(ip => { serverIp = ip; }); +const timeoutInterval = 6 * 60 * 1000 //minutes * seconds * miliseconds + setInterval(() => { fetchUsersAndDepartments(serverIp); -}, 5000); +}, timeoutInterval); setInterval(() => { watchDirectoryChanges(serverIp); -}, 5000); +}, timeoutInterval); setInterval(() => { fetchBackupSchemes(serverIp); -}, 5000); +}, timeoutInterval); -console.log("Service running. Press CTRL+C to stop."); +console.log("fetcher.js process started."); + +process.on('SIGINT', async () => { + console.log('Shutdown signal received in \'fetcher.js\'. Cleaning up...'); + + try { + console.log('Performing cleanup tasks...'); + console.log('Cleanup completed successfully.'); + } catch (error) { + console.error('An error occurred during cleanup:', error); + } finally { + console.log('Process terminated'); + process.exit(0); + } +}); + diff --git a/User/jobs/send_file.js b/User/jobs/send_file.js new file mode 100644 index 0000000..b37520f --- /dev/null +++ b/User/jobs/send_file.js @@ -0,0 +1,90 @@ +const fs = require('fs'); +const path = require('path'); +const axios = require('axios'); +const FormData = require('form-data'); +const {lockFile, unlockFile} = require("../helpers/lock_mechanism"); +const {decryptFileInPlace, encryptFileInPlace} = require("../src/main/aes_encrypt"); + +async function decryptAndGetServerIP(filePath) { + try { + await lockFile(filePath); + await decryptFileInPlace(filePath); + + const fileContent = await fs.promises.readFile(filePath, 'utf8'); + const jsonData = JSON.parse(fileContent); + const serverIP = jsonData.ip; + + await encryptFileInPlace(filePath) + await unlockFile(filePath); + return serverIP; + } catch (error) { + console.error('An error occurred:', error); + return null; + } +} + +async function extractId() { + try { + // Path to the JSON file + const jsonFilePath = path.join(__dirname, '..', 'loginData.json'); + + // Read and parse the JSON file + const jsonData = await fs.promises.readFile(jsonFilePath, 'utf-8'); + const { id } = JSON.parse(jsonData); + + return id; + } catch (error) { + console.error('Failed to read file or parse data:', error); + throw error; + } +} + +async function uploadFile(filePath, serverIp) { + try { + const idUser = await extractId(); // Fetch ID from JSON + const nameOfFile = path.basename(filePath); // Extract the file name from the path + + // Ensure the file exists and get its size + if (!fs.existsSync(filePath)) { + console.error("File does not exist: " + filePath); + process.exit(1); + } + const fileSizeInBytes = fs.statSync(filePath).size; + + const form = new FormData(); + form.append('idUser', idUser); + form.append('nameOfFile', nameOfFile); + form.append('sizeOfFile', fileSizeInBytes); + form.append('file', fs.createReadStream(filePath)); + + const response = await axios.post(`http://${serverIp}/upload`, form, { + headers: { + ...form.getHeaders(), + }, + }); + + console.log('File uploaded successfully:', response.data); + process.exit(0); // Exit with status 0 (success) + } catch (error) { + console.error('Error uploading file:', error.message); + process.exit(1); // Exit with status 1 (error) + } +} + +// Command-line argument for file path +if (process.argv.length < 3) { + console.log('Usage: node + + + Sending file + + +
+
+

DECRYPTING BACKUP!

+

PlEASE WAIT

+ Description of GIF + +
+
+ + diff --git a/User/src/renderer/html/ip_submit.html b/User/src/renderer/html/ip_submit.html index 0352f05..e4c7f0d 100644 --- a/User/src/renderer/html/ip_submit.html +++ b/User/src/renderer/html/ip_submit.html @@ -5,7 +5,7 @@ - + diff --git a/User/src/renderer/html/main_menu.html b/User/src/renderer/html/main_menu.html index f7cb909..7ac28ca 100644 --- a/User/src/renderer/html/main_menu.html +++ b/User/src/renderer/html/main_menu.html @@ -38,13 +38,14 @@
- +
- +
+
diff --git a/User/src/renderer/html/sending_file_confirmation.html b/User/src/renderer/html/sending_file_confirmation.html index 9af7fd1..7774872 100644 --- a/User/src/renderer/html/sending_file_confirmation.html +++ b/User/src/renderer/html/sending_file_confirmation.html @@ -9,8 +9,49 @@ + + + Sending file
diff --git a/User/src/renderer/js/change_department.js b/User/src/renderer/js/change_department.js index d1b5dec..d675cdd 100644 --- a/User/src/renderer/js/change_department.js +++ b/User/src/renderer/js/change_department.js @@ -17,9 +17,11 @@ document.addEventListener('DOMContentLoaded', async function () { const formContent = document.querySelector('.department-form-content'); Object.entries(data).forEach(([key, department]) => { - const label = document.createElement('label'); - label.innerHTML = `${department.name}`; - formContent.appendChild(label); + if(department.name !== 'CEO'){ + const label = document.createElement('label'); + label.innerHTML = `${department.name}`; + formContent.appendChild(label); + } }); }).catch(async error => { await window.electronAPI.showAlert(error.message) diff --git a/User/src/renderer/js/login.js b/User/src/renderer/js/login.js index f086f95..812c401 100644 --- a/User/src/renderer/js/login.js +++ b/User/src/renderer/js/login.js @@ -34,6 +34,8 @@ document.addEventListener('DOMContentLoaded', async function () { }) }).then(async response => { if (response.ok) { + await window.electronAPI.killBeforeLogout(); + await window.electronAPI.startMainProcesses(); fadeOut('main_menu.html'); } else { await window.electronAPI.deleteFile('loginData.json'); @@ -84,6 +86,7 @@ document.addEventListener('DOMContentLoaded', async function () { }).then(async data => { data.data.password = password await window.electronAPI.writeFile('loginData.json', JSON.stringify(data.data, null, 2)); + await window.electronAPI.startMainProcesses(); fadeOut('main_menu.html'); }) .catch(async error => { @@ -92,8 +95,4 @@ document.addEventListener('DOMContentLoaded', async function () { .catch(error => console.error('Error showing alert:', error)); }) }); - - function delayWithTimeout(ms) { - return new Promise(resolve => setTimeout(resolve, ms)); - } }); diff --git a/User/src/renderer/js/main_menu.js b/User/src/renderer/js/main_menu.js index 7d3682b..bc81839 100644 --- a/User/src/renderer/js/main_menu.js +++ b/User/src/renderer/js/main_menu.js @@ -1,5 +1,8 @@ document.addEventListener('DOMContentLoaded', async function () { + await insertUsername(); + const backupButton = document.getElementById('backup'); + const shareButton = document.getElementById('share_dir'); const changeDepartmentButton = document.getElementById('change_department'); const changeInfoButton = document.getElementById('change_info'); const shareFileButton = document.getElementById('share_file'); @@ -19,21 +22,12 @@ document.addEventListener('DOMContentLoaded', async function () { let triggerSource = ''; - function handleOverlayOpen(buttonId) { overlay.style.display = 'block'; triggerSource = buttonId; // Remember the button that triggered the overlay console.log(`${buttonId} button clicked!`); } - changeDepartmentButton.addEventListener('click', function () { - handleOverlayOpen('change_department'); - }); - - decryptButton.addEventListener('click', function () { - handleOverlayOpen('decrypt'); - }); - ceoBackButton.addEventListener('click', function () { overlay.style.display = 'none'; }); @@ -59,7 +53,8 @@ document.addEventListener('DOMContentLoaded', async function () { if (triggerSource === 'change_department') { fadeOut('change_department.html'); } else if (triggerSource === 'decrypt') { - fadeOut('decrypting_files.html'); + console.log('astept decryptarea') + fadeOut('decrypting_backup.html'); } }) @@ -68,13 +63,28 @@ document.addEventListener('DOMContentLoaded', async function () { }); checkDirBackupFileExists() - .then(() => console.log('verificare facuta')); - await insertUsername(); + .then(() => console.log('verificare backupDir facuta')); + + checkShareDirFileExists() + .then(() => console.log('verificare ShareDir facuta')); + + checkDepartmentDirFileExists() + .then(() => {console.log('verificare departmentDir facuta')}) backupButton.addEventListener('click', function () { console.log('Set backup directory button clicked!'); - window.electronAPI.openBackupDirDialog() + window.electronAPI.openJsonDirConfigDialog('dirBackup.json') + .then(() => console.log('Back-up directory set')) + .catch(async error => await window.electronAPI.showAlert(error.message) + .then(() => console.log('Alert window opened')) + .catch(error => console.error('Error showing alert:', error))); + }); + + shareButton.addEventListener('click', function () { + console.log('Set backup directory button clicked!'); + + window.electronAPI.openJsonDirConfigDialog('dirShare.json') .then(() => console.log('Back-up directory set')) .catch(async error => await window.electronAPI.showAlert(error.message) .then(() => console.log('Alert window opened')) @@ -86,6 +96,14 @@ document.addEventListener('DOMContentLoaded', async function () { fadeOut('profile.html'); }); + changeDepartmentButton.addEventListener('click', function () { + handleOverlayOpen('change_department'); + }); + + decryptButton.addEventListener('click', function () { + handleOverlayOpen('decrypt'); + }); + shareFileButton.addEventListener('click', function () { console.log('Share a file button clicked!'); fadeOut('share_file.html'); @@ -93,7 +111,7 @@ document.addEventListener('DOMContentLoaded', async function () { logoutButton.addEventListener('click', async function () { console.log('Logout button clicked!'); - + await window.electronAPI.killBeforeLogout(); await window.electronAPI.deleteFile('loginData.json'); fadeOut('login.html'); }); @@ -109,7 +127,7 @@ document.addEventListener('DOMContentLoaded', async function () { button.id = 'backup_alert'; button.name = 'alert'; button.textContent = 'Set your backup directory!'; - button.addEventListener('click', handleButtonClick); + button.addEventListener('click', handleBackupButtonPressed); notificationsDiv.appendChild(button); } } catch (error) { @@ -117,11 +135,46 @@ document.addEventListener('DOMContentLoaded', async function () { } } + async function checkShareDirFileExists() { + try { + const fileExists = await window.electronAPI.checkFileExists('dirShare.json'); - async function handleButtonClick() { + if (!fileExists) { + const notificationsDiv = document.getElementById('notifications'); + const button = document.createElement('button'); + button.id = 'share_file_alert'; + button.name = 'alert'; + button.textContent = 'Set your share directory!'; + button.addEventListener('click', handleShareButtonPressed); + notificationsDiv.appendChild(button); + } + } catch (error) { + console.error('Error checking file existence:', error); + } + } + + async function checkDepartmentDirFileExists() { + try { + const fileExists = await window.electronAPI.checkFileExists('dirDepartment.json'); + + if (!fileExists) { + const notificationsDiv = document.getElementById('notifications'); + const button = document.createElement('button'); + button.id = 'department_alert'; + button.name = 'alert'; + button.textContent = 'Set your department directory!'; + button.addEventListener('click', handleDepartmentButtonPressed); + notificationsDiv.appendChild(button); + } + } catch (error) { + console.error('Error checking file existence:', error); + } + } + + async function handleBackupButtonPressed() { console.log('Button clicked!'); - await window.electronAPI.openBackupDirDialog() + await window.electronAPI.openJsonDirConfigDialog('dirBackup.json') .then(() => console.log('Back-up directory set')) .catch(async error => await window.electronAPI.showAlert(error.message) .then(() => console.log('Alert window opened')) @@ -131,6 +184,32 @@ document.addEventListener('DOMContentLoaded', async function () { button.remove(); } + async function handleShareButtonPressed() { + console.log('Button clicked!'); + + await window.electronAPI.openJsonDirConfigDialog('dirShare.json') + .then(() => console.log('Share directory set')) + .catch(async error => await window.electronAPI.showAlert(error.message) + .then(() => console.log('Alert window opened')) + .catch(error => console.error('Error showing alert:', error))); + + const button = document.getElementById('backup_alert'); + button.remove(); + } + + async function handleDepartmentButtonPressed() { + console.log('Button clicked!'); + + await window.electronAPI.openJsonDirConfigDialog('dirDepartment.json') + .then(() => console.log('Department directory set')) + .catch(async error => await window.electronAPI.showAlert(error.message) + .then(() => console.log('Alert window opened')) + .catch(error => console.error('Error showing alert:', error))); + + const button = document.getElementById('backup_alert'); + button.remove(); + } + async function insertUsername() { try { const userData = await window.electronAPI.readFile('loginData.json'); diff --git a/User/src/renderer/js/profile.js b/User/src/renderer/js/profile.js index e4972d2..1ff712f 100644 --- a/User/src/renderer/js/profile.js +++ b/User/src/renderer/js/profile.js @@ -23,10 +23,7 @@ document.addEventListener('DOMContentLoaded', async function () { backButton.addEventListener('click', function () { console.log('Back button clicked!'); - - window.electronAPI.changeContent('main_menu.html') - .then(() => console.log('Navigated to dashboard')) - .catch(error => console.error('Error navigating:', error)); + fadeOut('main_menu.html') }); submitButton.addEventListener('click', async function (e) { diff --git a/User/src/renderer/js/share_file.js b/User/src/renderer/js/share_file.js index 5d8cdee..462fbc9 100644 --- a/User/src/renderer/js/share_file.js +++ b/User/src/renderer/js/share_file.js @@ -1,5 +1,11 @@ -document.addEventListener("DOMContentLoaded", function () { +document.addEventListener("DOMContentLoaded", async function () { let pathToFile = ''; + let serverIp = ''; + await window.electronAPI.readFile('ipConfig.json') + .then(result => { + const jsonData = JSON.parse(result.content); + serverIp = jsonData.ip; + }) function updateFileName() { const fileNameElement = document.getElementById('fileName'); @@ -18,7 +24,7 @@ document.addEventListener("DOMContentLoaded", function () { const {id} = loginData; - fetch('http://localhost:5000/users', { + fetch(`http://${serverIp}/users`, { method: 'GET', headers: { 'x-api-key': 'uc_api' @@ -66,32 +72,58 @@ document.addEventListener("DOMContentLoaded", function () { event.preventDefault(); console.log('Submit button clicked'); - if (pathToFile === '' || pathToFile.length === 0) { + const fileInput = document.getElementById('fileInput'); + if (!fileInput.files.length) { await window.electronAPI.showAlert('File not chosen!') .then(() => console.log('Alert window opened')) - .catch(error => console.error('Error changing content:', error)); - return + .catch(error => console.error('Error showing alert:', error)); + return; } const form = document.getElementById('userDestForm'); const checkboxes = form.querySelectorAll('input[name="users"]'); - const selectedUserIds = []; + const selectedUserIds = Array.from(checkboxes) + .filter(checkbox => checkbox.checked) + .map(checkbox => checkbox.value); - checkboxes.forEach(checkbox => { - if (checkbox.checked) { - selectedUserIds.push(checkbox.value); - } - }); - - if (selectedUserIds === []) { + if (!selectedUserIds.length) { await window.electronAPI.showAlert('No user selected!') .then(() => console.log('Alert window opened')) - .catch(error => console.error('Error changing content:', error)); + .catch(error => console.error('Error showing alert:', error)); return; } - //TODO: logic to send files + const uploadData = { + filePath: fileInput.files[0].path, + users: [] + }; + + for (const userId of selectedUserIds) { + try { + const ipResponse = await fetch(`http://${serverIp}/backup_schemes/${userId}`); + if (!ipResponse.ok) { + throw new Error(`Failed to fetch IP address for user ${userId}: status ${ipResponse.status}`); + } + const { data: destIp } = await ipResponse.json(); + uploadData.users.push({ + userId, + destIp, + destPort: 3000, // Static destination port + fileName: fileInput.files[0].name + }); + } catch (error) { + console.error('Error fetching user data:', error); + } + } + + window.electronAPI.writeFile('usersDestTemp.json', JSON.stringify(uploadData)) + .then(() => { + console.log('File saved successfully'); + fadeOut('sending_file_confirmation.html'); + }) + .catch(error => console.error('Failed to save file:', error)); }); + fetchUsersAndCreateCheckboxes().then(() => console.log('Page rendered')) }); diff --git a/User/src/renderer/js/sign_up_departments.js b/User/src/renderer/js/sign_up_departments.js index 9da4ab2..c121496 100644 --- a/User/src/renderer/js/sign_up_departments.js +++ b/User/src/renderer/js/sign_up_departments.js @@ -17,9 +17,11 @@ document.addEventListener('DOMContentLoaded', async function () { const formContent = document.querySelector('.signup-form-content'); Object.entries(data).forEach(([key, department]) => { - const label = document.createElement('label'); - label.innerHTML = `${department.name}`; - formContent.appendChild(label); + if(department.name !== 'CEO') { + const label = document.createElement('label'); + label.innerHTML = `${department.name}`; + formContent.appendChild(label); + } }); }).catch(async error => { await window.electronAPI.showAlert(error.message)