Class: PactBroker::Matrix::Repository

Inherits:
Object
  • Object
show all
Includes:
Repositories, Repositories::Helpers
Defined in:
lib/pact_broker/matrix/repository.rb

Constant Summary collapse

TP_COLS =

TODO move latest verification logic in to database

PactBroker::Matrix::Row::TP_COLS
GROUP_BY_PROVIDER_VERSION_NUMBER = 
[:consumer_name, :consumer_version_number, :provider_name, :provider_version_number]
GROUP_BY_PROVIDER = 
[:consumer_name, :consumer_version_number, :provider_name]
GROUP_BY_PACT = 
[:consumer_name, :provider_name]

Instance Method Summary collapse

Methods included from Repositories

#label_repository, #matrix_repository, #pact_repository, #pacticipant_repository, #tag_repository, #verification_repository, #version_repository, #webhook_repository

Methods included from Repositories::Helpers

#case_sensitivity_options, #mysql?, #name_like, #order_ignore_case, #postgres?, #select_all_qualified, #select_for_subquery, #upsert

Instance Method Details

#find(specified_selectors, options = {}) ⇒ Object

Return the latest matrix row (pact/verification) for each consumer_version_number/provider_version_number



52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/pact_broker/matrix/repository.rb', line 52

def find specified_selectors, options = {}
  resolved_selectors = resolve_selectors(specified_selectors, options)
  lines = query_matrix(resolved_selectors, options)
  lines = apply_latestby(options, specified_selectors, lines)

  # This needs to be done after the latestby, so can't be done in the db unless
  # the latestby logic is moved to the db
  if options.key?(:success)
    lines = lines.select{ |l| options[:success].include?(l.success) }
  end

  integrations = find_integrations_for_specified_selectors(resolved_selectors.select(&:specified?))

  QueryResults.new(lines.sort, specified_selectors, options, resolved_selectors, integrations)
end

#find_compatible_pacticipant_versions(selectors) ⇒ Object 



74
75
76
 
# File 'lib/pact_broker/matrix/repository.rb', line 74

def find_compatible_pacticipant_versions selectors
  find(selectors, latestby: 'cvpv').select{|line| line.success }
end

#find_for_consumer_and_provider(pacticipant_1_name, pacticipant_2_name) ⇒ Object 



68
69
70
71
72
 
# File 'lib/pact_broker/matrix/repository.rb', line 68

def find_for_consumer_and_provider pacticipant_1_name, pacticipant_2_name
  selectors = [{ pacticipant_name: pacticipant_1_name }, { pacticipant_name: pacticipant_2_name }]
  options = { latestby: 'cvpv' }
  find(selectors, options)
end

#find_ids_for_pacticipant_names(params) ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
 
# File 'lib/pact_broker/matrix/repository.rb', line 27

def find_ids_for_pacticipant_names params
  criteria  = {}

  if params[:consumer_name] || params[:provider_name]
    if params[:consumer_name]
      pacticipant = PactBroker::Domain::Pacticipant.where(name_like(:name, params[:consumer_name])).single_record
      criteria[:consumer_id] = pacticipant.id if pacticipant
    end

    if params[:provider_name]
      pacticipant = PactBroker::Domain::Pacticipant.where(name_like(:name, params[:provider_name])).single_record
      criteria[:provider_id] = pacticipant.id if pacticipant
    end
  end

  if params[:pacticipant_name]
    pacticipant = PactBroker::Domain::Pacticipant.where(name_like(:name, params[:pacticipant_name])).single_record
    criteria[:pacticipant_id] = pacticipant.id if pacticipant
  end

  criteria[:tag_name] = params[:tag_name] if params[:tag_name].is_a?(String) # Could be a sym from resource parameters in api.rb
  criteria
end

#find_integrations_for_specified_selectors(resolved_specified_selectors) ⇒ Object

If one pacticipant is specified, find all the integrations that involve that pacticipant If two or more are specified, just return the integrations that involve the specified pacticipants



80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
 
# File 'lib/pact_broker/matrix/repository.rb', line 80

def find_integrations_for_specified_selectors(resolved_specified_selectors)
  specified_pacticipant_names = resolved_specified_selectors.collect(&:pacticipant_name)
  Row
    .select(:consumer_name, :consumer_id, :provider_name, :provider_id)
    .matching_selectors(resolved_specified_selectors)
    .distinct
    .all
    .collect do |row |
      row.to_hash
    end
    .uniq
    .collect do | hash |
      required = is_a_row_for_this_integration_required?(specified_pacticipant_names, hash[:consumer_name])
      Integration.from_hash(hash.merge(required: required))
    end
end