Class: Bosh::Cli::Command::Micro

Inherits:

Base

• Object
• Base
• Bosh::Cli::Command::Micro

Includes:

DeploymentHelper, Deployer::Helpers

Defined in:

lib/bosh/cli/commands/micro.rb

Defined Under Namespace

Classes: DeployerRenderer

Constant Summary

MICRO_DIRECTOR_PORT =

25555

DEFAULT_CONFIG_PATH =

File.expand_path("~/.bosh_deployer_config")

Constants included from Deployer::Helpers

Deployer::Helpers::DEPLOYMENTS_FILE

Instance Method Summary

• #agent(*args) ⇒ Object
• #apply(spec) ⇒ Object
• #delete ⇒ Object
• #initialize(options = {}) ⇒ Micro constructor

  A new instance of Micro.

• #list ⇒ Object
• #perform(*options) ⇒ Object
• #set_current(name) ⇒ Object
• #show_current ⇒ Object
• #status ⇒ Object

Methods included from Deployer::Helpers

#cloud_plugin, #dig_hash, #is_tgz?

Constructor Details

#initialize(options = {}) ⇒ Micro

Returns a new instance of Micro.

# File 'lib/bosh/cli/commands/micro.rb', line 56

def initialize(options = {})
  options[:config] ||= DEFAULT_CONFIG_PATH #hijack Cli::Config
  super(options)
end

Instance Method Details

#agent(*args) ⇒ Object

# File 'lib/bosh/cli/commands/micro.rb', line 252

def agent(*args)
  message = args.shift
  args = args.map do |arg|
    if File.exists?(arg)
      load_yaml_file(arg)
    else
      arg
    end
  end

  say(deployer.agent.send(message.to_sym, *args).pretty_inspect)
end

#apply(spec) ⇒ Object

# File 'lib/bosh/cli/commands/micro.rb', line 265

def apply(spec)
  deployer.apply(load_yaml_file(spec))
end

#delete ⇒ Object

# File 'lib/bosh/cli/commands/micro.rb', line 159

def delete
  unless deployer.exists?
    err "No existing instance to delete"
  end

  name = deployer.state.name

  say "\nYou are going to delete micro BOSH deployment `#{name}'.\n\n" \
  "THIS IS A VERY DESTRUCTIVE OPERATION AND IT CANNOT BE UNDONE!\n".red

  unless confirmed?
    say "Canceled deleting deployment".green
    return
  end

  renderer = DeployerRenderer.new
  renderer.start
  deployer.renderer = renderer

  start_time = Time.now

  deployer.delete_deployment

  renderer.finish("done")

  duration = renderer.duration || (Time.now - start_time)

  say("Deleted deployment '#{name}', took #{format_time(duration).green} to complete")
end

#list ⇒ Object

# File 'lib/bosh/cli/commands/micro.rb', line 227

def list
  file = File.join(work_dir, DEPLOYMENTS_FILE)
  if File.exists?(file)
    deployments = load_yaml_file(file)["instances"]
  else
    deployments = []
  end

  err("No deployments") if deployments.size == 0

  na = "n/a"

  deployments_table = table do |t|
    t.headings = [ "Name", "VM name", "Stemcell name" ]
    deployments.each do |r|
      t << [ r[:name], r[:vm_cid] || na, r[:stemcell_cid] || na  ]
    end
  end

  say("\n")
  say(deployments_table)
  say("\n")
  say("Deployments total: %d" % deployments.size)
end

#perform(*options) ⇒ Object

# File 'lib/bosh/cli/commands/micro.rb', line 81

def perform(*options)
  update = options.delete("--update")
  stemcell = options.shift

  err "No deployment set" unless deployment

  manifest = load_yaml_file(deployment)

  if stemcell.nil?
    unless manifest.is_a?(Hash)
      err("Invalid manifest format")
    end

    stemcell = dig_hash(manifest, "cloud", "properties", "stemcell", "image_id")

    if stemcell.nil?
      err "No stemcell provided"
    end
  end

  rel_path = deployment[/#{Regexp.escape File.join(work_dir, '')}(.*)/, 1]

  desc = "`#{rel_path.green}' to `#{target_name.green}'"

  if update
    unless deployer.exists?
      err "No existing instance to update"
    end

    confirmation = "Updating"

    method = :update_deployment
  else
    if deployer.exists?
      err "Instance exists.  Did you mean to --update?"
    end

    # make sure the user knows a persistent disk is required
    unless dig_hash(manifest, "resources", "persistent_disk")
      quit("No persistent disk configured!".red)
    end

    confirmation = "Deploying new"

    method = :create_deployment
  end

  confirm_deployment("#{confirmation} micro BOSH instance #{desc}")

  if is_tgz?(stemcell)
    stemcell_file = Bosh::Cli::Stemcell.new(stemcell, cache)

    say("\nVerifying stemcell...")
    stemcell_file.validate
    say("\n")

    unless stemcell_file.valid?
      err("Stemcell is invalid, please fix, verify and upload again")
    end
  end

  renderer = DeployerRenderer.new
  renderer.start
  deployer.renderer = renderer

  start_time = Time.now

  deployer.send(method, stemcell)

  renderer.finish("done")

  duration = renderer.duration || (Time.now - start_time)

  update_target

  say("Deployed #{desc}, took #{format_time(duration).green} to complete")
end

#set_current(name) ⇒ Object

# File 'lib/bosh/cli/commands/micro.rb', line 189

def set_current(name)
  manifest_filename = find_deployment(name)

  if !File.exists?(manifest_filename)
    err "Missing manifest for #{name} (tried '#{manifest_filename}')"
  end

  manifest = load_yaml_file(manifest_filename)

  unless manifest.is_a?(Hash)
    err "Invalid manifest format"
  end

  if manifest["network"].blank?
    err "network is not defined in deployment manifest"
  end
  ip = deployer(manifest_filename).discover_bosh_ip || name

  if target
    old_director_ip = URI.parse(target).host
  else
    old_director_ip = nil
  end

  if old_director_ip != ip
    set_target(ip)
    say "#{"WARNING!".red} Your target has been changed to `#{target.red}'!"
  end

  say "Deployment set to '#{manifest_filename.green}'"
  config.set_deployment(manifest_filename)
  config.save
end

#show_current ⇒ Object

# File 'lib/bosh/cli/commands/micro.rb', line 223

def show_current
  say(deployment ? "Current deployment is '#{deployment.green}'" : "Deployment not set")
end

#status ⇒ Object

# File 'lib/bosh/cli/commands/micro.rb', line 61

def status
  stemcell_cid = deployer_state(:stemcell_cid)
  stemcell_name = deployer_state(:stemcell_name)
  vm_cid = deployer_state(:vm_cid)
  disk_cid = deployer_state(:disk_cid)
  deployment = config.deployment ? config.deployment.green : "not set".red

  say("Stemcell CID".ljust(15) + stemcell_cid)
  say("Stemcell name".ljust(15) + stemcell_name)
  say("VM CID".ljust(15) + vm_cid)
  say("Disk CID".ljust(15) + disk_cid)
  say("Micro BOSH CID".ljust(15) + Bosh::Deployer::Config.uuid)
  say("Deployment".ljust(15) + deployment)

  update_target

  target_name = full_target_name ? full_target_name.green : "not set".red
  say("Target".ljust(15) + target_name)
end