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, &block)
      ws = listen("#{@url}/listeners/#{listener_id}")
      ws
    end

    def action(action_id, &block)
      ws = listen("#{@url}/actions/#{action_id}")
      ws
    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

2 entries across 2 versions & 1 rubygems

Version	Path
factor-0.5.05	lib/listener.rb
factor-0.5.04	lib/listener.rb