Initial release

Author: RedHitMark

.dockerignore

@@ -0,0 +1,8 @@
+node_modules
+.idea
+.dockerignore
+docker-compose.yml
+Dockerfile
+LICENSE
+README.md
+.env

.env

@@ -0,0 +1,7 @@
+MONGO_USER=2facesAdmin
+MONGO_PASSWORD=2facesPassword
+MONGO_DATABASE=2facesdb
+SERVER_PORT=9999
+SOCKET_MASTER_PORT=6969
+SOCKET_MASTER_PORT=6969
+

.gitignore

@@ -0,0 +1,2 @@
+node_modules
+.idea/

CryptoManager.js

@@ -0,0 +1,42 @@
+const crypto = require('crypto');
+
+function aes256Encrypt(message, key, iv) {
+    let ivBuffer = new Buffer.from(iv, 'base64');
+    let keyBuffer =  new Buffer.from(key, 'base64');
+
+    let cipher = crypto.createCipheriv('aes-256-cbc', keyBuffer, ivBuffer);
+    let encrypted = cipher.update(message, 'utf8', 'base64');
+    encrypted += cipher.final('base64');
+    return encrypted;
+}
+
+function aes256Decrypt(encrypted, key, iv) {
+    let ivBuffer = new Buffer.from(iv, 'base64');
+    let keyBuffer =  new Buffer.from(key, 'base64');
+    let encryptedBuffer = new Buffer.from(encrypted, 'base64');
+
+    let decipher = crypto.createDecipheriv('aes-256-cbc', keyBuffer, ivBuffer);
+    let decrypted = decipher.update(encryptedBuffer);
+    decrypted = Buffer.concat([decrypted, decipher.final()] );
+    return decrypted.toString('utf-8');
+}
+
+function sha256(message) {
+    return crypto.createHash('sha256').update(message).digest('base64');
+}
+function md5(message) {
+    return crypto.createHash('md5').update(message).digest('base64');
+}
+
+function sha256File(filePath) {
+    let stream = fs.ReadStream(filePath);
+    return sha256(stream.toString());
+}
+
+
+module.exports = {
+    aes256Encrypt,
+    aes256Decrypt,
+    sha256,
+    md5
+};

Dockerfile

@@ -0,0 +1,23 @@
+FROM node:latest
+# FROM openjdk:latest
+
+WORKDIR /app
+
+# Install app dependencies
+COPY package.json .
+COPY package-lock.json .
+RUN npm install && npm audit fix
+
+# Bundle app source
+COPY . .
+
+# API port
+EXPOSE 9999
+
+# socker master port
+EXPOSE 6969
+# socket slave ports
+EXPOSE 52000-52500
+# socket slave ports
+EXPOSE 60000-60100
+CMD ["npm", "run", "start"]

LICENSE

@@ -0,0 +1,26 @@
+# LetsCompileServer
+
+# 
+### Docker
+
+```
+docker-compose -d --build
+```
+
+### NPM
+```
+npm start
+```
+
+### API
+Endpoint | Method | Description
+------------ | ------------ | -------------
+/api/v.1.0/devices | GET | Content from cell 2
+/api/v.1.0/devices | POST | Content from cell 2
+/api/v.1.0/payloads | GET| Content in the second column
+/api/v.1.0/payloads | POST | Content in the second column
+/api/v.1.0/payloads | PUT | Content in the second column
+/api/v.1.0/payloads | DELETE | Content in the second column
+/api/v.1.0/attacks | GET | Content in the second column
+/api/v.1.0/attacks | POST  Content in the second column
+/api/v.1.0/attacks | DELETE | Content in the second column

README.md

