Class: VMC::KNIFE::RecipesConfigurationApplier
- Inherits:
-
Object
- Object
- VMC::KNIFE::RecipesConfigurationApplier
- Defined in:
- lib/vmc_knife/vmc_knife.rb,
lib/vmc_knife/data_services.rb
Instance Attribute Summary collapse
-
#applications ⇒ Object
Returns the value of attribute applications.
-
#client ⇒ Object
Returns the value of attribute client.
-
#data_services ⇒ Object
Returns the value of attribute data_services.
-
#opts ⇒ Object
Returns the value of attribute opts.
-
#recipes ⇒ Object
Returns the value of attribute recipes.
-
#root ⇒ Object
Returns the value of attribute root.
Instance Method Summary collapse
-
#__set_current(current_services = nil, current_services_info = nil) ⇒ Object
Only for testing: inject json.
- #apply_privileges ⇒ Object
- #credentials ⇒ Object
- #delete ⇒ Object
- #drop ⇒ Object
- #execute ⇒ Object
- #export ⇒ Object
- #extract_deployed ⇒ Object
- #import ⇒ Object
- #info ⇒ Object
-
#initialize(manifest, client, recipe_sel = nil, application_sel = nil, service_sel = nil, opts = nil) ⇒ RecipesConfigurationApplier
constructor
Select the applications and data-services to configure according to the values in the SaaS manifest.
- #logs ⇒ Object
- #logs_shell ⇒ Object
- #patch ⇒ Object
- #restart ⇒ Object
- #running_applications? ⇒ Boolean
- #shell ⇒ Object
- #shrink ⇒ Object
- #start ⇒ Object
- #stop ⇒ Object
- #update ⇒ Object
- #updates_pending ⇒ Object
- #upload ⇒ Object
- #version ⇒ Object
Constructor Details
#initialize(manifest, client, recipe_sel = nil, application_sel = nil, service_sel = nil, opts = nil) ⇒ RecipesConfigurationApplier
Select the applications and data-services to configure according to the values in the SaaS manifest. When the selector is nil all of them are selected.
276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 |
# File 'lib/vmc_knife/vmc_knife.rb', line 276 def initialize(manifest, client, recipe_sel=nil, application_sel=nil, service_sel=nil, opts=nil) @root = Root.new manifest @client = client @opts=opts @recipes = @root.recipes(recipe_sel) @applications = Array.new @data_services = Array.new @recipes.each do |recipe| @applications = @applications + recipe.applications(application_sel) @data_services = @data_services + recipe.data_services(service_sel) end app_names = @applications.collect {|app| app.name } unless @opts && @opts[:data_only] service_names = @data_services.collect {|service| service.name } unless @opts && @opts[:apps_only] app_names ||= Array.new service_names ||= Array.new if app_names.empty? && service_names.empty? puts "No applications and data-services were selected." else puts "Applications selected #{app_names.join(', ')}" unless app_names.empty? puts "Data-services selected #{service_names.join(', ')}" unless service_names.empty? end end |
Instance Attribute Details
#applications ⇒ Object
Returns the value of attribute applications.
273 274 275 |
# File 'lib/vmc_knife/vmc_knife.rb', line 273 def applications @applications end |
#client ⇒ Object
Returns the value of attribute client.
273 274 275 |
# File 'lib/vmc_knife/vmc_knife.rb', line 273 def client @client end |
#data_services ⇒ Object
Returns the value of attribute data_services.
273 274 275 |
# File 'lib/vmc_knife/vmc_knife.rb', line 273 def data_services @data_services end |
#opts ⇒ Object
Returns the value of attribute opts.
273 274 275 |
# File 'lib/vmc_knife/vmc_knife.rb', line 273 def opts @opts end |
#recipes ⇒ Object
Returns the value of attribute recipes.
273 274 275 |
# File 'lib/vmc_knife/vmc_knife.rb', line 273 def recipes @recipes end |
#root ⇒ Object
Returns the value of attribute root.
273 274 275 |
# File 'lib/vmc_knife/vmc_knife.rb', line 273 def root @root end |
Instance Method Details
#__set_current(current_services = nil, current_services_info = nil) ⇒ Object
Only for testing: inject json
299 300 301 302 |
# File 'lib/vmc_knife/vmc_knife.rb', line 299 def __set_current(current_services=nil,current_services_info=nil) @current_services = current_services @current_services_info = current_services_info end |
#apply_privileges ⇒ Object
200 201 202 203 204 |
# File 'lib/vmc_knife/data_services.rb', line 200 def apply_privileges() @data_services.each do |data_service| data_service.apply_privileges end end |
#credentials ⇒ Object
195 196 197 198 199 |
# File 'lib/vmc_knife/data_services.rb', line 195 def credentials() @data_services.each do |data_service| data_service.credentials end end |
#delete ⇒ Object
394 395 396 397 398 399 400 401 402 403 |
# File 'lib/vmc_knife/vmc_knife.rb', line 394 def delete() @applications.each do |application| application_updater = ApplicationManifestApplier.new application, @client application_updater.delete end @data_services.each do |data_service| data_service_updater = DataServiceManifestApplier.new data_service, @client, @current_services, @current_services_info data_service_updater.delete end end |
#drop ⇒ Object
219 220 221 222 223 224 |
# File 'lib/vmc_knife/data_services.rb', line 219 def drop() collection_or_table_names = @opts[:collection_or_table_names] if @opts @data_services.each do |data_service| data_service.drop(collection_or_table_names) end end |
#execute ⇒ Object
471 472 473 474 475 476 477 478 479 |
# File 'lib/vmc_knife/vmc_knife.rb', line 471 def execute() return if updates_pending.empty? @data_service_updaters.each do |name,data_service_updater| data_service_updater.execute end @application_updaters.each do |name,application_updater| application_updater.execute end end |
#export ⇒ Object
212 213 214 215 216 217 218 |
# File 'lib/vmc_knife/data_services.rb', line 212 def export() file_names = @opts[:file_names] if @opts app_name = @opts[:app_name] if @opts @data_services.each do |data_service| data_service.export(app_name,file_names) end end |
#extract_deployed ⇒ Object
368 369 370 371 372 373 |
# File 'lib/vmc_knife/vmc_knife.rb', line 368 def extract_deployed() @applications.each do |application| application_updater = ApplicationManifestApplier.new application, @client application_updater.extract_deployed(@opts[:force]) end end |
#import ⇒ Object
205 206 207 208 209 210 211 |
# File 'lib/vmc_knife/data_services.rb', line 205 def import() file_names = @opts[:file_names] if @opts app_name = @opts[:app_name] if @opts @data_services.each do |data_service| data_service.import(app_name,file_names) end end |
#info ⇒ Object
374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 |
# File 'lib/vmc_knife/vmc_knife.rb', line 374 def info() configure_only=@opts[:configure_only] || false if configure_only if updates_pending().empty? puts "All configuration up to date: true" return true else puts "All configuration up to data: false" return false end end up_to_date=true @applications.each do |application| application_updater = ApplicationManifestApplier.new application, @client app_up_to_date = application_updater.info() up_to_date = false unless app_up_to_date end puts "All up to date: #{up_to_date}" return up_to_date end |
#logs ⇒ Object
490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 |
# File 'lib/vmc_knife/vmc_knife.rb', line 490 def logs() output_file=@opts[:output_file] if @opts if @root.wrapped['logs'] man_logs=@root.wrapped['logs'] name_prefix=man_logs['prefix'] parent_output_folder=man_logs['destination'] if parent_output_folder FileUtils.mkdir_p parent_output_folder logs_base_url=man_logs['logs_base_url'] # TODO: clean the old files and folders if there are too many of them. end other_logs = man_logs['other_logs'] end name_prefix||="cflogs-" parent_output_folder||="/tmp" name="#{name_prefix}#{Time.now.strftime("%Y%m%d-%H%M%S")}" output_file||="#{name}.zip" output_folder="#{parent_output_folder}/#{name}" FileUtils.rm_rf(output_folder) if File.exist? output_folder FileUtils.mkdir(output_folder) log_apps=@opts[:log_apps] if @opts log_vcap=@opts[:log_vcap] if @opts log_apps||=false log_vcap||=false if log_apps FileUtils.mkdir(File.join(output_folder, 'apps')) @applications.each do |application| application.log(File.join(output_folder, 'apps')) end svc_dir = File.join(output_folder, 'services') FileUtils.mkdir(svc_dir) @data_services.each do | ds | ds.log(svc_dir) end end if log_vcap if ENV['CLOUD_FOUNDRY_CONFIG_PATH'] && File.exist?(ENV['CLOUD_FOUNDRY_CONFIG_PATH']) vcap_log_folder = File.join(File.dirname(ENV['CLOUD_FOUNDRY_CONFIG_PATH']), "log") else puts "Can't find the log folder for vcap, the environment variable CLOUD_FOUNDRY_CONFIG_PATH is not defined." end if File.exist? vcap_log_folder FileUtils.mkdir(File.join(output_folder, 'vcap')) FileUtils.cp_r Dir.glob(File.join(vcap_log_folder,"*")), File.join(output_folder, 'vcap') end end if other_logs other_logs_dir=File.join(output_folder, 'other_logs') FileUtils.mkdir other_logs_dir other_logs.each do |name,glob| other_dir=File.join(other_logs_dir, name) FileUtils.mkdir other_dir FileUtils.cp_r Dir.glob(glob), other_dir end end curr_dir=Dir.pwd destination=parent_output_folder||curr_dir copy_or_move=("/tmp" == parent_output_folder)?"mv":"cp" if "/tmp" == parent_output_folder puts "Generating a zip of the logs as #{curr_dir}/#{output_file}" else if logs_base_url hostname=`hostname`.strip complete_base_url= logs_base_url =~ /:\/\// ? logs_base_url : "http://#{hostname}.local#{logs_base_url}" puts "Logs available at #{complete_base_url}/#{name} and in #{parent_output_folder}/#{name}" end end `cd #{File.dirname(output_folder)}; zip -r #{output_file} #{File.basename(output_folder)}; #{copy_or_move} #{output_file} #{curr_dir}` if "/tmp" == parent_output_folder `rm -rf #{output_folder}` else `mv #{parent_output_folder}/#{output_file} #{parent_output_folder}/#{name}` end if logs_base_url # not the most elegant code to cp then delete: `rm #{output_file}` unless @opts[:output_file] end end |
#logs_shell ⇒ Object
480 481 482 483 484 485 486 487 488 489 |
# File 'lib/vmc_knife/vmc_knife.rb', line 480 def logs_shell() log_apps=@opts[:log_apps] if @opts logs_shell=@opts[:logs_shell] if @opts log_files_glob=@opts[:log_files_glob] if @opts raise "The name of the application to read its log is required." unless log_apps @applications.each do |application| application.log_shell(logs_shell,log_files_glob) end raise "No application with this name was found." end |
#patch ⇒ Object
362 363 364 365 366 367 |
# File 'lib/vmc_knife/vmc_knife.rb', line 362 def patch() @applications.each do |application| application_updater = ApplicationManifestApplier.new application, @client application_updater.patch(@opts[:force]) end end |
#restart ⇒ Object
404 405 406 407 |
# File 'lib/vmc_knife/vmc_knife.rb', line 404 def restart() stop() start() end |
#running_applications? ⇒ Boolean
414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 |
# File 'lib/vmc_knife/vmc_knife.rb', line 414 def running_applications?() if @opts && @opts[:wait] tries = @opts[:wait][:retries] tries = tries.to_i if tries interval = @opts[:wait][:interval] interval = interval.to_i if interval end tries ||= 1 interval ||= 30 curr_iteration = 0 already_running = {} @applications.each do |application| already_running[application.name] = "false" end vmc_apps = Array.new while (curr_iteration <= tries) # brute approach: cmd-line. vmc_apps = ENV['TEST_VMC_APPS_STRING'] # this is for testing. unless vmc_apps vmc_apps = `vmc apps`.strip.split("\n") raise "Unable to run vmc" unless $?.exitstatus == 0 end current_healths = Hash.new vmc_apps.each do |line| if line =~ /^\| (\S*)\s*\|\s*\d*\s*\|\s*(\S*)\s*\|/ app = $1 health = $2 current_healths[app] = health end end not_running = Array.new @applications.each do |application| #health = `echo "#{vmc_apps}" | grep \|\ #{application.name}\ | cut -d '|' -f4` health = current_healths[application.name] already_running[application.name] = health not_running << application.name unless health == 'RUNNING' end all_running = not_running.empty? curr_iteration = curr_iteration + 1 break if not_running.empty? || curr_iteration == tries p "Sleeping #{interval}s as #{not_running.join(' ')} #{not_running.size == 1 ? 'is' : 'are' } not running yet." sleep(interval) end p "Success: all apps are running" if all_running return true if all_running p "At least one app is not running" vmc_apps.each do |line| p line end return false end |
#shell ⇒ Object
184 185 186 187 188 189 190 191 192 193 194 |
# File 'lib/vmc_knife/data_services.rb', line 184 def shell() app_name = @opts[:app_name] if @opts file_name = @opts[:file_name] if @opts data_cmd = @opts[:data_cmd] if @opts if data_cmd file_name = data_cmd end @data_services.each do |data_service| data_service.shell(file_name) end end |
#shrink ⇒ Object
225 226 227 228 229 230 |
# File 'lib/vmc_knife/data_services.rb', line 225 def shrink() collection_or_table_names = @opts[:collection_or_table_names] if @opts @data_services.each do |data_service| data_service.shrink(collection_or_table_names) end end |
#start ⇒ Object
465 466 467 468 469 470 |
# File 'lib/vmc_knife/vmc_knife.rb', line 465 def start() @applications.each do |application| application_updater = ApplicationManifestApplier.new application, @client application_updater.start end end |
#stop ⇒ Object
408 409 410 411 412 413 |
# File 'lib/vmc_knife/vmc_knife.rb', line 408 def stop() @applications.each do |application| application_updater = ApplicationManifestApplier.new application, @client application_updater.stop end end |
#update ⇒ Object
356 357 358 359 360 361 |
# File 'lib/vmc_knife/vmc_knife.rb', line 356 def update() @applications.each do |application| application_updater = ApplicationManifestApplier.new application, @client application_updater.update(@opts[:force]) end end |
#updates_pending ⇒ Object
303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 |
# File 'lib/vmc_knife/vmc_knife.rb', line 303 def updates_pending() return @updates_report if @updates_report @current_services ||= @client.services @current_services_info ||= @client.services_info res = Hash.new data_services_updates = Hash.new applications_updates = Hash.new @data_service_updaters = Hash.new @application_updaters = Hash.new @data_services.each do |data_service| unless @data_service_updaters[data_service.name] data_service_updater = DataServiceManifestApplier.new data_service, @client, @current_services, @current_services_info @data_service_updaters[data_service.name] = data_service_updater updates = data_service_updater.updates_pending data_services_updates[data_service.name] = updates if updates end end @applications.each do |application| unless @application_updaters[application.name] application_updater = ApplicationManifestApplier.new application, @client @application_updaters[application.name] = application_updater updates = application_updater.updates_pending applications_updates[application.name] = updates if updates # if we did bind to a database; let's re-assign the ownership of the sql functions # to the favorite app if there is such a thing. if updates && updates['services'] && updates['services']['add'] list_services_name=updates['services']['add'] list_services_name.each do |cf_service_name| @data_services.each do |data_service| if data_service.name == cf_service_name # is this the privileged app? priv_app_name = data_service.wrapped['director']['bound_app'] if data_service.wrapped['director'] if priv_app_name == application.name data_service.apply_privileges(priv_app_name) end end end end end end end res['services'] = data_services_updates unless data_services_updates.empty? res['applications'] = applications_updates unless applications_updates.empty? @updates_report = res puts JSON.pretty_generate @updates_report @updates_report end |
#upload ⇒ Object
350 351 352 353 354 355 |
# File 'lib/vmc_knife/vmc_knife.rb', line 350 def upload() @applications.each do |application| application_updater = ApplicationManifestApplier.new application, @client application_updater.upload(@opts[:force]) end end |
#version ⇒ Object
571 572 573 574 575 576 577 578 579 580 581 |
# File 'lib/vmc_knife/vmc_knife.rb', line 571 def version() versions = {} @applications.each do |application| application_updater = ApplicationManifestApplier.new(application, @client) ver = application_updater.version_installed() puts "#{application.name()} => #{ver}" if VMC::Cli::Config.trace versions[application.name()] = ver end puts versions versions end |