Sha256: 7c54dba53c5e0ac8276e58e791bf947a9169c7c4bcade275c8590443e07ac531
Contents?: true
Size: 1.6 KB
Versions: 39
Compression:
Stored size: 1.6 KB
Contents
require "pact_broker/domain/tag"
require "pact_broker/repositories/helpers"
module PactBroker
module Tags
class Repository
include PactBroker::Repositories::Helpers
def create args
params = {
name: args.fetch(:name),
version_id: args.fetch(:version).id,
version_order: args.fetch(:version).order,
pacticipant_id: args.fetch(:version).pacticipant_id
}
Domain::Tag.new(params).insert_ignore
end
def find args
PactBroker::Domain::Tag
.select_all_qualified
.join(:versions, { id: :version_id })
.join(:pacticipants, {Sequel.qualify("pacticipants", "id") => Sequel.qualify("versions", "pacticipant_id")})
.where(name_like(Sequel.qualify("tags", "name"), args.fetch(:tag_name)))
.where(name_like(Sequel.qualify("versions", "number"), args.fetch(:pacticipant_version_number)))
.where(name_like(Sequel.qualify("pacticipants", "name"), args.fetch(:pacticipant_name)))
.single_record
end
def delete_by_version_id version_id
Domain::Tag.where(version_id: version_id).delete
end
def find_all_tag_names_for_pacticipant pacticipant_name
PactBroker::Domain::Tag
.select(Sequel[:tags][:name])
.join(:versions, { Sequel[:versions][:id] => Sequel[:tags][:version_id] })
.join(:pacticipants, { Sequel[:pacticipants][:id] => Sequel[:versions][:pacticipant_id] })
.where(Sequel[:pacticipants][:name] => pacticipant_name)
.distinct
.collect{ |tag| tag[:name] }.sort
end
end
end
end
Version data entries
39 entries across 39 versions & 1 rubygems