module HubClient
Constants
- HUB_VERSION
- VERSION
Public Class Methods
configuration()
click to toggle source
# File lib/hub_client/configuration.rb, line 6 def self.configuration @configuration ||= Configuration.new end
configuration=(config)
click to toggle source
# File lib/hub_client/configuration.rb, line 10 def self.configuration=(config) @configuration = config end
configure() { |configuration| ... }
click to toggle source
# File lib/hub_client/configuration.rb, line 18 def self.configure yield(configuration) if block_given? end
logger()
click to toggle source
# File lib/hub_client/logger.rb, line 10 def self.logger @logger ||= Logger.new end
publish(type, content, env = nil)
click to toggle source
# File lib/hub_client.rb, line 7 def self.publish(type, content, env = nil) raise ConfigArgumentMissing, "endpoint_url missing" unless HubClient.configuration.endpoint_url payload = { type: type, content: content.to_json } payload[:env] = HubClient.configuration.env if HubClient.configuration.env payload[:env] = env if env hub_url = build_hub_url(HubClient.configuration.endpoint_url) RestClient.post(hub_url, payload, content_type: :json) do |response, request, result| handle_response(response, request, result) end end
reset_configuration()
click to toggle source
# File lib/hub_client/configuration.rb, line 14 def self.reset_configuration @configuration = Configuration.new end
Private Class Methods
build_hub_url(endpoint_url)
click to toggle source
# File lib/hub_client.rb, line 23 def self.build_hub_url(endpoint_url) endpoint_url = endpoint_url.gsub(/\/$/, '') # remove last '/' if exists "#{endpoint_url}/api/#{HUB_VERSION}/messages" end
handle_response(response, request, result)
click to toggle source
# File lib/hub_client.rb, line 28 def self.handle_response(response, request, result) # When request didn't succeed we log it unless result.code.start_with?("2") HubClient.logger.info("HubClient Code: #{result.code} Response: #{response} Request: #{request.args}") end end