forked from cs4241-20a/a3-persistence
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathserver.js
More file actions
105 lines (86 loc) · 2.82 KB
/
server.js
File metadata and controls
105 lines (86 loc) · 2.82 KB
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
104
105
// server.js
// where your node app starts
// we've started you off with Express (https://expressjs.com/)
// but feel free to use whatever libraries or frameworks you'd like through `package.json`.
const express = require("express");
const expressLayouts = require('express-ejs-layouts');
const bodyParser = require("body-parser");
const app = express();
const mongoose = require('mongoose');
const passport = require('passport');
const flash = require('connect-flash');
const session = require('express-session');
//passport config
require('./config/passport')(passport)
//DB config
const db = require('./config/keys.js').mongoURI;
// Connect to MongoDB
mongoose
.connect(
db,
{ useNewUrlParser: true ,useUnifiedTopology: true}
)
.then(() => console.log('MongoDB Connected'))
.catch(err => console.log(err));
//EJS
app.use(expressLayouts)
app.set('view engine', 'ejs')
//bodyparser
app.use(express.urlencoded({ extended: true}))
//express session
app.use(session({
secret: 'secret',
resave: true,
saveUninitialized: true
}))
//passport
app.use(passport.initialize())
app.use(passport.session())
//connect flash
app.use(flash())
//global vars
app.use((req,res,next) => {
res.locals.success_msg = req.flash('success_msg')
res.locals.error_msg = req.flash('error_msg')
res.locals.error = req.flash('error')
next();
});
// make all the files in 'public' available
// https://expressjs.com/en/starter/static-files.html
app.use(express.static("public"));
//routes
app.use('/', require('./routes/index'))
app.use('/users', require('./routes/users'))
app.use('/groceries', require('./routes/groceries'))
const PORT = process.env.PORT || 5000;
app.listen(PORT, console.log(`Server started on port ${PORT}`));
const mongodb = require('mongodb');
const MongoClient = mongodb.MongoClient;
const uri = `
mongodb+srv://UserA3:${process.env.DBPASSWORD}@a3-cluster.gsvjm.azure.mongodb.net/<dbname>?retryWrites=true&w=majority`;
const client = new MongoClient(uri, { useNewUrlParser: true }, {useUnifiedTopology: true});
let collection = null;
client.connect(err => {
collection = client.db("datatest").collection("test")
});
app.post("/add", bodyParser.json(), function(request, response) {
console.log('body:', request.body);
collection.insertOne( request.body ).then( dbresponse => {
console.log( dbresponse )
response.json(dbresponse.ops[0])
})
})
app.post("/delete", bodyParser.json(), function(request, response){
console.log('delete body:', request.body);
collection
.deleteOne({ _id:mongodb.ObjectID( request.body.id ) })
.then( result => response.json( result ) )
})
app.post( '/update', (req,res) => {
collection
.updateOne(
{ _id:mongodb.ObjectID( req.body._id ) },
{ $set:{ item:req.body.item, price: req.body.price, dept: req.body.dept } }
)
.then( result => res.json( result ) )
})