socket_adapter.js.coffee

class @SocketAdapter
  constructor: (@aggregator, @socket_url) ->
    @websocket = new WebSocket(@socket_url)
    @websocket.onmessage = message_processor

  publish: (args...) =>
    @aggregator.trigger args...

  message_processor: (event) =>
    message = JSON.parse(event.data)

    switch message.type
      when "value"
        publish("socket:value", message.data)