From 1b66d266c11010832045e3d1f5b989a392968624 Mon Sep 17 00:00:00 2001
From: danbulant <danbulant@gmail.com>
Date: Sun, 16 Feb 2020 17:49:58 +0100
Subject: [PATCH] Connection to rethinkDB

---
 server/index.js | 54 ++++++++++++++++++++++++++++++++++++++++++-------
 1 file changed, 47 insertions(+), 7 deletions(-)

diff --git a/server/index.js b/server/index.js
index e436e70..2262768 100644
--- a/server/index.js
+++ b/server/index.js
@@ -1,18 +1,58 @@
 let express = require("express");
 let app = express();
+var r = require('rethinkdb');
 const PORT = 3001;
 
 console.log("Starting and loading, this may take a while...");
 
+var connection = null;
+r.connect({ host: 'localhost', port: 28015 }, function (err, conn) {
+    if (err) throw err;
+    connection = conn;
+});
 
 app.get("/user/exists/:user", (req, res)=>{
-    res.json({
-        code: 200,
-        message: "User exists",
-        user: true,
-        avatar: "https://api.adorable.io/avatars/285/" + req.params.user,
-        type: "user_exists"
-    });
+    try {
+        if(!req.params.user)return res.status(400).json({
+            code: 400,
+            message: "Bad request, missing params",
+            type: "e_missing_params"
+        });
+    } catch (e) {
+        if (!req.params.user) return res.status(400).json({
+            code: 400,
+            message: "Bad request, missing params",
+            type: "e_missing_params"
+        });
+    }
+
+    r.db("ester_os").table("users").filter(r.row("sysName").eq(req.params.user)).run(connection, (err, cursor) => {
+        if(err){
+            console.error(err);
+            return res.status(500).json({
+                code: 500,
+                message: "Internal error happened (DB error)",
+                type: "e_internal"
+            });
+        }
+        cursor.toArray(function (err, result) {
+            if (err){
+                console.error(err);
+                return res.status(500).json({
+                    code: 500,
+                    message: "Internal error happened (DB error at cursor)",
+                    type: "e_internal"
+                });
+            }
+            res.status(200).json({
+                code: 200,
+                message: "Success, see response",
+                exists: (result.length ? true : false),
+                response: result[0],
+                type: "user_data"
+            })
+        });
+    })
 });
 
 app.use((req, res, next)=>{