RTC8a1 (part 1)

Spec/RealtimeClient.swift

@@ -408,6 +408,62 @@ class RealtimeClient: QuickSpec {
                     }
                 }
 
+                // RTC8a1 - part 1
+                it("when the authentication token change is successful, then the client should receive a new CONNECTED ProtocolMessage") {
+                    let options = AblyTests.commonAppSetup()
+                    options.autoConnect = false
+                    let testToken = getTestToken()
+                    options.token = testToken
+                    let client = ARTRealtime(options: options)
+                    defer { client.dispose(); client.close() }
+                    client.setTransportClass(TestProxyTransport.self)
+
+                    waitUntil(timeout: testTimeout) { done in
+                        client.connection.once(.Connected) { stateChange in
+                            expect(stateChange?.reason).to(beNil())
+                            done()
+                        }
+                        client.connect()
+                    }
+
+                    waitUntil(timeout: testTimeout) { done in
+                        let partialDone = AblyTests.splitDone(2, done: done)
+
+                        client.connection.once(.Connected) { stateChange in
+                            guard let stateChange = stateChange else {
+                                fail("ConnectionStateChange is nil"); partialDone(); return
+                            }
+                            expect(stateChange.previous).to(equal(ARTRealtimeConnectionState.Connected))
+                            expect(stateChange.reason).toNot(beNil())
+
+                            guard let transport = client.transport as? TestProxyTransport else {
+                                fail("TestProxyTransport is not set"); partialDone(); return
+                            }
+                            let connectedMessages = transport.protocolMessagesReceived.filter{ $0.action == .Connected }
+                            expect(connectedMessages).to(haveCount(2))
+
+                            guard let connectedAfterAuth = connectedMessages.last, connectionDetailsAfterAuth = connectedAfterAuth.connectionDetails else {
+                                fail("Missing CONNECTED protocol message after AUTH protocol message"); partialDone(); return
+                            }
+
+                            expect(client.auth.clientId).to(equal(connectionDetailsAfterAuth.clientId))
+                            expect(client.connection.key).to(equal(connectionDetailsAfterAuth.connectionKey))
+                            partialDone()
+                        }
+
+                        client.auth.authorize(nil, options: nil) { tokenDetails, error in
+                            expect(error).to(beNil())
+                            guard let tokenDetails = tokenDetails else {
+                                fail("TokenDetails is nil"); partialDone(); return
+                            }
+                            expect(tokenDetails.token).toNot(equal(testToken))
+                            partialDone()
+                        }
+                    }
+
+                    expect(client.auth.tokenDetails?.token).toNot(equal(testToken))
+                }
+
             }
 
             it("should never register any connection listeners for internal use with the public EventEmitter") {