Module: Marty::Promises::Ruby::Create

Defined in:
app/services/marty/promises/ruby/create.rb

Class Method Summary collapse

Class Method Details

.call(module_name:, method_name:, method_args:, params: {}) ⇒ Object 



5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
 
# File 'app/services/marty/promises/ruby/create.rb', line 5

def self.call(module_name:, method_name:, method_args:, params: {})
  default_timeout = Marty::Promise::DEFAULT_PROMISE_TIMEOUT

  promise_params = params.with_indifferent_access

  title = promise_params['p_title'] || "#{module_name}.#{method_name}"
  timeout = promise_params['p_timeout'] || default_timeout
  hook = promise_params['p_hook']

  default_priority = 0
  pid = promise_params[:_parent_id]
  if pid
    ppr = Marty::Promise.find_by(id: pid)
    # make sure parent isn't cancelled
    return if ppr&.result&.[]('error') == 'Cancelled'

    default_priority = ppr.priority if ppr
  end
  priority = promise_params['p_priority'] || default_priority

  promise = Marty::Promise.create(
    title: title,
    user_id: promise_params[:_user_id],
    parent_id: promise_params[:_parent_id],
    priority: priority,
    promise_type: 'ruby',
    timeout: timeout
  )

  begin
    promise_job = Marty::PromiseRubyJob.new(
      promise,
      title,
      module_name,
      method_name,
      method_args,
      hook,
      promise_params['p_timeout']
    )

    job = Delayed::Job.enqueue(
      promise_job,
      priority: priority,
      queue: promise_params['p_queue'] ||
        Delayed::Worker.default_queue_name)
  rescue StandardError => e
    res = { 'error' => e.message }
    promise.set_start
    promise.set_result(res)
    raise
  end

  # keep a reference to the job. This is needed in case we want to
  # work off a promise job that we're waiting for and which hasn't
  # been reserved yet.
  promise.job_id = job.id
  promise.save!

  Marty::PromiseProxy.new(promise.id, timeout, 'result')
end