Contents

# encoding: UTF-8

require 'rest_client'
require 'websocket_manager'

module Factor
  # Class Listener for integrating with connector service
  class Listener
    def initialize(url)
      @url = url
    end

    def definition
      get("#{@url}/definition")
    end

    def listener(listener_id)
      listen("#{@url}/listeners/#{listener_id}")
    end

    def action(action_id)
      listen("#{@url}/actions/#{action_id}")
    end

    private

    def post(uri_path, payload)
      content = { 'payload' => MultiJson.dump(payload) }
      JSON.parse(RestClient.post(uri_path, content))
    end

    def get(uri_path)
      JSON.parse(RestClient.get(uri_path))
    end

    def delete(uri_path)
      JSON.parse(RestClient.delete(uri_path))
    end

    def listen(uri_path)
      WebSocketManager.new(uri_path)
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
factor-0.5.13	lib/listener.rb
factor-0.5.12	lib/listener.rb
factor-0.5.10	lib/listener.rb
factor-0.5.09	lib/listener.rb
factor-0.5.08	lib/listener.rb
factor-0.5.07	lib/listener.rb
factor-0.5.06	lib/listener.rb