server/app.js

   1 /**
   2  * Main application file
   3  */
   4
   5 'use strict';
   6
   7 // Set default node environment to development
   8 process.env.NODE_ENV = process.env.NODE_ENV || 'development';
   9 process.env.NODE_TLS_REJECT_UNAUTHORIZED = 0;
  10
  11 process.on('uncaughtException', function(err) {
  12   if (typeof err === 'object') {
  13     if (err.message) {
  14       console.log('\nMessage: ' + err.message)
  15     }
  16     if (err.stack) {
  17       console.log('\nStacktrace:')
  18       console.log('====================')
  19       console.log(err.stack);
  20     }
  21   } else {
  22     console.log('dumpError :: argument is not an object');
  23   }
  24 });
  25
  26
  27 var _ = require('lodash');
  28 var os = require('os');
  29 var http = require('http');
  30 var util = require('util');
  31 var crypto = require('crypto');
  32
  33 var express = require('express');
  34 var models = require('./models');
  35 var config = require('./config/environment');
  36
  37 var Setting = models.Setting;
  38
  39 // Setup server
  40 var app = express();
  41 var server = require('http').createServer(app);
  42 var io = require('socket.io')(server, {
  43   serveClient: (config.env === 'production') ? false : true,
  44   path: '/socket.io-client'
  45 });
  46
  47 var ami = require('asterisk-manager')('5038', '185.43.210.57', 'xcall', 'xcall1234', true);
  48 ami.keepConnected();
  49
  50 //Initialization Kue
  51 var kue = require('kue');
  52 kue.app.listen(3001);
  53
  54 var cronjob = require('cron').CronJob;
  55
  56 require('./config/express')(app);
  57 require('./routes')(app);
  58
  59 // Connect to database
  60 models
  61   .sequelize
  62   .sync()
  63   .then(function() {
  64
  65     // Populate DB with sample data
  66     if (config.seedDB) {
  67       require('./config/seed');
  68     }
  69
  70     // Start Cally Square Projects
  71     require('./config/socketio')(io);
  72     require('./config/kue.mail')(kue);
  73     require('./config/kue.chat')(kue);
  74     require('./config/kue.fax')(io, kue);
  75     require('./config/automations/mail')();
  76     require('./config/automations/fax')();
  77     require('./config/triggers/mail')();
  78     require('./config/imap')();
  79     require('./config/ami')(ami);
  80     require('./config/agi')();
  81     require('./config/autodialer')(ami);
  82     require('./config/integration')(io, ami);
  83
  84     // Start server
  85     server.listen(config.port, config.ip, function() {
  86       console.log('Express server listening on %d, in %s mode', config.port, app.get('env'));
  87
  88       // var netw0= os.networkInterfaces();
  89       // var myConf = null;
  90       //
  91       // for (var networkInterface in networkInterfaces) {
  92       //   if (networkInterfaces.hasOwnProperty(networkInterface)) {
  93       //
  94       //     var addresses = networkInterfaces[networkInterface];
  95       //
  96       //     for (var address in addresses) {
  97       //       if (addresses.hasOwnProperty(address)) {
  98       //         if (config.ip === addresses[address].address) {
  99       //           myConf = addresses[address];
 100       //           break;
 101       //         }
 102       //       }
 103       //     }
 104       //   }
 105       // }
 106       //
 107       // var postData = querystring.stringify(myConf);
 108       //
 109       // var options = {
 110       //   hostname: '192.168.2.133',
 111       //   port: 9000,
 112       //   path: '/api/servers',
 113       //   method: 'POST',
 114       //   headers: {
 115       //     'Content-Type': 'application/x-www-form-urlencoded',
 116       //     'Content-Length': postData.length
 117       //   }
 118       // };
 119       //
 120       // var req = http.request(options, function(res) {
 121       //   console.log('STATUS: ' + res.statusCode);
 122       //   console.log('HEADERS: ' + JSON.stringify(res.headers));
 123       //   res.setEncoding('utf8');
 124       //   res.on('data', function(chunk) {
 125       //     console.log('BODY: ' + chunk);
 126       //
 127       //     Setting
 128       //       .upsert({
 129       //         id: 1,
 130       //         license: JSON.parse(chunk).license,
 131       //         address: myConf.address,
 132       //         netmask: myConf.netmask,
 133       //         mac: myConf.mac
 134       //       })
 135       //       .then(function(setting) {
 136       //         console.log(setting);
 137       //       })
 138       //       .catch(function(err) {
 139       //         console.error(err);
 140       //       });
 141       //
 142       //   });
 143       //   res.on('end', function() {
 144       //     console.log('No more data in response.')
 145       //   })
 146       // });
 147       //
 148       // req.on('error', function(e) {
 149       //   console.log('problem with request: ' + e.message);
 150       // });
 151       //
 152       // // write data to request body
 153       // req.write(postData);
 154       // req.end();
 155     });
 156   })
 157   .catch(function(err) {
 158     console.error(err);
 159   });
 160
 161 // Connect to database history
 162 models
 163   .sequelize_history
 164   .sync()
 165   .then(function() {
 166     require('./config/history')(cronjob);
 167   })
 168   .catch(function(err) {
 169     console.error(err);
 170   });
 171
 172 // Expose app
 173 exports = module.exports = app;