35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
# File 'lib/wave_box/generate_wave.rb', line 35
def can_generate_wave(config)
raise ArgumentError, "Missing redis" unless config[:redis]
raise ArgumentError, "Missing id lambda" unless config[:id]
raise ArgumentError, "Missing wave name" unless config[:name]
name = config[:name]
[:redis, :expire, :max_size, :encode].each do |c|
define_method "#{name}_outbox_#{c}" do config[c] end
end
if config[:redis].is_a? Symbol
class_eval <<-RUBY
def #{name}_outbox_redis_instance
send( "#{config[:redis]}" )
end
RUBY
else
define_method "#{name}_outbox_redis_instance" do config[:redis] end
end
if config[:id].is_a? Symbol
class_eval <<-RUBY
def #{name}_outbox_id
send("#{config[:id]}")
end
RUBY
else
define_method "#{name}_outbox_id" do config[:redis] end
end
define_method "#{name}_outbox_key" do "wave:#{name}:outbox:#{send("#{name}_outbox_id")}" end
class_eval <<-RUBY
def #{name}_outbox
@#{name}_outbox ||= WaveBox::Box.new({
:encode => #{name}_outbox_encode,
:redis => #{name}_outbox_redis_instance,
:key => #{name}_outbox_key,
:expire => #{name}_outbox_expire,
:max_size => #{name}_outbox_max_size})
end
RUBY
end
|