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         $mutex.lock
 432
 433         if (@writer_thread == nil || @writer_thread.status == false)
 434           # The writer_thread has been killed because of socket errors.
 435           return
 436         end
 437
 438         if (csa_1st_str)
 439           str = csa_1st_str
 440           csa_1st_str = nil
 441         end
 442         if (@write_queue.size > Max_Write_Queue_Size)
 443           log_warning(sprintf("write_queue of %s is %d", @name, @write_queue.size))
 444                 return
 445         end
 446
 447         if (@status == "finished")
 448           return
 449         end
 450         str.chomp! if (str.class == String) # may be strip! ?
 451         case str
 452         when ""
 453           # Application-level protocol for Keep-Alive
 454           # If the server gets LF, it sends back LF.
 455           # 30 sec rule (client may not send LF again within 30 sec) is not implemented yet.
 456           write_safe("\n")
 457         when /^[\+\-][^%]/
 458           if (@status == "game")
 459             array_str = str.split(",")
 460             move = array_str.shift
 461             additional = array_str.shift
 462             if /^'(.*)/ =~ additional
 463               comment = array_str.unshift("'*#{$1}")
 464             end
 465             s = @game.handle_one_move(move, self)
 466             @game.fh.print("#{comment}\n") if (comment && !s)
 467             return if (s && @protocol == LoginCSA::PROTOCOL)
 468           end
 469         when /^%[^%]/, :timeout
 470           if (@status == "game")
 471             s = @game.handle_one_move(str, self)
 472             return if (s && @protocol == LoginCSA::PROTOCOL)
 473           # else
 474           #   begin
 475           #     @socket.write("##[KEEPALIVE] #{Time.now}\n")
 476           #   rescue Exception => ex
 477           #     log_error("Failed to send a keepalive to #{@name}.")
 478           #     log_error("#{ex.class}: #{ex.message}\n\t#{ex.backtrace[0]}")
 479           #     return
 480           #   end
 481           end
 482         when :exception
 483           log_error("Failed to receive a message from #{@name}.")
 484           return
 485         when /^REJECT/
 486           if (@status == "agree_waiting")
 487             @game.reject(@name)
 488             return if (@protocol == LoginCSA::PROTOCOL)
 489           else
 490             write_safe(sprintf("##[ERROR] you are in %s status. AGREE is valid in agree_waiting status\n", @status))
 491           end
 492         when /^AGREE/
 493           if (@status == "agree_waiting")
 494             @status = "start_waiting"
 495             if ((@game.sente.status == "start_waiting") &&
 496                 (@game.gote.status == "start_waiting"))
 497               @game.start
 498               @game.sente.status = "game"
 499               @game.gote.status = "game"
 500             end
 501           else
 502             write_safe(sprintf("##[ERROR] you are in %s status. AGREE is valid in agree_waiting status\n", @status))
 503           end
 504         when /^%%SHOW\s+(\S+)/
 505           game_id = $1
 506           if (LEAGUE.games[game_id])
 507             write_safe(LEAGUE.games[game_id].show.gsub(/^/, '##[SHOW] '))
 508           end
 509           write_safe("##[SHOW] +OK\n")
 510         when /^%%MONITORON\s+(\S+)/
 511           game_id = $1
 512           if (LEAGUE.games[game_id])
 513             LEAGUE.games[game_id].monitoron(self)
 514             write_safe(LEAGUE.games[game_id].show.gsub(/^/, "##[MONITOR][#{game_id}] "))
 515             write_safe("##[MONITOR][#{game_id}] +OK\n")
 516           end
 517         when /^%%MONITOROFF\s+(\S+)/
 518           game_id = $1
 519           if (LEAGUE.games[game_id])
 520             LEAGUE.games[game_id].monitoroff(self)
 521           end
 522         when /^%%HELP/
 523           write_safe(
 524             %!##[HELP] available commands "%%WHO", "%%CHAT str", "%%GAME game_name +", "%%GAME game_name -"\n!)
 525         when /^%%RATING/
 526           players = LEAGUE.rated_players
 527           players.sort {|a,b| b.rate <=> a.rate}.each do |p|
 528             write_safe("##[RATING] %s \t %4d @%s\n" %
 529                        [p.simple_id, p.rate, p.modified_at.strftime("%Y-%m-%d")])
 530           end
 531           write_safe("##[RATING] +OK\n")
 532         when /^%%VERSION/
 533           write_safe "##[VERSION] Shogi Server revision #{Revision}\n"
 534           write_safe("##[VERSION] +OK\n")
 535         when /^%%GAME\s*$/
 536           if ((@status == "connected") || (@status == "game_waiting"))
 537             @status = "connected"
 538             @game_name = ""
 539           else
 540             write_safe(sprintf("##[ERROR] you are in %s status. GAME is valid in connected or game_waiting status\n", @status))
 541           end
 542         when /^%%(GAME|CHALLENGE)\s+(\S+)\s+([\+\-\*])\s*$/
 543           command_name = $1
 544           game_name = $2
 545           my_sente_str = $3
 546           if (! Login::good_game_name?(game_name))
 547             write_safe(sprintf("##[ERROR] bad game name\n"))
 548             next
 549           elsif ((@status == "connected") || (@status == "game_waiting"))
 550             ## continue
 551           else
 552             write_safe(sprintf("##[ERROR] you are in %s status. GAME is valid in connected or game_waiting status\n", @status))
 553             next
 554           end
 555           if ((my_sente_str == "*") ||
 556               (my_sente_str == "+") ||
 557               (my_sente_str == "-"))
 558             ## ok
 559           else
 560             write_safe(sprintf("##[ERROR] bad game option\n"))
 561             next
 562           end
 563
 564           if (my_sente_str == "*")
 565             rival = LEAGUE.get_player("game_waiting", game_name, nil, self) # no preference
 566           elsif (my_sente_str == "+")
 567             rival = LEAGUE.get_player("game_waiting", game_name, false, self) # rival must be gote
 568           elsif (my_sente_str == "-")
 569             rival = LEAGUE.get_player("game_waiting", game_name, true, self) # rival must be sente
 570           else
 571             ## never reached
 572           end
 573           if (rival)
 574             @game_name = game_name
 575             if ((my_sente_str == "*") && (rival.sente == nil))
 576               if (rand(2) == 0)
 577                 @sente = true
 578                 rival.sente = false
 579               else
 580                 @sente = false
 581                 rival.sente = true
 582               end
 583             elsif (rival.sente == true) # rival has higher priority
 584               @sente = false
 585             elsif (rival.sente == false)
 586               @sente = true
 587             elsif (my_sente_str == "+")
 588               @sente = true
 589               rival.sente = false
 590             elsif (my_sente_str == "-")
 591               @sente = false
 592               rival.sente = true
 593             else
 594               ## never reached
 595             end
 596             Game::new(@game_name, self, rival)
 597             self.status = "agree_waiting"
 598             rival.status = "agree_waiting"
 599           else # rival not found
 600             if (command_name == "GAME")
 601               @status = "game_waiting"
 602               @game_name = game_name
 603               if (my_sente_str == "+")
 604                 @sente = true
 605               elsif (my_sente_str == "-")
 606                 @sente = false
 607               else
 608                 @sente = nil
 609               end
 610             else                # challenge
 611               write_safe(sprintf("##[ERROR] can't find rival for %s\n", game_name))
 612               @status = "connected"
 613               @game_name = ""
 614               @sente = nil
 615             end
 616           end
 617         when /^%%CHAT\s+(.+)/
 618           message = $1
 619           LEAGUE.players.each do |name, player|
 620             if (player.protocol != LoginCSA::PROTOCOL)
 621               player.write_safe(sprintf("##[CHAT][%s] %s\n", @name, message))
 622             end
 623           end
 624         when /^%%LIST/
 625           buf = Array::new
 626           LEAGUE.games.each do |id, game|
 627             buf.push(sprintf("##[LIST] %s\n", id))
 628           end
 629           buf.push("##[LIST] +OK\n")
 630           write_safe(buf.join)
 631         when /^%%WHO/
 632           buf = Array::new
 633           LEAGUE.players.each do |name, player|
 634             buf.push(sprintf("##[WHO] %s\n", player.to_s))
 635           end
 636           buf.push("##[WHO] +OK\n")
 637           write_safe(buf.join)
 638         when /^LOGOUT/
 639           @status = "connected"
 640           write_safe("LOGOUT:completed\n")
 641           return
 642         when /^CHALLENGE/
 643           # This command is only available for CSA's official testing server.
 644           # So, this means nothing for this program.
 645           write_safe("CHALLENGE ACCEPTED\n")
 646         when /^\s*$/
 647           ## ignore null string
 648         else
 649           msg = "##[ERROR] unknown command %s\n" % [str]
 650           write_safe(msg)
 651           log_error(msg)
 652         end
 653       ensure
 654         $mutex.unlock
 655       end
 656     end                         # enf of while
 657   end
 658 end
 659
 660 class Piece
 661   PROMOTE = {"FU" => "TO", "KY" => "NY", "KE" => "NK", "GI" => "NG", "KA" => "UM", "HI" => "RY"}
 662   def initialize(board, x, y, sente, promoted=false)
 663     @board = board
 664     @x = x
 665     @y = y
 666     @sente = sente
 667     @promoted = promoted
 668
 669     if ((x == 0) || (y == 0))
 670       if (sente)
 671         hands = board.sente_hands
 672       else
 673         hands = board.gote_hands
 674       end
 675       hands.push(self)
 676       hands.sort! {|a, b|
 677         a.name <=> b.name
 678       }
 679     else
 680       @board.array[x][y] = self
 681     end
 682   end
 683   attr_accessor :promoted, :sente, :x, :y, :board
 684
 685   def room_of_head?(x, y, name)
 686     true
 687   end
 688
 689   def movable_grids
 690     return adjacent_movable_grids + far_movable_grids
 691   end
 692
 693   def far_movable_grids
 694     return []
 695   end
 696
 697   def jump_to?(x, y)
 698     if ((1 <= x) && (x <= 9) && (1 <= y) && (y <= 9))
 699       if ((@board.array[x][y] == nil) || # dst is empty
 700           (@board.array[x][y].sente != @sente)) # dst is enemy
 701         return true
 702       end
 703     end
 704     return false
 705   end
 706
 707   def put_to?(x, y)
 708     if ((1 <= x) && (x <= 9) && (1 <= y) && (y <= 9))
 709       if (@board.array[x][y] == nil) # dst is empty?
 710         return true
 711       end
 712     end
 713     return false
 714   end
 715
 716   def adjacent_movable_grids
 717     grids = Array::new
 718     if (@promoted)
 719       moves = @promoted_moves
 720     else
 721       moves = @normal_moves
 722     end
 723     moves.each do |(dx, dy)|
 724       if (@sente)
 725         cand_y = @y - dy
 726       else
 727         cand_y = @y + dy
 728       end
 729       cand_x = @x + dx
 730       if (jump_to?(cand_x, cand_y))
 731         grids.push([cand_x, cand_y])
 732       end
 733     end
 734     return grids
 735   end
 736
 737   def move_to?(x, y, name)
 738     return false if (! room_of_head?(x, y, name))
 739     return false if ((name != @name) && (name != @promoted_name))
 740     return false if (@promoted && (name != @promoted_name)) # can't un-promote
 741
 742     if (! @promoted)
 743       return false if (((@x == 0) || (@y == 0)) && (name != @name)) # can't put promoted piece
 744       if (@sente)
 745         return false if ((4 <= @y) && (4 <= y) && (name != @name)) # can't promote
 746       else
 747         return false if ((6 >= @y) && (6 >= y) && (name != @name))
 748       end
 749     end
 750
 751     if ((@x == 0) || (@y == 0))
 752       return jump_to?(x, y)
 753     else
 754       return movable_grids.include?([x, y])
 755     end
 756   end
 757
 758   def move_to(x, y)
 759     if ((@x == 0) || (@y == 0))
 760       if (@sente)
 761         @board.sente_hands.delete(self)
 762       else
 763         @board.gote_hands.delete(self)
 764       end
 765       @board.array[x][y] = self
 766     elsif ((x == 0) || (y == 0))
 767       @promoted = false         # clear promoted flag before moving to hands
 768       if (@sente)
 769         @board.sente_hands.push(self)
 770       else
 771         @board.gote_hands.push(self)
 772       end
 773       @board.array[@x][@y] = nil
 774     else
 775       @board.array[@x][@y] = nil
 776       @board.array[x][y] = self
 777     end
 778     @x = x
 779     @y = y
 780   end
 781
 782   def point
 783     @point
 784   end
 785
 786   def name
 787     @name
 788   end
 789
 790   def promoted_name
 791     @promoted_name
 792   end
 793
 794   def to_s
 795     if (@sente)
 796       sg = "+"
 797     else
 798       sg = "-"
 799     end
 800     if (@promoted)
 801       n = @promoted_name
 802     else
 803       n = @name
 804     end
 805     return sg + n
 806   end
 807 end
 808
 809 class PieceFU < Piece
 810   def initialize(*arg)
 811     @point = 1
 812     @normal_moves = [[0, +1]]
 813     @promoted_moves = [[0, +1], [+1, +1], [-1, +1], [+1, +0], [-1, +0], [0, -1]]
 814     @name = "FU"
 815     @promoted_name = "TO"
 816     super
 817   end
 818   def room_of_head?(x, y, name)
 819     if (name == "FU")
 820       if (@sente)
 821         return false if (y == 1)
 822       else
 823         return false if (y == 9)
 824       end
 825       ## 2fu check
 826       c = 0
 827       iy = 1
 828       while (iy <= 9)
 829         if ((iy  != @y) &&      # not source position
 830             @board.array[x][iy] &&
 831             (@board.array[x][iy].sente == @sente) && # mine
 832             (@board.array[x][iy].name == "FU") &&
 833             (@board.array[x][iy].promoted == false))
 834           return false
 835         end
 836         iy = iy + 1
 837       end
 838     end
 839     return true
 840   end
 841 end
 842
 843 class PieceKY  < Piece
 844   def initialize(*arg)
 845     @point = 1
 846     @normal_moves = []
 847     @promoted_moves = [[0, +1], [+1, +1], [-1, +1], [+1, +0], [-1, +0], [0, -1]]
 848     @name = "KY"
 849     @promoted_name = "NY"
 850     super
 851   end
 852   def room_of_head?(x, y, name)
 853     if (name == "KY")
 854       if (@sente)
 855         return false if (y == 1)
 856       else
 857         return false if (y == 9)
 858       end
 859     end
 860     return true
 861   end
 862   def far_movable_grids
 863     grids = Array::new
 864     if (@promoted)
 865       return []
 866     else
 867       if (@sente)                 # up
 868         cand_x = @x
 869         cand_y = @y - 1
 870         while (jump_to?(cand_x, cand_y))
 871           grids.push([cand_x, cand_y])
 872           break if (! put_to?(cand_x, cand_y))
 873           cand_y = cand_y - 1
 874         end
 875       else                        # down
 876         cand_x = @x
 877         cand_y = @y + 1
 878         while (jump_to?(cand_x, cand_y))
 879           grids.push([cand_x, cand_y])
 880           break if (! put_to?(cand_x, cand_y))
 881           cand_y = cand_y + 1
 882         end
 883       end
 884       return grids
 885     end
 886   end
 887 end
 888 class PieceKE  < Piece
 889   def initialize(*arg)
 890     @point = 1
 891     @normal_moves = [[+1, +2], [-1, +2]]
 892     @promoted_moves = [[0, +1], [+1, +1], [-1, +1], [+1, +0], [-1, +0], [0, -1]]
 893     @name = "KE"
 894     @promoted_name = "NK"
 895     super
 896   end
 897   def room_of_head?(x, y, name)
 898     if (name == "KE")
 899       if (@sente)
 900         return false if ((y == 1) || (y == 2))
 901       else
 902         return false if ((y == 9) || (y == 8))
 903       end
 904     end
 905     return true
 906   end
 907 end
 908 class PieceGI  < Piece
 909   def initialize(*arg)
 910     @point = 1
 911     @normal_moves = [[0, +1], [+1, +1], [-1, +1], [+1, -1], [-1, -1]]
 912     @promoted_moves = [[0, +1], [+1, +1], [-1, +1], [+1, +0], [-1, +0], [0, -1]]
 913     @name = "GI"
 914     @promoted_name = "NG"
 915     super
 916   end
 917 end
 918 class PieceKI  < Piece
 919   def initialize(*arg)
 920     @point = 1
 921     @normal_moves = [[0, +1], [+1, +1], [-1, +1], [+1, +0], [-1, +0], [0, -1]]
 922     @promoted_moves = []
 923     @name = "KI"
 924     @promoted_name = nil
 925     super
 926   end
 927 end
 928 class PieceKA  < Piece
 929   def initialize(*arg)
 930     @point = 5
 931     @normal_moves = []
 932     @promoted_moves = [[0, +1], [+1, 0], [-1, 0], [0, -1]]
 933     @name = "KA"
 934     @promoted_name = "UM"
 935     super
 936   end
 937   def far_movable_grids
 938     grids = Array::new
 939     ## up right
 940     cand_x = @x - 1
 941     cand_y = @y - 1
 942     while (jump_to?(cand_x, cand_y))
 943       grids.push([cand_x, cand_y])
 944       break if (! put_to?(cand_x, cand_y))
 945       cand_x = cand_x - 1
 946       cand_y = cand_y - 1
 947     end
 948     ## down right
 949     cand_x = @x - 1
 950     cand_y = @y + 1
 951     while (jump_to?(cand_x, cand_y))
 952       grids.push([cand_x, cand_y])
 953       break if (! put_to?(cand_x, cand_y))
 954       cand_x = cand_x - 1
 955       cand_y = cand_y + 1
 956     end
 957     ## up left
 958     cand_x = @x + 1
 959     cand_y = @y - 1
 960     while (jump_to?(cand_x, cand_y))
 961       grids.push([cand_x, cand_y])
 962       break if (! put_to?(cand_x, cand_y))
 963       cand_x = cand_x + 1
 964       cand_y = cand_y - 1
 965     end
 966     ## down left
 967     cand_x = @x + 1
 968     cand_y = @y + 1
 969     while (jump_to?(cand_x, cand_y))
 970       grids.push([cand_x, cand_y])
 971       break if (! put_to?(cand_x, cand_y))
 972       cand_x = cand_x + 1
 973       cand_y = cand_y + 1
 974     end
 975     return grids
 976   end
 977 end
 978 class PieceHI  < Piece
 979   def initialize(*arg)
 980     @point = 5
 981     @normal_moves = []
 982     @promoted_moves = [[+1, +1], [-1, +1], [+1, -1], [-1, -1]]
 983     @name = "HI"
 984     @promoted_name = "RY"
 985     super
 986   end
 987   def far_movable_grids
 988     grids = Array::new
 989     ## up
 990     cand_x = @x
 991     cand_y = @y - 1
 992     while (jump_to?(cand_x, cand_y))
 993       grids.push([cand_x, cand_y])
 994       break if (! put_to?(cand_x, cand_y))
 995       cand_y = cand_y - 1
 996     end
 997     ## down
 998     cand_x = @x
 999     cand_y = @y + 1
1000     while (jump_to?(cand_x, cand_y))
1001       grids.push([cand_x, cand_y])
1002       break if (! put_to?(cand_x, cand_y))
1003       cand_y = cand_y + 1
1004     end
1005     ## right
1006     cand_x = @x - 1
1007     cand_y = @y
1008     while (jump_to?(cand_x, cand_y))
1009       grids.push([cand_x, cand_y])
1010       break if (! put_to?(cand_x, cand_y))
1011       cand_x = cand_x - 1
1012     end
1013     ## down
1014     cand_x = @x + 1
1015     cand_y = @y
1016     while (jump_to?(cand_x, cand_y))
1017       grids.push([cand_x, cand_y])
1018       break if (! put_to?(cand_x, cand_y))
1019       cand_x = cand_x + 1
1020     end
1021     return grids
1022   end
1023 end
1024 class PieceOU < Piece
1025   def initialize(*arg)
1026     @point = 0
1027     @normal_moves = [[0, +1], [+1, +1], [-1, +1], [+1, +0], [-1, +0], [0, -1], [+1, -1], [-1, -1]]
1028     @promoted_moves = []
1029     @name = "OU"
1030     @promoted_name = nil
1031     super
1032   end
1033 end
1034
1035 class Board
1036   def initialize
1037     @sente_hands = Array::new
1038     @gote_hands = Array::new
1039     @history = Hash::new
1040     @sente_history = Hash::new
1041     @gote_history = Hash::new
1042     @array = [[], [], [], [], [], [], [], [], [], []]
1043     @move_count = 0
1044   end
1045   attr_accessor :array, :sente_hands, :gote_hands, :history, :sente_history, :gote_history
1046   attr_reader :move_count
1047
1048   def initial
1049     PieceKY::new(self, 1, 1, false)
1050     PieceKE::new(self, 2, 1, false)
1051     PieceGI::new(self, 3, 1, false)
1052     PieceKI::new(self, 4, 1, false)
1053     PieceOU::new(self, 5, 1, false)
1054     PieceKI::new(self, 6, 1, false)
1055     PieceGI::new(self, 7, 1, false)
1056     PieceKE::new(self, 8, 1, false)
1057     PieceKY::new(self, 9, 1, false)
1058     PieceKA::new(self, 2, 2, false)
1059     PieceHI::new(self, 8, 2, false)
1060     (1..9).each do |i|
1061       PieceFU::new(self, i, 3, false)
1062     end
1063
1064     PieceKY::new(self, 1, 9, true)
1065     PieceKE::new(self, 2, 9, true)
1066     PieceGI::new(self, 3, 9, true)
1067     PieceKI::new(self, 4, 9, true)
1068     PieceOU::new(self, 5, 9, true)
1069     PieceKI::new(self, 6, 9, true)
1070     PieceGI::new(self, 7, 9, true)
1071     PieceKE::new(self, 8, 9, true)
1072     PieceKY::new(self, 9, 9, true)
1073     PieceKA::new(self, 8, 8, true)
1074     PieceHI::new(self, 2, 8, true)
1075     (1..9).each do |i|
1076       PieceFU::new(self, i, 7, true)
1077     end
1078   end
1079
1080   def have_piece?(hands, name)
1081     piece = hands.find { |i|
1082       i.name == name
1083     }
1084     return piece
1085   end
1086
1087   def move_to(x0, y0, x1, y1, name, sente)
1088     if (sente)
1089       hands = @sente_hands
1090     else
1091       hands = @gote_hands
1092     end
1093
1094     if ((x0 == 0) || (y0 == 0))
1095       piece = have_piece?(hands, name)
1096       return :illegal if (! piece.move_to?(x1, y1, name)) # TODO null check for the piece?
1097       piece.move_to(x1, y1)
1098     else
1099       return :illegal if (! @array[x0][y0].move_to?(x1, y1, name))  # TODO null check?
1100       if (@array[x0][y0].name != name) # promoted ?
1101         @array[x0][y0].promoted = true
1102       end
1103       if (@array[x1][y1]) # capture
1104         if (@array[x1][y1].name == "OU")
1105           return :outori        # return board update
1106         end
1107         @array[x1][y1].sente = @array[x0][y0].sente
1108         @array[x1][y1].move_to(0, 0)
1109         hands.sort! {|a, b| # TODO refactor. Move to Piece class
1110           a.name <=> b.name
1111         }
1112       end
1113       @array[x0][y0].move_to(x1, y1)
1114     end
1115     @move_count += 1
1116     return true
1117   end
1118
1119   def look_for_ou(sente)
1120     x = 1
1121     while (x <= 9)
1122       y = 1
1123       while (y <= 9)
1124         if (@array[x][y] &&
1125             (@array[x][y].name == "OU") &&
1126             (@array[x][y].sente == sente))
1127           return @array[x][y]
1128         end
1129         y = y + 1
1130       end
1131       x = x + 1
1132     end
1133     raise "can't find ou"
1134   end
1135
1136   # note checkmate, but check. sente is checked.
1137   def checkmated?(sente)        # sente is loosing
1138     ou = look_for_ou(sente)
1139     x = 1
1140     while (x <= 9)
1141       y = 1
1142       while (y <= 9)
1143         if (@array[x][y] &&
1144             (@array[x][y].sente != sente))
1145           if (@array[x][y].movable_grids.include?([ou.x, ou.y]))
1146             return true
1147           end
1148         end
1149         y = y + 1
1150       end
1151       x = x + 1
1152     end
1153     return false
1154   end
1155
1156   def uchifuzume?(sente)
1157     rival_ou = look_for_ou(! sente)   # rival's ou
1158     if (sente)                  # rival is gote
1159       if ((rival_ou.y != 9) &&
1160           (@array[rival_ou.x][rival_ou.y + 1]) &&
1161           (@array[rival_ou.x][rival_ou.y + 1].name == "FU") &&
1162           (@array[rival_ou.x][rival_ou.y + 1].sente == sente)) # uchifu true
1163         fu_x = rival_ou.x
1164         fu_y = rival_ou.y + 1
1165       else
1166         return false
1167       end
1168     else                        # gote
1169       if ((rival_ou.y != 0) &&
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     end
1179
1180     ## case: rival_ou is moving
1181     escaped = false
1182     rival_ou.movable_grids.each do |(cand_x, cand_y)|
1183       tmp_board = Marshal.load(Marshal.dump(self))
1184       s = tmp_board.move_to(rival_ou.x, rival_ou.y, cand_x, cand_y, "OU", ! sente)
1185       raise "internal error" if (s != true)
1186       if (! tmp_board.checkmated?(! sente)) # good move
1187         return false
1188       end
1189     end
1190
1191     ## case: rival is capturing fu
1192     x = 1
1193     while (x <= 9)
1194       y = 1
1195       while (y <= 9)
1196         if (@array[x][y] &&
1197             (@array[x][y].sente != sente) &&
1198             @array[x][y].movable_grids.include?([fu_x, fu_y])) # capturable
1199           if (@array[x][y].promoted)
1200             name = @array[x][y].promoted_name
1201           else
1202             name = @array[x][y].name
1203           end
1204           tmp_board = Marshal.load(Marshal.dump(self))
1205           s = tmp_board.move_to(x, y, fu_x, fu_y, name, ! sente)
1206           raise "internal error" if (s != true)
1207           if (! tmp_board.checkmated?(! sente)) # good move
1208             return false
1209           end
1210         end
1211         y = y + 1
1212       end
1213       x = x + 1
1214     end
1215     return true
1216   end
1217
1218   def oute_sennichite?(sente)
1219     if (checkmated?(! sente))
1220       str = to_s
1221       if (sente)
1222         if (@sente_history[str] && (@sente_history[str] >= 3)) # already 3 times
1223           return true
1224         end
1225       else
1226         if (@gote_history[str] && (@gote_history[str] >= 3)) # already 3 times
1227           return true
1228         end
1229       end
1230     end
1231     return false
1232   end
1233
1234   def sennichite?(sente)
1235     str = to_s
1236     if (@history[str] && (@history[str] >= 3)) # already 3 times
1237       return true
1238     end
1239     return false
1240   end
1241
1242   def good_kachi?(sente)
1243     if (checkmated?(sente))
1244       puts "'NG: Checkmating." if $DEBUG
1245       return false
1246     end
1247
1248     ou = look_for_ou(sente)
1249     if (sente && (ou.y >= 4))
1250       puts "'NG: Black's OU does not enter yet." if $DEBUG
1251       return false
1252     end
1253     if (! sente && (ou.y <= 6))
1254       puts "'NG: White's OU does not enter yet." if $DEBUG
1255       return false
1256     end
1257
1258     number = 0
1259     point = 0
1260
1261     if (sente)
1262       hands = @sente_hands
1263       r = [1, 2, 3]
1264     else
1265       hands = @gote_hands
1266       r = [7, 8, 9]
1267     end
1268     r.each do |y|
1269       x = 1
1270       while (x <= 9)
1271         if (@array[x][y] &&
1272             (@array[x][y].sente == sente) &&
1273             (@array[x][y].point > 0))
1274           point = point + @array[x][y].point
1275           number = number + 1
1276         end
1277         x = x + 1
1278       end
1279     end
1280     hands.each do |piece|
1281       point = point + piece.point
1282     end
1283
1284     if (number < 10)
1285       puts "'NG: Piece#[%d] is too small." % [number] if $DEBUG
1286       return false
1287     end
1288     if (sente)
1289       if (point < 28)
1290         puts "'NG: Black's point#[%d] is too small." % [point] if $DEBUG
1291         return false
1292       end
1293     else
1294       if (point < 27)
1295         puts "'NG: White's point#[%d] is too small." % [point] if $DEBUG
1296         return false
1297       end
1298     end
1299
1300     puts "'Good: Piece#[%d], Point[%d]." % [number, point] if $DEBUG
1301     return true
1302   end
1303
1304   # sente is nil only if tests in test_board run
1305   def handle_one_move(str, sente=nil)
1306     if (str =~ /^([\+\-])(\d)(\d)(\d)(\d)([A-Z]{2})/)
1307       sg = $1
1308       x0 = $2.to_i
1309       y0 = $3.to_i
1310       x1 = $4.to_i
1311       y1 = $5.to_i
1312       name = $6
1313     elsif (str =~ /^%KACHI/)
1314       raise ArgumentError, "sente is null", caller if sente == nil
1315       if (good_kachi?(sente))
1316         return :kachi_win
1317       else
1318         return :kachi_lose
1319       end
1320     elsif (str =~ /^%TORYO/)
1321       return :toryo
1322     else
1323       return :illegal
1324     end
1325
1326     if (((x0 == 0) || (y0 == 0)) && # source is not from hand
1327         ((x0 != 0) || (y0 != 0)))
1328       return :illegal
1329     elsif ((x1 == 0) || (y1 == 0)) # destination is out of board
1330       return :illegal
1331     end
1332
1333
1334     if (sg == "+")
1335       sente = true if sente == nil           # deprecated
1336       return :illegal unless sente == true   # black player's move must be black
1337       hands = @sente_hands
1338     else
1339       sente = false if sente == nil          # deprecated
1340       return :illegal unless sente == false  # white player's move must be white
1341       hands = @gote_hands
1342     end
1343
1344     ## source check
1345     if ((x0 == 0) && (y0 == 0))
1346       return :illegal if (! have_piece?(hands, name))
1347     elsif (! @array[x0][y0])
1348       return :illegal           # no piece
1349     elsif (@array[x0][y0].sente != sente)
1350       return :illegal           # this is not mine
1351     elsif (@array[x0][y0].name != name)
1352       return :illegal if (@array[x0][y0].promoted_name != name) # can't promote
1353     end
1354
1355     ## destination check
1356     if (@array[x1][y1] &&
1357         (@array[x1][y1].sente == sente)) # can't capture mine
1358       return :illegal
1359     elsif ((x0 == 0) && (y0 == 0) && @array[x1][y1])
1360       return :illegal           # can't put on existing piece
1361     end
1362
1363     tmp_board = Marshal.load(Marshal.dump(self))
1364     return :illegal if (tmp_board.move_to(x0, y0, x1, y1, name, sente) == :illegal)
1365     return :oute_kaihimore if (tmp_board.checkmated?(sente))
1366     return :oute_sennichite if tmp_board.oute_sennichite?(sente)
1367     return :sennichite if tmp_board.sennichite?(sente)
1368
1369     if ((x0 == 0) && (y0 == 0) && (name == "FU") && tmp_board.uchifuzume?(sente))
1370       return :uchifuzume
1371     end
1372
1373     move_to(x0, y0, x1, y1, name, sente)
1374     str = to_s
1375
1376     if (checkmated?(! sente))
1377       if (sente)
1378         @sente_history[str] = (@sente_history[str] || 0) + 1
1379       else
1380         @gote_history[str] = (@gote_history[str] || 0) + 1
1381       end
1382     else
1383       if (sente)
1384         @sente_history.clear
1385       else
1386         @gote_history.clear
1387       end
1388     end
1389     @history[str] = (@history[str] || 0) + 1
1390     return :normal
1391   end
1392
1393   def to_s
1394     a = Array::new
1395     y = 1
1396     while (y <= 9)
1397       a.push(sprintf("P%d", y))
1398       x = 9
1399       while (x >= 1)
1400         piece = @array[x][y]
1401         if (piece)
1402           s = piece.to_s
1403         else
1404           s = " * "
1405         end
1406         a.push(s)
1407         x = x - 1
1408       end
1409       a.push(sprintf("\n"))
1410       y = y + 1
1411     end
1412     if (! sente_hands.empty?)
1413       a.push("P+")
1414       sente_hands.each do |p|
1415         a.push("00" + p.name)
1416       end
1417       a.push("\n")
1418     end
1419     if (! gote_hands.empty?)
1420       a.push("P-")
1421       gote_hands.each do |p|
1422         a.push("00" + p.name)
1423       end
1424       a.push("\n")
1425     end
1426     a.push("+\n")
1427     return a.join
1428   end
1429 end
1430
1431 class GameResult
1432   attr_reader :players, :black, :white
1433
1434   def initialize(p1, p2)
1435     @players = []
1436     @players << p1
1437     @players << p2
1438     if p1.sente && !p2.sente
1439       @black, @white = p1, p2
1440     elsif !p1.sente && p2.sente
1441       @black, @white = p2, p1
1442     else
1443       raise "Never reached!"
1444     end
1445   end
1446 end
1447
1448 class GameResultWin < GameResult
1449   attr_reader :winner, :loser
1450
1451   def initialize(winner, loser)
1452     super
1453     @winner, @loser = winner, loser
1454   end
1455
1456   def to_s
1457     black_name = @black.id || @black.name
1458     white_name = @white.id || @white.name
1459     "%s:%s" % [black_name, white_name]
1460   end
1461 end
1462
1463 class GameResultDraw < GameResult
1464
1465 end
1466
1467 class Game
1468   @@mutex = Mutex.new
1469   @@time  = 0
1470
1471   def initialize(game_name, player0, player1)
1472     @monitors = Array::new
1473     @game_name = game_name
1474     if (@game_name =~ /-(\d+)-(\d+)$/)
1475       @total_time = $1.to_i
1476       @byoyomi = $2.to_i
1477     end
1478
1479     if (player0.sente)
1480       @sente = player0
1481       @gote = player1
1482     else
1483       @sente = player1
1484       @gote = player0
1485     end
1486     @current_player = @sente
1487     @next_player = @gote
1488
1489     @sente.game = self
1490     @gote.game = self
1491
1492     @last_move = ""
1493     @current_turn = 0
1494
1495     @sente.status = "agree_waiting"
1496     @gote.status = "agree_waiting"
1497
1498     @id = sprintf("%s+%s+%s+%s+%s",
1499                   LEAGUE.event, @game_name, @sente.name, @gote.name, issue_current_time)
1500     @logfile = File.join(LEAGUE.dir, @id + ".csa")
1501
1502     LEAGUE.games[@id] = self
1503
1504     log_message(sprintf("game created %s", @id))
1505
1506     @board = Board::new
1507     @board.initial
1508     @start_time = nil
1509     @fh = nil
1510     @result = nil
1511
1512     propose
1513   end
1514   attr_accessor :game_name, :total_time, :byoyomi, :sente, :gote, :id, :board, :current_player, :next_player, :fh, :monitors
1515   attr_accessor :last_move, :current_turn
1516   attr_reader   :result
1517
1518   def rated?
1519     @sente.rated? && @gote.rated?
1520   end
1521
1522   def monitoron(monitor)
1523     @monitors.delete(monitor)
1524     @monitors.push(monitor)
1525   end
1526
1527   def monitoroff(monitor)
1528     @monitors.delete(monitor)
1529   end
1530
1531   def reject(rejector)
1532     @sente.write_safe(sprintf("REJECT:%s by %s\n", @id, rejector))
1533     @gote.write_safe(sprintf("REJECT:%s by %s\n", @id, rejector))
1534     finish
1535   end
1536
1537   def kill(killer)
1538     if ((@sente.status == "agree_waiting") || (@sente.status == "start_waiting"))
1539       reject(killer.name)
1540     elsif (@current_player == killer)
1541       abnormal_lose()
1542       finish
1543     end
1544   end
1545
1546   def finish
1547     log_message(sprintf("game finished %s", @id))
1548     @fh.printf("'$END_TIME:%s\n", Time::new.strftime("%Y/%m/%d %H:%M:%S"))
1549     @fh.close
1550
1551     @sente.game = nil
1552     @gote.game = nil
1553     @sente.status = "connected"
1554     @gote.status = "connected"
1555
1556     if (@current_player.protocol == LoginCSA::PROTOCOL)
1557       @current_player.finish
1558     end
1559     if (@next_player.protocol == LoginCSA::PROTOCOL)
1560       @next_player.finish
1561     end
1562     @monitors = Array::new
1563     @sente = nil
1564     @gote = nil
1565     @current_player = nil
1566     @next_player = nil
1567     LEAGUE.games.delete(@id)
1568   end
1569
1570   def handle_one_move(str, player)
1571     finish_flag = true
1572     if (@current_player == player)
1573       @end_time = Time::new
1574       t = (@end_time - @start_time).floor
1575       t = Least_Time_Per_Move if (t < Least_Time_Per_Move)
1576
1577       move_status = nil
1578       if ((@current_player.mytime - t <= -@byoyomi) && ((@total_time > 0) || (@byoyomi > 0)))
1579         status = :timeout
1580       elsif (str == :timeout)
1581         return false            # time isn't expired. players aren't swapped. continue game
1582       else
1583         @current_player.mytime = @current_player.mytime - t
1584         if (@current_player.mytime < 0)
1585           @current_player.mytime = 0
1586         end
1587
1588 #        begin
1589           move_status = @board.handle_one_move(str, @sente == @current_player)
1590 #        rescue
1591 #          log_error("handle_one_move raise exception for #{str}")
1592 #          move_status = :illegal
1593 #        end
1594
1595         if ((move_status == :illegal) || (move_status == :uchifuzme) || (move_status == :oute_kaihimore))
1596           @fh.printf("'ILLEGAL_MOVE(%s)\n", str)
1597         else
1598           if ((move_status == :normal) || (move_status == :outori) || (move_status == :sennichite) || (move_status == :oute_sennichite))
1599             @sente.write_safe(sprintf("%s,T%d\n", str, t))
1600             @gote.write_safe(sprintf("%s,T%d\n", str, t))
1601             @fh.printf("%s\nT%d\n", str, t)
1602             @last_move = sprintf("%s,T%d", str, t)
1603             @current_turn = @current_turn + 1
1604           end
1605
1606           @monitors.each do |monitor|
1607             monitor.write_safe(show.gsub(/^/, "##[MONITOR][#{@id}] "))
1608             monitor.write_safe(sprintf("##[MONITOR][%s] +OK\n", @id))
1609           end
1610         end
1611       end
1612
1613       if (@next_player.status != "game") # rival is logout or disconnected
1614         abnormal_win()
1615       elsif (status == :timeout)
1616         timeout_lose()
1617       elsif (move_status == :illegal)
1618         illegal_lose()
1619       elsif (move_status == :kachi_win)
1620         kachi_win()
1621       elsif (move_status == :kachi_lose)
1622         kachi_lose()
1623       elsif (move_status == :toryo)
1624         toryo_lose()
1625       elsif (move_status == :outori)
1626         outori_win()
1627       elsif (move_status == :sennichite)
1628         sennichite_draw()
1629       elsif (move_status == :oute_sennichite)
1630         oute_sennichite_lose()
1631       elsif (move_status == :uchifuzume)
1632         uchifuzume_lose()
1633       elsif (move_status == :oute_kaihimore)
1634         oute_kaihimore_lose()
1635       else
1636         finish_flag = false
1637       end
1638       finish() if finish_flag
1639       (@current_player, @next_player) = [@next_player, @current_player]
1640       @start_time = Time::new
1641       return finish_flag
1642     end
1643   end
1644
1645   def abnormal_win
1646     @current_player.status = "connected"
1647     @next_player.status = "connected"
1648     @current_player.write_safe("%TORYO\n#RESIGN\n#WIN\n")
1649     @next_player.write_safe("%TORYO\n#RESIGN\n#LOSE\n")
1650     @fh.printf("%%TORYO\n")
1651     @fh.print(@board.to_s.gsub(/^/, "\'"))
1652     @fh.printf("'summary:abnormal:%s win:%s lose\n", @current_player.name, @next_player.name)
1653     @result = GameResultWin.new(@current_player, @next_player)
1654     @fh.printf("'rating:#{@result.to_s}\n") if rated?
1655     @monitors.each do |monitor|
1656       monitor.write_safe(sprintf("##[MONITOR][%s] %%TORYO\n", @id))
1657     end
1658   end
1659
1660   def abnormal_lose
1661     @current_player.status = "connected"
1662     @next_player.status = "connected"
1663     @current_player.write_safe("%TORYO\n#RESIGN\n#LOSE\n")
1664     @next_player.write_safe("%TORYO\n#RESIGN\n#WIN\n")
1665     @fh.printf("%%TORYO\n")
1666     @fh.print(@board.to_s.gsub(/^/, "\'"))
1667     @fh.printf("'summary:abnormal:%s lose:%s win\n", @current_player.name, @next_player.name)
1668     @result = GameResultWin.new(@next_player, @current_player)
1669     @fh.printf("'rating:#{@result.to_s}\n") if rated?
1670     @monitors.each do |monitor|
1671       monitor.write_safe(sprintf("##[MONITOR][%s] %%TORYO\n", @id))
1672     end
1673   end
1674
1675   def sennichite_draw
1676     @current_player.status = "connected"
1677     @next_player.status = "connected"
1678     @current_player.write_safe("#SENNICHITE\n#DRAW\n")
1679     @next_player.write_safe("#SENNICHITE\n#DRAW\n")
1680     @fh.print(@board.to_s.gsub(/^/, "\'"))
1681     @fh.printf("'summary:sennichite:%s draw:%s draw\n", @current_player.name, @next_player.name)
1682     @result = GameResultDraw.new(@current_player, @next_player)
1683     @fh.printf("'rating:#{@result.to_s}\n") if rated?
1684     @monitors.each do |monitor|
1685       monitor.write_safe(sprintf("##[MONITOR][%s] #SENNICHITE\n", @id))
1686     end
1687   end
1688
1689   def oute_sennichite_lose
1690     @current_player.status = "connected"
1691     @next_player.status = "connected"
1692     @current_player.write_safe("#OUTE_SENNICHITE\n#LOSE\n")
1693     @next_player.write_safe("#OUTE_SENNICHITE\n#WIN\n")
1694     @fh.print(@board.to_s.gsub(/^/, "\'"))
1695     @fh.printf("'summary:oute_sennichite:%s lose:%s win\n", @current_player.name, @next_player.name)
1696     @result = GameResultWin.new(@next_player, @current_player)
1697     @fh.printf("'rating:#{@result.to_s}\n") if rated?
1698     @monitors.each do |monitor|
1699       monitor.write_safe(sprintf("##[MONITOR][%s] #OUTE_SENNICHITE\n", @id))
1700     end
1701   end
1702
1703   def illegal_lose
1704     @current_player.status = "connected"
1705     @next_player.status = "connected"
1706     @current_player.write_safe("#ILLEGAL_MOVE\n#LOSE\n")
1707     @next_player.write_safe("#ILLEGAL_MOVE\n#WIN\n")
1708     @fh.print(@board.to_s.gsub(/^/, "\'"))
1709     @fh.printf("'summary:illegal move:%s lose:%s win\n", @current_player.name, @next_player.name)
1710     @result = GameResultWin.new(@next_player, @current_player)
1711     @fh.printf("'rating:#{@result.to_s}\n") if rated?
1712     @monitors.each do |monitor|
1713       monitor.write_safe(sprintf("##[MONITOR][%s] #ILLEGAL_MOVE\n", @id))
1714     end
1715   end
1716
1717   def uchifuzume_lose
1718     @current_player.status = "connected"
1719     @next_player.status = "connected"
1720     @current_player.write_safe("#ILLEGAL_MOVE\n#LOSE\n")
1721     @next_player.write_safe("#ILLEGAL_MOVE\n#WIN\n")
1722     @fh.print(@board.to_s.gsub(/^/, "\'"))
1723     @fh.printf("'summary:uchifuzume:%s lose:%s win\n", @current_player.name, @next_player.name)
1724     @result = GameResultWin.new(@next_player, @current_player)
1725     @fh.printf("'rating:#{@result.to_s}\n") if rated?
1726     @monitors.each do |monitor|
1727       monitor.write_safe(sprintf("##[MONITOR][%s] #ILLEGAL_MOVE\n", @id))
1728     end
1729   end
1730
1731   def oute_kaihimore_lose
1732     @current_player.status = "connected"
1733     @next_player.status = "connected"
1734     @current_player.write_safe("#ILLEGAL_MOVE\n#LOSE\n")
1735     @next_player.write_safe("#ILLEGAL_MOVE\n#WIN\n")
1736     @fh.print(@board.to_s.gsub(/^/, "\'"))
1737     @fh.printf("'summary:oute_kaihimore:%s lose:%s win\n", @current_player.name, @next_player.name)
1738     @result = GameResultWin.new(@next_player, @current_player)
1739     @fh.printf("'rating:#{@result.to_s}\n") if rated?
1740     @monitors.each do |monitor|
1741       monitor.write_safe(sprintf("##[MONITOR][%s] #ILLEGAL_MOVE\n", @id))
1742     end
1743   end
1744
1745   def timeout_lose
1746     @current_player.status = "connected"
1747     @next_player.status = "connected"
1748     @current_player.write_safe("#TIME_UP\n#LOSE\n")
1749     @next_player.write_safe("#TIME_UP\n#WIN\n")
1750     @fh.print(@board.to_s.gsub(/^/, "\'"))
1751     @fh.printf("'summary:time up:%s lose:%s win\n", @current_player.name, @next_player.name)
1752     @result = GameResultWin.new(@next_player, @current_player)
1753     @fh.printf("'rating:#{@result.to_s}\n") if rated?
1754     @monitors.each do |monitor|
1755       monitor.write_safe(sprintf("##[MONITOR][%s] #TIME_UP\n", @id))
1756     end
1757   end
1758
1759   def kachi_win
1760     @current_player.status = "connected"
1761     @next_player.status = "connected"
1762     @current_player.write_safe("%KACHI\n#JISHOGI\n#WIN\n")
1763     @next_player.write_safe("%KACHI\n#JISHOGI\n#LOSE\n")
1764     @fh.printf("%%KACHI\n")
1765     @fh.print(@board.to_s.gsub(/^/, "\'"))
1766     @fh.printf("'summary:kachi:%s win:%s lose\n", @current_player.name, @next_player.name)
1767     @result = GameResultWin.new(@current_player, @next_player)
1768     @fh.printf("'rating:#{@result.to_s}\n") if rated?
1769     @monitors.each do |monitor|
1770       monitor.write_safe(sprintf("##[MONITOR][%s] %%KACHI\n", @id))
1771     end
1772   end
1773
1774   def kachi_lose
1775     @current_player.status = "connected"
1776     @next_player.status = "connected"
1777     @current_player.write_safe("%KACHI\n#ILLEGAL_MOVE\n#LOSE\n")
1778     @next_player.write_safe("%KACHI\n#ILLEGAL_MOVE\n#WIN\n")
1779     @fh.printf("%%KACHI\n")
1780     @fh.print(@board.to_s.gsub(/^/, "\'"))
1781     @fh.printf("'summary:illegal kachi:%s lose:%s win\n", @current_player.name, @next_player.name)
1782     @result = GameResultWin.new(@next_player, @current_player)
1783     @fh.printf("'rating:#{@result.to_s}\n") if rated?
1784     @monitors.each do |monitor|
1785       monitor.write_safe(sprintf("##[MONITOR][%s] %%KACHI\n", @id))
1786     end
1787   end
1788
1789   def toryo_lose
1790     @current_player.status = "connected"
1791     @next_player.status = "connected"
1792     @current_player.write_safe("%TORYO\n#RESIGN\n#LOSE\n")
1793     @next_player.write_safe("%TORYO\n#RESIGN\n#WIN\n")
1794     @fh.printf("%%TORYO\n")
1795     @fh.print(@board.to_s.gsub(/^/, "\'"))
1796     @fh.printf("'summary:toryo:%s lose:%s win\n", @current_player.name, @next_player.name)
1797     @result = GameResultWin.new(@next_player, @current_player)
1798     @fh.printf("'rating:#{@result.to_s}\n") if rated?
1799     @monitors.each do |monitor|
1800       monitor.write_safe(sprintf("##[MONITOR][%s] %%TORYO\n", @id))
1801     end
1802   end
1803
1804   def outori_win
1805     @current_player.status = "connected"
1806     @next_player.status = "connected"
1807     @current_player.write_safe("#ILLEGAL_MOVE\n#WIN\n")
1808     @next_player.write_safe("#ILLEGAL_MOVE\n#LOSE\n")
1809     @fh.print(@board.to_s.gsub(/^/, "\'"))
1810     @fh.printf("'summary:outori:%s win:%s lose\n", @current_player.name, @next_player.name)
1811     @result = GameResultWin.new(@current_player, @next_player)
1812     @fh.printf("'rating:#{@result.to_s}\n") if rated?
1813     @monitors.each do |monitor|
1814       monitor.write_safe(sprintf("##[MONITOR][%s] #ILLEGAL_MOVE\n", @id))
1815     end
1816   end
1817
1818   def start
1819     log_message(sprintf("game started %s", @id))
1820     @sente.write_safe(sprintf("START:%s\n", @id))
1821     @gote.write_safe(sprintf("START:%s\n", @id))
1822     @sente.mytime = @total_time
1823     @gote.mytime = @total_time
1824     @start_time = Time::new
1825   end
1826
1827   def propose
1828     begin
1829       @fh = open(@logfile, "w")
1830       @fh.sync = true
1831
1832       @fh.printf("V2\n")
1833       @fh.printf("N+%s\n", @sente.name)
1834       @fh.printf("N-%s\n", @gote.name)
1835       @fh.printf("$EVENT:%s\n", @id)
1836
1837       @sente.write_safe(propose_message("+"))
1838       @gote.write_safe(propose_message("-"))
1839
1840       @fh.printf("$START_TIME:%s\n", Time::new.strftime("%Y/%m/%d %H:%M:%S"))
1841       @fh.print <<EOM
1842 P1-KY-KE-GI-KI-OU-KI-GI-KE-KY
1843 P2 * -HI *  *  *  *  * -KA *
1844 P3-FU-FU-FU-FU-FU-FU-FU-FU-FU
1845 P4 *  *  *  *  *  *  *  *  *
1846 P5 *  *  *  *  *  *  *  *  *
1847 P6 *  *  *  *  *  *  *  *  *
1848 P7+FU+FU+FU+FU+FU+FU+FU+FU+FU
1849 P8 * +KA *  *  *  *  * +HI *
1850 P9+KY+KE+GI+KI+OU+KI+GI+KE+KY
1851 +
1852 EOM
1853     end
1854   end
1855
1856   def show()
1857     str0 = <<EOM
1858 BEGIN Game_Summary
1859 Protocol_Version:1.1
1860 Protocol_Mode:Server
1861 Format:Shogi 1.0
1862 Declaration:Jishogi 1.1
1863 Game_ID:#{@id}
1864 Name+:#{@sente.name}
1865 Name-:#{@gote.name}
1866 Rematch_On_Draw:NO
1867 To_Move:+
1868 BEGIN Time
1869 Time_Unit:1sec
1870 Total_Time:#{@total_time}
1871 Byoyomi:#{@byoyomi}
1872 Least_Time_Per_Move:#{Least_Time_Per_Move}
1873 Remaining_Time+:#{@sente.mytime}
1874 Remaining_Time-:#{@gote.mytime}
1875 Last_Move:#{@last_move}
1876 Current_Turn:#{@current_turn}
1877 END Time
1878 BEGIN Position
1879 EOM
1880
1881     str1 = <<EOM
1882 END Position
1883 END Game_Summary
1884 EOM
1885
1886     return str0 + @board.to_s + str1
1887   end
1888
1889   def propose_message(sg_flag)
1890     str = <<EOM
1891 BEGIN Game_Summary
1892 Protocol_Version:1.1
1893 Protocol_Mode:Server
1894 Format:Shogi 1.0
1895 Declaration:Jishogi 1.1
1896 Game_ID:#{@id}
1897 Name+:#{@sente.name}
1898 Name-:#{@gote.name}
1899 Your_Turn:#{sg_flag}
1900 Rematch_On_Draw:NO
1901 To_Move:+
1902 BEGIN Time
1903 Time_Unit:1sec
1904 Total_Time:#{@total_time}
1905 Byoyomi:#{@byoyomi}
1906 Least_Time_Per_Move:#{Least_Time_Per_Move}
1907 END Time
1908 BEGIN Position
1909 P1-KY-KE-GI-KI-OU-KI-GI-KE-KY
1910 P2 * -HI *  *  *  *  * -KA *
1911 P3-FU-FU-FU-FU-FU-FU-FU-FU-FU
1912 P4 *  *  *  *  *  *  *  *  *
1913 P5 *  *  *  *  *  *  *  *  *
1914 P6 *  *  *  *  *  *  *  *  *
1915 P7+FU+FU+FU+FU+FU+FU+FU+FU+FU
1916 P8 * +KA *  *  *  *  * +HI *
1917 P9+KY+KE+GI+KI+OU+KI+GI+KE+KY
1918 P+
1919 P-
1920 +
1921 END Position
1922 END Game_Summary
1923 EOM
1924     return str
1925   end
1926
1927   private
1928
1929   def issue_current_time
1930     time = Time::new.strftime("%Y%m%d%H%M%S").to_i
1931     @@mutex.synchronize do
1932       while time <= @@time do
1933         time += 1
1934       end
1935       @@time = time
1936     end
1937   end
1938 end
1939 end # module ShogiServer
1940
1941 #################################################
1942 # MAIN
1943 #
1944
1945 def usage
1946     print <<EOM
1947 NAME
1948         shogi-server - server for CSA server protocol
1949
1950 SYNOPSIS
1951         shogi-server [OPTIONS] event_name port_number
1952
1953 DESCRIPTION
1954         server for CSA server protocol
1955
1956 OPTIONS
1957         --pid-file file
1958                 specify filename for logging process ID
1959     --daemon dir
1960         run as a daemon. Log files will be put in dir.
1961
1962 LICENSE
1963         this file is distributed under GPL version2 and might be compiled by Exerb
1964
1965 SEE ALSO
1966
1967 RELEASE
1968         #{ShogiServer::Release}
1969
1970 REVISION
1971         #{ShogiServer::Revision}
1972 EOM
1973 end
1974
1975 def log_message(str)
1976   $logger.info(str)
1977 end
1978
1979 def log_warning(str)
1980   $logger.warn(str)
1981 end
1982
1983 def log_error(str)
1984   $logger.error(str)
1985 end
1986
1987
1988 def parse_command_line
1989   options = Hash::new
1990   parser = GetoptLong.new( ["--daemon",         GetoptLong::REQUIRED_ARGUMENT],
1991                            ["--pid-file",       GetoptLong::REQUIRED_ARGUMENT]
1992                          )
1993   parser.quiet = true
1994   begin
1995     parser.each_option do |name, arg|
1996       name.sub!(/^--/, '')
1997       options[name] = arg.dup
1998     end
1999   rescue
2000     usage
2001     raise parser.error_message
2002   end
2003   return options
2004 end
2005
2006 def write_pid_file(file)
2007   open(file, "w") do |fh|
2008     fh.print Process::pid, "\n"
2009   end
2010 end
2011
2012 def mutex_watchdog(mutex, sec)
2013   while true
2014     begin
2015       timeout(sec) do
2016         begin
2017           mutex.lock
2018         ensure
2019           mutex.unlock
2020         end
2021       end
2022       sleep(sec)
2023     rescue TimeoutError
2024       log_error("mutex watchdog timeout")
2025       exit(1)
2026     end
2027   end
2028 end
2029
2030 def main
2031
2032   $mutex = Mutex::new
2033   Thread::start do
2034     Thread.pass
2035     mutex_watchdog($mutex, 10)
2036   end
2037
2038   $options = parse_command_line
2039   if (ARGV.length != 2)
2040     usage
2041     exit 2
2042   end
2043
2044   LEAGUE.event = ARGV.shift
2045   port = ARGV.shift
2046
2047   write_pid_file($options["pid-file"]) if ($options["pid-file"])
2048
2049   dir = $options["daemon"] || nil
2050   if dir && ! File.exist?(dir)
2051     FileUtils.mkdir(dir)
2052   end
2053   log_file = dir ? File.join(dir, "shogi-server.log") : STDOUT
2054   $logger = WEBrick::Log.new(log_file)
2055
2056   LEAGUE.dir = dir || File.dirname(__FILE__)
2057   LEAGUE.setup_players_database
2058
2059   config = {}
2060   config[:Port]       = port
2061   config[:ServerType] = WEBrick::Daemon if $options["daemon"]
2062   config[:Logger]     = $logger
2063
2064   server = WEBrick::GenericServer.new(config)
2065   ["INT", "TERM"].each {|signal| trap(signal){ server.shutdown } }
2066   $stderr.puts("server started as a deamon [Revision: #{ShogiServer::Revision}]") if $options["daemon"]
2067   log_message("server started [Revision: #{ShogiServer::Revision}]")
2068
2069   server.start do |client|
2070       # client.sync = true # this is already set in WEBrick
2071       client.setsockopt(Socket::SOL_SOCKET, Socket::SO_KEEPALIVE, true)
2072         # Keepalive time can be set by /proc/sys/net/ipv4/tcp_keepalive_time
2073       player = nil
2074       login  = nil
2075       while (str = client.gets_timeout(ShogiServer::Login_Time))
2076         begin
2077           $mutex.lock
2078           str =~ /([\r\n]*)$/
2079           eol = $1
2080           if (ShogiServer::Login::good_login?(str))
2081             player = ShogiServer::Player::new(str, client)
2082             player.eol = eol
2083             login  = ShogiServer::Login::factory(str, player)
2084             if (LEAGUE.players[player.name])
2085               if ((LEAGUE.players[player.name].password == player.password) &&
2086                   (LEAGUE.players[player.name].status != "game"))
2087                 log_message(sprintf("user %s login forcely", player.name))
2088                 LEAGUE.players[player.name].kill
2089               else
2090                 login.incorrect_duplicated_player(str)
2091                 #Thread::exit
2092                 #return
2093                 # TODO
2094                 player = nil
2095                 break
2096               end
2097             end
2098             LEAGUE.add(player)
2099             break
2100           else
2101             client.write_safe("LOGIN:incorrect" + eol)
2102             client.write_safe("type 'LOGIN name password' or 'LOGIN name password x1'" + eol) if (str.split.length >= 4)
2103           end
2104         ensure
2105           $mutex.unlock
2106         end
2107       end                       # login loop
2108       if (! player)
2109         #client.close
2110         #Thread::exit
2111         #return
2112         next
2113       end
2114       log_message(sprintf("user %s login", player.name))
2115       login.process
2116       player.run(login.csa_1st_str)
2117       begin
2118         $mutex.lock
2119         if (player.game)
2120           player.game.kill(player)
2121         end
2122         player.finish # socket has been closed
2123         LEAGUE.delete(player)
2124         log_message(sprintf("user %s logout", player.name))
2125       ensure
2126         $mutex.unlock
2127       end
2128   end
2129 end
2130
2131
2132 if ($0 == __FILE__)
2133   STDOUT.sync = true
2134   STDERR.sync = true
2135   TCPSocket.do_not_reverse_lookup = true
2136   Thread.abort_on_exception = true
2137
2138   LEAGUE = ShogiServer::League::new
2139   main
2140 end