2009-08-02 23:37:54 +00:00
|
|
|
module Fog
|
2009-09-05 01:24:11 +00:00
|
|
|
class Collection < Array
|
2009-08-02 23:37:54 +00:00
|
|
|
|
2010-01-05 06:03:24 +00:00
|
|
|
Array.public_instance_methods(false).each do |method|
|
|
|
|
class_eval <<-RUBY
|
|
|
|
def #{method}(*args)
|
|
|
|
lazy_load
|
|
|
|
super
|
|
|
|
end
|
|
|
|
RUBY
|
|
|
|
end
|
|
|
|
|
2009-11-21 21:46:46 +00:00
|
|
|
def self._load(marhsalled)
|
|
|
|
new(Marshal.load(marshalled))
|
|
|
|
end
|
|
|
|
|
2009-08-30 21:43:01 +00:00
|
|
|
def self.attribute(name, other_names = [])
|
|
|
|
class_eval <<-EOS, __FILE__, __LINE__
|
|
|
|
attr_accessor :#{name}
|
|
|
|
EOS
|
2009-11-12 07:18:17 +00:00
|
|
|
@attributes ||= []
|
|
|
|
@attributes |= [name]
|
2009-08-30 21:43:01 +00:00
|
|
|
for other_name in [*other_names]
|
|
|
|
aliases[other_name] = name
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2009-10-30 07:11:50 +00:00
|
|
|
def self.model(new_model)
|
|
|
|
@model = new_model
|
2009-10-30 06:35:28 +00:00
|
|
|
end
|
|
|
|
|
2009-08-30 21:43:01 +00:00
|
|
|
def self.aliases
|
|
|
|
@aliases ||= {}
|
|
|
|
end
|
|
|
|
|
|
|
|
def self.attributes
|
|
|
|
@attributes ||= []
|
|
|
|
end
|
|
|
|
|
2009-11-21 21:46:46 +00:00
|
|
|
def _dump
|
|
|
|
Marshal.dump(attributes)
|
|
|
|
end
|
|
|
|
|
2009-10-30 06:35:28 +00:00
|
|
|
def attributes
|
|
|
|
attributes = {}
|
|
|
|
for attribute in self.class.attributes
|
|
|
|
attributes[attribute] = send("#{attribute}")
|
|
|
|
end
|
|
|
|
attributes
|
|
|
|
end
|
|
|
|
|
2009-11-21 21:46:46 +00:00
|
|
|
def connection=(new_connection)
|
|
|
|
@connection = new_connection
|
|
|
|
end
|
|
|
|
|
|
|
|
def connection
|
|
|
|
@connection
|
|
|
|
end
|
|
|
|
|
2009-10-30 06:35:28 +00:00
|
|
|
def create(attributes = {})
|
|
|
|
object = new(attributes)
|
|
|
|
object.save
|
|
|
|
object
|
|
|
|
end
|
|
|
|
|
2009-08-02 23:37:54 +00:00
|
|
|
def initialize(attributes = {})
|
2009-09-01 05:40:07 +00:00
|
|
|
merge_attributes(attributes)
|
2010-01-05 06:03:24 +00:00
|
|
|
@loaded = false
|
2009-08-02 23:37:54 +00:00
|
|
|
end
|
|
|
|
|
|
|
|
def inspect
|
|
|
|
data = "#<#{self.class.name}"
|
2009-09-01 05:40:07 +00:00
|
|
|
for attribute in self.class.attributes
|
|
|
|
data << " #{attribute}=#{send(attribute).inspect}"
|
2009-08-02 23:37:54 +00:00
|
|
|
end
|
2009-08-18 01:34:44 +00:00
|
|
|
data << " ["
|
2009-10-02 06:22:47 +00:00
|
|
|
for member in self
|
|
|
|
data << "#{member.inspect},"
|
2009-08-02 23:37:54 +00:00
|
|
|
end
|
2009-10-15 04:55:53 +00:00
|
|
|
data.chop! unless self.empty?
|
2009-08-02 23:37:54 +00:00
|
|
|
data << "]>"
|
|
|
|
end
|
|
|
|
|
2009-10-30 07:11:50 +00:00
|
|
|
def model
|
|
|
|
self.class.instance_variable_get('@model')
|
2009-08-30 21:43:01 +00:00
|
|
|
end
|
|
|
|
|
|
|
|
def merge_attributes(new_attributes = {})
|
|
|
|
for key, value in new_attributes
|
2009-09-01 05:40:07 +00:00
|
|
|
if aliased_key = self.class.aliases[key]
|
2009-09-15 04:36:24 +00:00
|
|
|
send("#{aliased_key}=", value)
|
2009-08-30 21:43:01 +00:00
|
|
|
else
|
2009-09-15 04:36:24 +00:00
|
|
|
send("#{key}=", value)
|
2009-08-30 21:43:01 +00:00
|
|
|
end
|
2009-08-05 03:09:08 +00:00
|
|
|
end
|
2009-08-18 01:34:44 +00:00
|
|
|
self
|
2009-08-05 03:09:08 +00:00
|
|
|
end
|
|
|
|
|
2009-10-30 06:35:28 +00:00
|
|
|
def new(attributes = {})
|
2009-10-30 07:11:50 +00:00
|
|
|
model.new(
|
2009-10-30 06:35:28 +00:00
|
|
|
attributes.merge!(
|
|
|
|
:collection => self,
|
|
|
|
:connection => connection
|
|
|
|
)
|
|
|
|
)
|
|
|
|
end
|
|
|
|
|
|
|
|
def reload
|
|
|
|
self.clear.concat(all)
|
|
|
|
end
|
|
|
|
|
2009-08-02 23:37:54 +00:00
|
|
|
private
|
|
|
|
|
2010-01-05 06:03:24 +00:00
|
|
|
def lazy_load
|
|
|
|
unless @loaded
|
|
|
|
self.all
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2009-08-04 17:51:54 +00:00
|
|
|
def remap_attributes(attributes, mapping)
|
|
|
|
for key, value in mapping
|
2009-08-18 01:34:44 +00:00
|
|
|
if attributes.key?(key)
|
2009-08-04 17:51:54 +00:00
|
|
|
attributes[value] = attributes.delete(key)
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2009-08-02 23:37:54 +00:00
|
|
|
end
|
|
|
|
end
|