-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathserver.js
103 lines (89 loc) · 2.53 KB
/
server.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
const express=require('express');
const mysql=require('mysql');
const cors=require('cors');
const PORT = process.env.PORT || 4000;
const app = express();
const connection=mysql.createConnection({
host: 'localhost',
user:'root',
password:'password',
database: 'acme'
});
SELECT_ALL='SELECT * FROM users';
connection.connect((err)=>{
if(err){
throw err;
}
console.log('MySQL Connected...');
});
app.use(cors());
app.get('/',(req,res)=>{
res.send('go to /users to see all users')
});
app.get('/users',(req,res)=>{
connection.query(SELECT_ALL,(err,results)=>{
if(err){
return res.send(err)
}
else{
return res.json({
data: results
})
}
})
});
app.get('/users/add',(req,res)=> {
const {username,password}=req.query;
const INSERT_USER=`INSERT INTO users (username,userPasswords) VALUE (\'${username}\',sha2(CONCAT(\'${password}\',\'boring\'),256))`;
connection.query(INSERT_USER, (err, result) => {
if (err) throw err;
console.log(result);
res.send('user successfully added');
});
});
app.get('/users/get',(req,res)=> {
const {username,password}=req.query;
const GET_USER=`select * from users where username=\'${username}\' and userPasswords=sha2(CONCAT(\'${password}\',\'boring\'),256)`;
connection.query(GET_USER, (err, result) => {
if(err){
return res.send(err)
}
else{
return res.json({
data: result
})
}
});
});
//UPDATE users set userPasswords=sha2(CONCAT('stevepass', 'boring'),256) where username='steve';
app.get('/users/send', (req,res)=>{
const {userID,toUserID,message}=req.query;
const SEND_TO_USER='INSERT INTO messages (messageDATE,messageDATETIME,message,userID,toUserID) VALUE(current_date(),now(),\''+message+'\','+userID+','+toUserID+')';
connection.query(SEND_TO_USER,(err,result)=>{
if(err){
return res.send(err)
}
else{
return res.json({
data:result
})
}
})
});
app.get('/users/received', (req,res)=>{
const {userID,toUserID}=req.query;
const SEND_TO_USER='SELECT * FROM messages WHERE (userID ='+userID+ ' AND toUserID='+ toUserID +') OR (userID ='+toUserID+ ' AND toUserID='+ userID +')ORDER BY messageDATETIME ASC';
connection.query(SEND_TO_USER,(err,result)=>{
if(err){
return res.send(err)
}
else{
return res.json({
data:result
})
}
})
});
app.listen(PORT, ()=>{
console.log('App running on port 4000');
});