class DaVinciPASTestKit::Jobs::SendSubscriptionHandshake
def authorization_header
def authorization_header @authorization_header ||= @bearer_token.present? ? { 'Authorization' => "Bearer #{@bearer_token}" } : {} end
def await_subscription_creation
def await_subscription_creation sleep 0.5 until subscription.present? end
def content_type_header
def content_type_header @content_type_header ||= { 'Content-Type' => actual_mime_type(subscription) } end
def default_handshake_parameters_base_json
def default_handshake_parameters_base_json '{ "parameter": [ { "name": "subscription", "valueReference": { "reference": "replace_with_subscription_ref" } }, { "name": "topic", "valueCanonical": "replace_with_topic_canonical" }, { "name": "status", "valueCode": "requested" }, { "name": "type", "valueCode": "handshake" }, { "name": "events-since-subscription-start", "valueString": "0" } ], "resourceType": "Parameters" }' # rubocop:disable Layout/LineLength end
def default_notification_base_json
def default_notification_base_json FHIR::Bundle.new( timestamp: Time.now.utc.iso8601, type: 'history', entry: [ FHIR::Bundle::Entry.new(fullUrl: "urn:uuid:#{SecureRandom.uuid}", resource: FHIR.from_contents(default_handshake_parameters_base_json)) ] ).to_json end
def headers
def headers @headers ||= subscription_headers.merge(content_type_header).merge(authorization_header) end
def perform(test_run_id, test_session_id, result_id, subscription_id, subscription_url, client_endpoint,
def perform(test_run_id, test_session_id, result_id, subscription_id, subscription_url, client_endpoint, bearer_token, notification_json, test_run_identifier, test_suite_base_url) @test_run_id = test_run_id @test_session_id = test_session_id @result_id = result_id @subscription_id = subscription_id @subscription_url = subscription_url @client_endpoint = client_endpoint @bearer_token = bearer_token @notification_json = notification_json.present? ? notification_json : default_notification_base_json @test_run_identifier = test_run_identifier @test_suite_base_url = test_suite_base_url await_subscription_creation sleep 1 return unless test_still_waiting? send_handshake_notification test_suite_connection.get(RESUME_PASS_PATH.delete_prefix('/'), { token: @test_run_identifier }) end
def persist_notification_request(response, tags)
def persist_notification_request(response, tags) inferno_request_headers = headers.map { |name, value| { name:, value: } } inferno_response_headers = response.headers&.map { |name, value| { name:, value: } } requests_repo.create( verb: 'POST', url: response.env.url.to_s, direction: 'outgoing', status: response.status, request_body: response.env.request_body, response_body: response.env.response_body, test_session_id: @test_session_id, result_id: @result_id, request_headers: inferno_request_headers, response_headers: inferno_response_headers, tags: ) end
def requests_repo
def requests_repo @requests_repo ||= Inferno::Repositories::Requests.new end
def rest_hook_connection
def rest_hook_connection @rest_hook_connection ||= Faraday.new(url: @client_endpoint, request: { open_timeout: 30 }, headers:) end
def results_repo
def results_repo @results_repo ||= Inferno::Repositories::Results.new end
def send_handshake_notification
def send_handshake_notification handshake_json = derive_handshake_notification(@notification_json, @subscription_url, subscription_topic).to_json response = send_notification(handshake_json) persist_notification_request(response, [REST_HOOK_HANDSHAKE_NOTIFICATION_TAG]) response end
def send_notification(request_body)
def send_notification(request_body) rest_hook_connection.post('', request_body) rescue Faraday::Error => e # Warning: This is a hack. If there is an error with the request such that we never get a response, we have # no clean way to persist that information for the Inferno test to check later. The solution here # is to persist the request anyway with a status of nil, using the error message as response body Faraday::Response.new(response_body: e.message, url: rest_hook_connection.url_prefix.to_s) end
def subscription
def subscription @subscription ||= find_subscription(@test_session_id) end
def subscription_headers
def subscription_headers return {} unless subscription.present? @subscription_headers ||= subscription.channel&.header&.each_with_object({}) do |header, hash| header_name, header_value = header.split(': ', 2) hash[header_name] = header_value end || {} end
def subscription_topic
def subscription_topic @subscription_topic ||= subscription&.criteria end
def test_still_waiting?
def test_still_waiting? results_repo.find_waiting_result(test_run_id: @test_run_id) end
def test_suite_connection
def test_suite_connection @test_suite_connection ||= Faraday.new(@test_suite_base_url) end