Contents

module OpsWorks
  class Deployment < Resource
    attr_accessor :id, :command, :status, :created_at, :custom_json, :app_id

    TIMEOUT = 300
    POLL_INTERVAL = 5
    API_LIMIT = 25

    def self.wait(deployments, timeout = TIMEOUT)
      start_time = Time.now
      timeout ||= TIMEOUT
      while deployments.any?(&:running?)
        return if Time.now - start_time > timeout
        sleep POLL_INTERVAL
        updates = []
        running_deployments = deployments.select(&:running?)
        groups = running_deployments.group_by { |d| d.client.config.region }

        groups.each do |region, region_deployments|
          client = Aws::OpsWorks::Client.new(region: region)
          region_deployments.map(&:id).each_slice(API_LIMIT) do |slice|
            response = client.describe_deployments(deployment_ids: slice)
            updates += from_collection_response(client, response)
          end
        end

        running_deployments.each do |deployment|
          update = updates.find { |u| u.id == deployment.id }
          deployment.status = update.status
        end
      end
    end

    def self.from_collection_response(client, response)
      response.data[:deployments].map do |deployment|
        hash = deployment.to_h
        new(
          client,
          id: hash[:deployment_id],
          command: hash[:command],
          created_at: hash[:created_at],
          status: hash[:status],
          custom_json: hash[:custom_json],
          app_id: hash[:app_id]
        )
      end
    end

    def self.from_response(client, response)
      new(client, id: response[:deployment_id])
    end

    def running?
      status.nil? || status == 'running'
    end

    def success?
      status == 'successful'
    end

    def failed?
      status == 'failed'
    end

    def created_at
      Time.parse(@created_at)
    rescue
      @created_at
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
opsworks-cli-0.7.1	lib/opsworks/deployment.rb
opsworks-cli-0.7.0	lib/opsworks/deployment.rb
opsworks-cli-0.6.0	lib/opsworks/deployment.rb