3 ## Copyright (C) 2004 NABEYA Kenichi (aka nanami@2ch)
4 ## Copyright (C) 2007-2008 Daigo Moriwaki (daigo at debian dot org)
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.
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.
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
20 module ShogiServer # for a namespace
30 @last_game_win = false
33 # Idetifier of the player in the rating system
34 attr_accessor :player_id
39 # Password of the player, which does not include a trip
40 attr_accessor :password
42 # Score in the rating sysem
45 # Number of games for win and loss in the rating system
46 attr_accessor :win, :loss
48 # Group in the rating system
49 attr_accessor :rating_group
51 # Last timestamp when the rate was modified
52 attr_accessor :modified_at
54 # Whether win the previous game or not
55 attr_accessor :last_game_win
58 @modified_at || Time.now
64 @modified_at = Time.now
78 simple_name = @name.gsub(/@.*?$/, '')
79 "%s+%s" % [simple_name, @trip[0..8]]
86 # Parses str in the LOGIN command, sets up @player_id and @trip
91 @player_id = "%s+%s" % [@name, Digest::MD5.hexdigest(@password)]
93 @player_id = @password = nil
99 class Player < BasicPlayer
100 def initialize(str, socket, eol=nil)
103 @status = "connected" # game_waiting -> agree_waiting -> start_waiting -> game -> finished
105 @protocol = nil # CSA or x1
106 @eol = eol || "\m" # favorite eol code
109 @mytime = 0 # set in start method also
112 @main_thread = Thread::current
113 @write_queue = Queue.new
118 attr_accessor :socket, :status
119 attr_accessor :protocol, :eol, :game, :mytime, :game_name, :sente
120 attr_accessor :main_thread
121 attr_reader :socket_buffer
123 def setup_logger(dir)
124 log_file = File.join(dir, "%s.log" % [simple_player_id])
125 @player_logger = Logger.new(log_file, 'daily')
126 @player_logger.formatter = ShogiServer::Formatter.new
127 @player_logger.level = $DEBUG ? Logger::DEBUG : Logger::INFO
128 @player_logger.datetime_format = "%Y-%m-%d %H:%M:%S"
131 def log(level, direction, message)
132 return unless @player_logger
136 str = "IN: %s" % [str]
138 str = "OUT: %s" % [str]
140 str = "UNKNOWN DIRECTION: %s %s" % [direction, str]
144 @player_logger.debug(str)
146 @player_logger.info(str)
148 @player_logger.warn(str)
150 @player_logger.error(str)
152 @player_logger.debug("UNKNOWN LEVEL: %s %s" % [level, str])
154 rescue Exception => ex
155 log_error("#{ex.class}: #{ex.message}\n\t#{ex.backtrace[0]}")
159 log_message(sprintf("user %s killed", @name))
164 Thread::kill(@main_thread) if @main_thread
165 Thread::kill(@write_thread) if @write_thread
169 if (@status != "finished")
171 log_message(sprintf("user %s finish", @name))
173 # @socket.close if (! @socket.closed?)
176 @player_logger.close if @player_logger
178 log_message(sprintf("user %s finish failed", @name))
183 def start_write_thread
184 @write_thread = Thread.start do
186 while !@socket.closed?
191 str = @write_queue.deq
199 if r = select(nil, [@socket], nil, 20)
200 r[1].first.write(str)
201 log(:info, :out, str)
203 log_error("Sending a message to #{@name} timed up.")
205 rescue Exception => ex
206 log_error("Failed to send a message to #{@name}. #{ex.class}: #{ex.message}\t#{ex.backtrace[0]}")
209 log_message("terminated %s's write thread" % [@name])
216 # Note that sending a message is included in the giant lock.
223 if ["game_waiting", "start_waiting", "agree_waiting", "game"].include?(status)
225 return sprintf("%s %s %s %s +", rated? ? @player_id : @name, @protocol, @status, @game_name)
226 elsif (@sente == false)
227 return sprintf("%s %s %s %s -", rated? ? @player_id : @name, @protocol, @status, @game_name)
228 elsif (@sente == nil)
229 return sprintf("%s %s %s %s *", rated? ? @player_id : @name, @protocol, @status, @game_name)
232 return sprintf("%s %s %s", rated? ? @player_id : @name, @protocol, @status)
236 def run(csa_1st_str=nil)
237 while ( csa_1st_str ||
238 str = gets_safe(@socket, (@socket_buffer.empty? ? Default_Timeout : 1)) )
239 log(:info, :in, str) if str && str.instance_of?(String)
242 if !@write_thread.alive?
243 log_error("%s's write thread is dead. Aborting..." % [@name])
246 if (@game && @game.turn?(self))
247 @socket_buffer << str
248 str = @socket_buffer.shift
250 log_message("%s (%s)" % [str, @socket_buffer.map {|a| String === a ? a.strip : a }.join(",")]) if $DEBUG
257 if (@status == "finished")
260 str.chomp! if (str.class == String) # may be strip! ?
263 # Application-level protocol for Keep-Alive
264 # If the server gets LF, it sends back LF.
265 # 30 sec rule (client may not send LF again within 30 sec) is not implemented yet.
268 if (@status == "game")
269 array_str = str.split(",")
270 move = array_str.shift
271 additional = array_str.shift
272 if /^'(.*)/ =~ additional
273 comment = array_str.unshift("'*#{$1.toeuc}")
275 s = @game.handle_one_move(move, self)
276 @game.fh.print("#{Kconv.toeuc(comment.first)}\n") if (comment && comment.first && !s)
277 return if (s && @protocol == LoginCSA::PROTOCOL)
279 when /^%[^%]/, :timeout
280 if (@status == "game")
281 s = @game.handle_one_move(str, self)
282 return if (s && @protocol == LoginCSA::PROTOCOL)
285 log_error("Failed to receive a message from #{@name}.")
288 if (@status == "agree_waiting")
290 return if (@protocol == LoginCSA::PROTOCOL)
292 write_safe(sprintf("##[ERROR] you are in %s status. AGREE is valid in agree_waiting status\n", @status))
295 if (@status == "agree_waiting")
296 @status = "start_waiting"
297 if ((@game.sente.status == "start_waiting") &&
298 (@game.gote.status == "start_waiting"))
300 @game.sente.status = "game"
301 @game.gote.status = "game"
304 write_safe(sprintf("##[ERROR] you are in %s status. AGREE is valid in agree_waiting status\n", @status))
306 when /^%%SHOW\s+(\S+)/
308 if (LEAGUE.games[game_id])
309 write_safe(LEAGUE.games[game_id].show.gsub(/^/, '##[SHOW] '))
311 write_safe("##[SHOW] +OK\n")
312 when /^%%MONITORON\s+(\S+)/
314 if (LEAGUE.games[game_id])
315 LEAGUE.games[game_id].monitoron(self)
316 write_safe(LEAGUE.games[game_id].show.gsub(/^/, "##[MONITOR][#{game_id}] "))
317 write_safe("##[MONITOR][#{game_id}] +OK\n")
319 when /^%%MONITOROFF\s+(\S+)/
321 if (LEAGUE.games[game_id])
322 LEAGUE.games[game_id].monitoroff(self)
326 %!##[HELP] available commands "%%WHO", "%%CHAT str", "%%GAME game_name +", "%%GAME game_name -"\n!)
328 players = LEAGUE.rated_players
329 players.sort {|a,b| b.rate <=> a.rate}.each do |p|
330 write_safe("##[RATING] %s \t %4d @%s\n" %
331 [p.simple_player_id, p.rate, p.modified_at.strftime("%Y-%m-%d")])
333 write_safe("##[RATING] +OK\n")
335 write_safe "##[VERSION] Shogi Server revision #{Revision}\n"
336 write_safe("##[VERSION] +OK\n")
338 if ((@status == "connected") || (@status == "game_waiting"))
339 @status = "connected"
342 write_safe(sprintf("##[ERROR] you are in %s status. GAME is valid in connected or game_waiting status\n", @status))
344 when /^%%(GAME|CHALLENGE)\s+(\S+)\s+([\+\-\*])\s*$/
348 if (! Login::good_game_name?(game_name))
349 write_safe(sprintf("##[ERROR] bad game name\n"))
351 elsif ((@status == "connected") || (@status == "game_waiting"))
354 write_safe(sprintf("##[ERROR] you are in %s status. GAME is valid in connected or game_waiting status\n", @status))
359 if (League::Floodgate.game_name?(game_name))
360 if (my_sente_str != "*")
361 write_safe(sprintf("##[ERROR] You are not allowed to specify TEBAN %s for the game %s\n", my_sente_str, game_name))
366 if (my_sente_str == "*")
367 rival = LEAGUE.get_player("game_waiting", game_name, nil, self) # no preference
368 elsif (my_sente_str == "+")
369 rival = LEAGUE.get_player("game_waiting", game_name, false, self) # rival must be gote
370 elsif (my_sente_str == "-")
371 rival = LEAGUE.get_player("game_waiting", game_name, true, self) # rival must be sente
374 write_safe(sprintf("##[ERROR] bad game option\n"))
380 @game_name = game_name
381 if ((my_sente_str == "*") && (rival.sente == nil))
389 elsif (rival.sente == true) # rival has higher priority
391 elsif (rival.sente == false)
393 elsif (my_sente_str == "+")
396 elsif (my_sente_str == "-")
402 Game::new(@game_name, self, rival)
403 else # rival not found
404 if (command_name == "GAME")
405 @status = "game_waiting"
406 @game_name = game_name
407 if (my_sente_str == "+")
409 elsif (my_sente_str == "-")
415 write_safe(sprintf("##[ERROR] can't find rival for %s\n", game_name))
416 @status = "connected"
421 when /^%%CHAT\s+(.+)/
423 LEAGUE.players.each do |name, player|
424 if (player.protocol != LoginCSA::PROTOCOL)
425 player.write_safe(sprintf("##[CHAT][%s] %s\n", @name, message))
430 LEAGUE.games.each do |id, game|
431 buf.push(sprintf("##[LIST] %s\n", id))
433 buf.push("##[LIST] +OK\n")
437 LEAGUE.players.each do |name, player|
438 buf.push(sprintf("##[WHO] %s\n", player.to_s))
440 buf.push("##[WHO] +OK\n")
443 @status = "connected"
444 write_safe("LOGOUT:completed\n")
447 # This command is only available for CSA's official testing server.
448 # So, this means nothing for this program.
449 write_safe("CHALLENGE ACCEPTED\n")
451 ## ignore null string
453 msg = "##[ERROR] unknown command %s\n" % [str]