@@ -0,0 +1,165 @@
+module.exports = (app, socketManager) => {
+    const BASE_API_URL = "/api";
+    const API_VERSION_1_0 = '/v1.0';
+
+    const deviceManager = require('./v1.0/deviceManager');
+
+    const payloads = require('../database/models/payload');
+    const attacks = require('../database/models/attackResult');
+
+    app.get(BASE_API_URL + API_VERSION_1_0 + "/devices", (req, res) => {
+        deviceManager.showAllDevices(socketManager)
+            .then((ok) => {
+                res.json(ok);
+            }).catch((error) => {
+                res.status(error.status).json({error: error.message});
+            });
+    });
+
+    app.post(BASE_API_URL + API_VERSION_1_0 + "/devices", (req, res) => {
+        const device = req.body.device;
+        const payload_id = req.body.payload_id;
+
+        deviceManager.triggerDevice(socketManager, device, payload_id)
+            .then((ok) => {
+                res.json(ok);
+            }).catch((error) => {
+                res.status(error.status).json({error: error.message});
+            });
+    });
+
+
+    app.get(BASE_API_URL + API_VERSION_1_0 + "/payloads", (req, res) => {
+        const payload_id = req.query.payload_id;
+        if(payload_id) {
+            payloads.readOneById(payload_id)
+                .then((payload) => {
+                    if(payload) {
+                        res.json(payload);
+                    } else {
+                        res.status(404).json({error: "payload not found"});
+                    }
+
+                }).catch((error) => {
+                    res.status(error.status).json({error: error.message});
+                });
+        } else {
+            payloads.readAll()
+                .then((payloads) => {
+                    res.json(payloads);
+                }).catch((error) => {
+                    res.status(error.status).json({error: error.message});
+                });
+        }
+    });
+
+    app.post(BASE_API_URL + API_VERSION_1_0 + "/payloads", (req, res) => {
+        payloads.create(req.body)
+            .then((payloads) => {
+                res.json(payloads);
+            }).catch((error) => {
+                res.status(500).json({
+                    error: error
+                });
+            });
+    });
+
+    app.delete(BASE_API_URL + API_VERSION_1_0 + "/payloads", (req, res) => {
+        const payload_id = req.query.payload_id;
+        payloads.deleteOne(payload_id)
+            .then((payloads) => {
+                res.json(payloads);
+            }).catch((error) => {
+                res.status(error.status).json({error: error.message});
+            });
+    });
+
+    app.put(BASE_API_URL + API_VERSION_1_0 + "/payloads", (req, res) => {
+        const payload_id = req.query.payload_id;
+        payloads.updateOne(payload_id, req.body)
+            .then((payloads) => {
+                res.json(payloads);
+            }).catch((error) => {
+                res.status(error.status).json({error: error.message});
+            });
+    });
+
+
+    app.get(BASE_API_URL + API_VERSION_1_0 + "/attacks", (req, res) => {
+        const attack_id = req.query.attack_id;
+        if(attack_id) {
+            attacks.readOneById(attack_id)
+                .then( (attack) => {
+                    if (attack) {
+                        res.json(attack);
+                    } else {
+                        res.status(404).json({error: "payload not found"});
+                    }
+                }).catch((error) => {
+                    res.status(error.status).json({error: error.message});
+                });
+        } else {
+            attacks.readAll()
+                .then((attacks) => {
+                    res.json(attacks);
+                }).catch((error) => {
+                    res.status(error.status).json({error: error.message});
+                });
+        }
+    });
+
+    app.post(BASE_API_URL + API_VERSION_1_0 + "/attacks", (req, res) => {
+        attacks.create(req.body)
+            .then( (attacks) => {
+                res.json(attacks);
+            }).catch((error) => {
+                res.status(500).json({
+                    error: error
+                });
+            });
+    });
+
+    app.delete(BASE_API_URL + API_VERSION_1_0 + "/attacks", (req, res) => {
+        const attack_id = req.query.attack_id;
+        payloads.deleteOne(attack_id)
+            .then((attack) => {
+                res.json(attack);
+            }).catch((error) => {
+                res.status(error.status).json({error: error.message});
+            });
+    });
+
+
+    app.post(BASE_API_URL + API_VERSION_1_0 + "/build-apk", (req, res) => {
+        if (req.files && req.files.apk) {
+            let apkFile = req.files.apk;
+
+            //Use the mv() method to place the file in upload directory (i.e. "uploads")
+            avatar.mv('./uploads/' + apkFile.name);
+
+            const spawn = require("child_process").spawn;
+            const pythonProcess = spawn('python',["path/to/script.py", "child_process"]);
+            pythonProcess.stdout.on('data', (data) => {
+                // Do something with the data returned from python script
+            });
+        }
+    });
+
+    /** NOT FOUND FALL-BACK **/
+    app.get('*', (req, res) => {
+        console.log('GET fall back');
+        res.status(404).json({message : "not found on this server"});
+    });
+    app.post('*', (req, res) => {
+        console.log('POST fall back');
+        res.status(404).json({message : "not found on this server"});
+    });
+    app.delete('*', (req, res) => {
+        console.log('DELETE fall back');
+        res.status(404).json({message : "not found on this server"});
+    });
+    app.put('*', (req, res) => {
+        console.log('PUT fall back');
+        res.status(404).json({message : "not found on this server"});
+    });
+};