Class: Delayed::PerformableMethod

Inherits:
Struct
  • Object
show all
Defined in:
lib/delayed/performable_method.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(object, method, args = [], fail_cb = nil, permanent_fail_cb = nil) ⇒ PerformableMethod

Returns a new instance of PerformableMethod.

Raises:

  • (NoMethodError) 


3
4
5
6
7
8
9
10
11
 
# File 'lib/delayed/performable_method.rb', line 3

def initialize(object, method, args = [], fail_cb = nil, permanent_fail_cb = nil)
  raise NoMethodError, "undefined method `#{method}' for #{object.inspect}" unless object.respond_to?(method, true)

  self.object = object
  self.args   = args
  self.method = method.to_sym
  self.fail_cb           = fail_cb
  self.permanent_fail_cb = permanent_fail_cb
end

Instance Attribute Details

#args ⇒ Object

Returns the value of attribute args

Returns:

  • (Object) —

    the current value of args



2
3
4
 
# File 'lib/delayed/performable_method.rb', line 2

def args
  @args
end

#fail_cb ⇒ Object

Returns the value of attribute fail_cb

Returns:

  • (Object) —

    the current value of fail_cb



2
3
4
 
# File 'lib/delayed/performable_method.rb', line 2

def fail_cb
  @fail_cb
end

#method ⇒ Object

Returns the value of attribute method

Returns:

  • (Object) —

    the current value of method



2
3
4
 
# File 'lib/delayed/performable_method.rb', line 2

def method
  @method
end

#object ⇒ Object

Returns the value of attribute object

Returns:

  • (Object) —

    the current value of object



2
3
4
 
# File 'lib/delayed/performable_method.rb', line 2

def object
  @object
end

#permanent_fail_cb ⇒ Object

Returns the value of attribute permanent_fail_cb

Returns:

  • (Object) —

    the current value of permanent_fail_cb



2
3
4
 
# File 'lib/delayed/performable_method.rb', line 2

def permanent_fail_cb
  @permanent_fail_cb
end

Instance Method Details

#deep_de_ar_ize(arg) ⇒ Object 



34
35
36
37
38
39
40
41
42
43
44
45
 
# File 'lib/delayed/performable_method.rb', line 34

def deep_de_ar_ize(arg)
  case arg
  when Hash
    "{#{arg.map { |k, v| "#{deep_de_ar_ize(k)} => #{deep_de_ar_ize(v)}" }.join(', ')}}"
  when Array
    "[#{arg.map { |a| deep_de_ar_ize(a) }.join(', ')}]"
  when ActiveRecord::Base
    "#{arg.class}.find(#{arg.id})"
  else
    arg.inspect
  end
end

#display_name ⇒ Object Also known as: tag 



13
14
15
16
17
18
19
 
# File 'lib/delayed/performable_method.rb', line 13

def display_name
  if object.is_a?(Module)
    "#{object}.#{method}"
  else
    "#{object.class}##{method}"
  end
end

#full_name ⇒ Object 



47
48
49
50
 
# File 'lib/delayed/performable_method.rb', line 47

def full_name
  obj_name = object.is_a?(ActiveRecord::Base) ? "#{object.class}.find(#{object.id}).#{method}" : display_name
  "#{obj_name}(#{args.map { |a| deep_de_ar_ize(a) }.join(', ')})"
end

#on_failure(error) ⇒ Object 



26
27
28
 
# File 'lib/delayed/performable_method.rb', line 26

def on_failure(error)
  object.send(fail_cb, error) if fail_cb
end

#on_permanent_failure(error) ⇒ Object 



30
31
32
 
# File 'lib/delayed/performable_method.rb', line 30

def on_permanent_failure(error)
  object.send(permanent_fail_cb, error) if permanent_fail_cb
end

#perform ⇒ Object 



22
23
24
 
# File 'lib/delayed/performable_method.rb', line 22

def perform
  object.send(method, *args)
end