22
23
24
25
26
27
28
29
30
31
32
33
34
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
|
# File 'lib/wave_box/receive_wave.rb', line 22
def can_receive_wave(config)
raise ArgumentError, "Missing redis config" unless config[:redis]
raise ArgumentError, "Missing id lambda" unless config[:id]
raise ArgumentError, "Missing wave name" unless config[:name]
name = config[:name]
[:expire, :max_size, :encode].each do |c|
define_method "#{name}_inbox_#{c}" do config[c] end
end
if config[:redis].is_a? Symbol
class_eval <<-RUBY
def #{name}_inbox_redis_instance
send("#{config[:redis]}")
end
RUBY
else
define_method "#{name}_inbox_redis_instance" do config[:redis] end
end
if config[:id].is_a? Symbol
class_eval <<-RUBY
def #{name}_inbox_id
send("#{config[:id]}")
end
RUBY
else
define_method "#{name}_inbox_id" do config[:redis] end
end
define_method "#{name}_inbox_key" do "wave:#{name}:inbox:#{send("#{name}_inbox_id")}" end
class_eval <<-RUBY
def #{name}_inbox
@#{name}_inbox ||= WaveBox::Box.new({
:redis => #{name}_inbox_redis_instance,
:key => #{name}_inbox_key,
:encode => #{name}_inbox_encode,
:expire => #{name}_inbox_expire,
:max_size => #{name}_inbox_max_size})
end
RUBY
end
|