alpha

Author: h0m36r0wn

.gitignore

@@ -0,0 +1,2 @@
+node_modules/
+node_modules/*

Gulpfile.js

@@ -0,0 +1,37 @@
+var gulp = require('gulp');
+var sass = require('gulp-sass');
+var nodemon  = require('gulp-nodemon');
+
+
+/*
+* sass compilation task
+**********************/
+gulp.task('sass', function() {
+    gulp.src(['./public/scss/app.scss','./public/scss/response.scss'])
+        .pipe(sass().on('error', sass.logError))
+        .pipe(gulp.dest('./public/css/'))
+});
+
+/*
+* nodemon task
+*********************************/
+gulp.task('nodemon',function(cb){
+  var called = false;
+  var initialized = false;
+  return nodemon({
+    script:'./bin/www',
+    ext:'js',
+    watch:['./routes/','./controllers/','./models/','./bin'],
+    legacyWatch:true,
+  });
+})
+
+gulp.task('sass:watch',function(){
+    gulp.watch('./public/scss/*.scss',['sass']);
+})
+
+
+/*
+* defaul task -  nodemon and sass:watch
+*******************************************************/
+gulp.task('default',['nodemon','sass:watch']);

app.js

@@ -0,0 +1,61 @@
+var express = require('express');
+var path = require('path');
+var favicon = require('serve-favicon');
+var logger = require('morgan');
+var CONFIG = require('./bin/config');
+var cookieParser = require('cookie-parser');
+var bodyParser = require('body-parser');
+var session = require('express-session');
+var index = require('./routes/home');
+var session = require('express-session');
+var flash = require('connect-flash');
+var routes = require('./routes/');
+var app = express();
+var cors = require('cors');
+var passportObj = require('./bin/passport');
+// view engine setup
+app.set('views', path.join(__dirname, 'views'));
+app.set('view engine', 'ejs');
+app.use(cors());
+// uncomment after placing your favicon in /public
+//app.use(favicon(path.join(__dirname, 'public', 'favicon.ico')));
+app.use(logger('dev'));
+app.use(bodyParser.json({limit:'50mb'}));
+app.use(bodyParser.urlencoded({ extended: false , limit:'50mb'}));
+app.use(cookieParser());
+app.use(express.static(path.join(__dirname, 'public')));
+
+app.use(session({
+  secret:CONFIG.SECRET,
+  saveUninitialized:true,
+  resave:true
+}));
+app.use(flash());
+app.use(passportObj.initialize());
+app.use(passportObj.startSession());
+
+app.use('/', index);
+
+
+Object.keys(routes).forEach((routeName) => {
+    app.use('/'+routeName, routes[routeName]);
+})
+// catch 404 and forward to error handler
+app.use(function(req, res, next) {
+  var err = new Error('Not Found');
+  err.status = 404;
+  next(err);
+});
+
+// error handler
+app.use(function(err, req, res, next) {
+  // set locals, only providing error in development
+  res.locals.message = err.message;
+  res.locals.error = req.app.get('env') === 'development' ? err : {};
+
+  // render the error page
+  res.status(err.status || 500);
+  res.render('error');
+});
+
+module.exports = app;

bin/config.js

@@ -0,0 +1,24 @@
+module.exports = {
+
+	"SESSION_SECRET":"RESPONSE",
+	"ROLES":{
+		"ADMIN":"admin",
+		"SECURITY_TEAM":"security_team",
+		"RESIDENT":"resident"
+	},
+	"DATABASE":"mongodb://localhost/response_center",
+	"DATABASE_PROD":"mongodb://h0m36r0wn:[email protected]:45299/response_center",
+	"SECRET":"SOS",
+	"REPORT_TYPES":{
+		"EMERGENCY":"emergency",
+		"FIRE":"fire",
+		"EQUAKE":"earthquake",
+		"FLOOD":"flood",
+		"MED_EMERGENCY":"medical_emergency",
+		"BURGLARY":"burglary",
+		"INTIMIDATION":"intimidation",
+		"HEINOUS":"heinous_crime",
+		"ACCIDENT":"accident",
+		"OTHER":"other"
+	}
+}

bin/passport.js

