moviepilot/minimum-term

require 'active_support/core_ext/object/try'

module Lacerda
  module Reporters
    class RSpec < Lacerda::Reporter
      def initialize(group = ::RSpec.describe("Lacerda infrastructure contract validation"))
        @group = group
      end

      # errors is a hash with the following structure:
      #   { "publisher_name -> consumer_name" => [
      #      { :error => :ERR_MISSING_DEFINITION,
      #        :message =>"Some text",
      #        :location => 'consumer_name/publisher_name::object_name
      #      }]
      #   }
      def consume_specification_errors(consumer, errors)
        error_messages = errors.map do |error|
          "- #{error[:error]} in #{error[:location]}: #{error[:message]}"
        end
        msg = "expected #{@current_publisher.description} to satisfy "\
          "#{consumer.name} but found these errors:\n"\
          "  #{error_messages.join("\n")}"
        @current_publisher.it "satisfies #{consumer.name}" do |example|
          # We need to set the location to avoid rspec STDOUT errors
          example.metadata[:location] = 'spec/config/zeta_spec.rb'
          expect(error_messages).to be_empty, msg
        end
      end

      def check_publishing
        @publish_group = @group.describe("publishers")
      end

      def check_publisher(service)
        @current_publisher = @publish_group.describe(service.try(:name))
      end

      def check_consuming
        @consume_group = @group.describe("consumers")
      end

      def check_consumer(service)
        @current_consumer = @consume_group.describe("#{service.try(:name)} consuming")
      end

      def check_consumed_object(consumed_object_name, publisher_name, publisher_exists, is_published)
        error = if !publisher_exists
                  "Publisher #{publisher_name} does not exist"
                elsif !is_published
                  "#{publisher_name} does not publish #{consumed_object_name}"
                end
        @current_consumer.it "#{consumed_object_name} from #{publisher_name}" do |example|
          # We need to set the location to avoid rspec STDOUT errors
          example.metadata[:location] = 'spec/config/zeta_spec.rb'
          expect(publisher_exists && is_published).to eq(true), error
        end
      end

      def result(errors)
      end

    end
  end
end