Class: Riaction::EventPerformer

Inherits:
Object
  • Object
show all
Extended by:
ApiFailure
Defined in:
lib/riaction/event_performer.rb

Class Method Summary collapse

Methods included from ApiFailure

default_behavior, handle_api_failure, handle_api_failure_with

Class Method Details

.check_class_requirements!(event_name, klass_name) ⇒ Object 



25
26
27
28
29
30
31
 
# File 'lib/riaction/event_performer.rb', line 25

def self.check_class_requirements!(event_name, klass_name)
  unless  klass_name.constantize.riactionary? &&
          klass_name.constantize.riaction_events? &&
          klass_name.constantize.riaction_defines_event?(event_name.to_sym)
    raise ::Riaction::ConfigurationError.new("#{klass_name} does not define event #{event_name}")
  end
end

.handle_api_failure(exception, event_name, klass_name, id) ⇒ Object 



49
50
51
52
53
54
55
56
57
 
# File 'lib/riaction/event_performer.rb', line 49

def self.handle_api_failure(exception, event_name, klass_name, id)
  if @api_failure_handler_block
    if @api_failure_handler_block.call(exception, event_name, klass_name, id)
      Resque.enqueue(self, event_name, klass_name, id)
    end
  else
    default_behavior(exception)
  end
end

.log_event(event_name, klass_name, id) ⇒ Object 



33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
 
# File 'lib/riaction/event_performer.rb', line 33

def self.log_event(event_name, klass_name, id)
  iactionable_api = IActionable::Api.new      
  if event_object = klass_name.constantize.find_by_id(id)
    event_params = event_object.riaction_event_params
    if event_params.has_key?(event_name.to_sym)
          iactionable_api.log_event(  event_params[event_name.to_sym][:profile][:type],
                                      event_params[event_name.to_sym][:profile][:id_type],
                                      event_params[event_name.to_sym][:profile][:id],
                                      event_name.to_sym,
                                      event_params[event_name.to_sym][:params])
    else
      raise ::Riaction::ConfigurationError.new("Instance of #{klass_name} with ID #{id} could not construct event parameters for event #{event_name}.  Is the profile a valid one?")
    end
  end
end

.perform(event_name, klass_name, id, attempt = 0) ⇒ Object

Sends an event to IActionable based on the name of a riaction class and the ID used to locate the instance



11
12
13
14
15
16
17
18
19
20
21
22
23
 
# File 'lib/riaction/event_performer.rb', line 11

def self.perform(event_name, klass_name, id, attempt=0)
  check_class_requirements!(event_name, klass_name)
  begin
    log_event(event_name, klass_name, id)
  rescue IActionable::Error::BadRequest => e
    # Log event should never throw this as of IActionable API v3
  rescue Faraday::Error::TimeoutError, Timeout::Error => e
    Resque.enqueue(self, event_name, klass_name, id, attempt+1)
  rescue IActionable::Error::Internal => e
    # handle_api_failure(event_name, klass_name, id, attempt)
    handle_api_failure(e, event_name, klass_name, id)
  end
end