@@ -0,0 +1,81 @@
+'use strict';
+var passport = require('passport');
+var LocalStrategy = require('passport-local');
+var UserMdl = require('../models/Users_mdl');
+var CONFIG = require('./config');
+class Passport{
+	constructor(){
+		this.strategy = new LocalStrategy({
+			usernameField:'email', passwordField:'password', passReqToCallback:true
+		}, function(req, email, password, next){
+			UserMdl.findUserByEmail(email).then((userObj) => {
+				if(userObj){
+					if(userObj.password === password){
+						return next(null, userObj);
+					}else{
+						return next(null, false,req.flash('loginMessage','Email and password does not match'))
+					}
+				}else{
+					return next(null, false, req.flash('loginMessage','The email you entered does not exists'))
+				}
+
+			}) 	
+		})
+	}
+
+	initialize(){
+		passport.use(this.strategy);
+		passport.serializeUser((user, done ) => {
+			done(null, user);
+		})
+		passport.deserializeUser((user, done) => {
+			done(null, user);
+		})
+		return passport.initialize();
+	}
+
+	startSession(){
+		return passport.session();
+	}
+
+	authenticate(){
+		return passport.authenticate('local',{
+			failureRedirect:'/response/signin',
+			failureFlash:true
+		});
+	}
+
+	checkAuthentication(req, res, next){
+		if(req.isAuthenticated()){
+			return next();
+		}else{
+			res.redirect('/response/signin');
+		}
+	}
+
+	validateProfile(req, res ,next){
+		switch(req.user.role){
+			case CONFIG.ROLES.SECURITY_TEAM :
+				res.redirect('/admin/map');
+				break;
+			case CONFIG.ROLE.ADMIN :
+				res.redirect('/admin/dashboard');
+				break;
+			default:
+				res.redirect('/response/signout');
+		}
+	}
+
+	logout(req, res, next){
+		req.logout();
+		req.session.destroy();
+		res.redirect('/response/signin');
+	}
+}
+
+
+let passportObj = new Passport();
+module.exports = passportObj;
+
+
+

bin/www

@@ -0,0 +1,107 @@
+#!/usr/bin/env node
+'use strict';
+/**
+ * Module dependencies.
+ */
+
+var app = require('../app');
+var debug = require('debug')('response-center:server');
+var http = require('http');
+var mongoose = require('mongoose');
+var CONFIG = require('./config');
+var db = mongoose.connect(CONFIG.DATABASE);
+var conn = mongoose.connection;
+mongoose.Promise = global.Promise;
+
+/**
+ * Get port from environment and store in Express.
+ */
+
+var port = normalizePort(process.env.PORT || '3000');
+app.set('port', port);
+
+/**
+ * Create HTTP server.
+ */
+
+var server = http.createServer(app);
+var io =  require('socket.io')(server, {origins:'*:*'});
+/**
+ * Listen on provided port, on all network interfaces.
+ */
+
+
+conn.on('error', console.error.bind(console, 'connection error'));
+conn.on('open', () => {
+  server.listen(port);
+  server.on('error', onError);
+  server.on('listening', onListening);
+  io.on('connection', (socket) => {
+    console.log('user connected');
+    socket.on('sos', (location) => {
+      console.log('sos recieved');
+      io.emit('sendSos', location)
+    })
+  })
+})
+
+
+/**
+ * Normalize a port into a number, string, or false.
+ */
+
+function normalizePort(val) {
+  var port = parseInt(val, 10);
+
+  if (isNaN(port)) {
+    // named pipe
+    return val;
+  }
+
+  if (port >= 0) {
+    // port number
+    return port;
+  }
+
+  return false;
+}
+
+/**
+ * Event listener for HTTP server "error" event.
+ */
+
+function onError(error) {
+  if (error.syscall !== 'listen') {
+    throw error;
+  }
+
+  var bind = typeof port === 'string'
+    ? 'Pipe ' + port
+    : 'Port ' + port;
+
+  // handle specific listen errors with friendly messages
+  switch (error.code) {
+    case 'EACCES':
+      console.error(bind + ' requires elevated privileges');
+      process.exit(1);
+      break;
+    case 'EADDRINUSE':
+      console.error(bind + ' is already in use');
+      process.exit(1);
+      break;
+    default:
+      throw error;
+  }
+}
+
+/**
+ * Event listener for HTTP server "listening" event.
+ */
+
+function onListening() {
+  var addr = server.address();
+  var bind = typeof addr === 'string'
+    ? 'pipe ' + addr
+    : 'port ' + addr.port;
+  debug('Listening on ' + bind);
+}