OSDN Git Service

Fix a bug.
[shogi-server/shogi-server.git] / shogi-server
1 #! /usr/bin/env ruby
2 ## $Id$
3
4 ## Copyright (C) 2004 NABEYA Kenichi (aka nanami@2ch)
5 ##
6 ## This program is free software; you can redistribute it and/or modify
7 ## it under the terms of the GNU General Public License as published by
8 ## the Free Software Foundation; either version 2 of the License, or
9 ## (at your option) any later version.
10 ##
11 ## This program is distributed in the hope that it will be useful,
12 ## but WITHOUT ANY WARRANTY; without even the implied warranty of
13 ## MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14 ## GNU General Public License for more details.
15 ##
16 ## You should have received a copy of the GNU General Public License
17 ## along with this program; if not, write to the Free Software
18 ## Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
19
20 Max_Write_Queue_Size = 1000
21 Max_Identifier_Length = 32
22 Default_Timeout = 60            # for single socket operation
23
24 Default_Game_Name = "default-1500-0"
25
26 One_Time = 10
27 Least_Time_Per_Move = 1
28 Login_Time = 300                # time for LOGIN
29
30 Release = "$Name$".split[1].sub(/\A[^\d]*/, '').gsub(/_/, '.')
31 Release.concat("-") if (Release == "")
32 Revision = "$Revision$".gsub(/[^\.\d]/, '')
33
34 STDOUT.sync = true
35 STDERR.sync = true
36
37 require 'getoptlong'
38 require 'thread'
39 require 'timeout'
40 require 'socket'
41 require 'yaml'
42 require 'yaml/store'
43 require 'digest/md5'
44
45 TCPSocket.do_not_reverse_lookup = true
46 Thread.abort_on_exception = true
47
48
49 class TCPSocket
50   def gets_timeout(t = Default_Timeout)
51     begin
52       timeout(t) do
53         return self.gets
54       end
55     rescue TimeoutError
56       return nil
57     rescue
58       return nil
59     end
60   end
61   def gets_safe(t = nil)
62     if (t && t > 0)
63       begin
64         timeout(t) do
65           return self.gets
66         end
67       rescue TimeoutError
68         return :timeout
69       rescue
70         return nil
71       end
72     else
73       begin
74         return self.gets
75       rescue
76         return nil
77       end
78     end
79   end
80   def write_safe(str)
81     begin
82       return self.write(str)
83     rescue
84       return nil
85     end
86   end
87 end
88
89
90 class League
91   def initialize
92     @games = Hash::new
93     @players = Hash::new
94     @event = nil
95     @db = YAML::Store.new( File.join(File.dirname(__FILE__), "players.yaml") )
96   end
97   attr_accessor :players, :games, :event
98
99   def add(player)
100     self.load(player) if player.id
101     @players[player.name] = player
102   end
103   
104   def delete(player)
105     @players.delete(player.name)
106   end
107   
108   def get_player(status, game_name, sente, searcher=nil)
109     @players.each do |name, player|
110       if ((player.status == status) &&
111           (player.game_name == game_name) &&
112           ((sente == nil) || (player.sente == nil) || (player.sente == sente)) &&
113           ((searcher == nil) || (player != searcher)))
114         return player
115       end
116     end
117     return nil
118   end
119   
120   def save
121     @db.transaction do
122       @players.each_value do |p|
123         next unless p.id
124         @db[p.id] = {'name' => p.name, 'rate' => p.rate}
125       end
126     end
127   end
128
129   def load(player)
130     hash = search(player.id)
131     if hash
132       # a current user
133       player.rate = hash['rate']
134     end
135   end
136
137   def search(id)
138     hash = nil
139     @db.transaction do
140       hash = @db[id]
141     end
142     hash
143   end
144 end
145
146 class Player
147   def initialize(str, socket)
148     @name = nil
149     @password = nil
150     @id = nil, @rate = nil      # used by rating
151     @socket = socket
152     @status = "connected"        # game_waiting -> agree_waiting -> start_waiting -> game -> finished
153
154     @protocol = nil             # CSA or x1
155     @eol = "\m"                 # favorite eol code
156     @game = nil
157     @game_name = ""
158     @mytime = 0                 # set in start method also
159     @sente = nil
160     @writer_thread = nil
161     @main_thread = nil
162     @write_queue = Queue::new
163     login(str)
164   end
165
166   attr_accessor :name, :password, :socket, :status, :rate
167   attr_accessor :protocol, :eol, :game, :mytime, :game_name, :sente
168   attr_accessor :main_thread, :writer_thread, :write_queue
169   attr_reader   :id
170   
171   def kill
172     log_message(sprintf("user %s killed", @name))
173     if (@game)
174       @game.kill(self)
175     end
176     finish
177     Thread::kill(@main_thread) if @main_thread
178   end
179
180   def finish
181     if (@status != "finished")
182       @status = "finished"
183       log_message(sprintf("user %s finish", @name))    
184       Thread::kill(@writer_thread) if @writer_thread
185       begin
186         @socket.close if (! @socket.closed?)
187       rescue
188         log_message(sprintf("user %s finish failed", @name))    
189       end
190     end
191   end
192
193   def write_safe(str)
194     @write_queue.push(str.gsub(/[\r\n]+/, @eol))
195   end
196
197   def writer
198     while (str = @write_queue.pop)
199       @socket.write_safe(str)
200     end
201   end
202
203   def to_s
204     if ((status == "game_waiting") ||
205         (status == "start_waiting") ||
206         (status == "agree_waiting") ||
207         (status == "game"))
208       if (@sente)
209         return sprintf("%s %s %s %s +", @name, @protocol, @status, @game_name)
210       elsif (@sente == false)
211         return sprintf("%s %s %s %s -", @name, @protocol, @status, @game_name)
212       elsif (@sente == nil)
213         return sprintf("%s %s %s %s *", @name, @protocol, @status, @game_name)
214       end
215     else
216       return sprintf("%s %s %s", @name, @protocol, @status)
217     end
218   end
219
220   def write_help
221     @socket.write_safe('##[HELP] available commands "%%WHO", "%%CHAT str", "%%GAME game_name +", "%%GAME game_name -"')
222   end
223
224   def login(str)
225     str =~ /([\r\n]*)$/
226     @eol = $1
227     str.chomp!
228     (login, @name, @password, ext) = str.split
229     @name, trip = @name.split(",") # used by rating
230     @id = trip ? Digest::MD5.hexdigest("#{@name},#{@trip}") : nil
231     if (ext)
232       @protocol = "x1"
233     else
234       @protocol = "CSA"
235     end
236     @main_thread = Thread::current
237     @writer_thread = Thread::start do
238       writer()
239     end
240   end
241   
242   def run
243     write_safe(sprintf("LOGIN:%s OK\n", @name))
244     if (@protocol != "CSA")
245       log_message(sprintf("user %s run in %s mode", @name, @protocol))
246       write_safe(sprintf("##[LOGIN] +OK %s\n", @protocol))
247     else
248       log_message(sprintf("user %s run in CSA mode", @name))
249       if (good_game_name?(@password))
250         csa_1st_str = "%%GAME #{@password} *"
251       else
252         csa_1st_str = "%%GAME #{Default_Game_Name} *"
253       end
254     end
255     
256     while (csa_1st_str || (str = @socket.gets_safe(Default_Timeout)))
257       begin
258         $mutex.lock
259         if (csa_1st_str)
260           str = csa_1st_str
261           csa_1st_str = nil
262         end
263         if (@write_queue.size > Max_Write_Queue_Size)
264           log_warning(sprintf("write_queue of %s is %d", @name, @write_queue.size))
265                 return
266         end
267
268         if (@status == "finished")
269           return
270         end
271         str.chomp! if (str.class == String)
272         case str
273         when /^[\+\-][^%]/
274           if (@status == "game")
275             array_str = str.split(",")
276             move = array_str.shift
277             additional = array_str.shift
278             if /^'(.*)/ =~ additional
279               comment = array_str.unshift("'*#{$1}")
280             end
281             s = @game.handle_one_move(move, self)
282             @game.fh.print("#{comment}\n") if (comment && !s)
283             return if (s && @protocol == "CSA")
284           end
285         when /^%[^%]/, :timeout
286           if (@status == "game")
287             s = @game.handle_one_move(str, self)
288             return if (s && @protocol == "CSA")
289           end
290         when /^REJECT/
291           if (@status == "agree_waiting")
292             @game.reject(@name)
293             return if (@protocol == "CSA")
294           else
295             write_safe(sprintf("##[ERROR] you are in %s status. AGREE is valid in agree_waiting status\n", @status))
296           end
297         when /^AGREE/
298           if (@status == "agree_waiting")
299             @status = "start_waiting"
300             if ((@game.sente.status == "start_waiting") &&
301                 (@game.gote.status == "start_waiting"))
302               @game.start
303               @game.sente.status = "game"
304               @game.gote.status = "game"
305             end
306           else
307             write_safe(sprintf("##[ERROR] you are in %s status. AGREE is valid in agree_waiting status\n", @status))
308           end
309         when /^%%SHOW\s+(\S+)/
310           game_id = $1
311           if (LEAGUE.games[game_id])
312             write_safe(LEAGUE.games[game_id].show.gsub(/^/, '##[SHOW] '))
313           end
314           write_safe("##[SHOW] +OK\n")
315         when /^%%MONITORON\s+(\S+)/
316           game_id = $1
317           if (LEAGUE.games[game_id])
318             LEAGUE.games[game_id].monitoron(self)
319             write_safe(LEAGUE.games[game_id].show.gsub(/^/, "##[MONITOR][#{game_id}] "))
320             write_safe("##[MONITOR][#{game_id}] +OK\n")
321           end
322         when /^%%MONITOROFF\s+(\S+)/
323           game_id = $1
324           if (LEAGUE.games[game_id])
325             LEAGUE.games[game_id].monitoroff(self)
326           end
327         when /^%%HELP/
328           write_help
329         when /^%%GAME\s*$/
330           if ((@status == "connected") || (@status == "game_waiting"))
331             @status = "connected"
332             @game_name = ""
333           else
334             write_safe(sprintf("##[ERROR] you are in %s status. GAME is valid in connected or game_waiting status\n", @status))
335           end
336         when /^%%(GAME|CHALLENGE)\s+(\S+)\s+([\+\-\*])\s*$/
337           command_name = $1
338           game_name = $2
339           my_sente_str = $3
340           if (! good_game_name?(game_name))
341             write_safe(sprintf("##[ERROR] bad game name\n"))
342             next
343           elsif ((@status == "connected") || (@status == "game_waiting"))
344             ## continue
345           else
346             write_safe(sprintf("##[ERROR] you are in %s status. GAME is valid in connected or game_waiting status\n", @status))
347             next
348           end
349           if ((my_sente_str == "*") ||
350               (my_sente_str == "+") ||
351               (my_sente_str == "-"))
352             ## ok
353           else
354             write_safe(sprintf("##[ERROR] bad game option\n"))
355             next
356           end
357
358           if (my_sente_str == "*")
359             rival = LEAGUE.get_player("game_waiting", game_name, nil, self) # no preference
360           elsif (my_sente_str == "+")
361             rival = LEAGUE.get_player("game_waiting", game_name, false, self) # rival must be gote
362           elsif (my_sente_str == "-")
363             rival = LEAGUE.get_player("game_waiting", game_name, true, self) # rival must be sente
364           else
365             ## never reached
366           end
367           if (rival)
368             @game_name = game_name
369             if ((my_sente_str == "*") && (rival.sente == nil))
370               if (rand(2) == 0)
371                 @sente = true
372                 rival.sente = false
373               else
374                 @sente = false
375                 rival.sente = true
376               end
377             elsif (rival.sente == true) # rival has higher priority
378               @sente = false
379             elsif (rival.sente == false)
380               @sente = true
381             elsif (my_sente_str == "+")
382               @sente = true
383               rival.sente = false
384             elsif (my_sente_str == "-")
385               @sente = false
386               rival.sente = true
387             else
388               ## never reached
389             end
390             Game::new(@game_name, self, rival)
391             self.status = "agree_waiting"
392             rival.status = "agree_waiting"
393           else # rival not found
394             if (command_name == "GAME")
395               @status = "game_waiting"
396               @game_name = game_name
397               if (my_sente_str == "+")
398                 @sente = true
399               elsif (my_sente_str == "-")
400                 @sente = false
401               else
402                 @sente = nil
403               end
404             else                # challenge
405               write_safe(sprintf("##[ERROR] can't find rival for %s\n", game_name))
406               @status = "connected"
407               @game_name = ""
408               @sente = nil
409             end
410           end
411         when /^%%CHAT\s+(.+)/
412           message = $1
413           LEAGUE.players.each do |name, player|
414             if (player.protocol != "CSA")
415               player.write_safe(sprintf("##[CHAT][%s] %s\n", @name, message)) 
416             end
417           end
418         when /^%%LIST/
419           buf = Array::new
420           LEAGUE.games.each do |id, game|
421             buf.push(sprintf("##[LIST] %s\n", id))
422           end
423           buf.push("##[LIST] +OK\n")
424           write_safe(buf.join)
425         when /^%%WHO/
426           buf = Array::new
427           LEAGUE.players.each do |name, player|
428             buf.push(sprintf("##[WHO] %s\n", player.to_s))
429           end
430           buf.push("##[WHO] +OK\n")
431           write_safe(buf.join)
432         when /^LOGOUT/
433           @status = "connected"
434           write_safe("LOGOUT:completed\n")
435           return
436         when /^\s*$/
437           ## ignore null string
438         else
439           write_safe(sprintf("##[ERROR] unknown command %s\n", str))
440         end
441       ensure
442         $mutex.unlock
443       end
444     end                         # enf of while
445   end
446 end
447
448 class Piece
449   PROMOTE = {"FU" => "TO", "KY" => "NY", "KE" => "NK", "GI" => "NG", "KA" => "UM", "HI" => "RY"}
450   def initialize(board, x, y, sente, promoted=false)
451     @board = board
452     @x = x
453     @y = y
454     @sente = sente
455     @promoted = promoted
456
457     if ((x == 0) || (y == 0))
458       if (sente)
459         hands = board.sente_hands
460       else
461         hands = board.gote_hands
462       end
463       hands.push(self)
464       hands.sort! {|a, b|
465         a.name <=> b.name
466       }
467     else
468       @board.array[x][y] = self
469     end
470   end
471   attr_accessor :promoted, :sente, :x, :y, :board
472
473   def room_of_head?(x, y, name)
474     true
475   end
476
477   def movable_grids
478     return adjacent_movable_grids + far_movable_grids
479   end
480
481   def far_movable_grids
482     return []
483   end
484
485   def jump_to?(x, y)
486     if ((1 <= x) && (x <= 9) && (1 <= y) && (y <= 9))
487       if ((@board.array[x][y] == nil) || # dst is empty
488           (@board.array[x][y].sente != @sente)) # dst is enemy
489         return true
490       end
491     end
492     return false
493   end
494
495   def put_to?(x, y)
496     if ((1 <= x) && (x <= 9) && (1 <= y) && (y <= 9))
497       if (@board.array[x][y] == nil) # dst is empty?
498         return true
499       end
500     end
501     return false
502   end
503
504   def adjacent_movable_grids
505     grids = Array::new
506     if (@promoted)
507       moves = @promoted_moves
508     else
509       moves = @normal_moves
510     end
511     moves.each do |(dx, dy)|
512       if (@sente)
513         cand_y = @y - dy
514       else
515         cand_y = @y + dy
516       end
517       cand_x = @x + dx
518       if (jump_to?(cand_x, cand_y))
519         grids.push([cand_x, cand_y])
520       end
521     end
522     return grids
523   end
524
525   def move_to?(x, y, name)
526     return false if (! room_of_head?(x, y, name))
527     return false if ((name != @name) && (name != @promoted_name))
528     return false if (@promoted && (name != @promoted_name)) # can't un-promote
529
530     if (! @promoted)
531       return false if (((@x == 0) || (@y == 0)) && (name != @name)) # can't put promoted piece
532       if (@sente)
533         return false if ((4 <= @y) && (4 <= y) && (name != @name)) # can't promote
534       else
535         return false if ((6 >= @y) && (6 >= y) && (name != @name))
536       end
537     end
538
539     if ((@x == 0) || (@y == 0))
540       return jump_to?(x, y)
541     else
542       return movable_grids.include?([x, y])
543     end
544   end
545
546   def move_to(x, y)
547     if ((@x == 0) || (@y == 0))
548       if (@sente)
549         @board.sente_hands.delete(self)
550       else
551         @board.gote_hands.delete(self)
552       end
553       @board.array[x][y] = self
554     elsif ((x == 0) || (y == 0))
555       @promoted = false         # clear promoted flag before moving to hands
556       if (@sente)
557         @board.sente_hands.push(self)
558       else
559         @board.gote_hands.push(self)
560       end
561       @board.array[@x][@y] = nil
562     else
563       @board.array[@x][@y] = nil
564       @board.array[x][y] = self
565     end
566     @x = x
567     @y = y
568   end
569
570   def point
571     @point
572   end
573
574   def name
575     @name
576   end
577
578   def promoted_name
579     @promoted_name
580   end
581
582   def to_s
583     if (@sente)
584       sg = "+"
585     else
586       sg = "-"
587     end
588     if (@promoted)
589       n = @promoted_name
590     else
591       n = @name
592     end
593     return sg + n
594   end
595 end
596
597 class PieceFU < Piece
598   def initialize(*arg)
599     @point = 1
600     @normal_moves = [[0, +1]]
601     @promoted_moves = [[0, +1], [+1, +1], [-1, +1], [+1, +0], [-1, +0], [0, -1]]
602     @name = "FU"
603     @promoted_name = "TO"
604     super
605   end
606   def room_of_head?(x, y, name)
607     if (name == "FU")
608       if (@sente)
609         return false if (y == 1)
610       else
611         return false if (y == 9)
612       end
613       ## 2fu check
614       c = 0
615       iy = 1
616       while (iy <= 9)
617         if ((iy  != @y) &&      # not source position
618             @board.array[x][iy] &&
619             (@board.array[x][iy].sente == @sente) && # mine
620             (@board.array[x][iy].name == "FU") &&
621             (@board.array[x][iy].promoted == false))
622           return false
623         end
624         iy = iy + 1
625       end
626     end
627     return true
628   end
629 end
630
631 class PieceKY  < Piece
632   def initialize(*arg)
633     @point = 1
634     @normal_moves = []
635     @promoted_moves = [[0, +1], [+1, +1], [-1, +1], [+1, +0], [-1, +0], [0, -1]]
636     @name = "KY"
637     @promoted_name = "NY"
638     super
639   end
640   def room_of_head?(x, y, name)
641     if (name == "KY")
642       if (@sente)
643         return false if (y == 1)
644       else
645         return false if (y == 9)
646       end
647     end
648     return true
649   end
650   def far_movable_grids
651     grids = Array::new
652     if (@promoted)
653       return []
654     else
655       if (@sente)                 # up
656         cand_x = @x
657         cand_y = @y - 1
658         while (jump_to?(cand_x, cand_y))
659           grids.push([cand_x, cand_y])
660           break if (! put_to?(cand_x, cand_y))
661           cand_y = cand_y - 1
662         end
663       else                        # down
664         cand_x = @x
665         cand_y = @y + 1
666         while (jump_to?(cand_x, cand_y))
667           grids.push([cand_x, cand_y])
668           break if (! put_to?(cand_x, cand_y))
669           cand_y = cand_y + 1
670         end
671       end
672       return grids
673     end
674   end
675 end
676 class PieceKE  < Piece
677   def initialize(*arg)
678     @point = 1
679     @normal_moves = [[+1, +2], [-1, +2]]
680     @promoted_moves = [[0, +1], [+1, +1], [-1, +1], [+1, +0], [-1, +0], [0, -1]]
681     @name = "KE"
682     @promoted_name = "NK"
683     super
684   end
685   def room_of_head?(x, y, name)
686     if (name == "KE")
687       if (@sente)
688         return false if ((y == 1) || (y == 2))
689       else
690         return false if ((y == 9) || (y == 8))
691       end
692     end
693     return true
694   end
695 end
696 class PieceGI  < Piece
697   def initialize(*arg)
698     @point = 1
699     @normal_moves = [[0, +1], [+1, +1], [-1, +1], [+1, -1], [-1, -1]]
700     @promoted_moves = [[0, +1], [+1, +1], [-1, +1], [+1, +0], [-1, +0], [0, -1]]
701     @name = "GI"
702     @promoted_name = "NG"
703     super
704   end
705 end
706 class PieceKI  < Piece
707   def initialize(*arg)
708     @point = 1
709     @normal_moves = [[0, +1], [+1, +1], [-1, +1], [+1, +0], [-1, +0], [0, -1]]
710     @promoted_moves = []
711     @name = "KI"
712     @promoted_name = nil
713     super
714   end
715 end
716 class PieceKA  < Piece
717   def initialize(*arg)
718     @point = 5
719     @normal_moves = []
720     @promoted_moves = [[0, +1], [+1, 0], [-1, 0], [0, -1]]
721     @name = "KA"
722     @promoted_name = "UM"
723     super
724   end
725   def far_movable_grids
726     grids = Array::new
727     ## up right
728     cand_x = @x - 1
729     cand_y = @y - 1
730     while (jump_to?(cand_x, cand_y))
731       grids.push([cand_x, cand_y])
732       break if (! put_to?(cand_x, cand_y))
733       cand_x = cand_x - 1
734       cand_y = cand_y - 1
735     end
736     ## down right
737     cand_x = @x - 1
738     cand_y = @y + 1
739     while (jump_to?(cand_x, cand_y))
740       grids.push([cand_x, cand_y])
741       break if (! put_to?(cand_x, cand_y))
742       cand_x = cand_x - 1
743       cand_y = cand_y + 1
744     end
745     ## up left
746     cand_x = @x + 1
747     cand_y = @y - 1
748     while (jump_to?(cand_x, cand_y))
749       grids.push([cand_x, cand_y])
750       break if (! put_to?(cand_x, cand_y))
751       cand_x = cand_x + 1
752       cand_y = cand_y - 1
753     end
754     ## down left
755     cand_x = @x + 1
756     cand_y = @y + 1
757     while (jump_to?(cand_x, cand_y))
758       grids.push([cand_x, cand_y])
759       break if (! put_to?(cand_x, cand_y))
760       cand_x = cand_x + 1
761       cand_y = cand_y + 1
762     end
763     return grids
764   end
765 end
766 class PieceHI  < Piece
767   def initialize(*arg)
768     @point = 5
769     @normal_moves = []
770     @promoted_moves = [[+1, +1], [-1, +1], [+1, -1], [-1, -1]]
771     @name = "HI"
772     @promoted_name = "RY"
773     super
774   end
775   def far_movable_grids
776     grids = Array::new
777     ## up
778     cand_x = @x
779     cand_y = @y - 1
780     while (jump_to?(cand_x, cand_y))
781       grids.push([cand_x, cand_y])
782       break if (! put_to?(cand_x, cand_y))
783       cand_y = cand_y - 1
784     end
785     ## down
786     cand_x = @x
787     cand_y = @y + 1
788     while (jump_to?(cand_x, cand_y))
789       grids.push([cand_x, cand_y])
790       break if (! put_to?(cand_x, cand_y))
791       cand_y = cand_y + 1
792     end
793     ## right
794     cand_x = @x - 1
795     cand_y = @y
796     while (jump_to?(cand_x, cand_y))
797       grids.push([cand_x, cand_y])
798       break if (! put_to?(cand_x, cand_y))
799       cand_x = cand_x - 1
800     end
801     ## down
802     cand_x = @x + 1
803     cand_y = @y
804     while (jump_to?(cand_x, cand_y))
805       grids.push([cand_x, cand_y])
806       break if (! put_to?(cand_x, cand_y))
807       cand_x = cand_x + 1
808     end
809     return grids
810   end
811 end
812 class PieceOU < Piece
813   def initialize(*arg)
814     @point = 0
815     @normal_moves = [[0, +1], [+1, +1], [-1, +1], [+1, +0], [-1, +0], [0, -1], [+1, -1], [-1, -1]]
816     @promoted_moves = []
817     @name = "OU"
818     @promoted_name = nil
819     super
820   end
821 end
822
823 class Board
824   def initialize
825     @sente_hands = Array::new
826     @gote_hands = Array::new
827     @history = Hash::new
828     @sente_history = Hash::new
829     @gote_history = Hash::new
830     @array = [[], [], [], [], [], [], [], [], [], []]
831     @move_count = 0
832   end
833   attr_accessor :array, :sente_hands, :gote_hands, :history, :sente_history, :gote_history
834   attr_reader :move_count
835
836   def initial
837     PieceKY::new(self, 1, 1, false)
838     PieceKE::new(self, 2, 1, false)
839     PieceGI::new(self, 3, 1, false)
840     PieceKI::new(self, 4, 1, false)
841     PieceOU::new(self, 5, 1, false)
842     PieceKI::new(self, 6, 1, false)
843     PieceGI::new(self, 7, 1, false)
844     PieceKE::new(self, 8, 1, false)
845     PieceKY::new(self, 9, 1, false)
846     PieceKA::new(self, 2, 2, false)
847     PieceHI::new(self, 8, 2, false)
848     PieceFU::new(self, 1, 3, false)
849     PieceFU::new(self, 2, 3, false)
850     PieceFU::new(self, 3, 3, false)
851     PieceFU::new(self, 4, 3, false)
852     PieceFU::new(self, 5, 3, false)
853     PieceFU::new(self, 6, 3, false)
854     PieceFU::new(self, 7, 3, false)
855     PieceFU::new(self, 8, 3, false)
856     PieceFU::new(self, 9, 3, false)
857
858     PieceKY::new(self, 1, 9, true)
859     PieceKE::new(self, 2, 9, true)
860     PieceGI::new(self, 3, 9, true)
861     PieceKI::new(self, 4, 9, true)
862     PieceOU::new(self, 5, 9, true)
863     PieceKI::new(self, 6, 9, true)
864     PieceGI::new(self, 7, 9, true)
865     PieceKE::new(self, 8, 9, true)
866     PieceKY::new(self, 9, 9, true)
867     PieceKA::new(self, 8, 8, true)
868     PieceHI::new(self, 2, 8, true)
869     PieceFU::new(self, 1, 7, true)
870     PieceFU::new(self, 2, 7, true)
871     PieceFU::new(self, 3, 7, true)
872     PieceFU::new(self, 4, 7, true)
873     PieceFU::new(self, 5, 7, true)
874     PieceFU::new(self, 6, 7, true)
875     PieceFU::new(self, 7, 7, true)
876     PieceFU::new(self, 8, 7, true)
877     PieceFU::new(self, 9, 7, true)
878   end
879
880   def have_piece?(hands, name)
881     piece = hands.find { |i|
882       i.name == name
883     }
884     return piece
885   end
886
887   def move_to(x0, y0, x1, y1, name, sente)
888     if (sente)
889       hands = @sente_hands
890     else
891       hands = @gote_hands
892     end
893
894     if ((x0 == 0) || (y0 == 0))
895       piece = have_piece?(hands, name)
896       return :illegal if (! piece.move_to?(x1, y1, name))
897       piece.move_to(x1, y1)
898     else
899       return :illegal if (! @array[x0][y0].move_to?(x1, y1, name))
900       if (@array[x0][y0].name != name) # promoted ?
901         @array[x0][y0].promoted = true
902       end
903       if (@array[x1][y1])
904         if (@array[x1][y1].name == "OU")
905           return :outori        # return board update
906         end
907         @array[x1][y1].sente = @array[x0][y0].sente
908         @array[x1][y1].move_to(0, 0)
909         hands.sort! {|a, b|
910           a.name <=> b.name
911         }
912       end
913       @array[x0][y0].move_to(x1, y1)
914     end
915     @move_count += 1
916     return true
917   end
918
919   def look_for_ou(sente)
920     x = 1
921     while (x <= 9)
922       y = 1
923       while (y <= 9)
924         if (@array[x][y] &&
925             (@array[x][y].name == "OU") &&
926             (@array[x][y].sente == sente))
927           return @array[x][y]
928         end
929         y = y + 1
930       end
931       x = x + 1
932     end
933     raise "can't find ou"
934   end
935
936   def checkmated?(sente)        # sente is loosing
937     ou = look_for_ou(sente)
938     x = 1
939     while (x <= 9)
940       y = 1
941       while (y <= 9)
942         if (@array[x][y] &&
943             (@array[x][y].sente != sente))
944           if (@array[x][y].movable_grids.include?([ou.x, ou.y]))
945             return true
946           end
947         end
948         y = y + 1
949       end
950       x = x + 1
951     end
952     return false
953   end
954
955   def uchifuzume?(sente)
956     rival_ou = look_for_ou(! sente)   # rival's ou
957     if (sente)                  # rival is gote
958       if ((rival_ou.y != 9) &&
959           (@array[rival_ou.x][rival_ou.y + 1]) &&
960           (@array[rival_ou.x][rival_ou.y + 1].name == "FU") &&
961           (@array[rival_ou.x][rival_ou.y + 1].sente == sente)) # uchifu true
962         fu_x = rival_ou.x
963         fu_y = rival_ou.y + 1
964       else
965         return false
966       end
967     else                        # gote
968       if ((rival_ou.y != 0) &&
969           (@array[rival_ou.x][rival_ou.y - 1]) &&
970           (@array[rival_ou.x][rival_ou.y - 1].name == "FU") &&
971           (@array[rival_ou.x][rival_ou.y - 1].sente == sente)) # uchifu true
972         fu_x = rival_ou.x
973         fu_y = rival_ou.y - 1
974       else
975         return false
976       end
977     end
978     
979     ## case: rival_ou is moving
980     escaped = false
981     rival_ou.movable_grids.each do |(cand_x, cand_y)|
982       tmp_board = Marshal.load(Marshal.dump(self))
983       s = tmp_board.move_to(rival_ou.x, rival_ou.y, cand_x, cand_y, "OU", ! sente)
984       raise "internal error" if (s != true)
985       if (! tmp_board.checkmated?(! sente)) # good move
986         return false
987       end
988     end
989
990     ## case: rival is capturing fu
991     x = 1
992     while (x <= 9)
993       y = 1
994       while (y <= 9)
995         if (@array[x][y] &&
996             (@array[x][y].sente != sente) &&
997             @array[x][y].movable_grids.include?([fu_x, fu_y])) # capturable
998           if (@array[x][y].promoted)
999             name = @array[x][y].promoted_name
1000           else
1001             name = @array[x][y].name
1002           end
1003           tmp_board = Marshal.load(Marshal.dump(self))
1004           s = tmp_board.move_to(x, y, fu_x, fu_y, name, ! sente)
1005           raise "internal error" if (s != true)
1006           if (! tmp_board.checkmated?(! sente)) # good move
1007             return false
1008           end
1009         end
1010         y = y + 1
1011       end
1012       x = x + 1
1013     end
1014     return true
1015   end
1016
1017   def oute_sennichite?(sente)
1018     if (checkmated?(! sente))
1019       str = to_s
1020       if (sente)
1021         if (@sente_history[str] && (@sente_history[str] >= 3)) # already 3 times
1022           return true
1023         end
1024       else
1025         if (@gote_history[str] && (@gote_history[str] >= 3)) # already 3 times
1026           return true
1027         end
1028       end
1029     end
1030     return false
1031   end
1032
1033   def sennichite?(sente)
1034     str = to_s
1035     if (@history[str] && (@history[str] >= 3)) # already 3 times
1036       return true
1037     end
1038     return false
1039   end
1040
1041   def good_kachi?(sente)
1042     if (checkmated?(sente))
1043       puts "'NG: Checkmating." if $DEBUG
1044       return false 
1045     end
1046     
1047     ou = look_for_ou(sente)
1048     if (sente && (ou.y >= 4))
1049       puts "'NG: Black's OU does not enter yet." if $DEBUG
1050       return false     
1051     end  
1052     if (! sente && (ou.y <= 6))
1053       puts "'NG: White's OU does not enter yet." if $DEBUG
1054       return false 
1055     end
1056       
1057     number = 0
1058     point = 0
1059
1060     if (sente)
1061       hands = @sente_hands
1062       r = [1, 2, 3]
1063     else
1064       hands = @gote_hands
1065       r = [7, 8, 9]
1066     end
1067     r.each do |y|
1068       x = 1
1069       while (x <= 9)
1070         if (@array[x][y] &&
1071             (@array[x][y].sente == sente) &&
1072             (@array[x][y].point > 0))
1073           point = point + @array[x][y].point
1074           number = number + 1
1075         end
1076         x = x + 1
1077       end
1078     end
1079     hands.each do |piece|
1080       point = point + piece.point
1081     end
1082
1083     if (number < 10)
1084       puts "'NG: Piece#[%d] is too small." % [number] if $DEBUG
1085       return false     
1086     end  
1087     if (sente)
1088       if (point < 28)
1089         puts "'NG: Black's point#[%d] is too small." % [point] if $DEBUG
1090         return false 
1091       end  
1092     else
1093       if (point < 27)
1094         puts "'NG: White's point#[%d] is too small." % [point] if $DEBUG
1095         return false 
1096       end
1097     end
1098
1099     puts "'Good: Piece#[%d], Point[%d]." % [number, point] if $DEBUG
1100     return true
1101   end
1102
1103   def handle_one_move(str, sente)
1104     if (str =~ /^([\+\-])(\d)(\d)(\d)(\d)([A-Z]{2})/)
1105       sg = $1
1106       x0 = $2.to_i
1107       y0 = $3.to_i
1108       x1 = $4.to_i
1109       y1 = $5.to_i
1110       name = $6
1111     elsif (str =~ /^%KACHI/)
1112       if (good_kachi?(sente))
1113         return :kachi_win
1114       else
1115         return :kachi_lose
1116       end
1117     elsif (str =~ /^%TORYO/)
1118       return :toryo
1119     else
1120       return :illegal
1121     end
1122     
1123     if (((x0 == 0) || (y0 == 0)) && # source is not from hand
1124         ((x0 != 0) || (y0 != 0)))
1125       return :illegal
1126     elsif ((x1 == 0) || (y1 == 0)) # destination is out of board
1127       return :illegal
1128     end
1129     
1130     if (sg == "+")
1131       sente = true
1132       hands = @sente_hands
1133     else
1134       sente = false
1135       hands = @gote_hands
1136     end
1137     
1138     ## source check
1139     if ((x0 == 0) && (y0 == 0))
1140       return :illegal if (! have_piece?(hands, name))
1141     elsif (! @array[x0][y0])
1142       return :illegal           # no piece
1143     elsif (@array[x0][y0].sente != sente)
1144       return :illegal           # this is not mine
1145     elsif (@array[x0][y0].name != name)
1146       return :illegal if (@array[x0][y0].promoted_name != name) # can't promote
1147     end
1148
1149     ## destination check
1150     if (@array[x1][y1] &&
1151         (@array[x1][y1].sente == sente)) # can't capture mine
1152       return :illegal
1153     elsif ((x0 == 0) && (y0 == 0) && @array[x1][y1])
1154       return :illegal           # can't put on existing piece
1155     end
1156
1157     tmp_board = Marshal.load(Marshal.dump(self))
1158     return :illegal if (tmp_board.move_to(x0, y0, x1, y1, name, sente) == :illegal)
1159     return :oute_kaihimore if (tmp_board.checkmated?(sente))
1160     return :oute_sennichite if tmp_board.oute_sennichite?(sente)
1161     return :sennichite if tmp_board.sennichite?(sente)
1162
1163     if ((x0 == 0) && (y0 == 0) && (name == "FU") && tmp_board.uchifuzume?(sente))
1164       return :uchifuzume
1165     end
1166
1167     move_to(x0, y0, x1, y1, name, sente)
1168     str = to_s
1169
1170     if (checkmated?(! sente))
1171       if (sente)
1172         @sente_history[str] = (@sente_history[str] || 0) + 1
1173       else
1174         @gote_history[str] = (@gote_history[str] || 0) + 1
1175       end
1176     else
1177       if (sente)
1178         @sente_history.clear
1179       else
1180         @gote_history.clear
1181       end
1182     end
1183     @history[str] = (@history[str] || 0) + 1
1184     return :normal
1185   end
1186
1187   def to_s
1188     a = Array::new
1189     y = 1
1190     while (y <= 9)
1191       a.push(sprintf("P%d", y))
1192       x = 9
1193       while (x >= 1)
1194         piece = @array[x][y]
1195         if (piece)
1196           s = piece.to_s
1197         else
1198           s = " * "
1199         end
1200         a.push(s)
1201         x = x - 1
1202       end
1203       a.push(sprintf("\n"))
1204       y = y + 1
1205     end
1206     if (! sente_hands.empty?)
1207       a.push("P+")
1208       sente_hands.each do |p|
1209         a.push("00" + p.name)
1210       end
1211       a.push("\n")
1212     end
1213     if (! gote_hands.empty?)
1214       a.push("P-")
1215       gote_hands.each do |p|
1216         a.push("00" + p.name)
1217       end
1218       a.push("\n")
1219     end
1220     a.push("+\n")
1221     return a.join
1222   end
1223 end
1224
1225 #################################################
1226 # Rating module
1227 #
1228 # http://www2.saganet.ne.jp/a-sim/mhp0726.html
1229 # http://www10.plala.or.jp/greenstone/content1_3.html
1230 class Rating
1231   K = 16
1232
1233   def new_rate(me, you, win)
1234     w = win ? 1 : 0
1235     
1236     if me == nil && you != nil
1237       return (you + w*400).to_i
1238     elsif me == nil && you == nil
1239       return (1100 + w*400).to_i
1240     elsif you == nil
1241       return me.to_i
1242     end
1243     score = me + K*(w - we(me, you))
1244     score.to_i
1245   end
1246
1247   private
1248
1249   # win expectancy
1250   def we(me, you)
1251     dr = (me - you)
1252     1.0 / ( 10**(-1.0*dr/400) + 1 )
1253   end
1254 end
1255
1256
1257
1258 class GameResult
1259   def initialize(p1, p2)
1260     @players = []
1261     @players << p1
1262     @players << p2
1263   end
1264 end
1265
1266 class GameResultWin < GameResult
1267   attr_reader :winner, :loser
1268     
1269   def initialize(winner, loser)
1270     super
1271     @winner, @loser = winner, loser
1272     rate if @winner.id && @loser.id
1273   end
1274
1275   def win?(player)
1276     @winner == player
1277   end
1278
1279   def rate
1280     rating = Rating.new
1281     new_winner = rating.new_rate(@winner.rate, @loser.rate,  true)
1282     new_loser  = rating.new_rate(@loser.rate,  @winner.rate, false)
1283     @winner.rate = new_winner if new_winner
1284     @loser.rate  = new_loser  if new_loser
1285   end
1286 end
1287
1288 class GameResultDraw < GameResult
1289
1290 end
1291
1292 class Game
1293   @@mutex = Mutex.new
1294   @@time  = 0
1295
1296   def initialize(game_name, player0, player1)
1297     @monitors = Array::new
1298     @game_name = game_name
1299     if (@game_name =~ /-(\d+)-(\d+)$/)
1300       @total_time = $1.to_i
1301       @byoyomi = $2.to_i
1302     end
1303
1304     if (player0.sente)
1305       @sente = player0
1306       @gote = player1
1307     else
1308       @sente = player1
1309       @gote = player0
1310     end
1311     @current_player = @sente
1312     @next_player = @gote
1313
1314     @sente.game = self
1315     @gote.game = self
1316
1317     @last_move = ""
1318     @current_turn = 0
1319
1320     @sente.status = "agree_waiting"
1321     @gote.status = "agree_waiting"
1322     
1323     @id = sprintf("%s+%s+%s+%s+%s", 
1324                   LEAGUE.event, @game_name, @sente.name, @gote.name, issue_current_time)
1325     @logfile = @id + ".csa"
1326
1327     LEAGUE.games[@id] = self
1328
1329     log_message(sprintf("game created %s", @id))
1330
1331     @board = Board::new
1332     @board.initial
1333     @start_time = nil
1334     @fh = nil
1335     @result = nil
1336
1337     propose
1338   end
1339   attr_accessor :game_name, :total_time, :byoyomi, :sente, :gote, :id, :board, :current_player, :next_player, :fh, :monitors
1340   attr_accessor :last_move, :current_turn
1341   attr_reader   :result
1342
1343   def monitoron(monitor)
1344     @monitors.delete(monitor)
1345     @monitors.push(monitor)
1346   end
1347
1348   def monitoroff(monitor)
1349     @monitors.delete(monitor)
1350   end
1351
1352   def reject(rejector)
1353     @sente.write_safe(sprintf("REJECT:%s by %s\n", @id, rejector))
1354     @gote.write_safe(sprintf("REJECT:%s by %s\n", @id, rejector))
1355     finish
1356   end
1357
1358   def kill(killer)
1359     if ((@sente.status == "agree_waiting") || (@sente.status == "start_waiting"))
1360       reject(killer.name)
1361     elsif (@current_player == killer)
1362       abnormal_lose()
1363       finish
1364     end
1365   end
1366
1367   def finish
1368     log_message(sprintf("game finished %s", @id))
1369     @fh.printf("'$END_TIME:%s\n", Time::new.strftime("%Y/%m/%d %H:%M:%S"))    
1370     @fh.close
1371
1372     @sente.game = nil
1373     @gote.game = nil
1374     @sente.status = "connected"
1375     @gote.status = "connected"
1376
1377     if (@current_player.protocol == "CSA")
1378       @current_player.finish
1379     end
1380     if (@next_player.protocol == "CSA")
1381       @next_player.finish
1382     end
1383     @monitors = Array::new
1384     @sente = nil
1385     @gote = nil
1386     @current_player = nil
1387     @next_player = nil
1388     LEAGUE.games.delete(@id)
1389     LEAGUE.save
1390   end
1391
1392   def handle_one_move(str, player)
1393     finish_flag = true
1394     if (@current_player == player)
1395       @end_time = Time::new
1396       t = (@end_time - @start_time).floor
1397       t = Least_Time_Per_Move if (t < Least_Time_Per_Move)
1398       
1399       move_status = nil
1400       if ((@current_player.mytime - t <= -@byoyomi) && ((@total_time > 0) || (@byoyomi > 0)))
1401         status = :timeout
1402       elsif (str == :timeout)
1403         return false            # time isn't expired. players aren't swapped. continue game
1404       else
1405         @current_player.mytime = @current_player.mytime - t
1406         if (@current_player.mytime < 0)
1407           @current_player.mytime = 0
1408         end
1409
1410 #        begin
1411           move_status = @board.handle_one_move(str, @sente == @current_player)
1412 #        rescue
1413 #          log_error("handle_one_move raise exception for #{str}")
1414 #          move_status = :illegal
1415 #        end
1416
1417         if ((move_status == :illegal) || (move_status == :uchifuzme) || (move_status == :oute_kaihimore))
1418           @fh.printf("'ILLEGAL_MOVE(%s)\n", str)
1419         else
1420           if ((move_status == :normal) || (move_status == :outori) || (move_status == :sennichite) || (move_status == :oute_sennichite))
1421             @sente.write_safe(sprintf("%s,T%d\n", str, t))
1422             @gote.write_safe(sprintf("%s,T%d\n", str, t))
1423             @fh.printf("%s\nT%d\n", str, t)
1424             @last_move = sprintf("%s,T%d", str, t)
1425             @current_turn = @current_turn + 1
1426           end
1427
1428           @monitors.each do |monitor|
1429             monitor.write_safe(show.gsub(/^/, "##[MONITOR][#{@id}] "))
1430             monitor.write_safe(sprintf("##[MONITOR][%s] +OK\n", @id))
1431           end
1432         end
1433       end
1434
1435       if (@next_player.status != "game") # rival is logout or disconnected
1436         abnormal_win()
1437       elsif (status == :timeout)
1438         timeout_lose()
1439       elsif (move_status == :illegal)
1440         illegal_lose()
1441       elsif (move_status == :kachi_win)
1442         kachi_win()
1443       elsif (move_status == :kachi_lose)
1444         kachi_lose()
1445       elsif (move_status == :toryo)
1446         toryo_lose()
1447       elsif (move_status == :outori)
1448         outori_win()
1449       elsif (move_status == :sennichite)
1450         sennichite_draw()
1451       elsif (move_status == :oute_sennichite)
1452         oute_sennichite_lose()
1453       elsif (move_status == :uchifuzume)
1454         uchifuzume_lose()
1455       elsif (move_status == :oute_kaihimore)
1456         oute_kaihimore_lose()
1457       else
1458         finish_flag = false
1459       end
1460       finish() if finish_flag
1461       (@current_player, @next_player) = [@next_player, @current_player]
1462       @start_time = Time::new
1463       return finish_flag
1464     end
1465   end
1466
1467   def abnormal_win
1468     @current_player.status = "connected"
1469     @next_player.status = "connected"
1470     @current_player.write_safe("%TORYO\n#RESIGN\n#WIN\n")
1471     @next_player.write_safe("%TORYO\n#RESIGN\n#LOSE\n")
1472     @result = GameResultWin.new(@current_player, @next_player)
1473     @fh.printf("%%TORYO\n")
1474     @fh.print(@board.to_s.gsub(/^/, "\'"))
1475     @fh.printf("'summary:abnormal:%s win:%s lose\n", @current_player.name, @next_player.name)
1476     @monitors.each do |monitor|
1477       monitor.write_safe(sprintf("##[MONITOR][%s] %%TORYO\n", @id))
1478     end
1479   end
1480
1481   def abnormal_lose
1482     @current_player.status = "connected"
1483     @next_player.status = "connected"
1484     @current_player.write_safe("%TORYO\n#RESIGN\n#LOSE\n")
1485     @next_player.write_safe("%TORYO\n#RESIGN\n#WIN\n")
1486     @result = GameResultWin.new(@next_player, @current_player)
1487     @fh.printf("%%TORYO\n")
1488     @fh.print(@board.to_s.gsub(/^/, "\'"))
1489     @fh.printf("'summary:abnormal:%s lose:%s win\n", @current_player.name, @next_player.name)
1490     @monitors.each do |monitor|
1491       monitor.write_safe(sprintf("##[MONITOR][%s] %%TORYO\n", @id))
1492     end
1493   end
1494
1495   def sennichite_draw
1496     @current_player.status = "connected"
1497     @next_player.status = "connected"
1498     @current_player.write_safe("#SENNICHITE\n#DRAW\n")
1499     @next_player.write_safe("#SENNICHITE\n#DRAW\n")
1500     @result = GameResultDraw.new(@current_player, @next_player)
1501     @fh.print(@board.to_s.gsub(/^/, "\'"))
1502     @fh.printf("'summary:sennichite:%s draw:%s draw\n", @current_player.name, @next_player.name)
1503     @monitors.each do |monitor|
1504       monitor.write_safe(sprintf("##[MONITOR][%s] #SENNICHITE\n", @id))
1505     end
1506   end
1507
1508   def oute_sennichite_lose
1509     @current_player.status = "connected"
1510     @next_player.status = "connected"
1511     @current_player.write_safe("#OUTE_SENNICHITE\n#LOSE\n")
1512     @next_player.write_safe("#OUTE_SENNICHITE\n#WIN\n")
1513     @result = GameResultWin.new(@next_player, @current_player)
1514     @fh.print(@board.to_s.gsub(/^/, "\'"))
1515     @fh.printf("'summary:oute_sennichite:%s lose:%s win\n", @current_player.name, @next_player.name)
1516     @monitors.each do |monitor|
1517       monitor.write_safe(sprintf("##[MONITOR][%s] #OUTE_SENNICHITE\n", @id))
1518     end
1519   end
1520
1521   def illegal_lose
1522     @current_player.status = "connected"
1523     @next_player.status = "connected"
1524     @current_player.write_safe("#ILLEGAL_MOVE\n#LOSE\n")
1525     @next_player.write_safe("#ILLEGAL_MOVE\n#WIN\n")
1526     @result = GameResultWin.new(@next_player, @current_player)
1527     @fh.print(@board.to_s.gsub(/^/, "\'"))
1528     @fh.printf("'summary:illegal move:%s lose:%s win\n", @current_player.name, @next_player.name)
1529     @monitors.each do |monitor|
1530       monitor.write_safe(sprintf("##[MONITOR][%s] #ILLEGAL_MOVE\n", @id))
1531     end
1532   end
1533
1534   def uchifuzume_lose
1535     @current_player.status = "connected"
1536     @next_player.status = "connected"
1537     @current_player.write_safe("#ILLEGAL_MOVE\n#LOSE\n")
1538     @next_player.write_safe("#ILLEGAL_MOVE\n#WIN\n")
1539     @result = GameResultWin.new(@next_player, @current_player)
1540     @fh.print(@board.to_s.gsub(/^/, "\'"))
1541     @fh.printf("'summary:uchifuzume:%s lose:%s win\n", @current_player.name, @next_player.name)
1542     @monitors.each do |monitor|
1543       monitor.write_safe(sprintf("##[MONITOR][%s] #ILLEGAL_MOVE\n", @id))
1544     end
1545   end
1546
1547   def oute_kaihimore_lose
1548     @current_player.status = "connected"
1549     @next_player.status = "connected"
1550     @current_player.write_safe("#ILLEGAL_MOVE\n#LOSE\n")
1551     @next_player.write_safe("#ILLEGAL_MOVE\n#WIN\n")
1552     @result = GameResultWin.new(@next_player, @current_player)
1553     @fh.print(@board.to_s.gsub(/^/, "\'"))
1554     @fh.printf("'summary:oute_kaihimore:%s lose:%s win\n", @current_player.name, @next_player.name)
1555     @monitors.each do |monitor|
1556       monitor.write_safe(sprintf("##[MONITOR][%s] #ILLEGAL_MOVE\n", @id))
1557     end
1558   end
1559
1560   def timeout_lose
1561     @current_player.status = "connected"
1562     @next_player.status = "connected"
1563     @current_player.write_safe("#TIME_UP\n#LOSE\n")
1564     @next_player.write_safe("#TIME_UP\n#WIN\n")
1565     @result = GameResultWin.new(@next_player, @current_player)
1566     @fh.print(@board.to_s.gsub(/^/, "\'"))
1567     @fh.printf("'summary:time up:%s lose:%s win\n", @current_player.name, @next_player.name)
1568     @monitors.each do |monitor|
1569       monitor.write_safe(sprintf("##[MONITOR][%s] #TIME_UP\n", @id))
1570     end
1571   end
1572
1573   def kachi_win
1574     @current_player.status = "connected"
1575     @next_player.status = "connected"
1576     @current_player.write_safe("%KACHI\n#JISHOGI\n#WIN\n")
1577     @next_player.write_safe("%KACHI\n#JISHOGI\n#LOSE\n")
1578     @result = GameResultWin.new(@current_player, @next_player)
1579     @fh.printf("%%KACHI\n")
1580     @fh.print(@board.to_s.gsub(/^/, "\'"))
1581     @fh.printf("'summary:kachi:%s win:%s lose\n", @current_player.name, @next_player.name)
1582     @monitors.each do |monitor|
1583       monitor.write_safe(sprintf("##[MONITOR][%s] %%KACHI\n", @id))
1584     end
1585   end
1586
1587   def kachi_lose
1588     @current_player.status = "connected"
1589     @next_player.status = "connected"
1590     @current_player.write_safe("%KACHI\n#ILLEGAL_MOVE\n#LOSE\n")
1591     @next_player.write_safe("%KACHI\n#ILLEGAL_MOVE\n#WIN\n")
1592     @result = GameResultWin(@next_player, @current_player)
1593     @fh.printf("%%KACHI\n")
1594     @fh.print(@board.to_s.gsub(/^/, "\'"))
1595     @fh.printf("'summary:illegal kachi:%s lose:%s win\n", @current_player.name, @next_player.name)
1596     @monitors.each do |monitor|
1597       monitor.write_safe(sprintf("##[MONITOR][%s] %%KACHI\n", @id))
1598     end
1599   end
1600
1601   def toryo_lose
1602     @current_player.status = "connected"
1603     @next_player.status = "connected"
1604     @current_player.write_safe("%TORYO\n#RESIGN\n#LOSE\n")
1605     @next_player.write_safe("%TORYO\n#RESIGN\n#WIN\n")
1606     @result = GameResultWin.new(@next_player, @current_player)
1607     @fh.printf("%%TORYO\n")
1608     @fh.print(@board.to_s.gsub(/^/, "\'"))
1609     @fh.printf("'summary:toryo:%s lose:%s win\n", @current_player.name, @next_player.name)
1610     @monitors.each do |monitor|
1611       monitor.write_safe(sprintf("##[MONITOR][%s] %%TORYO\n", @id))
1612     end
1613   end
1614
1615   def outori_win
1616     @current_player.status = "connected"
1617     @next_player.status = "connected"
1618     @current_player.write_safe("#ILLEGAL_MOVE\n#WIN\n")
1619     @next_player.write_safe("#ILLEGAL_MOVE\n#LOSE\n")
1620     @result = GameResultWin.new(@current_player, @next_player)
1621     @fh.print(@board.to_s.gsub(/^/, "\'"))
1622     @fh.printf("'summary:outori:%s win:%s lose\n", @current_player.name, @next_player.name)
1623     @monitors.each do |monitor|
1624       monitor.write_safe(sprintf("##[MONITOR][%s] #ILLEGAL_MOVE\n", @id))
1625     end
1626   end
1627
1628   def start
1629     log_message(sprintf("game started %s", @id))
1630     @sente.write_safe(sprintf("START:%s\n", @id))
1631     @gote.write_safe(sprintf("START:%s\n", @id))
1632     @sente.mytime = @total_time
1633     @gote.mytime = @total_time
1634     @start_time = Time::new
1635   end
1636
1637   def propose
1638     begin
1639       @fh = open(@logfile, "w")
1640       @fh.sync = true
1641
1642       @fh.printf("V2\n")
1643       @fh.printf("N+%s\n", @sente.name)
1644       @fh.printf("N-%s\n", @gote.name)
1645       @fh.printf("$EVENT:%s\n", @id)
1646
1647       @sente.write_safe(propose_message("+"))
1648       @gote.write_safe(propose_message("-"))
1649
1650       @fh.printf("$START_TIME:%s\n", Time::new.strftime("%Y/%m/%d %H:%M:%S"))
1651       @fh.print <<EOM
1652 P1-KY-KE-GI-KI-OU-KI-GI-KE-KY
1653 P2 * -HI *  *  *  *  * -KA * 
1654 P3-FU-FU-FU-FU-FU-FU-FU-FU-FU
1655 P4 *  *  *  *  *  *  *  *  * 
1656 P5 *  *  *  *  *  *  *  *  * 
1657 P6 *  *  *  *  *  *  *  *  * 
1658 P7+FU+FU+FU+FU+FU+FU+FU+FU+FU
1659 P8 * +KA *  *  *  *  * +HI * 
1660 P9+KY+KE+GI+KI+OU+KI+GI+KE+KY
1661 +
1662 EOM
1663     end
1664   end
1665
1666   def show()
1667     str0 = <<EOM
1668 BEGIN Game_Summary
1669 Protocol_Version:1.1
1670 Protocol_Mode:Server
1671 Format:Shogi 1.0
1672 Declaration:Jishogi 1.1
1673 Game_ID:#{@id}
1674 Name+:#{@sente.name}
1675 Name-:#{@gote.name}
1676 Rematch_On_Draw:NO
1677 To_Move:+
1678 BEGIN Time
1679 Time_Unit:1sec
1680 Total_Time:#{@total_time}
1681 Byoyomi:#{@byoyomi}
1682 Least_Time_Per_Move:#{Least_Time_Per_Move}
1683 Remaining_Time+:#{@sente.mytime}
1684 Remaining_Time-:#{@gote.mytime}
1685 Last_Move:#{@last_move}
1686 Current_Turn:#{@current_turn}
1687 END Time
1688 BEGIN Position
1689 EOM
1690
1691     str1 = <<EOM
1692 END Position
1693 END Game_Summary
1694 EOM
1695
1696     return str0 + @board.to_s + str1
1697   end
1698
1699   def propose_message(sg_flag)
1700     str = <<EOM
1701 BEGIN Game_Summary
1702 Protocol_Version:1.1
1703 Protocol_Mode:Server
1704 Format:Shogi 1.0
1705 Declaration:Jishogi 1.1
1706 Game_ID:#{@id}
1707 Name+:#{@sente.name}
1708 Name-:#{@gote.name}
1709 Your_Turn:#{sg_flag}
1710 Rematch_On_Draw:NO
1711 To_Move:+
1712 BEGIN Time
1713 Time_Unit:1sec
1714 Total_Time:#{@total_time}
1715 Byoyomi:#{@byoyomi}
1716 Least_Time_Per_Move:#{Least_Time_Per_Move}
1717 END Time
1718 BEGIN Position
1719 P1-KY-KE-GI-KI-OU-KI-GI-KE-KY
1720 P2 * -HI *  *  *  *  * -KA * 
1721 P3-FU-FU-FU-FU-FU-FU-FU-FU-FU
1722 P4 *  *  *  *  *  *  *  *  * 
1723 P5 *  *  *  *  *  *  *  *  * 
1724 P6 *  *  *  *  *  *  *  *  * 
1725 P7+FU+FU+FU+FU+FU+FU+FU+FU+FU
1726 P8 * +KA *  *  *  *  * +HI * 
1727 P9+KY+KE+GI+KI+OU+KI+GI+KE+KY
1728 P+
1729 P-
1730 +
1731 END Position
1732 END Game_Summary
1733 EOM
1734     return str
1735   end
1736   
1737   private
1738   
1739   def issue_current_time
1740     time = Time::new.strftime("%Y%m%d%H%M%S").to_i
1741     @@mutex.synchronize do
1742       while time <= @@time do
1743         time += 1
1744       end
1745       @@time = time
1746     end
1747   end
1748 end
1749
1750 #################################################
1751 # MAIN
1752 #
1753
1754 def usage
1755     print <<EOM
1756 NAME
1757         shogi-server - server for CSA server protocol
1758
1759 SYNOPSIS
1760         shogi-server event_name port_number
1761
1762 DESCRIPTION
1763         server for CSA server protocol
1764
1765 OPTIONS
1766         --pid-file file
1767                 specify filename for logging process ID
1768
1769 LICENSE
1770         this file is distributed under GPL version2 and might be compiled by Exerb
1771
1772 SEE ALSO
1773
1774 RELEASE
1775         #{Release}
1776
1777 REVISION
1778         #{Revision}
1779 EOM
1780 end
1781
1782 def log_message(str)
1783   printf("%s message: %s\n", Time::new.to_s, str)
1784 end
1785
1786 def log_warning(str)
1787   printf("%s warning: %s\n", Time::new.to_s, str)
1788 end
1789
1790 def log_error(str)
1791   printf("%s error: %s\n", Time::new.to_s, str)
1792 end
1793
1794
1795 def parse_command_line
1796   options = Hash::new
1797   parser = GetoptLong.new
1798   parser.ordering = GetoptLong::REQUIRE_ORDER
1799   parser.set_options(
1800                      ["--pid-file", GetoptLong::REQUIRED_ARGUMENT])
1801
1802   parser.quiet = true
1803   begin
1804     parser.each_option do |name, arg|
1805       name.sub!(/^--/, '')
1806       options[name] = arg.dup
1807     end
1808   rescue
1809     usage
1810     raise parser.error_message
1811   end
1812   return options
1813 end
1814
1815 def good_game_name?(str)
1816   if ((str =~ /^(.+)-\d+-\d+$/) &&
1817       (good_identifier?($1)))
1818     return true
1819   else
1820     return false
1821   end
1822 end
1823
1824 def good_identifier?(str)
1825   if ( ((str =~ /\A[\w\d_@\-\.]+\z/) || 
1826         (str =~ /\A[\w\d_@\-\.]+,[\w\d_@\-\.]+\z/)) &&
1827       (str.length < Max_Identifier_Length))
1828     return true
1829   else
1830     return false
1831   end
1832 end
1833
1834 def good_login?(str)
1835   tokens = str.split
1836   if (((tokens.length == 3) || ((tokens.length == 4) && tokens[3] == "x1")) &&
1837       (tokens[0] == "LOGIN") &&
1838       (good_identifier?(tokens[1])))
1839     return true
1840   else
1841     return false
1842   end
1843 end
1844
1845 def  write_pid_file(file)
1846   open(file, "w") do |fh|
1847     fh.print Process::pid, "\n"
1848   end
1849 end
1850
1851 def mutex_watchdog(mutex, sec)
1852   while true
1853     begin
1854       timeout(sec) do
1855         begin
1856           mutex.lock
1857         ensure
1858           mutex.unlock
1859         end
1860       end
1861       sleep(sec)
1862     rescue TimeoutError
1863       log_error("mutex watchdog timeout")
1864       exit(1)
1865     end
1866   end
1867 end
1868
1869 def main
1870   $mutex = Mutex::new
1871   Thread::start do
1872     Thread.pass
1873     mutex_watchdog($mutex, 10)
1874   end
1875
1876   $options = parse_command_line
1877   if (ARGV.length != 2)
1878     usage
1879     exit 2
1880   end
1881
1882   LEAGUE.event = ARGV.shift
1883   port = ARGV.shift
1884
1885   write_pid_file($options["pid-file"]) if ($options["pid-file"])
1886
1887   server = TCPserver.open(port)
1888   log_message("server started")
1889
1890   while true
1891     Thread::start(server.accept) do |client|
1892       Thread.pass
1893       client.sync = true
1894       player = nil
1895       while (str = client.gets_timeout(Login_Time))
1896         begin
1897           $mutex.lock
1898           str =~ /([\r\n]*)$/
1899           eol = $1
1900           if (good_login?(str))
1901             player = Player::new(str, client)
1902             if (LEAGUE.players[player.name])
1903               if ((LEAGUE.players[player.name].password == player.password) &&
1904                   (LEAGUE.players[player.name].status != "game"))
1905                 log_message(sprintf("user %s login forcely", player.name))
1906                 LEAGUE.players[player.name].kill
1907               else
1908                 client.write_safe("LOGIN:incorrect" + eol)
1909                 client.write_safe(sprintf("username %s is already connected%s", player.name, eol)) if (str.split.length >= 4)
1910                 client.close
1911                 Thread::exit
1912                 return
1913               end
1914             end
1915             LEAGUE.add(player)
1916             break
1917           else
1918             client.write_safe("LOGIN:incorrect" + eol)
1919             client.write_safe("type 'LOGIN name password' or 'LOGIN name password x1'" + eol) if (str.split.length >= 4)
1920           end
1921         ensure
1922           $mutex.unlock
1923         end
1924       end                       # login loop
1925       if (! player)
1926         client.close
1927         Thread::exit
1928         return
1929       end
1930       log_message(sprintf("user %s login", player.name))
1931       player.run
1932       begin
1933         $mutex.lock
1934         if (player.game)
1935           player.game.kill(player)
1936         end
1937         player.finish # socket has been closed
1938         LEAGUE.delete(player)
1939         log_message(sprintf("user %s logout", player.name))
1940       ensure
1941         $mutex.unlock
1942       end
1943     end
1944   end
1945 end
1946
1947 if ($0 == __FILE__)
1948   LEAGUE = League::new
1949   main
1950 end