# -*- coding: utf-8 -*-

module Dcmgr::Models
  class VolumeSnapshot < AccountResource
    taggable 'snap'

    STATE_TYPE_REGISTERING = "registering"
    STATE_TYPE_CREATING = "creating"
    STATE_TYPE_AVAILABLE = "available"
    STATE_TYPE_FAILED = "failed"
    STATE_TYPE_DELETING = "deleting"
    STATE_TYPE_DELETED = "deleted"

    inheritable_schema do
      Fixnum :storage_pool_id, :null=>false
      String :origin_volume_id, :null=>false
      Fixnum :size, :null=>false
      Fixnum :status, :null=>false, :default=>0
      String :state, :null=>false, :default=>STATE_TYPE_REGISTERING
      String :destination_key, :null=>false 
      Time   :deleted_at
      index :storage_pool_id
      index  :deleted_at
    end
    with_timestamps

    many_to_one :storage_pool
    plugin ArchiveChangedColumn, :histories

    RECENT_TERMED_PERIOD=(60 * 15)
    # lists the volumes are available and deleted within
    # RECENT_TERMED_PERIOD sec.
    def_dataset_method(:alives_and_recent_termed) {
      filter("deleted_at IS NULL OR deleted_at >= ?", (Time.now.utc - RECENT_TERMED_PERIOD))
    }

    class RequestError < RuntimeError; end

    # Hash data for API response.
    def to_api_document
      h = {
        :id => self.canonical_uuid,
        :uuid => self.canonical_uuid,
        :state => self.state,
        :size => self.size,
        :origin_volume_id => self.origin_volume_id,
        :destination_id => self.destination,
        :destination_name => self.display_name, 
        :created_at => self.created_at,
        :deleted_at => self.deleted_at,
      }
    end

    # create volume inherite from this snapshot for the account.
    # limitation: inherit volume is created on same storage_pool.
    def create_volume(account_id)
      storage_pool.create_volume(account_id, self.size, self.canonical_uuid)
    end

    def display_name
      repository_config = Dcmgr::StorageService.snapshot_repository_config
      repository = repository_config[self.destination]
      repository['display_name']
    end

    def origin_volume
      Volume[origin_volume_id]
    end
    
    def snapshot_filename
      "#{self.canonical_uuid}.zsnap"
    end
    
    def destination
      self.destination_key.split('@')[0]
    end

    def self.delete_snapshot(account_id, uuid)
      vs = self.dataset.where(:account_id => account_id).where(:uuid => uuid.split('-').last).first
      if vs.state.to_sym != :available
        raise RequestError, "invalid delete request"
      end
      vs.state = :deleting
      vs.save_changes
    end
    
    def update_destination_key(account_id, destination_key)
      self.destination_key = destination_key
      self.save_changes
    end

    def self.store_local?(destination)
      destination.nil?
    end 

  end
end