Add test for connectionId attribute for a message sent over REST

[mattheworiordan]

If connected to Ably with echo_messages false, and a message is published over REST with the connection ID matching the realtime connected client, the message should not be received by that client.

Create a spec and update the docs repo to reflect this param

[mattheworiordan]

@paddybyers please can you take a look at a test that I added to cover the above functionality at b14f914. It fails unfortunately, so not sure if I have misunderstood something, or if this is a realtime bug.

Also, on a separate note, can you explain how we prevent any client posting messages on behalf of another client with with the connectionId param given the connectionId is a public property of a presence member?

Ably::Realtime::Channel Message
  using JSON protocol
    local echo when published
      with :echo_messages option set to false
17:17:35.543 DEBUG [ -- ] Ably::Realtime::Channel: Transitioned to attaching
17:17:35.543 DEBUG [ -- ] Ably::Realtime::Channel: StateEmitter changed from STATE.Initialized => attaching
17:17:35.544 DEBUG [ -- ] Ably::Realtime::Connection: Transitioned to connecting
17:17:35.544 DEBUG [ -- ] Ably::Realtime::Connection: StateEmitter changed from STATE.Initialized => connecting
17:17:35.544 DEBUG [ -- ] ConnectionManager: Opening a websocket transport connection
17:17:35.554 DEBUG [ -- ] ConnectionManager: Setting up automatic connection timeout timer for 15s
17:17:35.555 DEBUG [ -- ] Connection: Prot msg queued =>: ACTION.Attach {"action":10,"channel":"subscribe_send_text-670e09d3f27a223f68f2bfdd92a83b07"}
17:17:35.555 DEBUG [ -- ] Connection: Opening socket connection to sandbox-realtime.ably.io:443 and URL 'wss://sandbox-realtime.ably.io?key=RJmb4w.oyEXCg%3AQ3_yw8eiujTgAU5D&timestamp=1441383455555&format=json&echo=false'
17:17:35.559 DEBUG [ -- ] Ably::Realtime::Connection::WebsocketTransport: StateEmitter changed from STATE.Initialized => STATE.Connecting
17:17:35.578 DEBUG [ -- ] Ably::Realtime::Connection::WebsocketTransport: StateEmitter changed from STATE.Connecting => STATE.Connected
17:17:35.898 DEBUG [ -- ] WebsocketTransport: socket opened to wss://sandbox-realtime.ably.io?key=RJmb4w.oyEXCg%3AQ3_yw8eiujTgAU5D&timestamp=1441383455555&format=json&echo=false, waiting for Connected protocol message
17:17:35.900 DEBUG [ -- ] WebsocketTransport: Prot msg recv <=: ACTION.Connected - {"action"=>4, "connectionId"=>"NrK8crY5E0", "connectionKey"=>"NrK8crY5E0JMQ701", "connectionSerial"=>-1}
17:17:35.901 DEBUG [ -- ] ACTION.Connected received: {"action":4,"connectionId":"NrK8crY5E0","connectionKey":"NrK8crY5E0JMQ701","connectionSerial":-1}
17:17:35.901 DEBUG [ -- ] ConnectionManager: New connection created with ID NrK8crY5E0 and key NrK8crY5E0JMQ701
17:17:35.901 DEBUG [NrK8crY5E0] Ably::Realtime::Connection: Transitioned from connecting => connected
17:17:35.901 DEBUG [NrK8crY5E0] Ably::Realtime::Connection: StateEmitter changed from STATE.Connecting => connected
17:17:35.903 DEBUG [NrK8crY5E0] WebsocketTransport: Prot msg sent =>: ACTION.Attach {"action":10,"channel":"subscribe_send_text-670e09d3f27a223f68f2bfdd92a83b07"}
17:17:36.463 DEBUG [NrK8crY5E0] WebsocketTransport: Prot msg recv <=: ACTION.Attached - {"action"=>11, "channel"=>"subscribe_send_text-670e09d3f27a223f68f2bfdd92a83b07", "channelSerial"=>"728c219128426:-1"}
17:17:36.464 DEBUG [NrK8crY5E0] ACTION.Attached received: {"action":11,"channel":"subscribe_send_text-670e09d3f27a223f68f2bfdd92a83b07","channelSerial":"728c219128426:-1"}
17:17:36.465 DEBUG [NrK8crY5E0] Ably::Realtime::Presence::MembersMap: StateEmitter changed from STATE.Initialized => in_sync
17:17:36.465 DEBUG [NrK8crY5E0] Ably::Realtime::Channel: Transitioned from attaching => attached
17:17:36.465 DEBUG [NrK8crY5E0] Ably::Realtime::Channel: StateEmitter changed from STATE.Attaching => attached
17:17:36.468 DEBUG => URL: post https://sandbox-rest.ably.io/channels/subscribe_send_text-670e09d3f27a223f68f2bfdd92a83b07/publish, Headers: Content-Type: "application/json", Accept: "application/json", User-Agent: "Ably Ruby client 0.8.3 (https://www.ably.io)", Authorization: "Basic UkptYjR3Lm95RVhDZzpRM195dzhlaXVqVGdBVTVE"
17:17:36.468 DEBUG => Body: {"name":"test_event","connectionId":"NrK8crY5E0"}
17:17:36.570 DEBUG <= Status: 201, Headers: access-control-allow-credentials: "true", access-control-allow-origin: "*", access-control-expose-headers: "Link", content-type: "application/json", date: "Fri, 04 Sep 2015 16:17:36 GMT", server: "nginx", vary: "Origin", x-ably-serverid: "frontend.3e86.sandbox-eu-central-1-A.i-aaf1c864", content-length: "2", connection: "Close", Ably-Middleware-Parsed: true
17:17:36.570 DEBUG <= Body:
17:17:36.571 DEBUG [NrK8crY5E0] WebsocketTransport: Prot msg recv <=: ACTION.Message - {"action"=>15, "id"=>"LZkuSTLbIn-0", "count"=>10, "channel"=>"subscribe_send_text-670e09d3f27a223f68f2bfdd92a83b07", "channelSerial"=>"728c219128426:0", "connectionSerial"=>0, "timestamp"=>1441383456410, "messages"=>[{"name"=>"test_event", "connectionId"=>"NrK8crY5E0", "timestamp"=>1441383456410}]}
17:17:36.572 DEBUG [NrK8crY5E0] ACTION.Message received: {"action":15,"id":"LZkuSTLbIn-0","count":10,"channel":"subscribe_send_text-670e09d3f27a223f68f2bfdd92a83b07","channelSerial":"728c219128426:0","connectionSerial":0,"timestamp":1441383456410,"messages":[{"name":"test_event","connectionId":"NrK8crY5E0","timestamp":1441383456410}]}
17:17:36.573 DEBUG [NrK8crY5E0] Ably::Realtime::Connection: Transitioned from connected => closing
17:17:36.573 DEBUG [NrK8crY5E0] Ably::Realtime::Connection: StateEmitter changed from STATE.Connected => closing
17:17:36.574 DEBUG [NrK8crY5E0] Connection: Prot msg queued =>: ACTION.Close {"action":7}
17:17:36.574 DEBUG [NrK8crY5E0] Ably::Realtime::Connection::WebsocketTransport: StateEmitter changed from STATE.Connected => STATE.Disconnected
17:17:36.574 DEBUG [NrK8crY5E0] ConnectionManager: Unsubscribed from all events from current transport
17:17:36.574 DEBUG [NrK8crY5E0] Ably::Realtime::Connection: Transitioned from closing => closed
17:17:36.575 DEBUG [NrK8crY5E0] Ably::Realtime::Connection: StateEmitter changed from STATE.Closing => closed
17:17:36.575 DEBUG [NrK8crY5E0] Ably::Realtime::Channel: Transitioned from attached => detaching
17:17:36.575 DEBUG [NrK8crY5E0] Ably::Realtime::Channel: StateEmitter changed from STATE.Attached => detaching
17:17:36.575 DEBUG [NrK8crY5E0] Ably::Realtime::Channel: Transitioned from detaching => detached
17:17:36.575 DEBUG [NrK8crY5E0] Ably::Realtime::Channel: StateEmitter changed from STATE.Detaching => detached
17:17:36.575 DEBUG [NrK8crY5E0] Ably::Realtime::Presence: Transitioned to left
17:17:36.575 DEBUG [NrK8crY5E0] Ably::Realtime::Presence: StateEmitter changed from STATE.Initialized => left
        will not echo messages to the client from other REST clients publishing using that connection_ID (FAILED - 1)