1 files changed, 12 insertions, 68 deletions

diff --git a/lib/nickserver/em_server.rb b/lib/nickserver/em_server.rb
index faace4b..bcec4cd 100644
--- a/lib/nickserver/em_server.rb
+++ b/lib/nickserver/em_server.rb
@@ -2,6 +2,7 @@ require 'eventmachine'
 silence_warnings do
   require 'evma_httpserver'
 end
+require 'nickserver/request_handler'
 
 module Nickserver
   class EmServer < EM::Connection
@@ -9,7 +10,7 @@ module Nickserver
 
     def self.start(options = {})
       EventMachine.run do
-        EM.start_server options[:host], options[:port], Nickserver::EmServer
+        EM.start_server options[:host], options[:port], self
       end
     end
 
@@ -19,32 +20,10 @@ module Nickserver
     end
 
     def process_http_request
-      uid = get_uid_from_request
-      if uid.nil?
-        send_not_found
-      elsif uid !~ EmailAddress
-        send_error("Not a valid address")
-      else
-        send_key(uid)
-      end
-    rescue RuntimeError => exc
-      puts "Error: #{exc}"
-      puts exc.backtrace
-      send_error(exc.to_s)
-    end
-
-    private
-
-    def send_error(msg = "not supported")
-      send_response(status: 500, content: "500 #{msg}\n")
+      handler.respond_to params, @http_headers
     end
 
-    def send_not_found(msg = "Not Found")
-      send_response(status: 404, content: "404 #{msg}\n")
-    end
-
-    def send_response(opts = {})
-      options = {status: 200, content_type: 'text/plain', content: ''}.merge(opts)
+    def send_response(options = {})
       response = EM::DelegatedHttpResponse.new(self)
       response.status = options[:status]
       response.content_type options[:content_type]
@@ -54,54 +33,19 @@ module Nickserver
       end
     end
 
-    def get_uid_from_request
-      if @http_query_string
-        params = CGI.parse(@http_query_string)
-      elsif @http_post_content
-        params = CGI.parse(@http_post_content)
-      end
-      if params && params["address"] && params["address"].any?
-        return params["address"].first
-      else
-        return nil
-      end
-    end
+    private
 
-    def send_key(uid)
-      if local_address?(uid)
-        source = Nickserver::CouchDB::Source.new(adapter)
-      else
-        source = Nickserver::Hkp::Source.new(adapter)
-      end
-      source.query(uid) do |response|
-        send_response(status: response.status, content: response.content)
-      end
+    def handler
+      @handler ||= RequestHandler.new(self, Nickserver::Adapters::EmHttp.new)
     end
 
-    #
-    # Return true if the user address is for a user of this service provider.
-    # e.g. if the provider is example.org, then alice@example.org returns true.
-    #
-    # If 'domain' is not configured, we rely on the Host header of the HTTP request.
-    #
-    def local_address?(uid)
-      uid_domain = uid.sub(/^.*@(.*)$/, "\\1")
-      if Config.domain
-        return uid_domain == Config.domain
-      else
-        # no domain configured, use Host header
-        host_header = @http_headers.split(/\0/).grep(/^Host: /).first
-        if host_header.nil?
-          send_error("HTTP request must include a Host header.")
-        else
-          host = host_header.split(':')[1].strip.sub(/^nicknym\./, '')
-          return uid_domain == host
-        end
+    def params
+      if @http_query_string
+        CGI.parse(@http_query_string)
+      elsif @http_post_content
+        CGI.parse(@http_post_content)
       end
     end
 
-    def adapter
-      @adapter ||= Nickserver::Adapters::EmHttp.new
-    end
   end
 end