Contents

# Class for Polling Service
class K2Polling
  include K2Validation, K2Utilities
  attr_reader :location_url, :k2_response_body
  attr_accessor :access_token

  # Initialize with access token
  def initialize(access_token)
    raise ArgumentError, 'Nil or Empty Access Token Given!' if access_token.blank?
    @threads = []
    @access_token = access_token
  end

  def poll(params)
    k2_request_body = {
      scope: params[:scope],
      scope_reference: params[:scope_reference],
      from_time: params[:from_time],
      to_time: params[:to_time],
      _links: { callback_url: params[:callback_url] }
    }
    poll_hash = make_hash(K2Config.path_url('poll'), 'post', @access_token,'Polling', k2_request_body)
    @location_url =  K2Connect.make_request(poll_hash)
  end

  # Retrieve your newly created polling request by its resource location
  def query_resource(location_url = @location_url)
    query_hash = make_hash(location_url, 'get', @access_token, 'Polling', nil)
    @threads << Thread.new do
      sleep 0.25
      @k2_response_body = K2Connect.make_request(query_hash)
    end
    @threads.each(&:join)
  end

  # Retrieve your newly created polling request by specific resource location
  def query_resource_url(url)
    query_resource(url)
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
k2-connect-ruby-2.0.0	lib/k2-connect-ruby/k2_entity/k2_polling.rb
k2-connect-ruby-1.0.0	lib/k2-connect-ruby/k2_entity/k2_polling.rb