fog--fog/lib/fog/attributes.rb

148 lines
3.6 KiB
Ruby
Raw Normal View History

2010-06-08 01:22:31 +00:00
module Fog
module Attributes
module ClassMethods
2010-06-08 01:22:31 +00:00
def _load(marshalled)
new(Marshal.load(marshalled))
end
2010-06-08 01:22:31 +00:00
def aliases
@aliases ||= {}
end
2010-06-08 01:22:31 +00:00
def attributes
@attributes ||= []
end
def attribute(name, options = {})
# FIXME: handle legacy where options would have been one or more aliases
if !options.is_a?(Hash)
options = {:aliases => options}
end
2010-06-08 01:22:31 +00:00
class_eval <<-EOS, __FILE__, __LINE__
attr_reader :#{name}
2010-06-08 01:22:31 +00:00
EOS
case options[:type]
when :boolean
class_eval <<-EOS, __FILE__, __LINE__
def #{name}=(new_#{name})
@#{name} = case new_#{name}
when 'true'
true
when 'false'
false
end
end
EOS
when :float
class_eval <<-EOS, __FILE__, __LINE__
def #{name}=(new_#{name})
@#{name} = new_#{name}.to_f
end
EOS
when :integer
class_eval <<-EOS, __FILE__, __LINE__
def #{name}=(new_#{name})
@#{name} = new_#{name}.to_i
end
EOS
when :string
class_eval <<-EOS, __FILE__, __LINE__
def #{name}=(new_#{name})
@#{name} = new_#{name}.to_s
end
EOS
when :time
class_eval <<-EOS, __FILE__, __LINE__
def #{name}=(new_#{name})
2010-06-19 01:42:59 +00:00
if !new_#{name}.is_a?(Time)
@#{name} = Time.parse(new_#{name})
else
@#{name} = new_#{name}
end
end
EOS
else
class_eval <<-EOS, __FILE__, __LINE__
attr_writer :#{name}
EOS
end
2010-06-08 01:22:31 +00:00
@attributes ||= []
@attributes |= [name]
for new_alias in [*options[:aliases]]
aliases[new_alias] = name
2010-06-08 01:22:31 +00:00
end
end
2010-06-08 01:22:31 +00:00
def identity(name, other_names = [])
@identity = name
self.attribute(name, other_names)
end
end
2010-06-08 01:22:31 +00:00
module InstanceMethods
2010-06-08 01:22:31 +00:00
def _dump
Marshal.dump(attributes)
end
2010-06-08 01:22:31 +00:00
def attributes
attributes = {}
for attribute in self.class.attributes
attributes[attribute] = send("#{attribute}")
end
attributes
end
2010-06-08 01:22:31 +00:00
def identity
send(self.class.instance_variable_get('@identity'))
end
2010-06-08 01:22:31 +00:00
def identity=(new_identity)
send("#{self.class.instance_variable_get('@identity')}=", new_identity)
end
2010-06-08 01:22:31 +00: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
2010-06-08 01:22:31 +00:00
self
end
2010-06-08 01:22:31 +00:00
def new_record?
!identity
end
2010-06-08 01:22:31 +00:00
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
2010-06-08 01:22:31 +00:00
private
2010-06-08 01:22:31 +00:00
def remap_attributes(attributes, mapping)
for key, value in mapping
if attributes.key?(key)
attributes[value] = attributes.delete(key)
end
end
end
2010-06-08 01:22:31 +00:00
end
end
2010-06-08 01:22:31 +00:00
end