Sha256: 7d715cc571ae00e35c3ba7e602e2618aa21a5c8b5e607a031e3793eb27cdcbe5
Contents?: true
Size: 1.69 KB
Versions: 20
Compression:
Stored size: 1.69 KB
Contents
%w( v1 ).each do |lib|
require "scooter/httpdispatchers/activity/v1/#{lib}"
end
module Scooter
module HttpDispatchers
module Activity
include Scooter::HttpDispatchers::Activity::V1
include Scooter::Utilities
def set_activity_service_path(connection=self.connection)
set_url_prefix
connection.url_prefix.path = '/activity-api'
end
# Used to compare replica activity to master. Raises exception if it does not match.
# @param [String] host_name
def activity_database_matches_self?(replica_host)
# Save a beaker host_hash[:vmhostname], set it to the supplied host_name param,
# and then set it back to the original at the end of the ensure. The :vmhostname
#overrides the host.hostname, and nothing should win out over it.
original_host_name = host.host_hash[:vmhostname]
begin
host.host_hash[:vmhostname] = replica_host.hostname
other_rbac_events = get_rbac_events.env.body
other_classifier_events = get_classifier_events.env.body
ensure
host.host_hash[:vmhostname] = original_host_name
end
self_rbac_events = get_rbac_events.env.body
self_classifier_events = get_classifier_events.env.body
rbac_events_match = other_rbac_events == self_rbac_events
classifier_events_match = other_classifier_events == self_classifier_events
errors = ''
errors << "Rbac events do not match\r\n" unless rbac_events_match
errors << "Classifier events do not match\r\n" unless classifier_events_match
host.logger.warn(errors.chomp) unless errors.empty?
errors.empty?
end
end
end
end
Version data entries
20 entries across 20 versions & 1 rubygems