module DTK::Client::Poller
Constants
- PERIOD_WAIT_TIME
Public Instance Methods
poller_response(wait_time = PERIOD_WAIT_TIME) { || ... }
click to toggle source
# File lib/commands/common/thor/poller.rb, line 23 def poller_response(wait_time = PERIOD_WAIT_TIME) begin response = nil thread = Thread.new(self) do |main_thread| begin while true messages_response = main_thread.get main_thread.rest_url("messages/retrieve") print_response(messages_response.data) if messages_response.ok? sleep(wait_time) end rescue => e puts e.message pp e.backtrace end end response = yield ensure thread.kill end response end
print_response(message_array)
click to toggle source
# File lib/commands/common/thor/poller.rb, line 46 def print_response(message_array) message_array.each do |msg| DTK::Client::OsUtil.print(msg['message'], resolve_type(msg['type'])) end end
resolve_type(message_type)
click to toggle source
# File lib/commands/common/thor/poller.rb, line 52 def resolve_type(message_type) case message_type.to_sym when :info :white when :warning :yellow when :error :red else :white end end