Class: Inferno::DSL::FHIRResourceValidation::Validator

Inherits:
Object
  • Object
show all
Defined in:
lib/inferno/dsl/fhir_resource_validation.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name = nil, test_suite_id = nil, requirements = nil) ⇒ Validator

Returns a new instance of Validator.



33
34
35
36
37
38
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 33

def initialize(name = nil, test_suite_id = nil, requirements = nil, &)
  @name = name
  @test_suite_id = test_suite_id
  instance_eval(&)
  @requirements = requirements
end

Instance Attribute Details

#name ⇒ Object

Returns the value of attribute name.



30
31
32
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 30

def name
  @name
end

#requirements ⇒ Object (readonly)

Returns the value of attribute requirements.



29
30
31
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 29

def requirements
  @requirements
end

#session_id ⇒ Object

Returns the value of attribute session_id.



30
31
32
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 30

def session_id
  @session_id
end

#test_suite_id ⇒ Object

Returns the value of attribute test_suite_id.



30
31
32
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 30

def test_suite_id
  @test_suite_id
end

Instance Method Details

#additional_validation_messages(resource, profile_url) ⇒ Object 



136
137
138
139
140
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 136

def additional_validation_messages(resource, profile_url)
  additional_validations
    .flat_map { |step| step.call(resource, profile_url) }
    .select { |message| message.is_a? Hash }
end

#additional_validations ⇒ Object 



108
109
110
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 108

def additional_validations
  @additional_validations ||= []
end

#call_validator(resource, profile_url) ⇒ Object 



271
272
273
274
275
276
277
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 271

def call_validator(resource, profile_url)
  request_body = wrap_resource_for_hl7_wrapper(resource, profile_url)
  Faraday.new(
    url,
    request: { timeout: 600 }
  ).post('validate', request_body, content_type: 'application/json')
end

#cli_context(definition = nil) ⇒ Object

Set the cliContext used as part of each validation request. Fields may be passed as either a Hash or block. Note that all fields included here will be sent directly in requests, there is no check that the fields are correct.

Examples:

fhir_resource_validator do
  url 'http://example.com/validator'
  cli_context do
    noExtensibleBindingMessages true
    txServer nil
  end
end
fhir_resource_validator do
  url 'http://example.org/validator'
  cli_context({
    noExtensibleBindingMessages: true,
    txServer: nil
  })
end

Parameters:

  • definition (Hash) (defaults to: nil) —

    raw fields to set, optional



94
95
96
97
98
99
100
101
102
103
104
105
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 94

def cli_context(definition = nil, &)
  if @cli_context
    if definition
      @cli_context.definition.merge!(definition.deep_symbolize_keys)
    elsif block_given?
      @cli_context.instance_eval(&)
    end
  else
    @cli_context = CliContext.new(definition || {}, &)
  end
  @cli_context
end

#default_validator_url ⇒ Object 



41
42
43
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 41

def default_validator_url
  ENV.fetch('FHIR_RESOURCE_VALIDATOR_URL')
end

#exclude_message {|message| ... } ⇒ Object

Filter out unwanted validation messages. Any messages for which the block evalutates to a truthy value will be excluded.

Examples:

validator do
  exclude_message { |message| message.type == 'info' }
end

Yield Parameters:



150
151
152
153
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 150

def exclude_message(&block)
  @exclude_message = block if block_given?
  @exclude_message
end

#filter_messages(message_hashes) ⇒ Object 



190
191
192
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 190

def filter_messages(message_hashes)
  message_hashes.reject! { |message| exclude_message.call(Entities::Message.new(message)) } if exclude_message
end

#igs(*validator_igs) ⇒ Object

Set the IGs that the validator will need to load

Examples:

igs "hl7.fhir.us.core#4.0.0"
igs("hl7.fhir.us.core#3.1.1", "hl7.fhir.us.core#6.0.0")

Parameters:

  • validator_igs (Array<String>) 


64
65
66
67
68
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 64

def igs(*validator_igs)
  cli_context(igs: validator_igs) if validator_igs

  cli_context.igs
end

#issue_message(issue, resource) ⇒ Object 



226
227
228
229
230
231
232
233
234
235
236
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 226

def issue_message(issue, resource)
  location = if issue.respond_to?(:expression)
               issue.expression&.join(', ')
             else
               issue.location&.join(', ')
             end

  location_prefix = resource.id ? "#{resource.resourceType}/#{resource.id}" : resource.resourceType

  "#{location_prefix}: #{location}: #{issue&.details&.text}"
end

#issue_severity(issue) ⇒ Object 



214
215
216
217
218
219
220
221
222
223
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 214

def issue_severity(issue)
  case issue.severity
  when 'warning'
    'warning'
  when 'information'
    'info'
  else
    'error'
  end
end

#message_hash_from_issue(issue, resource) ⇒ Object 



206
207
208
209
210
211
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 206

def message_hash_from_issue(issue, resource)
  {
    type: issue_severity(issue),
    message: issue_message(issue, resource)
  }
end

#message_hashes_from_outcome(outcome, resource, profile_url) ⇒ Object 



195
196
197
198
199
200
201
202
203
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 195

def message_hashes_from_outcome(outcome, resource, profile_url)
  message_hashes = outcome.issue&.map { |issue| message_hash_from_issue(issue, resource) } || []

  message_hashes.concat(additional_validation_messages(resource, profile_url))

  filter_messages(message_hashes)

  message_hashes
end

#operation_outcome_from_hl7_wrapped_response(response_hash) ⇒ Object 



