server.js

var express     = require('express'),
    http        = require('http'),
    path        = require('path'),
    mongoose    = require('mongoose'),
    winston     = require('winston'),
    Q           = require('q'),
    crawler     = require('./lib/crawler');

var Ad          = require('./lib/models/ad'),
    Search      = require('./lib/models/search'),
    City        = require('./lib/models/city');

var app = express();


// Connect to the mongo database
mongoose.connect('mongodb://localhost/lbc');



var logger = new (winston.Logger)();

if(app.get('env') === 'development') {
    logger.add(winston.transports.Console, {
        colorize: true
    });

    logger.cli();

    crawler.setLogger(logger);
};



// all environments
app.set('port', process.env.PORT || 3000);
app.set('views', __dirname + '/views');
app.use(express.logger('dev'));
app.use(express.bodyParser());
app.use(express.methodOverride());
app.use(app.router);

app.configure('development', function() {
    app.use(express.static(path.join(__dirname, 'app')));
});

app.configure('production', function() {
    app.use(express.static(path.join(__dirname, 'dist')));
});

// development only
if ('development' == app.get('env')) {
    app.use(express.errorHandler());
}

/**
 * Return search by id
 * @param  {String} id Search id
 * @return {Q.promise}
 */
var getSearchById = function(id) {
    var defer = Q.defer();

    Search
        .findById(id)
        .populate('cities', 'realName postcode')
        .exec(function(err, search) {
            defer.resolve(search);
        });

    return defer.promise;
}

var getAds = function(page, limit, filters) {
    var defer = Q.defer();

    page = page || 1;
    limit = limit || 30;
    filters = filters || {};

    return Ad.find(filters)
        .sort('-updatedAt')
        .skip((page-1)*limit)
        .limit(limit)
        .exec(function(err, ads) {
            if(err) {
                return defer.reject();
            }

            return defer.resolve(ads);
        });

    return defer.promise;
};

var getAdsBySearch = function(search, page, limit, filters) {

    // Filter by cities
    if(search.cities.length > 0) {

        var cities = [];

        for(var i = 0; i < search.cities.length; i++) {
            cities.push(search.cities[i].realName);
        }

        filters.city = { $in: cities };
    } 

    return getAds(page, limit, filters)
}

// Get ads
app.get('/ws/ads', function(req, res) {

    var page = req.query.page || 1;
    var limit = req.query.limit || 30;
    var filters = {};
    var ignored = req.query.ignored === 'true';
    var followed = req.query.followed === 'true';

    filters.ignored = req.query.ignored;

    if(followed) {
        filters.followed = true;
    }

    if(req.query.idSearch) {

        getSearchById(req.query.idSearch)
            .then(function(search) {
                return getAdsBySearch(search, page, limit, filters)
            })
            .then(function(ads) {
                res.send(ads)
            });
    } else {

        getSearch(page, limit, filters)
            .then(function(ads) {
                res.send(ads)
            });
    }
});

// Get ad
app.get('/ws/ads/:idAd', function(req, res) {

    return Ad
        .findById(req.params.idAd, function(err, ad) {

            if(ad.partial == true) {
                return crawler.updateAd(ad)
                    .then(function(ad) {
                        res.send(ad);
                    });
            }

            res.send(ad);
        });
});

// Put ad
app.put('/ws/ads/:idAd', function(req, res) {

    var $set = {
        ignored: req.body.ignored,
        partial: req.body.partial,
        followed: req.body.followed,
    };

    return Ad
        .findByIdAndUpdate(req.params.idAd, {
            $set: $set
        }, function(err, ad) {
            res.send(ad);
        });
});


// Get cities
app.get('/ws/cities', function(req, res) {
    var limit = req.params.limit || 10;
    var filters = {};

    if(req.query.q) {
        filters.realName = {
            $regex: req.query.q+'.*',
            $options: 'i'
        };
    }

    return City
        .find(filters)
        .limit(limit)
        .sort('-population')
        .exec(function(err, cities) {
            if(err) {
                return res.status(404).send(err);
            }

            return res.send(cities);
        });
});

// Get searches
app.get('/ws/searches', function(req, res) {
    Search
        .find()
        .populate('cities', 'realName postcode')
        .exec(function(err, searches) {
            if(err) {
                return res.status(404).send(err);
            }

            return res.send(searches);
        });
});

// Get search
app.get('/ws/searches/:idSearch', function(req, res) {

    if(!req.params.idSearch) {
        return res.status(404).send('Search not found');
    }

    return Search
        .findById(req.params.idSearch)
        .populate('cities', 'realName postcode')
        .exec(function(err, search) {
            if(err) {
                return res.status(404).send(err);
            }

            return res.send(search);
        });
});

// Create search
app.post('/ws/searches', function(req, res) {

    var search = new Search(req.body).save(function(err) {
        if(err) {
            return res.status(404).send(err);
        }

        return search
            .populate('cities', 'realName postcode', function() {
                return res.send(search);
            });
    });
});

// Update search
app.post('/ws/searches/:idSearch', function(req, res) {

    if(!req.params.idSearch) {
        return res.status(404).send('Search not found');
    }

    var datas = req.body;

    return Search
        .findById(req.params.idSearch)
        .exec(function(err, search) {
            if(err) {
                return res.status(404).send(err);
            }
            
            search.title = datas.title;
            search.photoOnly = datas.photoOnly;
            search.updatedAt = datas.updatedAt;
            search.updateFrequency = datas.updateFrequency;
            search.cities = [];

            for(var i in datas.cities) {
                search.cities.push(datas.cities[i]._id);
            }

            search.urls = [];

            for(var i in datas.urls) {
                search.urls.push(datas.urls[i]);
            }

            return search.save(function(err) {
                if(err) {
                    return res.status(404).send(err);
                }

                return search
                    .populate('cities', 'realName postcode', function() {
                        return res.send(search);
                    });
            });
        });
});


// Get search ads
app.get('/ws/searches/:idSearch/ads', function(req, res) {

    if(!req.params.idSearch) {
        return res.status(404).send('Search not found');
    }

    return Search
        .findById(req.params.idSearch)
        .populate('cities', 'realName')
        .exec(function(err, search) {

            if(err) {
                return res.status(404).send(err);
            }

            var page = req.query.page || 1;
            var limit = req.query.limit || 30;

            var filters = {}

            // Filter by cities
            if(search.cities.length > 0) {

                var cities = [];

                for(var i = 0; i < search.cities.length; i++) {
                    cities.push(search.cities[i].realName);
                }

                filters.city = { $in: cities };
            }

            return Ad.find(filters)
                .sort('-updatedAt')
                .skip((page-1)*limit)
                .limit(limit)
                .exec(function(err, ads) {
                    if(err) {
                        return res.status(404).send(err);
                    }

                    return res.send(ads);
                });
        });
});


http.createServer(app).listen(app.get('port'), function() {
    console.log('Express server listening on port ' + app.get('port') + ' in '+app.get('env')+' mode');
});