gateway_server.rb

require 'timeout'
require 'peer'
require 'gateway_common'
require 'gateway_client'
require 'thread'
require 'client_request'

module Gateway
  class Server
    include Gateway::Common
    attr_reader(:port, :peer_socket, :server)

    def initialize(port)
      @port     = port
      @requests = {}
      @mutex    = Mutex.new
    end

    def start_stunt
      port_client  = PortClient.new("blastmefy.net:2000")
      @peer_socket = Peer.new(port_client).start("testy", 2004)
    end

    def start
      $stderr.puts("starting nat traversal")
      start_stunt

      @server = TCPServer.new(port)
      $stderr.puts("gateway server started on port #{port}")

      Thread.new do
        handle_peer
      end

      loop do
        begin
          timeout(KEEPALIVE_TIMEOUT) do
            $stderr.puts("waiting for connections")
            client_socket = server.accept
            Thread.new do
              handle_client(ClientRequest.new(new_request_id, client_socket))
            end
          end
        rescue Timeout::Error
          $stderr.puts("sending keepalive")
          keepalive
          retry
        end
      end
    end
  end
end

if $0 == __FILE__
  Gateway::Server.new(8080).start
end