Sha256: 1b71cd3408a855d75a9b0248f56c76c739753a5ecafc7a0cb190d40a32949a4b
Contents?: true
Size: 1.91 KB
Versions: 22
Compression:
Stored size: 1.91 KB
Contents
require 'json'
module CPEE
module Callbacks
def self::implementation(id,opts)
Proc.new do
run CPEE::Callbacks::Callbacks, id, opts if get
on resource do
run CPEE::Callbacks::ExCallback, id, opts if put
end
end
end
class Callbacks < Riddl::Implementation #{{{
def response
id = @a[0]
opts = @a[1]
Riddl::Parameter::Complex.new("callbacks","text/xml") do
ret = XML::Smart::string <<-END
<callbacks/>
END
CPEE::Persistence::extract_set(id,opts,'callbacks').each do |de|
ret.root.add('callback', de[1], :id => de[0])
end
ret.to_s
end
end
end #}}}
class ExCallback < Riddl::Implementation #{{{
def response
id = @a[0]
opts = @a[1]
callback = @r[-1]
if opts[:redis].get("instance:#{id}/callback/#{callback}/type") == 'callback'
ret = {}
ret['values'] = @p.map{ |e|
[e.name, e.class == Riddl::Parameter::Simple ? [:simple,e.value] : [:complex,e.mimetype,e.value.path] ]
}
ret['headers'] = @h
CPEE::Message::send(
:'callback-response',
callback,
opts[:url],
id,
{},
{},
ret,
opts[:redis]
)
elsif opts[:redis].get("instance:#{id}/callback/#{callback}/type") == 'vote'
if @p.length == 1 && @p[0].name == 'continue' && @p[0].class == Riddl::Parameter::Simple
CPEE::Message::send(
:'vote-response',
callback,
opts[:url],
id,
{},
{},
@p[0].value,
opts[:redis]
)
else
@status = 400
end
else
@status = 503
end
nil
end
end #}}}
end
end
Version data entries
22 entries across 22 versions & 1 rubygems