Contents

# frozen_string_literal: true
require 'net/http'
require 'addressable/uri'

require 'roqua/healthy/a19/response_validator'
require 'roqua/healthy/a19/response_parser'

module Roqua
  module Healthy
    module A19
      class Fetcher
        attr_reader :patient_id
        attr_reader :client

        def initialize(patient_id, client)
          @patient_id = patient_id
          @client = client
        end

        def fetch
          response = mirth_response
          parser   = ResponseParser.new(response)

          parser.fetch("HL7Message") if ResponseValidator.new(response.code, parser, patient_id).validate
        end

        def mirth_response
          Net::HTTP.start(remote_url.host, remote_url.port, use_ssl: use_ssl?) do |http|
            request = Net::HTTP::Post.new(remote_url.path)
            request.basic_auth(@client.a19_username, @client.a19_password) if @client.use_basic_auth?
            request.set_form_data(mirth_params)
            http.request request
          end
        rescue ::Timeout::Error, Errno::ETIMEDOUT => error
          raise ::Roqua::Healthy::Timeout, error.message
        rescue Errno::EHOSTUNREACH => error
          raise ::Roqua::Healthy::HostUnreachable, error.message
        rescue Errno::ECONNREFUSED => error
          raise ::Roqua::Healthy::ConnectionRefused, error.message
        end

        private

        def mirth_params
          {'method' => 'A19', 'patient_id' => patient_id.to_s, 'application' => "healthy"}
        end

        def use_ssl?
          remote_url.port == 443 || remote_url.scheme == 'https'
        end

        def remote_url
          return @remote_url if @remote_url

          url = Addressable::URI.parse(client.a19_endpoint)
          url.path = "/"

          @remote_url = URI.parse(url.to_s)
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
roqua-healthy-1.5.0	lib/roqua/healthy/a19/fetcher.rb