@@ -74,80 +74,6 @@ def pm_refresh_workers
7474 end
7575 alias refresh_workers pm_refresh_workers
7676
77- def log_depot_edit
78- assert_privileges ( "#{ @sb [ :selected_typ ] == "miq_server" ? "" : "zone_" } log_depot_edit" )
79- @record = @sb [ :selected_typ ] . classify . constantize . find ( @sb [ :selected_server_id ] )
80- # @schedule = nil # setting to nil, since we are using same view for both db_back and log_depot edit
81- case params [ :button ]
82- when "cancel"
83- @in_a_form = false
84- @edit = session [ :edit ] = nil
85- add_flash ( _ ( "Edit Log Depot settings was cancelled by the user" ) )
86- diagnostics_set_form_vars
87- replace_right_cell ( :nodetype => x_node )
88- when "save"
89- if @flash_array
90- javascript_flash ( :spinner_off => true )
91- return
92- end
93-
94- begin
95- if params [ :log_protocol ] . blank?
96- @record . log_file_depot . try ( :destroy )
97- else
98- new_uri = "#{ params [ :uri_prefix ] } ://#{ params [ :uri ] } "
99- raise _ ( "Unsupported log depot protocol: %{protocol}" ) % { :protocol => params [ :log_protocol ] } unless FileDepot . supported_depots . key? ( params [ :log_protocol ] )
100-
101- build_supported_depots_for_select
102- log_protocol = params [ :log_protocol ]
103- protocols = FileDepot . supported_depots . map { |k , _v | [ k , k . constantize ] } . to_h
104- raise _ ( 'Invalid or unsupported file depot type.' ) unless protocols . key? ( log_protocol )
105-
106- depot = @record . log_file_depot . instance_of? ( protocols [ log_protocol ] ) ? @record . log_file_depot : @record . build_log_file_depot ( :type => log_protocol )
107- depot . update ( :uri => new_uri , :name => params [ :depot_name ] )
108- creds = set_credentials
109- depot . update_authentication ( creds ) if protocols [ log_protocol ] . try ( :requires_credentials? )
110- @record . save!
111- end
112- rescue => bang
113- add_flash ( _ ( "Error during 'Save': %{message}" ) % { :message => bang . message } , :error )
114- @changed = true
115- render :update do |page |
116- page << javascript_prologue
117- page . replace_html ( "diagnostics_collect_logs" , :partial => "ops/log_collection" )
118- end
119- else
120- add_flash ( _ ( "Log Depot Settings were saved" ) )
121- @edit = nil
122- diagnostics_set_form_vars
123- replace_right_cell ( :nodetype => x_node )
124- end
125- when "validate"
126- creds = set_credentials
127- settings = {
128- :username => creds [ :default ] [ :userid ] ,
129- :password => creds [ :default ] [ :password ] ,
130- :uri => "#{ params [ :uri_prefix ] } ://#{ params [ :uri ] } "
131- }
132-
133- begin
134- log_protocol = params [ :log_protocol ]
135- protocols = FileDepot . supported_depots . map { |k , _v | [ k , k . constantize ] } . to_h
136- raise _ ( "Unsupported log depot protocol: %{protocol}" ) % { :protocol => log_protocol } unless protocols . key? ( log_protocol )
137-
138- protocols [ log_protocol ] . validate_settings ( settings )
139- rescue => bang
140- add_flash ( _ ( "Error during 'Validate': %{message}" ) % { :message => bang . message } , :error )
141- else
142- add_flash ( _ ( "Log Depot Settings were validated" ) )
143- end
144- javascript_flash ( :spinner_off => true )
145- when nil # Reset or first time in
146- @in_a_form = true
147- replace_right_cell ( :nodetype => "log_depot_edit" )
148- end
149- end
150-
15177 # Send the log in text format
15278 def fetch_log
15379 assert_privileges ( "fetch_log" )
@@ -257,36 +183,6 @@ def cu_repair
257183 end
258184 end
259185
260- def log_collection_form_fields
261- assert_privileges ( "#{ @sb [ :selected_typ ] == "miq_server" ? "" : "zone_" } log_depot_edit" )
262- @record = @sb [ :selected_typ ] . classify . constantize . find ( @sb [ :selected_server_id ] )
263- log_depot = @record . log_file_depot
264- log_depot_json = log_depot ? build_log_depot_json ( log_depot ) : build_empty_log_depot_json
265- render :json => log_depot_json
266- end
267-
268- def build_log_depot_json ( log_depot )
269- prefix , uri = log_depot [ :uri ] . to_s . split ( '://' )
270- klass = @record . log_file_depot . try ( :class )
271-
272- log_depot_json = { :depot_name => log_depot [ :name ] ,
273- :uri => uri ,
274- :uri_prefix => prefix ,
275- :log_userid => log_depot . authentication_userid ,
276- :log_protocol => klass . to_s }
277- log_depot_json
278- end
279-
280- def build_empty_log_depot_json
281- log_depot_json = { :depot_name => '' ,
282- :uri => '' ,
283- :uri_prefix => '' ,
284- :log_userid => '' ,
285- :log_password => '' ,
286- :log_protocol => '' }
287- log_depot_json
288- end
289-
290186 def diagnostics_server_list
291187 assert_privileges ( "ops_diagnostics_server_view" )
292188
@@ -376,31 +272,6 @@ def cu_repair_get_form_vars
376272 end
377273 end
378274
379- # Collect the current logs from the selected zone or server
380- def logs_collect ( options = { } )
381- options [ :support_case ] = params [ :support_case ] if params [ :support_case ]
382- obj , id = x_node . split ( "-" )
383- assert_privileges ( "#{ obj == "z" ? "zone_" : "" } collect_logs" )
384- klass = obj == "svr" ? MiqServer : Zone
385- instance = @selected_server = klass . find ( id . to_i )
386- if !instance . active?
387- add_flash ( _ ( "Cannot start log collection, requires a started server" ) , :error )
388- elsif instance . log_collection_active_recently?
389- add_flash ( _ ( "Cannot start log collection, a log collection is already in progress within this scope" ) , :error )
390- else
391- begin
392- options [ :context ] = klass . name
393- instance . synchronize_logs ( session [ :userid ] , options )
394- rescue => bang
395- add_flash ( _ ( "Log collection error returned: %{error_message}" ) % { :error_message => bang . message } , :error )
396- else
397- add_flash ( _ ( "Log collection for %{product} %{object_type} %{name} has been initiated" ) % { :product => Vmdb ::Appliance . PRODUCT_NAME , :object_type => klass . name , :name => instance . display_name } )
398- end
399- end
400- get_node_info ( x_node )
401- replace_right_cell ( :nodetype => x_node )
402- end
403-
404275 # Reload the selected node and redraw the screen via ajax
405276 def refresh_server_summary
406277 assert_privileges ( "refresh_server_summary" )
@@ -677,7 +548,7 @@ def diagnostics_set_form_vars
677548 @sb [ :selected_typ ] = "miq_server"
678549 end
679550 else
680- @sb [ :active_tab ] = "diagnostics_collect_logs " # setting it to show collect logs tab as first tab for the servers that are not started
551+ @sb [ :active_tab ] = "diagnostics_summary " # setting it to summary tab as first tab for the servers that are not started
681552 @record = @selected_server = MiqServer . find ( x_node . split ( "-" ) . last . to_i )
682553 @sb [ :selected_server_id ] = @selected_server . id
683554 @sb [ :selected_typ ] = "miq_server"
@@ -726,20 +597,4 @@ def diagnostics_get_info
726597 diagnostics_set_form_vars
727598 end
728599 end
729-
730- def build_supported_depots_for_select
731- not_supported_depots = %w[ FileDepotS3 FileDepotSwift ]
732- supported_depots = FileDepot . supported_depots . reject { |model , _desc | not_supported_depots . include? ( model ) }
733- @uri_prefixes = supported_depots . keys . map { |model | [ model , model . constantize . uri_prefix ] } . to_h
734- @supported_depots_for_select = { '' => _ ( '<No Depot>' ) } . merge ( supported_depots )
735- end
736-
737- def set_credentials
738- creds = { }
739- if params [ :log_userid ]
740- log_password = params [ :log_password ] || @record . log_file_depot . authentication_password
741- creds [ :default ] = { :userid => params [ :log_userid ] , :password => log_password }
742- end
743- creds
744- end
745600end
0 commit comments