Connection to rethinkDB

This commit is contained in:
danbulant 2020-02-16 17:49:58 +01:00
parent 68ddaf90a8
commit 1b66d266c1

View file

@ -1,18 +1,58 @@
let express = require("express"); let express = require("express");
let app = express(); let app = express();
var r = require('rethinkdb');
const PORT = 3001; const PORT = 3001;
console.log("Starting and loading, this may take a while..."); 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)=>{ app.get("/user/exists/:user", (req, res)=>{
res.json({ try {
code: 200, if(!req.params.user)return res.status(400).json({
message: "User exists", code: 400,
user: true, message: "Bad request, missing params",
avatar: "https://api.adorable.io/avatars/285/" + req.params.user, type: "e_missing_params"
type: "user_exists"
}); });
} 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)=>{ app.use((req, res, next)=>{