class MonitorObserver
def update(game_result)
game_result.game.each_monitor do |monitor|
- monitor.write_safe("##[MONITOR][%s] %s\n" % [game_result.game.game_id, game_result.type])
+ monitor.write_safe("##[MONITOR][%s] %s\n" % [game_result.game.game_id, game_result.result_type])
end
end
end
attr_reader :black
# White plyer object
attr_reader :white
- # Command to send monitors such as '%%TORYO' etc...
+ # Command to send monitors such as '%TORYO' etc...
attr_reader :result_type
def initialize(game, p1, p2)
$options["floodgate-history"]
add_observer League::Floodgate::History.factory
end
+
end
def process
end
def log_board
- log(@game.board.to_s.gsub(/^/, "\'"))
+ log(@game.board.to_s.gsub(/^/, "\'").chomp)
end
end
black_result = "lose"
white_result = "win"
end
- log("'summary:%s:%s %s:%s %s\n" % [type,
- @black.name, black_result,
- @white.name, white_result])
+ log("'summary:%s:%s %s:%s %s" % [type,
+ @black.name, black_result,
+ @white.name, white_result])
end
end
def process
@winner.write_safe("%TORYO\n#RESIGN\n#WIN\n")
@loser.write_safe( "%TORYO\n#RESIGN\n#LOSE\n")
- log("%%TORYO\n")
+ log("%TORYO")
log_summary("abnormal")
- @result_type = "%%TORYO"
+ @result_type = "%TORYO"
notify
end
end
def process
@winner.write_safe("%KACHI\n#JISHOGI\n#WIN\n")
@loser.write_safe( "%KACHI\n#JISHOGI\n#LOSE\n")
- log("%%KACHI\n")
+ log("%KACHI")
log_summary("kachi")
- @result_type = "%%KACHI"
+ @result_type = "%KACHI"
notify
end
end
def process
@winner.write_safe("%KACHI\n#ILLEGAL_MOVE\n#WIN\n")
@loser.write_safe( "%KACHI\n#ILLEGAL_MOVE\n#LOSE\n")
- log("%%KACHI\n")
+ log("%KACHI")
log_summary("illegal kachi")
- @result_type = "%%KACHI"
+ @result_type = "%KACHI"
notify
end
end
end
end
-class GameResultOuteKaihiMoreWin < GameResultWin
+class GameResultOuteKaihiMoreWin < GameResultIllegalWin
def initialize(game, winner, loser)
super(game, winner, loser, "oute_kaihimore")
end
class GameResultOutoriWin < GameResultWin
def initialize(game, winner, loser)
- super(game, winner, loser, "outori")
+ super(game, winner, loser)
end
end
-class GameReulstToryoWin < GameResultWin
+class GameResultToryoWin < GameResultWin
def process
@winner.write_safe("%TORYO\n#RESIGN\n#WIN\n")
@loser.write_safe( "%TORYO\n#RESIGN\n#LOSE\n")
- log("%%TORYO\n")
+ log("%TORYO")
log_summary("toryo")
- @result_type = "%%TORYO"
+ @result_type = "%TORYO"
notify
end
end
def log_summary(type)
log_board
- log("'summary:%s:%s draw:%s draw\n" % [type, @black.name, @white.name])
+ log("'summary:%s:%s draw:%s draw" % [type, @black.name, @white.name])
end
end
end
class Game
+ # When this duration passes after this object instanciated (i.e.
+ # the agree_waiting or start_waiting state lasts too long),
+ # the game will be rejected by the Server.
+ WAITING_EXPIRATION = 120 # seconds
+
@@mutex = Mutex.new
@@time = 0
-
- def initialize(game_name, player0, player1)
+ def initialize(game_name, player0, player1, board)
@monitors = Array::new
@game_name = game_name
if (@game_name =~ /-(\d+)-(\d+)$/)
end
@sente.socket_buffer.clear
@gote.socket_buffer.clear
- @current_player, @next_player = @sente, @gote
+ @board = board
+ if @board.teban
+ @current_player, @next_player = @sente, @gote
+ else
+ @current_player, @next_player = @gote, @sente
+ end
@sente.game = self
@gote.game = self
- @last_move = ""
- @current_turn = 0
+ @last_move = @board.initial_moves.empty? ? "" : "%s,T1" % [@board.initial_moves.last]
+ @current_turn = @board.initial_moves.size
@sente.status = "agree_waiting"
@gote.status = "agree_waiting"
@game_id = sprintf("%s+%s+%s+%s+%s",
- LEAGUE.event, @game_name,
+ $league.event, @game_name,
@sente.name, @gote.name, issue_current_time)
- now = Time.now
- log_dir_name = File.join(LEAGUE.dir,
- now.strftime("%Y"),
- now.strftime("%m"),
- now.strftime("%d"))
+ # The time when this Game instance was created.
+ # Don't be confused with @start_time when the game was started to play.
+ @prepared_time = Time.now
+ log_dir_name = File.join($league.dir,
+ @prepared_time.strftime("%Y"),
+ @prepared_time.strftime("%m"),
+ @prepared_time.strftime("%d"))
FileUtils.mkdir_p(log_dir_name) unless File.exist?(log_dir_name)
@logfile = File.join(log_dir_name, @game_id + ".csa")
- LEAGUE.games[@game_id] = self
+ $league.games[@game_id] = self
log_message(sprintf("game created %s", @game_id))
- @board = Board::new
- @board.initial
@start_time = nil
@fh = open(@logfile, "w")
@fh.sync = true
end
attr_accessor :game_name, :total_time, :byoyomi, :sente, :gote, :game_id, :board, :current_player, :next_player, :fh, :monitors
attr_accessor :last_move, :current_turn
- attr_reader :result
+ attr_reader :result, :prepared_time
+
+ # Path of a log file for this game.
+ attr_reader :logfile
def rated?
@sente.rated? && @gote.rated?
end
def kill(killer)
- if ["agree_waiting", "start_waiting"].include?(@sente.status)
- reject(killer.name)
- elsif (@current_player == killer)
+ [@sente, @gote].each do |player|
+ if ["agree_waiting", "start_waiting"].include?(player.status)
+ reject(killer.name)
+ return # return from this method
+ end
+ end
+
+ if (@current_player == killer)
result = GameResultAbnormalWin.new(self, @next_player, @current_player)
result.process
finish
@gote = nil
@current_player = nil
@next_player = nil
- LEAGUE.games.delete(@game_id)
+ $league.games.delete(@game_id)
end
# class Game
elsif (move_status == :kachi_lose)
result = GameResultIllegalKachiWin.new(self, @next_player, @current_player)
elsif (move_status == :toryo)
- result = GameReulstToryoWin.new(self, @next_player, @current_player)
+ result = GameResultToryoWin.new(self, @next_player, @current_player)
elsif (move_status == :outori)
# The current player captures the next player's king
result = GameResultOutoriWin.new(self, @current_player, @next_player)
return finish_flag
end
+ def is_startable_status?
+ return (@sente && @gote &&
+ (@sente.status == "start_waiting") &&
+ (@gote.status == "start_waiting"))
+ end
+
def start
log_message(sprintf("game started %s", @game_id))
+ @sente.status = "game"
+ @gote.status = "game"
@sente.write_safe(sprintf("START:%s\n", @game_id))
@gote.write_safe(sprintf("START:%s\n", @game_id))
@sente.mytime = @total_time
white_name = @gote.rated? ? @gote.player_id : @gote.name
@fh.puts("'rating:%s:%s" % [black_name, white_name])
end
+ unless @board.initial_moves.empty?
+ @fh.puts "'buoy game starting with %d moves" % [@board.initial_moves.size]
+ @board.initial_moves.each do |move|
+ @fh.puts move
+ @fh.puts "T1"
+ end
+ end
end
def show()
Least_Time_Per_Move:#{Least_Time_Per_Move}
END Time
BEGIN Position
-P1-KY-KE-GI-KI-OU-KI-GI-KE-KY
-P2 * -HI * * * * * -KA *
-P3-FU-FU-FU-FU-FU-FU-FU-FU-FU
-P4 * * * * * * * * *
-P5 * * * * * * * * *
-P6 * * * * * * * * *
-P7+FU+FU+FU+FU+FU+FU+FU+FU+FU
-P8 * +KA * * * * * +HI *
-P9+KY+KE+GI+KI+OU+KI+GI+KE+KY
-P+
-P-
-+
+#{@board.to_s.chomp}
END Position
END Game_Summary
EOM
return str
end
+
+ def prepared_expire?
+ if @prepared_time && (@prepared_time + WAITING_EXPIRATION < Time.now)
+ return true
+ end
+
+ return false
+ end
private
OSDN Git Service
