engine/app/controllers/admin/imports_controller.rb

module Admin
  class ImportsController < BaseController

    sections 'settings', 'site'

    actions :show, :new, :create

    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
      identifier = store_zipfile!

      if identifier
        job = Locomotive::Import::Job.new(identifier, current_site)
        Delayed::Job.enqueue job, { :site => current_site, :job_type => 'import' }

        flash[:notice] = t('flash.admin.imports.create.notice')

        redirect_to admin_import_url
      else
        @error = t('errors.messages.invalid_theme_file')
        flash[:alert] = t('flash.admin.imports.create.alert')

        render 'new'
      end
    end

    protected

    def store_zipfile!
      return nil if params[:zipfile].blank?

      file = CarrierWave::SanitizedFile.new(params[:zipfile])

      uploader = ThemeUploader.new(current_site)

      begin
        uploader.store!(file)
      rescue CarrierWave::IntegrityError
        return nil
      end

      uploader.identifier
    end

  end
end