Deletes current cv and requests new index when cv unknown

Author: beaucollins

src/simperium/channel.js

@@ -336,9 +336,7 @@ Channel.prototype.onAuth = function( data ) {
 				this.localQueue.start();
 				this.sendChangeVersionRequest( cv );
 			} else {
-				this.bucket.isIndexing = true;
-				this.bucket.emit( 'indexing' );
-				this.sendIndexRequest();
+				this.startIndexing();
 			}
 		};
 
@@ -348,6 +346,13 @@ Channel.prototype.onAuth = function( data ) {
 	}
 };
 
+Channel.prototype.startIndexing = function() {
+	this.localQueue.pause();
+	this.bucket.isIndexing = true;
+	this.bucket.emit( 'indexing' );
+	this.sendIndexRequest();
+}
+
 Channel.prototype.onConnect = function() {
 	var init = {
 		name: this.bucket.name,
@@ -410,9 +415,8 @@ Channel.prototype.onChanges = function( data ) {
 
 Channel.prototype.onChangeVersion = function( data ) {
 	if ( data === UNKNOWN_CV ) {
-		// TODO: delete current cv
-		// Start new index
-		throw new Error( 'not implemented' );
+		this.store.setChangeVersion( null )
+		.then( () => this.startIndexing() )
 	}
 }
 
@@ -494,6 +498,10 @@ LocalQueue.prototype.start = function() {
 	}
 }
 
+LocalQueue.prototype.pause = function() {
+	this.ready = false;
+}
+
 LocalQueue.prototype.acknowledge = function( change ) {
 	if ( this.sent[change.id] === change ) {
 		delete this.sent[change.id];

test/simperium/channel_test.js

@@ -385,6 +385,16 @@ describe( 'Channel', function() {
 		} );
 	} );
 
+	it( 'should request index when cv is unknown', done => {
+		channel.once( 'send', ( data ) => {
+			ok( !store.cv )
+			ok( bucket.isIndexing )
+			equal( data, 'i:1:::10' );
+			done()
+		} )
+		channel.handleMessage( 'cv:?' );
+	} )
+
 	// TODO: handle auth failures
 	// <=	 0:auth:expired
 	// =>	 0:i:1:::10
@@ -434,14 +444,6 @@ describe( 'Channel', function() {
 			} );
 		} );
 
-		it( 'should request index when cv is unknown', done => {
-			channel.once( 'send', ( data ) => {
-				equal( data, '' );
-				done()
-			} )
-			channel.handleMessage( 'cv:?' );
-		} )
-
 		it( 'should emit index and ready event when index complete', () => new Promise( resolve => {
 			var page = 'i:{"index":[{"id":"objectid","v":1,"d":{"title":"Hello World"}}],"current":"cv"}';
 			let indexed = false