Class: Bg::Deferrable

Inherits:
Object
  • Object
show all
Defined in:
lib/bg/deferrable.rb

Defined Under Namespace

Modules: Behavior

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(object, queue: :default, wait: 0) ⇒ Deferrable

Returns a new instance of Deferrable.

Raises:

  • (::ArgumentError) 


32
33
34
35
36
37
 
# File 'lib/bg/deferrable.rb', line 32

def initialize(object, queue: :default, wait: 0)
  raise ::ArgumentError unless object.is_a?(::GlobalID::Identification)
  @object = object
  @queue  = queue || :default
  @wait   = wait.to_i
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method

#method_missing(name, *args) ⇒ Object 



39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
 
# File 'lib/bg/deferrable.rb', line 39

def method_missing(name, *args)
  if object.respond_to? name
    raise ::ArgumentError.new("blocks are not supported") if block_given?
    begin
      queue_args = { queue: queue }
      queue_args[:wait] = wait if wait > 0
      job = ::Bg::DeferredMethodCallJob.set(**queue_args).perform_later object, name.to_s, *self.class.make_enqueable(args)
    rescue ::StandardError => e
      raise ::ArgumentError.new("Failed to background method call! <#{object.class.name}##{name}> #{e.message}")
    ensure
      return job
    end
  end
  super
end

Instance Attribute Details

#object ⇒ Object (readonly)

Returns the value of attribute object.



30
31
32
 
# File 'lib/bg/deferrable.rb', line 30

def object
  @object
end

#queue ⇒ Object (readonly)

Returns the value of attribute queue.



30
31
32
 
# File 'lib/bg/deferrable.rb', line 30

def queue
  @queue
end

#wait ⇒ Object (readonly)

Returns the value of attribute wait.



30
31
32
 
# File 'lib/bg/deferrable.rb', line 30

def wait
  @wait
end

Class Method Details

.make_enqueable(value) ⇒ Object 



13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/bg/deferrable.rb', line 13

def self.make_enqueable(value)
  case value
  when ::Hash then
    value.each.with_object({}) do |(key, val), memo|
      memo[key.to_s] = make_enqueable(val)
    end
  when ::Array then
    value.map { |val| make_enqueable val }
  when ::Symbol then
    value.to_s
  when ::Date, ::Time, ::DateTime then
    value.respond_to?(:iso8601) ? value.iso8601 : value.to_s
  else
    value
  end
end

Instance Method Details

#respond_to?(name) ⇒ Boolean

Returns:

  • (Boolean) 


55
56
57
58
 
# File 'lib/bg/deferrable.rb', line 55

def respond_to?(name)
  return true if object.respond_to? name
  super
end