plomlompom.com Git - plomrogue/blob - roguelike-server

   1 #!/usr/bin/python3
   2
   3 # This file is part of PlomRogue. PlomRogue is licensed under the GPL version 3
   4 # or any later version. For details on its copyright, license, and warranties,
   5 # see the file NOTICE in the root directory of the PlomRogue source package.
   6
   7
   8 import argparse
   9 import errno
  10 import os
  11 import shlex
  12 import shutil
  13 import time
  14 import ctypes
  15 import math
  16
  17
  18 class RandomnessIO:
  19     """"Interface to libplomrogue's pseudo-randomness generator."""
  20
  21     def set_seed(self, seed):
  22         libpr.seed_rrand(1, seed)
  23
  24     def get_seed(self):
  25         return libpr.seed_rrand(0, 0)
  26
  27     def next(self):
  28         return libpr.rrand()
  29
  30     seed = property(get_seed, set_seed)
  31
  32
  33 def prep_library():
  34     """Prepare ctypes library at ./libplomrogue.so"""
  35     libpath = ("./libplomrogue.so")
  36     if not os.access(libpath, os.F_OK):
  37         raise SystemExit("No library " + libpath + ", run ./redo first?")
  38     libpr = ctypes.cdll.LoadLibrary(libpath)
  39     libpr.seed_rrand.restype = ctypes.c_uint32
  40     return libpr
  41
  42
  43 def c_pointer_to_bytearray(ba):
  44     """Return C char * pointer to ba."""
  45     type = ctypes.c_char * len(ba)
  46     return type.from_buffer(ba)
  47
  48
  49 def strong_write(file, string):
  50     """Apply write(string), then flush()."""
  51     file.write(string)
  52     file.flush()
  53
  54
  55 def setup_server_io():
  56     """Fill IO files DB with proper file( path)s. Write process IO test string.
  57
  58     Ensure IO files directory at server/. Remove any old input file if found.
  59     Set up new input file for reading, and new output file for writing. Start
  60     output file with process hash line of format PID + " " + floated UNIX time
  61     (io_db["teststring"]). Raise SystemExit if file is found at path of either
  62     record or save file plus io_db["tmp_suffix"].
  63     """
  64     def detect_atomic_leftover(path, tmp_suffix):
  65         path_tmp = path + tmp_suffix
  66         msg = "Found file '" + path_tmp + "' that may be a leftover from an " \
  67               "aborted previous attempt to write '" + path + "'. Aborting " \
  68               "until matter is resolved by removing it from its current path."
  69         if os.access(path_tmp, os.F_OK):
  70             raise SystemExit(msg)
  71     io_db["teststring"] = str(os.getpid()) + " " + str(time.time())
  72     io_db["save_wait"] = 0
  73     io_db["verbose"] = False
  74     io_db["record_chunk"] = ""
  75     os.makedirs(io_db["path_server"], exist_ok=True)
  76     io_db["file_out"] = open(io_db["path_out"], "w")
  77     strong_write(io_db["file_out"], io_db["teststring"] + "\n")
  78     if os.access(io_db["path_in"], os.F_OK):
  79         os.remove(io_db["path_in"])
  80     io_db["file_in"] = open(io_db["path_in"], "w")
  81     io_db["file_in"].close()
  82     io_db["file_in"] = open(io_db["path_in"], "r")
  83     detect_atomic_leftover(io_db["path_save"], io_db["tmp_suffix"])
  84     detect_atomic_leftover(io_db["path_record"], io_db["tmp_suffix"])
  85
  86
  87 def cleanup_server_io():
  88     """Close and (if io_db["kicked_by_rival"] false) remove files in io_db."""
  89     def helper(file_key, path_key):
  90         if file_key in io_db:
  91             io_db[file_key].close()
  92         if not io_db["kicked_by_rival"] \
  93            and os.access(io_db[path_key], os.F_OK):
  94             os.remove(io_db[path_key])
  95     helper("file_in", "path_in")
  96     helper("file_out", "path_out")
  97     helper("file_worldstate", "path_worldstate")
  98     if "file_record" in io_db:
  99         io_db["file_record"].close()
 100
 101
 102 def log(msg):
 103     """Send "msg" to log."""
 104     strong_write(io_db["file_out"], "LOG " + msg + "\n")
 105
 106
 107 def obey(command, prefix, replay=False, do_record=False):
 108     """Call function from commands_db mapped to command's first token.
 109
 110     Tokenize command string with shlex.split(comments=True). If replay is set,
 111     a non-meta command from the commands_db merely triggers obey() on the next
 112     command from the records file. If not, non-meta commands set
 113     io_db["worldstate_updateable"] to world_db["WORLD_ACTIVE"], and, if
 114     do_record is set, are recorded to io_db["record_chunk"], and save_world()
 115     is called (and io_db["record_chunk"] written) if 15 seconds have passed
 116     since the last time it was called. The prefix string is inserted into the
 117     server's input message between its beginning 'input ' and ':'. All activity
 118     is preceded by a server_test() call. Commands that start with a lowercase
 119     letter are ignored when world_db["WORLD_ACTIVE"] is False/0.
 120     """
 121     server_test()
 122     if io_db["verbose"]:
 123         print("input " + prefix + ": " + command)
 124     try:
 125         tokens = shlex.split(command, comments=True)
 126     except ValueError as err:
 127         print("Can't tokenize command string: " + str(err) + ".")
 128         return
 129     if len(tokens) > 0 and tokens[0] in commands_db \
 130        and len(tokens) == commands_db[tokens[0]][0] + 1:
 131         if commands_db[tokens[0]][1]:
 132             commands_db[tokens[0]][2](*tokens[1:])
 133         elif tokens[0][0].islower() and not world_db["WORLD_ACTIVE"]:
 134             print("Ignoring lowercase-starting commands when world inactive.")
 135         elif replay:
 136             print("Due to replay mode, reading command as 'go on in record'.")
 137             line = io_db["file_record"].readline()
 138             if len(line) > 0:
 139                 obey(line.rstrip(), io_db["file_record"].prefix
 140                      + str(io_db["file_record"].line_n))
 141                 io_db["file_record"].line_n = io_db["file_record"].line_n + 1
 142             else:
 143                 print("Reached end of record file.")
 144         else:
 145             commands_db[tokens[0]][2](*tokens[1:])
 146             if do_record:
 147                 io_db["record_chunk"] += command + "\n"
 148                 if time.time() > io_db["save_wait"] + 15:
 149                     atomic_write(io_db["path_record"], io_db["record_chunk"],
 150                                  do_append=True)
 151                     if world_db["WORLD_ACTIVE"]:
 152                         save_world()
 153                     io_db["record_chunk"] = ""
 154                     io_db["save_wait"] = time.time()
 155             io_db["worldstate_updateable"] = world_db["WORLD_ACTIVE"]
 156     elif 0 != len(tokens):
 157         print("Invalid command/argument, or bad number of tokens.")
 158
 159
 160 def atomic_write(path, text, do_append=False, delete=True):
 161     """Atomic write of text to file at path, appended if do_append is set."""
 162     path_tmp = path + io_db["tmp_suffix"]
 163     mode = "w"
 164     if do_append:
 165         mode = "a"
 166         if os.access(path, os.F_OK):
 167             shutil.copyfile(path, path_tmp)
 168     file = open(path_tmp, mode)
 169     strong_write(file, text)
 170     file.close()
 171     if delete and os.access(path, os.F_OK):
 172         os.remove(path)
 173     os.rename(path_tmp, path)
 174
 175
 176 def save_world():
 177     """Save all commands needed to reconstruct current world state."""
 178
 179     def quote(string):
 180         string = string.replace("\u005C", '\u005C\u005C')
 181         return '"' + string.replace('"', '\u005C"') + '"'
 182
 183     def mapsetter(key):
 184         def helper(id=None):
 185             string = ""
 186             if key == "MAP" or world_db["Things"][id][key]:
 187                 map = world_db["MAP"] if key == "MAP" \
 188                                       else world_db["Things"][id][key]
 189                 length = world_db["MAP_LENGTH"]
 190                 for i in range(length):
 191                     line = map[i * length:(i * length) + length].decode()
 192                     string = string + key + " " + str(i) + " " + quote(line) \
 193                         + "\n"
 194             return string
 195         return helper
 196
 197     def memthing(id):
 198         string = ""
 199         for memthing in world_db["Things"][id]["T_MEMTHING"]:
 200             string = string + "T_MEMTHING " + str(memthing[0]) + " " + \
 201                 str(memthing[1]) + " " + str(memthing[2]) + "\n"
 202         return string
 203
 204     def helper(category, id_string, special_keys={}):
 205         string = ""
 206         for id in sorted(world_db[category].keys()):
 207             string = string + id_string + " " + str(id) + "\n"
 208             for key in sorted(world_db[category][id].keys()):
 209                 if not key in special_keys:
 210                     x = world_db[category][id][key]
 211                     argument = quote(x) if str == type(x) else str(x)
 212                     string = string + key + " " + argument + "\n"
 213                 elif special_keys[key]:
 214                     string = string + special_keys[key](id)
 215         return string
 216
 217     string = ""
 218     for key in sorted(world_db.keys()):
 219         if (not isinstance(world_db[key], dict)) and key != "MAP" and \
 220            key != "WORLD_ACTIVE":
 221             string = string + key + " " + str(world_db[key]) + "\n"
 222     string = string + mapsetter("MAP")()
 223     string = string + helper("ThingActions", "TA_ID")
 224     string = string + helper("ThingTypes", "TT_ID", {"TT_CORPSE_ID": False})
 225     for id in sorted(world_db["ThingTypes"].keys()):
 226         string = string + "TT_ID " + str(id) + "\n" + "TT_CORPSE_ID " + \
 227             str(world_db["ThingTypes"][id]["TT_CORPSE_ID"]) + "\n"
 228     string = string + helper("Things", "T_ID",
 229                              {"T_CARRIES": False, "carried": False,
 230                               "T_MEMMAP": mapsetter("T_MEMMAP"),
 231                               "T_MEMTHING": memthing, "fovmap": False,
 232                               "T_MEMDEPTHMAP": mapsetter("T_MEMDEPTHMAP")})
 233     for id in sorted(world_db["Things"].keys()):
 234         if [] != world_db["Things"][id]["T_CARRIES"]:
 235             string = string + "T_ID " + str(id) + "\n"
 236             for carried in sorted(world_db["Things"][id]["T_CARRIES"]):
 237                 string = string + "T_CARRIES " + str(carried) + "\n"
 238     string = string + "SEED_RANDOMNESS " + str(rand.seed) + "\n" + \
 239         "WORLD_ACTIVE " + str(world_db["WORLD_ACTIVE"])
 240     atomic_write(io_db["path_save"], string)
 241
 242
 243 def obey_lines_in_file(path, name, do_record=False):
 244     """Call obey() on each line of path's file, use name in input prefix."""
 245     file = open(path, "r")
 246     line_n = 1
 247     for line in file.readlines():
 248         obey(line.rstrip(), name + "file line " + str(line_n),
 249              do_record=do_record)
 250         line_n = line_n + 1
 251     file.close()
 252
 253
 254 def parse_command_line_arguments():
 255     """Return settings values read from command line arguments."""
 256     parser = argparse.ArgumentParser()
 257     parser.add_argument('-s', nargs='?', type=int, dest='replay', const=1,
 258                         action='store')
 259     parser.add_argument('-l', nargs="?", const="save", dest='savefile',
 260                         action="store")
 261     parser.add_argument('-v', dest='verbose', action='store_true')
 262     opts, unknown = parser.parse_known_args()
 263     return opts
 264
 265
 266 def server_test():
 267     """Ensure valid server out file belonging to current process.
 268
 269     This is done by comparing io_db["teststring"] to what's found at the start
 270     of the current file at io_db["path_out"]. On failure, set
 271     io_db["kicked_by_rival"] and raise SystemExit.
 272     """
 273     if not os.access(io_db["path_out"], os.F_OK):
 274         raise SystemExit("Server output file has disappeared.")
 275     file = open(io_db["path_out"], "r")
 276     test = file.readline().rstrip("\n")
 277     file.close()
 278     if test != io_db["teststring"]:
 279         io_db["kicked_by_rival"] = True
 280         msg = "Server test string in server output file does not match. This" \
 281               " indicates that the current server process has been " \
 282               "superseded by another one."
 283         raise SystemExit(msg)
 284
 285
 286 def read_command():
 287     """Return next newline-delimited command from server in file.
 288
 289     Keep building return string until a newline is encountered. Pause between
 290     unsuccessful reads, and after too much waiting, run server_test().
 291     """
 292     wait_on_fail = 0.03333
 293     max_wait = 5
 294     now = time.time()
 295     command = ""
 296     while True:
 297         add = io_db["file_in"].readline()
 298         if len(add) > 0:
 299             command = command + add
 300             if len(command) > 0 and "\n" == command[-1]:
 301                 command = command[:-1]
 302                 break
 303         else:
 304             time.sleep(wait_on_fail)
 305             if now + max_wait < time.time():
 306                 server_test()
 307                 now = time.time()
 308     return command
 309
 310
 311 def try_worldstate_update():
 312     """Write worldstate file if io_db["worldstate_updateable"] is set."""
 313     if io_db["worldstate_updateable"]:
 314
 315         def write_map(string, map):
 316             for i in range(length):
 317                 line = map[i * length:(i * length) + length].decode()
 318                 string = string + line + "\n"
 319             return string
 320
 321         inventory = ""
 322         if [] == world_db["Things"][0]["T_CARRIES"]:
 323             inventory = "(none)\n"
 324         else:
 325             for id in world_db["Things"][0]["T_CARRIES"]:
 326                 type_id = world_db["Things"][id]["T_TYPE"]
 327                 name = world_db["ThingTypes"][type_id]["TT_NAME"]
 328                 inventory = inventory + name + "\n"
 329         string = str(world_db["TURN"]) + "\n" + \
 330             str(world_db["Things"][0]["T_LIFEPOINTS"]) + "\n" + \
 331             str(world_db["Things"][0]["T_SATIATION"]) + "\n" + \
 332             inventory + "%\n" + \
 333             str(world_db["Things"][0]["T_POSY"]) + "\n" + \
 334             str(world_db["Things"][0]["T_POSX"]) + "\n" + \
 335             str(world_db["MAP_LENGTH"]) + "\n"
 336         length = world_db["MAP_LENGTH"]
 337         fov = bytearray(b' ' * (length ** 2))
 338         ord_v = ord("v")
 339         for pos in [pos for pos in range(length ** 2)
 340                         if ord_v == world_db["Things"][0]["fovmap"][pos]]:
 341             fov[pos] = world_db["MAP"][pos]
 342         length = world_db["MAP_LENGTH"]
 343         for id in [id for tid in reversed(sorted(list(world_db["ThingTypes"])))
 344                       for id in world_db["Things"]
 345                       if not world_db["Things"][id]["carried"]
 346                       if world_db["Things"][id]["T_TYPE"] == tid
 347                       if world_db["Things"][0]["fovmap"][
 348                            world_db["Things"][id]["T_POSY"] * length
 349                            + world_db["Things"][id]["T_POSX"]] == ord_v]:
 350             type = world_db["Things"][id]["T_TYPE"]
 351             c = ord(world_db["ThingTypes"][type]["TT_SYMBOL"])
 352             fov[world_db["Things"][id]["T_POSY"] * length
 353                 + world_db["Things"][id]["T_POSX"]] = c
 354         string = write_map(string, fov)
 355         mem = world_db["Things"][0]["T_MEMMAP"][:]
 356         for mt in [mt for tid in reversed(sorted(list(world_db["ThingTypes"])))
 357                       for mt in world_db["Things"][0]["T_MEMTHING"]
 358                       if mt[0] == tid]:
 359              c = world_db["ThingTypes"][mt[0]]["TT_SYMBOL"]
 360              mem[(mt[1] * length) + mt[2]] = ord(c)
 361         string = write_map(string, mem)
 362         atomic_write(io_db["path_worldstate"], string, delete=False)
 363         strong_write(io_db["file_out"], "WORLD_UPDATED\n")
 364         io_db["worldstate_updateable"] = False
 365
 366
 367 def replay_game():
 368     """Replay game from record file.
 369
 370     Use opts.replay as breakpoint turn to which to replay automatically before
 371     switching to manual input by non-meta commands in server input file
 372     triggering further reads of record file. Ensure opts.replay is at least 1.
 373     Run try_worldstate_update() before each interactive obey()/read_command().
 374     """
 375     if opts.replay < 1:
 376         opts.replay = 1
 377     print("Replay mode. Auto-replaying up to turn " + str(opts.replay) +
 378           " (if so late a turn is to be found).")
 379     if not os.access(io_db["path_record"], os.F_OK):
 380         raise SystemExit("No record file found to replay.")
 381     io_db["file_record"] = open(io_db["path_record"], "r")
 382     io_db["file_record"].prefix = "record file line "
 383     io_db["file_record"].line_n = 1
 384     while world_db["TURN"] < opts.replay:
 385         line = io_db["file_record"].readline()
 386         if "" == line:
 387             break
 388         obey(line.rstrip(), io_db["file_record"].prefix
 389              + str(io_db["file_record"].line_n))
 390         io_db["file_record"].line_n = io_db["file_record"].line_n + 1
 391     while True:
 392         try_worldstate_update()
 393         obey(read_command(), "in file", replay=True)
 394
 395
 396 def play_game():
 397     """Play game by server input file commands. Before, load save file found.
 398
 399     If no save file is found, a new world is generated from the commands in the
 400     world config plus a 'MAKE WORLD [current Unix timestamp]'. Record this
 401     command and all that follow via the server input file. Run
 402     try_worldstate_update() before each interactive obey()/read_command().
 403     """
 404     if os.access(io_db["path_save"], os.F_OK):
 405         obey_lines_in_file(io_db["path_save"], "save")
 406     else:
 407         if not os.access(io_db["path_worldconf"], os.F_OK):
 408             msg = "No world config file from which to start a new world."
 409             raise SystemExit(msg)
 410         obey_lines_in_file(io_db["path_worldconf"], "world config ",
 411                            do_record=True)
 412         obey("MAKE_WORLD " + str(int(time.time())), "in file", do_record=True)
 413     while True:
 414         try_worldstate_update()
 415         obey(read_command(), "in file", do_record=True)
 416
 417
 418 def make_map():
 419     """(Re-)make island map.
 420
 421     Let "~" represent water, "." land, "X" trees: Build island shape randomly,
 422     start with one land cell in the middle, then go into cycle of repeatedly
 423     selecting a random sea cell and transforming it into land if it is neighbor
 424     to land. The cycle ends when a land cell is due to be created at the map's
 425     border. Then put some trees on the map (TODO: more precise algorithm desc).
 426     """
 427
 428     def is_neighbor(coordinates, type):
 429         y = coordinates[0]
 430         x = coordinates[1]
 431         length = world_db["MAP_LENGTH"]
 432         ind = y % 2
 433         diag_west = x + (ind > 0)
 434         diag_east = x + (ind < (length - 1))
 435         pos = (y * length) + x
 436         if (y > 0 and diag_east
 437             and type == chr(world_db["MAP"][pos - length + ind])) \
 438            or (x < (length - 1)
 439                and type == chr(world_db["MAP"][pos + 1])) \
 440            or (y < (length - 1) and diag_east
 441                and type == chr(world_db["MAP"][pos + length + ind])) \
 442            or (y > 0 and diag_west
 443                and type == chr(world_db["MAP"][pos - length - (not ind)])) \
 444            or (x > 0
 445                and type == chr(world_db["MAP"][pos - 1])) \
 446            or (y < (length - 1) and diag_west
 447                and type == chr(world_db["MAP"][pos + length - (not ind)])):
 448             return True
 449         return False
 450
 451     world_db["MAP"] = bytearray(b'~' * (world_db["MAP_LENGTH"] ** 2))
 452     length = world_db["MAP_LENGTH"]
 453     add_half_width = (not (length % 2)) * int(length / 2)
 454     world_db["MAP"][int((length ** 2) / 2) + add_half_width] = ord(".")
 455     while (1):
 456         y = rand.next() % length
 457         x = rand.next() % length
 458         pos = (y * length) + x
 459         if "~" == chr(world_db["MAP"][pos]) and is_neighbor((y, x), "."):
 460             if y == 0 or y == (length - 1) or x == 0 or x == (length - 1):
 461                 break
 462             world_db["MAP"][pos] = ord(".")
 463     n_trees = int((length ** 2) / 16)
 464     i_trees = 0
 465     while (i_trees <= n_trees):
 466         single_allowed = rand.next() % 32
 467         y = rand.next() % length
 468         x = rand.next() % length
 469         pos = (y * length) + x
 470         if "." == chr(world_db["MAP"][pos]) \
 471                 and ((not single_allowed) or is_neighbor((y, x), "X")):
 472             world_db["MAP"][pos] = ord("X")
 473             i_trees += 1
 474     # This all-too-precise replica of the original C code misses iter_limit().
 475
 476
 477 def eat_vs_hunger_threshold(thingtype):
 478     """Return satiation cost of eating for type. Good food for it must be >."""
 479     hunger_unit = hunger_per_turn(thingtype)
 480     actiontype = [id for id in world_db["ThingActions"]
 481                if world_db["ThingActions"][id]["TA_NAME"] == "use"][0]
 482     return world_db["ThingActions"][actiontype]["TA_EFFORT"] * hunger_unit
 483
 484
 485 def update_map_memory(t, age_map=True):
 486     """Update t's T_MEMMAP with what's in its FOV now,age its T_MEMMEPTHMAP."""
 487
 488     def age_some_memdepthmap_on_nonfov_cells():
 489         # OUTSOURCED FOR PERFORMANCE REASONS TO libplomrogue.so:
 490         # ord_v = ord("v")
 491         # ord_0 = ord("0")
 492         # ord_9 = ord("9")
 493         # for pos in [pos for pos in range(world_db["MAP_LENGTH"] ** 2)
 494         #             if not ord_v == t["fovmap"][pos]
 495         #             if ord_0 <= t["T_MEMDEPTHMAP"][pos]
 496         #             if ord_9 > t["T_MEMDEPTHMAP"][pos]
 497         #             if not rand.next() % (2 **
 498         #                                   (t["T_MEMDEPTHMAP"][pos] - 48))]:
 499         #     t["T_MEMDEPTHMAP"][pos] += 1
 500         memdepthmap = c_pointer_to_bytearray(t["T_MEMDEPTHMAP"])
 501         fovmap = c_pointer_to_bytearray(t["fovmap"])
 502         libpr.age_some_memdepthmap_on_nonfov_cells(memdepthmap, fovmap)
 503
 504     if not t["T_MEMMAP"]:
 505         t["T_MEMMAP"] = bytearray(b' ' * (world_db["MAP_LENGTH"] ** 2))
 506     if not t["T_MEMDEPTHMAP"]:
 507         t["T_MEMDEPTHMAP"] = bytearray(b' ' * (world_db["MAP_LENGTH"] ** 2))
 508     ord_v = ord("v")
 509     ord_0 = ord("0")
 510     for pos in [pos for pos in range(world_db["MAP_LENGTH"] ** 2)
 511                 if ord_v == t["fovmap"][pos]]:
 512         t["T_MEMDEPTHMAP"][pos] = ord_0
 513         t["T_MEMMAP"][pos] = world_db["MAP"][pos]
 514     if age_map:
 515         age_some_memdepthmap_on_nonfov_cells()
 516     t["T_MEMTHING"] = [mt for mt in t["T_MEMTHING"]
 517                        if ord_v != t["fovmap"][(mt[1] * world_db["MAP_LENGTH"])
 518                                                + mt[2]]]
 519     for id in [id for id in world_db["Things"]
 520                if not world_db["Things"][id]["carried"]]:
 521         type = world_db["Things"][id]["T_TYPE"]
 522         if not world_db["ThingTypes"][type]["TT_LIFEPOINTS"]:
 523             y = world_db["Things"][id]["T_POSY"]
 524             x = world_db["Things"][id]["T_POSX"]
 525             if ord_v == t["fovmap"][(y * world_db["MAP_LENGTH"]) + x]:
 526                 t["T_MEMTHING"].append((type, y, x))
 527
 528
 529 def set_world_inactive():
 530     """Set world_db["WORLD_ACTIVE"] to 0 and remove worldstate file."""
 531     server_test()
 532     if os.access(io_db["path_worldstate"], os.F_OK):
 533         os.remove(io_db["path_worldstate"])
 534     world_db["WORLD_ACTIVE"] = 0
 535
 536
 537 def integer_test(val_string, min, max=None):
 538     """Return val_string if integer >= min & (if max set) <= max, else None."""
 539     try:
 540         val = int(val_string)
 541         if val < min or (max is not None and val > max):
 542             raise ValueError
 543         return val
 544     except ValueError:
 545         msg = "Ignoring: Please use integer >= " + str(min)
 546         if max is not None:
 547             msg += " and <= " + str(max)
 548         msg += "."
 549         print(msg)
 550         return None
 551
 552
 553 def setter(category, key, min, max=None):
 554     """Build setter for world_db([category + "s"][id])[key] to >=min/<=max."""
 555     if category is None:
 556         def f(val_string):
 557             val = integer_test(val_string, min, max)
 558             if None != val:
 559                 world_db[key] = val
 560     else:
 561         if category == "Thing":
 562             id_store = command_tid
 563             decorator = test_Thing_id
 564         elif category == "ThingType":
 565             id_store = command_ttid
 566             decorator = test_ThingType_id
 567         elif category == "ThingAction":
 568             id_store = command_taid
 569             decorator = test_ThingAction_id
 570
 571         @decorator
 572         def f(val_string):
 573             val = integer_test(val_string, min, max)
 574             if None != val:
 575                 world_db[category + "s"][id_store.id][key] = val
 576     return f
 577
 578
 579 def build_fov_map(t):
 580     """Build Thing's FOV map."""
 581     t["fovmap"] = bytearray(b'v' * (world_db["MAP_LENGTH"] ** 2))
 582     fovmap = c_pointer_to_bytearray(t["fovmap"])
 583     map = c_pointer_to_bytearray(world_db["MAP"])
 584     if libpr.build_fov_map(t["T_POSY"], t["T_POSX"], fovmap, map):
 585         raise RuntimeError("Malloc error in build_fov_Map().")
 586
 587
 588 def log_help():
 589     """Send quick usage info to log."""
 590     log("LOG See README file for help.")
 591
 592
 593 def decrement_lifepoints(t):
 594     """Decrement t's lifepoints by 1, and if to zero, corpse it.
 595
 596     If t is the player avatar, only blank its fovmap, so that the client may
 597     still display memory data. On non-player things, erase fovmap and memory.
 598     Dying actors drop all their things.
 599     """
 600     t["T_LIFEPOINTS"] -= 1
 601     if 0 == t["T_LIFEPOINTS"]:
 602         for id in t["T_CARRIES"]:
 603             t["T_CARRIES"].remove(id)
 604             world_db["Things"][id]["T_POSY"] = t["T_POSY"]
 605             world_db["Things"][id]["T_POSX"] = t["T_POSX"]
 606             world_db["Things"][id]["carried"] = False
 607         t["T_TYPE"] = world_db["ThingTypes"][t["T_TYPE"]]["TT_CORPSE_ID"]
 608         if world_db["Things"][0] == t:
 609             t["fovmap"] = bytearray(b' ' * (world_db["MAP_LENGTH"] ** 2))
 610             log("You die.")
 611             log("See README on how to start over.")
 612         else:
 613             t["fovmap"] = False
 614             t["T_MEMMAP"] = False
 615             t["T_MEMDEPTHMAP"] = False
 616             t["T_MEMTHING"] = []
 617
 618
 619 def mv_yx_in_dir_legal(dir, y, x):
 620     """Wrapper around libpr.mv_yx_in_dir_legal to simplify its use."""
 621     dir_c = dir.encode("ascii")[0]
 622     test = libpr.mv_yx_in_dir_legal_wrap(dir_c, y, x)
 623     if -1 == test:
 624         raise RuntimeError("Too much wrapping in mv_yx_in_dir_legal_wrap()!")
 625     return (test, libpr.result_y(), libpr.result_x())
 626
 627
 628 def actor_wait(t):
 629     """Make t do nothing (but loudly, if player avatar)."""
 630     if t == world_db["Things"][0]:
 631         log("You wait")
 632
 633
 634 def actor_move(t):
 635     """If passable, move/collide(=attack) thing into T_ARGUMENT's direction."""
 636     passable = False
 637     move_result = mv_yx_in_dir_legal(chr(t["T_ARGUMENT"]),
 638                                      t["T_POSY"], t["T_POSX"])
 639     if 1 == move_result[0]:
 640         pos = (move_result[1] * world_db["MAP_LENGTH"]) + move_result[2]
 641         hitted = [id for id in world_db["Things"]
 642                   if world_db["Things"][id] != t
 643                   if world_db["Things"][id]["T_LIFEPOINTS"]
 644                   if world_db["Things"][id]["T_POSY"] == move_result[1]
 645                   if world_db["Things"][id]["T_POSX"] == move_result[2]]
 646         if len(hitted):
 647             hit_id = hitted[0]
 648             if t == world_db["Things"][0]:
 649                 hitted_type = world_db["Things"][hit_id]["T_TYPE"]
 650                 hitted_name = world_db["ThingTypes"][hitted_type]["TT_NAME"]
 651                 log("You wound " + hitted_name + ".")
 652             elif 0 == hit_id:
 653                 hitter_name = world_db["ThingTypes"][t["T_TYPE"]]["TT_NAME"]
 654                 log(hitter_name +" wounds you.")
 655             decrement_lifepoints(world_db["Things"][hit_id])
 656             return
 657         passable = "." == chr(world_db["MAP"][pos])
 658     dir = [dir for dir in directions_db
 659            if directions_db[dir] == chr(t["T_ARGUMENT"])][0]
 660     if passable:
 661         t["T_POSY"] = move_result[1]
 662         t["T_POSX"] = move_result[2]
 663         for id in t["T_CARRIES"]:
 664             world_db["Things"][id]["T_POSY"] = move_result[1]
 665             world_db["Things"][id]["T_POSX"] = move_result[2]
 666         build_fov_map(t)
 667         if t == world_db["Things"][0]:
 668             log("You move " + dir + ".")
 669     elif t == world_db["Things"][0]:
 670         log("You fail to move " + dir + ".")
 671
 672
 673 def actor_pick_up(t):
 674     """Make t pick up (topmost?) Thing from ground into inventory.
 675
 676     Define topmostness by how low the thing's type ID is.
 677     """
 678     ids = [id for id in world_db["Things"] if world_db["Things"][id] != t
 679            if not world_db["Things"][id]["carried"]
 680            if world_db["Things"][id]["T_POSY"] == t["T_POSY"]
 681            if world_db["Things"][id]["T_POSX"] == t["T_POSX"]]
 682     if len(ids):
 683         lowest_tid = -1
 684         for iid in ids:
 685             tid = world_db["Things"][iid]["T_TYPE"]
 686             if lowest_tid == -1 or tid < lowest_tid:
 687                 id = iid
 688                 lowest_tid = tid
 689         world_db["Things"][id]["carried"] = True
 690         t["T_CARRIES"].append(id)
 691         if t == world_db["Things"][0]:
 692                 log("You pick up an object.")
 693     elif t == world_db["Things"][0]:
 694             log("You try to pick up an object, but there is none.")
 695
 696
 697 def actor_drop(t):
 698     """Make t rop Thing from inventory to ground indexed by T_ARGUMENT."""
 699     # TODO: Handle case where T_ARGUMENT matches nothing.
 700     if len(t["T_CARRIES"]):
 701         id = t["T_CARRIES"][t["T_ARGUMENT"]]
 702         t["T_CARRIES"].remove(id)
 703         world_db["Things"][id]["carried"] = False
 704         if t == world_db["Things"][0]:
 705             log("You drop an object.")
 706     elif t == world_db["Things"][0]:
 707        log("You try to drop an object, but you own none.")
 708
 709
 710 def actor_use(t):
 711     """Make t use (for now: consume) T_ARGUMENT-indexed Thing in inventory."""
 712     # TODO: Handle case where T_ARGUMENT matches nothing.
 713     if len(t["T_CARRIES"]):
 714         id = t["T_CARRIES"][t["T_ARGUMENT"]]
 715         type = world_db["Things"][id]["T_TYPE"]
 716         if world_db["ThingTypes"][type]["TT_TOOL"] == "food":
 717             t["T_CARRIES"].remove(id)
 718             del world_db["Things"][id]
 719             t["T_SATIATION"] += world_db["ThingTypes"][type]["TT_TOOLPOWER"]
 720             if t == world_db["Things"][0]:
 721                 log("You consume this object.")
 722         elif t == world_db["Things"][0]:
 723             log("You try to use this object, but fail.")
 724     elif t == world_db["Things"][0]:
 725         log("You try to use an object, but you own none.")
 726
 727
 728 def thingproliferation(t, prol_map):
 729     """To chance of 1/TT_PROLIFERATE, create t offspring in open neighbor cell.
 730
 731     Naturally only works with TT_PROLIFERATE > 0. The neighbor cell must be be
 732     marked '.' in prol_map. If there are several map cell candidates, one is
 733     selected randomly.
 734     """
 735     prolscore = world_db["ThingTypes"][t["T_TYPE"]]["TT_PROLIFERATE"]
 736     if prolscore and (1 == prolscore or 1 == (rand.next() % prolscore)):
 737         candidates = []
 738         for dir in [directions_db[key] for key in sorted(directions_db.keys())]:
 739             mv_result = mv_yx_in_dir_legal(dir, t["T_POSY"], t["T_POSX"])
 740             if mv_result[0] and  ord('.') == prol_map[mv_result[1]
 741                                                       * world_db["MAP_LENGTH"]
 742                                                       + mv_result[2]]:
 743                 candidates.append((mv_result[1], mv_result[2]))
 744         if len(candidates):
 745             i = rand.next() % len(candidates)
 746             id = id_setter(-1, "Things")
 747             newT = new_Thing(t["T_TYPE"], (candidates[i][0], candidates[i][1]))
 748             world_db["Things"][id] = newT
 749
 750
 751 def try_healing(t):
 752     """If t's HP < max, increment them if well-nourished, maybe waiting."""
 753     if t["T_LIFEPOINTS"] < \
 754        world_db["ThingTypes"][t["T_TYPE"]]["TT_LIFEPOINTS"]:
 755         wait_id = [id for id in world_db["ThingActions"]
 756                       if world_db["ThingActions"][id]["TA_NAME"] == "wait"][0]
 757         wait_divider = 8 if t["T_COMMAND"] == wait_id else 1
 758         testval = int(abs(t["T_SATIATION"]) / wait_divider)
 759         if (testval <= 1 or 1 == (rand.next() % testval)):
 760             t["T_LIFEPOINTS"] += 1
 761             if t == world_db["Things"][0]:
 762                 log("You heal.")
 763
 764
 765 def hunger_per_turn(type_id):
 766     """The amount of satiation score lost per turn for things of given type."""
 767     return int(math.sqrt(world_db["ThingTypes"][type_id]["TT_LIFEPOINTS"]))
 768
 769
 770 def hunger(t):
 771     """Decrement t's satiation,dependent on it trigger lifepoint dec chance."""
 772     if t["T_SATIATION"] > -32768:
 773         t["T_SATIATION"] -= hunger_per_turn(t["T_TYPE"])
 774     if 0 != t["T_SATIATION"] and 0 == int(rand.next() / abs(t["T_SATIATION"])):
 775         if t == world_db["Things"][0]:
 776             if t["T_SATIATION"] < 0:
 777                 log("You suffer from hunger.")
 778             else:
 779                 log("You suffer from over-eating.")
 780         decrement_lifepoints(t)
 781
 782
 783 def get_dir_to_target(t, filter):
 784     """Try to set T_COMMAND/T_ARGUMENT for move to "filter"-determined target.
 785
 786     The path-wise nearest target is chosen, via the shortest available path.
 787     Target must not be t. On succcess, return positive value, else False.
 788     Filters:
 789     "a": Thing in FOV is animate, but of ThingType, starts out weaker than t
 790          is, and its corpse would be healthy food for t
 791     "f": move away from an enemy – any visible actor whose thing type has more
 792          TT_LIFEPOINTS than t LIFEPOINTS, and might find t's corpse healthy
 793          food – if it is closer than n steps, where n will shrink as t's hunger
 794          grows; if enemy is too close, move towards (attack) the enemy instead;
 795          if no fleeing is possible, nor attacking useful, wait; don't tread on
 796          non-enemies for fleeing
 797     "c": Thing in memorized map is consumable of sufficient nutrition for t
 798     "s": memory map cell with greatest-reachable degree of unexploredness
 799     """
 800
 801     def zero_score_map_where_char_on_memdepthmap(c):
 802         # OUTSOURCED FOR PERFORMANCE REASONS TO libplomrogue.so:
 803         # for i in [i for i in range(world_db["MAP_LENGTH"] ** 2)
 804         #           if t["T_MEMDEPTHMAP"][i] == mem_depth_c[0]]:
 805         #     set_map_score(i, 0)
 806         map = c_pointer_to_bytearray(t["T_MEMDEPTHMAP"])
 807         if libpr.zero_score_map_where_char_on_memdepthmap(c, map):
 808             raise RuntimeError("No score map allocated for "
 809                                "zero_score_map_where_char_on_memdepthmap().")
 810
 811     def set_map_score_at_thingpos(id, score):
 812         pos = world_db["Things"][id]["T_POSY"] * world_db["MAP_LENGTH"] \
 813                                      + world_db["Things"][id]["T_POSX"]
 814         set_map_score(pos, score)
 815
 816     def set_map_score(pos, score):
 817         test = libpr.set_map_score(pos, score)
 818         if test:
 819             raise RuntimeError("No score map allocated for set_map_score().")
 820
 821     def get_map_score(pos):
 822         result = libpr.get_map_score(pos)
 823         if result < 0:
 824             raise RuntimeError("No score map allocated for get_map_score().")
 825         return result
 826
 827     def animate_in_fov(Thing):
 828         if Thing["carried"] or Thing == t or not Thing["T_LIFEPOINTS"]:
 829             return False
 830         pos = Thing["T_POSY"] * world_db["MAP_LENGTH"] + Thing["T_POSX"]
 831         if ord("v") == t["fovmap"][pos]:
 832             return True
 833
 834     def good_attack_target(v):
 835         eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
 836         type = world_db["ThingTypes"][v["T_TYPE"]]
 837         type_corpse = world_db["ThingTypes"][type["TT_CORPSE_ID"]]
 838         if t["T_LIFEPOINTS"] > type["TT_LIFEPOINTS"] \
 839         and type_corpse["TT_TOOL"] == "food" \
 840         and type_corpse["TT_TOOLPOWER"] > eat_cost:
 841             return True
 842         return False
 843
 844     def good_flee_target(m):
 845         own_corpse_id = world_db["ThingTypes"][t["T_TYPE"]]["TT_CORPSE_ID"]
 846         corpse_type = world_db["ThingTypes"][own_corpse_id]
 847         targetness = 0 if corpse_type["TT_TOOL"] != "food" \
 848                        else corpse_type["TT_TOOLPOWER"]
 849         type = world_db["ThingTypes"][m["T_TYPE"]]
 850         if t["T_LIFEPOINTS"] < type["TT_LIFEPOINTS"] \
 851         and targetness > eat_vs_hunger_threshold(m["T_TYPE"]):
 852             return True
 853         return False
 854
 855     def seeing_thing():
 856         if t["fovmap"] and "a" == filter:
 857             for id in world_db["Things"]:
 858                 if animate_in_fov(world_db["Things"][id]):
 859                     if good_attack_target(world_db["Things"][id]):
 860                         return True
 861         elif t["fovmap"] and "f" == filter:
 862             for id in world_db["Things"]:
 863                 if animate_in_fov(world_db["Things"][id]):
 864                     if good_flee_target(world_db["Things"][id]):
 865                         return True
 866         elif t["T_MEMMAP"] and "c" == filter:
 867             eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
 868             for mt in t["T_MEMTHING"]:
 869                 if ' ' != chr(t["T_MEMMAP"][(mt[1] * world_db["MAP_LENGTH"])
 870                                             + mt[2]]) \
 871                    and world_db["ThingTypes"][mt[0]]["TT_TOOL"] == "food" \
 872                    and world_db["ThingTypes"][mt[0]]["TT_TOOLPOWER"] \
 873                        > eat_cost:
 874                     return True
 875         return False
 876
 877     def set_cells_passable_on_memmap_to_65534_on_scoremap():
 878         # OUTSOURCED FOR PERFORMANCE REASONS TO libplomrogue.so:
 879         # ord_dot = ord(".")
 880         # memmap = t["T_MEMMAP"]
 881         # for i in [i for i in range(world_db["MAP_LENGTH"] ** 2)
 882         #            if ord_dot == memmap[i]]:
 883         #     set_map_score(i, 65534) # i.e. 65535-1
 884         map = c_pointer_to_bytearray(t["T_MEMMAP"])
 885         if libpr.set_cells_passable_on_memmap_to_65534_on_scoremap(map):
 886             raise RuntimeError("No score map allocated for set_cells_passable"
 887                                "_on_memmap_to_65534_on_scoremap().")
 888
 889     def init_score_map():
 890         test = libpr.init_score_map()
 891         if test:
 892             raise RuntimeError("Malloc error in init_score_map().")
 893         ord_v = ord("v")
 894         ord_blank = ord(" ")
 895         set_cells_passable_on_memmap_to_65534_on_scoremap()
 896         if "a" == filter:
 897             for id in world_db["Things"]:
 898                 if animate_in_fov(world_db["Things"][id]) \
 899                 and good_attack_target(world_db["Things"][id]):
 900                     set_map_score_at_thingpos(id, 0)
 901         elif "f" == filter:
 902             for id in world_db["Things"]:
 903                 if animate_in_fov(world_db["Things"][id]) \
 904                 and good_flee_target(world_db["Things"][id]):
 905                     set_map_score_at_thingpos(id, 0)
 906         elif "c" == filter:
 907             eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
 908             for mt in [mt for mt in t["T_MEMTHING"]
 909                        if ord_blank != t["T_MEMMAP"][mt[1]
 910                                                      * world_db["MAP_LENGTH"]
 911                                                      + mt[2]]
 912                        if world_db["ThingTypes"][mt[0]]["TT_TOOL"] == "food"
 913                        if world_db["ThingTypes"][mt[0]]["TT_TOOLPOWER"]
 914                            > eat_cost]:
 915                 set_map_score(mt[1] * world_db["MAP_LENGTH"] + mt[2], 0)
 916         elif "s" == filter:
 917             zero_score_map_where_char_on_memdepthmap(mem_depth_c[0])
 918         if "a" != filter:
 919             for id in world_db["Things"]:
 920                 if animate_in_fov(world_db["Things"][id]):
 921                     if "f" == filter:
 922                         pos = world_db["Things"][id]["T_POSY"] \
 923                               * world_db["MAP_LENGTH"] \
 924                               + world_db["Things"][id]["T_POSX"]
 925                         if 0 == get_map_score(pos):
 926                             continue
 927                     set_map_score_at_thingpos(id, 65535)
 928
 929     def rand_target_dir(neighbors, cmp, dirs):
 930         candidates = []
 931         n_candidates = 0
 932         for i in range(len(dirs)):
 933             if cmp == neighbors[i]:
 934                 candidates.append(dirs[i])
 935                 n_candidates += 1
 936         return candidates[rand.next() % n_candidates] if n_candidates else 0
 937
 938     def get_neighbor_scores(dirs, eye_pos):
 939         scores = []
 940         if libpr.ready_neighbor_scores(eye_pos):
 941             raise RuntimeError("No score map allocated for " +
 942                                "ready_neighbor_scores.()")
 943         for i in range(len(dirs)):
 944             scores.append(libpr.get_neighbor_score(i))
 945         return scores
 946
 947     def get_dir_from_neighbors():
 948         dir_to_target = False
 949         dirs = "edcxsw"
 950         eye_pos = t["T_POSY"] * world_db["MAP_LENGTH"] + t["T_POSX"]
 951         neighbors = get_neighbor_scores(dirs, eye_pos)
 952         minmax_start = 0 if "f" == filter else 65535 - 1
 953         minmax_neighbor = minmax_start
 954         for i in range(len(dirs)):
 955             if ("f" == filter and get_map_score(eye_pos) < neighbors[i] and
 956                 minmax_neighbor < neighbors[i] and 65535 != neighbors[i]) \
 957                or ("f" != filter and minmax_neighbor > neighbors[i]):
 958                 minmax_neighbor = neighbors[i]
 959         if minmax_neighbor != minmax_start:
 960             dir_to_target = rand_target_dir(neighbors, minmax_neighbor, dirs)
 961         if "f" == filter:
 962             distance = get_map_score(eye_pos)
 963             fear_distance = world_db["MAP_LENGTH"]
 964             if t["T_SATIATION"] < 0 and math.sqrt(-t["T_SATIATION"]) > 0:
 965                 fear_distance = fear_distance / math.sqrt(-t["T_SATIATION"])
 966             attack_distance = 1
 967             if not dir_to_target:
 968                 if attack_distance >= distance:
 969                     dir_to_target = rand_target_dir(neighbors,
 970                                                     distance - 1, dirs)
 971                 elif fear_distance >= distance:
 972                     t["T_COMMAND"] = [id for id in world_db["ThingActions"]
 973                                       if
 974                                       world_db["ThingActions"][id]["TA_NAME"]
 975                                       == "wait"][0]
 976                     return 1
 977             elif dir_to_target and fear_distance < distance:
 978                 dir_to_target = 0
 979         return dir_to_target
 980
 981     dir_to_target = False
 982     mem_depth_c = b' '
 983     run_i = 9 + 1 if "s" == filter else 1
 984     while run_i and not dir_to_target and ("s" == filter or seeing_thing()):
 985         run_i -= 1
 986         init_score_map()
 987         mem_depth_c = b'9' if b' ' == mem_depth_c \
 988             else bytes([mem_depth_c[0] - 1])
 989         if libpr.dijkstra_map():
 990             raise RuntimeError("No score map allocated for dijkstra_map().")
 991         dir_to_target = get_dir_from_neighbors()
 992         libpr.free_score_map()
 993         if dir_to_target and str == type(dir_to_target):
 994             t["T_COMMAND"] = [id for id in world_db["ThingActions"]
 995                               if world_db["ThingActions"][id]["TA_NAME"]
 996                               == "move"][0]
 997             t["T_ARGUMENT"] = ord(dir_to_target)
 998     return dir_to_target
 999
