app.js 3.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123
  1. 'use strict';
  2. // nodejs modules
  3. const path = require('path'),
  4. fs = require('fs'),
  5. os = require('os');
  6. process.env.NODE_CONFIG_DIR = `${__dirname}/config`;
  7. // npm modules
  8. const express = require('express'),
  9. session = require('express-session'),
  10. mongoose = require('mongoose'),
  11. MongoStore = require('connect-mongo')(session),
  12. bodyParser = require('body-parser'),
  13. config = require('config'),
  14. request = require('request'),
  15. passport = require('passport'),
  16. bcrypt = require('bcrypt'),
  17. LocalStrategy = require('passport-local').Strategy,
  18. GitHubStrategy = require('passport-github').Strategy,
  19. DiscordStrategy = require('passport-discord').Strategy,
  20. passportSocketIo = require("passport.socketio");
  21. // global module
  22. const global = require('./logic/global');
  23. // database
  24. const MongoDB = mongoose.connect('mongodb://172.16.0.1:27017/musare').connection;
  25. MongoDB.on('error', (err) => {
  26. console.log('Database error: ' + err.message);
  27. });
  28. MongoDB.once('open', () => {
  29. console.log('Connected to database');
  30. setupExpress();
  31. });
  32. // setup express and socket.io
  33. function setupExpress() {
  34. const app = express(MongoDB);
  35. const server = app.listen(80);
  36. global.io = require('socket.io')(server);
  37. // other custom modules
  38. const coreHandler = require('./logic/coreHandler'),
  39. socketHandler = require('./logic/socketHandler'),
  40. expressHandler = require('./logic/expressHandler');
  41. global.db = {
  42. user: require('./schemas/user')(mongoose),
  43. station: require('./schemas/station')(mongoose),
  44. song: require('./schemas/song')(mongoose),
  45. queueSong: require('./schemas/queueSong')(mongoose)
  46. };
  47. const mongoStore = new MongoStore({'mongooseConnection': MongoDB});
  48. app.use(session({
  49. secret: config.get('secret'),
  50. key: 'connect.sid',
  51. store: mongoStore,
  52. resave: true,
  53. saveUninitialized: true
  54. }));
  55. global.io.use(passportSocketIo.authorize({
  56. cookieParser: require('cookie-parser'),
  57. key: 'connect.sid',
  58. secret: config.get('secret'),
  59. store: mongoStore,
  60. success: function (data, accept) {
  61. console.log('successful connection to socket.io');
  62. accept();
  63. },
  64. fail: function (data, message, error, accept) {
  65. if (error) throw new Error(message);
  66. accept();
  67. }
  68. }));
  69. app.use(passport.initialize());
  70. app.use(passport.session());
  71. passport.serializeUser((user, done) => {
  72. done(null, user);
  73. });
  74. passport.deserializeUser((user, done) => {
  75. done(null, user);
  76. });
  77. passport.use(new LocalStrategy({usernameField: 'email'}, (email, password, done) => {
  78. process.nextTick(() => {
  79. global.db.user.findOne({"email.address": email}, (err, user) => {
  80. if (err) return done(err);
  81. if (!user) return done(null, false);
  82. bcrypt.compare(password, user.services.password.password, function(err, res) {
  83. if (res) {
  84. return done(null, user);
  85. } else if (err) {
  86. return done(err);
  87. } else {
  88. return done(null, false);
  89. }
  90. });
  91. });
  92. });
  93. }));
  94. app.use(bodyParser.json());
  95. app.use(bodyParser.urlencoded({
  96. extended: true
  97. }));
  98. app.get('*', (req, res) => {
  99. res.redirect('/');
  100. });
  101. socketHandler(coreHandler, global.io);
  102. expressHandler(coreHandler, app);
  103. }