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 " def \#{name}_outbox_redis_instance\n send( \"\#{config[:redis]}\" )\n end\n RUBY\n else\n define_method \"\#{name}_outbox_redis_instance\" do config[:redis] end\n end\n\n if config[:id].is_a? Symbol\n class_eval <<-RUBY\n def \#{name}_outbox_id\n send(\"\#{config[:id]}\")\n end\n RUBY\n else\n define_method \"\#{name}_outbox_id\" do config[:redis] end\n end\n\n define_method \"\#{name}_outbox_key\" do \"wave:\#{name}:outbox:\#{send(\"\#{name}_outbox_id\")}\" end\n\n class_eval <<-RUBY\n def \#{name}_outbox\n @\#{name}_outbox ||= WaveBox::Box.new({\n :encode => \#{name}_outbox_encode,\n :redis => \#{name}_outbox_redis_instance,\n :key => \#{name}_outbox_key,\n :expire => \#{name}_outbox_expire,\n :max_size => \#{name}_outbox_max_size})\n end\n RUBY\n\nend\n"
|