Plugins » Docker

class ContainersController < ::ApplicationController

  before_filter :find_resource, :only => [:show, :auto_complete_image, :auto_complete_image_tags,

                                          :commit]

  def index

    @container_resources = allowed_resources.select { |cr| cr.provider == 'Docker' }

    if @container_resources.empty?

      warning('You need a Compute Resource of type Docker to start managing containers')

      redirect_to new_compute_resource_path

    end

  # This should only rescue Fog::Errors, but Fog returns all kinds of errors...

  rescue

    process_error

  end

  def new

    @container = Container.create

    redirect_to container_step_path(:container_id => @container.id, :id => :preliminary)

  end

  def destroy

    if resource_deletion

      process_success(:success_redirect => containers_path,

                      :success_msg      => (_("Container %s is being deleted.") %

                                            @deleted_identifier))

    else

      process_error(:redirect => containers_path)

    end

  rescue ActiveRecord::RecordNotFound

    not_found

  end

  def show

  end

  def auto_complete_image

    images = @container.compute_resource.all_images(params[:search]).map do |image|

      image.info['RepoTags'].map do |image_tag|

        name, _ = image_tag.split(':')

        name

      end

    end

    render :json => images.flatten.uniq.map do |n|

      { :label => CGI.escapeHTML(n), :value => CGI.escapeHTML(n) }

    end

  end

  def auto_complete_image_tags

    images = @container.compute_resource.all_images(params[:search]).map do |image|

      image.info['RepoTags'].map do |image_tag|

        _, tag = image_tag.split(':')

        { :label => CGI.escapeHTML(tag), :value => CGI.escapeHTML(tag) }

      end

    end

    render :json => images.flatten

  end

  def commit

    Docker::Container.get(@container.uuid).commit(:author  => params[:commit][:author],

                                                  :repo    => params[:commit][:repo],

                                                  :tag     => params[:commit][:tag],

                                                  :comment => params[:commit][:comment])

    process_success :success_redirect => :back,

                    :success_msg      => _("%{container} commit was successful") %

                                         { :container => @container }

  rescue => e

    process_error :redirect => :back, :error_msg => _("Failed to commit %{container}: %{e}") %

                                                    { :container => @container, :e => e }

  end

  private

  def action_permission

    case params[:action]

    when 'auto_complete_image', 'auto_complete_image_tags'

      :view

    when 'commit'

      :commit

    else

      super

    end

  end

  def resource_deletion

    # Unmanaged container - only present in Compute Resource

    if params[:compute_resource_id].present?

      @deleted_identifier  = params[:id]

      destroy_compute_resource_vm(params[:compute_resource_id], params[:id])

    else # Managed container

      find_resource

      @deleted_identifier = @container.name

      destroy_compute_resource_vm(@container.compute_resource, @container.uuid) &&

      @container.destroy

    end

  end

  def destroy_compute_resource_vm(resource_id, uuid)

    @container_resource = ComputeResource.authorized(:destroy_compute_resources_vms)

                                         .find(resource_id)

    @container_resource.destroy_vm(uuid)

  rescue => error

    logger.error "#{error.message} (#{error.class})\n#{error.backtrace.join("\n")}"

    false

  end

  def allowed_resources

    ComputeResource.authorized(:view_compute_resources)

  end

end