Skip to content

Instantly share code, notes, and snippets.

@gleicon
Created August 14, 2010 12:06
  • Star 6 You must be signed in to star a gist
  • Fork 1 You must be signed in to fork a gist
Star You must be signed in to star a gist
Save gleicon/524240 to your computer and use it in GitHub Desktop.
# Sinatra minimalist RestMQ
# no COMET, just /q/ routes and queue logic
# the core of RestMQ is how it uses Redis' data types
require 'rubygems'
require 'sinatra'
require 'redis'
require 'json'
QUEUESET = 'QUEUESET' # queue index
UUID_SUFFIX = ':UUID' # queue unique id
QUEUE_SUFFIX = ':queue' # suffix to identify each queue's LIST
reds = Redis.new
get '/q' do
b = reds.smembers QUEUESET
throw :halt, [404, 'Not found (empty queueset)'] if b == nil
b.map! do |q| q = '/q/'+q end
b.to_json
end
get '/q/*' do
queue = params['splat'].to_s
soft = params['soft'] # soft = true doesn't rpop values
throw :halt, [404, 'Not found'] if queue == nil
queue = queue + QUEUE_SUFFIX
if soft != nil
puts queue
b = reds.lindex queue, -1
else
b = reds.rpop queue
end
throw :halt, [404, 'Not found (empty queue)'] if b == nil
v = reds.get b
throw :halt, [200, "{'value':" + v + "'key':" + b + "}"] unless v == nil
'empty value'
end
post '/q/*' do
queue = params['splat'].to_s
value = params['value'].to_s
throw :halt, [404, "Not found"] if queue == nil
q1 = queue + QUEUE_SUFFIX
uuid = reds.incr queue + UUID_SUFFIX
reds.sadd QUEUESET, q1
lkey = queue + ':' + uuid.to_s
reds.set lkey, value
reds.lpush q1, lkey
'{ok, '+lkey+'}'
end
@denzuko
Copy link

denzuko commented Oct 11, 2010

smashing, updated the one I posted http://gist.github.com/616837 check it out

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment