Dedicated server stuff should now work
[progcomp2013.git] / qchess / src / main.py
1 #!/usr/bin/python -u
2
3 # Do you know what the -u does? It unbuffers stdin and stdout
4 # I can't remember why, but last year things broke without that
5
6 """
7         UCC::Progcomp 2013 Quantum Chess game
8         @author Sam Moore [SZM] "matches"
9         @copyright The University Computer Club, Incorporated
10                 (ie: You can copy it for not for profit purposes)
11 """
12
13 # system python modules or whatever they are called
14 import sys
15 import os
16 import time
17
18 turn_delay = 0.5
19 sleep_timeout = None
20 [game, graphics] = [None, None]
21
22 def make_player(name, colour):
23         if name[0] == '@':
24                 if name[1:] == "human":
25                         return HumanPlayer(name, colour)
26                 s = name[1:].split(":")
27                 if s[0] == "network":
28                         ip = None
29                         port = 4562
30                         #print str(s)
31                         if len(s) > 1:
32                                 if s[1] != "":
33                                         ip = s[1]
34                         if len(s) > 2:
35                                 port = int(s[2])
36                                 
37                         if ip == None:
38                                 if colour == "black":
39                                         port += 1
40                         elif colour == "white":
41                                 port += 1
42                                                 
43                         return NetworkPlayer(colour, Network((ip, port)), None)
44                 if s[0] == "internal":
45
46                         import inspect
47                         internal_agents = inspect.getmembers(sys.modules[__name__], inspect.isclass)
48                         internal_agents = [x for x in internal_agents if issubclass(x[1], InternalAgent)]
49                         internal_agents.remove(('InternalAgent', InternalAgent)) 
50                         
51                         if len(s) != 2:
52                                 sys.stderr.write(sys.argv[0] + " : '@internal' should be followed by ':' and an agent name\n")
53                                 sys.stderr.write(sys.argv[0] + " : Choices are: " + str(map(lambda e : e[0], internal_agents)) + "\n")
54                                 return None
55
56                         for a in internal_agents:
57                                 if s[1] == a[0]:
58                                         return a[1](name, colour)
59                         
60                         sys.stderr.write(sys.argv[0] + " : Can't find an internal agent matching \"" + s[1] + "\"\n")
61                         sys.stderr.write(sys.argv[0] + " : Choices are: " + str(map(lambda e : e[0], internal_agents)) + "\n")
62                         return None
63                         
64
65         else:
66                 return ExternalAgent(name, colour)
67                         
68
69
70 # The main function! It does the main stuff!
71 def main(argv):
72
73         # Apparently python will silently treat things as local unless you do this
74         # Anyone who says "You should never use a global variable" can die in a fire
75         global game
76         global graphics
77         
78         global turn_delay
79         global agent_timeout
80         global log_files
81         global src_file
82         global graphics_enabled
83         global always_reveal_states
84         global sleep_timeout
85
86
87         server_addr = None
88
89         max_moves = None
90         src_file = None
91         
92         style = "quantum"
93         colour = "white"
94
95         # Get the important warnings out of the way
96         if platform.system() == "Windows":
97                 sys.stderr.write(sys.argv[0] + " : Warning - You are using " + platform.system() + "\n")
98                 if platform.release() == "Vista":
99                         sys.stderr.write(sys.argv[0] + " : God help you.\n")
100         
101
102         players = []
103         i = 0
104         while i < len(argv)-1:
105                 i += 1
106                 arg = argv[i]
107                 if arg[0] != '-':
108                         p = make_player(arg, colour)
109                         if not isinstance(p, Player):
110                                 sys.stderr.write(sys.argv[0] + " : Fatal error creating " + colour + " player\n")
111                                 return 100
112                         players.append(p)
113                         if colour == "white":
114                                 colour = "black"
115                         elif colour == "black":
116                                 pass
117                         else:
118                                 sys.stderr.write(sys.argv[0] + " : Too many players (max 2)\n")
119                         continue
120
121                 # Option parsing goes here
122                 if arg[1] == '-' and arg[2:] == "classical":
123                         style = "classical"
124                 elif arg[1] == '-' and arg[2:] == "quantum":
125                         style = "quantum"
126                 elif arg[1] == '-' and arg[2:] == "reveal":
127                         always_reveal_states = True
128                 elif (arg[1] == '-' and arg[2:] == "graphics"):
129                         graphics_enabled = True
130                 elif (arg[1] == '-' and arg[2:] == "no-graphics"):
131                         graphics_enabled = False
132                 elif (arg[1] == '-' and arg[2:].split("=")[0] == "file"):
133                         # Load game from file
134                         if len(arg[2:].split("=")) == 1:
135                                 src_file = sys.stdin
136                         else:
137                                 f = arg[2:].split("=")[1]
138                                 if f[0:7] == "http://":
139                                         src_file = HttpReplay(f)
140                                 else:
141                                         src_file = FileReplay(f.split(":")[0])
142
143                                         if len(f.split(":")) == 2:
144                                                 max_moves = int(f.split(":")[1])
145                                                 
146                 elif (arg[1] == '-' and arg[2:].split("=")[0] == "server"):
147                         #debug("Server: " + str(arg[2:]))
148                         if len(arg[2:].split("=")) <= 1:
149                                 server_addr = True
150                         else:
151                                 server_addr = arg[2:].split("=")[1]
152                         
153                 elif (arg[1] == '-' and arg[2:].split("=")[0] == "log"):
154                         # Log file
155                         if len(arg[2:].split("=")) == 1:
156                                 log_files.append(LogFile(sys.stdout,""))
157                         else:
158                                 f = arg[2:].split("=")[1]
159                                 if f == "":
160                                         log_files.append(LogFile(sys.stdout, ""))
161                                 elif f[0] == '@':
162                                         log_files.append(ShortLog(f[1:]))
163                                 else:
164                                         log_files.append(LogFile(open(f, "w", 0), f))
165                 elif (arg[1] == '-' and arg[2:].split("=")[0] == "delay"):
166                         # Delay
167                         if len(arg[2:].split("=")) == 1:
168                                 turn_delay = 0
169                         else:
170                                 turn_delay = float(arg[2:].split("=")[1])
171
172                 elif (arg[1] == '-' and arg[2:].split("=")[0] == "timeout"):
173                         # Timeout
174                         if len(arg[2:].split("=")) == 1:
175                                 agent_timeout = -1
176                         else:
177                                 agent_timeout = float(arg[2:].split("=")[1])
178                 elif (arg[1] == '-' and arg[2:].split("=")[0] == "blackout"):
179                         # Screen saver delay
180                         if len(arg[2:].split("=")) == 1:
181                                 sleep_timeout = -1
182                         else:
183                                 sleep_timeout = float(arg[2:].split("=")[1])
184                                 
185                 elif (arg[1] == '-' and arg[2:] == "help"):
186                         # Help
187                         os.system("less data/help.txt") # The best help function
188                         return 0
189                 
190         # Dedicated server?
191         
192         #debug("server_addr = " + str(server_addr))
193         
194         if server_addr != None:
195                 if server_addr == True:
196                         return dedicated_server()
197                 else:
198                         return client(server_addr)
199                 
200
201         # Create the board
202         
203         # Construct a GameThread! Make it global! Damn the consequences!
204                         
205         if src_file != None:
206                 # Hack to stop ReplayThread from exiting
207                 #if len(players) == 0:
208                 #       players = [HumanPlayer("dummy", "white"), HumanPlayer("dummy", "black")]
209
210                 # Normally the ReplayThread exits if there are no players
211                 # TODO: Decide which behaviour to use, and fix it
212                 end = (len(players) == 0)
213                 if end:
214                         players = [Player("dummy", "white"), Player("dummy", "black")]
215                 elif len(players) != 2:
216                         sys.stderr.write(sys.argv[0] + " : Usage " + sys.argv[0] + " white black\n")
217                         if graphics_enabled:
218                                 sys.stderr.write(sys.argv[0] + " : (You won't get a GUI, because --file was used, and the author is lazy)\n")
219                         return 44
220                 game = ReplayThread(players, src_file, end=end, max_moves=max_moves)
221         else:
222                 board = Board(style)
223                 board.max_moves = max_moves
224                 game = GameThread(board, players) 
225
226
227
228
229         # Initialise GUI
230         if graphics_enabled == True:
231                 try:
232                         graphics = GraphicsThread(game.board, grid_sz = [64,64]) # Construct a GraphicsThread!
233                         
234                         graphics.sleep_timeout = sleep_timeout
235
236                 except Exception,e:
237                         graphics = None
238                         sys.stderr.write(sys.argv[0] + " : Got exception trying to initialise graphics\n"+str(e.message)+"\nDisabled graphics\n")
239                         graphics_enabled = False
240
241         # If there are no players listed, display a nice pretty menu
242         if len(players) != 2:
243                 if graphics != None:
244                         
245                         server_addr = graphics.SelectServer()
246                         if server_addr != None:
247                                 if server_addr == True:
248                                         return dedicated_server()
249                                 else:
250                                         return client(server_addr)      
251                         
252                         players = graphics.SelectPlayers(players)
253                 else:
254                         sys.stderr.write(sys.argv[0] + " : Usage " + sys.argv[0] + " white black\n")
255                         return 44
256
257         # If there are still no players, quit
258         if players == None or len(players) != 2:
259                 sys.stderr.write(sys.argv[0] + " : Graphics window closed before players chosen\n")
260                 return 45
261
262         old = players[:]
263         for p in old:
264                 if isinstance(p, NetworkPlayer):
265                         for i in range(len(old)):
266                                 if old[i] == p or isinstance(old[i], NetworkPlayer):
267                                         continue
268                                 players[i] = NetworkPlayer(old[i].colour, p.network, old[i])
269                 
270         for p in players:
271                 #debug(str(p))
272                 if isinstance(p, NetworkPlayer):
273                         p.board = game.board
274                         if not p.network.connected:
275                                 if not p.network.server:
276                                         time.sleep(0.2)
277                                 p.network.connect()
278                                 
279         
280         # If using windows, select won't work; use horrible TimeoutPlayer hack
281         if agent_timeout > 0:
282                 if platform.system() == "Windows":
283                         for i in range(len(players)):
284                                 if isinstance(players[i], ExternalAgent) or isinstance(players[i], InternalAgent):
285                                         players[i] = TimeoutPlayer(players[i], agent_timeout)
286
287                 else:
288                         warned = False
289                         # InternalAgents get wrapped to an ExternalAgent when there is a timeout
290                         # This is not confusing at all.
291                         for i in range(len(players)):
292                                 if isinstance(players[i], InternalAgent):
293                                                 players[i] = ExternalWrapper(players[i])
294
295
296                 
297
298
299
300
301         log_init(game.board, players)
302         
303         
304         if graphics != None:
305                 game.start() # This runs in a new thread
306                 graphics.run()
307                 if game.is_alive():
308                         game.join()
309         
310
311                 error = game.error + graphics.error
312         else:
313                 game.run()
314                 error = game.error
315         
316
317         for l in log_files:
318                 l.close()
319
320         if src_file != None and src_file != sys.stdin:
321                 src_file.close()
322
323         sys.stdout.write(game.final_result + "\n")
324
325         return error
326                 
327                 
328         
329                 
330         
331                 
332                 
333
334 # This is how python does a main() function...
335 if __name__ == "__main__":
336         retcode = 0
337         try:
338                 retcode = main(sys.argv)
339         except KeyboardInterrupt:
340                 sys.stderr.write(sys.argv[0] + " : Got KeyboardInterrupt. Stopping everything\n")
341                 if isinstance(graphics, StoppableThread):
342                         graphics.stop()
343                         graphics.run() # Will clean up graphics because it is stopped, not run it (a bit dodgy)
344
345                 if isinstance(game, StoppableThread):
346                         game.stop()
347                         if game.is_alive():
348                                 game.join()
349                 retcode = 102
350         #except Exception, e:
351         #       sys.stderr.write(sys.argv[0] + " : " + e.message + "\n")
352         #       retcode = 103   
353                 
354         try:
355                 sys.stdout.close()
356         except:
357                 pass
358         try:
359                 sys.stderr.close()
360         except:
361                 pass
362         sys.exit(retcode)
363                 
364

UCC git Repository :: git.ucc.asn.au