server.js

// Require our dependencies
var express = require('express'),
  exphbs = require('express-handlebars'),
  http = require('http'),
  mongoose = require('mongoose'),
  twitter = require('twitter'),
  routes = require('./routes'),
  config = require('./config'),
  streamHandler = require('./utils/streamHandler'),
  term = "mufc", bodyParser = require('body-parser');
// Create an express instance and set a port variable

var stream;
var app = express();
var port = process.env.PORT || 8080;
// Set handlebars as the templating engine
app.engine('handlebars', exphbs({ defaultLayout: 'main'}));
app.set('view engine', 'handlebars');

// Disable etag headers on responses
app.disable('etag');

// Connect to our mongo database
mongoose.connect('mongodb://localhost/react-tweets');

// Create a new ntwitter instance
var twit = new twitter(config.twitter);

// Index Route
app.get('/', routes.index);

// Page Route
app.get('/page/:page/:skip', routes.page);

// Term Update
app.use(bodyParser.json()); // support json encoded bodies
app.use(bodyParser.urlencoded({ extended: true })); // support encoded bodies
var a;
app.post('/query', function(request, response) {
  if (term === request.body.q) {
		return false;
	} 
	term = request.body.q;
	
	try {
		steam.destroy();
	} catch (error) {
		
	}
	twit.stream('statuses/filter', {"track" : term}, function(str){
	  stream = str;
	  streamHandler(stream,io);
	});		
  response.write('{}');
  response.end();
});



// Set /public as our static content dir
app.use("/", express.static(__dirname + "/public/"));

// Fire this bitch up (start our server)
var server = http.createServer(app).listen(port, function() {
  console.log('Express server listening on port ' + port);
});

// Initialize socket.io
var io = require('socket.io').listen(server);
var jobs=require("./jobs/purge");
jobs.start();