Resolve "Update highscores"

Closes #6 (closed)

backend/api/highscores.js

@@ -37,16 +37,15 @@ router.get("/gamescore/:userid/:gameid", (req, res) => {
   );
 });
 
-router.post("/highscore", (req, res) => {
-  MongoClient.connect(
-    connectionUrl,
-    { useNewUrlParser: true, useUnifiedTopology: true },
-    (err, client) => {
-      // Unable to connect to database
-      if (err) {
-        res.sendStatus(500); // Internal server error
+router.post("/highscore", async (req, res) => {
+  updateHighscore(req.body.gameid, req.body.userid, req.body.value).then(
+    result => {
+      if (result == 500) {
+        res.sendStatus(500);
         return;
       }
+      res.json(result);
+      return;
 
       const db = client.db("gameWare");
       const collection = "highscores";
@@ -73,6 +72,40 @@ router.post("/highscore", (req, res) => {
   );
 });
 
+function updateHighscore(gameid, userid, value) {
+  return new Promise((resolve, reject) => {
+    MongoClient.connect(
+      connectionUrl,
+      { useNewUrlParser: true, useUnifiedTopology: true },
+      (err, client) => {
+        // Unable to connect to database
+        if (err) {
+          resolve(500); // Internal server error
+        }
+
+        const db = client.db("gameWare");
+        const collection = "highscores";
+
+        db.collection(collection).updateOne(
+          {
+            gameid: mongo.ObjectID(gameid),
+            userid: mongo.ObjectID(userid)
+          },
+          { $max: { value: value } },
+          { upsert: true },
+          (err, result) => {
+            if (err) {
+              resolve(500);
+              return;
+            }
+            resolve(result);
+          }
+        );
+      }
+    );
+  });
+}
+
 router.get("/userscore/:userid", (req, res) => {
   // Connect to database
   MongoClient.connect(