Class: Flydata::Command::Base
Direct Known Subclasses
Conf, Crontab, Encrypt, Helper, Kill_all, Login, Restart, Routine, Sender, Setlogdel, Setup, Start, Status, Stop, Sync, Version
Instance Attribute Summary collapse
Instance Method Summary
collapse
included
#before_logging, #log_error_stderr, #log_info_stdout, #log_warn_stderr
Constructor Details
#initialize(options = Slop.new) ⇒ Base
Returns a new instance of Base.
17
18
19
20
|
# File 'lib/flydata/command/base.rb', line 17
def initialize(options = Slop.new)
@api_client = ApiClient.instance
@opts = options
end
|
Instance Attribute Details
#opts ⇒ Object
Returns the value of attribute opts.
21
22
23
|
# File 'lib/flydata/command/base.rb', line 21
def opts
@opts
end
|
Instance Method Details
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
# File 'lib/flydata/command/base.rb', line 116
def ask_input_table_name
input = nil
loop do
log_info_stdout("Input a table name.")
say(">> ")
input = gets.strip
if input =~ /^[a-zA-Z0-9_]+$/
break
else
puts "Please enter a valid table name."
end
end
log_info(">> #{input}")
input
end
|
#ask_yes_no(message, default_yes = true) ⇒ Object
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
|
# File 'lib/flydata/command/base.rb', line 77
def ask_yes_no(message, default_yes=true)
suffix = default_yes ? "(Y/n)" : "(y/n)"
prompt = "#{message} #{suffix}: "
if opts && opts.yes? log_info_stdout("#{prompt}Yes")
return true
end
loop do
ans = ask(prompt)
return true if default_yes and ans == ''
if ans.size > 0
case ans[0].downcase
when 'y'
log_info("#{prompt}Yes")
return true
when 'n'
log_info("#{prompt}No")
return false
end
end
log_warn_stderr(" ! Please answer y[es] or n[o]")
newline
end
end
|
#choose_one(message, prompt, menu_list, value_list = []) ⇒ Object
102
103
104
105
106
107
108
109
110
111
112
113
114
115
|
# File 'lib/flydata/command/base.rb', line 102
def choose_one(message, prompt, , value_list=[])
choice = nil
value_list = unless .size == value_list.size
log_info_stdout(message) if message
choose do ||
.index = :number
.index_suffix = ") "
.select_by = :index
.prompt = prompt ? prompt : ">> "
.choices(*) {|item| choice = value_list[.index(item)]}
end
log_info_stdout(" -> #{choice}")
choice
end
|
#dashboard_url ⇒ Object
64
65
66
|
# File 'lib/flydata/command/base.rb', line 64
def dashboard_url
"#{flydata.flydata_api_host}/dashboard"
end
|
#data_entry ⇒ Object
45
46
47
48
49
|
# File 'lib/flydata/command/base.rb', line 45
def data_entry
@de ||= retrieve_data_entries.first
raise "No data entry exists. Please set one up on the FlyData Console (#{dashboard_url})" unless @de
@de
end
|
#flydata ⇒ Object
22
|
# File 'lib/flydata/command/base.rb', line 22
def flydata; @api_client end
|
#newline ⇒ Object
73
|
# File 'lib/flydata/command/base.rb', line 73
def newline; puts end
|
#redshift_console_url ⇒ Object
68
69
70
|
# File 'lib/flydata/command/base.rb', line 68
def redshift_console_url
"#{flydata.flydata_api_host}/redshift_clusters/query/new"
end
|
#register_crontab ⇒ Object
55
56
57
58
59
60
61
62
|
# File 'lib/flydata/command/base.rb', line 55
def register_crontab
data_entries = retrieve_data_entries
if data_entries.any?{|e| e['log_deletion']}
require 'flydata/command/crontab'
Flydata::Command::Crontab.new.run
end
end
|
#retrieve_data_entries ⇒ Object
#separator(str = "=") ⇒ Object
74
75
76
|
# File 'lib/flydata/command/base.rb', line 74
def separator(str="=")
puts str * 64
end
|
#show_purpose_name ⇒ Object
40
41
42
43
|
# File 'lib/flydata/command/base.rb', line 40
def show_purpose_name
de = data_entry
log_info_stdout("Your current application name is '#{de['purpose_name']}'")
end
|
#source ⇒ Object
51
52
53
|
# File 'lib/flydata/command/base.rb', line 51
def source
@source ||= Source.create(data_entry)
end
|