import React from 'react'; import { StaticRouter } from 'react-router-dom'; import express from 'express'; import { renderToString } from 'react-dom/server'; import serialize from 'serialize-javascript'; const bodyParser = require('body-parser') const session = require('express-session') const pgSession = require('connect-pg-simple')(session); import App from './frontend/app'; import { pool } from './db'; import { authUser, createUser, getUserById } from './user'; import { queryBuildingAtPoint } from './building'; // create server const server = express(); // reference packed assets const assets = require(process.env.RAZZLE_ASSETS_MANIFEST); // disable header server.disable('x-powered-by'); // serve static files server.use(express.static(process.env.RAZZLE_PUBLIC_DIR)); // parse POSTed json body server.use(bodyParser.json()); // handle user sessions const sess = { name: 'cl.session', store: new pgSession({ pool: pool, tableName : 'user_sessions' }), secret: process.env.APP_COOKIE_SECRET, resave: false, cookie: { maxAge: 30 * 24 * 60 * 60 * 1000 } // 30 days }; if (server.get('env') === 'production') { // trust first proxy server.set('trust proxy', 1) // serve secure cookies sess.cookie.secure = true } server.use(session(sess)); // handle HTML routes (server-side rendered React) server.get('/*.html', frontendRoute); server.get('/', frontendRoute); function frontendRoute(req, res) { const context = {}; const data = {}; if (req.session.user_id) { getUserById(req.session.user_id).then(function(user){ data.user = user; console.log(user); renderHTML(context, data, req, res) }).catch(function(){ renderHTML(context, data, req, res); }); } else { renderHTML(context, data, req, res); } } function renderHTML(context, data, req, res){ const markup = renderToString( ); if (context.url) { res.redirect(context.url); } else { res.status(200).send( ` Colouring London ${ assets.client.css ? `` : '' } ${ process.env.NODE_ENV === 'production' ? `` : `` }
${markup}
` ); } } // GET building at point server.get('/buildings', function(req, res){ const { lng, lat } = req.query queryBuildingAtPoint(lng, lat).then(function(result){ if (result) { res.send(result) } else { res.status(404).send({error:'Not Found'}) } }).catch(function(error){ res.send({error:'Database error'}) }) }) // POST new user server.post('/users', function(req, res){ const user = req.body; if (req.session.user_id) { res.send({error: 'Already signed in'}); } if (user.email){ if (user.email != user.confirm_email) { res.send({error: "Email did not match confirmation."}); } } else { user.email = null; } createUser(user).then(function(result){ if (result.user_id) { req.session.user_id = result.user_id; res.send({user_id: result.user_id}); } else { req.session.user_id = undefined; res.send({error: result.error}); } }).catch(function(err){ console.error(err); res.send({error: 'Server error'}) }); }); // POST user auth server.post('/login', function(req, res){ authUser(req.body.username, req.body.password).then(function(user) { if (user.user_id) { req.session.user_id = user.user_id; } else { req.session.user_id = undefined; } res.send(user); }).catch(function(error){ res.send(error); }) }); // POST user logout server.post('/logout', function(req, res){ req.session.destroy(function(err){ if (err) { console.error(err); res.send({error: 'Failed to end session'}) } res.send({success: true}); }); }); // GET own user info server.get('/users/me', function(req, res){ if (!req.session.user_id) { res.send({error: 'Must be logged in'}); return } getUserById(req.session.user_id).then(function(user){ res.send(user); }).catch(function(error){ res.send(error); }); }); export default server;