Comparing version 0.9.0-beta.5 to 0.9.0-beta.6
{ | ||
"name": "Ably", | ||
"version": "0.9.0-beta.5", | ||
"version": "0.9.0-beta.6", | ||
"homepage": "https://www.ably.io/", | ||
@@ -5,0 +5,0 @@ "authors": [ |
/** | ||
* @license Copyright 2017, Ably | ||
* | ||
* Ably JavaScript Library v0.9.0-beta.5 | ||
* Ably JavaScript Library v0.9.0-beta.6 | ||
* https://github.com/ably/ably-js | ||
@@ -6,0 +6,0 @@ * |
@@ -12,3 +12,3 @@ if(typeof window !== 'object') { | ||
createHmac: null, | ||
msgpack: Ably.msgpack, | ||
msgpack: msgpack, | ||
supportsBinary: !!window.TextDecoder, | ||
@@ -15,0 +15,0 @@ preferBinary: false, |
@@ -26,3 +26,3 @@ require('nativescript-websockets'); | ||
createHmac: null, | ||
msgpack: Ably.msgpack, | ||
msgpack: msgpack, | ||
supportsBinary: (typeof TextDecoder !== 'undefined') && TextDecoder, | ||
@@ -29,0 +29,0 @@ preferBinary: false, |
@@ -8,3 +8,3 @@ var Platform = { | ||
createHmac: null, | ||
msgpack: Ably.msgpack, | ||
msgpack: msgpack, | ||
supportsBinary: (typeof TextDecoder !== 'undefined') && TextDecoder, | ||
@@ -11,0 +11,0 @@ preferBinary: false, |
@@ -23,3 +23,3 @@ Defaults.protocolVersion = 1; | ||
Defaults.version = '0.9.0-beta.5'; | ||
Defaults.version = '0.9.0-beta.6'; | ||
Defaults.libstring = 'js-' + Defaults.version; | ||
@@ -26,0 +26,0 @@ Defaults.apiVersion = '0.9'; |
{ | ||
"name": "ably", | ||
"description": "Realtime client library for Ably.io, the realtime messaging service", | ||
"version": "0.9.0-beta.5", | ||
"version": "0.9.0-beta.6", | ||
"main": "./nodejs/index.js", | ||
@@ -6,0 +6,0 @@ "typings": "ably.ts.d", |
# [Ably](https://www.ably.io) | ||
## Version: 0.9.0-beta.5 | ||
## Version: 0.9.0-beta.6 | ||
@@ -5,0 +5,0 @@ This repo contains the Ably javascript client library, for the browser (including IE8+), Nodejs, React Native, and Cordova. |
@@ -168,30 +168,69 @@ "use strict"; | ||
exports.extras_field = function(test) { | ||
var realtime = helper.AblyRealtime(), | ||
event = 'event', | ||
extras = {push: [{title: 'testing'}]}; | ||
test.expect(3); | ||
testOnAllTransports(exports, 'auth_token_expires', function(realtimeOpts) { return function(test) { | ||
test.expect(4); | ||
var clientRealtime, | ||
rest = helper.AblyRest(); | ||
realtime.connection.once('connected', function() { | ||
var transport = realtime.connection.connectionManager.activeProtocol.transport, | ||
originalSend = transport.send; | ||
rest.auth.requestToken({ ttl: 5000 }, null, function(err, tokenDetails) { | ||
if(err) { | ||
test.ok(false, displayError(err)); | ||
test.done(); | ||
return; | ||
} | ||
clientRealtime = helper.AblyRealtime(mixin(realtimeOpts, { tokenDetails: tokenDetails, queryTime: true, log: {level: 4} })); | ||
transport.send = function(message) { | ||
if (message.action === 15) { | ||
test.equal(message.messages[0].name, event, 'Outgoing message interecepted'); | ||
test.deepEqual(message.messages[0].extras, extras, 'Check extras field is present'); | ||
clientRealtime.connection.on('failed', function(){ | ||
test.ok(false, 'Failed to connect before token expired'); | ||
closeAndFinish(test, clientRealtime); | ||
}); | ||
clientRealtime.connection.once('connected', function(){ | ||
clientRealtime.connection.off('failed'); | ||
test.ok(true, 'Verify connection connected'); | ||
clientRealtime.connection.once('disconnected', function(stateChange){ | ||
test.ok(true, 'Verify connection disconnected'); | ||
test.equal(stateChange.reason.statusCode, 401, 'Verify correct disconnect statusCode'); | ||
test.equal(stateChange.reason.code, 40142, 'Verify correct disconnect code'); | ||
closeAndFinish(test, clientRealtime); | ||
}); | ||
}); | ||
}); | ||
}}); | ||
testOnAllTransports(exports, 'auth_tokenDetails_expiry_with_authcallback', function(realtimeOpts) { return function(test) { | ||
test.expect(4); | ||
var realtime, rest = helper.AblyRest(); | ||
var clientId = "test clientid"; | ||
var authCallback = function(tokenParams, callback) { | ||
tokenParams.ttl = 5000; | ||
rest.auth.requestToken(tokenParams, null, function(err, tokenDetails) { | ||
if(err) { | ||
test.ok(false, displayError(err)); | ||
closeAndFinish(test, realtime); | ||
return; | ||
} | ||
originalSend.apply(transport, arguments); | ||
}; | ||
callback(null, tokenDetails); | ||
}); | ||
}; | ||
var channel = realtime.channels.get('extras_field'); | ||
channel.publish({name: event, extras: extras}, function(err) { | ||
test.ok(!err, err && helper.displayError(err)); | ||
closeAndFinish(test, realtime); | ||
realtime = helper.AblyRealtime(mixin(realtimeOpts, { authCallback: authCallback, clientId: clientId, log: {level: 4} })); | ||
monitorConnection(test, realtime); | ||
realtime.connection.once('connected', function(){ | ||
test.ok(true, 'Verify connection connected'); | ||
realtime.connection.once('disconnected', function(stateChange){ | ||
test.ok(true, 'Verify connection disconnected'); | ||
test.equal(stateChange.reason.code, 40142, 'Verify correct disconnect code'); | ||
realtime.connection.once('connected', function(){ | ||
test.ok(true, 'Verify connection reconnected'); | ||
realtime.close(); | ||
test.done(); | ||
}); | ||
}); | ||
}); | ||
}; | ||
monitorConnection(test, realtime); | ||
}}); | ||
return module.exports = helper.withTimeout(exports); | ||
}); |
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
3678613
80787