280
281
282
283
284
285
286
287
288
289
290
291
292
293
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 280

def operation_outcome_from_hl7_wrapped_response(response_hash)
  if response_hash['sessionId'] && response_hash['sessionId'] != @session_id
    validator_session_repo.save(test_suite_id:, validator_session_id: response_hash['sessionId'],
                                validator_name: name.to_s, suite_options: requirements)
    @session_id = response_hash['sessionId']
  end

  # assume for now that one resource -> one request
  issues = response_hash['outcomes'][0]['issues']&.map do |i|
    { severity: i['level'].downcase, expression: i['location'], details: { text: i['message'] } }
  end
  # this is circuitous, ideally we would map this response directly to message_hashes
  FHIR::OperationOutcome.new(issue: issues)
end

#operation_outcome_from_validator_response(response, runnable) ⇒ Object 



301
302
303
304
305
306
307
308
309
310
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 301

def operation_outcome_from_validator_response(response, runnable)
  sanitized_body = remove_invalid_characters(response.body)

  operation_outcome_from_hl7_wrapped_response(JSON.parse(sanitized_body))
rescue JSON::ParserError
  runnable.add_message('error', "Validator Response: HTTP #{response.status}\n#{sanitized_body}")
  raise Inferno::Exceptions::ErrorInValidatorException,
        'Validator response was an unexpected format. ' \
        'Review Messages tab or validator service logs for more information.'
end

#perform_additional_validation {|resource, profile_url| ... } ⇒ Object

Perform validation steps in addition to FHIR validation.

Examples:

perform_additional_validation do |resource, profile_url|
  if something_is_wrong
    { type: 'error', message: 'something is wrong' }
  else
    { type: 'info', message: 'everything is ok' }
  end
end

Yield Parameters:

  • resource (FHIR::Model) —

    the resource being validated

  • profile_url (String) —

    the profile the resource is being validated against

Yield Returns:

  • (Array<Hash<Symbol, String>>, Hash<Symbol, String>) —

    The block should return a Hash or an Array of Hashes if any validation messages should be added. The Hash must contain two keys: ‘:type` and `:message`. `:type` can have a value of `’info’‘, `’warning’‘, or `’error’‘. A type of `’error’‘ means the resource is invalid. `:message` contains the message string itself.



131
132
133
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 131

def perform_additional_validation(&block)
  additional_validations << block
end

#remove_invalid_characters(string) ⇒ Object 



296
297
298
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 296

def remove_invalid_characters(string)
  string.gsub(/[^[:print:]\r\n]+/, '')
end

#resource_is_valid?(resource, profile_url, runnable) ⇒ Boolean

Returns:

  • (Boolean)

See Also:

  • Inferno::DSL::FHIRResourceValidation#resource_is_valid?


156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 156

def resource_is_valid?(resource, profile_url, runnable)
  profile_url ||= FHIR::Definitions.resource_definition(resource.resourceType).url

  begin
    response = call_validator(resource, profile_url)
  rescue StandardError => e
    # This could be a complete failure to connect (validator isn't running)
    # or a timeout (validator took too long to respond).
    runnable.add_message('error', e.message)
    raise Inferno::Exceptions::ErrorInValidatorException, "Unable to connect to validator at #{url}."
  end
  outcome = operation_outcome_from_validator_response(response, runnable)

  message_hashes = message_hashes_from_outcome(outcome, resource, profile_url)

  message_hashes
    .each { |message_hash| runnable.add_message(message_hash[:type], message_hash[:message]) }

  unless response.status == 200
    raise Inferno::Exceptions::ErrorInValidatorException,
          'Error occurred in the validator. Review Messages tab or validator service logs for more information.'
  end

  message_hashes
    .none? { |message_hash| message_hash[:type] == 'error' }
rescue Inferno::Exceptions::ErrorInValidatorException
  raise
rescue StandardError => e
  runnable.add_message('error', e.message)
  raise Inferno::Exceptions::ErrorInValidatorException,
        'Error occurred in the validator. Review Messages tab or validator service logs for more information.'
end

#url(validator_url = nil) ⇒ Object

Set the url of the validator service

Parameters:

  • validator_url (String) (defaults to: nil) 


52
53
54
55
56
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 52

def url(validator_url = nil)
  @url = validator_url if validator_url
  @url ||= default_validator_url
  @url
end

#validate(resource, profile_url) ⇒ String

Post a resource to the validation service for validating.

Parameters:

Returns:

  • (String) —

    the body of the validation response



266
267
268
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 266

def validate(resource, profile_url)
  call_validator(resource, profile_url).body
end

#validator_session_repo ⇒ Object 



45
46
47
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 45

def validator_session_repo
  @validator_session_repo ||= Inferno::Repositories::ValidatorSessions.new
end

#wrap_resource_for_hl7_wrapper(resource, profile_url) ⇒ Object 



239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
 
# File 'lib/inferno/dsl/fhir_resource_validation.rb', line 239

def wrap_resource_for_hl7_wrapper(resource, profile_url)
  validator_session_id =
    validator_session_repo.find_validator_session_id(test_suite_id,
                                                     name.to_s, requirements)
  @session_id = validator_session_id if validator_session_id
  wrapped_resource = {
    cliContext: {
      **cli_context.definition,
      profiles: [profile_url]
    },
    filesToValidate: [
      {
        fileName: "#{resource.resourceType}/#{resource.id}.json",
        fileContent: resource.source_contents,
        fileType: 'json'
      }
    ],
    sessionId: @session_id
  }
  wrapped_resource.to_json
end