forked from kimjon0509/midterm
/
server.js
146 lines (132 loc) · 4.42 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
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
// load .env data into process.env
require('dotenv').config();
// Web server config
const PORT = process.env.PORT || 8080;
const ENV = process.env.ENV || "development";
const express = require("express");
const bodyParser = require("body-parser");
const sass = require("node-sass-middleware");
const app = express();
const morgan = require('morgan');
const socketio = require('socket.io')
const http = require('http')
const cookieSession = require ('cookie-session')
const server = http.createServer(app)
const io = socketio(server)
// PG database client/connection setup
const { Pool } = require('pg');
const dbParams = require('./lib/db.js');
const db = new Pool(dbParams);
db.connect();
// Load the logger first so all (static) HTTP requests are logged to STDOUT
// 'dev' = Concise output colored by response status for development use.
// The :status token will be colored red for server error codes, yellow for client error codes, cyan for redirection codes, and uncolored for all other codes.
app.use(morgan('dev'));
app.set("view engine", "ejs");
app.use(bodyParser.urlencoded({ extended: true }));
app.use(cookieSession({name: 'session',keys: ['smashthekeyboard']}));
app.use("/styles", sass({
src: __dirname + "/styles",
dest: __dirname + "/public/styles",
debug: true,
outputStyle: 'expanded'
}));
app.use(express.static("public"));
// Separated Routes for each Resource
// Note: Feel free to replace the example routes below with your own
const usersRoutes = require("./routes/users");
const widgetsRoutes = require("./routes/widgets");
const favouritesRoutes = require("./routes/favourites");
const listingsRoutes = require("./routes/listings");
const newListingsRoutes = require("./routes/new-listings");
const registerPageRoutes = require("./routes/register-page");
const messagesRoutes = require("./routes/messages");
const productsRoutes = require("./routes/products");
const searchRoutes = require("./routes/search");
const dropdownRoutes = require("./routes/dropdown");
const myProducts = require("./routes/myProduct");
// Mount all resource routes
// Note: Feel free to replace the example routes below with your own
app.use("/api/users", usersRoutes(db));
app.use("/api/widgets", widgetsRoutes(db));
// Note: mount other resources here, using the same pattern above
app.use("/api/favourites", favouritesRoutes(db));
app.use("/api/listings", listingsRoutes(db));
app.use("/api/newListings", newListingsRoutes(db));
app.use("/api/register", registerPageRoutes(db));
app.use("/api/messages", messagesRoutes(db, io));
app.use("/api/products", productsRoutes(db));
app.use("/api/search", searchRoutes(db));
app.use("/api/dropdown", dropdownRoutes(db));
app.use("/api/myproducts", myProducts(db) );
// Home page
// Warning: avoid creating more routes in this file!
// Separate them into separate routes files (see above).
app.get("/", (req, res) => {
let templateVars = {user: req.session.user_id};
if (req.session.user_id) {
console.log("check")
db.query(`
SELECT *
FROM products;
`)
.then( response=> {
templateVars.products = response.rows
})
.then(() => {
getUserInfo(req.session.user_id, db)
.then((user) => {
templateVars.user_info = user
console.log(templateVars)
res.render("index", templateVars);
})
})
} else {
db.query(`
SELECT *
FROM products;
`)
.then( response=> {
res.render("index", {products: response.rows, user: req.session.user_id});
})
}
});
app.post('/logout', (req, res) => {
req.session = null;
res.redirect('/');
});
app.post("/login", (req, res) => {
console.log(req.body, 'login body')
const {email, password} = req.body;
getUserByEmail(email, db).then (user => {
if (!user || !password || user.password !== password) {
res.status(401).send("Incorrect credentials");
}
else {
req.session.user_id = user.id;
res.redirect("/");
}
})
})
const getUserByEmail = (email, db) => {
return db.query(`
SELECT users.* FROM users
WHERE users.email = $1`,[email])
.then ( (response) => {
console.log(response.rows);
return response.rows[0]
})
}
const getUserInfo = (id, db) => {
return db.query(`
SELECT *
FROM users
WHERE users.id= $1`,[id])
.then ( (response) => {
console.log(response.rows[0].id);
return response.rows[0]
})
}
server.listen(PORT, () => {
console.log(`Example app listening on port ${PORT}`);
});