cloudfoundry/cloud_controller_ng

module VCAP::CloudController
  class ServiceInstancePurge
    def initialize(event_repository)
      @event_repository = event_repository
    end

    def purge(service_instance)
      logger.info("purging service instance #{service_instance.guid}")

      service_instance.db.transaction do
        service_instance.routes.each do |route|
          route.route_binding.destroy
          route.route_binding.notify_diego
          Repositories::ServiceGenericBindingEventRepository.new(
            Repositories::ServiceGenericBindingEventRepository::SERVICE_ROUTE_BINDING
          ).record_delete(route.route_binding, @event_repository.user_audit_info)
        end

        service_instance.service_bindings.each do |binding|
          binding.destroy
          Repositories::ServiceGenericBindingEventRepository.new(
            Repositories::ServiceGenericBindingEventRepository::SERVICE_APP_CREDENTIAL_BINDING
          ).record_delete(binding, @event_repository.user_audit_info)
        end

        service_instance.service_keys.each do |key|
          key.destroy
          Repositories::ServiceGenericBindingEventRepository.new(
            Repositories::ServiceGenericBindingEventRepository::SERVICE_KEY_CREDENTIAL_BINDING
          ).record_delete(key, @event_repository.user_audit_info)
        end

        service_instance.shared_spaces.each do |target_space|
          Repositories::ServiceInstanceShareEventRepository.record_unshare_event(service_instance, target_space, @event_repository.user_audit_info)
        end

        service_instance.destroy
        @event_repository.record_service_instance_event('purge', service_instance, nil)
      end

      logger.info("successfully purged service instance #{service_instance.guid}")
    end

    def logger
      @logger ||= Steno.logger('cc.service_lifecycle.instance_purger')
    end
  end
end