feat: allow dashboard resource to be filtered by consumer/provider

lib/pact_broker/api.rb

@@ -84,6 +84,7 @@ module PactBroker
         add ['matrix'], Api::Resources::Matrix, {resource_name: "matrix"}
 
         add ['dashboard'], Api::Resources::Dashboard, {resource_name: "dashboard"}
+        add ['dashboard', 'provider', :provider_name, 'consumer', :consumer_name ], Api::Resources::Dashboard, {resource_name: "integration_dashboard"}
         add ['test','error'], Api::Resources::ErrorTest, {resource_name: "error_test"}
 
         add ['integrations'], Api::Resources::Integrations, {resource_name: "integrations"}

lib/pact_broker/api/decorators/integration_decorator.rb

@@ -1,16 +1,26 @@
 require_relative 'base_decorator'
+require 'pact_broker/api/pact_broker_urls'
 
 module PactBroker
   module Api
     module Decorators
       class IntegrationDecorator < BaseDecorator
+        include PactBroker::Api::PactBrokerUrls
+
         property :consumer do
           property :name
         end
 
         property :provider do
           property :name
         end
+
+        link "pb:dashboard" do | options |
+          {
+            title: "BETA: Pacts to show on the dashboard",
+            href: dashboard_url_for_integration(represented.consumer.name, represented.provider.name, options.fetch(:base_url))
+          }
+        end
       end
     end
   end

lib/pact_broker/api/pact_broker_urls.rb

@@ -81,6 +81,10 @@ def integration_url consumer_name, provider_name, base_url = ""
         "#{base_url}/integrations/provider/#{url_encode(provider_name)}/consumer/#{url_encode(consumer_name)}"
       end
 
+      def dashboard_url_for_integration consumer_name, provider_name, base_url = ""
+        "#{base_url}/dashboard/provider/#{url_encode(provider_name)}/consumer/#{url_encode(consumer_name)}"
+      end
+
       def previous_distinct_diff_url pact, base_url
         pact_url(base_url, pact) + "/diff/previous-distinct"
       end

lib/pact_broker/api/resources/dashboard.rb

@@ -30,7 +30,7 @@ def to_text
         private
 
         def index_items
-          index_service.find_index_items(tags: true)
+          index_service.find_index_items(identifier_from_path.merge(tags: true))
         end
       end
     end

lib/pact_broker/index/service.rb

@@ -19,6 +19,9 @@ def self.find_index_items options = {}
           .eager(:latest_triggered_webhooks)
           .eager(:webhooks)
 
+        rows = rows.consumer(options[:consumer_name]) if options[:consumer_name]
+        rows = rows.provider(options[:provider_name]) if options[:provider_name]
+
         if !options[:tags]
           rows = rows.where(consumer_version_tag_name: nil)
         else

lib/pact_broker/matrix/row.rb

@@ -25,6 +25,14 @@ class Row < Sequel::Model(:matrix)
         include PactBroker::Repositories::Helpers
         include PactBroker::Logging
 
+        def consumer consumer_name
+          where(name_like(:consumer_name, consumer_name))
+        end
+
+        def provider provider_name
+          where(name_like(:provider_name, provider_name))
+        end
+
         def matching_selectors selectors
           if selectors.size == 1
             where_consumer_or_provider_is(selectors.first)

spec/lib/pact_broker/api/decorators/integration_decorator_spec.rb

@@ -5,6 +5,10 @@ module PactBroker
   module Api
     module Decorators
       describe IntegrationDecorator do
+        before do
+          allow(integration_decorator).to receive(:dashboard_url_for_integration).and_return("/dashboard")
+        end
+
         let(:integration) do
           instance_double(PactBroker::Integrations::Integration,
             consumer: consumer,
@@ -13,24 +17,39 @@ module Decorators
         end
         let(:consumer) { double("consumer", name: "the consumer") }
         let(:provider) { double("provider", name: "the provider") }
-
+        let(:options) { { user_options: { base_url: 'http://example.org' } } }
         let(:expected_hash) do
           {
             "consumer" => {
               "name" => "the consumer"
             },
             "provider" => {
               "name" => "the provider"
+            },
+            "_links" => {
+              "pb:dashboard" => {
+                "href" => "/dashboard"
+              }
             }
           }
         end
 
-        let(:json) { IntegrationDecorator.new(integration).to_json }
+        let(:integration_decorator) { IntegrationDecorator.new(integration) }
+        let(:json) { integration_decorator.to_json(options) }
         subject { JSON.parse(json) }
 
         it "generates a hash" do
           expect(subject).to match_pact expected_hash
         end
+
+        it "generates the correct link for the dashboard" do
+          expect(integration_decorator).to receive(:dashboard_url_for_integration).with(
+            "the consumer",
+            "the provider",
+            "http://example.org"
+          )
+          subject
+        end
       end
     end
   end