cloudfoundry/cloud_controller_ng

module VCAP::CloudController
  class RouteDelete
    class ServiceInstanceAssociationError < StandardError; end

    def initialize(app_event_repository:, route_event_repository:, user_audit_info:)
      @app_event_repository   = app_event_repository
      @route_event_repository = route_event_repository
      @user_audit_info        = user_audit_info
      @logger = Steno.logger('cc.action.route_delete')
    end

    def delete_sync(route:, recursive:)
      deletion_job = do_delete(recursive, route)
      deletion_job.perform
    end

    def delete_async(route:, recursive:)
      deletion_job = do_delete(recursive, route)
      Jobs::Enqueuer.new(deletion_job, queue: Jobs::Queues.generic).enqueue
    end

    def delete_unmapped_route(route:)
      delete_count = Route.where(id: route.id).
                     exclude(guid: RouteMappingModel.select(:route_guid)).
                     exclude(id: RouteBinding.select(:route_id)).
                     delete

      route_event_repository.record_route_delete_request(route, user_audit_info, false) if delete_count > 0
    rescue Sequel::ForeignKeyConstraintViolation => e
      @logger.info("Tried to delete route '#{route.guid}', got error: #{e}")
    end

    private

    def do_delete(recursive, route)
      raise ServiceInstanceAssociationError.new if !recursive && route.service_instance.present?

      route_event_repository.record_route_delete_request(route, user_audit_info, recursive)

      route.route_mappings.each do |route_mapping|
        app_event_repository.record_unmap_route(
          user_audit_info,
          route_mapping
        )
      end

      Jobs::Runtime::ModelDeletion.new(route.class, route.guid)
    end

    attr_reader :route_event_repository, :app_event_repository, :user_audit_info
  end
end