engine/app/controllers/admin/import_controller.rb

module Admin
  class ImportController < BaseController

    sections 'settings', 'site'

    actions :show, :new, :create

    skip_load_and_authorize_resource

    before_filter :authorize_import

    def show
      @job = Delayed::Job.where({ :job_type => 'import', :site_id => current_site.id }).last

      respond_to do |format|
        format.html do
          redirect_to new_admin_import_url if @job.nil?
        end
        format.json { render :json => {
          :step => @job.nil? ? 'done' : @job.step,
          :failed => @job && @job.last_error.present?
        } }
      end
    end

    def new; end

    def create
      begin
        Locomotive::Import::Job.run!(params[:zipfile], current_site, {
          :samples  => Boolean.set(params[:samples]),
          :reset    => Boolean.set(params[:reset])
        })

        flash[:notice] = t("flash.admin.import.create.#{Locomotive.config.delayed_job ? 'notice' : 'done'}")

        redirect_to Locomotive.config.delayed_job ? admin_import_url : new_admin_import_url
      rescue Exception => e
        logger.error "[Locomotive import] #{e.message} / #{e.backtrace}"

        @error = e.message
        flash[:alert] = t('flash.admin.import.create.alert')

        render 'new'
      end
    end

    protected

    def authorize_import
      authorize! :import, Site
    end

  end
end