OSDN Git Service

- shogi_server/pairing.rb: Added a new class: StartGameWithoutHumans.
[shogi-server/shogi-server.git] / shogi_server / command.rb
1 ## $Id$
2
3 ## Copyright (C) 2004 NABEYA Kenichi (aka nanami@2ch)
4 ## Copyright (C) 2007-2008 Daigo Moriwaki (daigo at debian dot org)
5 ##
6 ## This program is free software; you can redistribute it and/or modify
7 ## it under the terms of the GNU General Public License as published by
8 ## the Free Software Foundation; either version 2 of the License, or
9 ## (at your option) any later version.
10 ##
11 ## This program is distributed in the hope that it will be useful,
12 ## but WITHOUT ANY WARRANTY; without even the implied warranty of
13 ## MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14 ## GNU General Public License for more details.
15 ##
16 ## You should have received a copy of the GNU General Public License
17 ## along with this program; if not, write to the Free Software
18 ## Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
19
20 require 'kconv'
21 require 'shogi_server'
22
23 module ShogiServer
24
25   class Command
26     # Factory method
27     #
28     def Command.factory(str, player)
29       cmd = nil
30       case str 
31       when "" 
32         cmd = KeepAliveCommand.new(str, player)
33       when /^[\+\-][^%]/
34         cmd = MoveCommand.new(str, player)
35       when /^%[^%]/, :timeout
36         cmd = SpecialCommand.new(str, player)
37       when :exception
38         cmd = ExceptionCommand.new(str, player)
39       when /^REJECT/
40         cmd = RejectCommand.new(str, player)
41       when /^AGREE/
42         cmd = AgreeCommand.new(str, player)
43       when /^%%SHOW\s+(\S+)/
44         game_id = $1
45         cmd = ShowCommand.new(str, player, $league.games[game_id])
46       when /^%%MONITORON\s+(\S+)/
47         game_id = $1
48         cmd = MonitorOnCommand.new(str, player, $league.games[game_id])
49       when /^%%MONITOROFF\s+(\S+)/
50         game_id = $1
51         cmd = MonitorOffCommand.new(str, player, $league.games[game_id])
52       when /^%%HELP/
53         cmd = HelpCommand.new(str, player)
54       when /^%%RATING/
55         cmd = RatingCommand.new(str, player, $league.rated_players)
56       when /^%%VERSION/
57         cmd = VersionCommand.new(str, player)
58       when /^%%GAME\s*$/
59         cmd = GameCommand.new(str, player)
60       when /^%%(GAME|CHALLENGE)\s+(\S+)\s+([\+\-\*])\s*$/
61         command_name = $1
62         game_name = $2
63         my_sente_str = $3
64         cmd = GameChallengeCommand.new(str, player, 
65                                        command_name, game_name, my_sente_str)
66       when /^%%CHAT\s+(.+)/
67         message = $1
68         cmd = ChatCommand.new(str, player, message, $league.players)
69       when /^%%LIST/
70         cmd = ListCommand.new(str, player, $league.games)
71       when /^%%WHO/
72         cmd = WhoCommand.new(str, player, $league.players)
73       when /^LOGOUT/
74         cmd = LogoutCommand.new(str, player)
75       when /^CHALLENGE/
76         cmd = ChallengeCommand.new(str, player)
77       when /^%%SETBUOY\s+(\S+)\s+(\S+)(.*)/
78         game_name = $1
79         moves     = $2
80         count = 1 # default
81         if $3 && /^\s+(\d*)/ =~ $3
82           count = $1.to_i
83         end
84         cmd = SetBuoyCommand.new(str, player, game_name, moves, count)
85       when /^%%DELETEBUOY\s+(\S+)/
86         game_name = $1
87         cmd = DeleteBuoyCommand.new(str, player, game_name)
88       when /^%%GETBUOYCOUNT\s+(\S+)/
89         game_name = $1
90         cmd = GetBuoyCountCommand.new(str, player, game_name)
91       when /^\s*$/
92         cmd = SpaceCommand.new(str, player)
93       else
94         cmd = ErrorCommand.new(str, player)
95       end
96
97       return cmd
98     end
99
100     def initialize(str, player)
101       @str    = str
102       @player = player
103     end
104   end
105
106   # Application-level protocol for Keep-Alive.
107   # If the server receives an LF, it sends back an LF.  Note that the 30 sec
108   # rule (client may not send LF again within 30 sec) is not implemented
109   # yet.
110   #
111   class KeepAliveCommand < Command
112     def initialize(str, player)
113       super
114     end
115
116     def call
117       @player.write_safe("\n")
118       return :continue
119     end
120   end
121
122   # Command of moving a piece.
123   #
124   class MoveCommand < Command
125     def initialize(str, player)
126       super
127     end
128
129     def call
130       if (@player.status == "game")
131         array_str = @str.split(",")
132         move = array_str.shift
133         additional = array_str.shift
134         comment = nil
135         if /^'(.*)/ =~ additional
136           comment = array_str.unshift("'*#{$1.toeuc}")
137         end
138         s = @player.game.handle_one_move(move, @player)
139         @player.game.log_game(Kconv.toeuc(comment.first)) if (comment && comment.first && !s)
140         return :return if (s && @player.protocol == LoginCSA::PROTOCOL)
141       end
142       return :continue
143     end
144   end
145
146   # Command like "%TORYO" or :timeout
147   #
148   class SpecialCommand < Command
149     def initialize(str, player)
150       super
151     end
152
153     def call
154       rc = :continue
155       if (@player.status == "game")
156         rc = in_game_status()
157       elsif ["agree_waiting", "start_waiting"].include?(@player.status) 
158         rc = in_waiting_status()
159       else
160         log_error("Received a command [#{@str}] from #{@player.name} in an inappropriate status [#{@player.status}].") unless @str == :timeout
161       end
162       return rc
163     end
164
165     def in_game_status
166       rc = :continue
167
168       s = @player.game.handle_one_move(@str, @player)
169       rc = :return if (s && @player.protocol == LoginCSA::PROTOCOL)
170
171       return rc
172     end
173
174     def in_waiting_status
175       rc = :continue
176
177       if @player.game.prepared_expire?
178         log_warning("#{@player.status} lasted too long. This play has been expired: %s" % [@player.game.game_id])
179         @player.game.reject("the Server (timed out)")
180         rc = :return if (@player.protocol == LoginCSA::PROTOCOL)
181       end
182
183       return rc
184     end
185   end
186
187   # Command of :exception
188   #
189   class ExceptionCommand < Command
190     def initialize(str, player)
191       super
192     end
193
194     def call
195       log_error("Failed to receive a message from #{@player.name}.")
196       return :return
197     end
198   end
199
200   # Command of REJECT
201   #
202   class RejectCommand < Command
203     def initialize(str, player)
204       super
205     end
206
207     def call
208       if (@player.status == "agree_waiting")
209         @player.game.reject(@player.name)
210         return :return if (@player.protocol == LoginCSA::PROTOCOL)
211       else
212         log_error("Received a command [#{@str}] from #{@player.name} in an inappropriate status [#{@player.status}].")
213         @player.write_safe(sprintf("##[ERROR] you are in %s status. REJECT is valid in agree_waiting status\n", @player.status))
214       end
215       return :continue
216     end
217   end
218
219   # Command of AGREE
220   #
221   class AgreeCommand < Command
222     def initialize(str, player)
223       super
224     end
225
226     def call
227       if (@player.status == "agree_waiting")
228         @player.status = "start_waiting"
229         if (@player.game.is_startable_status?)
230           @player.game.start
231         end
232       else
233         log_error("Received a command [#{@str}] from #{@player.name} in an inappropriate status [#{@player.status}].")
234         @player.write_safe(sprintf("##[ERROR] you are in %s status. AGREE is valid in agree_waiting status\n", @player.status))
235       end
236       return :continue
237     end
238   end
239
240   # Base Command calss requiring a game instance
241   #
242   class BaseCommandForGame < Command
243     def initialize(str, player, game)
244       super(str, player)
245       @game    = game
246       @game_id = game ? game.game_id : nil
247     end
248   end
249
250   # Command of SHOW
251   #
252   class ShowCommand < BaseCommandForGame
253     def initialize(str, player, game)
254       super
255     end
256
257     def call
258       if (@game)
259         @player.write_safe(@game.show.gsub(/^/, '##[SHOW] '))
260       end
261       @player.write_safe("##[SHOW] +OK\n")
262       return :continue
263     end
264   end
265
266   # Command of MONITORON
267   #
268   class MonitorOnCommand < BaseCommandForGame
269     def initialize(str, player, game)
270       super
271     end
272
273     def call
274       if (@game)
275         @game.monitoron(@player)
276         @player.write_safe(@game.show.gsub(/^/, "##[MONITOR][#{@game_id}] "))
277         @player.write_safe("##[MONITOR][#{@game_id}] +OK\n")
278       end
279       return :continue
280     end
281   end
282
283   # Command of MONITOROFF
284   #
285   class MonitorOffCommand < BaseCommandForGame
286     def initialize(str, player, game)
287       super
288     end
289
290     def call
291       if (@game)
292         @game.monitoroff(@player)
293       end
294       return :continue
295     end
296   end
297
298   # Command of HELP
299   #
300   class HelpCommand < Command
301     def initialize(str, player)
302       super
303     end
304
305     def call
306       @player.write_safe(
307         %!##[HELP] available commands "%%WHO", "%%CHAT str", "%%GAME game_name +", "%%GAME game_name -"\n!)
308       return :continue
309     end
310   end
311
312   # Command of RATING
313   #
314   class RatingCommand < Command
315     def initialize(str, player, rated_players)
316       super(str, player)
317       @rated_players = rated_players
318     end
319
320     def call
321       @rated_players.sort {|a,b| b.rate <=> a.rate}.each do |p|
322         @player.write_safe("##[RATING] %s \t %4d @%s\n" % 
323                    [p.simple_player_id, p.rate, p.modified_at.strftime("%Y-%m-%d")])
324       end
325       @player.write_safe("##[RATING] +OK\n")
326       return :continue
327     end
328   end
329
330   # Command of VERSION
331   #
332   class VersionCommand < Command
333     def initialize(str, player)
334       super
335     end
336
337     def call
338       @player.write_safe "##[VERSION] Shogi Server revision #{ShogiServer::Revision}\n"
339       @player.write_safe("##[VERSION] +OK\n")
340       return :continue
341     end
342   end
343
344   # Command of GAME
345   #
346   class GameCommand < Command
347     def initialize(str, player)
348       super
349     end
350
351     def call
352       if ((@player.status == "connected") || (@player.status == "game_waiting"))
353         @player.status = "connected"
354         @player.game_name = ""
355       else
356         @player.write_safe(sprintf("##[ERROR] you are in %s status. GAME is valid in connected or game_waiting status\n", @player.status))
357       end
358       return :continue
359     end
360   end
361
362   # Commando of game challenge
363   # TODO make a test case
364   #
365   class GameChallengeCommand < Command
366     def initialize(str, player, command_name, game_name, my_sente_str)
367       super(str, player)
368       @command_name = command_name
369       @game_name    = game_name
370       @my_sente_str = my_sente_str
371     end
372
373     def call
374       if (! Login::good_game_name?(@game_name))
375         @player.write_safe(sprintf("##[ERROR] bad game name\n"))
376         return :continue
377       elsif ((@player.status == "connected") || (@player.status == "game_waiting"))
378         ## continue
379       else
380         @player.write_safe(sprintf("##[ERROR] you are in %s status. GAME is valid in connected or game_waiting status\n", @player.status))
381         return :continue
382       end
383
384       rival = nil
385       if (Buoy.game_name?(@game_name))
386         if (@my_sente_str != "*")
387           @player.write_safe(sprintf("##[ERROR] You are not allowed to specify TEBAN %s for the game %s\n", @my_sente_str, @game_name))
388           return :continue
389         end
390         @player.sente = nil
391       end # really end
392
393       if (League::Floodgate.game_name?(@game_name))
394         if (@my_sente_str != "*")
395           @player.write_safe(sprintf("##[ERROR] You are not allowed to specify TEBAN %s for the game %s\n", @my_sente_str, @game_name))
396           return :continue
397         end
398         @player.sente = nil
399       else
400         if (@my_sente_str == "*")
401           rival = $league.get_player("game_waiting", @game_name, nil, @player) # no preference
402         elsif (@my_sente_str == "+")
403           rival = $league.get_player("game_waiting", @game_name, false, @player) # rival must be gote
404         elsif (@my_sente_str == "-")
405           rival = $league.get_player("game_waiting", @game_name, true, @player) # rival must be sente
406         else
407           ## never reached
408           @player.write_safe(sprintf("##[ERROR] bad game option\n"))
409           return :continue
410         end
411       end
412
413       if (rival)
414         @player.game_name = @game_name
415         
416         if ((@my_sente_str == "*") && (rival.sente == nil))
417           if (rand(2) == 0)
418             @player.sente = true
419             rival.sente = false
420           else
421             @player.sente = false
422             rival.sente = true
423           end
424         elsif (rival.sente == true) # rival has higher priority
425           @player.sente = false
426         elsif (rival.sente == false)
427           @player.sente = true
428         elsif (@my_sente_str == "+")
429           @player.sente = true
430           rival.sente = false
431         elsif (@my_sente_str == "-")
432           @player.sente = false
433           rival.sente = true
434         else
435           ## never reached
436         end
437         if (Buoy.game_name?(@game_name))
438           buoy = Buoy.new # TODO config
439           if buoy.is_new_game?(@game_name)
440             # The buoy game is not ready yet.
441             # When the game is set, it will be started.
442             @player.status = "game_waiting"
443           else
444             buoy_game = buoy.get_game(@game_name)
445             if buoy_game.instance_of? NilBuoyGame
446               # error. never reach
447             end
448
449             moves_array = Board::split_moves(buoy_game.moves)
450             board = Board.new
451             begin
452               board.set_from_moves(moves_array)
453             rescue => err
454               # it will never happen since moves have already been checked
455               log_error "Failed to set up a buoy game: #{moves}"
456               return :continue
457             end
458             buoy.decrement_count(buoy_game)
459             Game::new(@player.game_name, @player, rival, board)
460           end
461         else
462           board = Board.new
463           board.initial
464           Game::new(@player.game_name, @player, rival, board)
465         end
466       else # rival not found
467         if (@command_name == "GAME")
468           @player.status = "game_waiting"
469           @player.game_name = @game_name
470           if (@my_sente_str == "+")
471             @player.sente = true
472           elsif (@my_sente_str == "-")
473             @player.sente = false
474           else
475             @player.sente = nil
476           end
477         else                # challenge
478           @player.write_safe(sprintf("##[ERROR] can't find rival for %s\n", @game_name))
479           @player.status = "connected"
480           @player.game_name = ""
481           @player.sente = nil
482         end
483       end
484       return :continue
485     end
486   end
487
488   # Command of CHAT
489   #
490   class ChatCommand < Command
491
492     # players array of [name, player]
493     #
494     def initialize(str, player, message, players)
495       super(str, player)
496       @message = message
497       @players = players
498     end
499
500     def call
501       @players.each do |name, p| # TODO player change name
502         if (p.protocol != LoginCSA::PROTOCOL)
503           p.write_safe(sprintf("##[CHAT][%s] %s\n", @player.name, @message)) 
504         end
505       end
506       return :continue
507     end
508   end
509
510   # Command of LIST
511   #
512   class ListCommand < Command
513
514     # games array of [game_id, game]
515     #
516     def initialize(str, player, games)
517       super(str, player)
518       @games = games
519     end
520
521     def call
522       buf = Array::new
523       @games.each do |id, game|
524         buf.push(sprintf("##[LIST] %s\n", id))
525       end
526       buf.push("##[LIST] +OK\n")
527       @player.write_safe(buf.join)
528       return :continue
529     end
530   end
531
532   # Command of WHO
533   #
534   class WhoCommand < Command
535
536     # players array of [[name, player]]
537     #
538     def initialize(str, player, players)
539       super(str, player)
540       @players = players
541     end
542
543     def call
544       buf = Array::new
545       @players.each do |name, p|
546         buf.push(sprintf("##[WHO] %s\n", p.to_s))
547       end
548       buf.push("##[WHO] +OK\n")
549       @player.write_safe(buf.join)
550       return :continue
551     end
552   end
553
554   # Command of LOGOUT
555   #
556   class LogoutCommand < Command
557     def initialize(str, player)
558       super
559     end
560
561     def call
562       @player.status = "connected"
563       @player.write_safe("LOGOUT:completed\n")
564       return :return
565     end
566   end
567
568   # Command of CHALLENGE
569   #
570   class ChallengeCommand < Command
571     def initialize(str, player)
572       super
573     end
574
575     def call
576       # This command is only available for CSA's official testing server.
577       # So, this means nothing for this program.
578       @player.write_safe("CHALLENGE ACCEPTED\n")
579       return :continue
580     end
581   end
582
583   # Command for a space
584   #
585   class SpaceCommand < Command
586     def initialize(str, player)
587       super
588     end
589
590     def call
591       ## ignore null string
592       return :continue
593     end
594   end
595
596   # Command for an error
597   #
598   class ErrorCommand < Command
599     def initialize(str, player)
600       super
601     end
602
603     def call
604       msg = "##[ERROR] unknown command %s\n" % [@str]
605       @player.write_safe(msg)
606       log_error(msg)
607       return :continue
608     end
609   end
610
611   #
612   #
613   class SetBuoyCommand < Command
614
615     def initialize(str, player, game_name, moves, count)
616       super(str, player)
617       @game_name = game_name
618       @moves     = moves
619       @count     = count
620     end
621
622     def call
623       unless (Buoy.game_name?(@game_name))
624         @player.write_safe(sprintf("##[ERROR] wrong buoy game name: %s\n", @game_name))
625         log_error "Received a wrong buoy game name: %s from %s." % [@game_name, @player.name]
626         return :continue
627       end
628       buoy = Buoy.new
629       unless buoy.is_new_game?(@game_name)
630         @player.write_safe(sprintf("##[ERROR] duplicated buoy game name: %s\n", @game_name))
631         log_error "Received duplicated buoy game name: %s from %s." % [@game_name, @player.name]
632         return :continue
633       end
634       if @count < 1
635         @player.write_safe(sprintf("##[ERROR] invalid count: %s\n", @count))
636         log_error "Received an invalid count for a buoy game: %s, %s from %s." % [@count, @game_name, @player.name]
637         return :continue
638       end
639
640       # check moves
641       moves_array = Board::split_moves(@moves)
642       board = Board.new
643       begin
644         board.set_from_moves(moves_array)
645       rescue
646         raise WrongMoves
647       end
648
649       buoy_game = BuoyGame.new(@game_name, @moves, @player.name, @count)
650       buoy.add_game(buoy_game)
651       @player.write_safe(sprintf("##[SETBUOY] +OK\n"))
652       log_info("A buoy game was created: %s by %s" % [@game_name, @player.name])
653
654       # if two players, who are not @player, are waiting for a new game, start it
655       p1 = $league.get_player("game_waiting", @game_name, true, @player)
656       return :continue unless p1
657       p2 = $league.get_player("game_waiting", @game_name, false, @player)
658       return :continue unless p2
659
660       buoy.decrement_count(buoy_game)
661       game = Game::new(@game_name, p1, p2, board)
662       return :continue
663     rescue WrongMoves => e
664       @player.write_safe(sprintf("##[ERROR] wrong moves: %s\n", @moves))
665       log_error "Received wrong moves: %s from %s. [%s]" % [@moves, @player.name, e.message]
666       return :continue
667     end
668   end
669
670   #
671   #
672   class DeleteBuoyCommand < Command
673     def initialize(str, player, game_name)
674       super(str, player)
675       @game_name = game_name
676     end
677
678     def call
679       buoy = Buoy.new
680       buoy_game = buoy.get_game(@game_name)
681       if buoy_game.instance_of?(NilBuoyGame)
682         @player.write_safe(sprintf("##[ERROR] buoy game not found: %s\n", @game_name))
683         log_error "Game name not found: %s by %s" % [@game_name, @player.name]
684         return :continue
685       end
686
687       if buoy_game.owner != @player.name
688         @player.write_safe(sprintf("##[ERROR] you are not allowed to delete a buoy game that you did not set: %s\n", @game_name))
689         log_error "%s are not allowed to delete a game: %s" % [@player.name, @game_name]
690         return :continue
691       end
692
693       buoy.delete_game(buoy_game)
694       @player.write_safe(sprintf("##[DELETEBUOY] +OK\n"))
695       log_info("A buoy game was deleted: %s" % [@game_name])
696       return :continue
697     end
698   end
699
700   #
701   #
702   class GetBuoyCountCommand < Command
703     def initialize(str, player, game_name)
704       super(str, player)
705       @game_name = game_name
706     end
707
708     def call
709       buoy = Buoy.new
710       buoy_game = buoy.get_game(@game_name)
711       if buoy_game.instance_of?(NilBuoyGame)
712         @player.write_safe("##[GETBUOYCOUNT] -1\n")
713       else
714         @player.write_safe("##[GETBUOYCOUNT] %s\n" % [buoy_game.count])
715       end
716       @player.write_safe("##[GETBUOYCOUNT] +OK\n")
717     end
718   end
719
720 end # module ShogiServer