-
-
- Rankings
- Submit Scores
- DivaBot
-
-
-
*/}
+ Menu
-- Rankings
- Submit Scores
- DivaBot
-
-
-
+
+
+ Rankings
+ Submit Scores
+ DivaBot
+
+
+
Menu
++ Rankings
+ Submit Scores
+ DivaBot
+
+
+ Event Data
-Event Editor
Can or no Can?
+Project DivaR
Welcome! This website is here to store and track all your Project Diva records for yours and others' enjoyment! @@ -2776,7 +2625,7 @@ function App() { return (
- {/*
+
- */}
+
@@ -2784,7 +2633,7 @@ function App() {
Thank you for using Project DivaR!
Your authentication code is ${authCode}!` + }, (err, info) => { + if (err) { + console.log(err.message) + } else { + console.log(info.envelope); + console.log(info.messageId); + } + }); +} + +function SendRegistrationEmail(username,emailTo,authCode) { + const transporter = nodemailer.createTransport({ + service: 'gmail', + auth: { + user: 'admin@projectdivar.com', + pass: process.env.GMAIL // naturally, replace both with your real credentials or an application-specific password + } + }); + transporter.sendMail({ + from: 'admin@projectdivar.com', + to: emailTo, + subject: 'Project DivaR Registration Code', + html: `${username},
Thank you for signing up for Project DivaR!
Your authentication code is ${authCode}!` + }, (err, info) => { + if (err) { + console.log(err.message) + } else { + console.log(info.envelope); + console.log(info.messageId); + } + }); +} + +function GetUserInfo(username) { + return db.query("select id,username,email,code_time from users where username=$1 limit 1",[username]) +} +function GetUserLoginAllowed(username,authCode) { + return db.query("select id,username,email,code_time,playstyle,twitter_name,twitch_name from users where username=$1 and code=$2 limit 1",[username,authCode]) +} +app.post('/authenticate/authToken',(req,res)=>{ + if (req.body&&req.body.username&&req.body.authCode) { + GetUserLoginAllowed(req.body.username.trim(),req.body.authCode.trim()) + .then((data)=>{ + if (data.rows.length>0) { + return db.query("select authentication_token from users where id=$1",[data.rows[0].id]) + } else { + return new Error("Failed login!") + } + }) + .then((data)=>{ + if (data.rows.length>0) { + res.status(200).json(data.rows[0]) + } else { + return new Error("Failed to get authentication token!") + } + }) + .catch((err)=>{ + res.status(500).send(err.message) + }) + } else { + res.status(400).send("Invalid Credentials!") + } +}) + +app.post('/authenticate/login',(req,res)=>{ + if (req.body&&req.body.username&&req.body.authCode) { + GetUserLoginAllowed(req.body.username.trim(),req.body.authCode.trim()) + .then((data)=>{ + if (data.rows.length>0) { + res.status(200).json(data.rows[0]) + } else { + return new Error("Failed login!") + } + }) + } else { + res.status(400).send("Invalid Credentials!") + } +}) + +app.post('/sendemail/login',function(req,res) { + if (req.body&&req.body.username) { + GetUserInfo(req.body.username.trim()) + .then((data)=>{ + if (data.rows.length>0) { + res.status(200).send("Email sent.") + //console.log(data.rows[0].code_time) + if (data.rows[0].code_time) { + if (moment(data.rows[0].code_time,"YYYY-MM-DD HH:mm:ss.SSSZ").diff(moment(),'minutes')<=-15) { + var authCode=Math.floor(Math.random()*90000)+10000 + SendLoginEmail(req.body.username,data.rows[0].email,authCode) + db.query("update users set code=$1,code_time=$3 where id=$2",[authCode,data.rows[0].id,moment()]) + } + //console.log(moment(data.rows[0].code_time,"YYYY-MM-DD HH:mm:ss.SSSZ").diff(moment(),'minutes')) + } else { + var authCode=Math.floor(Math.random()*90000)+10000 + SendLoginEmail(req.body.username,data.rows[0].email,authCode) + db.query("update users set code=$1,code_time=$3 where id=$2",[authCode,data.rows[0].id,moment()]) + } + } else { + return new Error("User does not exist!") + } + }) + .catch((err)=>{ + res.status(500).send(err.message) + }) + } else { + res.status(400).send("Invalid credentials!") + } +}) + +app.patch('/updateRegisteredState',function(req,res) { + if (req.body&&req.body.username&&req.body.authCode) { + GetUserLoginAllowed(req.body.username,req.body.authCode) + .then((data)=>{ + if (data.rows.length>0) { + return db.query("update users set registered=$1 where id=$2",[true,data.rows[0].id]) + } else { + throw new Error("Could not login!") + } + }) + .then((data)=>{ + res.status(200).send("Registered!") + }) + .catch((err)=>{ + res.status(500).send("Could not finish registration!") + }) + } else { + res.status(400).send("Invalid credentials!") + } +}) + +app.post('/sendemail/register',function(req,res) { + if (req.body&&req.body.username&&req.body.email) { + //Generate a token for the user to login with. + CheckUserExists(req.body.username.trim(),req.body.email.trim()) + .then((data)=>{ + var authCode=Math.floor(Math.random()*90000)+10000 + var authenticationToken=String(Math.floor(Math.random()*90000)+10000)+"-"+String(Math.floor(Math.random()*90000)+10000)+"-"+String(Math.floor(Math.random()*90000)+10000); + if (data.rows.length>0) { + //db.query("update users set code=$1 where id=$2",[authCode,data.rows[0].id]) + if (data.rows[0].registered) { + throw new Error("User already exists!") + } else { + return db.query("update users set code=$1 where id=$2 returning code",[authCode,data.rows[0].id]) + } + } else { + return db.query("insert into users(username,email,authentication_token,code) values($1,$2,$3,$4) returning code", + [req.body.username,req.body.email,authenticationToken,authCode]) + } + }) + .then((data)=>{ + if (data.rows.length>0) { + res.status(200).send("Email sent.") + SendRegistrationEmail(req.body.username,req.body.email,data.rows[0].code) + } else { + throw new Error("Something bad happened!") + } + }) + .catch((err)=>{ + res.status(500).send(err.message) + }) + } else { + res.status(400).send("Invalid credentials!") + } +}) + +function AuthenticateUser(username,auth) { + return db.query("select id,username,email from users where username=$1 and authentication_token=$2 limit 1",[username,auth]) +} + +app.post('/authenticateuser',function(req,res) { + if (req.body&&req.body.username&&req.body.authenticationToken) { + AuthenticateUser(req.body.username.trim(),req.body.authenticationToken.trim()) + .then((data)=>{ + if (data.rows.length>0) { + res.status(200).send("Authentication Success!") + } else { + throw new Error("Authentication Failed!") + } + }) + .catch((err)=>{ + res.status(500).send(err.message) + }) + } else { + res.status(400).send("Invalid credentials!") + } +}) + +app.post('/updateuser', function(req, res) { + var userId=-1; + if (req.body&&req.body.playStyle&&req.body.username&&req.body.authCode) { + GetUserLoginAllowed(req.body.username ,req.body.authCode) + .then((data)=>{ + if (data.rows.length>0) { + userId=data.rows[0].id + if (req.body.twitchName) { + db.query("update users set twitch_name=$1 where id=$2",[req.body.twitchName,userId]) + } + + + if (req.body.twitterName) { + return axios.get('https://api.twitter.com/1.1/users/show.json?screen_name='+req.body.twitterName, { + headers: { + /*BEARER*/ Authorization: 'Bearer '+process.env.TWITTER_BEARER //the token is a variable which holds the token + } + }) + } else + { + return {data:{}} + } + } else { + throw new Error("Could not login!") + } + }) + .then((data)=>{ + if (data.data.id) { + return db.query("update users set playstyle=$1,twitter=$2,twitter_name=$3 where id=$4",[req.body.playStyle,data.data.id,req.body.twitterName,userId]) + } else { + return db.query("update users set playstyle=$1 where id=$2",[req.body.playStyle,userId]) + } + }) + .then((data)=>{ + res.status(200).send("Successfully updated user settings!") + }) + .catch((err)=>{ + res.status(500).send(err.message) + }) + } else { + res.status(400).send("Invalid credentials!") + } +}) + +app.post('/getUserAuthData', function(req, res) { + if (req.body&&req.body.password&&req.body.userId) { + if (req.body.password===process.env.GUARDIANPASSWORD) { + db.query("select uploads,username,authentication_token from users where id=$1",[req.body.userId]) + .then((data)=>{ + if (data.rows.length>0) { + res.status(400).json(data.rows[0]) + db.query("update users set uploads=$1 where id=$2",[data.rows[0].uploads+1,req.body.userId]) + } else { + res.status(400).send("No user found!") + } + } + ) + .catch((err)=>{ + res.status(500).send(err.message) + }) + } else { + res.status(400).send("Authentication failed!") + } + } else { + res.status(400).send("Invalid credentials!"); + } +}) + +app.post('/passImageData',function(req,res) { + if (req.body&&req.body.user&&req.body.auth&&req.body.url) { + axios.post("http://projectdivar.com/image",{user:req.body.user,auth:req.body.auth,url:req.body.url}) + .then((data)=>{ + res.status(200).json(data.data) + }) + .catch((err)=>{ + res.status(500).send(err.message) + }) + } else { + res.status(400).send("Invalid credentials!") + } +}) + +app.post('/streamstart/:id',function (req,res){ + if (req.body&&req.body.username&&req.body.authentication_token) { + GetUserLoginAllowed(req.body.username.trim(),req.body.authentication_token.trim()) + .then((data)=>{ + if (data.rows.length>0) { + spawn("../divabotguardian/stream_monitor.sh",[Number(req.params.id)]) + res.status(200).send("Monitor started") + } else { + res.status(400).send("Failed to authenticate") + } + }) + .catch((err)=>{ + res.status(500).send(err.message) + }) + } else { + res.status(400).send("Invalid credentials!") + } +}) + +app.post('/streamtop/:id',function (req,res){ + exec("ps 43",(err,out,stderr)=>{ + if (err) { + res.status(500).send(`${err.message}`); + return; + } + if (stderr) { + res.status(500).send(`${stderr}`); + return; + } + res.status(200).send(`${out}`); + }) +}) + +app.post('/streaminfo/:id',function (req,res){ + if (req.body&&req.body.username&&req.body.authentication_token) { + GetUserLoginAllowed(req.body.username.trim(),req.body.authentication_token.trim()) + .then((data)=>{ + if (data.rows.length>0) { + exec("ps $(cat ../divabotguardian/processes/"+Number(req.params.id)+".ffmpeg)|wc -l",(err,out,stderr)=>{ + if (err) { + res.status(500).send(`${err.message}`); + return; + } + if (stderr) { + res.status(500).send(`${stderr}`); + return; + } + res.status(200).send(`${out}`); + }) + } else { + res.status(400).send("Failed to authenticate") + } + }) + .catch((err)=>{ + res.status(500).send(err.message) + }) + } else { + res.status(400).send("Invalid credentials!") + } +}) + +const lastscores={} + +app.post('/eventsubmit',function(req,res) { + const EVENTID=12; + + function submit() { + lastscores[req.body.rank]=Number(req.body.points) + db.query("insert into eventdata(eventid,rank,date,name,description,points) values($1,$2,$3,$4,$5,$6) returning *;", + [req.body.eventid,req.body.rank,req.body.date?req.body.date:new Date(),req.body.name,req.body.description,req.body.points]) + .then((data)=>{ + if (data.rows.length>0) { + res.status(200).send("Submitted.") + } else { + res.status(500).send("Failed to submit.") + } + }) + .catch((err)=>{ + res.status(500).send(`${err.message}`); + }) + } + + //add to table. + + function FurtherTierIsOkay(tier,scores,points) { + var tiers= [1,2,3,4,5,6,7,8,9,10,11,12,13,14,15,16,17,18,19,20,50,100,500,1000,2000,5000,10000,20000,30000,50000] + if (tier<=1) { + return true; + } else + { + //Find the previous tier. + var previousTier = -1; + for (var i=0;i