OSDN Git Service

e9eb01dff2bef83d208b81961c16c6c85147263e
[shogi-server/shogi-server.git] / shogi-server
1 #! /usr/bin/env ruby
2 ## -*-Ruby-*- $RCSfile$ $Revision$ $Name$
3
4 ## Copyright (C) 2004 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           ((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     finish
137     Thread::kill(@main_thread) if @main_thread
138   end
139
140   def finish
141     if (@status != "finished")
142       @status = "finished"
143       log_message(sprintf("user %s finish", @name))    
144       Thread::kill(@writer_thread) if @writer_thread
145       begin
146         @socket.close if (! @socket.closed?)
147       rescue
148         log_message(sprintf("user %s finish failed", @name))    
149       end
150     end
151   end
152
153   def write_safe(str)
154     @write_queue.push(str.gsub(/[\r\n]+/, @eol))
155   end
156
157   def writer
158     while (str = @write_queue.pop)
159       @socket.write_safe(str)
160     end
161   end
162
163   def to_s
164     if ((status == "game_waiting") ||
165         (status == "start_waiting") ||
166         (status == "agree_waiting") ||
167         (status == "game"))
168       if (@sente)
169         return sprintf("%s %s %s %s +", @name, @protocol, @status, @game_name)
170       elsif (@sente == false)
171         return sprintf("%s %s %s %s -", @name, @protocol, @status, @game_name)
172       elsif (@sente == nil)
173         return sprintf("%s %s %s %s +-", @name, @protocol, @status, @game_name)
174       end
175     else
176       return sprintf("%s %s %s", @name, @protocol, @status)
177     end
178   end
179
180   def write_help
181     @socket.write_safe('##[HELP] available commands "%%WHO", "%%CHAT str", "%%GAME game_name +", "%%GAME game_name -"')
182   end
183
184   def login(str)
185     str =~ /([\r\n]*)$/
186     @eol = $1
187     str.chomp!
188     (login, @name, @password, ext) = str.split
189     if (ext)
190       @protocol = "x1"
191     else
192       @protocol = "CSA"
193     end
194     @main_thread = Thread::current
195     @writer_thread = Thread::start do
196       writer()
197     end
198   end
199     
200   def run
201     write_safe(sprintf("LOGIN:%s OK\n", @name))
202     if (@protocol != "CSA")
203       log_message(sprintf("user %s run in %s mode", @name, @protocol))
204       write_safe(sprintf("##[LOGIN] +OK %s\n", @protocol))
205     else
206       log_message(sprintf("user %s run in CSA mode", @name))
207       csa_1st_str = "%%GAME #{Default_Game_Name} +-"
208     end
209     
210     while (csa_1st_str || (str = @socket.gets_safe(Default_Timeout)))
211       begin
212         $mutex.lock
213         if (csa_1st_str)
214           str = csa_1st_str
215           csa_1st_str = nil
216         end
217         if (@write_queue.size > Max_Write_Queue_Size)
218           log_warning(sprintf("write_queue of %s is %d", @name, @write_queue.size))
219           return
220         end
221
222         if (@status == "finished")
223           return
224         end
225         str.chomp! if (str.class == String)
226         case str
227         when /^[\+\-%][^%]/, :timeout
228           if (@status == "game")
229             s = @game.handle_one_move(str, self)
230             return if (s && @protocol == "CSA")
231           end
232         when /^REJECT/
233           if (@status == "agree_waiting")
234             @game.reject(@name)
235             return if (@protocol == "CSA")
236           else
237             write_safe(sprintf("##[ERROR] you are in %s status. AGREE is valid in agree_waiting status\n", @status))
238           end
239         when /^AGREE/
240           if (@status == "agree_waiting")
241             @status = "start_waiting"
242             if ((@game.sente.status == "start_waiting") &&
243                 (@game.gote.status == "start_waiting"))
244               @game.start
245               @game.sente.status = "game"
246               @game.gote.status = "game"
247             end
248           else
249             write_safe(sprintf("##[ERROR] you are in %s status. AGREE is valid in agree_waiting status\n", @status))
250           end
251         when /^%%SHOW\s+(\S+)/
252           game_id = $1
253           if (LEAGUE.games[game_id])
254             write_safe(LEAGUE.games[game_id].show.gsub(/^/, '##[SHOW] '))
255           end
256           write_safe("##[SHOW] +OK\n")
257         when /^%%MONITORON\s+(\S+)/
258           game_id = $1
259           if (LEAGUE.games[game_id])
260             LEAGUE.games[game_id].monitoron(self)
261             write_safe(LEAGUE.games[game_id].show.gsub(/^/, "##[MONITOR][#{game_id}] "))
262             write_safe("##[MONITOR][#{game_id}] +OK\n")
263           end
264         when /^%%MONITOROFF\s+(\S+)/
265           game_id = $1
266           if (LEAGUE.games[game_id])
267             LEAGUE.games[game_id].monitoroff(self)
268           end
269         when /^%%HELP/
270           write_help
271         when /^%%GAME\s+(\S+)\s+([\+\-])/
272           game_name = $1
273           sente_str = $2
274           if (! good_game_name?(game_name))
275             write_safe(sprintf("##[ERROR] bad game name\n"))
276           elsif ((@status == "connected") || (@status == "game_waiting"))
277             @status = "game_waiting"
278           else
279             write_safe(sprintf("##[ERROR] you are in %s status. GAME is valid in connected or game_waiting status\n", @status))
280           end
281           @status = "game_waiting"
282           @game_name = $1
283           if (sente_str == "+")
284             @sente = true
285             rival_sente = false
286           elsif (sente_str == "-")
287             @sente = false
288             rival_sente = true
289           else
290             @sente = nil
291             rival_sente = nil
292           end
293           rival = LEAGUE.get_player("game_waiting", @game_name, rival_sente, self)
294           rival = LEAGUE.get_player("game_waiting", @game_name, nil, self) if (! rival)
295           if (rival)
296             if (@sente == nil)
297               if (rand(2) == 0)
298                 @sente = true
299                 rival_sente = false
300               else
301                 @sente = false
302                 rival_sente = true
303               end
304             elsif (rival_sente == nil)
305               if (@sente)
306                 rival_sente = false
307               else
308                 rival_sente = true
309               end
310             end
311             rival.sente = rival_sente
312             Game::new(@game_name, self, rival)
313             self.status = "agree_waiting"
314             rival.status = "agree_waiting"
315           end
316         when /^%%CHAT\s+(.+)/
317           message = $1
318           LEAGUE.players.each do |name, player|
319             if (player.protocol != "CSA")
320               s = player.write_safe(sprintf("##[CHAT][%s] %s\n", @name, message)) 
321               player.status = "zombie" if (! s)
322             end
323           end
324         when /^%%LIST/
325           buf = Array::new
326           LEAGUE.games.each do |id, game|
327             buf.push(sprintf("##[LIST] %s\n", id))
328           end
329           buf.push("##[LIST] +OK\n")
330           write_safe(buf.join)
331         when /^%%WHO/
332           buf = Array::new
333           LEAGUE.players.each do |name, player|
334             buf.push(sprintf("##[WHO] %s\n", player.to_s))
335           end
336           buf.push("##[WHO] +OK\n")
337           write_safe(buf.join)
338         when /^LOGOUT/
339           @status = "connected"
340           write_safe("LOGOUT:completed\n")
341           return
342         when /^\s*$/
343           ## ignore null string
344         else
345           write_safe(sprintf("##[ERROR] unknown command %s\n", str))
346         end
347       ensure
348         $mutex.unlock
349       end
350     end                         # enf of while
351   end
352 end
353
354 class Piece
355   PROMOTE = {"FU" => "TO", "KY" => "NY", "KE" => "NK", "GI" => "NG", "KA" => "UM", "HI" => "RY"}
356   def initialize(name, sente)
357     @name = name
358     @sente = sente
359     @promoted = false
360   end
361   attr_accessor :name, :promoted, :sente
362
363   def promoted_name
364     PROMOTE[name]
365   end
366
367   def to_s
368     if (@sente)
369       sg = "+"
370     else
371       sg = "-"
372     end
373     if (@promoted)
374       n = PROMOTE[@name]
375     else
376       n = @name
377     end
378     return sg + n
379   end
380 end
381
382
383
384 class Board
385   def initialize
386     @sente_hands = Array::new
387     @gote_hands = Array::new
388     @history = Hash::new
389     @array = [[], [], [], [], [], [], [], [], [], []]
390   end
391   attr_accessor :array, :sente_hands, :gote_hands, :history
392
393   def initial
394     @array[1][1] = Piece::new("KY", false)
395     @array[2][1] = Piece::new("KE", false)
396     @array[3][1] = Piece::new("GI", false)
397     @array[4][1] = Piece::new("KI", false)
398     @array[5][1] = Piece::new("OU", false)
399     @array[6][1] = Piece::new("KI", false)
400     @array[7][1] = Piece::new("GI", false)
401     @array[8][1] = Piece::new("KE", false)
402     @array[9][1] = Piece::new("KY", false)
403     @array[2][2] = Piece::new("KA", false)
404     @array[8][2] = Piece::new("HI", false)
405     @array[1][3] = Piece::new("FU", false)
406     @array[2][3] = Piece::new("FU", false)
407     @array[3][3] = Piece::new("FU", false)
408     @array[4][3] = Piece::new("FU", false)
409     @array[5][3] = Piece::new("FU", false)
410     @array[6][3] = Piece::new("FU", false)
411     @array[7][3] = Piece::new("FU", false)
412     @array[8][3] = Piece::new("FU", false)
413     @array[9][3] = Piece::new("FU", false)
414
415     @array[1][9] = Piece::new("KY", true)
416     @array[2][9] = Piece::new("KE", true)
417     @array[3][9] = Piece::new("GI", true)
418     @array[4][9] = Piece::new("KI", true)
419     @array[5][9] = Piece::new("OU", true)
420     @array[6][9] = Piece::new("KI", true)
421     @array[7][9] = Piece::new("GI", true)
422     @array[8][9] = Piece::new("KE", true)
423     @array[9][9] = Piece::new("KY", true)
424     @array[2][8] = Piece::new("HI", true)
425     @array[8][8] = Piece::new("KA", true)
426     @array[1][7] = Piece::new("FU", true)
427     @array[2][7] = Piece::new("FU", true)
428     @array[3][7] = Piece::new("FU", true)
429     @array[4][7] = Piece::new("FU", true)
430     @array[5][7] = Piece::new("FU", true)
431     @array[6][7] = Piece::new("FU", true)
432     @array[7][7] = Piece::new("FU", true)
433     @array[8][7] = Piece::new("FU", true)
434     @array[9][7] = Piece::new("FU", true)
435   end
436
437   def have_piece?(hands, name)
438     p = hands.find { |i|
439       i.name == name
440     }
441     return p
442   end
443
444   def get_piece_from_hands(hands, name)
445     p = hands.find { |i|
446       i.name == name
447     }
448     if (p)
449       hands.delete(p)
450     end
451     return p
452   end
453
454   def handle_one_move(str)
455     if (str =~ /^([\+\-])(\d)(\d)(\d)(\d)([A-Z]{2})/)
456       p = $1
457       x0 = $2.to_i
458       y0 = $3.to_i
459       x1 = $4.to_i
460       y1 = $5.to_i
461       name = $6
462     elsif (str =~ /^%KACHI/)
463       return :kachi
464     elsif (str =~ /^%TORYO/)
465       return :toryo
466     else
467       return :illegal
468     end
469     
470     if (((x0 == 0) || (y0 == 0)) && # source is not from hand
471         ((x0 != 0) || (y0 != 0)))
472       return :illegal
473     elsif ((x1 == 0) || (y1 == 0)) # destination is out of board
474       return :illegal
475     end
476     
477     if (p == "+")
478       sente = true
479       hands = @sente_hands
480     else
481       sente = false
482       hands = @gote_hands
483     end
484     
485     ## source check
486     if ((x0 == 0) && (y0 == 0))
487       return :illegal if (! have_piece?(hands, name))
488     elsif (! @array[x0][y0])
489       return :illegal           # no piece
490     elsif (@array[x0][y0].sente != sente)
491       return :illegal           # this is not mine
492     elsif (@array[x0][y0].name != name)
493       return :illegal if (@array[x0][y0].promoted_name != name) # can't promote
494     end
495     
496     ## destination check
497     if (@array[x1][y1] &&
498         (@array[x1][y1].sente == sente)) # can't capture mine
499       return :illegal
500     elsif ((x0 == 0) && (y0 == 0) && @array[x1][y1])
501       return :illegal           # can't put on existing piece
502     end
503
504     if ((x0 == 0) && (y0 == 0))
505       p = get_piece_from_hands(hands, name)
506       @array[x1][y1] = p
507       p.sente = sente
508       p.promoted = false
509     else
510       if (@array[x0][y0].name != name) # promoted ?
511         @array[x0][y0].promoted = true
512       end
513       if (@array[x1][y1])
514         if (@array[x1][y1].name == "OU")
515           return :outori        # return board update
516         end
517         hands.push(@array[x1][y1])
518         hands.sort! {|a, b|
519           a.name <=> b.name
520         }
521       end
522       @array[x1][y1] = @array[x0][y0]
523       @array[x0][y0] = nil
524     end
525
526     ## sennichite check
527     str = to_s
528     @history[str] = (@history[str] || 0) + 1
529     if (@history[str] >= 4)
530       return :sennichite
531     end
532
533     return :normal             # legal move
534   end
535
536   def to_s
537     a = Array::new
538     y = 1
539     while (y <= 9)
540       a.push(sprintf("P%d", y))
541       x = 9
542       while (x >= 1)
543         piece = @array[x][y]
544         if (piece)
545           s = piece.to_s
546         else
547           s = " * "
548         end
549         a.push(s)
550         x = x - 1
551       end
552       a.push(sprintf("\n"))
553       y = y + 1
554     end
555     if (! sente_hands.empty?)
556       a.push("P+")
557       sente_hands.each do |p|
558         a.push("00" + p.name)
559       end
560       a.push("\n")
561     end
562     if (! gote_hands.empty?)
563       a.push("P-")
564       gote_hands.each do |p|
565         a.push("00" + p.name)
566       end
567       a.push("\n")
568     end
569     a.push("+\n")
570     return a.join
571   end
572 end
573
574 class Game
575   def initialize(game_name, player0, player1)
576     @monitors = Array::new
577     @game_name = game_name
578     if (@game_name =~ /-(\d+)-(\d+)$/)
579       @total_time = $1.to_i
580       @byoyomi = $2.to_i
581     end
582
583     if (player0.sente)
584       @sente = player0
585       @gote = player1
586     else
587       @sente = player1
588       @gote = player0
589     end
590     @current_player = @sente
591     @next_player = @gote
592
593     @sente.game = self
594     @gote.game = self
595
596     @last_move = ""
597     @current_turn = 0
598
599     @sente.status = "agree_waiting"
600     @gote.status = "agree_waiting"
601     @id = sprintf("%s+%s+%s+%s+%s", 
602                   LEAGUE.event, @game_name, @sente.name, @gote.name,
603                   Time::new.strftime("%Y%m%d%H%M%S"))
604
605     LEAGUE.games[@id] = self
606
607
608     log_message(sprintf("game created %s %s %s", game_name, sente.name, gote.name))
609
610     @logfile = @id + ".csa"
611     @board = Board::new
612     @board.initial
613     @start_time = nil
614     @fh = nil
615
616     propose
617   end
618   attr_accessor :game_name, :total_time, :byoyomi, :sente, :gote, :id, :board, :current_player, :next_player, :fh, :monitors
619   attr_accessor :last_move, :current_turn
620
621   def monitoron(monitor)
622     @monitors.delete(monitor)
623     @monitors.push(monitor)
624   end
625
626   def monitoroff(monitor)
627     @monitors.delete(monitor)
628   end
629
630   def reject(rejector)
631     @sente.write_safe(sprintf("REJECT:%s by %s\n", @id, rejector))
632     @gote.write_safe(sprintf("REJECT:%s by %s\n", @id, rejector))
633     finish
634   end
635
636   def kill(killer)
637     if ((@sente.status == "agree_waiting") || (@sente.status == "start_waiting"))
638       reject(killer.name)
639     elsif (@current_player == killer)
640       abnormal_lose()
641       finish
642     end
643   end
644
645   def finish
646     log_message(sprintf("game finished %s %s %s", game_name, sente.name, gote.name))
647     @fh.printf("'$END_TIME:%s\n", Time::new.strftime("%Y/%m/%d %H:%M:%S"))    
648     @fh.close
649
650     @sente.game = nil
651     @gote.game = nil
652     @sente.status = "connected"
653     @gote.status = "connected"
654
655     if (@current_player.protocol == "CSA")
656       @current_player.finish
657     end
658     if (@next_player.protocol == "CSA")
659       @next_player.finish
660     end
661     @monitors = Array::new
662     @sente = nil
663     @gote = nil
664     @current_player = nil
665     @next_player = nil
666     LEAGUE.games.delete(@id)
667   end
668
669   def handle_one_move(str, player)
670     finish_flag = true
671     if (@current_player == player)
672       @end_time = Time::new
673       t = (@end_time - @start_time).ceil
674       t = Least_Time_Per_Move if (t < Least_Time_Per_Move)
675       
676       move_status = nil
677       if ((@current_player.mytime - t <= 0) && (@total_time > 0))
678         status = :timeout
679       elsif (str == :timeout)
680         return false            # time isn't expired. players aren't swapped. continue game
681       else
682         begin
683           move_status = @board.handle_one_move(str)
684         rescue
685           log_error("handle_one_move raise exception for #{str}")
686           move_status = :illegal
687         end
688         if (move_status == :illegal)
689           @fh.printf("'ILLEGAL_MOVE(%s)\n", str)
690         else
691           if ((move_status == :normal) || (move_status == :outori) || (move_status == :sennichite))
692             @sente.write_safe(sprintf("%s,T%d\n", str, t))
693             @gote.write_safe(sprintf("%s,T%d\n", str, t))
694             @fh.printf("%s\nT%d\n", str, t)
695             @last_move = sprintf("%s,T%d", str, t)
696             @current_turn = @current_turn + 1
697           end
698           @monitors.each do |monitor|
699             monitor.write_safe(show.gsub(/^/, "##[MONITOR][#{@id}] "))
700             monitor.write_safe(sprintf("##[MONITOR][%s] +OK\n", @id))
701           end
702         end
703       end
704
705       if (@current_player.mytime - t < @byoyomi)
706         @current_player.mytime = @byoyomi
707       else
708         @current_player.mytime = @current_player.mytime - t
709       end
710
711       if (@next_player.status != "game") # rival is logout or disconnected
712         abnormal_win()
713       elsif (status == :timeout)
714         timeout_lose()
715       elsif (move_status == :illegal)
716         illegal_lose()
717       elsif (move_status == :kachi)
718         kachi_win()
719       elsif (move_status == :toryo)
720         toryo_lose()
721       elsif (move_status == :outori)
722         outori_win()
723       elsif (move_status == :sennichite)
724         sennichite_draw()
725       else
726         finish_flag = false
727       end
728       finish() if finish_flag
729       (@current_player, @next_player) = [@next_player, @current_player]
730       @start_time = Time::new
731       return finish_flag
732     end
733   end
734
735   def abnormal_win
736     @current_player.status = "connected"
737     @next_player.status = "connected"
738     @current_player.write_safe("%TORYO\n#RESIGN\n#WIN\n")
739     @next_player.write_safe("%TORYO\n#RESIGN\n#LOSE\n")
740     @fh.printf("%%TORYO\n")
741     @fh.printf("'summary:abnormal:%s win:%s lose\n", @current_player.name, @next_player.name)
742     @monitors.each do |monitor|
743       monitor.write_safe(sprintf("##[MONITOR][%s] %%TORYO\n", @id))
744     end
745   end
746
747   def abnormal_lose
748     @current_player.status = "connected"
749     @next_player.status = "connected"
750     @current_player.write_safe("%TORYO\n#RESIGN\n#LOSE\n")
751     @next_player.write_safe("%TORYO\n#RESIGN\n#WIN\n")
752     @fh.printf("%%TORYO\n")
753     @fh.printf("'summary:abnormal:%s lose:%s win\n", @current_player.name, @next_player.name)
754     @monitors.each do |monitor|
755       monitor.write_safe(sprintf("##[MONITOR][%s] %%TORYO\n", @id))
756     end
757   end
758
759   def sennichite_draw
760     @current_player.status = "connected"
761     @next_player.status = "connected"
762     @current_player.write_safe("#SENNICHITE\n#DRAW\n")
763     @next_player.write_safe("#SENNICHITE\n#DRAW\n")
764     @fh.printf("'summary:sennichite:%s draw:%s draw\n", @current_player.name, @next_player.name)
765     @monitors.each do |monitor|
766       monitor.write_safe(sprintf("##[MONITOR][%s] #SENNICHITE\n", @id))
767     end
768   end
769
770   def illegal_lose
771     @current_player.status = "connected"
772     @next_player.status = "connected"
773     @current_player.write_safe("#ILLEGAL_MOVE\n#LOSE\n")
774     @next_player.write_safe("#ILLEGAL_MOVE\n#WIN\n")
775     @fh.printf("'summary:illegal move:%s lose:%s win\n", @current_player.name, @next_player.name)
776     @monitors.each do |monitor|
777       monitor.write_safe(sprintf("##[MONITOR][%s] #ILLEGAL_MOVE\n", @id))
778     end
779   end
780
781   def timeout_lose
782     @current_player.status = "connected"
783     @next_player.status = "connected"
784     @current_player.write_safe("#TIME_UP\n#LOSE\n")
785     @next_player.write_safe("#TIME_UP\n#WIN\n")
786     @fh.printf("'summary:time up:%s lose:%s win\n", @current_player.name, @next_player.name)
787     @monitors.each do |monitor|
788       monitor.write_safe(sprintf("##[MONITOR][%s] #TIME_UP\n", @id))
789     end
790   end
791
792   def kachi_win
793     @current_player.status = "connected"
794     @next_player.status = "connected"
795     @current_player.write_safe("%KACHI\n#JISHOGI\n#WIN\n")
796     @next_player.write_safe("%KACHI\n#JISHOGI\n#LOSE\n")
797     @fh.printf("%%KACHI\n")
798     @fh.printf("'summary:kachi:%s win:%s lose\n", @current_player.name, @next_player.name)
799     @monitors.each do |monitor|
800       monitor.write_safe(sprintf("##[MONITOR][%s] %%KACHI\n", @id))
801     end
802   end
803
804   def toryo_lose
805     @current_player.status = "connected"
806     @next_player.status = "connected"
807     @current_player.write_safe("%TORYO\n#RESIGN\n#LOSE\n")
808     @next_player.write_safe("%TORYO\n#RESIGN\n#WIN\n")
809     @fh.printf("%%TORYO\n")
810     @fh.printf("'summary:toryo:%s lose:%s win\n", @current_player.name, @next_player.name)
811     @monitors.each do |monitor|
812       monitor.write_safe(sprintf("##[MONITOR][%s] %%TORYO\n", @id))
813     end
814   end
815
816   def outori_win
817     @current_player.status = "connected"
818     @next_player.status = "connected"
819     @current_player.write_safe("#ILLEGAL_MOVE\n#WIN\n")
820     @next_player.write_safe("#ILLEGAL_MOVE\n#LOSE\n")
821     @fh.printf("'summary:outori:%s win:%s lose\n", @current_player.name, @next_player.name)
822     @monitors.each do |monitor|
823       monitor.write_safe(sprintf("##[MONITOR][%s] #ILLEGAL_MOVE\n", @id))
824     end
825   end
826
827   def start
828     log_message(sprintf("game started %s %s %s", game_name, sente.name, gote.name))
829     @sente.write_safe(sprintf("START:%s\n", @id))
830     @gote.write_safe(sprintf("START:%s\n", @id))
831     @sente.mytime = @total_time
832     @gote.mytime = @total_time
833     @start_time = Time::new
834   end
835
836   def propose
837     begin
838       @fh = open(@logfile, "w")
839       @fh.sync = true
840
841       @fh.printf("V2\n")
842       @fh.printf("N+%s\n", @sente.name)
843       @fh.printf("N-%s\n", @gote.name)
844       @fh.printf("$EVENT:%s\n", @id)
845
846       @sente.write_safe(propose_message("+"))
847       @gote.write_safe(propose_message("-"))
848
849       @fh.printf("$START_TIME:%s\n", Time::new.strftime("%Y/%m/%d %H:%M:%S"))
850       @fh.print <<EOM
851 P1-KY-KE-GI-KI-OU-KI-GI-KE-KY
852 P2 * -HI *  *  *  *  * -KA * 
853 P3-FU-FU-FU-FU-FU-FU-FU-FU-FU
854 P4 *  *  *  *  *  *  *  *  * 
855 P5 *  *  *  *  *  *  *  *  * 
856 P6 *  *  *  *  *  *  *  *  * 
857 P7+FU+FU+FU+FU+FU+FU+FU+FU+FU
858 P8 * +KA *  *  *  *  * +HI * 
859 P9+KY+KE+GI+KI+OU+KI+GI+KE+KY
860 +
861 EOM
862     end
863   end
864
865   def show()
866     str0 = <<EOM
867 BEGIN Game_Summary
868 Protocol_Version:1.0
869 Protocol_Mode:Server
870 Format:Shogi 1.0
871 Game_ID:#{@id}
872 Name+:#{@sente.name}
873 Name-:#{@gote.name}
874 Rematch_On_Draw:NO
875 To_Move:+
876 BEGIN Time
877 Time_Unit:1sec
878 Total_Time:#{@total_time}
879 Byoyomi:#{@byoyomi}
880 Least_Time_Per_Move:#{Least_Time_Per_Move}
881 Remaining_Time+:#{@sente.mytime}
882 Remaining_Time-:#{@gote.mytime}
883 Last_Move:#{@last_move}
884 Current_Turn:#{@current_turn}
885 END Time
886 BEGIN Position
887 Jishogi_Declaration:1.1
888 EOM
889
890     str1 = <<EOM
891 END Position
892 END Game_Summary
893 EOM
894
895     return str0 + @board.to_s + str1
896   end
897
898   def propose_message(sg_flag)
899     str = <<EOM
900 BEGIN Game_Summary
901 Protocol_Version:1.0
902 Protocol_Mode:Server
903 Format:Shogi 1.0
904 Game_ID:#{@id}
905 Name+:#{@sente.name}
906 Name-:#{@gote.name}
907 Your_Turn:#{sg_flag}
908 Rematch_On_Draw:NO
909 To_Move:+
910 BEGIN Time
911 Time_Unit:1sec
912 Total_Time:#{@total_time}
913 Byoyomi:#{@byoyomi}
914 Least_Time_Per_Move:#{Least_Time_Per_Move}
915 END Time
916 BEGIN Position
917 Jishogi_Declaration:1.1
918 P1-KY-KE-GI-KI-OU-KI-GI-KE-KY
919 P2 * -HI *  *  *  *  * -KA * 
920 P3-FU-FU-FU-FU-FU-FU-FU-FU-FU
921 P4 *  *  *  *  *  *  *  *  * 
922 P5 *  *  *  *  *  *  *  *  * 
923 P6 *  *  *  *  *  *  *  *  * 
924 P7+FU+FU+FU+FU+FU+FU+FU+FU+FU
925 P8 * +KA *  *  *  *  * +HI * 
926 P9+KY+KE+GI+KI+OU+KI+GI+KE+KY
927 P+
928 P-
929 +
930 END Position
931 END Game_Summary
932 EOM
933     return str
934   end
935 end
936
937 def usage
938     print <<EOM
939 NAME
940         shogi-server - server for CSA server protocol
941
942 SYNOPSIS
943         shogi-server event_name port_number
944
945 DESCRIPTION
946         server for CSA server protocol
947
948 OPTIONS
949         --pid-file file
950                 specify filename for logging process ID
951
952 LICENSE
953         this file is distributed under GPL version2 and might be compiled by Exerb
954
955 SEE ALSO
956
957 RELEASE
958         #{Release}
959
960 REVISION
961         #{Revision}
962 EOM
963 end
964
965 def log_message(str)
966   printf("%s message: %s\n", Time::new.to_s, str)
967 end
968
969 def log_warning(str)
970   printf("%s warning: %s\n", Time::new.to_s, str)
971 end
972
973 def log_error(str)
974   printf("%s error: %s\n", Time::new.to_s, str)
975 end
976
977
978 def parse_command_line
979   options = Hash::new
980   parser = GetoptLong.new
981   parser.ordering = GetoptLong::REQUIRE_ORDER
982   parser.set_options(
983                      ["--pid-file", GetoptLong::REQUIRED_ARGUMENT])
984
985   parser.quiet = true
986   begin
987     parser.each_option do |name, arg|
988       name.sub!(/^--/, '')
989       options[name] = arg.dup
990     end
991   rescue
992     usage
993     raise parser.error_message
994   end
995   return options
996 end
997
998 def good_game_name?(str)
999   if ((str =~ /^(.+)-\d+-\d+$/) &&
1000       (good_identifier?($1)))
1001     return true
1002   else
1003     return false
1004   end
1005 end
1006
1007 def good_identifier?(str)
1008   if ((str =~ /\A[\w\d_@\-\.]+\z/) &&
1009       (str.length < Max_Identifier_Length))
1010     return true
1011   else
1012     return false
1013   end
1014 end
1015
1016 def good_login?(str)
1017   tokens = str.split
1018   if (((tokens.length == 3) || ((tokens.length == 4) && tokens[3] == "x1")) &&
1019       (tokens[0] == "LOGIN") &&
1020       (good_identifier?(tokens[1])))
1021     return true
1022   else
1023     return false
1024   end
1025 end
1026
1027 def  write_pid_file(file)
1028   open(file, "w") do |fh|
1029     fh.print Process::pid, "\n"
1030   end
1031 end
1032
1033 def mutex_watchdog(mutex, sec)
1034   while true
1035     begin
1036       timeout(sec) do
1037         mutex.lock
1038         mutex.unlock
1039       end
1040       sleep(sec)
1041     rescue TimeoutError
1042       log_error("mutex watchdog timeout")
1043       exit(1)
1044     end
1045   end
1046 end
1047
1048 def main
1049   $mutex = Mutex::new
1050   Thread::start do
1051     mutex_watchdog($mutex, 10)
1052   end
1053
1054   $options = parse_command_line
1055   if (ARGV.length != 2)
1056     usage
1057     exit 2
1058   end
1059
1060   LEAGUE.event = ARGV.shift
1061   port = ARGV.shift
1062
1063   write_pid_file($options["pid-file"]) if ($options["pid-file"])
1064
1065
1066   Thread.abort_on_exception = true
1067
1068   server = TCPserver.open(port)
1069   log_message("server started")
1070
1071   while true
1072     Thread::start(server.accept) do |client|
1073       client.sync = true
1074       player = nil
1075       while (str = client.gets_timeout(Login_Time))
1076         begin
1077           $mutex.lock
1078           str =~ /([\r\n]*)$/
1079           eol = $1
1080           if (good_login?(str))
1081             player = Player::new(str, client)
1082             if (LEAGUE.players[player.name])
1083               if ((LEAGUE.players[player.name].password == player.password) &&
1084                   (LEAGUE.players[player.name].status != "game"))
1085                 log_message(sprintf("user %s login forcely", player.name))
1086                 LEAGUE.players[player.name].kill
1087               else
1088                 client.write_safe("LOGIN:incorrect" + eol)
1089                 client.write_safe(sprintf("username %s is already connected%s", player.name, eol)) if (str.split.length >= 4)
1090                 client.close
1091                 Thread::exit
1092               end
1093             end
1094             LEAGUE.add(player)
1095             break
1096           else
1097             client.write_safe("LOGIN:incorrect" + eol)
1098             client.write_safe("type 'LOGIN name password' or 'LOGIN name password x1'" + eol) if (str.split.length >= 4)
1099           end
1100         ensure
1101           $mutex.unlock
1102         end
1103       end                       # login loop
1104       if (! player)
1105         client.close
1106         Thread::exit
1107       end
1108       log_message(sprintf("user %s login", player.name))
1109       player.run
1110       begin
1111         $mutex.lock
1112         if (player.game)
1113           player.game.kill(player)
1114         end
1115         player.finish
1116         LEAGUE.delete(player)
1117         log_message(sprintf("user %s logout", player.name))
1118       ensure
1119         $mutex.unlock
1120       end
1121     end
1122   end
1123 end
1124
1125 if ($0 == __FILE__)
1126   LEAGUE = League::new
1127   main
1128 end