OSDN Git Service

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