Contents

module Inferno
  module Jobs
    class InvokeValidatorSession
      include Sidekiq::Worker
      sidekiq_options queue: 'validator_sessions'

      def perform(suite_id, validator_name, validator_index)
        suite = Inferno::Repositories::TestSuites.new.find suite_id
        validator = suite.fhir_validators[validator_name.to_sym][validator_index]
        response_body = validator.validate(FHIR::Patient.new, 'http://hl7.org/fhir/StructureDefinition/Patient')
        if response_body.start_with? '{'
          res = JSON.parse(response_body)
          session_id = res['sessionId']
          session_repo = Inferno::Repositories::ValidatorSessions.new
          session_repo.save(test_suite_id: suite_id, validator_session_id: session_id,
                            validator_name:, suite_options: validator.requirements)
          validator.session_id = session_id
        else
          Inferno::Application['logger'].error("InvokeValidatorSession - error from validator: #{response_body}")
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
inferno_core-0.4.39	lib/inferno/jobs/invoke_validator_session.rb
inferno_core-0.4.38	lib/inferno/jobs/invoke_validator_session.rb