Class: Babushka::Task

Inherits:

Object

• Object
• Babushka::Task

show all

Includes:

LogHelpers, PathHelpers, ShellHelpers, Singleton

Defined in:

lib/babushka/task.rb

Instance Attribute Summary (collapse)

• - (Object) opts readonly

  Returns the value of attribute opts.

• - (Object) persistent_log readonly

  Returns the value of attribute persistent_log.

• - (Object) reportable

  Returns the value of attribute reportable.

• - (Object) vars readonly

  Returns the value of attribute vars.

Instance Method Summary (collapse)

• - (Object) callstack
• - (Task) initialize constructor

  A new instance of Task.

• - (Object) log_path_for(dep)
• - (Object) opt(name)
• - (Object) process(dep_names, with_vars = {})
• - (Object) process_dep(dep_name, with_vars)
• - (Boolean) running?
• - (Object) task_info(dep, result)
• - (Object) var_path_for(dep)

Methods included from ShellHelpers

#cmd_dir, #failable_shell, #log_shell, #login_shell, #raw_shell, #shell, #shell!, #shell?, #sudo, #which

Methods included from LogHelpers

#debug, #log, #log_block, #log_error, #log_ok, #log_verbose, #log_warn

Methods included from PathHelpers

#cd, #in_build_dir, #in_dir, #in_download_dir

11
12
13
14
15

# File 'lib/babushka/task.rb', line 11

def initialize
  @vars = Vars.new
  @opts = Base.cmdline.opts.dup
  @running = false
end

8
9
10

# File 'lib/babushka/task.rb', line 8

def opts
  @opts
end

8
9
10

# File 'lib/babushka/task.rb', line 8

def persistent_log
  @persistent_log
end

9
10
11

# File 'lib/babushka/task.rb', line 9

def reportable
  @reportable
end

8
9
10

# File 'lib/babushka/task.rb', line 8

def vars
  @vars
end

60
61
62

# File 'lib/babushka/task.rb', line 60

def callstack
  @callstack ||= []
end

64
65
66

# File 'lib/babushka/task.rb', line 64

def log_path_for dep
  log_prefix / dep.contextual_name
end

52
53
54

# File 'lib/babushka/task.rb', line 52

def opt name
  opts[name]
end

17
18
19
20
21
22
23
24

# File 'lib/babushka/task.rb', line 17

def process dep_names, with_vars = {}
  raise "A task is already running." if running?
  @running = true
  Base.in_thread { RunReporter.post_reports }
  dep_names.all? {|dep_name| process_dep dep_name, with_vars }
ensure
  @running = false
end

26
27
28
29
30
31
32
33
34
35
36
37
38
39

# File 'lib/babushka/task.rb', line 26

def process_dep dep_name, with_vars
  Dep.find_or_suggest dep_name do |dep|
    log_dep(dep) {
      load_run_info_for dep, with_vars
      dep.with(task_args_for(dep, with_vars)).process(:top_level => true).tap {|result|
        save_run_info_for dep, result
      }
    }.tap {|result|
      log "You can view #{opt(:debug) ? 'the' : 'a more detailed'} log at '#{log_path_for(dep)}'." unless result
      RunReporter.queue dep, result, reportable
      BugReporter.report dep if reportable
    }
  end
end

56
57
58

# File 'lib/babushka/task.rb', line 56

def running?
  @running
end

41
42
43
44
45
46
47
48
49
50

# File 'lib/babushka/task.rb', line 41

def task_info dep, result
  {
    :version => VERSION,
    :run_at => Time.now,
    :system_info => Base.host.description,
    :dep_name => dep.name,
    :source_uri => dep.dep_source.uri,
    :result => result
  }
end

68
69
70

# File 'lib/babushka/task.rb', line 68

def var_path_for dep
  VarsPrefix.p / dep.contextual_name
end