remove.js

/**
 * Created by wbison on 04-05-15.
 */
// remove docs that are expired
module.exports = function(config) {
    var purge   = require('./purge')(config);
    var map     = require('./map')(config);
    var nano    = require('nano')(config);
    var log     = require('./log')(config);

    return function(databaseName, cb) {

        var db = nano.use(databaseName);

        purge(db, done);

        function done(e, res) {
            // if err and it is view not found (404) the create view
            if (e && e.statusCode === 404) {
                // create view and rerun
                log(db, "Creating design document '" + "_design/" + config._design_doc._id + "'");
                config._design_doc.views._default = {
                    map: map.toString()
                };
                db.insert(config._design_doc, "_design/" + config._design_doc._id,
                    function(err) {
                        if (err) {
                            log(db, "Error: " + err.reason);
                            return cb(err);
                        }
                        purge(db, done);
                    });
                return;
            } else if(e) {
                // need to report err
                return cb(e);
            }
            cb(null, res);
        }

    }
}