OSDN Git Service

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