module Oxidized require 'webrick' require 'json' module API class Rest def initialize nodes, listen @nodes = nodes addr, port = listen.to_s.split ':' port, addr = addr, nil if not port @web = WEBrick::HTTPServer.new :BindAddress=>addr, :Port=>port, :Logger=>Log maps end def work req = select @web.listeners, nil, nil, Config::Sleep while req @web.run req.first.first.accept req = select @web.listeners, nil, nil, 0 end end def maps @web.mount_proc '/nodes' do |req, res| #script_name, #path_info case req.path_info[1..-1] # /nodes/reload - reloads list of nodes when 'reload' @nodes.load res.body = JSON.dump 'OK' # /nodes/next/node - moves node to head of queue when /next\/(.*)/ @nodes.next $1 res.body = JSON.dump 'OK' # /nodes/list - returns list of nodes when 'list' res.body = JSON.dump @nodes.list # /nodes/show/node - returns data about node when /show\/(.*)/ res.body = JSON.dump @nodes.show $1 end end end end end end