Contents

module Phase
  module DSL

    # @param [String] role_name The value of the 'Role' tag
    # @param [String] environment The value of the 'Environment' tag
    # @param [Hash] options SSHKit concurrency options
    # @see SSHKit::Coordinator for concurrency options
    # @return [void]
    def on_role(role_name, environment = "staging", options = {}, &block)
      servers = ::Phase::Adapters::AWS::Server.where(role: role_name, environment: environment)
      on(servers.map {|s| s.resource.private_ip_address }, options, &block)
    end

    #
    def on(destination_ips, options = {}, &block)
      server = ::Phase::Adapters::AWS::Server.where(role: ::Phase.config.bastion_role).first
      raise ArgumentError, "no servers found" unless server

      bastion_host = "#{ ::Phase.config.bastion_user }@#{ server.resource.dns_name }"
      coordinator  = SSH::Coordinator.new(bastion_host)

      Array(destination_ips).each do |ip|
        coordinator.each(options) do
          on_remote_host(ip) { instance_exec(&block) }
        end
      end

      true
    end

    def run_locally(&block)
      ::SSHKit::Backend::Local.new(&block).run
    end

  end
end

include ::Phase::DSL

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
phase-0.0.4	lib/phase/dsl.rb