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 " def \#{name}_inbox_redis_instance\n send(\"\#{config[:redis]}\")\n end\n RUBY\n else\n define_method \"\#{name}_inbox_redis_instance\" do config[:redis] end\n end\n\n if config[:id].is_a? Symbol\n class_eval <<-RUBY\n def \#{name}_inbox_id\n send(\"\#{config[:id]}\")\n end\n RUBY\n else\n define_method \"\#{name}_inbox_id\" do config[:redis] end\n end\n\n define_method \"\#{name}_inbox_key\" do \"wave:\#{name}:inbox:\#{send(\"\#{name}_inbox_id\")}\" end\n\n class_eval <<-RUBY\n def \#{name}_inbox\n @\#{name}_inbox ||= WaveBox::Box.new({\n :redis => \#{name}_inbox_redis_instance,\n :key => \#{name}_inbox_key,\n :encode => \#{name}_inbox_encode,\n :expire => \#{name}_inbox_expire,\n :max_size => \#{name}_inbox_max_size})\n end\n RUBY\nend\n"
|