OSDN Git Service

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