module Nucleon
module Plugin
class Machine < CORL.plugin_class(:base)

  #-----------------------------------------------------------------------------
  # Machine plugin interface
  
  def normalize(reload)
  end
       
  #-----------------------------------------------------------------------------
  # Checks
  
  def created?
    false
  end
  
  #---
  
  def running?
    ( created? && false )
  end
   
  #-----------------------------------------------------------------------------
  # Property accessors / modifiers
  
  def node
    plugin_parent
  end
 
  def node=node
    myself.plugin_parent = node
  end
  
  #---
  
  def state
    nil
  end
  
  #---
  
  def hostname
    nil
  end
  
  #---
  
  def public_ip
    nil
  end
  
  #---
  
  def private_ip
    nil
  end
  
  #---
    
  def machine_types
    []
  end
  
  #---
  
  def machine_type
    nil
  end
  
  #---
  
  def images
    []
  end
  
  #---
  
  def image
    nil
  end
            
  #-----------------------------------------------------------------------------
  # Management
  
  def load
    success = true
    
    logger.debug("Loading #{plugin_provider} machine: #{plugin_name}")
    success = yield if block_given?  
        
    logger.warn("There was an error loading the machine #{plugin_name}") unless success
    success
  end
  
  #---
  
  def create(options = {})
    success = true
    
    if created?
      logger.debug("Machine #{plugin_name} already exists")
    else
      logger.debug("Creating #{plugin_provider} machine with: #{options.inspect}")
      config  = Config.ensure(options)
      success = yield(config) if block_given?  
    end
    
    logger.warn("There was an error creating the machine #{plugin_name}") unless success
    success
  end
  
  #---
  
  def download(remote_path, local_path, options = {})
    success = true
    
    if running?
      logger.debug("Downloading #{local_path} from #{remote_path} on #{plugin_provider} machine with: #{options.inspect}")
      config  = Config.ensure(options)      
      success = yield(config, success) if block_given?
    else
      logger.debug("Machine #{plugin_name} is not running")  
    end
    
    logger.warn("There was an error downloading from the machine #{plugin_name}") unless success
    success
  end
  
  #---
  
  def upload(local_path, remote_path, options = {})
    success = true
    
    if running?
      logger.debug("Uploading #{local_path} to #{remote_path} on #{plugin_provider} machine with: #{options.inspect}")
      config  = Config.ensure(options)      
      success = yield(config, success) if block_given?
    else
      logger.debug("Machine #{plugin_name} is not running")  
    end
    
    logger.warn("There was an error uploading to the machine #{plugin_name}") unless success
    success
  end
  
  #---
  
  def exec(commands, options = {})
    results = []
    
    if running?
      logger.info("Executing commands ( #{commands.inspect} ) on machine #{plugin_name}")
      config  = Config.ensure(options)      
      results = yield(config, results) if block_given?
    else
      logger.debug("Machine #{plugin_name} is not running")  
    end
    
    logger.warn("There was an error executing command on the machine #{plugin_name}") unless results
    results
  end
  
  #---
  
  def terminal(user, options = {})
    status = code.unknown_status
    
    if running?
      logger.debug("Launching #{user} terminal on #{plugin_provider} machine with: #{options.inspect}")
      config = Config.ensure(options)      
      status = yield(config) if block_given?
    else
      logger.debug("Machine #{plugin_name} is not running")  
    end    
    logger.warn("There was an error launching a #{user} terminal on the machine #{plugin_name}") unless status == code.success
    status
  end
  
  #---
  
  def reload(options = {})
    success = true
    
    if created?
      logger.debug("Reloading #{plugin_provider} machine with: #{options.inspect}")
      config  = Config.ensure(options)
      success = yield(config) if block_given?
    else
      logger.debug("Machine #{plugin_name} does not yet exist")
    end
    
    logger.warn("There was an error reloading the machine #{plugin_name}") unless success
    success
  end

  #---
  
  def create_image(options = {})
    success = true
    
    if running?
      logger.debug("Creating image of #{plugin_provider} machine with: #{options.inspect}")
      config  = Config.ensure(options)      
      success = yield(config) if block_given?
    else
      logger.debug("Machine #{plugin_name} is not running")  
    end
    
    logger.warn("There was an error creating an image of the machine #{plugin_name}") unless success
    success
  end

  #---
  
  def stop(options = {})
    success = true
    
    if running?
      logger.debug("Stopping #{plugin_provider} machine with: #{options.inspect}")
      config  = Config.ensure(options)      
      success = yield(config) if block_given?
    else
      logger.debug("Machine #{plugin_name} is not running")  
    end
    
    logger.warn("There was an error stopping the machine #{plugin_name}") unless success
    success
  end
  
  #---
  
  def start(options = {})
    success = true
    
    if running?
      logger.debug("Machine #{plugin_name} is already running")  
    else
      logger.debug("Starting #{plugin_provider} machine with: #{options.inspect}")
      
      logger.debug("Machine #{plugin_name} is not running yet")
      if block_given?
        success = yield(config)  
      else
        success = create(options)  
      end            
    end
    
    logger.warn("There was an error starting the machine #{plugin_name}") unless success
    success
  end
  
  #---

  def destroy(options = {})   
    success = true
    
    if created?
      logger.debug("Destroying #{plugin_provider} machine with: #{options.inspect}")
      config  = Config.ensure(options)
      success = yield(config) if block_given?
    else
      logger.debug("Machine #{plugin_name} does not yet exist")
    end
    
    logger.warn("There was an error destroying the machine #{plugin_name}") unless success
    success
  end
  
  #-----------------------------------------------------------------------------
  # Utilities

  def translate_state(state)
    return string(state).downcase.to_sym if status
    :unknown
  end
end
end
end