shogi-server

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