1000
1001 def standing_on_food(t):
1002     """Return True/False whether t is standing on healthy consumable."""
1003     eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
1004     for id in [id for id in world_db["Things"] if world_db["Things"][id] != t
1005                if not world_db["Things"][id]["carried"]
1006                if world_db["Things"][id]["T_POSY"] == t["T_POSY"]
1007                if world_db["Things"][id]["T_POSX"] == t["T_POSX"]
1008                if world_db["ThingTypes"][world_db["Things"][id]["T_TYPE"]]
1009                   ["TT_TOOL"] == "food"
1010                if world_db["ThingTypes"][world_db["Things"][id]["T_TYPE"]]
1011                   ["TT_TOOLPOWER"] > eat_cost]:
1012         return True
1013     return False
1014
1015
1016 def get_inventory_slot_to_consume(t):
1017     """Return invent. slot of healthiest consumable(if any healthy),else -1."""
1018     cmp_food = -1
1019     selection = -1
1020     i = 0
1021     eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
1022     for id in t["T_CARRIES"]:
1023         type = world_db["Things"][id]["T_TYPE"]
1024         if world_db["ThingTypes"][type]["TT_TOOL"] == "food" \
1025            and world_db["ThingTypes"][type]["TT_TOOLPOWER"]:
1026             nutvalue = world_db["ThingTypes"][type]["TT_TOOLPOWER"]
1027             tmp_cmp = abs(t["T_SATIATION"] + nutvalue - eat_cost)
1028             if (cmp_food < 0 and tmp_cmp < abs(t["T_SATIATION"])) \
1029             or tmp_cmp < cmp_food:
1030                 cmp_food = tmp_cmp
1031                 selection = i
1032         i += 1
1033     return selection
1034
1035
1036 def ai(t):
1037     """Determine next command/argment for actor t via AI algorithms."""
1038     t["T_COMMAND"] = [id for id in world_db["ThingActions"]
1039                       if world_db["ThingActions"][id]["TA_NAME"] == "wait"][0]
1040     if get_dir_to_target(t, "f"):
1041         return
1042     sel = get_inventory_slot_to_consume(t)
1043     if -1 != sel:
1044         t["T_COMMAND"] = [id for id in world_db["ThingActions"]
1045                           if world_db["ThingActions"][id]["TA_NAME"]
1046                              == "use"][0]
1047         t["T_ARGUMENT"] = sel
1048     elif standing_on_food(t):
1049             t["T_COMMAND"] = [id for id in world_db["ThingActions"]
1050                               if world_db["ThingActions"][id]["TA_NAME"]
1051                               == "pick_up"][0]
1052     else:
1053         going_to_known_food_spot = get_dir_to_target(t, "c")
1054         if not going_to_known_food_spot:
1055             aiming_for_walking_food = get_dir_to_target(t, "a")
1056             if not aiming_for_walking_food:
1057                 get_dir_to_target(t, "s")
1058
1059
1060 def turn_over():
1061     """Run game world and its inhabitants until new player input expected."""
1062     id = 0
1063     whilebreaker = False
1064     while world_db["Things"][0]["T_LIFEPOINTS"]:
1065         proliferable_map = world_db["MAP"][:]
1066         for id in [id for id in world_db["Things"]
1067                    if not world_db["Things"][id]["carried"]]:
1068             y = world_db["Things"][id]["T_POSY"]
1069             x = world_db["Things"][id]["T_POSX"]
1070             proliferable_map[y * world_db["MAP_LENGTH"] + x] = ord('X')
1071         for id in [id for id in world_db["Things"]]:  # Only what's from start!
1072             if not id in world_db["Things"] or \
1073                world_db["Things"][id]["carried"]:   # May have been consumed or
1074                 continue                            # picked up during turn …
1075             Thing = world_db["Things"][id]
1076             if Thing["T_LIFEPOINTS"]:
1077                 if not Thing["T_COMMAND"]:
1078                     update_map_memory(Thing)
1079                     if 0 == id:
1080                         whilebreaker = True
1081                         break
1082                     ai(Thing)
1083                 try_healing(Thing)
1084                 hunger(Thing)
1085                 if Thing["T_LIFEPOINTS"]:
1086                     Thing["T_PROGRESS"] += 1
1087                     taid = [a for a in world_db["ThingActions"]
1088                               if a == Thing["T_COMMAND"]][0]
1089                     ThingAction = world_db["ThingActions"][taid]
1090                     if Thing["T_PROGRESS"] == ThingAction["TA_EFFORT"]:
1091                         eval("actor_" + ThingAction["TA_NAME"])(Thing)
1092                         Thing["T_COMMAND"] = 0
1093                         Thing["T_PROGRESS"] = 0
1094             thingproliferation(Thing, proliferable_map)
1095         if whilebreaker:
1096             break
1097         world_db["TURN"] += 1
1098
1099
1100 def new_Thing(type, pos=(0, 0)):
1101     """Return Thing of type T_TYPE, with fovmap if alive and world active."""
1102     thing = {
1103         "T_LIFEPOINTS": world_db["ThingTypes"][type]["TT_LIFEPOINTS"],
1104         "T_ARGUMENT": 0,
1105         "T_PROGRESS": 0,
1106         "T_SATIATION": 0,
1107         "T_COMMAND": 0,
1108         "T_TYPE": type,
1109         "T_POSY": pos[0],
1110         "T_POSX": pos[1],
1111         "T_CARRIES": [],
1112         "carried": False,
1113         "T_MEMTHING": [],
1114         "T_MEMMAP": False,
1115         "T_MEMDEPTHMAP": False,
1116         "fovmap": False
1117     }
1118     if world_db["WORLD_ACTIVE"] and thing["T_LIFEPOINTS"]:
1119         build_fov_map(thing)
1120     return thing
1121
1122
1123 def id_setter(id, category, id_store=False, start_at_1=False):
1124     """Set ID of object of category to manipulate ID unused? Create new one.
1125     The ID is stored as id_store.id (if id_store is set). If the integer of the
1126     input is valid (if start_at_1, >= 0, else >= -1), but <0 or (if start_at_1)
1127     <1, calculate new ID: lowest unused ID >=0 or (if start_at_1) >= 1. None is
1128     always returned when no new object is created, else the new object's ID.
1129     """
1130     min = 0 if start_at_1 else -1
1131     if str == type(id):
1132         id = integer_test(id, min)
1133     if None != id:
1134         if id in world_db[category]:
1135             if id_store:
1136                 id_store.id = id
1137             return None
1138         else:
1139             if (start_at_1 and 0 == id) \
1140                or ((not start_at_1) and (id < 0)):
1141                 id = 0 if start_at_1 else -1
1142                 while 1:
1143                     id = id + 1
1144                     if id not in world_db[category]:
1145                         break
1146             if id_store:
1147                 id_store.id = id
1148     return id
1149
1150
1151 def command_ping():
1152     """Send PONG line to server output file."""
1153     strong_write(io_db["file_out"], "PONG\n")
1154
1155
1156 def command_quit():
1157     """Abort server process."""
1158     if None == opts.replay:
1159         if world_db["WORLD_ACTIVE"]:
1160             save_world()
1161         atomic_write(io_db["path_record"], io_db["record_chunk"], do_append=True)
1162     raise SystemExit("received QUIT command")
1163
1164
1165 def command_thingshere(str_y, str_x):
1166     """Write to out file list of Things known to player at coordinate y, x."""
1167     if world_db["WORLD_ACTIVE"]:
1168         y = integer_test(str_y, 0, 255)
1169         x = integer_test(str_x, 0, 255)
1170         length = world_db["MAP_LENGTH"]
1171         if None != y and None != x and y < length and x < length:
1172             pos = (y * world_db["MAP_LENGTH"]) + x
1173             strong_write(io_db["file_out"], "THINGS_HERE START\n")
1174             if "v" == chr(world_db["Things"][0]["fovmap"][pos]):
1175                 for id in [id for tid in sorted(list(world_db["ThingTypes"]))
1176                               for id in world_db["Things"]
1177                               if not world_db["Things"][id]["carried"]
1178                               if world_db["Things"][id]["T_TYPE"] == tid
1179                               if y == world_db["Things"][id]["T_POSY"]
1180                               if x == world_db["Things"][id]["T_POSX"]]:
1181                     type = world_db["Things"][id]["T_TYPE"]
1182                     name = world_db["ThingTypes"][type]["TT_NAME"]
1183                     strong_write(io_db["file_out"], name + "\n")
1184             else:
1185                 for mt in [mt for tid in sorted(list(world_db["ThingTypes"]))
1186                               for mt in world_db["Things"][0]["T_MEMTHING"]
1187                               if mt[0] == tid if y == mt[1] if x == mt[2]]:
1188                     name = world_db["ThingTypes"][mt[0]]["TT_NAME"]
1189                     strong_write(io_db["file_out"], name + "\n")
1190             strong_write(io_db["file_out"], "THINGS_HERE END\n")
1191         else:
1192             print("Ignoring: Invalid map coordinates.")
1193     else:
1194         print("Ignoring: Command only works on existing worlds.")
1195
1196
1197 def play_commander(action, args=False):
1198     """Setter for player's T_COMMAND and T_ARGUMENT, then calling turn_over().
1199
1200     T_ARGUMENT is set to direction char if action=="wait",or 8-bit int if args.
1201     """
1202
1203     def set_command():
1204         id = [x for x in world_db["ThingActions"]
1205               if world_db["ThingActions"][x]["TA_NAME"] == action][0]
1206         world_db["Things"][0]["T_COMMAND"] = id
1207         turn_over()
1208
1209     def set_command_and_argument_int(str_arg):
1210         val = integer_test(str_arg, 0, 255)
1211         if None != val:
1212             world_db["Things"][0]["T_ARGUMENT"] = val
1213             set_command()
1214
1215     def set_command_and_argument_movestring(str_arg):
1216         if str_arg in directions_db:
1217             world_db["Things"][0]["T_ARGUMENT"] = ord(directions_db[str_arg])
1218             set_command()
1219         else:
1220             print("Ignoring: Argument must be valid direction string.")
1221
1222     if action == "move":
1223         return set_command_and_argument_movestring
1224     elif args:
1225         return set_command_and_argument_int
1226     else:
1227         return set_command
1228
1229
1230 def command_seedrandomness(seed_string):
1231     """Set rand seed to int(seed_string)."""
1232     val = integer_test(seed_string, 0, 4294967295)
1233     if None != val:
1234         rand.seed = val
1235
1236
1237 def command_makeworld(seed_string):
1238     """(Re-)build game world, i.e. map, things, to a new turn 1 from seed.
1239
1240     Seed rand with seed. Do more only with a "wait" ThingAction and
1241     world["PLAYER_TYPE"] matching ThingType of TT_START_NUMBER > 0. Then,
1242     world_db["Things"] emptied, call make_map() and set
1243     world_db["WORLD_ACTIVE"], world_db["TURN"] to 1. Build new Things
1244     according to ThingTypes' TT_START_NUMBERS, with Thing of ID 0 to ThingType
1245     of ID = world["PLAYER_TYPE"]. Place Things randomly, and actors not on each
1246     other. Init player's memory map. Write "NEW_WORLD" line to out file.
1247     Call log_help().
1248     """
1249
1250     def free_pos():
1251         i = 0
1252         while 1:
1253             err = "Space to put thing on too hard to find. Map too small?"
1254             while 1:
1255                 y = rand.next() % world_db["MAP_LENGTH"]
1256                 x = rand.next() % world_db["MAP_LENGTH"]
1257                 if "." == chr(world_db["MAP"][y * world_db["MAP_LENGTH"] + x]):
1258                     break
1259                 i += 1
1260                 if i == 65535:
1261                     raise SystemExit(err)
1262             # Replica of C code, wrongly ignores animatedness of new Thing.
1263             pos_clear = (0 == len([id for id in world_db["Things"]
1264                                    if world_db["Things"][id]["T_LIFEPOINTS"]
1265                                    if world_db["Things"][id]["T_POSY"] == y
1266                                    if world_db["Things"][id]["T_POSX"] == x]))
1267             if pos_clear:
1268                 break
1269         return (y, x)
1270
1271     val = integer_test(seed_string, 0, 4294967295)
1272     if None == val:
1273         return
1274     rand.seed = val
1275     player_will_be_generated = False
1276     playertype = world_db["PLAYER_TYPE"]
1277     for ThingType in world_db["ThingTypes"]:
1278         if playertype == ThingType:
1279             if 0 < world_db["ThingTypes"][ThingType]["TT_START_NUMBER"]:
1280                 player_will_be_generated = True
1281             break
1282     if not player_will_be_generated:
1283         print("Ignoring: No player type with start number >0 defined.")
1284         return
1285     wait_action = False
1286     for ThingAction in world_db["ThingActions"]:
1287         if "wait" == world_db["ThingActions"][ThingAction]["TA_NAME"]:
1288             wait_action = True
1289     if not wait_action:
1290         print("Ignoring beyond SEED_MAP: " +
1291               "No thing action with name 'wait' defined.")
1292         return
1293     world_db["Things"] = {}
1294     make_map()
1295     world_db["WORLD_ACTIVE"] = 1
1296     world_db["TURN"] = 1
1297     for i in range(world_db["ThingTypes"][playertype]["TT_START_NUMBER"]):
1298         id = id_setter(-1, "Things")
1299         world_db["Things"][id] = new_Thing(playertype, free_pos())
1300     if not world_db["Things"][0]["fovmap"]:
1301         empty_fovmap = bytearray(b" " * world_db["MAP_LENGTH"] ** 2)
1302         world_db["Things"][0]["fovmap"] = empty_fovmap
1303     update_map_memory(world_db["Things"][0])
1304     for type in world_db["ThingTypes"]:
1305         for i in range(world_db["ThingTypes"][type]["TT_START_NUMBER"]):
1306             if type != playertype:
1307                 id = id_setter(-1, "Things")
1308                 world_db["Things"][id] = new_Thing(type, free_pos())
1309     strong_write(io_db["file_out"], "NEW_WORLD\n")
1310     log_help()
1311
1312
1313 def command_maplength(maplength_string):
1314     """Redefine map length. Invalidate map, therefore lose all things on it."""
1315     val = integer_test(maplength_string, 1, 256)
1316     if None != val:
1317         world_db["MAP_LENGTH"] = val
1318         world_db["MAP"] = False
1319         set_world_inactive()
1320         world_db["Things"] = {}
1321         libpr.set_maplength(val)
1322
1323
1324 def command_worldactive(worldactive_string):
1325     """Toggle world_db["WORLD_ACTIVE"] if possible.
1326
1327     An active world can always be set inactive. An inactive world can only be
1328     set active with a "wait" ThingAction, and a player Thing (of ID 0), and a
1329     map. On activation, rebuild all Things' FOVs, and the player's map memory.
1330     Also call log_help().
1331     """
1332     val = integer_test(worldactive_string, 0, 1)
1333     if None != val:
1334         if 0 != world_db["WORLD_ACTIVE"]:
1335             if 0 == val:
1336                 set_world_inactive()
1337             else:
1338                 print("World already active.")
1339         elif 0 == world_db["WORLD_ACTIVE"]:
1340             wait_exists = False
1341             for ThingAction in world_db["ThingActions"]:
1342                 if "wait" == world_db["ThingActions"][ThingAction]["TA_NAME"]:
1343                     wait_exists = True
1344                     break
1345             player_exists = False
1346             for Thing in world_db["Things"]:
1347                 if 0 == Thing:
1348                     player_exists = True
1349                     break
1350             if wait_exists and player_exists and world_db["MAP"]:
1351                 for id in world_db["Things"]:
1352                     if world_db["Things"][id]["T_LIFEPOINTS"]:
1353                         build_fov_map(world_db["Things"][id])
1354                         if 0 == id:
1355                             update_map_memory(world_db["Things"][id], False)
1356                 if not world_db["Things"][0]["T_LIFEPOINTS"]:
1357                     empty_fovmap = bytearray(b" " * world_db["MAP_LENGTH"] ** 2)
1358                     world_db["Things"][0]["fovmap"] = empty_fovmap
1359                 world_db["WORLD_ACTIVE"] = 1
1360                 log_help()
1361             else:
1362                 print("Ignoring: Not all conditions for world activation met.")
1363
1364
1365 def test_for_id_maker(object, category):
1366     """Return decorator testing for object having "id" attribute."""
1367     def decorator(f):
1368         def helper(*args):
1369             if hasattr(object, "id"):
1370                 f(*args)
1371             else:
1372                 print("Ignoring: No " + category +
1373                       " defined to manipulate yet.")
1374         return helper
1375     return decorator
1376
1377
1378 def command_tid(id_string):
1379     """Set ID of Thing to manipulate. ID unused? Create new one.
1380
1381     Default new Thing's type to the first available ThingType, others: zero.
1382     """
1383     id = id_setter(id_string, "Things", command_tid)
1384     if None != id:
1385         if world_db["ThingTypes"] == {}:
1386             print("Ignoring: No ThingType to settle new Thing in.")
1387             return
1388         type = list(world_db["ThingTypes"].keys())[0]
1389         world_db["Things"][id] = new_Thing(type)
1390
1391
1392 test_Thing_id = test_for_id_maker(command_tid, "Thing")
1393
1394
1395 @test_Thing_id
1396 def command_tcommand(str_int):
1397     """Set T_COMMAND of selected Thing."""
1398     val = integer_test(str_int, 0)
1399     if None != val:
1400         if 0 == val or val in world_db["ThingActions"]:
1401             world_db["Things"][command_tid.id]["T_COMMAND"] = val
1402         else:
1403             print("Ignoring: ThingAction ID belongs to no known ThingAction.")
1404
1405
1406 @test_Thing_id
1407 def command_ttype(str_int):
1408     """Set T_TYPE of selected Thing."""
1409     val = integer_test(str_int, 0)
1410     if None != val:
1411         if val in world_db["ThingTypes"]:
1412             world_db["Things"][command_tid.id]["T_TYPE"] = val
1413         else:
1414             print("Ignoring: ThingType ID belongs to no known ThingType.")
1415
1416
1417 @test_Thing_id
1418 def command_tcarries(str_int):
1419     """Append int(str_int) to T_CARRIES of selected Thing.
1420
1421     The ID int(str_int) must not be of the selected Thing, and must belong to a
1422     Thing with unset "carried" flag. Its "carried" flag will be set on owning.
1423     """
1424     val = integer_test(str_int, 0)
1425     if None != val:
1426         if val == command_tid.id:
1427             print("Ignoring: Thing cannot carry itself.")
1428         elif val in world_db["Things"] \
1429                 and not world_db["Things"][val]["carried"]:
1430             world_db["Things"][command_tid.id]["T_CARRIES"].append(val)
1431             world_db["Things"][val]["carried"] = True
1432         else:
1433             print("Ignoring: Thing not available for carrying.")
1434     # Note that the whole carrying structure is different from the C version:
1435     # Carried-ness is marked by a "carried" flag, not by Things containing
1436     # Things internally.
1437
1438
1439 @test_Thing_id
1440 def command_tmemthing(str_t, str_y, str_x):
1441     """Add (int(str_t), int(str_y), int(str_x)) to selected Thing's T_MEMTHING.
1442
1443     The type must fit to an existing ThingType, and the position into the map.
1444     """
1445     type = integer_test(str_t, 0)
1446     posy = integer_test(str_y, 0, 255)
1447     posx = integer_test(str_x, 0, 255)
1448     if None != type and None != posy and None != posx:
1449         if type not in world_db["ThingTypes"] \
1450            or posy >= world_db["MAP_LENGTH"] or posx >= world_db["MAP_LENGTH"]:
1451             print("Ignoring: Illegal value for thing type or position.")
1452         else:
1453             memthing = (type, posy, posx)
1454             world_db["Things"][command_tid.id]["T_MEMTHING"].append(memthing)
1455
1456
1457 def setter_map(maptype):
1458     """Set (world or Thing's) map of maptype's int(str_int)-th line to mapline.
1459
1460     If no map of maptype exists yet, initialize it with ' ' bytes first.
1461     """
1462
1463     def valid_map_line(str_int, mapline):
1464         val = integer_test(str_int, 0, 255)
1465         if None != val:
1466             if val >= world_db["MAP_LENGTH"]:
1467                 print("Illegal value for map line number.")
1468             elif len(mapline) != world_db["MAP_LENGTH"]:
1469                 print("Map line length is unequal map width.")
1470             else:
1471                 return val
1472         return None
1473
1474     def nonThingMap_helper(str_int, mapline):
1475         val = valid_map_line(str_int, mapline)
1476         if None != val:
1477             length = world_db["MAP_LENGTH"]
1478             if not world_db["MAP"]:
1479                 map = bytearray(b' ' * (length ** 2))
1480             else:
1481                 map = world_db["MAP"]
1482             map[val * length:(val * length) + length] = mapline.encode()
1483             if not world_db["MAP"]:
1484                 world_db["MAP"] = map
1485
1486     @test_Thing_id
1487     def ThingMap_helper(str_int, mapline):
1488         val = valid_map_line(str_int, mapline)
1489         if None != val:
1490             length = world_db["MAP_LENGTH"]
1491             if not world_db["Things"][command_tid.id][maptype]:
1492                 map = bytearray(b' ' * (length ** 2))
1493             else:
1494                 map = world_db["Things"][command_tid.id][maptype]
1495             map[val * length:(val * length) + length] = mapline.encode()
1496             if not world_db["Things"][command_tid.id][maptype]:
1497                 world_db["Things"][command_tid.id][maptype] = map
1498
1499     return nonThingMap_helper if maptype == "MAP" else ThingMap_helper
1500
1501
1502
1503 def setter_tpos(axis):
1504     """Generate setter for T_POSX or  T_POSY of selected Thing.
1505
1506     If world is active, rebuilds animate things' fovmap, player's memory map.
1507     """
1508     @test_Thing_id
1509     def helper(str_int):
1510         val = integer_test(str_int, 0, 255)
1511         if None != val:
1512             if val < world_db["MAP_LENGTH"]:
1513                 world_db["Things"][command_tid.id]["T_POS" + axis] = val
1514                 if world_db["WORLD_ACTIVE"] \
1515                    and world_db["Things"][command_tid.id]["T_LIFEPOINTS"]:
1516                     build_fov_map(world_db["Things"][command_tid.id])
1517                     if 0 == command_tid.id:
1518                         update_map_memory(world_db["Things"][command_tid.id])
1519             else:
1520                 print("Ignoring: Position is outside of map.")
1521     return helper
1522
1523
1524 def command_ttid(id_string):
1525     """Set ID of ThingType to manipulate. ID unused? Create new one.
1526
1527     Default new ThingType's TT_SYMBOL to "?", TT_CORPSE_ID to self, TT_TOOL to
1528     "", others: 0.
1529     """
1530     id = id_setter(id_string, "ThingTypes", command_ttid)
1531     if None != id:
1532         world_db["ThingTypes"][id] = {
1533             "TT_NAME": "(none)",
1534             "TT_TOOLPOWER": 0,
1535             "TT_LIFEPOINTS": 0,
1536             "TT_PROLIFERATE": 0,
1537             "TT_START_NUMBER": 0,
1538             "TT_SYMBOL": "?",
1539             "TT_CORPSE_ID": id,
1540             "TT_TOOL": ""
1541         }
1542
1543
1544 test_ThingType_id = test_for_id_maker(command_ttid, "ThingType")
1545
1546
1547 @test_ThingType_id
1548 def command_ttname(name):
1549     """Set TT_NAME of selected ThingType."""
1550     world_db["ThingTypes"][command_ttid.id]["TT_NAME"] = name
1551
1552
1553 @test_ThingType_id
1554 def command_tttool(name):
1555     """Set TT_TOOL of selected ThingType."""
1556     world_db["ThingTypes"][command_ttid.id]["TT_TOOL"] = name
1557
1558
1559 @test_ThingType_id
1560 def command_ttsymbol(char):
1561     """Set TT_SYMBOL of selected ThingType. """
1562     if 1 == len(char):
1563         world_db["ThingTypes"][command_ttid.id]["TT_SYMBOL"] = char
1564     else:
1565         print("Ignoring: Argument must be single character.")
1566
1567
1568 @test_ThingType_id
1569 def command_ttcorpseid(str_int):
1570     """Set TT_CORPSE_ID of selected ThingType."""
1571     val = integer_test(str_int, 0)
1572     if None != val:
1573         if val in world_db["ThingTypes"]:
1574             world_db["ThingTypes"][command_ttid.id]["TT_CORPSE_ID"] = val
1575         else:
1576             print("Ignoring: Corpse ID belongs to no known ThignType.")
1577
1578
1579 def command_taid(id_string):
1580     """Set ID of ThingAction to manipulate. ID unused? Create new one.
1581
1582     Default new ThingAction's TA_EFFORT to 1, its TA_NAME to "wait".
1583     """
1584     id = id_setter(id_string, "ThingActions", command_taid, True)
1585     if None != id:
1586         world_db["ThingActions"][id] = {
1587             "TA_EFFORT": 1,
1588             "TA_NAME": "wait"
1589         }
1590
1591
1592 test_ThingAction_id = test_for_id_maker(command_taid, "ThingAction")
1593
1594
1595 @test_ThingAction_id
1596 def command_taname(name):
1597     """Set TA_NAME of selected ThingAction.
1598
1599     The name must match a valid thing action function. If after the name
1600     setting no ThingAction with name "wait" remains, call set_world_inactive().
1601     """
1602     if name == "wait" or name == "move" or name == "use" or name == "drop" \
1603        or name == "pick_up":
1604         world_db["ThingActions"][command_taid.id]["TA_NAME"] = name
1605         if 1 == world_db["WORLD_ACTIVE"]:
1606             wait_defined = False
1607             for id in world_db["ThingActions"]:
1608                 if "wait" == world_db["ThingActions"][id]["TA_NAME"]:
1609                     wait_defined = True
1610                     break
1611             if not wait_defined:
1612                 set_world_inactive()
1613     else:
1614         print("Ignoring: Invalid action name.")
1615     # In contrast to the original,naming won't map a function to a ThingAction.
1616
1617
1618 def command_ai():
1619     """Call ai() on player Thing, then turn_over()."""
1620     ai(world_db["Things"][0])
1621     turn_over()
1622
1623
1624 """Commands database.
1625
1626 Map command start tokens to ([0]) number of expected command arguments, ([1])
1627 the command's meta-ness (i.e. is it to be written to the record file, is it to
1628 be ignored in replay mode if read from server input file), and ([2]) a function
1629 to be called on it.
1630 """
1631 commands_db = {
1632     "QUIT": (0, True, command_quit),
1633     "PING": (0, True, command_ping),
1634     "THINGS_HERE": (2, True, command_thingshere),
1635     "MAKE_WORLD": (1, False, command_makeworld),
1636     "SEED_RANDOMNESS": (1, False, command_seedrandomness),
1637     "TURN": (1, False, setter(None, "TURN", 0, 65535)),
1638     "PLAYER_TYPE": (1, False, setter(None, "PLAYER_TYPE", 0)),
1639     "MAP_LENGTH": (1, False, command_maplength),
1640     "WORLD_ACTIVE": (1, False, command_worldactive),
1641     "MAP": (2, False, setter_map("MAP")),
1642     "TA_ID": (1, False, command_taid),
1643     "TA_EFFORT": (1, False, setter("ThingAction", "TA_EFFORT", 0, 255)),
1644     "TA_NAME": (1, False, command_taname),
1645     "TT_ID": (1, False, command_ttid),
1646     "TT_NAME": (1, False, command_ttname),
1647     "TT_TOOL": (1, False, command_tttool),
1648     "TT_SYMBOL": (1, False, command_ttsymbol),
1649     "TT_CORPSE_ID": (1, False, command_ttcorpseid),
1650     "TT_TOOLPOWER": (1, False, setter("ThingType", "TT_TOOLPOWER", 0, 65535)),
1651     "TT_START_NUMBER": (1, False, setter("ThingType", "TT_START_NUMBER",
1652                                          0, 255)),
1653     "TT_PROLIFERATE": (1, False, setter("ThingType", "TT_PROLIFERATE",
1654                                         0, 65535)),
1655     "TT_LIFEPOINTS": (1, False, setter("ThingType", "TT_LIFEPOINTS", 0, 255)),
1656     "T_ID": (1, False, command_tid),
1657     "T_ARGUMENT": (1, False, setter("Thing", "T_ARGUMENT", 0, 255)),
1658     "T_PROGRESS": (1, False, setter("Thing", "T_PROGRESS", 0, 255)),
1659     "T_LIFEPOINTS": (1, False, setter("Thing", "T_LIFEPOINTS", 0, 255)),
1660     "T_SATIATION": (1, False, setter("Thing", "T_SATIATION", -32768, 32767)),
1661     "T_COMMAND": (1, False, command_tcommand),
1662     "T_TYPE": (1, False, command_ttype),
1663     "T_CARRIES": (1, False, command_tcarries),
1664     "T_MEMMAP": (2, False, setter_map("T_MEMMAP")),
1665     "T_MEMDEPTHMAP": (2, False, setter_map("T_MEMDEPTHMAP")),
1666     "T_MEMTHING": (3, False, command_tmemthing),
1667     "T_POSY": (1, False, setter_tpos("Y")),
1668     "T_POSX": (1, False, setter_tpos("X")),
1669     "wait": (0, False, play_commander("wait")),
1670     "move": (1, False, play_commander("move")),
1671     "pick_up": (0, False, play_commander("pick_up")),
1672     "drop": (1, False, play_commander("drop", True)),
1673     "use": (1, False, play_commander("use", True)),
1674     "ai": (0, False, command_ai)
1675 }
1676 # TODO: Unhandled cases: (Un-)killing animates (esp. player!) with T_LIFEPOINTS.
1677
1678
1679 """World state database. With sane default values. (Randomness is in rand.)"""
1680 world_db = {
1681     "TURN": 0,
1682     "MAP_LENGTH": 64,
1683     "PLAYER_TYPE": 0,
1684     "WORLD_ACTIVE": 0,
1685     "MAP": False,
1686     "ThingActions": {},
1687     "ThingTypes": {},
1688     "Things": {}
1689 }
1690
1691 """Mapping of direction names to internal direction chars."""
1692 directions_db = {"east": "d", "south-east": "c", "south-west": "x",
1693                  "west": "s", "north-west": "w", "north-east": "e"}
1694
1695 """File IO database."""
1696 io_db = {
1697     "path_save": "save",
1698     "path_record": "record_save",
1699     "path_worldconf": "confserver/world",
1700     "path_server": "server/",
1701     "path_in": "server/in",
1702     "path_out": "server/out",
1703     "path_worldstate": "server/worldstate",
1704     "tmp_suffix": "_tmp",
1705     "kicked_by_rival": False,
1706     "worldstate_updateable": False
1707 }
1708
1709
1710 try:
1711     libpr = prep_library()
1712     rand = RandomnessIO()
1713     opts = parse_command_line_arguments()
1714     if opts.savefile:
1715         io_db["path_save"] = opts.savefile
1716         io_db["path_record"] = "record_" + opts.savefile
1717     setup_server_io()
1718     if opts.verbose:
1719         io_db["verbose"] = True
1720     if None != opts.replay:
1721         replay_game()
1722     else:
1723         play_game()
1724 except SystemExit as exit:
1725     print("ABORTING: " + exit.args[0])
1726 except:
1727     print("SOMETHING WENT WRONG IN UNEXPECTED WAYS")
1728     raise
1729 finally:
1730     cleanup_server_io()