Class: PactBroker::Pacts::Repository
- Inherits:
-
Object
- Object
- PactBroker::Pacts::Repository
show all
- Includes:
- Logging
- Defined in:
- lib/pact_broker/pacts/repository.rb
Constant Summary
Constants included
from Logging
Logging::LOG_DIR, Logging::LOG_FILE_NAME
Instance Method Summary
collapse
-
#create(params) ⇒ Object
-
#delete(params) ⇒ Object
-
#find_all_pact_versions_between(consumer_name, options) ⇒ Object
-
#find_by_consumer_version(consumer_name, consumer_version_number) ⇒ Object
Returns latest pact version for the consumer_version_number.
-
#find_by_version_and_provider(version_id, provider_id) ⇒ Object
-
#find_latest_pact(consumer_name, provider_name, tag = nil) ⇒ Object
-
#find_latest_pact_versions_for_provider(provider_name, tag = nil) ⇒ Object
-
#find_latest_pacts ⇒ Object
-
#find_next_pact(pact) ⇒ Object
-
#find_pact(consumer_name, consumer_version, provider_name, pact_version_sha = nil) ⇒ Object
-
#find_previous_distinct_pact(pact) ⇒ Object
-
#find_previous_pact(pact) ⇒ Object
-
#update(id, params) ⇒ Object
Methods included from Logging
included, #log_error, #logger, #logger=
Instance Method Details
#create(params) ⇒ Object
19
20
21
22
23
24
25
|
# File 'lib/pact_broker/pacts/repository.rb', line 19
def create params
PactPublication.new(
consumer_version_id: params[:version_id],
provider_id: params[:provider_id],
pact_version: find_or_create_pact_version(params.fetch(:consumer_id), params.fetch(:provider_id), params[:json_content]),
).save.to_domain
end
|
#delete(params) ⇒ Object
42
43
44
45
46
47
48
49
|
# File 'lib/pact_broker/pacts/repository.rb', line 42
def delete params
id = AllPactPublications
.consumer(params.consumer_name)
.provider(params.provider_name)
.consumer_version_number(params.consumer_version_number)
.select(:id)
PactPublication.where(id: id).delete
end
|
#find_all_pact_versions_between(consumer_name, options) ⇒ Object
51
52
53
54
55
56
57
58
59
|
# File 'lib/pact_broker/pacts/repository.rb', line 51
def find_all_pact_versions_between consumer_name, options
provider_name = options.fetch(:and)
LatestPactPublicationsByConsumerVersion
.eager(:tags)
.consumer(consumer_name)
.provider(provider_name)
.reverse_order(:consumer_version_order)
.collect(&:to_domain)
end
|
#find_by_consumer_version(consumer_name, consumer_version_number) ⇒ Object
Returns latest pact version for the consumer_version_number
70
71
72
73
74
75
|
# File 'lib/pact_broker/pacts/repository.rb', line 70
def find_by_consumer_version consumer_name, consumer_version_number
LatestPactPublicationsByConsumerVersion
.consumer(consumer_name)
.consumer_version_number(consumer_version_number)
.collect(&:to_domain_with_content)
end
|
#find_by_version_and_provider(version_id, provider_id) ⇒ Object
77
78
79
80
81
82
|
# File 'lib/pact_broker/pacts/repository.rb', line 77
def find_by_version_and_provider version_id, provider_id
LatestPactPublicationsByConsumerVersion
.eager(:tags)
.where(consumer_version_id: version_id, provider_id: provider_id)
.limit(1).collect(&:to_domain_with_content)[0]
end
|
#find_latest_pact(consumer_name, provider_name, tag = nil) ⇒ Object
88
89
90
91
92
93
94
|
# File 'lib/pact_broker/pacts/repository.rb', line 88
def find_latest_pact(consumer_name, provider_name, tag = nil)
query = LatestPactPublicationsByConsumerVersion
.consumer(consumer_name)
.provider(provider_name)
query = query.tag(tag) unless tag.nil?
query.latest.all.collect(&:to_domain_with_content)[0]
end
|
#find_latest_pact_versions_for_provider(provider_name, tag = nil) ⇒ Object
61
62
63
64
65
66
67
|
# File 'lib/pact_broker/pacts/repository.rb', line 61
def find_latest_pact_versions_for_provider provider_name, tag = nil
if tag
LatestTaggedPactPublications.provider(provider_name).order(:consumer_name).where(tag_name: tag).order(:consumer_name).collect(&:to_domain)
else
LatestPactPublications.provider(provider_name).order(:consumer_name).collect(&:to_domain)
end
end
|
#find_latest_pacts ⇒ Object
84
85
86
|
# File 'lib/pact_broker/pacts/repository.rb', line 84
def find_latest_pacts
LatestPactPublications.order(:consumer_name, :provider_name).collect(&:to_domain_without_tags)
end
|
#find_next_pact(pact) ⇒ Object
115
116
117
118
119
120
121
122
|
# File 'lib/pact_broker/pacts/repository.rb', line 115
def find_next_pact pact
LatestPactPublicationsByConsumerVersion
.eager(:tags)
.consumer(pact.consumer.name)
.provider(pact.provider.name)
.consumer_version_order_after(pact.consumer_version.order)
.earliest.collect(&:to_domain_with_content)[0]
end
|
#find_pact(consumer_name, consumer_version, provider_name, pact_version_sha = nil) ⇒ Object
96
97
98
99
100
101
102
103
104
|
# File 'lib/pact_broker/pacts/repository.rb', line 96
def find_pact consumer_name, consumer_version, provider_name, pact_version_sha = nil
query = pact_version_sha ? AllPactPublications.pact_version_sha(pact_version_sha) : LatestPactPublicationsByConsumerVersion
query = query
.eager(:tags)
.consumer(consumer_name)
.provider(provider_name)
query = query.consumer_version_number(consumer_version) if consumer_version
query.limit(1).collect(&:to_domain_with_content)[0]
end
|
#find_previous_distinct_pact(pact) ⇒ Object
124
125
126
127
128
129
130
131
|
# File 'lib/pact_broker/pacts/repository.rb', line 124
def find_previous_distinct_pact pact
previous, current = nil, pact
loop do
previous = find_previous_distinct_pact_by_sha current
return previous if previous.nil? || different?(current, previous)
current = previous
end
end
|
#find_previous_pact(pact) ⇒ Object
106
107
108
109
110
111
112
113
|
# File 'lib/pact_broker/pacts/repository.rb', line 106
def find_previous_pact pact
LatestPactPublicationsByConsumerVersion
.eager(:tags)
.consumer(pact.consumer.name)
.provider(pact.provider.name)
.consumer_version_order_before(pact.consumer_version.order)
.latest.collect(&:to_domain_with_content)[0]
end
|
#update(id, params) ⇒ Object
27
28
29
30
31
32
33
34
35
36
37
38
39
40
|
# File 'lib/pact_broker/pacts/repository.rb', line 27
def update id, params
existing_model = PactPublication.find(id: id)
pact_version = find_or_create_pact_version(existing_model.consumer_version.pacticipant_id, existing_model.provider_id, params[:json_content])
if existing_model.pact_version_id != pact_version.id
PactPublication.new(
consumer_version_id: existing_model.consumer_version_id,
provider_id: existing_model.provider_id,
revision_number: (existing_model.revision_number + 1),
pact_version: pact_version,
).save.to_domain
else
existing_model.to_domain
end
end
|