Class: MandrillQueue::Message::Recipient::Data

Inherits:
Object
  • Object
show all
Defined in:
lib/mandrill_queue/message/recipient/data.rb

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Data

Returns a new instance of Data.



36
37
38
 
# File 'lib/mandrill_queue/message/recipient/data.rb', line 36

def initialize
	@_vars = []
end

Class Method Details

.inherited(base) ⇒ Object 



10
11
12
13
14
15
16
 
# File 'lib/mandrill_queue/message/recipient/data.rb', line 10

def self.inherited(base)
	base.class_eval do
		define_method(base.name.underscore.split('/').last) do
			@_vars
		end
	end
end

.var_class(klass = nil) ⇒ Object 



18
19
20
21
 
# File 'lib/mandrill_queue/message/recipient/data.rb', line 18

def self.var_class(klass = nil)
	@_var_class = klass unless klass.nil?
	@_var_class
end

Instance Method Details

#[](index) ⇒ Object 



77
78
79
 
# File 'lib/mandrill_queue/message/recipient/data.rb', line 77

def [](index)
	@_vars[index]
end

#add(*args, &block) ⇒ Object Also known as: dsl 



44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
 
# File 'lib/mandrill_queue/message/recipient/data.rb', line 44

def add(*args, &block)
	recipient = args.first
	if recipient.is_a?(String)
		ind = recipient_index[recipient]
		if ind.nil?
			@_vars << var_class.new(*args, &block)
			register_recipient(recipient, @_vars.count - 1)
		else
			self[ind].variables.dsl(&block)
		end
	elsif recipient.respond_to?(:each)
		add_objects(*args, &block)
	elsif !recipient.nil?
		raise MessageError, "Invalid recipient for #{name}"
	end
end

#clear_recipient_index ⇒ Object 



32
33
34
 
# File 'lib/mandrill_queue/message/recipient/data.rb', line 32

def clear_recipient_index
	@_rcpt_index = {}
end

#count ⇒ Object 



81
82
83
 
# File 'lib/mandrill_queue/message/recipient/data.rb', line 81

def count
	@_vars.count
end

#first ⇒ Object 



69
70
71
 
# File 'lib/mandrill_queue/message/recipient/data.rb', line 69

def first
	@_vars.first
end

#last ⇒ Object 



73
74
75
 
# File 'lib/mandrill_queue/message/recipient/data.rb', line 73

def last
	@_vars.last
end

#recipient_index ⇒ Object 



28
29
30
 
# File 'lib/mandrill_queue/message/recipient/data.rb', line 28

def recipient_index
	@_rcpt_index || clear_recipient_index
end

#register_recipient(email, index) ⇒ Object

Raises:



23
24
25
26
 
# File 'lib/mandrill_queue/message/recipient/data.rb', line 23

def register_recipient(email, index)
	raise RecipientDataError, "#{email} has already been registered in recipient index." if recipient_index.has_key?(email)
	recipient_index[email] = index
end

#set!(list) ⇒ Object 



91
92
93
94
95
96
97
 
# File 'lib/mandrill_queue/message/recipient/data.rb', line 91

def set!(list)
	@_vars = list.map do |obj|
		var_class.new.set!(obj.symbolize_keys)
	end

	self
end

#to_a(options = {}) ⇒ Object 



63
64
65
66
67
 
# File 'lib/mandrill_queue/message/recipient/data.rb', line 63

def to_a(options = {})
	@_vars.map do |v|
		v.to_hash(options)
	end
end

#validate(errors) ⇒ Object 



85
86
87
88
89
 
# File 'lib/mandrill_queue/message/recipient/data.rb', line 85

def validate(errors)
	@_vars.each do |v|
		v.validate(errors)
	end
end

#var_class ⇒ Object 



40
41
42
 
# File 'lib/mandrill_queue/message/recipient/data.rb', line 40

def var_class
	self.class.var_class
end