class Kameleoon::Managers::Warehouse::WarehouseManager
def get_visitor_warehouse_audience(visitor_code, custom_data_index, warehouse_key = nil, timeout = nil)
def get_visitor_warehouse_audience(visitor_code, custom_data_index, warehouse_key = nil, timeout = nil) Logging::KameleoonLogger.debug( "CALL: WarehouseManager.get_visitor_warehouse_audience(visitor_code: '%s', custom_data_index: %s," \ " warehouse_key: '%s', timeout: %s)", visitor_code, custom_data_index, warehouse_key, timeout ) Utils::VisitorCode.validate(visitor_code) remote_data_key = warehouse_key.nil? || warehouse_key.empty? ? visitor_code : warehouse_key response = @network_manager.get_remote_data(remote_data_key, timeout) unless response.is_a?(String) Logging::KameleoonLogger.debug( "RETURN: WarehouseManager.get_visitor_warehouse_audience(visitor_code: '%s', custom_data_index: %s," \ " warehouse_key: '%s', timeout: %s) -> (custom_data: nil)", visitor_code, custom_data_index, warehouse_key, timeout ) return nil end remote_data = JSON.parse(response) warehouse_audiences = remote_data.is_a?(Hash) ? remote_data[WAREHOUSE_AUDIENCES_FIELD_NAME] : nil data_values = warehouse_audiences.is_a?(Hash) ? warehouse_audiences.keys : [] warehouse_audiences_data = CustomData.new(custom_data_index, *data_values) @visitor_manager.add_data(visitor_code, warehouse_audiences_data) Logging::KameleoonLogger.debug( "RETURN: WarehouseManager.get_visitor_warehouse_audience(visitor_code: '%s', custom_data_index: %s," \ " warehouse_key: '%s', timeout: %s) -> (custom_data: %s)", visitor_code, custom_data_index, warehouse_key, timeout, warehouse_audiences_data ) warehouse_audiences_data end
def initialize(network_manager, visitor_manager)
def initialize(network_manager, visitor_manager) Logging::KameleoonLogger.debug('CALL: WarehouseManager.new(networkManager, visitorManager)') @network_manager = network_manager @visitor_manager = visitor_manager Logging::KameleoonLogger.debug('RETURN: WarehouseManager.new(networkManager, visitorManager)') end