cloudfoundry/cloud_controller_ng

module VCAP::CloudController
  class SharedDomainsController < RestController::ModelController
    attr_reader :routing_api_client

    def self.dependencies
      %i[routing_api_client router_group_type_populating_collection_renderer]
    end

    define_attributes do
      attribute :name, String, exclude_in: :update
      attribute :internal, Message::Boolean, exclude_in: :update, default: nil
      attribute :router_group_guid, String, exclude_in: :update, default: nil
    end

    query_parameters :name

    def inject_dependencies(dependencies)
      super
      @routing_api_client = dependencies.fetch(:routing_api_client)
      @router_group_type_populating_collection_renderer = dependencies.fetch(:router_group_type_populating_collection_renderer)
    end

    def before_create
      router_group_guid = request_attrs['router_group_guid']
      return if router_group_guid.nil?

      begin
        @router_group = routing_api_client.router_group(router_group_guid)
      rescue RoutingApi::RoutingApiDisabled
        raise CloudController::Errors::ApiError.new_from_details('RoutingApiDisabled')
      rescue RoutingApi::RoutingApiUnavailable
        raise CloudController::Errors::ApiError.new_from_details('RoutingApiUnavailable')
      rescue RoutingApi::UaaUnavailable
        raise CloudController::Errors::ApiError.new_from_details('UaaUnavailable')
      end

      return if @router_group

      raise CloudController::Errors::ApiError.new_from_details('DomainInvalid', "router group guid '#{router_group_guid}' not found")
    end

    def after_create(domain)
      super
      return if domain.nil?
      return if domain.router_group_guid.nil?

      domain.router_group_type = @router_group.type unless @router_group.nil?
    end

    def delete(guid)
      domain = find_guid_and_validate_access(:delete, guid)
      do_delete(domain)
    end

    get '/v2/shared_domains', :enumerate_shared_domains
    def enumerate_shared_domains
      validate_access(:index, model)
      begin
        @router_group_type_populating_collection_renderer.render_json(
          self.class,
          get_filtered_dataset_for_enumeration(model, SharedDomain.dataset, self.class.query_parameters, @opts),
          self.class.path,
          @opts,
          {}
        )
      rescue RoutingApi::RoutingApiUnavailable
        raise CloudController::Errors::ApiError.new_from_details('RoutingApiUnavailable')
      rescue RoutingApi::UaaUnavailable
        raise CloudController::Errors::ApiError.new_from_details('UaaUnavailable')
      end
    end

    get '/v2/shared_domains/:guid', :get_shared_domain
    def get_shared_domain(guid)
      domain = find_guid_and_validate_access(:read, guid)
      unless domain.router_group_guid.nil?
        begin
          rtr_grp = routing_api_client.router_group(domain.router_group_guid)
        rescue RoutingApi::RoutingApiDisabled
          raise CloudController::Errors::ApiError.new_from_details('RoutingApiDisabled')
        rescue RoutingApi::RoutingApiUnavailable
          raise CloudController::Errors::ApiError.new_from_details('RoutingApiUnavailable')
        rescue RoutingApi::UaaUnavailable
          raise CloudController::Errors::ApiError.new_from_details('UaaUnavailable')
        end
        domain.router_group_type = rtr_grp.type unless rtr_grp.nil?
      end
      object_renderer.render_json(self.class, domain, @opts)
    end

    define_messages
    define_routes

    def self.translate_validation_exception(e, attributes)
      name_errors = e.errors.on(:name)
      if name_errors && name_errors.include?(:unique)
        CloudController::Errors::ApiError.new_from_details('DomainNameTaken', attributes['name'])
      else
        CloudController::Errors::ApiError.new_from_details('DomainInvalid', e.errors.full_messages)
      end
    end

    def self.not_found_exception_name(_model_class)
      :DomainNotFound
    end
  end
end