OSDN Git Service

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