Class: PipeFitter::Cli

Inherits:
Thor
  • Object
show all
Defined in:
lib/pipe_fitter/cli.rb

Instance Method Summary collapse

Instance Method Details

#activate ⇒ Object 



46
47
48
49
 
# File 'lib/pipe_fitter/cli.rb', line 46

def activate
  t = options[:start_timestamp] ? Time.parse(options[:start_timestamp]) : nil
  puts client.activate(options[:pipeline_id], options[:parameter_file], t)
end

#diff(definition_file) ⇒ Object 



31
32
33
 
# File 'lib/pipe_fitter/cli.rb', line 31

def diff(definition_file)
  puts client.diff(options[:pipeline_id], definition_file, options[:format])
end

#diff_deploy_files(definition_file) ⇒ Object 



88
89
90
91
92
 
# File 'lib/pipe_fitter/cli.rb', line 88

def diff_deploy_files(definition_file)
  client.diff_deploy_files(definition_file, options[:format]).each do |d|
    puts d
  end
end

#export ⇒ Object 



10
11
12
 
# File 'lib/pipe_fitter/cli.rb', line 10

def export
  puts client.definition(options[:pipeline_id]).to_yaml
end

#find(definition_file) ⇒ Object 



58
59
60
 
# File 'lib/pipe_fitter/cli.rb', line 58

def find(definition_file)
  puts client.find_registered(definition_file).to_h.to_json
end

#find_diff(definition_file) ⇒ Object 



64
65
66
67
68
69
 
# File 'lib/pipe_fitter/cli.rb', line 64

def find_diff(definition_file)
  p = client.find_registered(definition_file)
  abort("Pipeline is not registered") if p.nil?
  puts client.diff(p.id, definition_file, options[:format])
  puts p.to_h.to_json
end

#find_update(definition_file) ⇒ Object 



73
74
75
76
77
78
79
80
81
82
83
84
 
# File 'lib/pipe_fitter/cli.rb', line 73

def find_update(definition_file)
  p = client.find_registered(definition_file)
  abort("Pipeline is not registered") if p.nil?
  unless options[:force_update]
    puts client.diff(p.id, definition_file)
    print "\nReally update pipeline definition? [y/N] : "
    abort("Update was canceled") if $stdin.gets.chomp !~ /^y$/i
  end
  res = client.update(p.id, definition_file)
  puts JSON.pretty_generate(res)
  puts p.to_h.to_json
end

#register(definition_file) ⇒ Object 



15
16
17
18
19
20
21
22
23
24
25
26
 
# File 'lib/pipe_fitter/cli.rb', line 15

def register(definition_file)
  id, res = client.register(definition_file)
  puts id, JSON.pretty_generate(res)

  diff = client.diff_deploy_files(definition_file)
  unless diff.empty?
    puts diff.join("\n")
    print "\nReally upload deploy_files? [y/N] : "
    abort("Upload deploy_files were canceled") if $stdin.gets.chomp !~ /^y$/i
    client.upload_deploy_files(definition_file)
  end
end

#show(definition_file) ⇒ Object 



53
54
55
 
# File 'lib/pipe_fitter/cli.rb', line 53

def show(definition_file)
  puts Pipeline.load_yaml(definition_file).to_yaml
end

#update(definition_file) ⇒ Object 



37
38
39
40
 
# File 'lib/pipe_fitter/cli.rb', line 37

def update(definition_file)
  res = client.update(options[:pipeline_id], definition_file)
  puts JSON.pretty_generate(res)
end

#upload_deploy_files(definition_file) ⇒ Object 



95
96
97
 
# File 'lib/pipe_fitter/cli.rb', line 95

def upload_deploy_files(definition_file)
  client.upload_deploy_files(definition_file)
end