Class: AvoDeploy::Task::LocalTaskExecutionEnvironment

Inherits:
TaskExecutionEnvironment show all
Defined in:
lib/avodeploy/task/local_task_execution_environment.rb

Instance Method Summary collapse

Methods inherited from TaskExecutionEnvironment

#get, #handle_abort, #log, #scm_provider=, #set

Constructor Details

#initialize(config) ⇒ LocalTaskExecutionEnvironment

Initialized the environment

Parameters:

  • config (Hash) —

    deployment configuration



26
27
28
29
30
 
# File 'lib/avodeploy/task/local_task_execution_environment.rb', line 26

def initialize(config)
  super

  @dir = Dir.pwd
end

Instance Method Details

#chdir(dir) ⇒ Object

Changes the directory for commands to be executed in

Parameters:

  • dir (String) —

    the directory to change to



43
44
45
46
47
48
 
# File 'lib/avodeploy/task/local_task_execution_environment.rb', line 43

def chdir(dir)
  log.debug "changing directory [#{dir.yellow}] " + "locally".cyan

  Dir.chdir(dir)
  @dir = Dir.pwd
end

#check_util_availability(utils) ⇒ Object

Checks, if all utilities are available for the deployment process to be executed

Parameters:

  • utils (Array) —

    array with utilities to check



36
37
38
 
# File 'lib/avodeploy/task/local_task_execution_environment.rb', line 36

def check_util_availability(utils)
  super(utils, 'locally')
end

#command(cmd) ⇒ CommandExecutionResult

Executes a command locally in the current directory

Parameters:

  • cmd (String) —

    the command to execute

Returns:



96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
 
# File 'lib/avodeploy/task/local_task_execution_environment.rb', line 96

def command(cmd)
  log = AvoDeploy::Deployment.instance.log

  log.info "Executing [" + cmd.yellow + "] " + "locally".cyan

  result = AvoDeploy::CommandExecutionResult.new

  begin
    stdout, stderr, status = ::Open3.capture3(cmd, :chdir => cwd())

    result.stdin = cmd
    result.stdout = stdout
    result.stderr = stderr
    result.retval = status.exitstatus

    if result.stdout.nil? == false && result.stdout.empty? == false
      log.debug "Stdout: " + result.stdout.green
    end

    if result.stderr.nil? == false && result.stderr.empty? == false
      log.debug "Stderr: " + result.stderr.red
    end
  rescue Exception => e
    handle_abort e
  end

  result
end

#copy_to_target(target, file, remote) ⇒ Object

Copies a file to a remote system (= target)

Parameters:

  • target (Target) —

    the target system to deploy to

  • file (String) —

    the local file to upload

  • remote (String) —

    path on the remote system



69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
 
# File 'lib/avodeploy/task/local_task_execution_environment.rb', line 69

def copy_to_target(target, file, remote)
  log = AvoDeploy::Deployment.instance.log

  log.info "started upload of file #{file} to #{target.name}"

    Net::SSH.start(
        target.config[:host],
        target.config[:user]
    ) do |session|
      session.scp.upload!(file, remote, :recursive => true) do |ch, name, sent, total|
          percentage = 0

          begin
            percentage = (sent.to_f * 100 / total.to_f).to_i
          rescue Exception => e
            AvoDeploy::Deployment.instance.handle_abort(e)
          end
    end
  end

  log.info "upload completed"
end

#cwd ⇒ String

Returns the current working directory

Returns:

  • (String) —

    current working directory



53
54
55
 
# File 'lib/avodeploy/task/local_task_execution_environment.rb', line 53

def cwd
  @dir
end

#targets ⇒ Hash

Returns all target systems to deploy to

Returns:

  • (Hash) —

    hash of target systems



60
61
62
 
# File 'lib/avodeploy/task/local_task_execution_environment.rb', line 60

def targets
  AvoDeploy::Deployment.instance.config.targets
end