WIP - connected mongodb, and start CRUD operation testing

Author: rinaldo stevenazzi

controllers/Global.js

@@ -16,7 +16,6 @@ class Global {
             this.mongoDB.getDB()
                 .then(result => {
                     this.db = result
-                    console.log('Global Controller - initDB initialisation', this.db)
                     this.users.init(this.db)
                     resolve(null)
                 })
@@ -26,6 +25,19 @@ class Global {
                 })
         })
     }
+
+    getHigherScore () {
+        return new Promise((resolve, reject) => {
+            this.users.checkUserScore(123)
+                .then((users) => {
+                    console.log('Global Controller - getHigherScore', users)
+                    resolve(users)
+                }).catch(e => {
+                console.log('Global Controller - getHigherScore failed !!!')
+                reject(e)
+                })
+        })
+    }
 }
 
 module.exports = Global

index.js

@@ -7,8 +7,6 @@ const app = express()
 const server = http.createServer(app)
 const PORT = process.env.API_PORT
 
-console.log('process env', process.env)
-
 const globalController = new Global()
 globalController.initDB()
     .then(() => console.log('SERVER - initDB - DONE'))
@@ -19,6 +17,13 @@ app.get('/', async (req, res) => {
     res.send('<h1>Hello world</h1>')
 });
 
+app.get('/getHighersScore', async (req, res) => {
+    globalController.getHigherScore().then(() => {
+        res.send('<h1>this is the higher score</h1>')
+    })
+
+});
+
 
 server.listen(PORT, () => {
     console.log(`Listening on ${ PORT }`)

services/MongoDB.js

@@ -11,7 +11,6 @@ class MongoDB {
         return new Promise((resolve, reject) => {
             client.connect()
                 .then(() => {
-                    console.log('MongoDB Class - getDB')
                     resolve(client.db("speed-puzzle-db"))
             })
                 .catch(e => {

services/Users.js

@@ -4,9 +4,13 @@ class Users {
         this.collection = null
     }
 
+    getCollectionScore(arr){
+        return arr.map(a => a.score);
+    }
+
     init (collection) {
+        console.log('Users Class - init')
         this.collection = collection.collection("users")
-        console.log('Users Class - init', this.collection)
     }
 
     addUser (user) {
@@ -36,6 +40,25 @@ class Users {
                 })
         })
     }
+
+
+    // TODO : create a Capped Collections with a fixed size to 20
+    // https://www.mongodb.com/docs/manual/core/capped-collections/#behavior
+    checkUserScore (score) {
+        return new Promise((resolve, reject) => {
+            this.collection.findOne({'name' : 'b'})
+                .then((result) => {
+                    console.log('findOne name b', result)
+                })
+            this.collection.find({}).sort({score:-1}).toArray()
+                .then((result) => {
+                    console.log('length', result.length)
+                    console.log('min', Math.min(...this.getCollectionScore(result)))
+                    console.log('max', Math.max(...this.getCollectionScore(result)))
+                })
+
+        })
+    }
 }
 
 module.exports = Users