server/mongodb_rest.js
function(entity, msg) {
            if (!msg._id) {
                msg._id = new ObjectID();
            }
            var collection = new mongodb.Collection(this.db, "__msg__" + entity);
            if (msg.method === 'delete' && (msg.id === 'all' || msg.id === 'clean')) {
                collection.remove(function () {
                    if (msg.id === 'all') {
                        collection.insert(msg, { safe: false } );
                    }
                });
            } else {
                collection.insert(msg, { safe: false } );
            }
        }
function(entity, msg) {
            if (!msg._id) {
                msg._id = new ObjectID();
            }
            var collection = new mongodb.Collection(this.db, "__msg__" + entity);
            if (msg.method === 'delete' && (msg.id === 'all' || msg.id === 'clean')) {
                collection.remove(function () {
                    if (msg.id === 'all') {
                        collection.insert(msg, { safe: false } );
                    }
                });
            } else {
                collection.insert(msg, { safe: false } );
            }
        }
function ( entity , msg ) { if ( ! msg . _id ) { msg . _id = new ObjectID ( ) ; } var collection = new mongodb . Collection ( this . db , "__msg__" + entity ) ; if ( msg . method === 'delete' && ( msg . id === 'all' || msg . id === 'clean' ) ) { collection . remove ( function ( ) { if ( msg . id === 'all' ) { collection . insert ( msg , { safe : false } ) ; } } ) ; } else { collection . insert ( msg , { safe : false } ) ; } }
save a new change message
save a new change message