lib/submodules/ably-ruby/SPEC.md in ably-rest-1.2.4 vs lib/submodules/ably-ruby/SPEC.md in ably-rest-1.2.6

- old
+ new

@@ -1,6 +1,6 @@ -# Ably Realtime & REST Client Library 1.1.5 Specification +# Ably Realtime & REST Client Library 1.2.6 Specification ### Ably::Realtime::Auth _(see [spec/acceptance/realtime/auth_spec.rb](./spec/acceptance/realtime/auth_spec.rb))_ * using JSON protocol * with basic auth @@ -187,319 +187,377 @@ * [retrieves limited history backwards with pagination](./spec/acceptance/realtime/channel_history_spec.rb#L127) * and REST history * [return the same results with unique matching message IDs](./spec/acceptance/realtime/channel_history_spec.rb#L145) * with option until_attach: true * [retrieves all messages before channel was attached](./spec/acceptance/realtime/channel_history_spec.rb#L172) - * [fails the deferrable unless the state is attached](./spec/acceptance/realtime/channel_history_spec.rb#L221) + * [fails the deferrable unless the state is attached](./spec/acceptance/realtime/channel_history_spec.rb#L242) + * when channel receives update event after an attachment + * [updates attach_serial](./spec/acceptance/realtime/channel_history_spec.rb#L197) * and two pages of messages - * [retrieves two pages of messages before channel was attached](./spec/acceptance/realtime/channel_history_spec.rb#L187) + * [retrieves two pages of messages before channel was attached](./spec/acceptance/realtime/channel_history_spec.rb#L208) ### Ably::Realtime::Channel _(see [spec/acceptance/realtime/channel_spec.rb](./spec/acceptance/realtime/channel_spec.rb))_ * using JSON protocol * initialization * with :auto_connect option set to false on connection * [remains initialized when accessing a channel](./spec/acceptance/realtime/channel_spec.rb#L29) * [opens a connection implicitly on #attach](./spec/acceptance/realtime/channel_spec.rb#L37) * #attach - * [returns a SafeDeferrable that catches exceptions in callbacks and logs them](./spec/acceptance/realtime/channel_spec.rb#L152) - * [calls the SafeDeferrable callback on success (#RTL4d)](./spec/acceptance/realtime/channel_spec.rb#L157) + * [returns a SafeDeferrable that catches exceptions in callbacks and logs them](./spec/acceptance/realtime/channel_spec.rb#L240) + * [calls the SafeDeferrable callback on success (#RTL4d)](./spec/acceptance/realtime/channel_spec.rb#L245) * when initialized * [emits attaching then attached events](./spec/acceptance/realtime/channel_spec.rb#L48) * [ignores subsequent #attach calls but calls the success callback if provided](./spec/acceptance/realtime/channel_spec.rb#L58) * [attaches to a channel](./spec/acceptance/realtime/channel_spec.rb#L71) * [attaches to a channel and calls the provided block (#RTL4d)](./spec/acceptance/realtime/channel_spec.rb#L79) * [sets attach_serial property after the attachment (#RTL15a)](./spec/acceptance/realtime/channel_spec.rb#L86) * [sends an ATTACH and waits for an ATTACHED (#RTL4c)](./spec/acceptance/realtime/channel_spec.rb#L96) - * [implicitly attaches the channel (#RTL7c)](./spec/acceptance/realtime/channel_spec.rb#L120) + * [implicitly attaches the channel (#RTL7c)](./spec/acceptance/realtime/channel_spec.rb#L208) + * context when channel options contain modes + * [sends an ATTACH with options as flags (#RTL4l)](./spec/acceptance/realtime/channel_spec.rb#L125) + * when channel is reattaching + * [sends ATTACH_RESUME flag along with other modes (RTL4j)](./spec/acceptance/realtime/channel_spec.rb#L139) + * context when channel options contain params + * [sends an ATTACH with params (#RTL4k)](./spec/acceptance/realtime/channel_spec.rb#L167) + * when received attached + * [decodes flags and sets it as modes on channel options (#RTL4m)](./spec/acceptance/realtime/channel_spec.rb#L182) + * [set params as channel options params (#RTL4k1)](./spec/acceptance/realtime/channel_spec.rb#L193) * when the implicit channel attach fails - * [registers the listener anyway (#RTL7c)](./spec/acceptance/realtime/channel_spec.rb#L137) + * [registers the listener anyway (#RTL7c)](./spec/acceptance/realtime/channel_spec.rb#L225) * when an ATTACHED acknowledge is not received on the current connection - * [sends another ATTACH each time the connection becomes connected](./spec/acceptance/realtime/channel_spec.rb#L168) + * [sends another ATTACH each time the connection becomes connected](./spec/acceptance/realtime/channel_spec.rb#L256) * when state is :attached - * [does nothing (#RTL4a)](./spec/acceptance/realtime/channel_spec.rb#L206) + * [does nothing (#RTL4a)](./spec/acceptance/realtime/channel_spec.rb#L294) * when state is :failed - * [reattaches and sets the errorReason to nil (#RTL4g)](./spec/acceptance/realtime/channel_spec.rb#L226) + * [reattaches and sets the errorReason to nil (#RTL4g)](./spec/acceptance/realtime/channel_spec.rb#L314) * when state is :detaching - * [does the attach operation after the completion of the pending request (#RTL4h)](./spec/acceptance/realtime/channel_spec.rb#L241) + * [does the attach operation after the completion of the pending request (#RTL4h)](./spec/acceptance/realtime/channel_spec.rb#L329) * with many connections and many channels on each simultaneously - * [attaches all channels](./spec/acceptance/realtime/channel_spec.rb#L269) + * [attaches all channels](./spec/acceptance/realtime/channel_spec.rb#L359) * failure as a result of insufficient key permissions - * [emits failed event (#RTL4e)](./spec/acceptance/realtime/channel_spec.rb#L300) - * [calls the errback of the returned Deferrable (#RTL4d)](./spec/acceptance/realtime/channel_spec.rb#L309) - * [updates the error_reason](./spec/acceptance/realtime/channel_spec.rb#L317) + * [emits failed event (#RTL4e)](./spec/acceptance/realtime/channel_spec.rb#L390) + * [calls the errback of the returned Deferrable (#RTL4d)](./spec/acceptance/realtime/channel_spec.rb#L399) + * [updates the error_reason](./spec/acceptance/realtime/channel_spec.rb#L407) * and subsequent authorisation with suitable permissions - * [attaches to the channel successfully and resets the channel error_reason](./spec/acceptance/realtime/channel_spec.rb#L326) + * [attaches to the channel successfully and resets the channel error_reason](./spec/acceptance/realtime/channel_spec.rb#L416) * with connection state - * [is initialized (#RTL4i)](./spec/acceptance/realtime/channel_spec.rb#L345) - * [is connecting (#RTL4i)](./spec/acceptance/realtime/channel_spec.rb#L352) - * [is disconnected (#RTL4i)](./spec/acceptance/realtime/channel_spec.rb#L360) + * [is initialized (#RTL4i)](./spec/acceptance/realtime/channel_spec.rb#L460) + * [is connecting (#RTL4i)](./spec/acceptance/realtime/channel_spec.rb#L468) + * [is disconnected (#RTL4i)](./spec/acceptance/realtime/channel_spec.rb#L477) + * clean attach (RTL4j) + * when channel wasn't previously attached + * [doesn't send ATTACH_RESUME](./spec/acceptance/realtime/channel_spec.rb#L492) + * when channel was explicitly detached + * [doesn't send ATTACH_RESUME](./spec/acceptance/realtime/channel_spec.rb#L507) * #detach * when state is :attached - * [it detaches from a channel (#RTL5d)](./spec/acceptance/realtime/channel_spec.rb#L375) - * [detaches from a channel and calls the provided block (#RTL5d, #RTL5e)](./spec/acceptance/realtime/channel_spec.rb#L385) - * [emits :detaching then :detached events](./spec/acceptance/realtime/channel_spec.rb#L395) - * [returns a SafeDeferrable that catches exceptions in callbacks and logs them](./spec/acceptance/realtime/channel_spec.rb#L407) - * [calls the Deferrable callback on success](./spec/acceptance/realtime/channel_spec.rb#L414) + * [it detaches from a channel (#RTL5d)](./spec/acceptance/realtime/channel_spec.rb#L533) + * [detaches from a channel and calls the provided block (#RTL5d, #RTL5e)](./spec/acceptance/realtime/channel_spec.rb#L546) + * [emits :detaching then :detached events](./spec/acceptance/realtime/channel_spec.rb#L559) + * [returns a SafeDeferrable that catches exceptions in callbacks and logs them](./spec/acceptance/realtime/channel_spec.rb#L573) + * [calls the Deferrable callback on success](./spec/acceptance/realtime/channel_spec.rb#L583) * and DETACHED message is not received within realtime request timeout - * [fails the deferrable and returns to the previous state (#RTL5f, #RTL5e)](./spec/acceptance/realtime/channel_spec.rb#L428) + * [fails the deferrable and returns to the previous state (#RTL5f, #RTL5e)](./spec/acceptance/realtime/channel_spec.rb#L600) * when state is :failed - * [fails the deferrable (#RTL5b)](./spec/acceptance/realtime/channel_spec.rb#L448) + * [fails the deferrable (#RTL5b)](./spec/acceptance/realtime/channel_spec.rb#L620) * when state is :attaching - * [waits for the attach to complete and then moves to detached](./spec/acceptance/realtime/channel_spec.rb#L461) + * [waits for the attach to complete and then moves to detached](./spec/acceptance/realtime/channel_spec.rb#L633) * when state is :detaching - * [ignores subsequent #detach calls but calls the callback if provided (#RTL5i)](./spec/acceptance/realtime/channel_spec.rb#L478) + * [ignores subsequent #detach calls but calls the callback if provided (#RTL5i)](./spec/acceptance/realtime/channel_spec.rb#L650) * when state is :suspended - * [moves the channel state immediately to DETACHED state (#RTL5j)](./spec/acceptance/realtime/channel_spec.rb#L495) + * [moves the channel state immediately to DETACHED state (#RTL5j)](./spec/acceptance/realtime/channel_spec.rb#L669) * when state is :initialized - * [does nothing as there is no channel to detach (#RTL5a)](./spec/acceptance/realtime/channel_spec.rb#L515) - * [returns a valid deferrable](./spec/acceptance/realtime/channel_spec.rb#L523) + * [does nothing as there is no channel to detach (#RTL5a)](./spec/acceptance/realtime/channel_spec.rb#L692) + * [returns a valid deferrable](./spec/acceptance/realtime/channel_spec.rb#L700) * when state is :detached - * [does nothing as the channel is detached (#RTL5a)](./spec/acceptance/realtime/channel_spec.rb#L533) + * [does nothing as the channel is detached (#RTL5a)](./spec/acceptance/realtime/channel_spec.rb#L710) * when connection state is * closing - * [fails the deferrable (#RTL5b)](./spec/acceptance/realtime/channel_spec.rb#L550) + * [fails the deferrable (#RTL5b)](./spec/acceptance/realtime/channel_spec.rb#L730) * failed and channel is failed - * [fails the deferrable (#RTL5b)](./spec/acceptance/realtime/channel_spec.rb#L570) + * [fails the deferrable (#RTL5b)](./spec/acceptance/realtime/channel_spec.rb#L750) * failed and channel is detached - * [fails the deferrable (#RTL5b)](./spec/acceptance/realtime/channel_spec.rb#L592) + * [fails the deferrable (#RTL5b)](./spec/acceptance/realtime/channel_spec.rb#L772) * initialized - * [does the detach operation once the connection state is connected (#RTL5h)](./spec/acceptance/realtime/channel_spec.rb#L612) + * [does the detach operation once the connection state is connected (#RTL5h)](./spec/acceptance/realtime/channel_spec.rb#L792) * connecting - * [does the detach operation once the connection state is connected (#RTL5h)](./spec/acceptance/realtime/channel_spec.rb#L627) + * [does the detach operation once the connection state is connected (#RTL5h)](./spec/acceptance/realtime/channel_spec.rb#L809) * disconnected - * [does the detach operation once the connection state is connected (#RTL5h)](./spec/acceptance/realtime/channel_spec.rb#L646) + * [does the detach operation once the connection state is connected (#RTL5h)](./spec/acceptance/realtime/channel_spec.rb#L830) * automatic channel recovery * when an ATTACH request times out - * [moves to the SUSPENDED state (#RTL4f)](./spec/acceptance/realtime/channel_spec.rb#L673) + * [moves to the SUSPENDED state (#RTL4f)](./spec/acceptance/realtime/channel_spec.rb#L859) * if a subsequent ATTACHED is received on an ATTACHED channel - * [ignores the additional ATTACHED if resumed is true (#RTL12)](./spec/acceptance/realtime/channel_spec.rb#L687) - * [emits an UPDATE only when resumed is true (#RTL12)](./spec/acceptance/realtime/channel_spec.rb#L701) - * [emits an UPDATE when resumed is true and includes the reason error from the ProtocolMessage (#RTL12)](./spec/acceptance/realtime/channel_spec.rb#L717) + * [ignores the additional ATTACHED if resumed is true (#RTL12)](./spec/acceptance/realtime/channel_spec.rb#L873) + * [emits an UPDATE only when resumed is true (#RTL12)](./spec/acceptance/realtime/channel_spec.rb#L887) + * [emits an UPDATE when resumed is true and includes the reason error from the ProtocolMessage (#RTL12)](./spec/acceptance/realtime/channel_spec.rb#L903) * #publish * when channel is attached (#RTL6c1) - * [publishes messages](./spec/acceptance/realtime/channel_spec.rb#L742) + * [publishes messages](./spec/acceptance/realtime/channel_spec.rb#L928) + * #(RTL17) + * when channel is initialized + * [sends messages only on attach](./spec/acceptance/realtime/channel_spec.rb#L941) + * when channel is attaching + * [sends messages only on attach](./spec/acceptance/realtime/channel_spec.rb#L956) + * when channel is detaching + * [stops sending message](./spec/acceptance/realtime/channel_spec.rb#L979) + * when channel is detached + * [stops sending message](./spec/acceptance/realtime/channel_spec.rb#L1007) + * when channel is failed + * [errors when trying to send a message](./spec/acceptance/realtime/channel_spec.rb#L1033) * when channel is not attached in state Initializing (#RTL6c1) - * [publishes messages immediately and does not implicitly attach (#RTL6c1)](./spec/acceptance/realtime/channel_spec.rb#L754) + * [publishes messages immediately and does not implicitly attach (#RTL6c1)](./spec/acceptance/realtime/channel_spec.rb#L1051) * when channel is Attaching (#RTL6c1) - * [publishes messages immediately (#RTL6c1)](./spec/acceptance/realtime/channel_spec.rb#L771) + * [publishes messages immediately (#RTL6c1)](./spec/acceptance/realtime/channel_spec.rb#L1068) * when channel is Detaching (#RTL6c1) - * [publishes messages immediately (#RTL6c1)](./spec/acceptance/realtime/channel_spec.rb#L796) + * [publishes messages immediately (#RTL6c1)](./spec/acceptance/realtime/channel_spec.rb#L1093) * when channel is Detached (#RTL6c1) - * [publishes messages immediately (#RTL6c1)](./spec/acceptance/realtime/channel_spec.rb#L823) + * [publishes messages immediately (#RTL6c1)](./spec/acceptance/realtime/channel_spec.rb#L1123) * with :queue_messages client option set to false (#RTL6c4) * and connection state connected (#RTL6c4) - * [publishes the message](./spec/acceptance/realtime/channel_spec.rb#L854) + * [publishes the message](./spec/acceptance/realtime/channel_spec.rb#L1156) * and connection state initialized (#RTL6c4) - * [fails the deferrable](./spec/acceptance/realtime/channel_spec.rb#L863) + * [fails the deferrable](./spec/acceptance/realtime/channel_spec.rb#L1165) * and connection state connecting (#RTL6c4) - * [fails the deferrable](./spec/acceptance/realtime/channel_spec.rb#L873) + * [fails the deferrable](./spec/acceptance/realtime/channel_spec.rb#L1175) * and connection state disconnected (#RTL6c4) - * [fails the deferrable](./spec/acceptance/realtime/channel_spec.rb#L888) + * [fails the deferrable](./spec/acceptance/realtime/channel_spec.rb#L1190) * and connection state suspended (#RTL6c4) - * [fails the deferrable](./spec/acceptance/realtime/channel_spec.rb#L888) + * [fails the deferrable](./spec/acceptance/realtime/channel_spec.rb#L1190) * and connection state closing (#RTL6c4) - * [fails the deferrable](./spec/acceptance/realtime/channel_spec.rb#L888) + * [fails the deferrable](./spec/acceptance/realtime/channel_spec.rb#L1190) * and connection state closed (#RTL6c4) - * [fails the deferrable](./spec/acceptance/realtime/channel_spec.rb#L888) + * [fails the deferrable](./spec/acceptance/realtime/channel_spec.rb#L1190) * and the channel state is failed (#RTL6c4) - * [fails the deferrable](./spec/acceptance/realtime/channel_spec.rb#L909) + * [fails the deferrable](./spec/acceptance/realtime/channel_spec.rb#L1211) * with name and data arguments - * [publishes the message and return true indicating success](./spec/acceptance/realtime/channel_spec.rb#L927) + * [publishes the message and return true indicating success](./spec/acceptance/realtime/channel_spec.rb#L1229) * and additional attributes - * [publishes the message with the attributes and return true indicating success](./spec/acceptance/realtime/channel_spec.rb#L940) + * [publishes the message with the attributes and return true indicating success](./spec/acceptance/realtime/channel_spec.rb#L1242) * and additional invalid attributes - * [throws an exception](./spec/acceptance/realtime/channel_spec.rb#L953) + * [throws an exception](./spec/acceptance/realtime/channel_spec.rb#L1255) * with an array of Hash objects with :name and :data attributes - * [publishes an array of messages in one ProtocolMessage](./spec/acceptance/realtime/channel_spec.rb#L967) + * [publishes an array of messages in one ProtocolMessage](./spec/acceptance/realtime/channel_spec.rb#L1269) * with an array of Message objects - * [publishes an array of messages in one ProtocolMessage](./spec/acceptance/realtime/channel_spec.rb#L995) + * [publishes an array of messages in one ProtocolMessage](./spec/acceptance/realtime/channel_spec.rb#L1297) * nil attributes * when name is nil - * [publishes the message without a name attribute in the payload](./spec/acceptance/realtime/channel_spec.rb#L1019) + * [publishes the message without a name attribute in the payload](./spec/acceptance/realtime/channel_spec.rb#L1321) * when data is nil - * [publishes the message without a data attribute in the payload](./spec/acceptance/realtime/channel_spec.rb#L1043) + * [publishes the message without a data attribute in the payload](./spec/acceptance/realtime/channel_spec.rb#L1345) * with neither name or data attributes - * [publishes the message without any attributes in the payload](./spec/acceptance/realtime/channel_spec.rb#L1067) + * [publishes the message without any attributes in the payload](./spec/acceptance/realtime/channel_spec.rb#L1369) * with two invalid message out of 12 * before client_id is known (validated) - * [calls the errback once](./spec/acceptance/realtime/channel_spec.rb#L1091) + * [calls the errback once](./spec/acceptance/realtime/channel_spec.rb#L1393) * when client_id is known (validated) - * [raises an exception](./spec/acceptance/realtime/channel_spec.rb#L1111) + * [raises an exception](./spec/acceptance/realtime/channel_spec.rb#L1413) * only invalid messages * before client_id is known (validated) - * [calls the errback once](./spec/acceptance/realtime/channel_spec.rb#L1130) + * [calls the errback once](./spec/acceptance/realtime/channel_spec.rb#L1432) * when client_id is known (validated) - * [raises an exception](./spec/acceptance/realtime/channel_spec.rb#L1149) + * [raises an exception](./spec/acceptance/realtime/channel_spec.rb#L1451) * with many many messages and many connections simultaneously - * [publishes all messages, all success callbacks are called, and a history request confirms all messages were published](./spec/acceptance/realtime/channel_spec.rb#L1163) + * [publishes all messages, all success callbacks are called, and a history request confirms all messages were published](./spec/acceptance/realtime/channel_spec.rb#L1465) * with more than allowed messages in a single publish - * [rejects the publish](./spec/acceptance/realtime/channel_spec.rb#L1186) + * [rejects the publish](./spec/acceptance/realtime/channel_spec.rb#L1488) * identified clients * when authenticated with a wildcard client_id * with a valid client_id in the message - * [succeeds](./spec/acceptance/realtime/channel_spec.rb#L1206) + * [succeeds](./spec/acceptance/realtime/channel_spec.rb#L1508) * with a wildcard client_id in the message - * [throws an exception](./spec/acceptance/realtime/channel_spec.rb#L1218) + * [throws an exception](./spec/acceptance/realtime/channel_spec.rb#L1522) * with a non-String client_id in the message - * [throws an exception](./spec/acceptance/realtime/channel_spec.rb#L1225) + * [throws an exception](./spec/acceptance/realtime/channel_spec.rb#L1529) * with an empty client_id in the message - * [succeeds and publishes without a client_id](./spec/acceptance/realtime/channel_spec.rb#L1232) + * [succeeds and publishes without a client_id](./spec/acceptance/realtime/channel_spec.rb#L1536) * when authenticated with a Token string with an implicit client_id * before the client is CONNECTED and the client's identity has been obtained * with a valid client_id in the message - * [succeeds](./spec/acceptance/realtime/channel_spec.rb#L1252) + * [succeeds](./spec/acceptance/realtime/channel_spec.rb#L1558) * with an invalid client_id in the message - * [succeeds in the client library but then fails when delivered to Ably](./spec/acceptance/realtime/channel_spec.rb#L1265) + * [succeeds in the client library ( while connecting ) but then fails when delivered to Ably](./spec/acceptance/realtime/channel_spec.rb#L1573) * with an empty client_id in the message - * [succeeds and publishes with an implicit client_id](./spec/acceptance/realtime/channel_spec.rb#L1276) + * [succeeds and publishes with an implicit client_id](./spec/acceptance/realtime/channel_spec.rb#L1587) * after the client is CONNECTED and the client's identity is known * with a valid client_id in the message - * [succeeds](./spec/acceptance/realtime/channel_spec.rb#L1290) + * [succeeds](./spec/acceptance/realtime/channel_spec.rb#L1603) * with an invalid client_id in the message - * [throws an exception](./spec/acceptance/realtime/channel_spec.rb#L1304) + * [throws an exception](./spec/acceptance/realtime/channel_spec.rb#L1617) * with an empty client_id in the message - * [succeeds and publishes with an implicit client_id](./spec/acceptance/realtime/channel_spec.rb#L1313) + * [succeeds and publishes with an implicit client_id](./spec/acceptance/realtime/channel_spec.rb#L1626) * when authenticated with a valid client_id * with a valid client_id - * [succeeds](./spec/acceptance/realtime/channel_spec.rb#L1335) + * [succeeds](./spec/acceptance/realtime/channel_spec.rb#L1648) * with a wildcard client_id in the message - * [throws an exception](./spec/acceptance/realtime/channel_spec.rb#L1347) + * [throws an exception](./spec/acceptance/realtime/channel_spec.rb#L1662) * with an invalid client_id in the message - * [throws an exception](./spec/acceptance/realtime/channel_spec.rb#L1354) + * [throws an exception](./spec/acceptance/realtime/channel_spec.rb#L1669) * with an empty client_id in the message - * [succeeds and publishes with an implicit client_id](./spec/acceptance/realtime/channel_spec.rb#L1361) + * [succeeds and publishes with an implicit client_id](./spec/acceptance/realtime/channel_spec.rb#L1676) * when anonymous and no client_id * with a client_id in the message - * [throws an exception](./spec/acceptance/realtime/channel_spec.rb#L1380) + * [throws an exception](./spec/acceptance/realtime/channel_spec.rb#L1697) * with a wildcard client_id in the message - * [throws an exception](./spec/acceptance/realtime/channel_spec.rb#L1387) + * [throws an exception](./spec/acceptance/realtime/channel_spec.rb#L1704) * with an empty client_id in the message - * [succeeds and publishes with an implicit client_id](./spec/acceptance/realtime/channel_spec.rb#L1394) + * [succeeds and publishes with an implicit client_id](./spec/acceptance/realtime/channel_spec.rb#L1711) + * message size exceeded (#TO3l8) + * and max_message_size is default (65536 bytes) + * [should allow to send a message (32 bytes)](./spec/acceptance/realtime/channel_spec.rb#L1734) + * [should not allow to send a message (700000 bytes)](./spec/acceptance/realtime/channel_spec.rb#L1744) + * and max_message_size is customized (11 bytes) + * and the message size is 30 bytes + * [should not allow to send a message](./spec/acceptance/realtime/channel_spec.rb#L1765) + * and max_message_size is nil + * and the message size is 30 bytes + * [should allow to send a message](./spec/acceptance/realtime/channel_spec.rb#L1787) + * and the message size is 65537 bytes + * [should not allow to send a message](./spec/acceptance/realtime/channel_spec.rb#L1806) * #subscribe * with an event argument - * [subscribes for a single event](./spec/acceptance/realtime/channel_spec.rb#L1410) + * [subscribes for a single event](./spec/acceptance/realtime/channel_spec.rb#L1826) * before attach - * [receives messages as soon as attached](./spec/acceptance/realtime/channel_spec.rb#L1420) + * [receives messages as soon as attached](./spec/acceptance/realtime/channel_spec.rb#L1836) * with no event argument - * [subscribes for all events](./spec/acceptance/realtime/channel_spec.rb#L1434) + * [subscribes for all events](./spec/acceptance/realtime/channel_spec.rb#L1850) * with a callback that raises an exception - * [logs the error and continues](./spec/acceptance/realtime/channel_spec.rb#L1446) + * [logs the error and continues](./spec/acceptance/realtime/channel_spec.rb#L1862) * many times with different event names - * [filters events accordingly to each callback](./spec/acceptance/realtime/channel_spec.rb#L1465) + * [filters events accordingly to each callback](./spec/acceptance/realtime/channel_spec.rb#L1883) * #unsubscribe * with an event argument - * [unsubscribes for a single event](./spec/acceptance/realtime/channel_spec.rb#L1488) + * [unsubscribes for a single event](./spec/acceptance/realtime/channel_spec.rb#L1908) * with no event argument - * [unsubscribes for a single event](./spec/acceptance/realtime/channel_spec.rb#L1501) + * [unsubscribes for a single event](./spec/acceptance/realtime/channel_spec.rb#L1923) * when connection state changes to * :failed * an :attaching channel - * [transitions state to :failed (#RTL3a)](./spec/acceptance/realtime/channel_spec.rb#L1524) + * [transitions state to :failed (#RTL3a)](./spec/acceptance/realtime/channel_spec.rb#L1948) * an :attached channel - * [transitions state to :failed (#RTL3a)](./spec/acceptance/realtime/channel_spec.rb#L1541) - * [updates the channel error_reason (#RTL3a)](./spec/acceptance/realtime/channel_spec.rb#L1553) + * [transitions state to :failed (#RTL3a)](./spec/acceptance/realtime/channel_spec.rb#L1965) + * [updates the channel error_reason (#RTL3a)](./spec/acceptance/realtime/channel_spec.rb#L1979) * a :detached channel - * [remains in the :detached state (#RTL3a)](./spec/acceptance/realtime/channel_spec.rb#L1567) + * [remains in the :detached state (#RTL3a)](./spec/acceptance/realtime/channel_spec.rb#L1995) * a :failed channel - * [remains in the :failed state and ignores the failure error (#RTL3a)](./spec/acceptance/realtime/channel_spec.rb#L1586) + * [remains in the :failed state and ignores the failure error (#RTL3a)](./spec/acceptance/realtime/channel_spec.rb#L2018) * a channel ATTACH request - * [fails the deferrable (#RTL4b)](./spec/acceptance/realtime/channel_spec.rb#L1606) + * [fails the deferrable (#RTL4b)](./spec/acceptance/realtime/channel_spec.rb#L2040) * :closed * an :attached channel - * [transitions state to :detached (#RTL3b)](./spec/acceptance/realtime/channel_spec.rb#L1622) + * [transitions state to :detached (#RTL3b)](./spec/acceptance/realtime/channel_spec.rb#L2056) * an :attaching channel (#RTL3b) - * [transitions state to :detached](./spec/acceptance/realtime/channel_spec.rb#L1633) + * [transitions state to :detached](./spec/acceptance/realtime/channel_spec.rb#L2069) * a :detached channel - * [remains in the :detached state (#RTL3b)](./spec/acceptance/realtime/channel_spec.rb#L1648) + * [remains in the :detached state (#RTL3b)](./spec/acceptance/realtime/channel_spec.rb#L2086) * a :failed channel - * [remains in the :failed state and retains the error_reason (#RTL3b)](./spec/acceptance/realtime/channel_spec.rb#L1668) + * [remains in the :failed state and retains the error_reason (#RTL3b)](./spec/acceptance/realtime/channel_spec.rb#L2109) * a channel ATTACH request when connection CLOSED - * [fails the deferrable (#RTL4b)](./spec/acceptance/realtime/channel_spec.rb#L1688) + * [fails the deferrable (#RTL4b)](./spec/acceptance/realtime/channel_spec.rb#L2131) * a channel ATTACH request when connection CLOSING - * [fails the deferrable (#RTL4b)](./spec/acceptance/realtime/channel_spec.rb#L1702) + * [fails the deferrable (#RTL4b)](./spec/acceptance/realtime/channel_spec.rb#L2145) * :suspended * an :attaching channel - * [transitions state to :suspended (#RTL3c)](./spec/acceptance/realtime/channel_spec.rb#L1718) + * [transitions state to :suspended (#RTL3c)](./spec/acceptance/realtime/channel_spec.rb#L2161) * an :attached channel - * [transitions state to :suspended (#RTL3c)](./spec/acceptance/realtime/channel_spec.rb#L1732) - * [transitions state automatically to :attaching once the connection is re-established (#RTN15c3)](./spec/acceptance/realtime/channel_spec.rb#L1741) + * [transitions state to :suspended (#RTL3c)](./spec/acceptance/realtime/channel_spec.rb#L2175) + * reattaching (#RTN15c3) + * [transitions state automatically to :attaching once the connection is re-established ](./spec/acceptance/realtime/channel_spec.rb#L2188) + * [sends ATTACH_RESUME flag when reattaching (RTL4j)](./spec/acceptance/realtime/channel_spec.rb#L2203) * a :detached channel - * [remains in the :detached state (#RTL3c)](./spec/acceptance/realtime/channel_spec.rb#L1755) + * [remains in the :detached state (#RTL3c)](./spec/acceptance/realtime/channel_spec.rb#L2225) * a :failed channel - * [remains in the :failed state and retains the error_reason (#RTL3c)](./spec/acceptance/realtime/channel_spec.rb#L1775) + * [remains in the :failed state and retains the error_reason (#RTL3c)](./spec/acceptance/realtime/channel_spec.rb#L2248) * a channel ATTACH request when connection SUSPENDED (#RTL4b) - * [fails the deferrable](./spec/acceptance/realtime/channel_spec.rb#L1797) + * [fails the deferrable](./spec/acceptance/realtime/channel_spec.rb#L2272) * :connected * a :suspended channel - * [is automatically reattached (#RTL3d)](./spec/acceptance/realtime/channel_spec.rb#L1813) + * [is automatically reattached (#RTL3d)](./spec/acceptance/realtime/channel_spec.rb#L2288) * when re-attach attempt fails - * [returns to a suspended state (#RTL3d)](./spec/acceptance/realtime/channel_spec.rb#L1830) + * [returns to a suspended state (#RTL3d)](./spec/acceptance/realtime/channel_spec.rb#L2307) * :disconnected * with an initialized channel - * [has no effect on the channel states (#RTL3e)](./spec/acceptance/realtime/channel_spec.rb#L1856) + * [has no effect on the channel states (#RTL3e)](./spec/acceptance/realtime/channel_spec.rb#L2336) * with an attaching channel - * [has no effect on the channel states (#RTL3e)](./spec/acceptance/realtime/channel_spec.rb#L1869) + * [has no effect on the channel states (#RTL3e)](./spec/acceptance/realtime/channel_spec.rb#L2349) * with an attached channel - * [has no effect on the channel states (#RTL3e)](./spec/acceptance/realtime/channel_spec.rb#L1884) + * [has no effect on the channel states (#RTL3e)](./spec/acceptance/realtime/channel_spec.rb#L2364) * with a detached channel - * [has no effect on the channel states (#RTL3e)](./spec/acceptance/realtime/channel_spec.rb#L1896) + * [has no effect on the channel states (#RTL3e)](./spec/acceptance/realtime/channel_spec.rb#L2380) * with a failed channel - * [has no effect on the channel states (#RTL3e)](./spec/acceptance/realtime/channel_spec.rb#L1918) + * [has no effect on the channel states (#RTL3e)](./spec/acceptance/realtime/channel_spec.rb#L2404) * #presence - * [returns a Ably::Realtime::Presence object](./spec/acceptance/realtime/channel_spec.rb#L1933) + * [returns a Ably::Realtime::Presence object](./spec/acceptance/realtime/channel_spec.rb#L2419) + * #set_options (#RTL16a) + * when channel is attaching + * behaves like an update that sends ATTACH message + * [sends an ATTACH message on options change](./spec/acceptance/realtime/channel_spec.rb#L2436) + * when channel is attached + * behaves like an update that sends ATTACH message + * [sends an ATTACH message on options change](./spec/acceptance/realtime/channel_spec.rb#L2436) + * when channel is initialized + * [doesn't send ATTACH message](./spec/acceptance/realtime/channel_spec.rb#L2469) * channel state change - * [emits a ChannelStateChange object](./spec/acceptance/realtime/channel_spec.rb#L1940) + * [emits a ChannelStateChange object](./spec/acceptance/realtime/channel_spec.rb#L2485) * ChannelStateChange object - * [has current state](./spec/acceptance/realtime/channel_spec.rb#L1949) - * [has a previous state](./spec/acceptance/realtime/channel_spec.rb#L1958) - * [has the event that generated the state change (#TA5)](./spec/acceptance/realtime/channel_spec.rb#L1967) - * [has an empty reason when there is no error](./spec/acceptance/realtime/channel_spec.rb#L1985) + * [has current state](./spec/acceptance/realtime/channel_spec.rb#L2494) + * [has a previous state](./spec/acceptance/realtime/channel_spec.rb#L2503) + * [has the event that generated the state change (#TA5)](./spec/acceptance/realtime/channel_spec.rb#L2512) + * [has an empty reason when there is no error](./spec/acceptance/realtime/channel_spec.rb#L2530) * on failure - * [has a reason Error object when there is an error on the channel](./spec/acceptance/realtime/channel_spec.rb#L1998) + * [has a reason Error object when there is an error on the channel](./spec/acceptance/realtime/channel_spec.rb#L2545) * #resume (#RTL2f) - * [is false when a channel first attaches](./spec/acceptance/realtime/channel_spec.rb#L2013) - * [is true when a connection is recovered and the channel is attached](./spec/acceptance/realtime/channel_spec.rb#L2021) - * [is false when a connection fails to recover and the channel is attached](./spec/acceptance/realtime/channel_spec.rb#L2040) - * when a resume fails - * [is false when a resume fails to recover and the channel is automatically re-attached](./spec/acceptance/realtime/channel_spec.rb#L2062) + * [is false when a channel first attaches](./spec/acceptance/realtime/channel_spec.rb#L2560) + * [is true when a connection is recovered and the channel is attached](./spec/acceptance/realtime/channel_spec.rb#L2568) + * [is false when a connection fails to recover and the channel is attached](./spec/acceptance/realtime/channel_spec.rb#L2587) + * when a connection resume fails + * [is false when channel_serial goes nil (RTP5a1) and the channel is automatically re-attached](./spec/acceptance/realtime/channel_spec.rb#L2609) + * [is true when channel_serial is intact and the channel is automatically re-attached](./spec/acceptance/realtime/channel_spec.rb#L2627) * moves to * suspended - * [all queued messages fail with NACK (#RTL11)](./spec/acceptance/realtime/channel_spec.rb#L2085) - * [all published messages awaiting an ACK do nothing (#RTL11a)](./spec/acceptance/realtime/channel_spec.rb#L2108) + * [all queued messages fail with NACK (#RTL11)](./spec/acceptance/realtime/channel_spec.rb#L2654) + * [all published messages awaiting an ACK do nothing (#RTL11a)](./spec/acceptance/realtime/channel_spec.rb#L2677) * failed - * [all queued messages fail with NACK (#RTL11)](./spec/acceptance/realtime/channel_spec.rb#L2085) - * [all published messages awaiting an ACK do nothing (#RTL11a)](./spec/acceptance/realtime/channel_spec.rb#L2108) + * [all queued messages fail with NACK (#RTL11)](./spec/acceptance/realtime/channel_spec.rb#L2654) + * [all published messages awaiting an ACK do nothing (#RTL11a)](./spec/acceptance/realtime/channel_spec.rb#L2677) * when it receives a server-initiated DETACHED (#RTL13) * and channel is initialized (#RTL13) - * [does nothing](./spec/acceptance/realtime/channel_spec.rb#L2143) + * [does nothing](./spec/acceptance/realtime/channel_spec.rb#L2712) * and channel is failed - * [does nothing (#RTL13)](./spec/acceptance/realtime/channel_spec.rb#L2164) + * [does nothing (#RTL13)](./spec/acceptance/realtime/channel_spec.rb#L2733) * and channel is attached - * [reattaches immediately (#RTL13a)](./spec/acceptance/realtime/channel_spec.rb#L2180) + * [reattaches immediately (#RTL13a) with ATTACH_RESUME flag(RTL4j)](./spec/acceptance/realtime/channel_spec.rb#L2749) * and channel is suspended - * [reattaches immediately (#RTL13a)](./spec/acceptance/realtime/channel_spec.rb#L2196) + * [reattaches immediately (#RTL13a) with ATTACH_RESUME flag(RTL4j)](./spec/acceptance/realtime/channel_spec.rb#L2778) + * when connection is no longer connected + * [will not attempt to reattach (#RTL13c)](./spec/acceptance/realtime/channel_spec.rb#L2810) * and channel is attaching - * [will move to the SUSPENDED state and then attempt to ATTACH with the ATTACHING state (#RTL13b)](./spec/acceptance/realtime/channel_spec.rb#L2218) + * [will move to the SUSPENDED state and then attempt to ATTACH with the ATTACHING state (#RTL13b)](./spec/acceptance/realtime/channel_spec.rb#L2836) * when it receives an ERROR ProtocolMessage - * [should transition to the failed state and the error_reason should be set (#RTL14)](./spec/acceptance/realtime/channel_spec.rb#L2266) + * [should transition to the failed state and the error_reason should be set (#RTL14)](./spec/acceptance/realtime/channel_spec.rb#L2885) ### Ably::Realtime::Channels _(see [spec/acceptance/realtime/channels_spec.rb](./spec/acceptance/realtime/channels_spec.rb))_ * using JSON protocol + * when channel supposed to trigger reattachment per RTL16a (#RTS3c1) + * [will raise an error](./spec/acceptance/realtime/channels_spec.rb#L34) + * params keys are the same but values are different + * [will raise an error](./spec/acceptance/realtime/channels_spec.rb#L50) * using shortcut method #channel on the client object * behaves like a channel * [returns a channel object](./spec/acceptance/realtime/channels_spec.rb#L6) * [returns channel object and passes the provided options](./spec/acceptance/realtime/channels_spec.rb#L12) * using #get method on client#channels * behaves like a channel * [returns a channel object](./spec/acceptance/realtime/channels_spec.rb#L6) * [returns channel object and passes the provided options](./spec/acceptance/realtime/channels_spec.rb#L12) * accessing an existing channel object with different options - * [overrides the existing channel options and returns the channel object](./spec/acceptance/realtime/channels_spec.rb#L41) + * [overrides the existing channel options and returns the channel object](./spec/acceptance/realtime/channels_spec.rb#L82) + * [shows deprecation warning](./spec/acceptance/realtime/channels_spec.rb#L90) * accessing an existing channel object without specifying any channel options - * [returns the existing channel without modifying the channel options](./spec/acceptance/realtime/channels_spec.rb#L53) + * [returns the existing channel without modifying the channel options](./spec/acceptance/realtime/channels_spec.rb#L105) * using undocumented array accessor [] method on client#channels * behaves like a channel * [returns a channel object](./spec/acceptance/realtime/channels_spec.rb#L6) * [returns channel object and passes the provided options](./spec/acceptance/realtime/channels_spec.rb#L12) @@ -529,60 +587,60 @@ * [calls the Proc](./spec/acceptance/realtime/client_spec.rb#L104) * [uses the token request returned from the callback when requesting a new token](./spec/acceptance/realtime/client_spec.rb#L111) * when the returned token has a client_id * [sets Auth#client_id to the new token's client_id immediately when connecting](./spec/acceptance/realtime/client_spec.rb#L119) * [sets Client#client_id to the new token's client_id immediately when connecting](./spec/acceptance/realtime/client_spec.rb#L127) - * with a wildcard client_id token + * with a wildcard client_id token * and an explicit client_id in ClientOptions - * [allows uses the explicit client_id in the connection](./spec/acceptance/realtime/client_spec.rb#L145) + * PENDING: *[allows uses the explicit client_id in the connection](./spec/acceptance/realtime/client_spec.rb#L146)* * and client_id omitted in ClientOptions - * [uses the token provided clientId in the connection](./spec/acceptance/realtime/client_spec.rb#L161) + * [uses the token provided clientId in the connection](./spec/acceptance/realtime/client_spec.rb#L162) * with an invalid wildcard "*" :client_id - * [raises an exception](./spec/acceptance/realtime/client_spec.rb#L177) + * [raises an exception](./spec/acceptance/realtime/client_spec.rb#L178) * realtime connection settings * defaults - * [disconnected_retry_timeout is 15s](./spec/acceptance/realtime/client_spec.rb#L186) - * [suspended_retry_timeout is 30s](./spec/acceptance/realtime/client_spec.rb#L191) + * [disconnected_retry_timeout is 15s](./spec/acceptance/realtime/client_spec.rb#L187) + * [suspended_retry_timeout is 30s](./spec/acceptance/realtime/client_spec.rb#L192) * overriden in ClientOptions - * [disconnected_retry_timeout is updated](./spec/acceptance/realtime/client_spec.rb#L200) - * [suspended_retry_timeout is updated](./spec/acceptance/realtime/client_spec.rb#L205) + * [disconnected_retry_timeout is updated](./spec/acceptance/realtime/client_spec.rb#L201) + * [suspended_retry_timeout is updated](./spec/acceptance/realtime/client_spec.rb#L206) * #connection - * [provides access to the Connection object](./spec/acceptance/realtime/client_spec.rb#L214) + * [provides access to the Connection object](./spec/acceptance/realtime/client_spec.rb#L215) * #channels - * [provides access to the Channels collection object](./spec/acceptance/realtime/client_spec.rb#L221) + * [provides access to the Channels collection object](./spec/acceptance/realtime/client_spec.rb#L222) * #auth - * [provides access to the Realtime::Auth object](./spec/acceptance/realtime/client_spec.rb#L228) + * [provides access to the Realtime::Auth object](./spec/acceptance/realtime/client_spec.rb#L229) * #request (#RSC19*) * get - * [returns an HttpPaginatedResponse object](./spec/acceptance/realtime/client_spec.rb#L240) + * [returns an HttpPaginatedResponse object](./spec/acceptance/realtime/client_spec.rb#L241) * 404 request to invalid URL - * [returns an object with 404 status code and error message](./spec/acceptance/realtime/client_spec.rb#L249) + * [returns an object with 404 status code and error message](./spec/acceptance/realtime/client_spec.rb#L250) * paged results - * [provides paging](./spec/acceptance/realtime/client_spec.rb#L263) + * [provides paging](./spec/acceptance/realtime/client_spec.rb#L264) * post - * [supports post](./spec/acceptance/realtime/client_spec.rb#L294) + * [supports post](./spec/acceptance/realtime/client_spec.rb#L295) * delete - * [supports delete](./spec/acceptance/realtime/client_spec.rb#L308) + * [supports delete](./spec/acceptance/realtime/client_spec.rb#L309) * patch - * [supports patch](./spec/acceptance/realtime/client_spec.rb#L325) + * [supports patch](./spec/acceptance/realtime/client_spec.rb#L326) * put - * [supports put](./spec/acceptance/realtime/client_spec.rb#L349) + * [supports put](./spec/acceptance/realtime/client_spec.rb#L350) * #publish (#TBC) - * [publishing a message implicity connects and publishes the message successfully on the provided channel](./spec/acceptance/realtime/client_spec.rb#L367) - * [publishing does not result in a channel being created](./spec/acceptance/realtime/client_spec.rb#L379) - * [publishing supports an array of Message objects](./spec/acceptance/realtime/client_spec.rb#L407) - * [publishing supports an array of Hash objects](./spec/acceptance/realtime/client_spec.rb#L419) - * [publishing on a closed connection fails](./spec/acceptance/realtime/client_spec.rb#L431) + * [publishing a message implicity connects and publishes the message successfully on the provided channel](./spec/acceptance/realtime/client_spec.rb#L368) + * [publishing does not result in a channel being created](./spec/acceptance/realtime/client_spec.rb#L380) + * [publishing supports an array of Message objects](./spec/acceptance/realtime/client_spec.rb#L408) + * [publishing supports an array of Hash objects](./spec/acceptance/realtime/client_spec.rb#L420) + * [publishing on a closed connection fails](./spec/acceptance/realtime/client_spec.rb#L432) * with extras - * [publishing supports extras](./spec/acceptance/realtime/client_spec.rb#L395) + * [publishing supports extras](./spec/acceptance/realtime/client_spec.rb#L396) * queue_messages ClientOption * when true - * [will queue messages whilst connecting and publish once connected](./spec/acceptance/realtime/client_spec.rb#L447) + * [will queue messages whilst connecting and publish once connected](./spec/acceptance/realtime/client_spec.rb#L448) * when false - * [will reject messages on an initializing connection](./spec/acceptance/realtime/client_spec.rb#L464) + * [will reject messages on an initializing connection](./spec/acceptance/realtime/client_spec.rb#L465) * with more than allowed messages in a single publish - * [rejects the publish](./spec/acceptance/realtime/client_spec.rb#L481) + * [rejects the publish](./spec/acceptance/realtime/client_spec.rb#L482) ### Ably::Realtime::Connection failures _(see [spec/acceptance/realtime/connection_failures_spec.rb](./spec/acceptance/realtime/connection_failures_spec.rb))_ * using JSON protocol * authentication failure @@ -639,87 +697,92 @@ * [attempts to reconnect](./spec/acceptance/realtime/connection_failures_spec.rb#L518) * when retry intervals are stubbed to attempt reconnection quickly * [never calls the provided success block](./spec/acceptance/realtime/connection_failures_spec.rb#L542) * connection resume * when DISCONNECTED ProtocolMessage received from the server - * [reconnects automatically and immediately](./spec/acceptance/realtime/connection_failures_spec.rb#L573) + * [reconnects automatically and immediately (#RTN15a)](./spec/acceptance/realtime/connection_failures_spec.rb#L573) + * when protocolMessage contains token error + * library does not have a means to renew the token (#RTN15h1) + * [moves connection state to failed](./spec/acceptance/realtime/connection_failures_spec.rb#L601) + * library have a means to renew the token (#RTN15h2) + * [attempts to reconnect](./spec/acceptance/realtime/connection_failures_spec.rb#L625) * connection state freshness is monitored - * [resumes connections when disconnected within the connection_state_ttl period (#RTN15g)](./spec/acceptance/realtime/connection_failures_spec.rb#L594) + * [resumes connections when disconnected within the connection_state_ttl period (#RTN15g)](./spec/acceptance/realtime/connection_failures_spec.rb#L649) * when connection_state_ttl period has passed since being disconnected - * [clears the local connection state and uses a new connection when the connection_state_ttl period has passed (#RTN15g)](./spec/acceptance/realtime/connection_failures_spec.rb#L634) + * [clears the local connection state and uses a new connection when the connection_state_ttl period has passed (#RTN15g)](./spec/acceptance/realtime/connection_failures_spec.rb#L689) * when connection_state_ttl period has passed since last activity on the connection - * [does not clear the local connection state when the connection_state_ttl period has passed since last activity, but the idle timeout has not passed (#RTN15g1, #RTN15g2)](./spec/acceptance/realtime/connection_failures_spec.rb#L687) - * [clears the local connection state and uses a new connection when the connection_state_ttl + max_idle_interval period has passed since last activity (#RTN15g1, #RTN15g2)](./spec/acceptance/realtime/connection_failures_spec.rb#L721) - * [still reattaches the channels automatically following a new connection being established (#RTN15g2)](./spec/acceptance/realtime/connection_failures_spec.rb#L756) + * [does not clear the local connection state when the connection_state_ttl period has passed since last activity, but the idle timeout has not passed (#RTN15g1, #RTN15g2)](./spec/acceptance/realtime/connection_failures_spec.rb#L742) + * [clears the local connection state and uses a new connection when the connection_state_ttl + max_idle_interval period has passed since last activity (#RTN15g1, #RTN15g2)](./spec/acceptance/realtime/connection_failures_spec.rb#L774) + * [still reattaches the channels automatically following a new connection being established (#RTN15g2)](./spec/acceptance/realtime/connection_failures_spec.rb#L807) * and subsequently fails to reconnect - * [retries every 15 seconds](./spec/acceptance/realtime/connection_failures_spec.rb#L815) + * [retries every 15 seconds](./spec/acceptance/realtime/connection_failures_spec.rb#L863) * when websocket transport is abruptly disconnected - * [reconnects automatically](./spec/acceptance/realtime/connection_failures_spec.rb#L858) + * [reconnects automatically](./spec/acceptance/realtime/connection_failures_spec.rb#L906) * hosts used - * [reconnects with the default host](./spec/acceptance/realtime/connection_failures_spec.rb#L874) + * [reconnects with the default host](./spec/acceptance/realtime/connection_failures_spec.rb#L922) * after successfully reconnecting and resuming - * [retains connection_id and updates the connection_key (#RTN15e, #RTN16d)](./spec/acceptance/realtime/connection_failures_spec.rb#L898) - * [includes the error received in the connection state change from Ably but leaves the channels attached](./spec/acceptance/realtime/connection_failures_spec.rb#L913) - * [retains channel subscription state](./spec/acceptance/realtime/connection_failures_spec.rb#L939) - * [retains the client_msg_serial (#RTN15c2, #RTN15c3)](./spec/acceptance/realtime/connection_failures_spec.rb#L1000) + * [retains connection_id and updates the connection_key (#RTN15e, #RTN16d)](./spec/acceptance/realtime/connection_failures_spec.rb#L946) + * [includes the error received in the connection state change from Ably but leaves the channels attached](./spec/acceptance/realtime/connection_failures_spec.rb#L961) + * [retains channel subscription state](./spec/acceptance/realtime/connection_failures_spec.rb#L987) + * [retains the client_msg_serial (#RTN15c2, #RTN15c3)](./spec/acceptance/realtime/connection_failures_spec.rb#L1038) * when messages were published whilst the client was disconnected - * [receives the messages published whilst offline](./spec/acceptance/realtime/connection_failures_spec.rb#L967) + * [receives the messages published whilst offline](./spec/acceptance/realtime/connection_failures_spec.rb#L1005) * when failing to resume * because the connection_key is not or no longer valid - * [updates the connection_id and connection_key](./spec/acceptance/realtime/connection_failures_spec.rb#L1040) - * [issue a reattach for all attached channels and fail all message awaiting an ACK (#RTN15c3)](./spec/acceptance/realtime/connection_failures_spec.rb#L1055) - * [issue a reattach for all attaching channels and fail all queued messages (#RTN15c3)](./spec/acceptance/realtime/connection_failures_spec.rb#L1093) - * [issue a attach for all suspended channels (#RTN15c3)](./spec/acceptance/realtime/connection_failures_spec.rb#L1129) - * [sets the error reason on each channel](./spec/acceptance/realtime/connection_failures_spec.rb#L1167) - * [continues to use the client_msg_serial (#RTN15c3)](./spec/acceptance/realtime/connection_failures_spec.rb#L1182) + * [updates the connection_id and connection_key](./spec/acceptance/realtime/connection_failures_spec.rb#L1078) + * [issue a reattach for all attached channels and fail all message awaiting an ACK (#RTN15c3)](./spec/acceptance/realtime/connection_failures_spec.rb#L1093) + * [issue a reattach for all attaching channels and fail all queued messages (#RTN15c3)](./spec/acceptance/realtime/connection_failures_spec.rb#L1131) + * [issue a attach for all suspended channels (#RTN15c3)](./spec/acceptance/realtime/connection_failures_spec.rb#L1167) + * [sets the error reason on each channel](./spec/acceptance/realtime/connection_failures_spec.rb#L1205) + * [continues to use the client_msg_serial (#RTN15c3)](./spec/acceptance/realtime/connection_failures_spec.rb#L1220) * as the DISCONNECTED window to resume has passed - * [starts a new connection automatically and does not try and resume](./spec/acceptance/realtime/connection_failures_spec.rb#L1219) + * [starts a new connection automatically and does not try and resume](./spec/acceptance/realtime/connection_failures_spec.rb#L1257) * when an ERROR protocol message is received * whilst connecting * with a token error code in the range 40140 <= code < 40150 (#RTN14b) - * [triggers a re-authentication](./spec/acceptance/realtime/connection_failures_spec.rb#L1250) + * [triggers a re-authentication](./spec/acceptance/realtime/connection_failures_spec.rb#L1288) * with an error code indicating an error other than a token failure (#RTN14g, #RTN15i) - * [causes the connection to fail](./spec/acceptance/realtime/connection_failures_spec.rb#L1266) + * [causes the connection to fail](./spec/acceptance/realtime/connection_failures_spec.rb#L1304) * with no error code indicating an error other than a token failure (#RTN14g, #RTN15i) - * [causes the connection to fail](./spec/acceptance/realtime/connection_failures_spec.rb#L1279) + * [causes the connection to fail](./spec/acceptance/realtime/connection_failures_spec.rb#L1317) * whilst connected * with a token error code in the range 40140 <= code < 40150 (#RTN14b) - * [triggers a re-authentication](./spec/acceptance/realtime/connection_failures_spec.rb#L1250) + * [triggers a re-authentication](./spec/acceptance/realtime/connection_failures_spec.rb#L1288) * with an error code indicating an error other than a token failure (#RTN14g, #RTN15i) - * [causes the connection to fail](./spec/acceptance/realtime/connection_failures_spec.rb#L1266) + * [causes the connection to fail](./spec/acceptance/realtime/connection_failures_spec.rb#L1304) * with no error code indicating an error other than a token failure (#RTN14g, #RTN15i) - * [causes the connection to fail](./spec/acceptance/realtime/connection_failures_spec.rb#L1279) + * [causes the connection to fail](./spec/acceptance/realtime/connection_failures_spec.rb#L1317) * whilst resuming * with a token error code in the region 40140 <= code < 40150 (RTN15c5) - * [triggers a re-authentication and then resumes the connection](./spec/acceptance/realtime/connection_failures_spec.rb#L1323) + * [triggers a re-authentication and then resumes the connection](./spec/acceptance/realtime/connection_failures_spec.rb#L1361) * with any other error (#RTN15c4) - * [moves the connection to the failed state](./spec/acceptance/realtime/connection_failures_spec.rb#L1355) + * [moves the connection to the failed state](./spec/acceptance/realtime/connection_failures_spec.rb#L1395) * fallback host feature * with custom realtime websocket host option - * [never uses a fallback host](./spec/acceptance/realtime/connection_failures_spec.rb#L1399) + * [never uses a fallback host](./spec/acceptance/realtime/connection_failures_spec.rb#L1439) * with custom realtime websocket port option - * [never uses a fallback host](./spec/acceptance/realtime/connection_failures_spec.rb#L1417) + * [never uses a fallback host](./spec/acceptance/realtime/connection_failures_spec.rb#L1457) * with non-production environment * :fallback_hosts_use_default is unset - * [uses fallback hosts by default](./spec/acceptance/realtime/connection_failures_spec.rb#L1441) + * [uses fallback hosts by default](./spec/acceptance/realtime/connection_failures_spec.rb#L1481) * :fallback_hosts_use_default is true - * [uses a fallback host on every subsequent disconnected attempt until suspended (#RTN17b, #TO3k7)](./spec/acceptance/realtime/connection_failures_spec.rb#L1459) - * [does not use a fallback host if the connection connects on the default host and then later becomes disconnected](./spec/acceptance/realtime/connection_failures_spec.rb#L1477) + * [uses a fallback host on every subsequent disconnected attempt until suspended (#RTN17b, #TO3k7)](./spec/acceptance/realtime/connection_failures_spec.rb#L1499) + * [does not use a fallback host if the connection connects on the default host and then later becomes disconnected](./spec/acceptance/realtime/connection_failures_spec.rb#L1517) * :fallback_hosts array is provided - * [uses a fallback host on every subsequent disconnected attempt until suspended (#RTN17b, #TO3k6)](./spec/acceptance/realtime/connection_failures_spec.rb#L1505) + * [uses a fallback host on every subsequent disconnected attempt until suspended (#RTN17b, #TO3k6)](./spec/acceptance/realtime/connection_failures_spec.rb#L1545) * with production environment * when the Internet is down - * [never uses a fallback host](./spec/acceptance/realtime/connection_failures_spec.rb#L1541) + * [never uses a fallback host](./spec/acceptance/realtime/connection_failures_spec.rb#L1581) * when the Internet is up * and default options - * [uses a fallback host + the original host once on every subsequent disconnected attempt until suspended](./spec/acceptance/realtime/connection_failures_spec.rb#L1564) - * [uses the primary host when suspended, and then every fallback host and the primary host again on every subsequent suspended attempt](./spec/acceptance/realtime/connection_failures_spec.rb#L1583) - * [uses the correct host name for the WebSocket requests to the fallback hosts](./spec/acceptance/realtime/connection_failures_spec.rb#L1606) + * [uses a fallback host + the original host once on every subsequent disconnected attempt until suspended](./spec/acceptance/realtime/connection_failures_spec.rb#L1604) + * [uses the primary host when suspended, and then every fallback host and the primary host again on every subsequent suspended attempt](./spec/acceptance/realtime/connection_failures_spec.rb#L1623) + * [uses the correct host name for the WebSocket requests to the fallback hosts](./spec/acceptance/realtime/connection_failures_spec.rb#L1646) * :fallback_hosts array is provided by an empty array - * [uses a fallback host on every subsequent disconnected attempt until suspended (#RTN17b, #TO3k6)](./spec/acceptance/realtime/connection_failures_spec.rb#L1636) + * [uses a fallback host on every subsequent disconnected attempt until suspended (#RTN17b, #TO3k6)](./spec/acceptance/realtime/connection_failures_spec.rb#L1676) * :fallback_hosts array is provided - * [uses a fallback host on every subsequent disconnected attempt until suspended (#RTN17b, #TO3k6)](./spec/acceptance/realtime/connection_failures_spec.rb#L1656) + * [uses a fallback host on every subsequent disconnected attempt until suspended (#RTN17b, #TO3k6)](./spec/acceptance/realtime/connection_failures_spec.rb#L1696) ### Ably::Realtime::Connection _(see [spec/acceptance/realtime/connection_spec.rb](./spec/acceptance/realtime/connection_spec.rb))_ * using JSON protocol * intialization @@ -735,213 +798,220 @@ * with valid pre authorized token expiring in the future * [uses the existing token created by Auth](./spec/acceptance/realtime/connection_spec.rb#L72) * that expire * opening a new connection * with almost expired tokens - * [renews token every time after it expires](./spec/acceptance/realtime/connection_spec.rb#L106) + * FAILED: ~~[renews token every time after it expires](./spec/acceptance/realtime/connection_spec.rb#L107)~~ * with immediately expired token and no fallback hosts - * [renews the token on connect, and makes one immediate subsequent attempt to obtain a new token (#RSA4b)](./spec/acceptance/realtime/connection_spec.rb#L136) + * [renews the token on connect, and makes one immediate subsequent attempt to obtain a new token (#RSA4b)](./spec/acceptance/realtime/connection_spec.rb#L137) * when disconnected_retry_timeout is 0.5 seconds - * [renews the token on connect, and continues to attempt renew based on the retry schedule](./spec/acceptance/realtime/connection_spec.rb#L151) + * [renews the token on connect, and continues to attempt renew based on the retry schedule](./spec/acceptance/realtime/connection_spec.rb#L152) * using implicit token auth - * [uses the primary host for subsequent connection and auth requests](./spec/acceptance/realtime/connection_spec.rb#L181) + * [uses the primary host for subsequent connection and auth requests](./spec/acceptance/realtime/connection_spec.rb#L182) * when connected with a valid non-expired token * that then expires following the connection being opened * the server - * [disconnects the client, and the client automatically renews the token and then reconnects](./spec/acceptance/realtime/connection_spec.rb#L212) + * [disconnects the client, and the client automatically renews the token and then reconnects](./spec/acceptance/realtime/connection_spec.rb#L213) * connection state - * [retains messages published when disconnected three times during authentication](./spec/acceptance/realtime/connection_spec.rb#L272) + * [retains messages published when disconnected three times during authentication](./spec/acceptance/realtime/connection_spec.rb#L273) * and subsequent token is invalid - * [transitions the connection to the failed state](./spec/acceptance/realtime/connection_spec.rb#L307) + * [transitions the connection to the failed state](./spec/acceptance/realtime/connection_spec.rb#L308) * for non-renewable tokens * that are expired * opening a new connection - * [transitions state to failed (#RSA4a)](./spec/acceptance/realtime/connection_spec.rb#L337) + * [transitions state to failed (#RSA4a)](./spec/acceptance/realtime/connection_spec.rb#L338) * when connected - * [transitions state to failed (#RSA4a)](./spec/acceptance/realtime/connection_spec.rb#L353) + * [transitions state to failed (#RSA4a)](./spec/acceptance/realtime/connection_spec.rb#L354) * with opaque token string that contain an implicit client_id * string - * [sets the Client#client_id and Auth#client_id once CONNECTED](./spec/acceptance/realtime/connection_spec.rb#L373) + * [sets the Client#client_id and Auth#client_id once CONNECTED](./spec/acceptance/realtime/connection_spec.rb#L374) * that is incompatible with the current client client_id - * [fails the connection](./spec/acceptance/realtime/connection_spec.rb#L385) + * PENDING: *[fails the connection](./spec/acceptance/realtime/connection_spec.rb#L387)* * wildcard - * [configures the Client#client_id and Auth#client_id with a wildcard once CONNECTED](./spec/acceptance/realtime/connection_spec.rb#L399) + * [configures the Client#client_id and Auth#client_id with a wildcard once CONNECTED](./spec/acceptance/realtime/connection_spec.rb#L401) * initialization state changes * with implicit #connect - * [are emitted in order](./spec/acceptance/realtime/connection_spec.rb#L431) + * [are emitted in order](./spec/acceptance/realtime/connection_spec.rb#L433) * with explicit #connect - * [are emitted in order](./spec/acceptance/realtime/connection_spec.rb#L437) + * [are emitted in order](./spec/acceptance/realtime/connection_spec.rb#L439) * #connect with no fallbacks - * [returns a SafeDeferrable that catches exceptions in callbacks and logs them](./spec/acceptance/realtime/connection_spec.rb#L447) - * [calls the Deferrable callback on success](./spec/acceptance/realtime/connection_spec.rb#L452) - * [calls the provided block on success even if state changes to disconnected first](./spec/acceptance/realtime/connection_spec.rb#L459) + * [returns a SafeDeferrable that catches exceptions in callbacks and logs them](./spec/acceptance/realtime/connection_spec.rb#L449) + * [calls the Deferrable callback on success](./spec/acceptance/realtime/connection_spec.rb#L454) + * [calls the provided block on success even if state changes to disconnected first](./spec/acceptance/realtime/connection_spec.rb#L461) + * when can't connect to host + * [logs error on failed connection attempt](./spec/acceptance/realtime/connection_spec.rb#L490) + * when explicitly reconnecting disconnected/suspended connection in retry (#RTN11c) + * when suspended + * [reconnects immediately](./spec/acceptance/realtime/connection_spec.rb#L530) + * when disconnected + * [reconnects immediately](./spec/acceptance/realtime/connection_spec.rb#L564) + * when reconnecting a failed connection + * [transitions all channels state to initialized and cleares error_reason](./spec/acceptance/realtime/connection_spec.rb#L594) * with invalid auth details - * [calls the Deferrable errback only once on connection failure](./spec/acceptance/realtime/connection_spec.rb#L488) + * [calls the Deferrable errback only once on connection failure](./spec/acceptance/realtime/connection_spec.rb#L622) * when already connected - * [does nothing and no further state changes are emitted](./spec/acceptance/realtime/connection_spec.rb#L504) + * [does nothing and no further state changes are emitted](./spec/acceptance/realtime/connection_spec.rb#L638) * connection#id - * [is null before connecting](./spec/acceptance/realtime/connection_spec.rb#L518) + * [is null before connecting](./spec/acceptance/realtime/connection_spec.rb#L652) * connection#key - * [is null before connecting](./spec/acceptance/realtime/connection_spec.rb#L525) + * [is null before connecting](./spec/acceptance/realtime/connection_spec.rb#L659) * once connected * connection#id - * [is a string](./spec/acceptance/realtime/connection_spec.rb#L536) - * [is unique from the connection#key](./spec/acceptance/realtime/connection_spec.rb#L543) - * [is unique for every connection](./spec/acceptance/realtime/connection_spec.rb#L550) + * [is a string](./spec/acceptance/realtime/connection_spec.rb#L670) + * [is unique from the connection#key](./spec/acceptance/realtime/connection_spec.rb#L677) + * [is unique for every connection](./spec/acceptance/realtime/connection_spec.rb#L684) * connection#key - * [is a string](./spec/acceptance/realtime/connection_spec.rb#L559) - * [is unique from the connection#id](./spec/acceptance/realtime/connection_spec.rb#L566) - * [is unique for every connection](./spec/acceptance/realtime/connection_spec.rb#L573) + * [is a string](./spec/acceptance/realtime/connection_spec.rb#L693) + * [is unique from the connection#id](./spec/acceptance/realtime/connection_spec.rb#L700) + * [is unique for every connection](./spec/acceptance/realtime/connection_spec.rb#L707) * following a previous connection being opened and closed - * [reconnects and is provided with a new connection ID and connection key from the server](./spec/acceptance/realtime/connection_spec.rb#L583) + * [reconnects and is provided with a new connection ID and connection key from the server](./spec/acceptance/realtime/connection_spec.rb#L717) * when closing - * [fails the deferrable before the connection is closed](./spec/acceptance/realtime/connection_spec.rb#L600) - * #serial connection serial - * [is set to -1 when a new connection is opened](./spec/acceptance/realtime/connection_spec.rb#L617) - * FAILED: ~~[is set to 0 when a message is received back](./spec/acceptance/realtime/connection_spec.rb#L640)~~ - * [is set to 1 when the second message is received](./spec/acceptance/realtime/connection_spec.rb#L648) - * when a message is sent but the ACK has not yet been received - * [the sent message msgSerial is 0 but the connection serial remains at -1](./spec/acceptance/realtime/connection_spec.rb#L625) + * [fails the deferrable before the connection is closed](./spec/acceptance/realtime/connection_spec.rb#L734) * #msgSerial * when messages are queued for publish before a connection is established - * [the msgSerial is always incrementing (and not reset when the new connection is established) ensuring messages are never de-duped by the realtime service](./spec/acceptance/realtime/connection_spec.rb#L676) + * [the msgSerial is always incrementing (and not reset when the new connection is established) ensuring messages are never de-duped by the realtime service](./spec/acceptance/realtime/connection_spec.rb#L758) * #close - * [returns a SafeDeferrable that catches exceptions in callbacks and logs them](./spec/acceptance/realtime/connection_spec.rb#L696) - * [calls the Deferrable callback on success](./spec/acceptance/realtime/connection_spec.rb#L703) + * [returns a SafeDeferrable that catches exceptions in callbacks and logs them](./spec/acceptance/realtime/connection_spec.rb#L790) + * [calls the Deferrable callback on success](./spec/acceptance/realtime/connection_spec.rb#L797) * when already closed - * [does nothing and no further state changes are emitted](./spec/acceptance/realtime/connection_spec.rb#L714) + * [does nothing and no further state changes are emitted](./spec/acceptance/realtime/connection_spec.rb#L808) * when connection state is * :initialized - * [changes the connection state to :closing and then immediately :closed without sending a ProtocolMessage CLOSE](./spec/acceptance/realtime/connection_spec.rb#L741) + * [changes the connection state to :closing and then immediately :closed without sending a ProtocolMessage CLOSE](./spec/acceptance/realtime/connection_spec.rb#L835) + * :connecting RTN12f + * :connected does not arrive when trying to close + * [moves to closed](./spec/acceptance/realtime/connection_spec.rb#L853) + * :connected arrive when trying to close + * [moves to connected and then to closed](./spec/acceptance/realtime/connection_spec.rb#L880) * :connected - * [changes the connection state to :closing and waits for the server to confirm connection is :closed with a ProtocolMessage](./spec/acceptance/realtime/connection_spec.rb#L758) + * [changes the connection state to :closing and waits for the server to confirm connection is :closed with a ProtocolMessage](./spec/acceptance/realtime/connection_spec.rb#L901) * with an unresponsive connection - * [force closes the connection when a :closed ProtocolMessage response is not received](./spec/acceptance/realtime/connection_spec.rb#L785) + * [force closes the connection when a :closed ProtocolMessage response is not received](./spec/acceptance/realtime/connection_spec.rb#L928) + * :suspended RTN12d + * [immediatly closes connection](./spec/acceptance/realtime/connection_spec.rb#L957) + * :disconnected RTN12d + * [immediatly closes connection](./spec/acceptance/realtime/connection_spec.rb#L992) * #ping - * [echoes a heart beat (#RTN13a)](./spec/acceptance/realtime/connection_spec.rb#L807) - * [sends a unique ID in each protocol message (#RTN13e)](./spec/acceptance/realtime/connection_spec.rb#L817) - * [waits until the connection becomes CONNECTED when in the CONNETING state](./spec/acceptance/realtime/connection_spec.rb#L841) + * [echoes a heart beat (#RTN13a)](./spec/acceptance/realtime/connection_spec.rb#L1025) + * [sends a unique ID in each protocol message (#RTN13e)](./spec/acceptance/realtime/connection_spec.rb#L1035) + * [waits until the connection becomes CONNECTED when in the CONNETING state](./spec/acceptance/realtime/connection_spec.rb#L1059) * with incompatible states * when not connected - * [fails the deferrable (#RTN13b)](./spec/acceptance/realtime/connection_spec.rb#L854) + * [fails the deferrable (#RTN13b)](./spec/acceptance/realtime/connection_spec.rb#L1072) * when suspended - * [fails the deferrable (#RTN13b)](./spec/acceptance/realtime/connection_spec.rb#L863) + * [fails the deferrable (#RTN13b)](./spec/acceptance/realtime/connection_spec.rb#L1081) * when failed - * [fails the deferrable (#RTN13b)](./spec/acceptance/realtime/connection_spec.rb#L875) + * [fails the deferrable (#RTN13b)](./spec/acceptance/realtime/connection_spec.rb#L1093) * when closed - * [fails the deferrable (#RTN13b)](./spec/acceptance/realtime/connection_spec.rb#L887) + * [fails the deferrable (#RTN13b)](./spec/acceptance/realtime/connection_spec.rb#L1105) * when it becomes closed - * [fails the deferrable (#RTN13b)](./spec/acceptance/realtime/connection_spec.rb#L901) + * [fails the deferrable (#RTN13b)](./spec/acceptance/realtime/connection_spec.rb#L1119) * with a success block that raises an exception - * [catches the exception and logs the error](./spec/acceptance/realtime/connection_spec.rb#L914) + * [catches the exception and logs the error](./spec/acceptance/realtime/connection_spec.rb#L1132) * when ping times out - * [fails the deferrable logs a warning (#RTN13a, #RTN13c)](./spec/acceptance/realtime/connection_spec.rb#L928) - * [yields to the block with a nil value](./spec/acceptance/realtime/connection_spec.rb#L947) + * [fails the deferrable logs a warning (#RTN13a, #RTN13c)](./spec/acceptance/realtime/connection_spec.rb#L1146) + * [yields to the block with a nil value](./spec/acceptance/realtime/connection_spec.rb#L1165) * Heartbeats (#RTN23) * heartbeat interval * when reduced artificially - * [is the sum of the max_idle_interval and realtime_request_timeout (#RTN23a)](./spec/acceptance/realtime/connection_spec.rb#L974) - * [disconnects the transport if no heartbeat received since connected (#RTN23a)](./spec/acceptance/realtime/connection_spec.rb#L984) - * [disconnects the transport if no heartbeat received since last event received (#RTN23a)](./spec/acceptance/realtime/connection_spec.rb#L995) + * [is the sum of the max_idle_interval and realtime_request_timeout (#RTN23a)](./spec/acceptance/realtime/connection_spec.rb#L1191) + * [disconnects the transport if no heartbeat received since connected (#RTN23a)](./spec/acceptance/realtime/connection_spec.rb#L1201) + * [disconnects the transport if no heartbeat received since last event received (#RTN23a)](./spec/acceptance/realtime/connection_spec.rb#L1212) * transport-level heartbeats are supported in the websocket transport - * [provides the heartbeats argument in the websocket connection params (#RTN23b)](./spec/acceptance/realtime/connection_spec.rb#L1010) - * [receives websocket heartbeat messages (#RTN23b) [slow test as need to wait for heartbeat]](./spec/acceptance/realtime/connection_spec.rb#L1019) + * [provides the heartbeats argument in the websocket connection params (#RTN23b)](./spec/acceptance/realtime/connection_spec.rb#L1227) + * [receives websocket heartbeat messages (#RTN23b) [slow test as need to wait for heartbeat]](./spec/acceptance/realtime/connection_spec.rb#L1236) * with websocket heartbeats disabled (undocumented) - * [does not provide the heartbeats argument in the websocket connection params (#RTN23b)](./spec/acceptance/realtime/connection_spec.rb#L1035) - * [receives websocket protocol messages (#RTN23b) [slow test as need to wait for heartbeat]](./spec/acceptance/realtime/connection_spec.rb#L1044) + * [does not provide the heartbeats argument in the websocket connection params (#RTN23b)](./spec/acceptance/realtime/connection_spec.rb#L1252) + * [receives websocket protocol messages (#RTN23b) [slow test as need to wait for heartbeat]](./spec/acceptance/realtime/connection_spec.rb#L1261) * #details - * [is nil before connected](./spec/acceptance/realtime/connection_spec.rb#L1062) - * [contains the ConnectionDetails object once connected (#RTN21)](./spec/acceptance/realtime/connection_spec.rb#L1069) - * [contains the new ConnectionDetails object once a subsequent connection is created (#RTN21)](./spec/acceptance/realtime/connection_spec.rb#L1078) + * [is nil before connected](./spec/acceptance/realtime/connection_spec.rb#L1279) + * [contains the ConnectionDetails object once connected (#RTN21)](./spec/acceptance/realtime/connection_spec.rb#L1286) + * [contains the new ConnectionDetails object once a subsequent connection is created (#RTN21)](./spec/acceptance/realtime/connection_spec.rb#L1295) * with a different default connection_state_ttl - * [updates the private Connection#connection_state_ttl when received from Ably in ConnectionDetails](./spec/acceptance/realtime/connection_spec.rb#L1099) + * [updates the private Connection#connection_state_ttl when received from Ably in ConnectionDetails](./spec/acceptance/realtime/connection_spec.rb#L1316) * recovery * #recovery_key - * [is composed of connection key and serial that is kept up to date with each message ACK received](./spec/acceptance/realtime/connection_spec.rb#L1136) - * [is available when connection is in one of the states: connecting, connected, disconnected](./spec/acceptance/realtime/connection_spec.rb#L1164) - * [is nil when connection is explicitly CLOSED](./spec/acceptance/realtime/connection_spec.rb#L1194) + * [is available when connection is in one of the states: connecting, connected, disconnected](./spec/acceptance/realtime/connection_spec.rb#L1353) + * [is nil when connection is explicitly CLOSED](./spec/acceptance/realtime/connection_spec.rb#L1383) * opening a new connection using a recently disconnected connection's #recovery_key * connection#id after recovery - * [remains the same](./spec/acceptance/realtime/connection_spec.rb#L1206) + * [remains the same](./spec/acceptance/realtime/connection_spec.rb#L1395) * when messages have been sent whilst the old connection is disconnected * the new connection - * [recovers server-side queued messages](./spec/acceptance/realtime/connection_spec.rb#L1242) + * [recovers server-side queued messages](./spec/acceptance/realtime/connection_spec.rb#L1417) * when messages have been published * the new connection - * [uses the correct msgSerial from the old connection](./spec/acceptance/realtime/connection_spec.rb#L1271) + * [uses the correct msgSerial from the old connection](./spec/acceptance/realtime/connection_spec.rb#L1446) * when messages are published before the new connection is recovered * the new connection - * [uses the correct msgSerial from the old connection for the queued messages](./spec/acceptance/realtime/connection_spec.rb#L1301) + * [uses the correct msgSerial from the old connection for the queued messages](./spec/acceptance/realtime/connection_spec.rb#L1476) * with :recover option * with invalid syntax - * [raises an exception](./spec/acceptance/realtime/connection_spec.rb#L1348) - * with invalid formatted value sent to server - * [sets the #error_reason and moves the connection to FAILED](./spec/acceptance/realtime/connection_spec.rb#L1357) - * with expired (missing) value sent to server - * [connects but sets the error reason and includes the reason in the state change](./spec/acceptance/realtime/connection_spec.rb#L1372) + * [logs recovery decode error as a warning and connects successfully](./spec/acceptance/realtime/connection_spec.rb#L1523) + * with invalid connection key + * [connects but sets the error reason and includes the reason in the state change](./spec/acceptance/realtime/connection_spec.rb#L1538) * with many connections simultaneously - * [opens each with a unique connection#id and connection#key](./spec/acceptance/realtime/connection_spec.rb#L1391) + * [opens each with a unique connection#id and connection#key](./spec/acceptance/realtime/connection_spec.rb#L1557) * when a state transition is unsupported - * [logs the invalid state change as fatal](./spec/acceptance/realtime/connection_spec.rb#L1411) + * [logs the invalid state change as fatal](./spec/acceptance/realtime/connection_spec.rb#L1577) * protocol failure * receiving an invalid ProtocolMessage - * [emits an error on the connection and logs a fatal error message](./spec/acceptance/realtime/connection_spec.rb#L1427) + * [emits an error on the connection and logs a fatal error message](./spec/acceptance/realtime/connection_spec.rb#L1593) * undocumented method * #internet_up? - * [returns a Deferrable](./spec/acceptance/realtime/connection_spec.rb#L1445) + * [returns a Deferrable](./spec/acceptance/realtime/connection_spec.rb#L1611) * internet up URL protocol * when using TLS for the connection - * [uses TLS for the Internet check to https://internet-up.ably-realtime.com/is-the-internet-up.txt](./spec/acceptance/realtime/connection_spec.rb#L1456) + * [uses TLS for the Internet check to https://internet-up.ably-realtime.com/is-the-internet-up.txt](./spec/acceptance/realtime/connection_spec.rb#L1622) * when using a non-secured connection - * [uses TLS for the Internet check to http://internet-up.ably-realtime.com/is-the-internet-up.txt](./spec/acceptance/realtime/connection_spec.rb#L1466) + * [uses TLS for the Internet check to http://internet-up.ably-realtime.com/is-the-internet-up.txt](./spec/acceptance/realtime/connection_spec.rb#L1632) * when the Internet is up - * [calls the block with true](./spec/acceptance/realtime/connection_spec.rb#L1497) - * [calls the success callback of the Deferrable](./spec/acceptance/realtime/connection_spec.rb#L1504) + * [calls the block with true](./spec/acceptance/realtime/connection_spec.rb#L1663) + * [calls the success callback of the Deferrable](./spec/acceptance/realtime/connection_spec.rb#L1670) * with a TLS connection - * [checks the Internet up URL over TLS](./spec/acceptance/realtime/connection_spec.rb#L1480) + * [checks the Internet up URL over TLS](./spec/acceptance/realtime/connection_spec.rb#L1646) * with a non-TLS connection - * [checks the Internet up URL over TLS](./spec/acceptance/realtime/connection_spec.rb#L1490) + * [checks the Internet up URL over TLS](./spec/acceptance/realtime/connection_spec.rb#L1656) * when the Internet is down - * [calls the block with false](./spec/acceptance/realtime/connection_spec.rb#L1519) - * [calls the failure callback of the Deferrable](./spec/acceptance/realtime/connection_spec.rb#L1526) + * [calls the block with false](./spec/acceptance/realtime/connection_spec.rb#L1685) + * [calls the failure callback of the Deferrable](./spec/acceptance/realtime/connection_spec.rb#L1692) * state change side effects * when connection enters the :disconnected state - * [queues messages to be sent and all channels remain attached](./spec/acceptance/realtime/connection_spec.rb#L1540) + * [queues messages to be sent and all channels remain attached](./spec/acceptance/realtime/connection_spec.rb#L1706) * when connection enters the :suspended state - * [moves the channels into the suspended state and prevents publishing of messages on those channels](./spec/acceptance/realtime/connection_spec.rb#L1573) + * [moves the channels into the suspended state and prevents publishing of messages on those channels](./spec/acceptance/realtime/connection_spec.rb#L1739) * when connection enters the :failed state - * [sets all channels to failed and prevents publishing of messages on those channels](./spec/acceptance/realtime/connection_spec.rb#L1604) + * [sets all channels to failed and prevents publishing of messages on those channels](./spec/acceptance/realtime/connection_spec.rb#L1770) * connection state change - * [emits event to all and single subscribers](./spec/acceptance/realtime/connection_spec.rb#L1618) - * [emits a ConnectionStateChange object](./spec/acceptance/realtime/connection_spec.rb#L1633) + * [emits event to all and single subscribers](./spec/acceptance/realtime/connection_spec.rb#L1784) + * [emits a ConnectionStateChange object](./spec/acceptance/realtime/connection_spec.rb#L1799) * ConnectionStateChange object - * [has current state](./spec/acceptance/realtime/connection_spec.rb#L1641) - * [has a previous state](./spec/acceptance/realtime/connection_spec.rb#L1649) - * [has the event that generated the state change (#TH5)](./spec/acceptance/realtime/connection_spec.rb#L1657) - * [has an empty reason when there is no error](./spec/acceptance/realtime/connection_spec.rb#L1673) + * [has current state](./spec/acceptance/realtime/connection_spec.rb#L1807) + * [has a previous state](./spec/acceptance/realtime/connection_spec.rb#L1815) + * [has the event that generated the state change (#TH5)](./spec/acceptance/realtime/connection_spec.rb#L1823) + * [has an empty reason when there is no error](./spec/acceptance/realtime/connection_spec.rb#L1839) * on failure - * [has a reason Error object when there is an error on the connection](./spec/acceptance/realtime/connection_spec.rb#L1686) + * [has a reason Error object when there is an error on the connection](./spec/acceptance/realtime/connection_spec.rb#L1852) * retry_in - * [is nil when a retry is not required](./spec/acceptance/realtime/connection_spec.rb#L1701) - * [is 0 when first attempt to connect fails](./spec/acceptance/realtime/connection_spec.rb#L1708) - * [is 0 when an immediate reconnect will occur](./spec/acceptance/realtime/connection_spec.rb#L1718) - * [contains the next retry period when an immediate reconnect will not occur](./spec/acceptance/realtime/connection_spec.rb#L1728) + * [is nil when a retry is not required](./spec/acceptance/realtime/connection_spec.rb#L1867) + * FAILED: ~~[is 0 when first attempt to connect fails](./spec/acceptance/realtime/connection_spec.rb#L1874)~~ + * [is 0 when an immediate reconnect will occur](./spec/acceptance/realtime/connection_spec.rb#L1884) + * [contains the next retry period when an immediate reconnect will not occur](./spec/acceptance/realtime/connection_spec.rb#L1894) * whilst CONNECTED * when a CONNECTED message is received (#RTN24) - * [emits an UPDATE event](./spec/acceptance/realtime/connection_spec.rb#L1763) - * [updates the ConnectionDetail and Connection attributes (#RTC8a1)](./spec/acceptance/realtime/connection_spec.rb#L1778) + * [emits an UPDATE event](./spec/acceptance/realtime/connection_spec.rb#L1928) + * [updates the ConnectionDetail and Connection attributes (#RTC8a1)](./spec/acceptance/realtime/connection_spec.rb#L1943) * when a CONNECTED message with an error is received - * [emits an UPDATE event](./spec/acceptance/realtime/connection_spec.rb#L1813) + * [emits an UPDATE event](./spec/acceptance/realtime/connection_spec.rb#L1976) * version params - * [sends the protocol version param v (#G4, #RTN2f)](./spec/acceptance/realtime/connection_spec.rb#L1834) - * [sends the lib version param lib (#RTN2g)](./spec/acceptance/realtime/connection_spec.rb#L1843) - * with variant - * [sends the lib version param lib with the variant (#RTN2g + #RSC7b)](./spec/acceptance/realtime/connection_spec.rb#L1863) + * [sends the protocol version param v (#G4, #RTN2f)](./spec/acceptance/realtime/connection_spec.rb#L1997) + * [sends the lib version param agent (#RCS7d)](./spec/acceptance/realtime/connection_spec.rb#L2006) * transport_params (#RTC1f) - * [pases transport_params to query](./spec/acceptance/realtime/connection_spec.rb#L1877) + * [pases transport_params to query](./spec/acceptance/realtime/connection_spec.rb#L2019) * when changing default param - * [overrides default param (#RTC1f1)](./spec/acceptance/realtime/connection_spec.rb#L1890) + * [overrides default param (#RTC1f1)](./spec/acceptance/realtime/connection_spec.rb#L2032) ### Ably::Realtime::Channel Message _(see [spec/acceptance/realtime/message_spec.rb](./spec/acceptance/realtime/message_spec.rb))_ * using JSON protocol * [sends a String data payload](./spec/acceptance/realtime/message_spec.rb#L25) @@ -952,208 +1022,564 @@ * [is encoded and decoded to the same Array](./spec/acceptance/realtime/message_spec.rb#L56) * String * [is encoded and decoded to the same Array](./spec/acceptance/realtime/message_spec.rb#L64) * Binary * [is encoded and decoded to the same Array](./spec/acceptance/realtime/message_spec.rb#L72) + * a single Message object (#RSL1a) + * [publishes the message](./spec/acceptance/realtime/message_spec.rb#L83) + * an array of Message objects (#RSL1a) + * [publishes three messages](./spec/acceptance/realtime/message_spec.rb#L100) + * an array of hashes (#RSL1a) + * [publishes three messages](./spec/acceptance/realtime/message_spec.rb#L123) + * a name with data payload (#RSL1a, #RSL1b) + * [publishes a message](./spec/acceptance/realtime/message_spec.rb#L144) * with supported extra payload content type (#RTL6h, #RSL6a2) * JSON Object (Hash) - * [is encoded and decoded to the same hash](./spec/acceptance/realtime/message_spec.rb#L93) + * [is encoded and decoded to the same hash](./spec/acceptance/realtime/message_spec.rb#L170) * JSON Array - * [is encoded and decoded to the same Array](./spec/acceptance/realtime/message_spec.rb#L101) + * [is encoded and decoded to the same Array](./spec/acceptance/realtime/message_spec.rb#L178) * nil - * [is encoded and decoded to the same Array](./spec/acceptance/realtime/message_spec.rb#L107) + * [is encoded and decoded to the same Array](./spec/acceptance/realtime/message_spec.rb#L184) * with unsupported data payload content type * Integer - * [is raises an UnsupportedDataType 40013 exception](./spec/acceptance/realtime/message_spec.rb#L118) + * [is raises an UnsupportedDataType 40013 exception](./spec/acceptance/realtime/message_spec.rb#L195) * Float - * [is raises an UnsupportedDataType 40013 exception](./spec/acceptance/realtime/message_spec.rb#L127) + * [is raises an UnsupportedDataType 40013 exception](./spec/acceptance/realtime/message_spec.rb#L204) * Boolean - * [is raises an UnsupportedDataType 40013 exception](./spec/acceptance/realtime/message_spec.rb#L136) + * [is raises an UnsupportedDataType 40013 exception](./spec/acceptance/realtime/message_spec.rb#L213) * False - * [is raises an UnsupportedDataType 40013 exception](./spec/acceptance/realtime/message_spec.rb#L145) + * [is raises an UnsupportedDataType 40013 exception](./spec/acceptance/realtime/message_spec.rb#L222) * with ASCII_8BIT message name - * [is converted into UTF_8](./spec/acceptance/realtime/message_spec.rb#L154) + * [is converted into UTF_8](./spec/acceptance/realtime/message_spec.rb#L231) * when the message publisher has a client_id - * [contains a #client_id attribute](./spec/acceptance/realtime/message_spec.rb#L170) + * [contains a #client_id attribute](./spec/acceptance/realtime/message_spec.rb#L247) * #connection_id attribute * over realtime - * [matches the sender connection#id](./spec/acceptance/realtime/message_spec.rb#L183) + * [matches the sender connection#id](./spec/acceptance/realtime/message_spec.rb#L260) * when retrieved over REST - * [matches the sender connection#id](./spec/acceptance/realtime/message_spec.rb#L195) + * [matches the sender connection#id](./spec/acceptance/realtime/message_spec.rb#L272) * local echo when published - * [is enabled by default](./spec/acceptance/realtime/message_spec.rb#L207) + * [is enabled by default](./spec/acceptance/realtime/message_spec.rb#L284) * with :echo_messages option set to false - * [will not echo messages to the client but will still broadcast messages to other connected clients](./spec/acceptance/realtime/message_spec.rb#L227) - * [will not echo messages to the client from other REST clients publishing using that connection_key](./spec/acceptance/realtime/message_spec.rb#L246) - * [will echo messages with a valid connection_id to the client from other REST clients publishing using that connection_key](./spec/acceptance/realtime/message_spec.rb#L259) + * [will not echo messages to the client but will still broadcast messages to other connected clients](./spec/acceptance/realtime/message_spec.rb#L304) + * [will not echo messages to the client from other REST clients publishing using that connection_key](./spec/acceptance/realtime/message_spec.rb#L322) + * [will echo messages with a valid connection_id to the client from other REST clients publishing using that connection_key](./spec/acceptance/realtime/message_spec.rb#L335) * publishing lots of messages across two connections - * [sends and receives the messages on both opened connections and calls the success callbacks for each message published](./spec/acceptance/realtime/message_spec.rb#L285) + * [sends and receives the messages on both opened connections and calls the success callbacks for each message published](./spec/acceptance/realtime/message_spec.rb#L361) * without suitable publishing permissions - * [calls the error callback](./spec/acceptance/realtime/message_spec.rb#L330) - * server incorrectly resends a message that was already received by the client library - * [discards the message and logs it as an error to the channel](./spec/acceptance/realtime/message_spec.rb#L349) + * [calls the error callback](./spec/acceptance/realtime/message_spec.rb#L406) * encoding and decoding encrypted messages * with AES-128-CBC using crypto-data-128.json fixtures (#RTL7d) * item 0 with encrypted encoding utf-8/cipher+aes-128-cbc/base64 * behaves like an Ably encrypter and decrypter * with #publish and #subscribe - * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L416) - * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L436) + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) * item 1 with encrypted encoding cipher+aes-128-cbc/base64 * behaves like an Ably encrypter and decrypter * with #publish and #subscribe - * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L416) - * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L436) + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) * item 2 with encrypted encoding json/utf-8/cipher+aes-128-cbc/base64 * behaves like an Ably encrypter and decrypter * with #publish and #subscribe - * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L416) - * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L436) + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) * item 3 with encrypted encoding json/utf-8/cipher+aes-128-cbc/base64 * behaves like an Ably encrypter and decrypter * with #publish and #subscribe - * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L416) - * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L436) + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) * with AES-256-CBC using crypto-data-256.json fixtures (#RTL7d) * item 0 with encrypted encoding utf-8/cipher+aes-256-cbc/base64 * behaves like an Ably encrypter and decrypter * with #publish and #subscribe - * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L416) - * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L436) + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) * item 1 with encrypted encoding cipher+aes-256-cbc/base64 * behaves like an Ably encrypter and decrypter * with #publish and #subscribe - * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L416) - * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L436) + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) * item 2 with encrypted encoding json/utf-8/cipher+aes-256-cbc/base64 * behaves like an Ably encrypter and decrypter * with #publish and #subscribe - * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L416) - * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L436) + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) * item 3 with encrypted encoding json/utf-8/cipher+aes-256-cbc/base64 * behaves like an Ably encrypter and decrypter * with #publish and #subscribe - * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L416) - * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L436) + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 4 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 5 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 6 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 7 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 8 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 9 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 10 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 11 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 12 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 13 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 14 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 15 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 16 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 17 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 18 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 19 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 20 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 21 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 22 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 23 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 24 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 25 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 26 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 27 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 28 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 29 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 30 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 31 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 32 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 33 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 34 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 35 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 36 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 37 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 38 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 39 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 40 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 41 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 42 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 43 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 44 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 45 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 46 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 47 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 48 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 49 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 50 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 51 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 52 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 53 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 54 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 55 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 56 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 57 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 58 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 59 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 60 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 61 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 62 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 63 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 64 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 65 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 66 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 67 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 68 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 69 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 70 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 71 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 72 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) + * item 73 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * with #publish and #subscribe + * [encrypts message automatically before they are pushed to the server (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L457) + * [sends and receives messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/realtime/message_spec.rb#L477) * with multiple sends from one client to another - * [encrypts and decrypts all messages](./spec/acceptance/realtime/message_spec.rb#L475) - * [receives raw messages with the correct encoding](./spec/acceptance/realtime/message_spec.rb#L492) + * [encrypts and decrypts all messages](./spec/acceptance/realtime/message_spec.rb#L516) + * [receives raw messages with the correct encoding](./spec/acceptance/realtime/message_spec.rb#L533) * subscribing with a different transport protocol - * [delivers a String ASCII-8BIT payload to the receiver](./spec/acceptance/realtime/message_spec.rb#L526) - * [delivers a String UTF-8 payload to the receiver](./spec/acceptance/realtime/message_spec.rb#L526) - * [delivers a Hash payload to the receiver](./spec/acceptance/realtime/message_spec.rb#L526) + * [delivers a String ASCII-8BIT payload to the receiver](./spec/acceptance/realtime/message_spec.rb#L567) + * [delivers a String UTF-8 payload to the receiver](./spec/acceptance/realtime/message_spec.rb#L567) + * [delivers a Hash payload to the receiver](./spec/acceptance/realtime/message_spec.rb#L567) * publishing on an unencrypted channel and subscribing on an encrypted channel with another client - * [does not attempt to decrypt the message](./spec/acceptance/realtime/message_spec.rb#L547) + * [does not attempt to decrypt the message](./spec/acceptance/realtime/message_spec.rb#L588) * publishing on an encrypted channel and subscribing on an unencrypted channel with another client - * [delivers the message but still encrypted with a value in the #encoding attribute (#RTL7e)](./spec/acceptance/realtime/message_spec.rb#L565) - * [logs a Cipher error (#RTL7e)](./spec/acceptance/realtime/message_spec.rb#L576) + * [delivers the message but still encrypted with a value in the #encoding attribute (#RTL7e)](./spec/acceptance/realtime/message_spec.rb#L608) + * [logs a Cipher error (#RTL7e)](./spec/acceptance/realtime/message_spec.rb#L619) * publishing on an encrypted channel and subscribing with a different algorithm on another client - * [delivers the message but still encrypted with the cipher detials in the #encoding attribute (#RTL7e)](./spec/acceptance/realtime/message_spec.rb#L596) - * [emits a Cipher error on the channel (#RTL7e)](./spec/acceptance/realtime/message_spec.rb#L605) + * [delivers the message but still encrypted with the cipher detials in the #encoding attribute (#RTL7e)](./spec/acceptance/realtime/message_spec.rb#L639) + * [emits a Cipher error on the channel (#RTL7e)](./spec/acceptance/realtime/message_spec.rb#L650) * publishing on an encrypted channel and subscribing with a different key on another client - * [delivers the message but still encrypted with the cipher details in the #encoding attribute](./spec/acceptance/realtime/message_spec.rb#L625) - * [emits a Cipher error on the channel](./spec/acceptance/realtime/message_spec.rb#L636) + * [delivers the message but still encrypted with the cipher details in the #encoding attribute](./spec/acceptance/realtime/message_spec.rb#L670) + * [emits a Cipher error on the channel](./spec/acceptance/realtime/message_spec.rb#L681) * when message is published, the connection disconnects before the ACK is received, and the connection is resumed - * [publishes the message again, later receives the ACK and only one message is ever received from Ably](./spec/acceptance/realtime/message_spec.rb#L655) + * [publishes the message again, later receives the ACK and only one message is ever received from Ably](./spec/acceptance/realtime/message_spec.rb#L700) * when message is published, the connection disconnects before the ACK is received * the connection is not resumed - * [calls the errback for all messages](./spec/acceptance/realtime/message_spec.rb#L697) + * [calls the errback for all messages](./spec/acceptance/realtime/message_spec.rb#L745) * the connection becomes suspended - * [calls the errback for all messages](./spec/acceptance/realtime/message_spec.rb#L723) + * [calls the errback for all messages](./spec/acceptance/realtime/message_spec.rb#L771) * the connection becomes failed - * [calls the errback for all messages](./spec/acceptance/realtime/message_spec.rb#L750) + * [calls the errback for all messages](./spec/acceptance/realtime/message_spec.rb#L798) * message encoding interoperability * over a JSON transport * when decoding string - * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L791) + * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L839) * when encoding string - * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L809) + * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L857) * when decoding string - * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L791) + * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L839) * when encoding string - * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L809) + * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L857) * when decoding jsonObject - * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L791) + * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L839) * when encoding jsonObject - * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L809) + * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L857) * when decoding jsonArray - * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L791) + * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L839) * when encoding jsonArray - * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L809) + * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L857) * when decoding binary - * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L791) + * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L839) * when encoding binary - * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L809) + * [ensures that client libraries have compatible encoding and decoding using common fixtures](./spec/acceptance/realtime/message_spec.rb#L857) * over a MsgPack transport * when publishing a string using JSON protocol - * [receives the message over MsgPack and the data matches](./spec/acceptance/realtime/message_spec.rb#L843) + * [receives the message over MsgPack and the data matches](./spec/acceptance/realtime/message_spec.rb#L891) * when retrieving a string using JSON protocol - * [is compatible with a publishes using MsgPack](./spec/acceptance/realtime/message_spec.rb#L871) + * [is compatible with a publishes using MsgPack](./spec/acceptance/realtime/message_spec.rb#L919) * when publishing a string using JSON protocol - * [receives the message over MsgPack and the data matches](./spec/acceptance/realtime/message_spec.rb#L843) + * [receives the message over MsgPack and the data matches](./spec/acceptance/realtime/message_spec.rb#L891) * when retrieving a string using JSON protocol - * [is compatible with a publishes using MsgPack](./spec/acceptance/realtime/message_spec.rb#L871) + * [is compatible with a publishes using MsgPack](./spec/acceptance/realtime/message_spec.rb#L919) * when publishing a jsonObject using JSON protocol - * [receives the message over MsgPack and the data matches](./spec/acceptance/realtime/message_spec.rb#L843) + * [receives the message over MsgPack and the data matches](./spec/acceptance/realtime/message_spec.rb#L891) * when retrieving a jsonObject using JSON protocol - * [is compatible with a publishes using MsgPack](./spec/acceptance/realtime/message_spec.rb#L871) + * [is compatible with a publishes using MsgPack](./spec/acceptance/realtime/message_spec.rb#L919) * when publishing a jsonArray using JSON protocol - * [receives the message over MsgPack and the data matches](./spec/acceptance/realtime/message_spec.rb#L843) + * [receives the message over MsgPack and the data matches](./spec/acceptance/realtime/message_spec.rb#L891) * when retrieving a jsonArray using JSON protocol - * [is compatible with a publishes using MsgPack](./spec/acceptance/realtime/message_spec.rb#L871) + * [is compatible with a publishes using MsgPack](./spec/acceptance/realtime/message_spec.rb#L919) * when publishing a binary using JSON protocol - * [receives the message over MsgPack and the data matches](./spec/acceptance/realtime/message_spec.rb#L843) + * [receives the message over MsgPack and the data matches](./spec/acceptance/realtime/message_spec.rb#L891) * when retrieving a binary using JSON protocol - * [is compatible with a publishes using MsgPack](./spec/acceptance/realtime/message_spec.rb#L871) + * [is compatible with a publishes using MsgPack](./spec/acceptance/realtime/message_spec.rb#L919) ### Ably::Realtime::Presence history _(see [spec/acceptance/realtime/presence_history_spec.rb](./spec/acceptance/realtime/presence_history_spec.rb))_ * using JSON protocol * [provides up to the moment presence history](./spec/acceptance/realtime/presence_history_spec.rb#L21) - * [ensures REST presence history message IDs match ProtocolMessage wrapped message and connection IDs via Realtime](./spec/acceptance/realtime/presence_history_spec.rb#L42) + * [ensures REST presence history message IDs match ProtocolMessage wrapped message and connection IDs via Realtime](./spec/acceptance/realtime/presence_history_spec.rb#L44) ### Ably::Realtime::Presence _(see [spec/acceptance/realtime/presence_spec.rb](./spec/acceptance/realtime/presence_spec.rb))_ * using JSON protocol * when attached (but not present) on a presence channel with an anonymous client (no client ID) * [maintains state as other clients enter and leave the channel (#RTP2e)](./spec/acceptance/realtime/presence_spec.rb#L479) * #sync_complete? and SYNC flags (#RTP1) * when attaching to a channel without any members present - * [sync_complete? is true, there is no presence flag, and the presence channel is considered synced immediately (#RTP1)](./spec/acceptance/realtime/presence_spec.rb#L708) + * [sync_complete? is true, no members are received and the presence channel is synced (#RTP1)](./spec/acceptance/realtime/presence_spec.rb#L707) * when attaching to a channel with members present - * [sync_complete? is false, there is a presence flag, and the presence channel is subsequently synced (#RTP1)](./spec/acceptance/realtime/presence_spec.rb#L729) + * [sync_complete? is false, there is a presence flag, and the presence channel is subsequently synced (#RTP1)](./spec/acceptance/realtime/presence_spec.rb#L736) * 101 existing (present) members on a channel (2 SYNC pages) * requiring at least 2 SYNC ProtocolMessages * when a client attaches to the presence channel - * [emits :present for each member](./spec/acceptance/realtime/presence_spec.rb#L781) + * [emits :present for each member](./spec/acceptance/realtime/presence_spec.rb#L788) * and a member enters before the SYNC operation is complete - * [emits a :enter immediately and the member is :present once the sync is complete (#RTP2g)](./spec/acceptance/realtime/presence_spec.rb#L797) + * [emits a :enter immediately and the member is :present once the sync is complete (#RTP2g)](./spec/acceptance/realtime/presence_spec.rb#L804) * and a member leaves before the SYNC operation is complete - * [emits :leave immediately as the member leaves and cleans up the ABSENT member after (#RTP2f, #RTP2g)](./spec/acceptance/realtime/presence_spec.rb#L834) - * [ignores presence events with timestamps / identifiers prior to the current :present event in the MembersMap (#RTP2c)](./spec/acceptance/realtime/presence_spec.rb#L882) - * [does not emit :present after the :leave event has been emitted, and that member is not included in the list of members via #get (#RTP2f)](./spec/acceptance/realtime/presence_spec.rb#L927) + * [emits :leave immediately as the member leaves and cleans up the ABSENT member after (#RTP2f, #RTP2g)](./spec/acceptance/realtime/presence_spec.rb#L841) + * [ignores presence events with timestamps / identifiers prior to the current :present event in the MembersMap (#RTP2c)](./spec/acceptance/realtime/presence_spec.rb#L889) + * [does not emit :present after the :leave event has been emitted, and that member is not included in the list of members via #get (#RTP2f)](./spec/acceptance/realtime/presence_spec.rb#L934) * #get * by default - * [waits until sync is complete (#RTP11c1)](./spec/acceptance/realtime/presence_spec.rb#L977) + * [waits until sync is complete (#RTP11c1)](./spec/acceptance/realtime/presence_spec.rb#L984) * with :wait_for_sync option set to false (#RTP11c1) - * [it does not wait for sync](./spec/acceptance/realtime/presence_spec.rb#L998) + * [it does not wait for sync](./spec/acceptance/realtime/presence_spec.rb#L1005) * state * once opened - * [once opened, enters the :left state if the channel detaches](./spec/acceptance/realtime/presence_spec.rb#L1025) + * [once opened, enters the :left state if the channel detaches](./spec/acceptance/realtime/presence_spec.rb#L1032) * #enter * data attribute * when provided as argument option to #enter - * [changes to value provided in #leave](./spec/acceptance/realtime/presence_spec.rb#L1050) + * [changes to value provided in #leave](./spec/acceptance/realtime/presence_spec.rb#L1057) * message #connection_id - * [matches the current client connection_id](./spec/acceptance/realtime/presence_spec.rb#L1074) + * [matches the current client connection_id](./spec/acceptance/realtime/presence_spec.rb#L1081) * without necessary capabilities to join presence - * [calls the Deferrable errback on capabilities failure](./spec/acceptance/realtime/presence_spec.rb#L1093) + * [calls the Deferrable errback on capabilities failure](./spec/acceptance/realtime/presence_spec.rb#L1100) * it should behave like a public presence method - * [raise an exception if the channel is detached](./spec/acceptance/realtime/presence_spec.rb#L63) - * [raise an exception if the channel becomes detached](./spec/acceptance/realtime/presence_spec.rb#L81) - * [raise an exception if the channel is failed](./spec/acceptance/realtime/presence_spec.rb#L97) - * [raise an exception if the channel becomes failed](./spec/acceptance/realtime/presence_spec.rb#L114) + * [presence enter : raise an exception if the channel is detached](./spec/acceptance/realtime/presence_spec.rb#L63) + * [presence enter : raise an exception if the channel becomes detached](./spec/acceptance/realtime/presence_spec.rb#L81) + * [presence enter : raise an exception if the channel is failed](./spec/acceptance/realtime/presence_spec.rb#L97) + * [presence enter : raise an exception if the channel becomes failed](./spec/acceptance/realtime/presence_spec.rb#L114) * [implicitly attaches the channel](./spec/acceptance/realtime/presence_spec.rb#L130) * [returns a SafeDeferrable that catches exceptions in callbacks and logs them](./spec/acceptance/realtime/presence_spec.rb#L293) * [allows a block to be passed in that is executed upon success](./spec/acceptance/realtime/presence_spec.rb#L300) * [calls the Deferrable callback on success](./spec/acceptance/realtime/presence_spec.rb#L308) * [catches exceptions in the provided method block and logs them to the logger](./spec/acceptance/realtime/presence_spec.rb#L318) @@ -1185,20 +1611,20 @@ * False * [raises an UnsupportedDataType 40013 exception](./spec/acceptance/realtime/presence_spec.rb#L286) * if connection fails before success * [calls the Deferrable errback if channel is detached](./spec/acceptance/realtime/presence_spec.rb#L331) * #update - * [without previous #enter automatically enters](./spec/acceptance/realtime/presence_spec.rb#L1105) - * [updates the data if :data argument provided](./spec/acceptance/realtime/presence_spec.rb#L1130) - * [updates the data to nil if :data argument is not provided (assumes nil value)](./spec/acceptance/realtime/presence_spec.rb#L1142) + * [without previous #enter automatically enters](./spec/acceptance/realtime/presence_spec.rb#L1112) + * [updates the data if :data argument provided](./spec/acceptance/realtime/presence_spec.rb#L1137) + * [updates the data to nil if :data argument is not provided (assumes nil value)](./spec/acceptance/realtime/presence_spec.rb#L1149) * when ENTERED - * [has no effect on the state](./spec/acceptance/realtime/presence_spec.rb#L1115) + * [has no effect on the state](./spec/acceptance/realtime/presence_spec.rb#L1122) * it should behave like a public presence method - * [raise an exception if the channel is detached](./spec/acceptance/realtime/presence_spec.rb#L63) - * [raise an exception if the channel becomes detached](./spec/acceptance/realtime/presence_spec.rb#L81) - * [raise an exception if the channel is failed](./spec/acceptance/realtime/presence_spec.rb#L97) - * [raise an exception if the channel becomes failed](./spec/acceptance/realtime/presence_spec.rb#L114) + * [presence update : raise an exception if the channel is detached](./spec/acceptance/realtime/presence_spec.rb#L63) + * [presence update : raise an exception if the channel becomes detached](./spec/acceptance/realtime/presence_spec.rb#L81) + * [presence update : raise an exception if the channel is failed](./spec/acceptance/realtime/presence_spec.rb#L97) + * [presence update : raise an exception if the channel becomes failed](./spec/acceptance/realtime/presence_spec.rb#L114) * [implicitly attaches the channel](./spec/acceptance/realtime/presence_spec.rb#L130) * [returns a SafeDeferrable that catches exceptions in callbacks and logs them](./spec/acceptance/realtime/presence_spec.rb#L293) * [allows a block to be passed in that is executed upon success](./spec/acceptance/realtime/presence_spec.rb#L300) * [calls the Deferrable callback on success](./spec/acceptance/realtime/presence_spec.rb#L308) * [catches exceptions in the provided method block and logs them to the logger](./spec/acceptance/realtime/presence_spec.rb#L318) @@ -1230,20 +1656,20 @@ * False * [raises an UnsupportedDataType 40013 exception](./spec/acceptance/realtime/presence_spec.rb#L286) * if connection fails before success * [calls the Deferrable errback if channel is detached](./spec/acceptance/realtime/presence_spec.rb#L331) * #leave - * [succeeds and does not emit an event (#RTP10d)](./spec/acceptance/realtime/presence_spec.rb#L1236) + * [succeeds and does not emit an event (#RTP10d)](./spec/acceptance/realtime/presence_spec.rb#L1244) * :data option * when set to a string - * [emits the new data for the leave event](./spec/acceptance/realtime/presence_spec.rb#L1163) + * [emits the new data for the leave event](./spec/acceptance/realtime/presence_spec.rb#L1170) * when set to nil - * [emits the last value for the data attribute when leaving](./spec/acceptance/realtime/presence_spec.rb#L1178) + * [emits the last value for the data attribute when leaving](./spec/acceptance/realtime/presence_spec.rb#L1185) * when not passed as an argument (i.e. nil) - * [emits the previous value for the data attribute when leaving](./spec/acceptance/realtime/presence_spec.rb#L1193) + * [emits the previous value for the data attribute when leaving](./spec/acceptance/realtime/presence_spec.rb#L1200) * and sync is complete - * [does not cache members that have left](./spec/acceptance/realtime/presence_spec.rb#L1208) + * [does not cache members that have left](./spec/acceptance/realtime/presence_spec.rb#L1215) * it should behave like a public presence method * [returns a SafeDeferrable that catches exceptions in callbacks and logs them](./spec/acceptance/realtime/presence_spec.rb#L293) * [allows a block to be passed in that is executed upon success](./spec/acceptance/realtime/presence_spec.rb#L300) * [calls the Deferrable callback on success](./spec/acceptance/realtime/presence_spec.rb#L308) * [catches exceptions in the provided method block and logs them to the logger](./spec/acceptance/realtime/presence_spec.rb#L318) @@ -1266,26 +1692,26 @@ * False * [raises an UnsupportedDataType 40013 exception](./spec/acceptance/realtime/presence_spec.rb#L286) * if connection fails before success * [calls the Deferrable errback if channel is detached](./spec/acceptance/realtime/presence_spec.rb#L331) * :left event - * [emits the data defined in enter](./spec/acceptance/realtime/presence_spec.rb#L1254) - * [emits the data defined in update](./spec/acceptance/realtime/presence_spec.rb#L1267) + * [emits the data defined in enter](./spec/acceptance/realtime/presence_spec.rb#L1262) + * [emits the data defined in update](./spec/acceptance/realtime/presence_spec.rb#L1275) * entering/updating/leaving presence state on behalf of another client_id * #enter_client * multiple times on the same channel with different client_ids - * [has no affect on the client's presence state and only enters on behalf of the provided client_id](./spec/acceptance/realtime/presence_spec.rb#L1292) - * [enters a channel and sets the data based on the provided :data option](./spec/acceptance/realtime/presence_spec.rb#L1306) + * [has no affect on the client's presence state and only enters on behalf of the provided client_id](./spec/acceptance/realtime/presence_spec.rb#L1300) + * [enters a channel and sets the data based on the provided :data option](./spec/acceptance/realtime/presence_spec.rb#L1314) * message #connection_id - * [matches the current client connection_id](./spec/acceptance/realtime/presence_spec.rb#L1327) + * [matches the current client connection_id](./spec/acceptance/realtime/presence_spec.rb#L1335) * without necessary capabilities to enter on behalf of another client - * [calls the Deferrable errback on capabilities failure](./spec/acceptance/realtime/presence_spec.rb#L1347) + * [calls the Deferrable errback on capabilities failure](./spec/acceptance/realtime/presence_spec.rb#L1355) * it should behave like a public presence method - * [raise an exception if the channel is detached](./spec/acceptance/realtime/presence_spec.rb#L63) - * [raise an exception if the channel becomes detached](./spec/acceptance/realtime/presence_spec.rb#L81) - * [raise an exception if the channel is failed](./spec/acceptance/realtime/presence_spec.rb#L97) - * [raise an exception if the channel becomes failed](./spec/acceptance/realtime/presence_spec.rb#L114) + * [presence enter_client : raise an exception if the channel is detached](./spec/acceptance/realtime/presence_spec.rb#L63) + * [presence enter_client : raise an exception if the channel becomes detached](./spec/acceptance/realtime/presence_spec.rb#L81) + * [presence enter_client : raise an exception if the channel is failed](./spec/acceptance/realtime/presence_spec.rb#L97) + * [presence enter_client : raise an exception if the channel becomes failed](./spec/acceptance/realtime/presence_spec.rb#L114) * [implicitly attaches the channel](./spec/acceptance/realtime/presence_spec.rb#L130) * [returns a SafeDeferrable that catches exceptions in callbacks and logs them](./spec/acceptance/realtime/presence_spec.rb#L293) * [allows a block to be passed in that is executed upon success](./spec/acceptance/realtime/presence_spec.rb#L300) * [calls the Deferrable callback on success](./spec/acceptance/realtime/presence_spec.rb#L308) * [catches exceptions in the provided method block and logs them to the logger](./spec/acceptance/realtime/presence_spec.rb#L318) @@ -1348,18 +1774,18 @@ * [throws an exception](./spec/acceptance/realtime/presence_spec.rb#L463) * and an empty client_id * [throws an exception](./spec/acceptance/realtime/presence_spec.rb#L470) * #update_client * multiple times on the same channel with different client_ids - * [updates the data attribute for the member when :data option provided](./spec/acceptance/realtime/presence_spec.rb#L1361) - * [updates the data attribute to null for the member when :data option is not provided (assumed null)](./spec/acceptance/realtime/presence_spec.rb#L1387) - * [enters if not already entered](./spec/acceptance/realtime/presence_spec.rb#L1401) + * [updates the data attribute for the member when :data option provided](./spec/acceptance/realtime/presence_spec.rb#L1369) + * [updates the data attribute to null for the member when :data option is not provided (assumed null)](./spec/acceptance/realtime/presence_spec.rb#L1395) + * [enters if not already entered](./spec/acceptance/realtime/presence_spec.rb#L1409) * it should behave like a public presence method - * [raise an exception if the channel is detached](./spec/acceptance/realtime/presence_spec.rb#L63) - * [raise an exception if the channel becomes detached](./spec/acceptance/realtime/presence_spec.rb#L81) - * [raise an exception if the channel is failed](./spec/acceptance/realtime/presence_spec.rb#L97) - * [raise an exception if the channel becomes failed](./spec/acceptance/realtime/presence_spec.rb#L114) + * [presence update_client : raise an exception if the channel is detached](./spec/acceptance/realtime/presence_spec.rb#L63) + * [presence update_client : raise an exception if the channel becomes detached](./spec/acceptance/realtime/presence_spec.rb#L81) + * [presence update_client : raise an exception if the channel is failed](./spec/acceptance/realtime/presence_spec.rb#L97) + * [presence update_client : raise an exception if the channel becomes failed](./spec/acceptance/realtime/presence_spec.rb#L114) * [implicitly attaches the channel](./spec/acceptance/realtime/presence_spec.rb#L130) * [returns a SafeDeferrable that catches exceptions in callbacks and logs them](./spec/acceptance/realtime/presence_spec.rb#L293) * [allows a block to be passed in that is executed upon success](./spec/acceptance/realtime/presence_spec.rb#L300) * [calls the Deferrable callback on success](./spec/acceptance/realtime/presence_spec.rb#L308) * [catches exceptions in the provided method block and logs them to the logger](./spec/acceptance/realtime/presence_spec.rb#L318) @@ -1423,23 +1849,23 @@ * and an empty client_id * [throws an exception](./spec/acceptance/realtime/presence_spec.rb#L470) * #leave_client * leaves a channel * multiple times on the same channel with different client_ids - * [emits the :leave event for each client_id](./spec/acceptance/realtime/presence_spec.rb#L1433) - * [succeeds if that client_id has not previously entered the channel](./spec/acceptance/realtime/presence_spec.rb#L1459) + * [emits the :leave event for each client_id](./spec/acceptance/realtime/presence_spec.rb#L1441) + * [succeeds if that client_id has not previously entered the channel](./spec/acceptance/realtime/presence_spec.rb#L1467) * with a new value in :data option - * [emits the leave event with the new data value](./spec/acceptance/realtime/presence_spec.rb#L1485) + * [emits the leave event with the new data value](./spec/acceptance/realtime/presence_spec.rb#L1493) * with a nil value in :data option - * [emits the leave event with the previous value as a convenience](./spec/acceptance/realtime/presence_spec.rb#L1500) + * [emits the leave event with the previous value as a convenience](./spec/acceptance/realtime/presence_spec.rb#L1508) * with no :data option - * [emits the leave event with the previous value as a convenience](./spec/acceptance/realtime/presence_spec.rb#L1515) + * [emits the leave event with the previous value as a convenience](./spec/acceptance/realtime/presence_spec.rb#L1523) * it should behave like a public presence method - * [raise an exception if the channel is detached](./spec/acceptance/realtime/presence_spec.rb#L63) - * [raise an exception if the channel becomes detached](./spec/acceptance/realtime/presence_spec.rb#L81) - * [raise an exception if the channel is failed](./spec/acceptance/realtime/presence_spec.rb#L97) - * [raise an exception if the channel becomes failed](./spec/acceptance/realtime/presence_spec.rb#L114) + * [presence leave_client : raise an exception if the channel is detached](./spec/acceptance/realtime/presence_spec.rb#L63) + * [presence leave_client : raise an exception if the channel becomes detached](./spec/acceptance/realtime/presence_spec.rb#L81) + * [presence leave_client : raise an exception if the channel is failed](./spec/acceptance/realtime/presence_spec.rb#L97) + * [presence leave_client : raise an exception if the channel becomes failed](./spec/acceptance/realtime/presence_spec.rb#L114) * [implicitly attaches the channel](./spec/acceptance/realtime/presence_spec.rb#L130) * [returns a SafeDeferrable that catches exceptions in callbacks and logs them](./spec/acceptance/realtime/presence_spec.rb#L293) * [allows a block to be passed in that is executed upon success](./spec/acceptance/realtime/presence_spec.rb#L300) * [calls the Deferrable callback on success](./spec/acceptance/realtime/presence_spec.rb#L308) * [catches exceptions in the provided method block and logs them to the logger](./spec/acceptance/realtime/presence_spec.rb#L318) @@ -1501,110 +1927,104 @@ * and a wildcard client_id * [throws an exception](./spec/acceptance/realtime/presence_spec.rb#L463) * and an empty client_id * [throws an exception](./spec/acceptance/realtime/presence_spec.rb#L470) * #get - * [returns a SafeDeferrable that catches exceptions in callbacks and logs them](./spec/acceptance/realtime/presence_spec.rb#L1536) - * [calls the Deferrable callback on success](./spec/acceptance/realtime/presence_spec.rb#L1541) - * [catches exceptions in the provided method block](./spec/acceptance/realtime/presence_spec.rb#L1548) - * [implicitly attaches the channel (#RTP11b)](./spec/acceptance/realtime/presence_spec.rb#L1556) - * [fails if the connection is DETACHED (#RTP11b)](./spec/acceptance/realtime/presence_spec.rb#L1591) - * [fails if the connection is FAILED (#RTP11b)](./spec/acceptance/realtime/presence_spec.rb#L1606) - * [returns the current members on the channel (#RTP11a)](./spec/acceptance/realtime/presence_spec.rb#L1690) - * [filters by connection_id option if provided (#RTP11c3)](./spec/acceptance/realtime/presence_spec.rb#L1707) - * [filters by client_id option if provided (#RTP11c2)](./spec/acceptance/realtime/presence_spec.rb#L1729) - * [does not wait for SYNC to complete if :wait_for_sync option is false (#RTP11c1)](./spec/acceptance/realtime/presence_spec.rb#L1753) - * [returns the list of members and waits for SYNC to complete by default (#RTP11a)](./spec/acceptance/realtime/presence_spec.rb#L1765) + * [returns a SafeDeferrable that catches exceptions in callbacks and logs them](./spec/acceptance/realtime/presence_spec.rb#L1544) + * [calls the Deferrable callback on success](./spec/acceptance/realtime/presence_spec.rb#L1549) + * [catches exceptions in the provided method block](./spec/acceptance/realtime/presence_spec.rb#L1556) + * [implicitly attaches the channel (#RTP11b)](./spec/acceptance/realtime/presence_spec.rb#L1564) + * [fails if the connection is DETACHED (#RTP11b)](./spec/acceptance/realtime/presence_spec.rb#L1599) + * [fails if the connection is FAILED (#RTP11b)](./spec/acceptance/realtime/presence_spec.rb#L1616) + * [returns the current members on the channel (#RTP11a)](./spec/acceptance/realtime/presence_spec.rb#L1700) + * [filters by connection_id option if provided (#RTP11c3)](./spec/acceptance/realtime/presence_spec.rb#L1717) + * [filters by client_id option if provided (#RTP11c2)](./spec/acceptance/realtime/presence_spec.rb#L1739) + * [does not wait for SYNC to complete if :wait_for_sync option is false (#RTP11c1)](./spec/acceptance/realtime/presence_spec.rb#L1763) + * [returns the list of members and waits for SYNC to complete by default (#RTP11a)](./spec/acceptance/realtime/presence_spec.rb#L1775) * when the channel is SUSPENDED * with wait_for_sync: true - * [results in an error with @code@ @91005@ and a @message@ stating that the presence state is out of sync (#RTP11d)](./spec/acceptance/realtime/presence_spec.rb#L1566) + * [results in an error with @code@ @91005@ and a @message@ stating that the presence state is out of sync (#RTP11d)](./spec/acceptance/realtime/presence_spec.rb#L1574) * with wait_for_sync: false - * [returns the current PresenceMap and does not wait for the channel to change to the ATTACHED state (#RTP11d)](./spec/acceptance/realtime/presence_spec.rb#L1579) + * [returns the current PresenceMap and does not wait for the channel to change to the ATTACHED state (#RTP11d)](./spec/acceptance/realtime/presence_spec.rb#L1587) * during a sync * when :wait_for_sync is true - * [fails if the connection becomes FAILED (#RTP11b)](./spec/acceptance/realtime/presence_spec.rb#L1643) - * [fails if the channel becomes detached (#RTP11b)](./spec/acceptance/realtime/presence_spec.rb#L1666) + * [fails if the connection becomes FAILED (#RTP11b)](./spec/acceptance/realtime/presence_spec.rb#L1653) + * [fails if the channel becomes detached (#RTP11b)](./spec/acceptance/realtime/presence_spec.rb#L1676) * when a member enters and then leaves - * [has no members](./spec/acceptance/realtime/presence_spec.rb#L1778) + * [has no members](./spec/acceptance/realtime/presence_spec.rb#L1788) * when a member enters and the presence map is updated - * [adds the member as being :present (#RTP2d)](./spec/acceptance/realtime/presence_spec.rb#L1793) + * [adds the member as being :present (#RTP2d)](./spec/acceptance/realtime/presence_spec.rb#L1803) * with lots of members on different clients - * [returns a complete list of members on all clients](./spec/acceptance/realtime/presence_spec.rb#L1814) + * [returns a complete list of members on all clients](./spec/acceptance/realtime/presence_spec.rb#L1824) * #subscribe - * [implicitly attaches](./spec/acceptance/realtime/presence_spec.rb#L1889) + * [implicitly attaches](./spec/acceptance/realtime/presence_spec.rb#L1901) * with no arguments - * [calls the callback for all presence events](./spec/acceptance/realtime/presence_spec.rb#L1850) + * [calls the callback for all presence events](./spec/acceptance/realtime/presence_spec.rb#L1862) * with event name - * [calls the callback for specified presence event](./spec/acceptance/realtime/presence_spec.rb#L1870) + * [calls the callback for specified presence event](./spec/acceptance/realtime/presence_spec.rb#L1882) * with a callback that raises an exception - * [logs the error and continues](./spec/acceptance/realtime/presence_spec.rb#L1902) + * [logs the error and continues](./spec/acceptance/realtime/presence_spec.rb#L1914) * #unsubscribe * with no arguments - * [removes the callback for all presence events](./spec/acceptance/realtime/presence_spec.rb#L1923) + * [removes the callback for all presence events](./spec/acceptance/realtime/presence_spec.rb#L1935) * with event name - * [removes the callback for specified presence event](./spec/acceptance/realtime/presence_spec.rb#L1941) + * [removes the callback for specified presence event](./spec/acceptance/realtime/presence_spec.rb#L1953) * REST #get - * [returns current members](./spec/acceptance/realtime/presence_spec.rb#L1960) - * [returns no members once left](./spec/acceptance/realtime/presence_spec.rb#L1976) + * [returns current members](./spec/acceptance/realtime/presence_spec.rb#L1972) + * [returns no members once left](./spec/acceptance/realtime/presence_spec.rb#L1988) * client_id with ASCII_8BIT * in connection set up - * [is converted into UTF_8](./spec/acceptance/realtime/presence_spec.rb#L1996) + * [is converted into UTF_8](./spec/acceptance/realtime/presence_spec.rb#L2008) * in channel options - * [is converted into UTF_8](./spec/acceptance/realtime/presence_spec.rb#L2009) + * [is converted into UTF_8](./spec/acceptance/realtime/presence_spec.rb#L2021) * encoding and decoding of presence message data - * [encrypts presence message data](./spec/acceptance/realtime/presence_spec.rb#L2035) + * [encrypts presence message data](./spec/acceptance/realtime/presence_spec.rb#L2047) * #subscribe - * [emits decrypted enter events](./spec/acceptance/realtime/presence_spec.rb#L2054) - * [emits decrypted update events](./spec/acceptance/realtime/presence_spec.rb#L2066) - * [emits previously set data for leave events](./spec/acceptance/realtime/presence_spec.rb#L2080) + * [emits decrypted enter events](./spec/acceptance/realtime/presence_spec.rb#L2066) + * [emits decrypted update events](./spec/acceptance/realtime/presence_spec.rb#L2078) + * [emits previously set data for leave events](./spec/acceptance/realtime/presence_spec.rb#L2092) * #get - * [returns a list of members with decrypted data](./spec/acceptance/realtime/presence_spec.rb#L2096) + * [returns a list of members with decrypted data](./spec/acceptance/realtime/presence_spec.rb#L2108) * REST #get - * [returns a list of members with decrypted data](./spec/acceptance/realtime/presence_spec.rb#L2110) + * [returns a list of members with decrypted data](./spec/acceptance/realtime/presence_spec.rb#L2122) * when cipher settings do not match publisher - * [delivers an unencoded presence message left with encoding value](./spec/acceptance/realtime/presence_spec.rb#L2126) - * [emits an error when cipher does not match and presence data cannot be decoded](./spec/acceptance/realtime/presence_spec.rb#L2139) + * [delivers an unencoded presence message left with encoding value](./spec/acceptance/realtime/presence_spec.rb#L2138) + * [emits an error when cipher does not match and presence data cannot be decoded](./spec/acceptance/realtime/presence_spec.rb#L2151) * leaving - * [expect :left event once underlying connection is closed](./spec/acceptance/realtime/presence_spec.rb#L2155) - * [expect :left event with client data from enter event](./spec/acceptance/realtime/presence_spec.rb#L2165) + * [expect :left event once underlying connection is closed](./spec/acceptance/realtime/presence_spec.rb#L2169) + * [expect :left event with client data from enter event](./spec/acceptance/realtime/presence_spec.rb#L2179) * connection failure mid-way through a large member sync - * [resumes the SYNC operation (#RTP3)](./spec/acceptance/realtime/presence_spec.rb#L2184) + * [resumes the SYNC operation (#RTP3)](./spec/acceptance/realtime/presence_spec.rb#L2198) * server-initiated sync * with multiple SYNC pages - * [is initiated with a SYNC message and completed with a later SYNC message with no cursor value part of the channelSerial (#RTP18a, #RTP18b) ](./spec/acceptance/realtime/presence_spec.rb#L2222) + * [is initiated with a SYNC message and completed with a later SYNC message with no cursor value part of the channelSerial (#RTP18a, #RTP18b) ](./spec/acceptance/realtime/presence_spec.rb#L2236) * with a single SYNC page - * [is initiated and completed with a single SYNC message (and no channelSerial) (#RTP18a, #RTP18c) ](./spec/acceptance/realtime/presence_spec.rb#L2273) + * [is initiated and completed with a single SYNC message (and no channelSerial) (#RTP18a, #RTP18c) ](./spec/acceptance/realtime/presence_spec.rb#L2285) * when members exist in the PresenceMap before a SYNC completes - * [removes the members that are no longer present (#RTP19)](./spec/acceptance/realtime/presence_spec.rb#L2321) + * [removes the members that are no longer present (#RTP19)](./spec/acceptance/realtime/presence_spec.rb#L2332) * when the client does not have presence subscribe privileges but is present on the channel - * [receives presence updates for all presence events generated by the current connection and the presence map is kept up to date (#RTP17a)](./spec/acceptance/realtime/presence_spec.rb#L2379) + * [receives presence updates for all presence events generated by the current connection and the presence map is kept up to date (#RTP17a)](./spec/acceptance/realtime/presence_spec.rb#L2389) * local PresenceMap for presence members entered by this client - * [maintains a copy of the member map for any member that shares this connection's connection ID (#RTP17)](./spec/acceptance/realtime/presence_spec.rb#L2427) + * [maintains a copy of the member map for any member that shares this connection's connection ID (#RTP17)](./spec/acceptance/realtime/presence_spec.rb#L2437) * #RTP17b - * [updates presence members on leave](./spec/acceptance/realtime/presence_spec.rb#L2455) - * [does no update presence members on fabricated leave](./spec/acceptance/realtime/presence_spec.rb#L2480) + * [updates presence members on leave](./spec/acceptance/realtime/presence_spec.rb#L2465) + * [does no update presence members on fabricated leave](./spec/acceptance/realtime/presence_spec.rb#L2490) * when a channel becomes attached again - * and the resume flag is true - * and the presence flag is false - * [does not send any presence events as the PresenceMap is in sync (#RTP5c1)](./spec/acceptance/realtime/presence_spec.rb#L2527) - * and the presence flag is true - * and following the SYNC all local MemberMap members are present in the PresenceMap - * [does nothing as MemberMap is in sync (#RTP5c2)](./spec/acceptance/realtime/presence_spec.rb#L2557) - * and following the SYNC a local MemberMap member is not present in the PresenceMap - * [re-enters the missing members automatically (#RTP5c2)](./spec/acceptance/realtime/presence_spec.rb#L2596) * and the resume flag is false * and the presence flag is false - * [immediately resends all local presence members (#RTP5c2, #RTP19a)](./spec/acceptance/realtime/presence_spec.rb#L2679) + * [immediately resends all local presence members (#RTP5c2, #RTP19a)](./spec/acceptance/realtime/presence_spec.rb#L2539) * when re-entering a client automatically, if the re-enter fails for any reason - * [should emit an ErrorInfo with error code 91004 (#RTP5c3)](./spec/acceptance/realtime/presence_spec.rb#L2730) - * channel state side effects + * [should emit an ErrorInfo with error code 91004 (#RTP5c3)](./spec/acceptance/realtime/presence_spec.rb#L2614) + * channel state side effects (RTP5) + * channel transitions to the ATTACHED state (RTP5b) + * [all queued presence messages are sent](./spec/acceptance/realtime/presence_spec.rb#L2668) * channel transitions to the FAILED state - * [clears the PresenceMap and local member map copy and does not emit any presence events (#RTP5a)](./spec/acceptance/realtime/presence_spec.rb#L2787) + * [clears the PresenceMap and local member map copy and does not emit any presence events (#RTP5a)](./spec/acceptance/realtime/presence_spec.rb#L2688) * channel transitions to the DETACHED state - * [clears the PresenceMap and local member map copy and does not emit any presence events (#RTP5a)](./spec/acceptance/realtime/presence_spec.rb#L2814) + * [clears the PresenceMap and local member map copy and does not emit any presence events (#RTP5a)](./spec/acceptance/realtime/presence_spec.rb#L2715) * channel transitions to the SUSPENDED state - * [maintains the PresenceMap and only publishes presence event changes since the last attached state (#RTP5f)](./spec/acceptance/realtime/presence_spec.rb#L2850) + * [maintains the PresenceMap and only publishes presence event changes since the last attached state (#RTP5f)](./spec/acceptance/realtime/presence_spec.rb#L2753) ### Ably::Realtime::Push::Admin _(see [spec/acceptance/realtime/push_admin_spec.rb](./spec/acceptance/realtime/push_admin_spec.rb))_ * using JSON protocol * #publish @@ -1661,18 +2081,10 @@ * [device_id and client_id filters in the same request are not supported](./spec/acceptance/realtime/push_admin_spec.rb#L669) * #remove * [removes match for Hash object by channel and client_id](./spec/acceptance/realtime/push_admin_spec.rb#L697) * [succeeds even if there is no match](./spec/acceptance/realtime/push_admin_spec.rb#L709) -### Ably::Realtime::Push -_(see [spec/acceptance/realtime/push_spec.rb](./spec/acceptance/realtime/push_spec.rb))_ - * using JSON protocol - * #activate - * [raises an unsupported exception](./spec/acceptance/realtime/push_spec.rb#L14) - * #deactivate - * [raises an unsupported exception](./spec/acceptance/realtime/push_spec.rb#L21) - ### Ably::Realtime::Client#stats _(see [spec/acceptance/realtime/stats_spec.rb](./spec/acceptance/realtime/stats_spec.rb))_ * using JSON protocol * fetching stats * [returns a PaginatedResult](./spec/acceptance/realtime/stats_spec.rb#L10) @@ -1856,43 +2268,46 @@ * and the token expires * [should indicate an error and not retry the request (#RSA4a)](./spec/acceptance/rest/auth_spec.rb#L1113) * when token expires * [automatically renews the token (#RSA4b)](./spec/acceptance/rest/auth_spec.rb#L1143) * [fails if the token renewal fails (#RSA4b)](./spec/acceptance/rest/auth_spec.rb#L1153) + * when token does not expire + * for the next 2 hours + * [should not request for the new token (#RSA4b1)](./spec/acceptance/rest/auth_spec.rb#L1177) * when :client_id is provided in a token - * [#client_id contains the client_id](./spec/acceptance/rest/auth_spec.rb#L1177) + * [#client_id contains the client_id](./spec/acceptance/rest/auth_spec.rb#L1195) * #client_id_validated? * when using basic auth - * [is false as basic auth users do not have an identity](./spec/acceptance/rest/auth_spec.rb#L1189) + * [is false as basic auth users do not have an identity](./spec/acceptance/rest/auth_spec.rb#L1207) * when using a token auth string for a token with a client_id - * [is false as identification is not possible from an opaque token string](./spec/acceptance/rest/auth_spec.rb#L1197) + * [is false as identification is not possible from an opaque token string](./spec/acceptance/rest/auth_spec.rb#L1215) * when using a token * with a client_id - * [is true](./spec/acceptance/rest/auth_spec.rb#L1206) + * [is true](./spec/acceptance/rest/auth_spec.rb#L1224) * with no client_id (anonymous) - * [is true](./spec/acceptance/rest/auth_spec.rb#L1214) + * [is true](./spec/acceptance/rest/auth_spec.rb#L1232) * with a wildcard client_id (anonymous) - * [is false](./spec/acceptance/rest/auth_spec.rb#L1222) + * [is false](./spec/acceptance/rest/auth_spec.rb#L1240) * when using a token request with a client_id - * [is not true as identification is not confirmed until authenticated](./spec/acceptance/rest/auth_spec.rb#L1231) + * [is not true as identification is not confirmed until authenticated](./spec/acceptance/rest/auth_spec.rb#L1249) * after authentication - * [is true as identification is completed during implicit authentication](./spec/acceptance/rest/auth_spec.rb#L1238) + * [is true as identification is completed during implicit authentication](./spec/acceptance/rest/auth_spec.rb#L1256) * when using a :key and basic auth - * [#using_token_auth? is false](./spec/acceptance/rest/auth_spec.rb#L1246) - * [#key attribute contains the key string](./spec/acceptance/rest/auth_spec.rb#L1250) - * [#using_basic_auth? is true](./spec/acceptance/rest/auth_spec.rb#L1254) + * [#using_token_auth? is false](./spec/acceptance/rest/auth_spec.rb#L1264) + * [#key attribute contains the key string](./spec/acceptance/rest/auth_spec.rb#L1268) + * [#using_basic_auth? is true](./spec/acceptance/rest/auth_spec.rb#L1272) * deprecated #authorise - * [logs a deprecation warning (#RSA10l)](./spec/acceptance/rest/auth_spec.rb#L1263) - * [returns a valid token (#RSA10l)](./spec/acceptance/rest/auth_spec.rb#L1268) + * [logs a deprecation warning (#RSA10l)](./spec/acceptance/rest/auth_spec.rb#L1281) + * [returns a valid token (#RSA10l)](./spec/acceptance/rest/auth_spec.rb#L1286) * when using JWT - * [authenticates correctly using the JWT token generated by the echo server](./spec/acceptance/rest/auth_spec.rb#L1280) + * [authenticates correctly using the JWT token generated by the echo server](./spec/acceptance/rest/auth_spec.rb#L1298) * when the JWT embeds an Ably token - * [authenticates correctly using the embedded token](./spec/acceptance/rest/auth_spec.rb#L1287) + * [authenticates correctly using the embedded token](./spec/acceptance/rest/auth_spec.rb#L1305) * and the requested token is encrypted - * [authenticates correctly using the embedded token](./spec/acceptance/rest/auth_spec.rb#L1294) + * [authenticates correctly using the embedded token](./spec/acceptance/rest/auth_spec.rb#L1312) * when the token requested is returned with application/jwt content type - * [authenticates correctly and pulls stats](./spec/acceptance/rest/auth_spec.rb#L1305) + * [authenticates correctly and pulls stats](./spec/acceptance/rest/auth_spec.rb#L1323) ### Ably::Rest _(see [spec/acceptance/rest/base_spec.rb](./spec/acceptance/rest/base_spec.rb))_ * transport protocol * when protocol is not defined it defaults to :msgpack @@ -1922,102 +2337,115 @@ ### Ably::Rest::Channel _(see [spec/acceptance/rest/channel_spec.rb](./spec/acceptance/rest/channel_spec.rb))_ * using JSON protocol * #publish * with name and data arguments - * [publishes the message and return true indicating success](./spec/acceptance/rest/channel_spec.rb#L21) + * [publishes the message and return true indicating success](./spec/acceptance/rest/channel_spec.rb#L23) * and additional attributes - * [publishes the message with the attributes and return true indicating success](./spec/acceptance/rest/channel_spec.rb#L30) + * [publishes the message with the attributes and return true indicating success](./spec/acceptance/rest/channel_spec.rb#L32) * with a client_id configured in the ClientOptions - * [publishes the message without a client_id](./spec/acceptance/rest/channel_spec.rb#L41) - * [expects a client_id to be added by the realtime service](./spec/acceptance/rest/channel_spec.rb#L49) + * [publishes the message without a client_id](./spec/acceptance/rest/channel_spec.rb#L43) + * [expects a client_id to be added by the realtime service](./spec/acceptance/rest/channel_spec.rb#L51) * with an array of Hash objects with :name and :data attributes - * [publishes an array of messages in one HTTP request](./spec/acceptance/rest/channel_spec.rb#L62) + * [publishes an array of messages in one HTTP request](./spec/acceptance/rest/channel_spec.rb#L64) * with an array of Message objects - * [publishes an array of messages in one HTTP request](./spec/acceptance/rest/channel_spec.rb#L77) + * when max_message_size and max_frame_size is not set + * and messages size (130 bytes) is smaller than the max_message_size + * [publishes an array of messages in one HTTP request](./spec/acceptance/rest/channel_spec.rb#L89) + * and messages size (177784 bytes) is bigger than the max_message_size + * [should not publish and raise Ably::Exceptions::MaxMessageSizeExceeded](./spec/acceptance/rest/channel_spec.rb#L105) + * when max_message_size is 655 bytes + * and messages size (130 bytes) is smaller than the max_message_size + * [publishes an array of messages in one HTTP request](./spec/acceptance/rest/channel_spec.rb#L127) + * and messages size (177784 bytes) is bigger than the max_message_size + * [should not publish and raise Ably::Exceptions::MaxMessageSizeExceeded](./spec/acceptance/rest/channel_spec.rb#L143) * with a Message object - * [publishes the message](./spec/acceptance/rest/channel_spec.rb#L92) + * [publishes the message](./spec/acceptance/rest/channel_spec.rb#L158) * with a Message object and query params - * [should fail to publish the message (RSL1l1)](./spec/acceptance/rest/channel_spec.rb#L104) + * [should fail to publish the message (RSL1l1)](./spec/acceptance/rest/channel_spec.rb#L170) * with Messages and query params - * [should fail to publish the message (RSL1l1)](./spec/acceptance/rest/channel_spec.rb#L117) + * [should fail to publish the message (RSL1l1)](./spec/acceptance/rest/channel_spec.rb#L183) * without adequate permissions on the channel - * [raises a permission error when publishing](./spec/acceptance/rest/channel_spec.rb#L127) + * [raises a permission error when publishing](./spec/acceptance/rest/channel_spec.rb#L193) * null attributes * when name is null - * [publishes the message without a name attribute in the payload](./spec/acceptance/rest/channel_spec.rb#L136) + * [publishes the message without a name attribute in the payload](./spec/acceptance/rest/channel_spec.rb#L202) * when data is null - * [publishes the message without a data attribute in the payload](./spec/acceptance/rest/channel_spec.rb#L147) + * [publishes the message without a data attribute in the payload](./spec/acceptance/rest/channel_spec.rb#L213) * with neither name or data attributes - * [publishes the message without any attributes in the payload](./spec/acceptance/rest/channel_spec.rb#L158) + * [publishes the message without any attributes in the payload](./spec/acceptance/rest/channel_spec.rb#L224) * identified clients * when authenticated with a wildcard client_id * with a valid client_id in the message - * [succeeds](./spec/acceptance/rest/channel_spec.rb#L175) + * [succeeds](./spec/acceptance/rest/channel_spec.rb#L241) * with a wildcard client_id in the message - * [throws an exception](./spec/acceptance/rest/channel_spec.rb#L184) + * [throws an exception](./spec/acceptance/rest/channel_spec.rb#L250) * with an empty client_id in the message - * [succeeds and publishes without a client_id](./spec/acceptance/rest/channel_spec.rb#L190) + * [succeeds and publishes without a client_id](./spec/acceptance/rest/channel_spec.rb#L256) * when authenticated with a Token string with an implicit client_id * without having a confirmed identity * with a valid client_id in the message - * [succeeds](./spec/acceptance/rest/channel_spec.rb#L207) + * [succeeds](./spec/acceptance/rest/channel_spec.rb#L273) * with an invalid client_id in the message - * [succeeds in the client library but then fails when published to Ably](./spec/acceptance/rest/channel_spec.rb#L216) + * [succeeds in the client library but then fails when published to Ably](./spec/acceptance/rest/channel_spec.rb#L282) * with an empty client_id in the message - * [succeeds and publishes with an implicit client_id](./spec/acceptance/rest/channel_spec.rb#L222) + * [succeeds and publishes with an implicit client_id](./spec/acceptance/rest/channel_spec.rb#L288) * when authenticated with TokenDetails with a valid client_id * with a valid client_id in the message - * [succeeds](./spec/acceptance/rest/channel_spec.rb#L239) + * [succeeds](./spec/acceptance/rest/channel_spec.rb#L305) * with a wildcard client_id in the message - * [throws an exception](./spec/acceptance/rest/channel_spec.rb#L248) + * [throws an exception](./spec/acceptance/rest/channel_spec.rb#L314) * with an invalid client_id in the message - * [throws an exception](./spec/acceptance/rest/channel_spec.rb#L254) + * [throws an exception](./spec/acceptance/rest/channel_spec.rb#L320) * with an empty client_id in the message - * [succeeds and publishes with an implicit client_id](./spec/acceptance/rest/channel_spec.rb#L260) + * [succeeds and publishes with an implicit client_id](./spec/acceptance/rest/channel_spec.rb#L326) * when anonymous and no client_id * with a client_id in the message - * [throws an exception](./spec/acceptance/rest/channel_spec.rb#L276) + * [throws an exception](./spec/acceptance/rest/channel_spec.rb#L342) * with a wildcard client_id in the message - * [throws an exception](./spec/acceptance/rest/channel_spec.rb#L282) + * [throws an exception](./spec/acceptance/rest/channel_spec.rb#L348) * with an empty client_id in the message - * [succeeds and publishes with an implicit client_id](./spec/acceptance/rest/channel_spec.rb#L288) + * [succeeds and publishes with an implicit client_id](./spec/acceptance/rest/channel_spec.rb#L354) * with a non ASCII channel name * stubbed - * [correctly encodes the channel name](./spec/acceptance/rest/channel_spec.rb#L310) + * [correctly encodes the channel name](./spec/acceptance/rest/channel_spec.rb#L376) * with a frozen message event name - * [succeeds and publishes with an implicit client_id](./spec/acceptance/rest/channel_spec.rb#L320) + * [succeeds and publishes with an implicit client_id](./spec/acceptance/rest/channel_spec.rb#L386) * with a frozen payload - * [succeeds and publishes with an implicit client_id](./spec/acceptance/rest/channel_spec.rb#L342) + * [succeeds and publishes with an implicit client_id](./spec/acceptance/rest/channel_spec.rb#L408) + * message size is exceeded (#TO3l8) + * [should raise Ably::Exceptions::MaxMessageSizeExceeded exception](./spec/acceptance/rest/channel_spec.rb#L423) * #history - * [returns a PaginatedResult model](./spec/acceptance/rest/channel_spec.rb#L372) - * [returns the current message history for the channel](./spec/acceptance/rest/channel_spec.rb#L376) - * [returns paged history using the PaginatedResult model](./spec/acceptance/rest/channel_spec.rb#L404) + * [returns a PaginatedResult model](./spec/acceptance/rest/channel_spec.rb#L447) + * [returns the current message history for the channel](./spec/acceptance/rest/channel_spec.rb#L451) + * [returns paged history using the PaginatedResult model](./spec/acceptance/rest/channel_spec.rb#L479) * message timestamps - * [are after the messages were published](./spec/acceptance/rest/channel_spec.rb#L389) + * [are after the messages were published](./spec/acceptance/rest/channel_spec.rb#L464) * message IDs - * [is unique](./spec/acceptance/rest/channel_spec.rb#L397) + * [is unique](./spec/acceptance/rest/channel_spec.rb#L472) * direction - * [returns paged history backwards by default](./spec/acceptance/rest/channel_spec.rb#L431) - * [returns history forward if specified in the options](./spec/acceptance/rest/channel_spec.rb#L437) + * [returns paged history backwards by default](./spec/acceptance/rest/channel_spec.rb#L506) + * [returns history forward if specified in the options](./spec/acceptance/rest/channel_spec.rb#L512) * limit - * [defaults to 100](./spec/acceptance/rest/channel_spec.rb#L449) + * [defaults to 100](./spec/acceptance/rest/channel_spec.rb#L524) * #history option * :start * with milliseconds since epoch value - * [uses this value in the history request](./spec/acceptance/rest/channel_spec.rb#L489) + * [uses this value in the history request](./spec/acceptance/rest/channel_spec.rb#L564) * with a Time object value - * [converts the value to milliseconds since epoch in the hisotry request](./spec/acceptance/rest/channel_spec.rb#L499) + * [converts the value to milliseconds since epoch in the hisotry request](./spec/acceptance/rest/channel_spec.rb#L574) * :end * with milliseconds since epoch value - * [uses this value in the history request](./spec/acceptance/rest/channel_spec.rb#L489) + * [uses this value in the history request](./spec/acceptance/rest/channel_spec.rb#L564) * with a Time object value - * [converts the value to milliseconds since epoch in the hisotry request](./spec/acceptance/rest/channel_spec.rb#L499) + * [converts the value to milliseconds since epoch in the hisotry request](./spec/acceptance/rest/channel_spec.rb#L574) * when argument start is after end - * [should raise an exception](./spec/acceptance/rest/channel_spec.rb#L509) + * [should raise an exception](./spec/acceptance/rest/channel_spec.rb#L584) * #presence - * [returns a REST Presence object](./spec/acceptance/rest/channel_spec.rb#L519) + * [returns a REST Presence object](./spec/acceptance/rest/channel_spec.rb#L594) + * #status + * [should return channel details status (#RSL8, #RSL8a)](./spec/acceptance/rest/channel_spec.rb#L604) ### Ably::Rest::Channels _(see [spec/acceptance/rest/channels_spec.rb](./spec/acceptance/rest/channels_spec.rb))_ * using JSON protocol * using shortcut method #channel on the client object @@ -2026,14 +2454,18 @@ * [returns channel object and passes the provided options](./spec/acceptance/rest/channels_spec.rb#L11) * using #get method on client#channels * behaves like a channel * [returns a channel object](./spec/acceptance/rest/channels_spec.rb#L6) * [returns channel object and passes the provided options](./spec/acceptance/rest/channels_spec.rb#L11) + * #set_options (#RTL16) + * [updates channel's options](./spec/acceptance/rest/channels_spec.rb#L38) + * when providing Ably::Models::ChannelOptions object + * [updates channel's options](./spec/acceptance/rest/channels_spec.rb#L45) * accessing an existing channel object with different options - * [overrides the existing channel options and returns the channel object](./spec/acceptance/rest/channels_spec.rb#L39) + * [overrides the existing channel options and returns the channel object (RSN3c)](./spec/acceptance/rest/channels_spec.rb#L55) * accessing an existing channel object without specifying any channel options - * [returns the existing channel without modifying the channel options](./spec/acceptance/rest/channels_spec.rb#L50) + * [returns the existing channel without modifying the channel options](./spec/acceptance/rest/channels_spec.rb#L67) * using undocumented array accessor [] method on client#channels * behaves like a channel * [returns a channel object](./spec/acceptance/rest/channels_spec.rb#L6) * [returns channel object and passes the provided options](./spec/acceptance/rest/channels_spec.rb#L11) * using a frozen channel name @@ -2172,56 +2604,59 @@ * [#http_max_retry_duration uses provided value](./spec/acceptance/rest/client_spec.rb#L1057) * #auth * [is provides access to the Auth object](./spec/acceptance/rest/client_spec.rb#L1073) * [configures the Auth object with all ClientOptions passed to client in the initializer](./spec/acceptance/rest/client_spec.rb#L1077) * version headers - * with variant none - * [sends a protocol version and lib version header (#G4, #RSC7a, #RSC7b)](./spec/acceptance/rest/client_spec.rb#L1111) - * with variant foo - * [sends a protocol version and lib version header (#G4, #RSC7a, #RSC7b)](./spec/acceptance/rest/client_spec.rb#L1111) - * #request (#RSC19*) + * with default agent + * [sends a protocol version and lib version header (#G4, #RSC7a, #RSC7b)](./spec/acceptance/rest/client_spec.rb#L1097) + * with custom ably-ruby/1.1.1 ruby/3.1.1 agent + * [sends a protocol version and lib version header (#G4, #RSC7a, #RSC7b)](./spec/acceptance/rest/client_spec.rb#L1097) + * #request (#RSC19*, #TO3l9) * get - * [returns an HttpPaginatedResponse object](./spec/acceptance/rest/client_spec.rb#L1126) + * [returns an HttpPaginatedResponse object](./spec/acceptance/rest/client_spec.rb#L1119) * 404 request to invalid URL - * [returns an object with 404 status code and error message](./spec/acceptance/rest/client_spec.rb#L1133) + * [returns an object with 404 status code and error message](./spec/acceptance/rest/client_spec.rb#L1126) * paged results - * [provides paging](./spec/acceptance/rest/client_spec.rb#L1145) + * [provides paging](./spec/acceptance/rest/client_spec.rb#L1138) * post - * [supports post](./spec/acceptance/rest/client_spec.rb#L1170) + * [supports post](./spec/acceptance/rest/client_spec.rb#L1163) + * [raises an exception once body size in bytes exceeded](./spec/acceptance/rest/client_spec.rb#L1169) * delete - * [supports delete](./spec/acceptance/rest/client_spec.rb#L1183) + * [supports delete](./spec/acceptance/rest/client_spec.rb#L1182) * patch - * [supports patch](./spec/acceptance/rest/client_spec.rb#L1199) + * [supports patch](./spec/acceptance/rest/client_spec.rb#L1198) + * [raises an exception once body size in bytes exceeded](./spec/acceptance/rest/client_spec.rb#L1204) * put - * [supports put](./spec/acceptance/rest/client_spec.rb#L1222) - * request_id generation + * [supports put](./spec/acceptance/rest/client_spec.rb#L1227) + * [raises an exception once body size in bytes exceeded](./spec/acceptance/rest/client_spec.rb#L1233) + * request_id generation (#RSC7c) * Timeout error * with option add_request_ids: true and no fallback hosts - * [has an error with the same request_id of the request](./spec/acceptance/rest/client_spec.rb#L1245) + * [has an error with the same request_id of the request](./spec/acceptance/rest/client_spec.rb#L1256) * with option add_request_ids: true and REST operations with a message body * with mocks to inspect the params * with a single publish - * [succeeds and sends the request_id as a param](./spec/acceptance/rest/client_spec.rb#L1267) + * [succeeds and sends the request_id as a param](./spec/acceptance/rest/client_spec.rb#L1278) * with an array publish - * [succeeds and sends the request_id as a param](./spec/acceptance/rest/client_spec.rb#L1274) + * [succeeds and sends the request_id as a param](./spec/acceptance/rest/client_spec.rb#L1285) * without mocks to ensure the requests are accepted * with a single publish - * [succeeds and sends the request_id as a param](./spec/acceptance/rest/client_spec.rb#L1283) + * [succeeds and sends the request_id as a param](./spec/acceptance/rest/client_spec.rb#L1294) * with an array publish - * [succeeds and sends the request_id as a param](./spec/acceptance/rest/client_spec.rb#L1290) + * [succeeds and sends the request_id as a param](./spec/acceptance/rest/client_spec.rb#L1301) * option add_request_ids: true and specified fallback hosts - * [request_id is the same across retries](./spec/acceptance/rest/client_spec.rb#L1315) + * [request_id is the same across retries](./spec/acceptance/rest/client_spec.rb#L1326) * without request_id and no fallback hosts - * [does not include request_id in ConnectionTimeout error](./spec/acceptance/rest/client_spec.rb#L1327) + * [does not include request_id in ConnectionTimeout error](./spec/acceptance/rest/client_spec.rb#L1338) * UnauthorizedRequest nonce error - * [includes request_id in UnauthorizedRequest error due to replayed nonce](./spec/acceptance/rest/client_spec.rb#L1340) + * [includes request_id in UnauthorizedRequest error due to replayed nonce](./spec/acceptance/rest/client_spec.rb#L1351) * failed request logging - * [is absent when requests do not fail](./spec/acceptance/rest/client_spec.rb#L1357) + * [is absent when requests do not fail](./spec/acceptance/rest/client_spec.rb#L1368) * with the first request failing - * [is present with success message when requests do not actually fail](./spec/acceptance/rest/client_spec.rb#L1372) + * [is present with success message when requests do not actually fail](./spec/acceptance/rest/client_spec.rb#L1383) * with all requests failing - * [is present when all requests fail](./spec/acceptance/rest/client_spec.rb#L1389) + * [is present when all requests fail](./spec/acceptance/rest/client_spec.rb#L1400) ### Ably::Models::MessageEncoders _(see [spec/acceptance/rest/encoders_spec.rb](./spec/acceptance/rest/encoders_spec.rb))_ * with binary transport protocol * without encryption @@ -2257,116 +2692,404 @@ ### Ably::Rest::Channel messages _(see [spec/acceptance/rest/message_spec.rb](./spec/acceptance/rest/message_spec.rb))_ * using JSON protocol * publishing with an ASCII_8BIT message name * [is converted into UTF_8](./spec/acceptance/rest/message_spec.rb#L19) + * a single Message object (#RSL1a) + * [publishes the message](./spec/acceptance/rest/message_spec.rb#L32) + * an array of Message objects (#RSL1a) + * [publishes three messages](./spec/acceptance/rest/message_spec.rb#L47) + * an array of hashes (#RSL1a) + * [publishes three messages](./spec/acceptance/rest/message_spec.rb#L59) + * a name with data payload (#RSL1a, #RSL1b) + * [publishes the message](./spec/acceptance/rest/message_spec.rb#L69) * with supported data payload content type * JSON Object (Hash) - * [is encoded and decoded to the same hash](./spec/acceptance/rest/message_spec.rb#L31) + * [is encoded and decoded to the same hash](./spec/acceptance/rest/message_spec.rb#L82) * JSON Array - * [is encoded and decoded to the same Array](./spec/acceptance/rest/message_spec.rb#L40) + * [is encoded and decoded to the same Array](./spec/acceptance/rest/message_spec.rb#L91) * String - * [is encoded and decoded to the same Array](./spec/acceptance/rest/message_spec.rb#L49) + * [is encoded and decoded to the same Array](./spec/acceptance/rest/message_spec.rb#L100) * Binary - * [is encoded and decoded to the same Array](./spec/acceptance/rest/message_spec.rb#L58) + * [is encoded and decoded to the same Array](./spec/acceptance/rest/message_spec.rb#L109) * with supported extra payload content type (#RSL1h, #RSL6a2) * JSON Object (Hash) - * [is encoded and decoded to the same hash](./spec/acceptance/rest/message_spec.rb#L71) + * [is encoded and decoded to the same hash](./spec/acceptance/rest/message_spec.rb#L122) * JSON Array - * [is encoded and decoded to the same deep multi-type object](./spec/acceptance/rest/message_spec.rb#L80) + * [is encoded and decoded to the same deep multi-type object](./spec/acceptance/rest/message_spec.rb#L131) * nil - * [is encoded and decoded to the same Array](./spec/acceptance/rest/message_spec.rb#L87) + * [is encoded and decoded to the same Array](./spec/acceptance/rest/message_spec.rb#L138) * idempotency (#RSL1k) - * [idempotent publishing is disabled by default with 1.1 (#TO3n)](./spec/acceptance/rest/message_spec.rb#L156) - * [idempotent publishing is enabled by default with 1.2 (#TO3n)](./spec/acceptance/rest/message_spec.rb#L161) + * [idempotent publishing is set as per clientOptions](./spec/acceptance/rest/message_spec.rb#L207) + * [idempotent publishing is enabled by default (#TO3n)](./spec/acceptance/rest/message_spec.rb#L217) * when ID is not included (#RSL1k2) * with Message object - * [publishes the same message three times](./spec/acceptance/rest/message_spec.rb#L103) + * [publishes the same message three times](./spec/acceptance/rest/message_spec.rb#L154) * with #publish arguments only - * [publishes the same message three times](./spec/acceptance/rest/message_spec.rb#L110) + * [publishes the same message three times](./spec/acceptance/rest/message_spec.rb#L161) * when ID is included (#RSL1k2, #RSL1k5) - * [the ID provided is used for the published messages](./spec/acceptance/rest/message_spec.rb#L135) - * [for multiple messages in one publish operation (#RSL1k3)](./spec/acceptance/rest/message_spec.rb#L140) - * [for multiple messages in one publish operation with IDs following the required format described in RSL1k1 (#RSL1k3)](./spec/acceptance/rest/message_spec.rb#L147) + * [the ID provided is used for the published messages](./spec/acceptance/rest/message_spec.rb#L186) + * [for multiple messages in one publish operation (#RSL1k3)](./spec/acceptance/rest/message_spec.rb#L191) + * [for multiple messages in one publish operation with IDs following the required format described in RSL1k1 (#RSL1k3)](./spec/acceptance/rest/message_spec.rb#L198) * with Message object - * [three REST publishes result in only one message being published](./spec/acceptance/rest/message_spec.rb#L121) + * [three REST publishes result in only one message being published](./spec/acceptance/rest/message_spec.rb#L172) * with #publish arguments only - * [three REST publishes result in only one message being published](./spec/acceptance/rest/message_spec.rb#L129) + * [three REST publishes result in only one message being published](./spec/acceptance/rest/message_spec.rb#L180) * when idempotent publishing is enabled in the client library ClientOptions (#TO3n) - * [the ID is populated with a random ID and serial 0 from this lib (#RSL1k1)](./spec/acceptance/rest/message_spec.rb#L225) + * [the ID is populated with a random ID and serial 0 from this lib (#RSL1k1)](./spec/acceptance/rest/message_spec.rb#L280) * when there is a network failure triggering an automatic retry (#RSL1k4) - * [for multiple messages in one publish operation](./spec/acceptance/rest/message_spec.rb#L218) + * [for multiple messages in one publish operation](./spec/acceptance/rest/message_spec.rb#L273) * with Message object - * [two REST publish retries result in only one message being published](./spec/acceptance/rest/message_spec.rb#L188) + * [two REST publish retries result in only one message being published](./spec/acceptance/rest/message_spec.rb#L243) * with #publish arguments only - * [two REST publish retries result in only one message being published](./spec/acceptance/rest/message_spec.rb#L198) + * [two REST publish retries result in only one message being published](./spec/acceptance/rest/message_spec.rb#L253) * with explicitly provided message ID - * [two REST publish retries result in only one message being published](./spec/acceptance/rest/message_spec.rb#L210) + * [two REST publish retries result in only one message being published](./spec/acceptance/rest/message_spec.rb#L265) * when publishing a batch of messages - * [the ID is populated with a single random ID and sequence of serials from this lib (#RSL1k1)](./spec/acceptance/rest/message_spec.rb#L233) + * [the ID is populated with a single random ID and sequence of serials from this lib (#RSL1k1)](./spec/acceptance/rest/message_spec.rb#L288) * with unsupported data payload content type * Integer - * [is raises an UnsupportedDataType 40013 exception](./spec/acceptance/rest/message_spec.rb#L250) + * [is raises an UnsupportedDataType 40013 exception](./spec/acceptance/rest/message_spec.rb#L305) * Float - * [is raises an UnsupportedDataType 40013 exception](./spec/acceptance/rest/message_spec.rb#L258) + * [is raises an UnsupportedDataType 40013 exception](./spec/acceptance/rest/message_spec.rb#L313) * Boolean - * [is raises an UnsupportedDataType 40013 exception](./spec/acceptance/rest/message_spec.rb#L266) + * [is raises an UnsupportedDataType 40013 exception](./spec/acceptance/rest/message_spec.rb#L321) * False - * [is raises an UnsupportedDataType 40013 exception](./spec/acceptance/rest/message_spec.rb#L274) + * [is raises an UnsupportedDataType 40013 exception](./spec/acceptance/rest/message_spec.rb#L329) * encryption and encoding * with #publish and #history * with AES-128-CBC using crypto-data-128.json fixtures (#RTL7d) * item 0 with encrypted encoding utf-8/cipher+aes-128-cbc/base64 * behaves like an Ably encrypter and decrypter - * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L319) - * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L334) + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) * item 1 with encrypted encoding cipher+aes-128-cbc/base64 * behaves like an Ably encrypter and decrypter - * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L319) - * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L334) + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) * item 2 with encrypted encoding json/utf-8/cipher+aes-128-cbc/base64 * behaves like an Ably encrypter and decrypter - * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L319) - * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L334) + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) * item 3 with encrypted encoding json/utf-8/cipher+aes-128-cbc/base64 * behaves like an Ably encrypter and decrypter - * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L319) - * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L334) + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) * with AES-256-CBC using crypto-data-256.json fixtures (#RTL7d) * item 0 with encrypted encoding utf-8/cipher+aes-256-cbc/base64 * behaves like an Ably encrypter and decrypter - * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L319) - * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L334) + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) * item 1 with encrypted encoding cipher+aes-256-cbc/base64 * behaves like an Ably encrypter and decrypter - * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L319) - * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L334) + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) * item 2 with encrypted encoding json/utf-8/cipher+aes-256-cbc/base64 * behaves like an Ably encrypter and decrypter - * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L319) - * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L334) + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) * item 3 with encrypted encoding json/utf-8/cipher+aes-256-cbc/base64 * behaves like an Ably encrypter and decrypter - * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L319) - * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L334) + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 4 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 5 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 6 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 7 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 8 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 9 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 10 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 11 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 12 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 13 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 14 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 15 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 16 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 17 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 18 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 19 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 20 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 21 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 22 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 23 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 24 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 25 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 26 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 27 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 28 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 29 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 30 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 31 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 32 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 33 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 34 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 35 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 36 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 37 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 38 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 39 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 40 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 41 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 42 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 43 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 44 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 45 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 46 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 47 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 48 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 49 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 50 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 51 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 52 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 53 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 54 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 55 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 56 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 57 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 58 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 59 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 60 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 61 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 62 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 63 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 64 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 65 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 66 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 67 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 68 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 69 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 70 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 71 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 72 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) + * item 73 with encrypted encoding cipher+aes-256-cbc/base64 + * behaves like an Ably encrypter and decrypter + * [encrypts message automatically when published (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L374) + * [sends and retrieves messages that are encrypted & decrypted by the Ably library (#RTL7d)](./spec/acceptance/rest/message_spec.rb#L389) * when publishing lots of messages - * [encrypts on #publish and decrypts on #history](./spec/acceptance/rest/message_spec.rb#L367) + * [encrypts on #publish and decrypts on #history](./spec/acceptance/rest/message_spec.rb#L422) * when retrieving #history with a different protocol - * [delivers a String ASCII-8BIT payload to the receiver](./spec/acceptance/rest/message_spec.rb#L394) - * [delivers a String UTF-8 payload to the receiver](./spec/acceptance/rest/message_spec.rb#L394) - * [delivers a Hash payload to the receiver](./spec/acceptance/rest/message_spec.rb#L394) + * [delivers a String ASCII-8BIT payload to the receiver](./spec/acceptance/rest/message_spec.rb#L449) + * [delivers a String UTF-8 payload to the receiver](./spec/acceptance/rest/message_spec.rb#L449) + * [delivers a Hash payload to the receiver](./spec/acceptance/rest/message_spec.rb#L449) * when publishing on an unencrypted channel and retrieving with #history on an encrypted channel - * [does not attempt to decrypt the message](./spec/acceptance/rest/message_spec.rb#L410) + * [does not attempt to decrypt the message](./spec/acceptance/rest/message_spec.rb#L465) * when publishing on an encrypted channel and retrieving with #history on an unencrypted channel - * [retrieves the message that remains encrypted with an encrypted encoding attribute (#RTL7e)](./spec/acceptance/rest/message_spec.rb#L431) - * [logs a Cipher exception (#RTL7e)](./spec/acceptance/rest/message_spec.rb#L437) + * [retrieves the message that remains encrypted with an encrypted encoding attribute (#RTL7e)](./spec/acceptance/rest/message_spec.rb#L486) + * [logs a Cipher exception (#RTL7e)](./spec/acceptance/rest/message_spec.rb#L492) * publishing on an encrypted channel and retrieving #history with a different algorithm on another client (#RTL7e) - * [retrieves the message that remains encrypted with an encrypted encoding attribute (#RTL7e)](./spec/acceptance/rest/message_spec.rb#L458) - * [logs a Cipher exception (#RTL7e)](./spec/acceptance/rest/message_spec.rb#L464) + * [retrieves the message that remains encrypted with an encrypted encoding attribute (#RTL7e)](./spec/acceptance/rest/message_spec.rb#L513) + * [logs a Cipher exception (#RTL7e)](./spec/acceptance/rest/message_spec.rb#L519) * publishing on an encrypted channel and subscribing with a different key on another client - * [retrieves the message that remains encrypted with an encrypted encoding attribute](./spec/acceptance/rest/message_spec.rb#L485) - * [logs a Cipher exception](./spec/acceptance/rest/message_spec.rb#L491) + * [retrieves the message that remains encrypted with an encrypted encoding attribute](./spec/acceptance/rest/message_spec.rb#L540) + * [logs a Cipher exception](./spec/acceptance/rest/message_spec.rb#L546) ### Ably::Rest::Presence _(see [spec/acceptance/rest/presence_spec.rb](./spec/acceptance/rest/presence_spec.rb))_ * using JSON protocol * tested against presence fixture data set up in test app @@ -2466,66 +3189,58 @@ * [returns a DeviceDetails object if a DeviceDetails object is provided](./spec/acceptance/rest/push_admin_spec.rb#L274) * [raises a ResourceMissing exception if device ID does not exist](./spec/acceptance/rest/push_admin_spec.rb#L282) * #save (#RSH1b3) * [saves the new DeviceDetails Hash object](./spec/acceptance/rest/push_admin_spec.rb#L327) * [saves the associated DevicePushDetails](./spec/acceptance/rest/push_admin_spec.rb#L342) - * [does not allow some fields to be configured](./spec/acceptance/rest/push_admin_spec.rb#L396) - * [allows device_secret to be configured](./spec/acceptance/rest/push_admin_spec.rb#L409) - * [saves the new DeviceDetails object](./spec/acceptance/rest/push_admin_spec.rb#L418) - * [allows arbitrary number of subsequent saves](./spec/acceptance/rest/push_admin_spec.rb#L427) - * [fails if data is invalid](./spec/acceptance/rest/push_admin_spec.rb#L440) - * with GCM target + * [does not allow some fields to be configured](./spec/acceptance/rest/push_admin_spec.rb#L401) + * [allows device_secret to be configured](./spec/acceptance/rest/push_admin_spec.rb#L414) + * [saves the new DeviceDetails object](./spec/acceptance/rest/push_admin_spec.rb#L423) + * [allows arbitrary number of subsequent saves](./spec/acceptance/rest/push_admin_spec.rb#L432) + * [fails if data is invalid](./spec/acceptance/rest/push_admin_spec.rb#L445) + * with FCM target * [saves the associated DevicePushDetails](./spec/acceptance/rest/push_admin_spec.rb#L356) * with web target - * [saves the associated DevicePushDetails](./spec/acceptance/rest/push_admin_spec.rb#L377) + * [saves the associated DevicePushDetails](./spec/acceptance/rest/push_admin_spec.rb#L378) * #remove_where (#RSH1b5) - * [removes all matching device registrations by client_id](./spec/acceptance/rest/push_admin_spec.rb#L492) - * [removes device by device_id](./spec/acceptance/rest/push_admin_spec.rb#L497) - * [succeeds even if there is no match](./spec/acceptance/rest/push_admin_spec.rb#L502) + * [removes all matching device registrations by client_id](./spec/acceptance/rest/push_admin_spec.rb#L497) + * [removes device by device_id](./spec/acceptance/rest/push_admin_spec.rb#L502) + * [succeeds even if there is no match](./spec/acceptance/rest/push_admin_spec.rb#L507) * #remove (#RSH1b4) - * [removes the provided device id string](./spec/acceptance/rest/push_admin_spec.rb#L555) - * [removes the provided DeviceDetails](./spec/acceptance/rest/push_admin_spec.rb#L560) - * [succeeds if the item does not exist](./spec/acceptance/rest/push_admin_spec.rb#L565) + * [removes the provided device id string](./spec/acceptance/rest/push_admin_spec.rb#L560) + * [removes the provided DeviceDetails](./spec/acceptance/rest/push_admin_spec.rb#L565) + * [succeeds if the item does not exist](./spec/acceptance/rest/push_admin_spec.rb#L570) * #channel_subscriptions (#RSH1c) * #list (#RSH1c1) - * [returns a PaginatedResult object containing DeviceDetails objects](./spec/acceptance/rest/push_admin_spec.rb#L633) - * [returns an empty PaginatedResult if params do not match](./spec/acceptance/rest/push_admin_spec.rb#L639) - * [supports paging](./spec/acceptance/rest/push_admin_spec.rb#L645) - * [provides filtering](./spec/acceptance/rest/push_admin_spec.rb#L657) - * [raises an exception if none of the required filters are provided](./spec/acceptance/rest/push_admin_spec.rb#L685) + * [returns a PaginatedResult object containing DeviceDetails objects](./spec/acceptance/rest/push_admin_spec.rb#L638) + * [returns an empty PaginatedResult if params do not match](./spec/acceptance/rest/push_admin_spec.rb#L644) + * [supports paging](./spec/acceptance/rest/push_admin_spec.rb#L650) + * [provides filtering](./spec/acceptance/rest/push_admin_spec.rb#L662) + * [raises an exception if none of the required filters are provided](./spec/acceptance/rest/push_admin_spec.rb#L690) * #list_channels (#RSH1c2) - * [returns a PaginatedResult object containing String objects](./spec/acceptance/rest/push_admin_spec.rb#L712) - * [supports paging](./spec/acceptance/rest/push_admin_spec.rb#L719) - * [returns an accurate number of channels after devices are deleted](./spec/acceptance/rest/push_admin_spec.rb#L734) + * [returns a PaginatedResult object containing String objects](./spec/acceptance/rest/push_admin_spec.rb#L717) + * [supports paging](./spec/acceptance/rest/push_admin_spec.rb#L724) + * [returns an accurate number of channels after devices are deleted](./spec/acceptance/rest/push_admin_spec.rb#L739) * #save (#RSH1c3) - * [saves the new client_id PushChannelSubscription Hash object](./spec/acceptance/rest/push_admin_spec.rb#L759) - * [saves the new device_id PushChannelSubscription Hash object](./spec/acceptance/rest/push_admin_spec.rb#L770) - * [saves the client_id PushChannelSubscription object](./spec/acceptance/rest/push_admin_spec.rb#L781) - * [saves the device_id PushChannelSubscription object](./spec/acceptance/rest/push_admin_spec.rb#L792) - * [allows arbitrary number of subsequent saves](./spec/acceptance/rest/push_admin_spec.rb#L803) - * [fails if data is invalid](./spec/acceptance/rest/push_admin_spec.rb#L816) + * [saves the new client_id PushChannelSubscription Hash object](./spec/acceptance/rest/push_admin_spec.rb#L764) + * [saves the new device_id PushChannelSubscription Hash object](./spec/acceptance/rest/push_admin_spec.rb#L775) + * [saves the client_id PushChannelSubscription object](./spec/acceptance/rest/push_admin_spec.rb#L786) + * [saves the device_id PushChannelSubscription object](./spec/acceptance/rest/push_admin_spec.rb#L797) + * [allows arbitrary number of subsequent saves](./spec/acceptance/rest/push_admin_spec.rb#L808) + * [fails if data is invalid](./spec/acceptance/rest/push_admin_spec.rb#L821) * #remove_where (#RSH1c5) - * PENDING: *[removes matching channels](./spec/acceptance/rest/push_admin_spec.rb#L851)* - * [removes matching client_ids](./spec/acceptance/rest/push_admin_spec.rb#L859) - * [removes matching device_ids](./spec/acceptance/rest/push_admin_spec.rb#L865) - * [device_id and client_id filters in the same request are not suppoorted](./spec/acceptance/rest/push_admin_spec.rb#L871) - * [succeeds on no match](./spec/acceptance/rest/push_admin_spec.rb#L875) + * PENDING: *[removes matching channels](./spec/acceptance/rest/push_admin_spec.rb#L856)* + * [removes matching client_ids](./spec/acceptance/rest/push_admin_spec.rb#L864) + * [removes matching device_ids](./spec/acceptance/rest/push_admin_spec.rb#L870) + * [device_id and client_id filters in the same request are not suppoorted](./spec/acceptance/rest/push_admin_spec.rb#L876) + * [succeeds on no match](./spec/acceptance/rest/push_admin_spec.rb#L880) * #remove (#RSH1c4) - * [removes match for Hash object by channel and client_id](./spec/acceptance/rest/push_admin_spec.rb#L905) - * [removes match for PushChannelSubscription object by channel and client_id](./spec/acceptance/rest/push_admin_spec.rb#L910) - * [removes match for Hash object by channel and device_id](./spec/acceptance/rest/push_admin_spec.rb#L917) - * [removes match for PushChannelSubscription object by channel and client_id](./spec/acceptance/rest/push_admin_spec.rb#L922) - * [succeeds even if there is no match](./spec/acceptance/rest/push_admin_spec.rb#L929) + * [removes match for Hash object by channel and client_id](./spec/acceptance/rest/push_admin_spec.rb#L910) + * [removes match for PushChannelSubscription object by channel and client_id](./spec/acceptance/rest/push_admin_spec.rb#L915) + * [removes match for Hash object by channel and device_id](./spec/acceptance/rest/push_admin_spec.rb#L922) + * [removes match for PushChannelSubscription object by channel and client_id](./spec/acceptance/rest/push_admin_spec.rb#L927) + * [succeeds even if there is no match](./spec/acceptance/rest/push_admin_spec.rb#L934) -### Ably::Rest::Push -_(see [spec/acceptance/rest/push_spec.rb](./spec/acceptance/rest/push_spec.rb))_ - * using JSON protocol - * #activate - * [raises an unsupported exception](./spec/acceptance/rest/push_spec.rb#L14) - * #deactivate - * [raises an unsupported exception](./spec/acceptance/rest/push_spec.rb#L20) - ### Ably::Rest::Client#stats _(see [spec/acceptance/rest/stats_spec.rb](./spec/acceptance/rest/stats_spec.rb))_ * using JSON protocol * fetching application stats * [returns a PaginatedResult object](./spec/acceptance/rest/stats_spec.rb#L54) @@ -2574,10 +3289,20 @@ * fetching the service time * [should return the service time as a Time object](./spec/acceptance/rest/time_spec.rb#L10) * with reconfigured HTTP timeout * [should raise a timeout exception](./spec/acceptance/rest/time_spec.rb#L19) +### Ably::Models::ChannelOptions +_(see [spec/lib/unit/models/channel_options_spec.rb](./spec/lib/unit/models/channel_options_spec.rb))_ + * #modes_to_flags + * [converts modes to ProtocolMessage#flags correctly](./spec/lib/unit/models/channel_options_spec.rb#L17) + * #set_modes_from_flags + * [converts flags to ChannelOptions#modes correctly](./spec/lib/unit/models/channel_options_spec.rb#L30) + * #set_params + * [should be able to overwrite attributes](./spec/lib/unit/models/channel_options_spec.rb#L43) + * [should be able to make params empty](./spec/lib/unit/models/channel_options_spec.rb#L48) + ### Ably::Auth _(see [spec/unit/auth_spec.rb](./spec/unit/auth_spec.rb))_ * client_id option * with nil value * [is permitted](./spec/unit/auth_spec.rb#L20) @@ -2599,17 +3324,17 @@ ### Ably::Logger _(see [spec/unit/logger_spec.rb](./spec/unit/logger_spec.rb))_ * [uses the language provided Logger by default](./spec/unit/logger_spec.rb#L15) * with a custom Logger * with an invalid interface - * [raises an exception](./spec/unit/logger_spec.rb#L122) + * [raises an exception](./spec/unit/logger_spec.rb#L118) * with a valid interface - * [is used](./spec/unit/logger_spec.rb#L133) + * [is used](./spec/unit/logger_spec.rb#L129) * with blocks - * [does not call the block unless the log level is met](./spec/unit/logger_spec.rb#L151) + * [does not call the block unless the log level is met](./spec/unit/logger_spec.rb#L143) * with an exception in the logger block - * [catches the error and continues](./spec/unit/logger_spec.rb#L166) + * [catches the error and continues](./spec/unit/logger_spec.rb#L158) ### Ably::Models::AuthDetails _(see [spec/unit/models/auth_details_spec.rb](./spec/unit/models/auth_details_spec.rb))_ * behaves like a model * attributes @@ -2625,10 +3350,39 @@ * == * [is true when attributes are the same](./spec/unit/models/auth_details_spec.rb#L17) * [is false when attributes are not the same](./spec/unit/models/auth_details_spec.rb#L22) * [is false when class type differs](./spec/unit/models/auth_details_spec.rb#L26) +### Ably::Models::ChannelDetails +_(see [spec/unit/models/channel_details_spec.rb](./spec/unit/models/channel_details_spec.rb))_ + * #channel_id + * [should return channel id](./spec/unit/models/channel_details_spec.rb#L8) + * #name + * [should return name](./spec/unit/models/channel_details_spec.rb#L14) + * #status + * [should return status](./spec/unit/models/channel_details_spec.rb#L20) + +### Ably::Models::ChannelMetrics +_(see [spec/unit/models/channel_metrics_spec.rb](./spec/unit/models/channel_metrics_spec.rb))_ + * #connections + * [should return integer](./spec/unit/models/channel_metrics_spec.rb#L8) + * #presence_connections + * [should return integer](./spec/unit/models/channel_metrics_spec.rb#L14) + * #presence_members + * [should return integer](./spec/unit/models/channel_metrics_spec.rb#L20) + * #presence_subscribers + * [should return integer](./spec/unit/models/channel_metrics_spec.rb#L26) + * #publishers + * [should return integer](./spec/unit/models/channel_metrics_spec.rb#L32) + * #subscribers + * [should return integer](./spec/unit/models/channel_metrics_spec.rb#L38) + +### Ably::Models::ChannelOccupancy +_(see [spec/unit/models/channel_occupancy_spec.rb](./spec/unit/models/channel_occupancy_spec.rb))_ + * #metrics + * [should return attributes](./spec/unit/models/channel_occupancy_spec.rb#L8) + ### Ably::Models::ChannelStateChange _(see [spec/unit/models/channel_state_change_spec.rb](./spec/unit/models/channel_state_change_spec.rb))_ * #current (#TH1) * [is required](./spec/unit/models/channel_state_change_spec.rb#L10) * [is an attribute](./spec/unit/models/channel_state_change_spec.rb#L14) @@ -2645,10 +3399,20 @@ * [is false when ommitted](./spec/unit/models/channel_state_change_spec.rb#L50) * [is true when provided](./spec/unit/models/channel_state_change_spec.rb#L54) * invalid attributes * [raises an argument error](./spec/unit/models/channel_state_change_spec.rb#L60) +### Ably::Models::ChannelStatus +_(see [spec/unit/models/channel_status_spec.rb](./spec/unit/models/channel_status_spec.rb))_ + * #is_active + * when occupancy is active + * [should return true](./spec/unit/models/channel_status_spec.rb#L11) + * when occupancy is not active + * [should return false](./spec/unit/models/channel_status_spec.rb#L19) + * #occupancy + * [should return occupancy object](./spec/unit/models/channel_status_spec.rb#L26) + ### Ably::Models::CipherParams _(see [spec/unit/models/cipher_params_spec.rb](./spec/unit/models/cipher_params_spec.rb))_ * :key missing from constructor * [raises an exception](./spec/unit/models/cipher_params_spec.rb#L8) * #key @@ -2735,10 +3499,15 @@ * [is not required](./spec/unit/models/connection_state_change_spec.rb#L51) * [is an attribute](./spec/unit/models/connection_state_change_spec.rb#L55) * invalid attributes * [raises an argument error](./spec/unit/models/connection_state_change_spec.rb#L61) +### Ably::Models::DeltaExtras +_(see [spec/unit/models/delta_extras_spec.rb](./spec/unit/models/delta_extras_spec.rb))_ + * [should have `from` attribute](./spec/unit/models/delta_extras_spec.rb#L7) + * [should have `format` attribute](./spec/unit/models/delta_extras_spec.rb#L11) + ### Ably::Models::DeviceDetails _(see [spec/unit/models/device_details_spec.rb](./spec/unit/models/device_details_spec.rb))_ * #id and #id= * [setter accepts a string value and getter returns the new value](./spec/unit/models/device_details_spec.rb#L16) * [setter accepts nil](./spec/unit/models/device_details_spec.rb#L22) @@ -2802,30 +3571,38 @@ * [retrieves attribute :status_code](./spec/shared/model_behaviour.rb#L15) * #href * [retrieves attribute :href](./spec/shared/model_behaviour.rb#L15) * #message * [retrieves attribute :message](./spec/shared/model_behaviour.rb#L15) + * #request_id + * [retrieves attribute :request_id](./spec/shared/model_behaviour.rb#L15) + * #cause + * [retrieves attribute :cause](./spec/shared/model_behaviour.rb#L15) * #== * [is true when attributes are the same](./spec/shared/model_behaviour.rb#L41) * [is false when attributes are not the same](./spec/shared/model_behaviour.rb#L46) * [is false when class type differs](./spec/shared/model_behaviour.rb#L50) * is immutable * [prevents changes](./spec/shared/model_behaviour.rb#L76) * [dups options](./spec/shared/model_behaviour.rb#L80) * #status #TI1, #TI2 * [is an alias for #status_code](./spec/unit/models/error_info_spec.rb#L15) + * #request_id #RSC7c + * [should return request ID](./spec/unit/models/error_info_spec.rb#L24) + * #cause #TI1 + * [should return cause attribute](./spec/unit/models/error_info_spec.rb#L32) * log entries container help link #TI5 * without an error code - * [does not include the help URL](./spec/unit/models/error_info_spec.rb#L25) + * [does not include the help URL](./spec/unit/models/error_info_spec.rb#L41) * with a specified error code - * [includes https://help.ably.io/error/[CODE] in the stringified object](./spec/unit/models/error_info_spec.rb#L33) + * [includes https://help.ably.io/error/[CODE] in the stringified object](./spec/unit/models/error_info_spec.rb#L49) * with an error code and an href attribute - * [includes the specified href in the stringified object](./spec/unit/models/error_info_spec.rb#L41) + * [includes the specified href in the stringified object](./spec/unit/models/error_info_spec.rb#L57) * with an error code and a message with the same error URL - * [includes the specified error URL only once in the stringified object](./spec/unit/models/error_info_spec.rb#L50) + * [includes the specified error URL only once in the stringified object](./spec/unit/models/error_info_spec.rb#L66) * with an error code and a message with a different error URL - * [includes the specified error URL from the message and the error code URL in the stringified object](./spec/unit/models/error_info_spec.rb#L58) + * [includes the specified error URL from the message and the error code URL in the stringified object](./spec/unit/models/error_info_spec.rb#L74) ### Ably::Models::HttpPaginatedResponse: #HP1 -> #HP8 _(see [spec/unit/models/http_paginated_result_spec.rb](./spec/unit/models/http_paginated_result_spec.rb))_ * #items * [returns correct length from body](./spec/unit/models/http_paginated_result_spec.rb#L33) @@ -3121,29 +3898,48 @@ * [is compatible with original encoding](./spec/unit/models/message_spec.rb#L165) * as Integer * [raises an argument error](./spec/unit/models/message_spec.rb#L173) * as Nil * [is permitted](./spec/unit/models/message_spec.rb#L181) + * #size + * String (#TO3l8a) + * [should return 33 bytes](./spec/unit/models/message_spec.rb#L223) + * Object (#TO3l8b) + * [should return 38 bytes](./spec/unit/models/message_spec.rb#L234) + * Array (#TO3l8b) + * [should return 24 bytes](./spec/unit/models/message_spec.rb#L245) + * extras (#TO3l8d) + * [should return 57 bytes](./spec/unit/models/message_spec.rb#L256) + * nil (#TO3l8e) + * [should return 19 bytes](./spec/unit/models/message_spec.rb#L267) + * #protocol_message_index (#RTL21) + * [should return correct protocol_message_index](./spec/unit/models/message_spec.rb#L280) * #from_encoded (#TM3) * with no encoding - * [returns a message object](./spec/unit/models/message_spec.rb#L437) + * [returns a message object](./spec/unit/models/message_spec.rb#L510) * with a block - * [does not call the block](./spec/unit/models/message_spec.rb#L445) + * [does not call the block](./spec/unit/models/message_spec.rb#L518) * with an encoding - * [returns a message object](./spec/unit/models/message_spec.rb#L462) + * [returns a message object](./spec/unit/models/message_spec.rb#L535) * with a custom encoding - * [returns a message object with the residual incompatible transforms left in the encoding property](./spec/unit/models/message_spec.rb#L477) + * [returns a message object with the residual incompatible transforms left in the encoding property](./spec/unit/models/message_spec.rb#L550) * with a Cipher encoding - * [returns a message object with the residual incompatible transforms left in the encoding property](./spec/unit/models/message_spec.rb#L496) + * [returns a message object with the residual incompatible transforms left in the encoding property](./spec/unit/models/message_spec.rb#L569) * with invalid Cipher encoding * without a block - * [raises an exception](./spec/unit/models/message_spec.rb#L514) + * [raises an exception](./spec/unit/models/message_spec.rb#L587) * with a block - * [calls the block with the exception](./spec/unit/models/message_spec.rb#L520) + * [calls the block with the exception](./spec/unit/models/message_spec.rb#L593) * #from_encoded_array (#TM3) * with no encoding - * [returns an Array of message objects](./spec/unit/models/message_spec.rb#L539) + * [returns an Array of message objects](./spec/unit/models/message_spec.rb#L612) + * #delta_extras (TM2i) + * when delta + * [should return vcdiff format](./spec/unit/models/message_spec.rb#L630) + * [should return 1234-1234-5678-9009 message id](./spec/unit/models/message_spec.rb#L634) + * when no delta + * [should return nil](./spec/unit/models/message_spec.rb#L642) ### Ably::Models::PaginatedResult _(see [spec/unit/models/paginated_result_spec.rb](./spec/unit/models/paginated_result_spec.rb))_ * #items * [returns correct length from body](./spec/unit/models/paginated_result_spec.rb#L31) @@ -3254,40 +4050,51 @@ * [is compatible with original encoding](./spec/unit/models/presence_message_spec.rb#L166) * as Integer * [raises an argument error](./spec/unit/models/presence_message_spec.rb#L174) * as Nil * [is permitted](./spec/unit/models/presence_message_spec.rb#L182) + * #size + * String (#TO3l8a) + * [should return 20 bytes](./spec/unit/models/presence_message_spec.rb#L230) + * Object (#TO3l8b) + * [should return 32 bytes](./spec/unit/models/presence_message_spec.rb#L239) + * Array (#TO3l8b) + * [should return 18 bytes](./spec/unit/models/presence_message_spec.rb#L248) + * extras (#TO3l8d) + * [should return 51 bytes](./spec/unit/models/presence_message_spec.rb#L257) + * nil (#TO3l8e) + * [should return 1 bytes](./spec/unit/models/presence_message_spec.rb#L266) * #from_encoded (#TP4) * with no encoding - * [returns a presence message object](./spec/unit/models/presence_message_spec.rb#L395) + * [returns a presence message object](./spec/unit/models/presence_message_spec.rb#L444) * with a block - * [does not call the block](./spec/unit/models/presence_message_spec.rb#L403) + * [does not call the block](./spec/unit/models/presence_message_spec.rb#L452) * with an encoding - * [returns a presence message object](./spec/unit/models/presence_message_spec.rb#L420) + * [returns a presence message object](./spec/unit/models/presence_message_spec.rb#L469) * with a custom encoding - * [returns a presence message object with the residual incompatible transforms left in the encoding property](./spec/unit/models/presence_message_spec.rb#L435) + * [returns a presence message object with the residual incompatible transforms left in the encoding property](./spec/unit/models/presence_message_spec.rb#L484) * with a Cipher encoding - * [returns a presence message object with the residual incompatible transforms left in the encoding property](./spec/unit/models/presence_message_spec.rb#L454) + * [returns a presence message object with the residual incompatible transforms left in the encoding property](./spec/unit/models/presence_message_spec.rb#L503) * with invalid Cipher encoding * without a block - * [raises an exception](./spec/unit/models/presence_message_spec.rb#L471) + * [raises an exception](./spec/unit/models/presence_message_spec.rb#L520) * with a block - * [calls the block with the exception](./spec/unit/models/presence_message_spec.rb#L477) + * [calls the block with the exception](./spec/unit/models/presence_message_spec.rb#L526) * #from_encoded_array (#TP4) * with no encoding - * [returns an Array of presence message objects](./spec/unit/models/presence_message_spec.rb#L496) + * [returns an Array of presence message objects](./spec/unit/models/presence_message_spec.rb#L545) * #shallow_clone * with inherited attributes from ProtocolMessage - * [creates a duplicate of the message without any ProtocolMessage dependency](./spec/unit/models/presence_message_spec.rb#L516) + * [creates a duplicate of the message without any ProtocolMessage dependency](./spec/unit/models/presence_message_spec.rb#L565) * with embedded attributes for all fields - * [creates a duplicate of the message without any ProtocolMessage dependency](./spec/unit/models/presence_message_spec.rb#L530) + * [creates a duplicate of the message without any ProtocolMessage dependency](./spec/unit/models/presence_message_spec.rb#L579) * with new attributes passed in to the method - * [creates a duplicate of the message without any ProtocolMessage dependency](./spec/unit/models/presence_message_spec.rb#L546) + * [creates a duplicate of the message without any ProtocolMessage dependency](./spec/unit/models/presence_message_spec.rb#L595) * with an invalid ProtocolMessage (missing an ID) - * [allows an ID to be passed in to the shallow clone that takes precedence](./spec/unit/models/presence_message_spec.rb#L558) + * [allows an ID to be passed in to the shallow clone that takes precedence](./spec/unit/models/presence_message_spec.rb#L607) * with mixing of cases - * [resolves case issues and can use camelCase or snake_case](./spec/unit/models/presence_message_spec.rb#L565) + * [resolves case issues and can use camelCase or snake_case](./spec/unit/models/presence_message_spec.rb#L614) ### Ably::Models::ProtocolMessage _(see [spec/unit/models/protocol_message_spec.rb](./spec/unit/models/protocol_message_spec.rb))_ * behaves like a model * attributes @@ -3321,71 +4128,68 @@ * #has_message_serial? * without msg_serial * [returns false](./spec/unit/models/protocol_message_spec.rb#L116) * with msg_serial * [returns true](./spec/unit/models/protocol_message_spec.rb#L124) - * #connection_serial - * [converts :connection_serial to an Integer](./spec/unit/models/protocol_message_spec.rb#L132) * #flags (#TR4i) * when nil - * [is zero](./spec/unit/models/protocol_message_spec.rb#L142) + * [is zero](./spec/unit/models/protocol_message_spec.rb#L134) * when numeric - * [is an Integer](./spec/unit/models/protocol_message_spec.rb#L150) + * [is an Integer](./spec/unit/models/protocol_message_spec.rb#L142) * when presence flag present - * [#has_presence_flag? is true](./spec/unit/models/protocol_message_spec.rb#L158) - * [#has_channel_resumed_flag? is false](./spec/unit/models/protocol_message_spec.rb#L162) + * [#has_presence_flag? is true](./spec/unit/models/protocol_message_spec.rb#L150) + * [#has_channel_resumed_flag? is false](./spec/unit/models/protocol_message_spec.rb#L154) * when channel resumed flag present - * [#has_channel_resumed_flag? is true](./spec/unit/models/protocol_message_spec.rb#L170) - * [#has_presence_flag? is false](./spec/unit/models/protocol_message_spec.rb#L174) + * [#has_channel_resumed_flag? is true](./spec/unit/models/protocol_message_spec.rb#L162) + * [#has_presence_flag? is false](./spec/unit/models/protocol_message_spec.rb#L166) + * when attach resumed flag + * flags is 34 + * [#has_attach_resume_flag? is true](./spec/unit/models/protocol_message_spec.rb#L175) + * [#has_attach_presence_flag? is false](./spec/unit/models/protocol_message_spec.rb#L179) + * flags is 0 + * [should raise an exception if flags is a float number](./spec/unit/models/protocol_message_spec.rb#L187) * when channel resumed and presence flags present - * [#has_channel_resumed_flag? is true](./spec/unit/models/protocol_message_spec.rb#L182) - * [#has_presence_flag? is true](./spec/unit/models/protocol_message_spec.rb#L186) + * [#has_channel_resumed_flag? is true](./spec/unit/models/protocol_message_spec.rb#L196) + * [#has_presence_flag? is true](./spec/unit/models/protocol_message_spec.rb#L200) * when has another future flag - * [#has_presence_flag? is false](./spec/unit/models/protocol_message_spec.rb#L194) - * [#has_backlog_flag? is true](./spec/unit/models/protocol_message_spec.rb#L198) - * #has_connection_serial? - * without connection_serial - * [returns false](./spec/unit/models/protocol_message_spec.rb#L208) - * with connection_serial - * [returns true](./spec/unit/models/protocol_message_spec.rb#L216) - * #serial - * with underlying msg_serial - * [converts :msg_serial to an Integer](./spec/unit/models/protocol_message_spec.rb#L225) - * with underlying connection_serial - * [converts :connection_serial to an Integer](./spec/unit/models/protocol_message_spec.rb#L233) - * with underlying connection_serial and msg_serial - * [prefers connection_serial and converts :connection_serial to an Integer](./spec/unit/models/protocol_message_spec.rb#L241) - * #has_serial? - * without msg_serial or connection_serial - * [returns false](./spec/unit/models/protocol_message_spec.rb#L252) - * with msg_serial - * [returns true](./spec/unit/models/protocol_message_spec.rb#L260) - * with connection_serial - * [returns true](./spec/unit/models/protocol_message_spec.rb#L268) + * [#has_presence_flag? is false](./spec/unit/models/protocol_message_spec.rb#L208) + * [#has_backlog_flag? is true](./spec/unit/models/protocol_message_spec.rb#L212) + * #params (#RTL4k1) + * when present + * [is expected to eq {:foo=>:bar}](./spec/unit/models/protocol_message_spec.rb#L224) + * when empty + * [is expected to eq {}](./spec/unit/models/protocol_message_spec.rb#L230) * #error * with no error attribute - * [returns nil](./spec/unit/models/protocol_message_spec.rb#L278) + * [returns nil](./spec/unit/models/protocol_message_spec.rb#L240) * with nil error - * [returns nil](./spec/unit/models/protocol_message_spec.rb#L286) + * [returns nil](./spec/unit/models/protocol_message_spec.rb#L248) * with error - * [returns a valid ErrorInfo object](./spec/unit/models/protocol_message_spec.rb#L294) + * [returns a valid ErrorInfo object](./spec/unit/models/protocol_message_spec.rb#L256) * #messages (#TR4k) - * [contains Message objects](./spec/unit/models/protocol_message_spec.rb#L304) + * [contains Message objects](./spec/unit/models/protocol_message_spec.rb#L266) + * #messages (#RTL21) + * [contains Message objects in ascending order](./spec/unit/models/protocol_message_spec.rb#L284) * #presence (#TR4l) - * [contains PresenceMessage objects](./spec/unit/models/protocol_message_spec.rb#L314) + * [contains PresenceMessage objects](./spec/unit/models/protocol_message_spec.rb#L296) + * #message_size (#TO3l8) + * on presence + * [should return 13 bytes (sum in bytes: data and client_id)](./spec/unit/models/protocol_message_spec.rb#L309) + * on message + * [should return 76 bytes (sum in bytes: data, client_id, name, extras)](./spec/unit/models/protocol_message_spec.rb#L319) * #connection_details (#TR4o) * with a JSON value - * [contains a ConnectionDetails object](./spec/unit/models/protocol_message_spec.rb#L327) - * [contains the attributes from the JSON connectionDetails](./spec/unit/models/protocol_message_spec.rb#L331) + * [contains a ConnectionDetails object](./spec/unit/models/protocol_message_spec.rb#L331) + * [contains the attributes from the JSON connectionDetails](./spec/unit/models/protocol_message_spec.rb#L335) * without a JSON value - * [contains an empty ConnectionDetails object](./spec/unit/models/protocol_message_spec.rb#L340) + * [contains an empty ConnectionDetails object](./spec/unit/models/protocol_message_spec.rb#L344) * #auth (#TR4p) * with a JSON value - * [contains a AuthDetails object](./spec/unit/models/protocol_message_spec.rb#L354) - * [contains the attributes from the JSON auth details](./spec/unit/models/protocol_message_spec.rb#L358) + * [contains a AuthDetails object](./spec/unit/models/protocol_message_spec.rb#L358) + * [contains the attributes from the JSON auth details](./spec/unit/models/protocol_message_spec.rb#L362) * without a JSON value - * [contains an empty AuthDetails object](./spec/unit/models/protocol_message_spec.rb#L366) + * [contains an empty AuthDetails object](./spec/unit/models/protocol_message_spec.rb#L370) ### Ably::Models::PushChannelSubscription _(see [spec/unit/models/push_channel_subscription_spec.rb](./spec/unit/models/push_channel_subscription_spec.rb))_ * #channel and #channel= * [setter accepts a string value and getter returns the new value](./spec/unit/models/push_channel_subscription_spec.rb#L21) @@ -3573,31 +4377,34 @@ * [retrieves attribute :expires as Time](./spec/unit/models/token_details_spec.rb#L41) * #expires when converted to JSON * [is in milliseconds](./spec/unit/models/token_details_spec.rb#L50) * #expired? * once grace period buffer has passed - * [is true](./spec/unit/models/token_details_spec.rb#L63) + * [is true](./spec/unit/models/token_details_spec.rb#L64) * within grace period buffer - * [is false](./spec/unit/models/token_details_spec.rb#L71) + * [is false](./spec/unit/models/token_details_spec.rb#L72) * when expires is not available (i.e. string tokens) - * [is always false](./spec/unit/models/token_details_spec.rb#L79) + * [is always false](./spec/unit/models/token_details_spec.rb#L80) + * with :from attribute + * [is false](./spec/unit/models/token_details_spec.rb#L90) + * [is true](./spec/unit/models/token_details_spec.rb#L95) * == - * [is true when attributes are the same](./spec/unit/models/token_details_spec.rb#L89) - * [is false when attributes are not the same](./spec/unit/models/token_details_spec.rb#L94) - * [is false when class type differs](./spec/unit/models/token_details_spec.rb#L98) + * [is true when attributes are the same](./spec/unit/models/token_details_spec.rb#L105) + * [is false when attributes are not the same](./spec/unit/models/token_details_spec.rb#L110) + * [is false when class type differs](./spec/unit/models/token_details_spec.rb#L114) * to_json * with all attributes and values - * [returns all attributes](./spec/unit/models/token_details_spec.rb#L130) + * [returns all attributes](./spec/unit/models/token_details_spec.rb#L146) * with only a token string - * [returns populated attributes](./spec/unit/models/token_details_spec.rb#L143) + * [returns populated attributes](./spec/unit/models/token_details_spec.rb#L159) * from_json (#TD7) * with Ruby idiomatic Hash object - * [returns a valid TokenDetails object](./spec/unit/models/token_details_spec.rb#L169) + * [returns a valid TokenDetails object](./spec/unit/models/token_details_spec.rb#L185) * with JSON-like object - * [returns a valid TokenDetails object](./spec/unit/models/token_details_spec.rb#L192) + * [returns a valid TokenDetails object](./spec/unit/models/token_details_spec.rb#L208) * with JSON string - * [returns a valid TokenDetails object](./spec/unit/models/token_details_spec.rb#L214) + * [returns a valid TokenDetails object](./spec/unit/models/token_details_spec.rb#L230) ### Ably::Models::TokenRequest _(see [spec/unit/models/token_request_spec.rb](./spec/unit/models/token_request_spec.rb))_ * behaves like a model * attributes @@ -3737,57 +4544,68 @@ * [raises an argument error](./spec/unit/realtime/channel_spec.rb#L55) * as Nil * [raises an argument error](./spec/unit/realtime/channel_spec.rb#L63) * #publish name argument * as UTF_8 string - * [is permitted](./spec/unit/realtime/channel_spec.rb#L81) + * [is permitted](./spec/unit/realtime/channel_spec.rb#L82) * as SHIFT_JIS string - * [is permitted](./spec/unit/realtime/channel_spec.rb#L89) + * [is permitted](./spec/unit/realtime/channel_spec.rb#L90) * as ASCII_8BIT string - * [is permitted](./spec/unit/realtime/channel_spec.rb#L97) + * [is permitted](./spec/unit/realtime/channel_spec.rb#L98) * as Integer - * [raises an argument error](./spec/unit/realtime/channel_spec.rb#L105) + * [raises an argument error](./spec/unit/realtime/channel_spec.rb#L106) * as Nil - * [is permitted](./spec/unit/realtime/channel_spec.rb#L113) + * [is permitted](./spec/unit/realtime/channel_spec.rb#L114) * callbacks - * [are supported for valid STATE events](./spec/unit/realtime/channel_spec.rb#L120) - * [fail with unacceptable STATE event names](./spec/unit/realtime/channel_spec.rb#L126) + * [are supported for valid STATE events](./spec/unit/realtime/channel_spec.rb#L121) + * [fail with unacceptable STATE event names](./spec/unit/realtime/channel_spec.rb#L127) * subscriptions * #subscribe - * [without a block raises an invalid ArgumentError](./spec/unit/realtime/channel_spec.rb#L168) - * [with no event name specified subscribes the provided block to all events](./spec/unit/realtime/channel_spec.rb#L172) - * [with a single event name subscribes that block to matching events](./spec/unit/realtime/channel_spec.rb#L178) - * [with a multiple event name arguments subscribes that block to all of those event names](./spec/unit/realtime/channel_spec.rb#L185) - * [with a multiple duplicate event name arguments subscribes that block to all of those unique event names once](./spec/unit/realtime/channel_spec.rb#L197) + * [without a block raises an invalid ArgumentError](./spec/unit/realtime/channel_spec.rb#L169) + * [with no event name specified subscribes the provided block to all events](./spec/unit/realtime/channel_spec.rb#L173) + * [with a single event name subscribes that block to matching events](./spec/unit/realtime/channel_spec.rb#L179) + * [with a multiple event name arguments subscribes that block to all of those event names](./spec/unit/realtime/channel_spec.rb#L186) + * [with a multiple duplicate event name arguments subscribes that block to all of those unique event names once](./spec/unit/realtime/channel_spec.rb#L198) * #unsubscribe - * [with no event name specified unsubscribes that block from all events](./spec/unit/realtime/channel_spec.rb#L214) - * [with a single event name argument unsubscribes the provided block with the matching event name](./spec/unit/realtime/channel_spec.rb#L220) - * [with multiple event name arguments unsubscribes each of those matching event names with the provided block](./spec/unit/realtime/channel_spec.rb#L226) - * [with a non-matching event name argument has no effect](./spec/unit/realtime/channel_spec.rb#L232) - * [with no block argument unsubscribes all blocks for the event name argument](./spec/unit/realtime/channel_spec.rb#L238) + * [with no event name specified unsubscribes that block from all events](./spec/unit/realtime/channel_spec.rb#L215) + * [with a single event name argument unsubscribes the provided block with the matching event name](./spec/unit/realtime/channel_spec.rb#L221) + * [with multiple event name arguments unsubscribes each of those matching event names with the provided block](./spec/unit/realtime/channel_spec.rb#L227) + * [with a non-matching event name argument has no effect](./spec/unit/realtime/channel_spec.rb#L233) + * [with no block argument unsubscribes all blocks for the event name argument](./spec/unit/realtime/channel_spec.rb#L239) ### Ably::Realtime::Channels _(see [spec/unit/realtime/channels_spec.rb](./spec/unit/realtime/channels_spec.rb))_ * creating channels - * [[] creates a channel](./spec/unit/realtime/channels_spec.rb#L43) + * [[] creates a channel](./spec/unit/realtime/channels_spec.rb#L81) * #get - * [creates a channel if it does not exist](./spec/unit/realtime/channels_spec.rb#L14) + * when channel doesn't exist + * hash + * [is expected to be a kind of Hash](./spec/unit/realtime/channels_spec.rb#L28) + * [creates a channel (RTS3a)](./spec/unit/realtime/channels_spec.rb#L20) + * ChannelOptions object + * [is expected to be a kind of Ably::Models::ChannelOptions](./spec/unit/realtime/channels_spec.rb#L35) + * [creates a channel (RTS3a)](./spec/unit/realtime/channels_spec.rb#L20) * when an existing channel exists - * [will reuse a channel object if it exists](./spec/unit/realtime/channels_spec.rb#L20) - * [will update the options on the channel if provided](./spec/unit/realtime/channels_spec.rb#L26) - * [will leave the options intact on the channel if not provided](./spec/unit/realtime/channels_spec.rb#L34) + * [will update the options on the channel if provided (RSN3c)](./spec/unit/realtime/channels_spec.rb#L64) + * [will leave the options intact on the channel if not provided](./spec/unit/realtime/channels_spec.rb#L72) + * hash + * [is expected to be a kind of Hash](./spec/unit/realtime/channels_spec.rb#L52) + * [will reuse a channel object if it exists (RTS3a)](./spec/unit/realtime/channels_spec.rb#L43) + * ChannelOptions object + * [is expected to be a kind of Ably::Models::ChannelOptions](./spec/unit/realtime/channels_spec.rb#L59) + * [will reuse a channel object if it exists (RTS3a)](./spec/unit/realtime/channels_spec.rb#L43) * #fetch - * [retrieves a channel if it exists](./spec/unit/realtime/channels_spec.rb#L50) - * [calls the block if channel is missing](./spec/unit/realtime/channels_spec.rb#L55) + * [retrieves a channel if it exists](./spec/unit/realtime/channels_spec.rb#L88) + * [calls the block if channel is missing](./spec/unit/realtime/channels_spec.rb#L93) * destroying channels - * [#release detaches and then releases the channel resources](./spec/unit/realtime/channels_spec.rb#L63) + * [#release detaches and then releases the channel resources](./spec/unit/realtime/channels_spec.rb#L101) * is Enumerable - * [allows enumeration](./spec/unit/realtime/channels_spec.rb#L80) - * [provides #length](./spec/unit/realtime/channels_spec.rb#L96) + * [allows enumeration](./spec/unit/realtime/channels_spec.rb#L118) + * [provides #length](./spec/unit/realtime/channels_spec.rb#L134) * #each - * [returns an enumerator](./spec/unit/realtime/channels_spec.rb#L85) - * [yields each channel](./spec/unit/realtime/channels_spec.rb#L89) + * [returns an enumerator](./spec/unit/realtime/channels_spec.rb#L123) + * [yields each channel](./spec/unit/realtime/channels_spec.rb#L127) ### Ably::Realtime::Client _(see [spec/unit/realtime/client_spec.rb](./spec/unit/realtime/client_spec.rb))_ * behaves like a client initializer * with invalid arguments @@ -3933,10 +4751,17 @@ ### Ably::Realtime _(see [spec/unit/realtime/realtime_spec.rb](./spec/unit/realtime/realtime_spec.rb))_ * [constructor returns an Ably::Realtime::Client](./spec/unit/realtime/realtime_spec.rb#L6) +### Ably::Realtime::RecoveryKeyContext +_(see [spec/unit/realtime/recovery_key_context_spec.rb](./spec/unit/realtime/recovery_key_context_spec.rb))_ + * connection recovery key + * [should encode recovery key - RTN16i, RTN16f, RTN16j](./spec/unit/realtime/recovery_key_context_spec.rb#L8) + * [should decode recovery key - RTN16i, RTN16f, RTN16j](./spec/unit/realtime/recovery_key_context_spec.rb#L21) + * [should return nil for invalid recovery key - RTN16i, RTN16f, RTN16j](./spec/unit/realtime/recovery_key_context_spec.rb#L29) + ### Ably::Models::ProtocolMessage _(see [spec/unit/realtime/safe_deferrable_spec.rb](./spec/unit/realtime/safe_deferrable_spec.rb))_ * behaves like a safe Deferrable * #errback * [adds a callback that is called when #fail is called](./spec/shared/safe_deferrable_behaviour.rb#L15) @@ -3979,54 +4804,87 @@ ### Ably::Rest::Channel _(see [spec/unit/rest/channel_spec.rb](./spec/unit/rest/channel_spec.rb))_ * #initializer * as UTF_8 string - * [is permitted](./spec/unit/rest/channel_spec.rb#L23) - * [remains as UTF-8](./spec/unit/rest/channel_spec.rb#L27) + * [is permitted](./spec/unit/rest/channel_spec.rb#L24) + * [remains as UTF-8](./spec/unit/rest/channel_spec.rb#L28) * as frozen UTF_8 string - * [is permitted](./spec/unit/rest/channel_spec.rb#L36) - * [remains as UTF-8](./spec/unit/rest/channel_spec.rb#L40) + * [is permitted](./spec/unit/rest/channel_spec.rb#L37) + * [remains as UTF-8](./spec/unit/rest/channel_spec.rb#L41) * as SHIFT_JIS string - * [gets converted to UTF-8](./spec/unit/rest/channel_spec.rb#L48) - * [is compatible with original encoding](./spec/unit/rest/channel_spec.rb#L52) + * [gets converted to UTF-8](./spec/unit/rest/channel_spec.rb#L49) + * [is compatible with original encoding](./spec/unit/rest/channel_spec.rb#L53) * as ASCII_8BIT string - * [gets converted to UTF-8](./spec/unit/rest/channel_spec.rb#L60) - * [is compatible with original encoding](./spec/unit/rest/channel_spec.rb#L64) + * [gets converted to UTF-8](./spec/unit/rest/channel_spec.rb#L61) + * [is compatible with original encoding](./spec/unit/rest/channel_spec.rb#L65) * as Integer - * [raises an argument error](./spec/unit/rest/channel_spec.rb#L72) + * [raises an argument error](./spec/unit/rest/channel_spec.rb#L73) * as Nil - * [raises an argument error](./spec/unit/rest/channel_spec.rb#L80) + * [raises an argument error](./spec/unit/rest/channel_spec.rb#L81) * #publish name argument * as UTF_8 string - * [is permitted](./spec/unit/rest/channel_spec.rb#L92) + * [is permitted](./spec/unit/rest/channel_spec.rb#L93) * as frozen UTF_8 string - * [is permitted](./spec/unit/rest/channel_spec.rb#L101) + * [is permitted](./spec/unit/rest/channel_spec.rb#L102) * as SHIFT_JIS string - * [is permitted](./spec/unit/rest/channel_spec.rb#L109) + * [is permitted](./spec/unit/rest/channel_spec.rb#L110) * as ASCII_8BIT string - * [is permitted](./spec/unit/rest/channel_spec.rb#L117) + * [is permitted](./spec/unit/rest/channel_spec.rb#L118) * as Integer - * [raises an argument error](./spec/unit/rest/channel_spec.rb#L125) + * [raises an argument error](./spec/unit/rest/channel_spec.rb#L126) + * max message size exceeded + * when max_message_size is nil + * and a message size is 65537 bytes + * [should raise Ably::Exceptions::MaxMessageSizeExceeded](./spec/unit/rest/channel_spec.rb#L134) + * when max_message_size is 65536 bytes + * and a message size is 65537 bytes + * [should raise Ably::Exceptions::MaxMessageSizeExceeded](./spec/unit/rest/channel_spec.rb#L144) + * and a message size is 10 bytes + * [should send a message](./spec/unit/rest/channel_spec.rb#L150) + * when max_message_size is 10 bytes + * and a message size is 11 bytes + * [should raise Ably::Exceptions::MaxMessageSizeExceeded](./spec/unit/rest/channel_spec.rb#L160) + * and a message size is 2 bytes + * [should send a message](./spec/unit/rest/channel_spec.rb#L166) ### Ably::Rest::Channels _(see [spec/unit/rest/channels_spec.rb](./spec/unit/rest/channels_spec.rb))_ - * creating channels - * [#get creates a channel](./spec/unit/rest/channels_spec.rb#L12) - * [#get will reuse the channel object](./spec/unit/rest/channels_spec.rb#L17) - * [[] creates a channel](./spec/unit/rest/channels_spec.rb#L23) + * [[] creates a channel](./spec/unit/rest/channels_spec.rb#L91) + * #get + * when channel doesn't exist + * hash + * [is expected to be a kind of Hash](./spec/unit/rest/channels_spec.rb#L24) + * [creates a channel (RSN3a)](./spec/unit/rest/channels_spec.rb#L16) + * ChannelOptions object + * [is expected to be a kind of Ably::Models::ChannelOptions](./spec/unit/rest/channels_spec.rb#L31) + * [creates a channel (RSN3a)](./spec/unit/rest/channels_spec.rb#L16) + * when an existing channel exists + * hash + * [is expected to be a kind of Hash](./spec/unit/rest/channels_spec.rb#L48) + * [will reuse a channel object if it exists (RSN3a)](./spec/unit/rest/channels_spec.rb#L39) + * ChannelOptions object + * [is expected to be a kind of Ably::Models::ChannelOptions](./spec/unit/rest/channels_spec.rb#L55) + * [will reuse a channel object if it exists (RSN3a)](./spec/unit/rest/channels_spec.rb#L39) + * with new channel_options modes + * hash + * [is expected to be a kind of Hash](./spec/unit/rest/channels_spec.rb#L76) + * [will update channel with provided options modes (RSN3c)](./spec/unit/rest/channels_spec.rb#L62) + * ChannelOptions object + * [is expected to be a kind of Ably::Models::ChannelOptions](./spec/unit/rest/channels_spec.rb#L83) + * [will update channel with provided options modes (RSN3c)](./spec/unit/rest/channels_spec.rb#L62) * #fetch - * [retrieves a channel if it exists](./spec/unit/rest/channels_spec.rb#L30) - * [calls the block if channel is missing](./spec/unit/rest/channels_spec.rb#L35) + * [retrieves a channel if it exists](./spec/unit/rest/channels_spec.rb#L97) + * [calls the block if channel is missing](./spec/unit/rest/channels_spec.rb#L102) * destroying channels - * [#release releases the channel resoures](./spec/unit/rest/channels_spec.rb#L43) + * [#release releases the channel resoures](./spec/unit/rest/channels_spec.rb#L110) * is Enumerable - * [allows enumeration](./spec/unit/rest/channels_spec.rb#L59) - * [provides #length](./spec/unit/rest/channels_spec.rb#L75) + * [allows enumeration](./spec/unit/rest/channels_spec.rb#L126) + * [provides #length](./spec/unit/rest/channels_spec.rb#L142) * #each - * [returns an enumerator](./spec/unit/rest/channels_spec.rb#L64) - * [yields each channel](./spec/unit/rest/channels_spec.rb#L68) + * [returns an enumerator](./spec/unit/rest/channels_spec.rb#L131) + * [yields each channel](./spec/unit/rest/channels_spec.rb#L135) ### Ably::Rest::Client _(see [spec/unit/rest/client_spec.rb](./spec/unit/rest/client_spec.rb))_ * behaves like a client initializer * with invalid arguments @@ -4126,24 +4984,37 @@ * fallback_retry_timeout (#RSC15f) * default * [is set to 10 minutes](./spec/unit/rest/client_spec.rb#L27) * when provided * [configures a new timeout](./spec/unit/rest/client_spec.rb#L35) + * use agent + * set agent to non-default value + * default agent + * [should return default ably agent](./spec/unit/rest/client_spec.rb#L46) + * custom agent + * [should overwrite client.agent](./spec/unit/rest/client_spec.rb#L54) * :use_token_auth * set to false * with a key and :tls => false - * [fails for any operation with basic auth and attempting to send an API key over a non-secure connection](./spec/unit/rest/client_spec.rb#L46) + * [fails for any operation with basic auth and attempting to send an API key over a non-secure connection](./spec/unit/rest/client_spec.rb#L66) * without a key - * [fails as a key is required if not using token auth](./spec/unit/rest/client_spec.rb#L54) + * [fails as a key is required if not using token auth](./spec/unit/rest/client_spec.rb#L74) * set to true * without a key or token - * [fails as a key is required to issue tokens](./spec/unit/rest/client_spec.rb#L64) + * [fails as a key is required to issue tokens](./spec/unit/rest/client_spec.rb#L84) + * max_message_size + * is not present + * [should return default 65536 (#TO3l8)](./spec/unit/rest/client_spec.rb#L95) + * is nil + * [should return default 65536 (#TO3l8)](./spec/unit/rest/client_spec.rb#L103) + * is customized 131072 bytes + * [should return 131072](./spec/unit/rest/client_spec.rb#L112) * request_id generation - * [includes request_id in URL](./spec/unit/rest/client_spec.rb#L74) + * [includes request_id in URL](./spec/unit/rest/client_spec.rb#L121) * push - * [#device is not supported and raises an exception](./spec/unit/rest/client_spec.rb#L82) - * [#push returns a Push object](./spec/unit/rest/client_spec.rb#L86) + * [#device is not supported and raises an exception](./spec/unit/rest/client_spec.rb#L129) + * [#push returns a Push object](./spec/unit/rest/client_spec.rb#L133) ### Ably::Rest::Channel::PushChannel _(see [spec/unit/rest/push_channel_spec.rb](./spec/unit/rest/push_channel_spec.rb))_ * [is constructed with a channel](./spec/unit/rest/push_channel_spec.rb#L10) * [raises an exception if constructed with an invalid type](./spec/unit/rest/push_channel_spec.rb#L14) @@ -4173,15 +5044,13 @@ * [raises an exception](./spec/unit/util/crypto_spec.rb#L47) * with a base64-encoded :key param * [converts the key to binary](./spec/unit/util/crypto_spec.rb#L55) * with provided params * [overrides the defaults](./spec/unit/util/crypto_spec.rb#L67) - * encrypts & decrypt - * [#encrypt encrypts a string](./spec/unit/util/crypto_spec.rb#L79) - * [#decrypt decrypts a string](./spec/unit/util/crypto_spec.rb#L84) - * encrypting an empty string - * [raises an ArgumentError](./spec/unit/util/crypto_spec.rb#L93) + * #encrypt & #decrypt + * [encrypts and decrypts a non-empty string](./spec/unit/util/crypto_spec.rb#L79) + * [encrypts and decrypts an empty string](./spec/unit/util/crypto_spec.rb#L88) * using shared client lib fixture data * with AES-128-CBC * behaves like an Ably encrypter and decrypter (#RTL7d) * text payload * [encrypts exactly the same binary data as other client libraries](./spec/unit/util/crypto_spec.rb#L116) @@ -4204,8 +5073,8 @@ ------- ## Test summary - * Passing tests: 2109 - * Pending tests: 5 - * Failing tests: 1 + * Passing tests: 2491 + * Pending tests: 7 + * Failing tests: 2