Class: RWDServer

Inherits:

Object

• Object
• RWDServer

Defined in:

lib/rwd/rwd.rb

Instance Method Summary

• #initialize(obj, port, io, auth, realm) ⇒ RWDServer constructor

  A new instance of RWDServer.

Constructor Details

#initialize(obj, port, io, auth, realm) ⇒ RWDServer

Returns a new instance of RWDServer.

# File 'lib/rwd/rwd.rb', line 1164

def initialize(obj, port, io, auth, realm)
  @object		= obj
  @localbrowsing	= false
  @browserstarted	= false
  @sessions		= Sessions.new(obj.class, (not auth.nil?))

  if auth.nil?
    @localbrowsing	= true

    if ENV.include?("RWDBROWSER") and not ENV["RWDBROWSER"].nil? and not ENV["RWDBROWSER"].empty?
      @browserstarted	= true
      @object.exitbrowser

	# Start browser.

      @browserthread	=
      Thread.new do
        puts "Starting the browser..."

        #if ENV["RWDBROWSER"].downcase =~ /iexplore/	# ???
          #@ie	= IE.new("http://localhost:#{port}/")
        #else
          browser	= ENV["RWDBROWSER"].dup
          url		= "http://localhost:%s/" % [port]

          re		= /[$%]1\b/
          command	= "%s \"%s\"" % [browser, url]
          command	= browser.gsub(re, url)	if browser =~ re

          command.gsub!(/%port%/, port.to_s)

          system(command) or $stderr.puts "Starting of the browser failed, or the browser terminated abnormally.\nCommand => #{command}"
        #end

        puts "The browser has terminated."
      end
    end
  end

	# Start server.

  portio		= port
  portio		= [port, io]	unless io.nil?
  threadlimiter	= ThreadLimiter.new(1)

  HTTPServer.serve(portio, (not auth.nil?)) do |req, resp|
    threadlimiter.wait do
      vars	= {}
      req.vars.each do |k, v|
        vars[k]	= v.join("\t")
      end
      pad	= (req.request.path or "/")

      if auth.kind_of? String
        file	= "#{home}/#{auth}"
        auths	= {}
        auths	= Hash.file(file)	if File.file?(file)
      else
        auths	= auth
      end

      #oldsessionid	= vars["rwd_session"]
      oldsessionid	= req.cookies["sessionid"]

# Retrieve session.

      session	= @sessions[oldsessionid]

# Eventually create new session.

      if session.nil?
        sessionid	= MD5.new(req.peeraddr[3].to_s + @object.inspect.to_s + ("%1.6f" % Time.now.to_f)).to_s	while (sessionid == nil or @sessions.include?(sessionid))
        session		= RWDSession.new(sessionid)

        if auth.nil?
          session["object"]		= @object
        else
          session["object"]		= @object.clone
        end

        if oldsessionid.nil? or oldsessionid.empty?
          if not auth.nil? and not auth.empty? and not session.authenticated and pad !~ /^\/rwd_/

# Check authentication

            us	= vars["rwd_a"]
            pa	= vars["rwd_b"]

            if us.nil? or pa.nil? or auths[us] != pa
              session				= RWDSession.new
              session["object"]		= RWDLogin.new(realm)
              pad				= "/"
            else
              session.authenticated		= true
              @sessions[session.sessionid]	= session
            end
          else
            session.authenticated		= true
            @sessions[session.sessionid]	= session
          end
        else
          session		= RWDSession.new
          session["object"]	= RWDTimeOut.new
        end

        vars	= {}
      end

# Avoid timeout.

      session.touch

      if pad == "/"

# Serve methods/callbacks.

# Build new page.

        download	= ""
        downloadfile	= ""
        res		= ""

        done	= session.render(res, pad, vars, download, downloadfile, req.pda?)

        begin
          if download.empty?
            resp["Content-Type"]		= "text/html"
            if done
              resp.cookies["sessionid"]	= ""
            else
              resp.cookies["sessionid"]	= session.sessionid
            end

            resp << res
          else
            resp["Content-Type"]		= "application/octet-stream"
            resp["Content-Disposition"]	= "attachment;"
            resp["Content-Disposition"]	= "attachment; filename=%s" % downloadfile	unless downloadfile.empty?

            resp << download
          end
        rescue
          puts "Sending response to browser failed."

          @sessions.delete(session.sessionid)
        end

# Eventually delete this session.

        if done
          @sessions.delete(session.sessionid)

          if @localbrowsing
            resp.stop

            if @browserstarted and not @browserthread.nil? and @browserthread.alive?
              resp.stop do
                puts "Waiting for the browser to terminate..."

                @browserthread.join
              end
            end
          end
        end

      else

# Serve files.

        if pad == "/rwd_pixel.gif"
          resp["Cache-Control"]	= "max-age=86400"
          resp["Content-Type"]	= "image/gif"
          resp << $rwd_pixel
        else
          if session.authenticated
            pwd	= Dir.pwd
            file	= File.expand_path(pad.gsub(/^\/*/, ""), $rwd_files)

            if not file.index(pwd) == 0
              resp["Content-Type"]	= "text/html"
              resp.response		= "HTTP/1.0 400 BAD REQUEST"
              resp << "<html><body><p><b>Bad Request.</b> (<tt>#{pad}</tt>)</p></body></html>"
            elsif File.file?(file)
              resp << File.new(file, "rb").read	rescue nil
            else
              resp["Content-Type"]	= "text/html"
              resp.response		= "HTTP/1.0 404 NOT FOUND"
              resp << "<html><body><p><b>Not found.</b> (<tt>#{pad}</tt>)</p></body></html>"
            end
          else
            resp["Content-Type"]	= "text/html"
            resp.response		= "HTTP/1.0 ??? NOT AUTHORIZED"
            resp << "<html><body><p><b>Not Authorized.</b></p></body></html>"
          end
        end

      end

    end
  end
end