MongoDb recherche par communes

var yengin = require('yengin'),
    express = require('express'),
    bodyParser = require('body-parser'),
    MongoClient = require('mongodb').MongoClient,
    dbMap = require('./core/dbmap'),
    settings = require('./core/settings');

/* Création du serveur */
var app = express();
app.use(bodyParser.urlencoded({ extended: false }));

/* Base de données (mise en cache) */
var dbCache = false;

/* Connexion à la base de données */
MongoClient.connect(settings.connectChain, function (err, db) {
    dbCache = require('./core/dbcache')(db);
    setInterval(function () { dbCache.action(); }, 5*60*1000);
    dbCache.add('communes');
    dbCache.action();
});

/*
*   JSON Answers
*/

var jsonObj = function () {
    var obj = {};
    obj._pack = {'success': false, 'error': false, 'data': [], 'timer': 0};
    obj._timer = (new Date()).getTime();
    obj.success = function (data) {
        obj._pack.success = true;
        obj._pack.error = false;
        obj._pack.data = data;
    };
    obj.end = function (res) {
        obj._pack.timer = (new Date()).getTime()-obj._timer;
        res.writeHead(200, {'Content-Type': 'application/json; charset=utf-8'});
        res.write(JSON.stringify(obj._pack));
        res.end();
    };
    return obj;
};

/*
*   Routes
*/

app.get('/', function (req, res) {
    res.writeHead(200, {'Content-Type': 'text/html; charset=utf-8'});
    res.end();
});

app.get('/communes', function (req, res) {
    /* Données */
    var json = jsonObj(), q = req.query.q;

    /* Recherche */
    q = q.toLowerCase()
        .replace(/[ç]/g,'c').replace(/[ñ]/g,'n')
        .replace(/[áàâäãå]/g,'a').replace(/[éèêë]/g,'e')
        .replace(/[íìîï]/g,'i').replace(/[óòôöõ]/g,'o')
        .replace(/[úùûü]/g,'u').replace(/[ýÿ]/g,'y')
        .replace(/[^\w ]/g,'')
        .replace(/ +/g,'|');

    /* Communes */
    if(q.length) {
        dbCache.on('communes', function (docs) {

            /* Recherche dans la collection */
            var results = dbMap(docs, function () {
                var qsearch, entries = [this.nom,this.cp].join(' ').toLowerCase();
                /* Remplace les accents */
                entries = entries.replace(/[ç]/g,'c').replace(/[ñ]/g,'n')
                    .replace(/[áàâäãå]/g,'a').replace(/[éèêë]/g,'e')
                    .replace(/[íìîï]/g,'i').replace(/[óòôöõ]/g,'o')
                    .replace(/[úùûü]/g,'u').replace(/[ýÿ]/g,'y')
                    .replace(/[^\w ]/g,'');
                /* Effectue une recherche */
                qsearch = entries.match(new RegExp('('+q+')', 'gi'));
                if(qsearch != null) {
                    this.emit({
                        'id': this.id
                    }, {
                        'nom': this.nom,
                        'cp': this.cp,
                        'count': qsearch.length
                    });
                }
            });

            /* Dans l'ordre */
            results = yengin.quickSortArray(results, function (a,b) {
                var sa = a[1].count, sb = b[1].count;
                return (sa == sb ? 0 : (sa > sb ? -1 : 1));
            });

            results = results.slice(0, 10);

            json.success(results);
            json.end(res);
        });
    } else {
        json.end(res);
    }
});

/* Lancement du serveur */
app.listen(settings.port);
console.log('Server is started');

var dbCache = (function (db) {
    var obj = {};

    /* Données */
    var callbackCache = {}, dataCache = {}, indexCache = [];

    obj.action = function () {
        var i, callback
        for(i=0; i < indexCache.length; i++) {
            (function (collection) {
                db.collection(collection).find({}).toArray(function (err, docs) {
                    /* Enregistrement */
                    dataCache[collection] = docs;
                    /* Appels les callbacks caches */
                    if(callbackCache[collection] != undefined) {
                        while((callback = callbackCache[collection].pop(), callback)) {
                            callback(docs);
                        }
                        delete callbackCache[collection];
                    }
                });
            })(indexCache[i]);
        }
    };

    obj.on = function (collection, callback) {
        if(dataCache[collection] != undefined) {
            if(callback) { callback(dataCache[collection]); }
        } else {
            if(callbackCache[collection] == undefined) {
                callbackCache[collection] = []; }
            callbackCache[collection].push(callback);
        }
    };

    obj.add = function (collection) {
        indexCache.push(collection);
    };

    return obj;
});

module.exports = dbCache;

var dbMap = function (docs, mapFct) {
    var i, dataMap = [];

    /* Emission */
    var emit = function (index, values) { dataMap.push([index, values]); }

    /* Mapping */
    for(i=0; i < docs.length; i++) {
        docs[i].emit = emit;
        docs[i].mapFct = mapFct;
        docs[i].mapFct();
    }

    return dataMap;
};

module.exports = dbMap;