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