v1.0.1

CHANGELOG.md

@@ -1,3 +1,9 @@
+## [1.0.1] - 2016-07-19
+
+### Bug Fixes
+
+- Fixed issue where deleted record was not getting removed
+
 ## [1.0.0] - 2016-07-10
 
 ### Features

dist/deepstream.js

@@ -4991,18 +4991,18 @@ EventHandler.prototype.subscribe = function( eventName, callback ) {
  */
 EventHandler.prototype.unsubscribe = function( eventName, callback ) {
 	this._emitter.off( eventName, callback );
-
+	
 	if( !this._emitter.hasListeners( eventName ) ) {
 		this._ackTimeoutRegistry.add( eventName, C.ACTIONS.UNSUBSCRIBE );
 		this._connection.sendMsg( C.TOPIC.EVENT, C.ACTIONS.UNSUBSCRIBE, [ eventName ] );
 	}
 };
 
 /**
- * Emits an event locally and sends a message to the server to
+ * Emits an event locally and sends a message to the server to 
  * broadcast the event to the other connected clients
  *
- * @param   {String} name
+ * @param   {String} name 
  * @param   {Mixed} data will be serialized and deserialized to its original type.
  *
  * @public
@@ -5080,7 +5080,7 @@ EventHandler.prototype._$handle = function( message ) {
 		this._ackTimeoutRegistry.clear( message );
 		return;
 	}
-
+	
 	if( message.action === C.ACTIONS.ERROR ) {
 		message.processedError = true;
 		this._client._$onError( C.TOPIC.EVENT, message.data[ 0 ], message.data[ 1 ] );
@@ -5148,7 +5148,7 @@ var Connection = function( client, url, options ) {
 
 /**
  * Returns the current connection state.
- * (One of constants.CONNECTION_STATE)
+ * (One of constants.CONNECTION_STATE) 
  *
  * @public
  * @returns {String} connectionState
@@ -5181,7 +5181,7 @@ Connection.prototype.authenticate = function( authParams, callback ) {
 		this._deliberateClose = false;
 		return;
 	}
-
+	
 	if( this._state === C.CONNECTION_STATE.AWAITING_AUTHENTICATION ) {
 		this._sendAuthParams();
 	}
@@ -5221,7 +5221,7 @@ Connection.prototype.send = function( message ) {
 		this._currentMessageResetTimeout = utils.nextTick( this._resetCurrentMessageCount.bind( this ) );
 	}
 
-	if( this._state === C.CONNECTION_STATE.OPEN &&
+	if( this._state === C.CONNECTION_STATE.OPEN && 
 		this._queuedMessages.length < this._options.maxMessagesPerPacket &&
 		this._currentPacketMessageCount < this._options.maxMessagesPerPacket ) {
 		this._sendQueuedMessages();
@@ -5341,7 +5341,7 @@ Connection.prototype._sendAuthParams = function() {
 
 /**
  * Will be invoked once the connection is established. The client
- * can't send messages yet, and needs to get a connection ACK or REDIRECT
+ * can't send messages yet, and needs to get a connection ACK or REDIRECT 
  * from the server before authenticating
  *
  * @private
@@ -5394,7 +5394,7 @@ Connection.prototype._onClose = function() {
 	}
 	else if( this._deliberateClose === true ) {
 		this._setState( C.CONNECTION_STATE.CLOSED );
-	}
+	}  
 	else {
 		if( this._originalUrl !== this._url ) {
 			this._url = this._originalUrl;
@@ -5442,7 +5442,7 @@ Connection.prototype._onMessage = function( message ) {
  * by the client until the authentication is successful.
  *
  * If a challenge is recieved, the user will send the url to the server
- * in response to get the appropriate redirect. If the URL is invalid the
+ * in response to get the appropriate redirect. If the URL is invalid the 
  * server will respond with a REJECTION resulting in the client connection
  * being permanently closed.
  *
@@ -5457,15 +5457,15 @@ Connection.prototype._onMessage = function( message ) {
 Connection.prototype._handleConnectionResponse = function( message ) {
 	var data;
 
-	if( message.action === C.ACTIONS.ACK ) {
+	if( message.action === C.ACTIONS.ACK ) {	
 		this._setState( C.CONNECTION_STATE.AWAITING_AUTHENTICATION );
 		if( this._authParams ) {
 			this._sendAuthParams();
 		}
-	}
+	} 
 	else if( message.action === C.ACTIONS.CHALLENGE ) {
 		this._setState( C.CONNECTION_STATE.CHALLENGING );
-		this._endpoint.send( messageBuilder.getMsg( C.TOPIC.CONNECTION, C.ACTIONS.CHALLENGE_RESPONSE, [ this._originalUrl ] ) );
+		this._endpoint.send( messageBuilder.getMsg( C.TOPIC.CONNECTION, C.ACTIONS.CHALLENGE_RESPONSE, [ this._originalUrl ] ) );		
 	}
 	else if( message.action === C.ACTIONS.REJECTION ) {
 		this._challengeDenied = true;
@@ -5493,21 +5493,21 @@ Connection.prototype._handleAuthResponse = function( message ) {
 	var data;
 
 	if( message.action === C.ACTIONS.ERROR ) {
-
+		
 		if( message.data[ 0 ] === C.EVENT.TOO_MANY_AUTH_ATTEMPTS ) {
 			this._deliberateClose = true;
 			this._tooManyAuthAttempts = true;
 		} else {
 			this._setState( C.CONNECTION_STATE.AWAITING_AUTHENTICATION );
 		}
-
+		
 		if( this._authCallback ) {
 			this._authCallback( false, this._getAuthData( message.data[ 1 ] ) );
 		}
-
+	
 	} else if( message.action === C.ACTIONS.ACK ) {
 		this._setState( C.CONNECTION_STATE.OPEN );
-
+		
 		if( this._authCallback ) {
 			this._authCallback( true, this._getAuthData( message.data[ 0 ] ) );
 		}
@@ -5534,7 +5534,7 @@ Connection.prototype._getAuthData = function( data ) {
 };
 
 /**
- * Updates the connection state and emits the
+ * Updates the connection state and emits the 
  * connectionStateChanged event on the client
  *
  * @private
@@ -5551,7 +5551,7 @@ Connection.prototype._setState = function( state ) {
  *
  * If the number of failed reconnection attempts exceeds
  * options.maxReconnectAttempts the connection is closed
- *
+ * 
  * @private
  * @returns {void}
  */
@@ -5564,7 +5564,7 @@ Connection.prototype._tryReconnect = function() {
 		this._setState( C.CONNECTION_STATE.RECONNECTING );
 		this._reconnectTimeout = setTimeout(
 			this._tryOpen.bind( this ),
-			this._options.reconnectIntervalIncrement * this._reconnectionAttempt
+			this._options.reconnectIntervalIncrement * this._reconnectionAttempt 
 		);
 		this._reconnectionAttempt++;
 	} else {
@@ -5575,7 +5575,7 @@ Connection.prototype._tryReconnect = function() {
 
 /**
  * Attempts to open a errourosly closed connection
- *
+ * 
  * @private
  * @returns {void}
  */
@@ -6533,7 +6533,7 @@ RecordHandler.prototype.getRecord = function( name, recordOptions ) {
 		this._records[ name ] = new Record( name, recordOptions || {}, this._connection, this._options, this._client );
 		this._records[ name ].on( 'error', this._onRecordError.bind( this, name ) );
 		this._records[ name ].on( 'destroyPending', this._onDestroyPending.bind( this, name ) );
-		this._records[ name ].on( 'deleted', this._removeRecord.bind( this, name ) );
+		this._records[ name ].on( 'delete', this._removeRecord.bind( this, name ) );
 		this._records[ name ].on( 'discard', this._removeRecord.bind( this, name ) );
 	}
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "deepstream.io-client-js",
-  "version": "1.0.0",
+  "version": "1.0.1",
   "description": "the javascript client for deepstream.io",
   "main": "src/client.js",
   "directories": {