1
0
Fork 0
mirror of https://github.com/fog/fog.git synced 2022-11-09 13:51:43 -05:00
fog--fog/lib/fog/model.rb

132 lines
2.9 KiB
Ruby
Raw Normal View History

2009-08-02 19:37:54 -04:00
module Fog
class Model
def self._load(marshalled)
new(Marshal.load(marshalled))
end
2009-11-30 20:01:42 -05:00
def self.aliases
@aliases ||= {}
end
def self.attributes
@attributes ||= []
end
def self.attribute(name, other_names = [])
class_eval <<-EOS, __FILE__, __LINE__
attr_accessor :#{name}
EOS
@attributes ||= []
@attributes |= [name]
for other_name in [*other_names]
aliases[other_name] = name
end
end
def self.identity(name, other_names = [])
@identity = name
self.attribute(name, other_names)
end
def _dump
Marshal.dump(attributes)
end
attr_accessor :connection
def attributes
attributes = {}
for attribute in self.class.attributes
attributes[attribute] = send("#{attribute}")
end
attributes
end
def collection
@collection
end
def identity
send(self.class.instance_variable_get('@identity'))
end
2009-08-30 17:14:11 -04:00
def initialize(new_attributes = {})
merge_attributes(new_attributes)
2009-08-02 19:37:54 -04:00
end
def inspect
Thread.current[:formatador] ||= Formatador.new
data = "#{Thread.current[:formatador].indentation}<#{self.class.name}"
Thread.current[:formatador].indent do
unless self.class.attributes.empty?
data << "\n#{Thread.current[:formatador].indentation}"
data << self.class.attributes.map {|attribute| "#{attribute}=#{send(attribute).inspect}"}.join(",\n#{Thread.current[:formatador].indentation}")
end
2009-08-02 19:37:54 -04:00
end
data << "\n#{Thread.current[:formatador].indentation}>"
data
2009-08-02 19:37:54 -04:00
end
2009-08-30 17:14:11 -04:00
def merge_attributes(new_attributes = {})
for key, value in new_attributes
if aliased_key = self.class.aliases[key]
send("#{aliased_key}=", value)
else
send("#{key}=", value)
end
end
self
end
def new_record?
!identity
end
def reload
new_attributes = collection.get(identity).attributes
merge_attributes(new_attributes)
end
def requires(*args)
missing = []
for arg in [:connection] | args
missing << arg unless send("#{arg}")
end
unless missing.empty?
if missing.length == 1
raise(ArgumentError, "#{missing.first} is required for this operation")
else
raise(ArgumentError, "#{missing[0...-1].join(", ")} and #{missing[-1]} are required for this operation")
end
end
end
def wait_for(timeout = 600, &block)
start = Time.now
until instance_eval(&block)
if Time.now - start > timeout
break
end
reload
sleep(1)
end
end
2009-08-02 19:37:54 -04:00
private
def collection=(new_collection)
@collection = new_collection
end
2009-08-04 13:51:54 -04:00
def remap_attributes(attributes, mapping)
for key, value in mapping
2009-08-17 21:34:44 -04:00
if attributes.key?(key)
2009-08-04 13:51:54 -04:00
attributes[value] = attributes.delete(key)
end
end
end
2009-08-02 19:37:54 -04:00
end
end