Merge remote-tracking branch 'origin/dev' into dev

Author: bhasher

package-lock.json

@@ -23,6 +23,7 @@
     "express-minify": "^1.0.0",
     "express-prom-bundle": "^6.2.0",
     "less": "^3.12.2",
+    "mongodb": "^3.6.3",
     "morgan": "^1.10.0",
     "mysql": "^2.18.1",
     "nunjucks": "^3.2.2",

package.json

@@ -35,7 +35,7 @@ if (config.PRODUCTION) {
 else {
     app.use(logger('dev'));
 }
-app.use(minify({ minifyJS: false }));
+app.use(minify({ jsMatch: false }));
 
 // Prometheus middleware
 if(config.METRICS){

src/app.js

@@ -0,0 +1,102 @@
+const { MongoClient, ObjectID } = require("mongodb");
+const configs = require('../config/config');
+const utils = require('../utils');
+
+const baseCode = [
+    {uuid: utils.uuid(Math.random().toString(), 10), content: 'def main(text: str) -> None:'},
+    {uuid: utils.uuid(Math.random().toString(), 10), content: '    print(text)'},
+    {uuid: utils.uuid(Math.random().toString(), 10), content: ''},
+    {uuid: utils.uuid(Math.random().toString(), 10), content: 'if __name__ == \'__main__\':'},
+    {uuid: utils.uuid(Math.random().toString(), 10), content: '    main(\'Hello World !\')'}
+];
+
+
+class MongoDB {
+    // TODO handle error
+    // TODO change using BULK write
+    constructor (username, password, host, database, port) {
+        this.client = new MongoClient(`mongodb://127.0.0.1:36175/51a8b34f-d253-4cc3-8ed6-96d0ce9c03d5?`);
+    }
+
+    async connect () {
+        this.db = await this.client.connect();
+        this.codeWe = await this.db.db('codewe');
+        this.documentsCollection = await this.codeWe.collection('codewe');
+    }
+
+    async createDocument () {
+        let doc = {
+            content: baseCode,
+            creationDate: Date.now(),
+            lastViewedDate: Date.now(),
+            customDocumentName: '',
+            documentOwner: '',
+            editors: [],
+            linkEdit: '',
+            linkView: '',
+            language: '',
+            tab: 4
+        };
+        // TODO check if inseted etc
+        let results = (await this.documentsCollection.insertOne(doc));
+        return results.insertedId.toString();
+
+    }
+
+    async getDocument (id) {
+        return await this.documentsCollection.findOne({_id: ObjectID(id)});
+    }
+
+    async setLine (documentId, uuid, content) {
+        await this.documentsCollection.updateOne({_id: ObjectID(documentId), 'content.uuid': uuid}, {$set: {'content.$.content': content}});
+    }
+    
+    async newLine (documentId, previousUuid, uuid, content) {
+        // Insert a line at the right place
+        //TODO is it possible in one operation
+        // TODO find index
+        let index = -1
+        console.log(index)
+        this.documentsCollection.updateOne({_id: ObjectID(documentId)}, {
+            $push: {
+                content: {
+                    $each : [{uuid: uuid, content: content}],
+                    $position : index
+                }
+            }
+        });
+    }
+
+    async deleteLine (documentId, uuid) {
+        // Delete line at the right place
+        await this.documentsCollection.updateOne({_id: ObjectID(documentId)}, {$pull: {content: {uuid: uuid}}});
+
+    }
+
+    async applyRequests (documentId, requests) {
+        // TODO use bulk write instead of this slow methods
+        for (let request of requests) {
+            let requestType = request.type;
+            let data = request.data;
+            switch (requestType) {
+                case 'set-line':
+                    await this.setLine(documentId, data.id, data.content);
+                    break;
+                case 'new-line':
+                    await this.newLine(documentId, data.previous, data.id, data.content);
+                    break;
+                case 'delete-line':
+                    await this.deleteLine(documentId, data.id);
+                    break;
+            }
+        };
+    }
+}
+
+function getDB () {
+    db = new MongoDB(configs.DB_USERNAME, configs.DB_PASSWORD, configs.DB_HOST, configs.DB_DATABASE, configs.DB_PORT);
+    db.connect();
+    return db
+}
+
+module.exports = getDB();