Contents

var events = require('events'),
    querystring = require('querystring'),
    Args = require('vargs').Constructor,
    follow = require('follow'),
    cradle = require('../../cradle'),
    Database = require('./index').Database;

Database.prototype.changes = function (options, callback) {
    if (typeof(options) === 'function') { 
        callback = options;
        options = {}; 
    }
    
    options = options || {};
    
    if (callback) {
        return this.query({
            method: 'GET', 
            path: '_changes',
            query: options
        }, callback);
    }

    var response = new events.EventEmitter(),
        responded = false,
        auth = '',
        feed;

    if (!options.db) {
        if (this.connection.auth && this.connection.auth.username
            && this.connection.auth.password) {
            auth = this.connection.auth.username + ':' + this.connection.auth.password + '@';            
        }
        
        options.db = 'http://' + auth + this.connection.host + ':' + this.connection.port + '/' + this.name;
    }
        
    feed = new follow.Feed(options);
    feed.on('change', function () {
        //
        // Remark: Support the legacy `data` events. 
        //
        if (!responded) {
            responded = true;
            feed.emit('response', response);
        }
        
        response.emit.apply(response, ['data'].concat(Array.prototype.slice.call(arguments)));
    });
    
    if (options.follow !== false) {
      feed.follow();
    }
    
    return feed;
};

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
vulcan-0.8.2	server/node_modules/cradle/lib/cradle/database/changes.js
vulcan-0.8.1	server/node_modules/cradle/lib/cradle/database/changes.js
vulcan-0.8.0	server/node_modules/cradle/lib/cradle/database/changes.js
vulcan-0.7.2	server/node_modules/cradle/lib/cradle/database/changes.js
vulcan-0.7.1	server/node_modules/cradle/lib/cradle/database/changes.js
vulcan-0.7.0	server/node_modules/cradle/lib/cradle/database/changes.js