Contents

require 'rubygems'
require 'mongrel'
require 'base64'

# Mongrel handler that translates the incoming HTTP request into a
# Rush::Connection::Local call.  The results are sent back across the wire to
# be decoded by Rush::Connection::Remote on the other side.
class RushHandler < Mongrel::HttpHandler
	def process(request, response)
		params = {}
		request.params['QUERY_STRING'].split("?").last.split("&").each do |tuple|
			key, value = tuple.split("=")
			params[key.to_sym] = value
		end

		unless authorize(request.params['HTTP_AUTHORIZATION'])
			response.start(401) do |head, out|
			end
		else
			payload = request.body.read

			without_action = params
			without_action.delete(params[:action])
			printf "%-20s", params[:action]
			print without_action.inspect
			print " + #{payload.size} bytes of payload" if payload.size > 0
			puts

			params[:payload] = payload
			result = box.connection.receive(params)

			response.start(200) do |head, out|
				out.write result
			end
		end
	end

	def authorize(auth)
		unless m = auth.match(/^Basic (.+)$/)
			puts "Request with no authorization data"
			return false
		end

		decoded = Base64.decode64(m[1])
		user, password = decoded.split(':', 2)

		if user.nil? or user.length == 0 or password.nil? or password.length == 0
			puts "Malformed user or password"
			return false
		end

		if password == config.passwords[user]
			return true
		else
			puts "Access denied to #{user}"
			return false
		end
	end

	def box
		@box ||= Rush::Box.new('localhost')
	end

	def config
		@config ||= Rush::Config.new
	end
end

# A container class to run the Mongrel server for rushd.
class RushServer
	def run
		host = "127.0.0.1"
		port = Rush::Config::DefaultPort

		puts "rushd listening on #{host}:#{port}"

		h = Mongrel::HttpServer.new(host, port)
		h.register("/", RushHandler.new)
		h.run.join
	end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
rush-0.1	lib/rush/server.rb