Module: SimpliTest::DataValidationHelpers

Defined in:
lib/SimpliTest/helpers/data_validation.rb

Instance Method Summary collapse

Instance Method Details

#get_data_from_db(db, variables) ⇒ Object 



35
36
37
38
 
# File 'lib/SimpliTest/helpers/data_validation.rb', line 35

def get_data_from_db(db, variables)
  query = preprocess_template('query.sql', variables)
  db.execute query
end

#get_data_from_service(variables) ⇒ Object 



40
41
42
43
44
45
 
# File 'lib/SimpliTest/helpers/data_validation.rb', line 40

def get_data_from_service(variables)
  service = YAML.load(preprocess_template('service.yml', variables))
  service_path = service['url']
  uri = service_url_for service_path
  JSON.parse Net::HTTP.get(uri)
end

#preprocess_template(file, variables) ⇒ Object 



47
48
49
50
 
# File 'lib/SimpliTest/helpers/data_validation.rb', line 47

def preprocess_template(file, variables)
  template = File.read(File.join(@service_dir, file))
  ERB.new(template).result(OpenStruct.new(variables).instance_eval { binding })
end

#service_url_for(path) ⇒ Object 



52
53
54
55
56
57
 
# File 'lib/SimpliTest/helpers/data_validation.rb', line 52

def service_url_for(path)
  uri = URI.parse(path)
  service_host = SimpliTest.config[:environments][SimpliTest.config_environment + "_Services"]
  service_host = SimpliTest.config[:environments][SimpliTest.config_environment] unless service_host
  uri.absolute? ? uri : URI.parse(service_host + path)
end

#validate_service_against(db, service_dir, variables) ⇒ Object 



15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
 
# File 'lib/SimpliTest/helpers/data_validation.rb', line 15

def validate_service_against(db, service_dir, variables)
  require File.join(service_dir, 'mapper')
  #TODO: Horrible hard coding temporarily...will fix later
  SimpliTest.configure( {:support_directory => File.join(@project_path, 'features', 'support')})
  @service_dir = service_dir
  query_results = get_data_from_db(db, variables)
  if defined?(map_service_results)
    service_results = map_service_results(get_data_from_service(variables))
    query_results.each_with_index do |result, index|
      if result & service_results[index] == service_results[index]
        puts "Passed"
      else
        raise "Test Failed for #{service_results[index]}"
      end
    end
  else
    raise "It seems you have not defined a mapper for this service yet!"
  end
end