Merge pull request #54 from Simperium/add/object-local-changes

Added bucket.hasLocalChanges method

Author: roundhill

package.json

@@ -1,6 +1,6 @@
 {
   "name": "simperium",
-  "version": "0.3.0",
+  "version": "0.3.1",
   "description": "A simperium client for node.js",
   "main": "./lib/simperium/index.js",
   "repository": {

src/simperium/bucket.js

@@ -31,6 +31,10 @@ Bucket.prototype.update = function( id, data, options, callback ) {
 	return this.store.update( id, data, this.isIndexing, callback );
 };
 
+Bucket.prototype.hasLocalChanges = function( callback ) {
+	callback( null, false );
+};
+
 Bucket.prototype.getVersion = function( id, callback ) {
 	callback( null, 0 );
 };

src/simperium/channel.js

@@ -293,6 +293,10 @@ export default function Channel( appid, access_token, bucket, store ) {
 		collectionRevisions( channel, id, callback );
 	};
 
+	bucket.hasLocalChanges = function( callback ) {
+		callback( null, channel.localQueue.hasChanges() );
+	};
+
 	bucket.getVersion = function( id, callback ) {
 		store.get( id ).then(
 			( ghost ) => {
@@ -574,8 +578,11 @@ LocalQueue.prototype.queue = function( change ) {
 	if ( !this.ready ) return;
 
 	this.processQueue( change.id );
-}
-;
+};
+
+LocalQueue.prototype.hasChanges = function() {
+	return Object.keys(this.queues).length > 0;
+};
 
 LocalQueue.prototype.dequeueChangesFor = function( id ) {
 	var changes = [], sent = this.sent[id], queue = this.queues[id];

test/simperium/channel_test.js

@@ -310,6 +310,19 @@ describe( 'Channel', function() {
 			} );
 		} );
 
+		it( 'should have local changes on send', function( done ) {
+			channel.once( 'send', function() {
+				bucket.hasLocalChanges( ( error, hasChanges ) => {
+					assert.equal( hasChanges, true );
+					done();
+				} );
+			} );
+
+			store.put( '123', 3, {title: 'hello world'} ).then( function() {
+				bucket.update( '123', {title: 'goodbye world!!'} );
+			} );
+		} );
+
 		// If receiving a remote change while there are unsent local modifications,
 		// local changes should be rebased onto the new ghost and re-sent
 		it( 'should resolve applying patch to modified object', function( done ) {