# frozen_string_literal: true

require "singleton"
require "concurrent/map"

#
# Abstraction over WebMock to reduce duplication
#
# @author Mikael Henriksson <mikael@zoolutions.se>
# @since 0.1.0
#
module StubRequests
  #
  # Class ServiceRegistry provides registration of services
  #
  class ServiceRegistry
    include Singleton
    include Enumerable

    #
    # @!attribute [rw] services
    #   @return [Concurrent::Map<Symbol, Service>] a map with services
    attr_reader :services

    def initialize
      @services = Concurrent::Map.new
    end

    #
    # Resets the map with registered services
    #
    #
    # @api private
    def reset
      services.clear
    end

    #
    # Required by Enumerable
    #
    #
    # @return [Concurrent::Map<Symbol, Service>] an map with services
    #
    # @yield used by Enumerable
    #
    def each(&block)
      services.each(&block)
    end

    #
    # Registers a service in the registry
    #
    #
    # @param [Symbol] service_id a symbolic id of the service
    # @param [String] service_uri a string with a base_uri to the service
    #
    # @return [Service] the service that was just registered
    #
    def register_service(service_id, service_uri)
      if (service = get_service(service_id))
        StubRequests.logger.warn("Service already registered #{service}")
        raise ServiceHaveEndpoints, service if service.endpoints?
      end
      services[service_id] = Service.new(service_id, service_uri)
    end

    #
    # Removes a service from the registry
    #
    #
    # @param [Symbol] service_id the service_id to remove
    #
    # @raise [ServiceNotFound] when the service was not removed
    #
    def remove_service(service_id)
      services.delete(service_id) || raise(ServiceNotFound, service_id)
    end

    #
    # Fetches a service from the registry
    #
    #
    # @param [Symbol] service_id id of the service to remove
    #
    # @return [Service] the found service
    #
    def get_service(service_id)
      services[service_id]
    end

    #
    # Fetches a service from the registry or raises {ServiceNotFound}
    #
    #
    # @param [Symbol] service_id the id of a service
    #
    # @raise [ServiceNotFound] when an endpoint couldn't be found
    #
    # @return [Endpoint]
    #
    def get_service!(service_id)
      get_service(service_id) || raise(ServiceNotFound, service_id)
    end
  end
end