RTP10b

Spec/RealtimeClientPresence.swift

@@ -868,7 +868,7 @@ class RealtimeClientPresence: QuickSpec {
                     defer { client.close() }
                     let channel = client.channels.get("test")
 
-                    channel.attach()
+                                        channel.attach()
                     channel.detach()
 
                     waitUntil(timeout: testTimeout) { done in
@@ -927,6 +927,70 @@ class RealtimeClientPresence: QuickSpec {
                         }
                     }
                 }
+            }
+
+            // RTP10
+            context("leave") {
+
+                // RTP10b
+                it("optionally a callback can be provided that is called for success") {
+                    let options = AblyTests.commonAppSetup()
+                    options.clientId = "john"
+                    let client = ARTRealtime(options: options)
+                    defer { client.close() }
+                    let channel = client.channels.get("test")
+
+                    waitUntil(timeout: testTimeout) { done in
+                        channel.presence.enter("online") { error in
+                            expect(error).to(beNil())
+                            done()
+                        }
+                    }
+
+                    waitUntil(timeout: testTimeout) { done in
+                        channel.presence.leave("offline") { error in
+                            expect(error).to(beNil())
+                            done()
+                        }
+                    }
+                }
+
+                // RTP10b
+                it("optionally a callback can be provided that is called for failure") {
+                    let options = AblyTests.commonAppSetup()
+                    options.clientId = "john"
+                    let client = AblyTests.newRealtime(options)
+                    defer { client.close() }
+                    let channel = client.channels.get("test")
+
+                   waitUntil(timeout: testTimeout) { done in
+                       channel.presence.enter("online") { error in
+                           expect(error).to(beNil())
+                           done()
+                       }
+                   }
+
+                    waitUntil(timeout: testTimeout) { done in
+                        let sentError = ARTErrorInfo.createWithCode(0, message: "test error")
+                        let transport = client.transport as! TestProxyTransport
+                        transport.replaceAcksWithNacks(sentError) { doneReplacing in
+                            channel.presence.leave("offline") { error in
+                                expect(error).to(beIdenticalTo(sentError))
+                                doneReplacing()
+                                done()
+                            }
+                        }
+                    }
+                }
+
+                it("should raise an exception if client is not present") {
+                    let options = AblyTests.commonAppSetup()
+                    options.clientId = "john"
+                    let client = ARTRealtime(options: options)
+                    defer { client.close() }
+                    let channel = client.channels.get("test")
+                    expect(channel.presence.leave("offline")).to(raiseException())
+                }
 
             }
 

Spec/TestUtilities.swift

@@ -495,6 +495,7 @@ class TestProxyTransport: ARTWebSocketTransport {
 
     private(set) var rawDataSent = [NSData]()
     private(set) var rawDataReceived = [NSData]()
+    private var replacingAcksWithNacks: ARTErrorInfo?
 
     var beforeProcessingSentMessage: Optional<(ARTProtocolMessage)->()> = nil
     var beforeProcessingReceivedMessage: Optional<(ARTProtocolMessage)->()> = nil
@@ -522,6 +523,12 @@ class TestProxyTransport: ARTWebSocketTransport {
     }
 
     override func receive(msg: ARTProtocolMessage) {
+        if msg.action == .Ack {
+            if let error = replacingAcksWithNacks {
+                msg.action = .Nack
+                msg.error = error
+            }
+        }
         protocolMessagesReceived.append(msg)
         if actionsIgnored.contains(msg.action) {
             return
@@ -540,6 +547,10 @@ class TestProxyTransport: ARTWebSocketTransport {
         super.receiveWithData(data)
     }
 
+    func replaceAcksWithNacks(error: ARTErrorInfo, block: (() -> ()) -> ()) {
+        replacingAcksWithNacks = error
+        block({ self.replacingAcksWithNacks = nil })
+    }
 }
 
 
@@ -687,7 +698,6 @@ extension ARTWebSocketTransport {
         let webSocketDelegate = self as! WebSocketDelegate
         webSocketDelegate.webSocketError(error)
     }
-
 }