Sha256: aaba72fb3cae20ac2716865c6ad5fe8378cfc8f532ce1f8da5a3d4941bd0938f
Contents?: true
Size: 1.32 KB
Versions: 9
Compression:
Stored size: 1.32 KB
Contents
require 'pact_broker/matrix/quick_row'
module PactBroker
module Matrix
class EveryRow < PactBroker::Matrix::QuickRow
set_dataset(Sequel.as(:pact_publications, :p))
P_V_JOIN = { Sequel[:p][:pact_version_id] => Sequel[:v][:pact_version_id] }
PACT_COLUMNS = [
Sequel[:p][:id].as(:pact_publication_id),
Sequel[:p][:pact_version_id],
Sequel[:p][:revision_number].as(:pact_revision_number)
]
VERIFICATION_COLUMNS = [
Sequel[:v][:id].as(:verification_id)
]
ALL_COLUMNS = CONSUMER_COLUMNS + CONSUMER_VERSION_COLUMNS + PACT_COLUMNS +
PROVIDER_COLUMNS + PROVIDER_VERSION_COLUMNS + VERIFICATION_COLUMNS
SELECT_ALL_COLUMN_ARGS = [:select_all_columns] + ALL_COLUMNS
dataset_module do
select *SELECT_ALL_COLUMN_ARGS
def join_verifications
left_outer_join(:verifications, P_V_JOIN, { table_alias: :v } )
end
def verifications_for(query_ids)
db[:verifications]
.select(:id, :pact_version_id, :provider_id, :provider_version_id)
.where {
Sequel.&(
QueryBuilder.consumer_in_pacticipant_ids(query_ids),
QueryBuilder.provider_or_provider_version_matches(query_ids)
)
}
end
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems