Added function that checks if there's any changes in the channel's localQueue

Author: roundhill

src/simperium/channel.js

@@ -574,8 +574,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];

src/simperium/client.js

@@ -71,6 +71,10 @@ Client.prototype.bucket = function( name ) {
 
 	if ( this.open ) channel.onConnect();
 
+	bucket.hasLocalChanges = function() {
+		return channel.localQueue.hasChanges();
+	};
+
 	return bucket;
 };
 

test/simperium/channel_test.js

@@ -310,6 +310,29 @@ describe( 'Channel', function() {
 			} );
 		} );
 
+		it( 'should have local changes on send', function( done ) {
+			channel.once( 'send', function() {
+				assert.equal( channel.localQueue.hasChanges(), true );
+				done();
+			} );
+
+			store.put( '123', 3, {title: 'hello world'} ).then( function() {
+				bucket.update( '123', {title: 'goodbye world!!'} );
+			} );
+		} );
+
+		it( 'should have no local changes after ack', function( done ) {
+			channel.on( 'acknowledge', function() {
+				assert.equal( channel.localQueue.hasChanges(), false );
+				done();
+			} );
+
+			store.put( '123', 3, {title: 'hello world'} ).then( function() {
+				bucket.update( '123', {title: 'goodbye world!!'} );
+				done();
+			} );
+		} );
+
 		// 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 ) {