cloudfoundry/cloud_controller_ng

module VCAP::CloudController
  module Diego
    module Docker
      class StagingActionBuilder
        include ::Diego::ActionBuilder

        attr_reader :config, :staging_details

        def initialize(config, staging_details)
          @config          = config
          @staging_details = staging_details
        end

        def action
          run_args = [
            "-outputMetadataJSONFilename=#{STAGING_RESULT_FILE}",
            "-dockerRef=#{staging_details.package.image}"
          ]

          if config.get(:diego, :insecure_docker_registry_list).count > 0
            insecure_registries = "-insecureDockerRegistries=#{config.get(:diego, :insecure_docker_registry_list).join(',')}"
            run_args << insecure_registries
          end

          if staging_details.package.docker_username.present?
            run_args << "-dockerUser=#{staging_details.package.docker_username}"
            run_args << "-dockerPassword=#{staging_details.package.docker_password}"
          end

          stage_action = ::Diego::Bbs::Models::RunAction.new(
            path: '/tmp/lifecycle/builder',
            user: 'vcap',
            args: run_args,
            resource_limits: ::Diego::Bbs::Models::ResourceLimits.new(nofile: config.get(:staging, :minimum_staging_file_descriptor_limit)),
            env: BbsEnvironmentBuilder.build(staging_details.environment_variables)
          )

          emit_progress(
            stage_action,
            start_message: 'Staging...',
            success_message: 'Staging Complete',
            failure_message_prefix: 'Staging Failed'
          )
        end

        def image_layers
          return [] unless @config.get(:diego, :enable_declarative_asset_downloads)

          [::Diego::Bbs::Models::ImageLayer.new(
            name: 'docker-lifecycle',
            url: LifecycleBundleUriGenerator.uri(config.get(:diego, :lifecycle_bundles)[:docker]),
            destination_path: '/tmp/lifecycle',
            layer_type: ::Diego::Bbs::Models::ImageLayer::Type::SHARED,
            media_type: ::Diego::Bbs::Models::ImageLayer::MediaType::TGZ
          )]
        end

        def cached_dependencies
          return nil if @config.get(:diego, :enable_declarative_asset_downloads)

          [
            ::Diego::Bbs::Models::CachedDependency.new(
              from: LifecycleBundleUriGenerator.uri(config.get(:diego, :lifecycle_bundles)[:docker]),
              to: '/tmp/lifecycle',
              cache_key: 'docker-lifecycle'
            )
          ]
        end

        def stack
          "preloaded:#{config.get(:diego, :docker_staging_stack)}"
        end

        def task_environment_variables; end
      end
    end
  end
end