human_chat_server

app.rb

require 'socket'
require 'cgi'
sv=TCPServer.new((ARGV[0]||3000).to_i)
chan={}
mainqueue=Queue.new
Thread.new{loop{s=sv.accept;Thread.new{
  s.puts "HTTP/1.0 200 OK\r\nContent-type:text/html\r\n\r"
  begin
    l=s.gets
    if /\?(?<a>.+)=(?<b>[^ ]+)/=~l
      q=chan[a]
      q<<CGI.unescape(b)
    elsif l=~/ \/ /
      queue=Queue.new
      cid=rand.to_s
      chan[cid]=queue
      s.puts '<meta charset=utf-8>'
      s.puts '<iframe name=a style=display:none></iframe>'
      s.puts "<form target=a><input name=#{cid}></form>"
      Thread.new{loop{queue<<nil;sleep 1} rescue 0}
      loop{
        msg,f=queue.deq
        if msg
          s.puts "<pre><b>#{f||:you}:</b>&nbsp;#{CGI.escape_html msg}</pre>"
          if !f
            s.puts "<script>document.querySelector('input').value=''</script>"
            mainqueue<<[msg, queue]
          end
        else
          s.puts
        end
        s.flush
      }
    end
  rescue
  ensure
    queue.close rescue 0
    s.close rescue 0
  end
}}}

loop{
  msg,res=mainqueue.deq
  puts CGI.unescape msg
  $><<'>'
  res<<[gets,:bot] rescue 0
}