Class: PatientHttp::SolidQueue::CallbackJob Private

Inherits:
ActiveJob::Base
  • Object
show all
Defined in:
lib/patient_http/solid_queue/callback_job.rb

Overview

This class is part of a private API. You should avoid using this class if possible, as it may be removed or be changed in the future.

Active Job that invokes callback services for HTTP request results.

Receives serialized Response or Error data and invokes the appropriate callback service method (on_complete or on_error).

Instance Method Summary collapse

Instance Method Details

#perform(data, result_type, callback_service_name) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Parameters:

  • data (Hash) —

    Response or Error data (possibly a storage reference)

  • result_type (String) —

    “response” or “error” indicating the type of result

  • callback_service_name (String) —

    Fully qualified callback service class name



47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
 
# File 'lib/patient_http/solid_queue/callback_job.rb', line 47

def perform(data, result_type, callback_service_name)
  callback_service_class = PatientHttp::ClassHelper.resolve_class_name(callback_service_name)
  callback_service = callback_service_class.new

  ref_data = PatientHttp::ExternalStorage.storage_ref?(data) ? data : nil
  actual_data = ref_data ? PatientHttp::SolidQueue.external_storage.fetch(data) : data
  actual_data = PatientHttp::SolidQueue.decrypt(actual_data)

  begin
    if result_type == "response"
      response = PatientHttp::Response.load(actual_data)
      PatientHttp::SolidQueue.invoke_completion_callbacks(response)
      callback_service.on_complete(response)
    elsif result_type == "error"
      error = PatientHttp::Error.load(actual_data)
      PatientHttp::SolidQueue.invoke_error_callbacks(error)
      callback_service.on_error(error)
    else
      raise ArgumentError, "Unknown result_type: #{result_type}"
    end
  ensure
    PatientHttp::SolidQueue.external_storage.delete(ref_data) if ref_data
  end
end