volume_snapshot.rb in wakame-vdc-agents-11.06.0

- old
+ new
@@ -15,46 +15,83 @@
       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