ruby-list

青山です。

simple_chat_server.rb の http 部分を分離したついでに、さらにライブラリ
として取り出してみました。汎用として使うにはヘッダの生成の方があまりに
も貧弱(content-length しか無い)ですが、ヘッダの解釈の方はこの程度でも
使えそうです。

ついでに、これを使用したタイプの simple_chat_server.rb も付けます。(圧
縮しようかと思ったのですが、たいして変らないのでそのまま付けます。) 

ところで、CR, LF (できれば EOL も) という定数を用意するというのはいか
がでしょうか？　便利だと思いますし、弊害も無いと思いますが。


#!/usr/local/bin/ruby
#
# http-lib.rb
# ver0.01 1998/04/17
# Wakou Aoyama <wakou@fsinet.or.jp>
#
# == HTTP header analyze
# request_file_name = HTTP.header_analyze(IO)
#
# == add HTTP header
# http_content = HTTP.add_header("string")

class HTTP
  CR  = "\015"
  LF  = "\012"
  EOL = CR + LF

  def HTTP.header_analyze(io) # ===== header analyze
    head = ''
    head += io.read(1) while /#{EOL}#{EOL}|#{LF}#{LF}|#{CR}#{CR}/n !~ head
    head.gsub!(/#{EOL}|#{CR}|#{LF}/, "\n")
    case head
    when /^GET\s+([^?\s]+)\??([^\s]*)/
      request_file_name = $1
      ENV['REQUEST_METHOD'] = 'GET'
      ENV['QUERY_STRING'] = ($2 or '').to_s
    when /^POST\s+([^\s]+)/
      request_file_name = $1
      ENV['REQUEST_METHOD'] = 'POST'
      ENV['CONTENT_LENGTH'] = head.scan(/^Content-length: (\d+)/i)[0].to_s
    end
    head.scan(/\n([^:]+): (.*)/){|k,v|
      ENV['HTTP_' + k.upcase.gsub(/\-/, '_')] = v
    }
    request_file_name
  end

  def HTTP.add_header(content, options = '') # ===== add header
   'HTTP/1.0 200 OK' + EOL +
  ('Content-length: ' + content.length.to_s + EOL if
     'no-length' != options).to_s +
   'Content-type: text/html' + EOL + EOL +
    content
  end
end


#!/usr/local/bin/ruby
#
# simple_chat_server.rb
# ver0.20 1998/04/17
# Wakou Aoyama <wakou@fsinet.or.jp>

require 'socket'
require 'thread'
require 'kconv'
require 'cgi-lib'
require 'http-lib'

CR  = "\015"
LF  = "\012"
EOL = CR + LF

def send_for_all_member(member, message) # ===== send message
  member.each_value do |listener| # delivery for each listener
    begin
      listener['listen_window'] << message # delivery the message
    rescue # if listener was logouted
      handle = listener['handle']
      member.delete(listener['no'])
      send_for_all_member(member, '(' + handle + " is logout.)<BR>\n" )
    end
  end
end

def new_access(sock, serial_no, member) # ===== new access
  member[serial_no] = {'no'     => serial_no,
                       'handle' => 'No. ' + serial_no.to_s}
  sock << HTTP.add_header(
    %|<TITLE>CHAT</TITLE>
      <FRAMESET ROWS="*, 60">
        <FRAME SRC="/listen#{serial_no}.html">
        <FRAME SRC="/talk#{serial_no}.html">
      </FRAMESET>|.gsub(/^      /, ''), 'no-cache')
  sock.shutdown(2)
end

def new_listen_window(sock, my, member) # ===== new listen window
  my['listen_window'] = sock
  sock << HTTP.add_header(
    %|<BODY BGCOLOR="white">
      <H1>Welcome!<BR>simple chat server.</H1>
      <P><B>Powerd by
      <A HREF="http://www.netlab.co.jp/ruby/jp/">
      Ruby</A>.</B></P>
      <P>change handle. input like this.<BR>
      <TT>/HA handle</TT></P>|.gsub(/^      /, ''), 'no-length')
  send_for_all_member(member, '(' + my['handle'] + " is login.)<BR>\n")
  # socket don't shutdown
end

def talk_window(sock, my, member) # ===== talk window (post message)
  query = CGI.new(sock)
  if /\/HA (.+)/i =~ query.inputs['input'] # change handle
    send_for_all_member(member,
      '(change handle. "' + my['handle'] + '" --&gt; "' +
        Kconv.toeuc($1) + "\")<BR>\n" )
    my['handle'] = Kconv.toeuc($1)
  elsif query.inputs.include?('input') and '' != query.inputs['input']
    send_for_all_member(member, my['handle'] + ' &gt; ' +
      Kconv.toeuc( (query.inputs['input'] or '') ) + "<BR>\n" )
  end
  sock << HTTP.add_header(
    %|<BODY BGCOLOR="white">
      <FORM METHOD="post" ACTION="/talk#{my['no']}.html">
        <B>#{my['handle']} &gt; </B>
        <INPUT TYPE="text" NAME="input" SIZE="60">
        <INPUT TYPE="submit" VALUE="send">
      </FORM>|.gsub(/^      /, ''))
  sock.shutdown(2)
end

PORT = ARGV.shift || 8080
serial_no = 0
member = {}

port = TCPserver.open(PORT)
trap('PIPE', 'IGNORE')
STDERR.print (Time.now, "\tserver is on #{port.addr[1]}\n")

loop do
  s = port.accept # stand by for accept

  Thread.start do # divide the work
    sock = s # copy to thread-local variable
    case HTTP.header_analyze(sock)
    when %r|^/$|                 # ===== new access
      serial_no += 1
      new_access(sock, serial_no, member)
    when %r|^/talk(\d+).html$|   # ===== talk window (post message)
      talk_window(sock, member[$1.to_i], member)
    when %r|^/listen(\d+).html$| # ===== new listen window
      new_listen_window(sock, member[$1.to_i], member)
    else                         # ===== file not found
      sock << HTTP.add_header('<H1>file not found</H1>')
      sock.shutdown(2)
    end
  end
end


青山　和光 Wakou Aoyama <wakou@fsinet.or.jp>

Thread

Prev Next

In This Thread

Prev Next

[#7286] cmp operator — NAGAI Hidetoshi <nagai@...>

[#7287] mine — Takahiro Maebashi <maebashi@...>

[#7288] plain2 + popmail — tateishi@...

[#7292] Exception in ruby — TAKAHASHI Masayoshi <maki@...>

[#7295] Hash.key の繰り返し数 — Sinichiro Dezawa <dezawa@...>

[#7299] + operator — TEI meiki <tei@...>

[#7310] Re: modulo — toyofuku@...

[#7315] recovery of exception — tateishi@...

[#7316] README.EXT.jp — tateishi@...

[#7323] Re: miner matrix — toyofuku@...

[#7324] Re: miner matrix — toyofuku@...

[#7325] Re: miner matrix — toyofuku@...

[#7327] subscribe to ML — Saburo Ide <saburo@...4u.or.jp>

[#7328] p {} — gotoken@... (GOTO Kentaro)

[#7330] sub, gsub bug? — 金子尚史 <wbs01621@...>

[#7331] Email Millions with FREE REGISTERED Stealth !!! — 26348868@...

[#7334] — Kazutomi Ueda <ueda@...>

[#7339] please register me — Yuji Shigehiro <sigehiro@...>

[#7342] '$' in regexp — TAKAHASHI Masayoshi <maki@...>

[#7348] mirror.rb — shugo@... (Shugo Maeda)

[#7354] def foo=(a,b) — keiju@... (Keiju ISHITSUKA)

[#7356] Q: jcode.rb tr(String + nil) — WATANABE Tetsuya <tetsu@...>

[#7376] [Q] Thread — keiju@... (Keiju ISHITSUKA)

[#7378] Re: sub, gsub bug? — Katsuyuki Okabe <HGC02147@...>

[#7380] string replace — KANEKO Naoshi <wbs01621@...>

[#7386] Dir.foreach — "Hiroshi Ishikawa(NIMS)" <h-isikaw@...16.nims.nec.co.jp>

[#7388] inf-ruby.el — senda@...

[#7399] chomp — NAGAI Hidetoshi <nagai@...>

[#7410] irb — keiju@... (Keiju ISHITSUKA)

[#7412] ruby-mode.el (1.1b9_09) — WATANABE Tetsuya <tetsu@...>

[#7430] alpha-dec-osf3.0 — gotoken@... (GOTO Kentaro)

[#7433] Registration & initialize method in subclass of builtin class — Inaba Hiroto <inaba@...>

[#7435] Re: same name methods — ttate@...

[#7439] character code and bug? — TAKAHASHI Masayoshi <maki@...>

[#7440] subscribe — mugi@...3.so-net.or.jp

[#7442] telnet.rb — Wakou Aoyama <wakou@...>

[#7443] delegate.rb(1.1b9_09) — Wakou Aoyama <wakou@...>

[#7450] Re: call for scripts — 助田 雅紀 <masaki.suketa@...>

[#7457] Re: call for scripts — 助田 雅紀 <masaki.suketa@...>

[#7463] slanglib — Kikutani Makoto <kikutani@...>

[#7464] subscribe for ruby-list — Kazuhiro HIWADA <hiwada@...>

[#7465] call for script — ttate@...

[#7466] s/3*/=/g — toyofuku@...

[#7469] [Q]ensure — Makoto Nukui <gnue@...>

[#7470] [Q]class method — Makoto Nukui <gnue@...>

[#7471] scope — Wakou Aoyama <wakou@...>

[#7472] socket — Wakou Aoyama <wakou@...>

[#7492] Tcl/Tk fileevent — NAGAI Hidetoshi <nagai@...>

[#7495] Re: [Q]class method — Makoto Nukui <gnue@...>

[#7496] Re: [Q]ensure — Makoto Nukui <gnue@...>

[#7500] List on List — WATANABE Hirofumi <watanabe@...>

[#7509] クラスの変更 — Mitsuru Ogino <ogino@...>

[#7510] s/3*/=/g — toyofuku@...

[#7513] GD 0.5 compile error — Noritsugu Nakamura <nnakamur@...>

[#7520] variable of ruby — Makoto Nukui <gnue@...>

[#7521] 永続オブジェクトとオブジェクト指向 DB... — Makoto Nukui <gnue@...>

[#7522] Re: [Q]ensure — Makoto Nukui <gnue@...>

[#7523] Re: [Q]class method — Makoto Nukui <gnue@...>

[#7524] 永続オブジェクトとオブジェクト指向 DB... — Makoto Nukui <gnue@...>

[#7533] Re: variable of ruby — Makoto Nukui <gnue@...>

[#7534] Re: 永続オブジェクトとオブジェクト指向 DB... — Makoto Nukui <gnue@...>

[#7535] Re: 永続オブジェクトとオブジェクト指向 DB... — Makoto Nukui <gnue@...>

[#7539] Re: scope — Makoto Nukui <gnue@...>

[#7541] simple_chat_server.rb — Wakou Aoyama <wakou@...>

[#7559] link on ruby's page — SUNAGAWA Keiki <Keiki_SUNAGAWA@...>

[#7582] Re: List on List — Makoto Nukui <gnue@...>

[#7588] Re: [Q]class method — Makoto Nukui <gnue@...>

[#7590] instance variable — Makoto Nukui <gnue@...>

[#7591] How to write Perl's `@a[@b] = @c' in ruby — Inaba Hiroto <inaba@...>

[#7596] Re: instance variable — Makoto Nukui <gnue@...>

[#7597] http-lib.rb — Wakou Aoyama <wakou@...>

[#7598] Marshal... — Makoto Nukui <gnue@...>

[#7599] Re: [Q]class method — Makoto Nukui <gnue@...>

[#7600] manual sample (socket) — WATANABE Tetsuya <tetsu@...>

[#7603] Hello! — Hiroyuki Ueki <ueki@...>

[#7616] patches for ruby-1.1b9 — akira yamada / やまだあきら <akira@...>

[#7617] banner... — Makoto Nukui <gnue@...>

[#7618] Re: 永続オブジェクトとオブジェクト指向 DB... — Makoto Nukui <gnue@...>

[#7620] GD 0.5 typo — Noritsugu Nakamura <nnakamur@...>

[#7621] Re: Marshal... — Makoto Nukui <gnue@...>

[#7450] Re: call for scripts — 助田　雅紀 <masaki.suketa@...>

[#7457] Re: call for scripts — 助田　雅紀 <masaki.suketa@...>

[#7634] Re: dir search — 助田　雅紀 <masaki.suketa@...>

[#7635] Re: dir search — 助田　雅紀 <masaki.suketa@...>

[#7641] local of Time class — 助田　雅紀 <masaki.suketa@...>

[#7664] private and protected — 助田　雅紀 <masaki.suketa@...>

[#7668] Re: private and protected — 助田　雅紀 <masaki.suketa@...>

[#7670] Re: private and protected — 助田　雅紀 <masaki.suketa@...>

[#7697] Re: private and protected — 助田　雅紀 <masaki.suketa@...>

[#7703] Out of Range — 助田　雅紀 <masaki.suketa@...>

[#7708] Re: Out of Range — 助田　雅紀 <masaki.suketa@...>

[#7717] mail.rb(call for scripts) — 助田　雅紀 <masaki.suketa@...>

[#7752] ftplib — 助田　雅紀 <masaki.suketa@...>