Contents

require "pact_broker/domain/tag"

module PactBroker
  module Tags
    class Repository
      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(Sequel.name_like(Sequel.qualify("tags", "name"), args.fetch(:tag_name)))
          .where(Sequel.name_like(Sequel.qualify("versions", "number"), args.fetch(:pacticipant_version_number)))
          .where(Sequel.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

5 entries across 5 versions & 1 rubygems

Version	Path
pact_broker-2.112.0	lib/pact_broker/tags/repository.rb
pact_broker-2.111.0	lib/pact_broker/tags/repository.rb
pact_broker-2.109.1	lib/pact_broker/tags/repository.rb
pact_broker-2.109.0	lib/pact_broker/tags/repository.rb
pact_broker-2.108.0	lib/pact_broker/tags/repository.rb