Class: Bosh::Director::Jobs::UpdateStemcell
- Includes:
- DownloadHelper, ValidationHelper
- Defined in:
- lib/bosh/director/jobs/update_stemcell.rb
Constant Summary collapse
- UPDATE_STEPS =
5
Instance Attribute Summary
Attributes inherited from BaseJob
Class Method Summary collapse
Instance Method Summary collapse
-
#initialize(stemcell_path, options = {}) ⇒ UpdateStemcell
constructor
A new instance of UpdateStemcell.
- #perform ⇒ Object
Methods included from DownloadHelper
Methods included from ValidationHelper
Methods inherited from BaseJob
#begin_stage, #event_log, #logger, perform, #result_file, #single_step_stage, #task_cancelled?, #task_checkpoint, #track_and_log
Constructor Details
#initialize(stemcell_path, options = {}) ⇒ UpdateStemcell
Returns a new instance of UpdateStemcell.
19 20 21 22 23 24 25 26 27 28 29 30 31 |
# File 'lib/bosh/director/jobs/update_stemcell.rb', line 19 def initialize(stemcell_path, = {}) if ['remote'] # file will be downloaded to the stemcell_path @stemcell_path = File.join(Dir.tmpdir, "stemcell-#{SecureRandom.uuid}") @stemcell_url = stemcell_path else # file already exists at the stemcell_path @stemcell_path = stemcell_path end @cloud = Config.cloud @stemcell_manager = Api::StemcellManager.new end |
Class Method Details
.job_type ⇒ Object
13 14 15 |
# File 'lib/bosh/director/jobs/update_stemcell.rb', line 13 def self.job_type :update_stemcell end |
Instance Method Details
#perform ⇒ Object
33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 |
# File 'lib/bosh/director/jobs/update_stemcell.rb', line 33 def perform logger.info("Processing update stemcell") event_log.begin_stage("Update stemcell", @stemcell_url ? UPDATE_STEPS + 1 : UPDATE_STEPS) track_and_log("Downloading remote stemcell") { download_remote_stemcell } if @stemcell_url stemcell_dir = Dir.mktmpdir("stemcell") track_and_log("Extracting stemcell archive") do result = Bosh::Exec.sh("tar -C #{stemcell_dir} -xzf #{@stemcell_path} 2>&1", :on_error => :return) if result.failed? logger.error("Extracting stemcell archive failed in dir #{stemcell_dir}, " + "tar returned #{result.exit_status}, " + "output: #{result.output}") raise StemcellInvalidArchive, "Extracting stemcell archive failed. Check task debug log for details." end end track_and_log("Verifying stemcell manifest") do stemcell_manifest_file = File.join(stemcell_dir, "stemcell.MF") stemcell_manifest = Psych.load_file(stemcell_manifest_file) @name = safe_property(stemcell_manifest, "name", :class => String) @operating_system = safe_property(stemcell_manifest, "operating_system", :class => String, :optional => true) @version = safe_property(stemcell_manifest, "version", :class => String) @cloud_properties = safe_property(stemcell_manifest, "cloud_properties", :class => Hash, :optional => true) @sha1 = safe_property(stemcell_manifest, "sha1", :class => String) logger.info("Found stemcell image `#{@name}/#{@version}', " + "cloud properties are #{@cloud_properties.inspect}") logger.info("Verifying stemcell image") @stemcell_image = File.join(stemcell_dir, "image") unless File.file?(@stemcell_image) raise StemcellImageNotFound, "Stemcell image not found" end end track_and_log("Checking if this stemcell already exists") do if @stemcell_manager.stemcell_exists?(@name, @version) raise StemcellAlreadyExists, "Stemcell `#{@name}/#{@version}' already exists" end end stemcell = Models::Stemcell.new stemcell.name = @name stemcell. = @operating_system stemcell.version = @version stemcell.sha1 = @sha1 track_and_log("Uploading stemcell #{@name}/#{@version} to the cloud") do stemcell.cid = @cloud.create_stemcell(@stemcell_image, @cloud_properties) logger.info("Cloud created stemcell: #{stemcell.cid}") end track_and_log("Save stemcell #{@name}/#{@version} (#{stemcell.cid})") do stemcell.save end "/stemcells/#{stemcell.name}/#{stemcell.version}" ensure FileUtils.rm_rf(stemcell_dir) if stemcell_dir FileUtils.rm_rf(@stemcell_path) if @stemcell_path end |