2009-08-02 19:37:54 -04:00
|
|
|
module Fog
|
2009-09-04 21:24:11 -04:00
|
|
|
class Collection < Array
|
2009-08-02 19:37:54 -04:00
|
|
|
|
2010-01-05 01:03:24 -05:00
|
|
|
Array.public_instance_methods(false).each do |method|
|
|
|
|
class_eval <<-RUBY
|
|
|
|
def #{method}(*args)
|
|
|
|
lazy_load
|
|
|
|
super
|
|
|
|
end
|
|
|
|
RUBY
|
|
|
|
end
|
|
|
|
|
2010-02-27 16:05:09 -05:00
|
|
|
%w[reject select].each do |method|
|
2010-02-23 13:13:51 -05:00
|
|
|
class_eval <<-RUBY
|
|
|
|
def #{method}(*args)
|
|
|
|
lazy_load
|
2010-03-09 14:33:06 -05:00
|
|
|
data = super
|
|
|
|
self.class.new(:connection => self.connection).load(data.map {|member| member.attributes})
|
2010-02-23 13:13:51 -05:00
|
|
|
end
|
|
|
|
RUBY
|
|
|
|
end
|
|
|
|
|
2010-02-27 16:07:34 -05:00
|
|
|
def self._load(marshalled)
|
2009-11-21 16:46:46 -05:00
|
|
|
new(Marshal.load(marshalled))
|
|
|
|
end
|
|
|
|
|
2009-08-30 17:43:01 -04:00
|
|
|
def self.attribute(name, other_names = [])
|
|
|
|
class_eval <<-EOS, __FILE__, __LINE__
|
|
|
|
attr_accessor :#{name}
|
|
|
|
EOS
|
2009-11-12 02:18:17 -05:00
|
|
|
@attributes ||= []
|
|
|
|
@attributes |= [name]
|
2009-08-30 17:43:01 -04:00
|
|
|
for other_name in [*other_names]
|
|
|
|
aliases[other_name] = name
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2009-10-30 03:11:50 -04:00
|
|
|
def self.model(new_model)
|
|
|
|
@model = new_model
|
2009-10-30 02:35:28 -04:00
|
|
|
end
|
|
|
|
|
2009-08-30 17:43:01 -04:00
|
|
|
def self.aliases
|
|
|
|
@aliases ||= {}
|
|
|
|
end
|
|
|
|
|
|
|
|
def self.attributes
|
|
|
|
@attributes ||= []
|
|
|
|
end
|
|
|
|
|
2009-11-21 16:46:46 -05:00
|
|
|
def _dump
|
|
|
|
Marshal.dump(attributes)
|
|
|
|
end
|
|
|
|
|
2009-10-30 02:35:28 -04:00
|
|
|
def attributes
|
|
|
|
attributes = {}
|
|
|
|
for attribute in self.class.attributes
|
|
|
|
attributes[attribute] = send("#{attribute}")
|
|
|
|
end
|
|
|
|
attributes
|
|
|
|
end
|
|
|
|
|
2009-11-21 16:46:46 -05:00
|
|
|
def connection=(new_connection)
|
|
|
|
@connection = new_connection
|
|
|
|
end
|
|
|
|
|
|
|
|
def connection
|
|
|
|
@connection
|
|
|
|
end
|
|
|
|
|
2009-10-30 02:35:28 -04:00
|
|
|
def create(attributes = {})
|
|
|
|
object = new(attributes)
|
|
|
|
object.save
|
|
|
|
object
|
|
|
|
end
|
|
|
|
|
2009-08-02 19:37:54 -04:00
|
|
|
def initialize(attributes = {})
|
2009-09-01 01:40:07 -04:00
|
|
|
merge_attributes(attributes)
|
2010-01-05 01:03:24 -05:00
|
|
|
@loaded = false
|
2009-08-02 19:37:54 -04:00
|
|
|
end
|
|
|
|
|
|
|
|
def inspect
|
2010-02-14 17:34:33 -05:00
|
|
|
Thread.current[:formatador] ||= Formatador.new
|
|
|
|
data = "#{Thread.current[:formatador].indentation}<#{self.class.name}\n"
|
|
|
|
Thread.current[:formatador].indent do
|
|
|
|
unless self.class.attributes.empty?
|
2010-02-15 20:15:56 -05:00
|
|
|
data << "#{Thread.current[:formatador].indentation}"
|
2010-02-14 17:34:33 -05:00
|
|
|
data << self.class.attributes.map {|attribute| "#{attribute}=#{send(attribute).inspect}"}.join(",\n#{Thread.current[:formatador].indentation}")
|
2010-02-15 20:15:56 -05:00
|
|
|
data << "\n"
|
2010-02-14 17:34:33 -05:00
|
|
|
end
|
2010-02-15 20:15:56 -05:00
|
|
|
data << "#{Thread.current[:formatador].indentation}["
|
2010-02-14 17:34:33 -05:00
|
|
|
unless self.empty?
|
2010-02-15 20:15:56 -05:00
|
|
|
data << "\n"
|
2010-02-14 17:34:33 -05:00
|
|
|
Thread.current[:formatador].indent do
|
|
|
|
data << self.map {|member| member.inspect}.join(",\n")
|
|
|
|
data << "\n"
|
|
|
|
end
|
2010-02-15 20:15:56 -05:00
|
|
|
data << Thread.current[:formatador].indentation
|
2010-02-14 17:34:33 -05:00
|
|
|
end
|
2010-02-15 20:15:56 -05:00
|
|
|
data << "]\n"
|
2009-08-02 19:37:54 -04:00
|
|
|
end
|
2010-02-14 17:34:33 -05:00
|
|
|
data << "#{Thread.current[:formatador].indentation}>"
|
|
|
|
data
|
2009-08-02 19:37:54 -04:00
|
|
|
end
|
|
|
|
|
2010-03-06 23:02:10 -05:00
|
|
|
def load(objects)
|
|
|
|
if @loaded
|
|
|
|
clear
|
|
|
|
end
|
2010-02-27 16:05:09 -05:00
|
|
|
@loaded = true
|
2010-03-06 23:02:10 -05:00
|
|
|
for object in objects
|
|
|
|
self << new(object)
|
|
|
|
end
|
|
|
|
self
|
2010-02-27 16:05:09 -05:00
|
|
|
end
|
|
|
|
|
2009-10-30 03:11:50 -04:00
|
|
|
def model
|
|
|
|
self.class.instance_variable_get('@model')
|
2009-08-30 17:43:01 -04:00
|
|
|
end
|
|
|
|
|
|
|
|
def merge_attributes(new_attributes = {})
|
|
|
|
for key, value in new_attributes
|
2009-09-01 01:40:07 -04:00
|
|
|
if aliased_key = self.class.aliases[key]
|
2009-09-15 00:36:24 -04:00
|
|
|
send("#{aliased_key}=", value)
|
2009-08-30 17:43:01 -04:00
|
|
|
else
|
2009-09-15 00:36:24 -04:00
|
|
|
send("#{key}=", value)
|
2009-08-30 17:43:01 -04:00
|
|
|
end
|
2009-08-04 23:09:08 -04:00
|
|
|
end
|
2009-08-17 21:34:44 -04:00
|
|
|
self
|
2009-08-04 23:09:08 -04:00
|
|
|
end
|
|
|
|
|
2009-10-30 02:35:28 -04:00
|
|
|
def new(attributes = {})
|
2009-10-30 03:11:50 -04:00
|
|
|
model.new(
|
2010-05-10 14:57:35 -04:00
|
|
|
attributes.merge(
|
2009-10-30 02:35:28 -04:00
|
|
|
:collection => self,
|
|
|
|
:connection => connection
|
|
|
|
)
|
|
|
|
)
|
|
|
|
end
|
|
|
|
|
|
|
|
def reload
|
|
|
|
self.clear.concat(all)
|
|
|
|
end
|
|
|
|
|
2010-02-22 19:36:25 -05:00
|
|
|
def table(attributes = nil)
|
|
|
|
Formatador.display_table(self.map {|instance| instance.attributes}, attributes)
|
|
|
|
end
|
|
|
|
|
2010-03-27 21:06:32 -04:00
|
|
|
def to_json
|
|
|
|
self.map {|member| member}.to_json
|
|
|
|
end
|
|
|
|
|
2009-08-02 19:37:54 -04:00
|
|
|
private
|
|
|
|
|
2010-01-05 01:03:24 -05:00
|
|
|
def lazy_load
|
|
|
|
unless @loaded
|
|
|
|
self.all
|
|
|
|
end
|
|
|
|
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
|