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 appending. 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"], "a")
  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("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
 670
 671 def actor_pick_up(t):
 672     """Make t pick up (topmost?) Thing from ground into inventory.
 673
 674     Define topmostness by how low the thing's type ID is.
 675     """
 676     ids = [id for id in world_db["Things"] if world_db["Things"][id] != t
 677            if not world_db["Things"][id]["carried"]
 678            if world_db["Things"][id]["T_POSY"] == t["T_POSY"]
 679            if world_db["Things"][id]["T_POSX"] == t["T_POSX"]]
 680     if len(ids):
 681         lowest_tid = -1
 682         for iid in ids:
 683             tid = world_db["Things"][iid]["T_TYPE"]
 684             if lowest_tid == -1 or tid < lowest_tid:
 685                 id = iid
 686                 lowest_tid = tid
 687         world_db["Things"][id]["carried"] = True
 688         t["T_CARRIES"].append(id)
 689         if t == world_db["Things"][0]:
 690                 log("You PICK UP an object.")
 691
 692
 693 def actor_drop(t):
 694     """Make t rop Thing from inventory to ground indexed by T_ARGUMENT."""
 695     # TODO: Handle case where T_ARGUMENT matches nothing.
 696     if len(t["T_CARRIES"]):
 697         id = t["T_CARRIES"][t["T_ARGUMENT"]]
 698         t["T_CARRIES"].remove(id)
 699         world_db["Things"][id]["carried"] = False
 700         if t == world_db["Things"][0]:
 701             log("You DROP an object.")
 702
 703
 704 def actor_use(t):
 705     """Make t use (for now: consume) T_ARGUMENT-indexed Thing in inventory."""
 706     # TODO: Handle case where T_ARGUMENT matches nothing.
 707     if len(t["T_CARRIES"]):
 708         id = t["T_CARRIES"][t["T_ARGUMENT"]]
 709         type = world_db["Things"][id]["T_TYPE"]
 710         if world_db["ThingTypes"][type]["TT_TOOL"] == "food":
 711             t["T_CARRIES"].remove(id)
 712             del world_db["Things"][id]
 713             t["T_SATIATION"] += world_db["ThingTypes"][type]["TT_TOOLPOWER"]
 714             if t == world_db["Things"][0]:
 715                 log("You CONSUME this object.")
 716         elif t == world_db["Things"][0]:
 717             log("You try to use this object, but FAIL.")
 718
 719
 720 def thingproliferation(t, prol_map):
 721     """To chance of 1/TT_PROLIFERATE, create t offspring in open neighbor cell.
 722
 723     Naturally only works with TT_PROLIFERATE > 0. The neighbor cell must be be
 724     marked '.' in prol_map. If there are several map cell candidates, one is
 725     selected randomly.
 726     """
 727     prolscore = world_db["ThingTypes"][t["T_TYPE"]]["TT_PROLIFERATE"]
 728     if prolscore and (1 == prolscore or 1 == (rand.next() % prolscore)):
 729         candidates = []
 730         for dir in [directions_db[key] for key in sorted(directions_db.keys())]:
 731             mv_result = mv_yx_in_dir_legal(dir, t["T_POSY"], t["T_POSX"])
 732             if mv_result[0] and  ord('.') == prol_map[mv_result[1]
 733                                                       * world_db["MAP_LENGTH"]
 734                                                       + mv_result[2]]:
 735                 candidates.append((mv_result[1], mv_result[2]))
 736         if len(candidates):
 737             i = rand.next() % len(candidates)
 738             id = id_setter(-1, "Things")
 739             newT = new_Thing(t["T_TYPE"], (candidates[i][0], candidates[i][1]))
 740             world_db["Things"][id] = newT
 741
 742
 743 def try_healing(t):
 744     """If t's HP < max, increment them if well-nourished, maybe waiting."""
 745     if t["T_LIFEPOINTS"] < \
 746        world_db["ThingTypes"][t["T_TYPE"]]["TT_LIFEPOINTS"]:
 747         wait_id = [id for id in world_db["ThingActions"]
 748                       if world_db["ThingActions"][id]["TA_NAME"] == "wait"][0]
 749         wait_divider = 8 if t["T_COMMAND"] == wait_id else 1
 750         testval = int(abs(t["T_SATIATION"]) / wait_divider)
 751         if (testval <= 1 or 1 == (rand.next() % testval)):
 752             t["T_LIFEPOINTS"] += 1
 753             if t == world_db["Things"][0]:
 754                 log("You HEAL.")
 755
 756
 757 def hunger_per_turn(type_id):
 758     """The amount of satiation score lost per turn for things of given type."""
 759     return int(math.sqrt(world_db["ThingTypes"][type_id]["TT_LIFEPOINTS"]))
 760
 761
 762 def hunger(t):
 763     """Decrement t's satiation,dependent on it trigger lifepoint dec chance."""
 764     if t["T_SATIATION"] > -32768:
 765         t["T_SATIATION"] -= hunger_per_turn(t["T_TYPE"])
 766     if 0 != t["T_SATIATION"] and 0 == int(rand.next() / abs(t["T_SATIATION"])):
 767         if t == world_db["Things"][0]:
 768             if t["T_SATIATION"] < 0:
 769                 log("You SUFFER from hunger.")
 770             else:
 771                 log("You SUFFER from over-eating.")
 772         decrement_lifepoints(t)
 773
 774
 775 def get_dir_to_target(t, filter):
 776     """Try to set T_COMMAND/T_ARGUMENT for move to "filter"-determined target.
 777
 778     The path-wise nearest target is chosen, via the shortest available path.
 779     Target must not be t. On succcess, return positive value, else False.
 780     Filters:
 781     "a": Thing in FOV is animate, but of ThingType, starts out weaker than t
 782          is, and its corpse would be healthy food for t
 783     "f": move away from an enemy – any visible actor whose thing type has more
 784          TT_LIFEPOINTS than t LIFEPOINTS, and might find t's corpse healthy
 785          food – if it is closer than n steps, where n will shrink as t's hunger
 786          grows; if enemy is too close, move towards (attack) the enemy instead;
 787          if no fleeing is possible, nor attacking useful, wait; don't tread on
 788          non-enemies for fleeing
 789     "c": Thing in memorized map is consumable of sufficient nutrition for t
 790     "s": memory map cell with greatest-reachable degree of unexploredness
 791     """
 792
 793     def zero_score_map_where_char_on_memdepthmap(c):
 794         # OUTSOURCED FOR PERFORMANCE REASONS TO libplomrogue.so:
 795         # for i in [i for i in range(world_db["MAP_LENGTH"] ** 2)
 796         #           if t["T_MEMDEPTHMAP"][i] == mem_depth_c[0]]:
 797         #     set_map_score(i, 0)
 798         map = c_pointer_to_bytearray(t["T_MEMDEPTHMAP"])
 799         if libpr.zero_score_map_where_char_on_memdepthmap(c, map):
 800             raise RuntimeError("No score map allocated for "
 801                                "zero_score_map_where_char_on_memdepthmap().")
 802
 803     def set_map_score_at_thingpos(id, score):
 804         pos = world_db["Things"][id]["T_POSY"] * world_db["MAP_LENGTH"] \
 805                                      + world_db["Things"][id]["T_POSX"]
 806         set_map_score(pos, score)
 807
 808     def set_map_score(pos, score):
 809         test = libpr.set_map_score(pos, score)
 810         if test:
 811             raise RuntimeError("No score map allocated for set_map_score().")
 812
 813     def get_map_score(pos):
 814         result = libpr.get_map_score(pos)
 815         if result < 0:
 816             raise RuntimeError("No score map allocated for get_map_score().")
 817         return result
 818
 819     def animate_in_fov(Thing):
 820         if Thing["carried"] or Thing == t or not Thing["T_LIFEPOINTS"]:
 821             return False
 822         pos = Thing["T_POSY"] * world_db["MAP_LENGTH"] + Thing["T_POSX"]
 823         if ord("v") == t["fovmap"][pos]:
 824             return True
 825
 826     def good_attack_target(v):
 827         eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
 828         type = world_db["ThingTypes"][v["T_TYPE"]]
 829         type_corpse = world_db["ThingTypes"][type["TT_CORPSE_ID"]]
 830         if t["T_LIFEPOINTS"] > type["TT_LIFEPOINTS"] \
 831         and type_corpse["TT_TOOL"] == "food" \
 832         and type_corpse["TT_TOOLPOWER"] > eat_cost:
 833             return True
 834         return False
 835
 836     def good_flee_target(m):
 837         own_corpse_id = world_db["ThingTypes"][t["T_TYPE"]]["TT_CORPSE_ID"]
 838         corpse_type = world_db["ThingTypes"][own_corpse_id]
 839         targetness = 0 if corpse_type["TT_TOOL"] != "food" \
 840                        else corpse_type["TT_TOOLPOWER"]
 841         type = world_db["ThingTypes"][m["T_TYPE"]]
 842         if t["T_LIFEPOINTS"] < type["TT_LIFEPOINTS"] \
 843         and targetness > eat_vs_hunger_threshold(m["T_TYPE"]):
 844             return True
 845         return False
 846
 847     def seeing_thing():
 848         if t["fovmap"] and "a" == filter:
 849             for id in world_db["Things"]:
 850                 if animate_in_fov(world_db["Things"][id]):
 851                     if good_attack_target(world_db["Things"][id]):
 852                         return True
 853         elif t["fovmap"] and "f" == filter:
 854             for id in world_db["Things"]:
 855                 if animate_in_fov(world_db["Things"][id]):
 856                     if good_flee_target(world_db["Things"][id]):
 857                         return True
 858         elif t["T_MEMMAP"] and "c" == filter:
 859             eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
 860             for mt in t["T_MEMTHING"]:
 861                 if ' ' != chr(t["T_MEMMAP"][(mt[1] * world_db["MAP_LENGTH"])
 862                                             + mt[2]]) \
 863                    and world_db["ThingTypes"][mt[0]]["TT_TOOL"] == "food" \
 864                    and world_db["ThingTypes"][mt[0]]["TT_TOOLPOWER"] \
 865                        > eat_cost:
 866                     return True
 867         return False
 868
 869     def set_cells_passable_on_memmap_to_65534_on_scoremap():
 870         # OUTSOURCED FOR PERFORMANCE REASONS TO libplomrogue.so:
 871         # ord_dot = ord(".")
 872         # memmap = t["T_MEMMAP"]
 873         # for i in [i for i in range(world_db["MAP_LENGTH"] ** 2)
 874         #            if ord_dot == memmap[i]]:
 875         #     set_map_score(i, 65534) # i.e. 65535-1
 876         map = c_pointer_to_bytearray(t["T_MEMMAP"])
 877         if libpr.set_cells_passable_on_memmap_to_65534_on_scoremap(map):
 878             raise RuntimeError("No score map allocated for set_cells_passable"
 879                                "_on_memmap_to_65534_on_scoremap().")
 880
 881     def init_score_map():
 882         test = libpr.init_score_map()
 883         if test:
 884             raise RuntimeError("Malloc error in init_score_map().")
 885         ord_v = ord("v")
 886         ord_blank = ord(" ")
 887         set_cells_passable_on_memmap_to_65534_on_scoremap()
 888         if "a" == filter:
 889             for id in world_db["Things"]:
 890                 if animate_in_fov(world_db["Things"][id]) \
 891                 and good_attack_target(world_db["Things"][id]):
 892                     set_map_score_at_thingpos(id, 0)
 893         elif "f" == filter:
 894             for id in world_db["Things"]:
 895                 if animate_in_fov(world_db["Things"][id]) \
 896                 and good_flee_target(world_db["Things"][id]):
 897                     set_map_score_at_thingpos(id, 0)
 898         elif "c" == filter:
 899             eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
 900             for mt in [mt for mt in t["T_MEMTHING"]
 901                        if ord_blank != t["T_MEMMAP"][mt[1]
 902                                                      * world_db["MAP_LENGTH"]
 903                                                      + mt[2]]
 904                        if world_db["ThingTypes"][mt[0]]["TT_TOOL"] == "food"
 905                        if world_db["ThingTypes"][mt[0]]["TT_TOOLPOWER"]
 906                            > eat_cost]:
 907                 set_map_score(mt[1] * world_db["MAP_LENGTH"] + mt[2], 0)
 908         elif "s" == filter:
 909             zero_score_map_where_char_on_memdepthmap(mem_depth_c[0])
 910         if "a" != filter:
 911             for id in world_db["Things"]:
 912                 if animate_in_fov(world_db["Things"][id]):
 913                     if "f" == filter:
 914                         pos = world_db["Things"][id]["T_POSY"] \
 915                               * world_db["MAP_LENGTH"] \
 916                               + world_db["Things"][id]["T_POSX"]
 917                         if 0 == get_map_score(pos):
 918                             continue
 919                     set_map_score_at_thingpos(id, 65535)
 920
 921     def rand_target_dir(neighbors, cmp, dirs):
 922         candidates = []
 923         n_candidates = 0
 924         for i in range(len(dirs)):
 925             if cmp == neighbors[i]:
 926                 candidates.append(dirs[i])
 927                 n_candidates += 1
 928         return candidates[rand.next() % n_candidates] if n_candidates else 0
 929
 930     def get_neighbor_scores(dirs, eye_pos):
 931         scores = []
 932         if libpr.ready_neighbor_scores(eye_pos):
 933             raise RuntimeError("No score map allocated for " +
 934                                "ready_neighbor_scores.()")
 935         for i in range(len(dirs)):
 936             scores.append(libpr.get_neighbor_score(i))
 937         return scores
 938
 939     def get_dir_from_neighbors():
 940         dir_to_target = False
 941         dirs = "edcxsw"
 942         eye_pos = t["T_POSY"] * world_db["MAP_LENGTH"] + t["T_POSX"]
 943         neighbors = get_neighbor_scores(dirs, eye_pos)
 944         minmax_start = 0 if "f" == filter else 65535 - 1
 945         minmax_neighbor = minmax_start
 946         for i in range(len(dirs)):
 947             if ("f" == filter and get_map_score(eye_pos) < neighbors[i] and
 948                 minmax_neighbor < neighbors[i] and 65535 != neighbors[i]) \
 949                or ("f" != filter and minmax_neighbor > neighbors[i]):
 950                 minmax_neighbor = neighbors[i]
 951         if minmax_neighbor != minmax_start:
 952             dir_to_target = rand_target_dir(neighbors, minmax_neighbor, dirs)
 953         if "f" == filter:
 954             distance = get_map_score(eye_pos)
 955             fear_distance = world_db["MAP_LENGTH"]
 956             if t["T_SATIATION"] < 0 and math.sqrt(-t["T_SATIATION"]) > 0:
 957                 fear_distance = fear_distance / math.sqrt(-t["T_SATIATION"])
 958             attack_distance = 1
 959             if not dir_to_target:
 960                 if attack_distance >= distance:
 961                     dir_to_target = rand_target_dir(neighbors,
 962                                                     distance - 1, dirs)
 963                 elif fear_distance >= distance:
 964                     t["T_COMMAND"] = [id for id in world_db["ThingActions"]
 965                                       if
 966                                       world_db["ThingActions"][id]["TA_NAME"]
 967                                       == "wait"][0]
 968                     return 1
 969             elif dir_to_target and fear_distance < distance:
 970                 dir_to_target = 0
 971         return dir_to_target
 972
 973     dir_to_target = False
 974     mem_depth_c = b' '
 975     run_i = 9 + 1 if "s" == filter else 1
 976     while run_i and not dir_to_target and ("s" == filter or seeing_thing()):
 977         run_i -= 1
 978         init_score_map()
 979         mem_depth_c = b'9' if b' ' == mem_depth_c \
 980             else bytes([mem_depth_c[0] - 1])
 981         if libpr.dijkstra_map():
 982             raise RuntimeError("No score map allocated for dijkstra_map().")
 983         dir_to_target = get_dir_from_neighbors()
 984         libpr.free_score_map()
 985         if dir_to_target and str == type(dir_to_target):
 986             t["T_COMMAND"] = [id for id in world_db["ThingActions"]
 987                               if world_db["ThingActions"][id]["TA_NAME"]
 988                               == "move"][0]
 989             t["T_ARGUMENT"] = ord(dir_to_target)
 990     return dir_to_target
 991
 992
 993 def standing_on_food(t):
 994     """Return True/False whether t is standing on healthy consumable."""
 995     eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
 996     for id in [id for id in world_db["Things"] if world_db["Things"][id] != t
 997                if not world_db["Things"][id]["carried"]
 998                if world_db["Things"][id]["T_POSY"] == t["T_POSY"]
 999                if world_db["Things"][id]["T_POSX"] == t["T_POSX"]
1000                if world_db["ThingTypes"][world_db["Things"][id]["T_TYPE"]]
1001                   ["TT_TOOL"] == "food"
1002                if world_db["ThingTypes"][world_db["Things"][id]["T_TYPE"]]
1003                   ["TT_TOOLPOWER"] > eat_cost]:
1004         return True
1005     return False
1006
1007
1008 def get_inventory_slot_to_consume(t):
1009     """Return invent. slot of healthiest consumable(if any healthy),else -1."""
1010     cmp_food = -1
1011     selection = -1
1012     i = 0
1013     eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
1014     for id in t["T_CARRIES"]:
1015         type = world_db["Things"][id]["T_TYPE"]
1016         if world_db["ThingTypes"][type]["TT_TOOL"] == "food" \
1017            and world_db["ThingTypes"][type]["TT_TOOLPOWER"]:
1018             nutvalue = world_db["ThingTypes"][type]["TT_TOOLPOWER"]
1019             tmp_cmp = abs(t["T_SATIATION"] + nutvalue - eat_cost)
1020             if (cmp_food < 0 and tmp_cmp < abs(t["T_SATIATION"])) \
1021             or tmp_cmp < cmp_food:
1022                 cmp_food = tmp_cmp
1023                 selection = i
1024         i += 1
1025     return selection
1026
1027
1028 def ai(t):
1029     """Determine next command/argment for actor t via AI algorithms."""
1030     t["T_COMMAND"] = [id for id in world_db["ThingActions"]
1031                       if world_db["ThingActions"][id]["TA_NAME"] == "wait"][0]
1032     if get_dir_to_target(t, "f"):
1033         return
1034     sel = get_inventory_slot_to_consume(t)
1035     if -1 != sel:
1036         t["T_COMMAND"] = [id for id in world_db["ThingActions"]
1037                           if world_db["ThingActions"][id]["TA_NAME"]
1038                              == "use"][0]
1039         t["T_ARGUMENT"] = sel
1040     elif standing_on_food(t):
1041             t["T_COMMAND"] = [id for id in world_db["ThingActions"]
1042                               if world_db["ThingActions"][id]["TA_NAME"]
1043                               == "pick_up"][0]
1044     else:
1045         going_to_known_food_spot = get_dir_to_target(t, "c")
1046         if not going_to_known_food_spot:
1047             aiming_for_walking_food = get_dir_to_target(t, "a")
1048             if not aiming_for_walking_food:
1049                 get_dir_to_target(t, "s")
1050
1051
1052 def turn_over():
1053     """Run game world and its inhabitants until new player input expected."""
1054     id = 0
1055     whilebreaker = False
1056     while world_db["Things"][0]["T_LIFEPOINTS"]:
1057         proliferable_map = world_db["MAP"][:]
1058         for id in [id for id in world_db["Things"]
1059                    if not world_db["Things"][id]["carried"]]:
1060             y = world_db["Things"][id]["T_POSY"]
1061             x = world_db["Things"][id]["T_POSX"]
1062             proliferable_map[y * world_db["MAP_LENGTH"] + x] = ord('X')
1063         for id in [id for id in world_db["Things"]]:  # Only what's from start!
1064             if not id in world_db["Things"] or \
1065                world_db["Things"][id]["carried"]:   # May have been consumed or
1066                 continue                            # picked up during turn …
1067             Thing = world_db["Things"][id]
1068             if Thing["T_LIFEPOINTS"]:
1069                 if not Thing["T_COMMAND"]:
1070                     update_map_memory(Thing)
1071                     if 0 == id:
1072                         whilebreaker = True
1073                         break
1074                     ai(Thing)
1075                 try_healing(Thing)
1076                 hunger(Thing)
1077                 if Thing["T_LIFEPOINTS"]:
1078                     Thing["T_PROGRESS"] += 1
1079                     taid = [a for a in world_db["ThingActions"]
1080                               if a == Thing["T_COMMAND"]][0]
1081                     ThingAction = world_db["ThingActions"][taid]
1082                     if Thing["T_PROGRESS"] == ThingAction["TA_EFFORT"]:
1083                         eval("actor_" + ThingAction["TA_NAME"])(Thing)
1084                         Thing["T_COMMAND"] = 0
1085                         Thing["T_PROGRESS"] = 0
1086             thingproliferation(Thing, proliferable_map)
1087         if whilebreaker:
1088             break
1089         world_db["TURN"] += 1
1090
1091
1092 def new_Thing(type, pos=(0, 0)):
1093     """Return Thing of type T_TYPE, with fovmap if alive and world active."""
1094     thing = {
1095         "T_LIFEPOINTS": world_db["ThingTypes"][type]["TT_LIFEPOINTS"],
1096         "T_ARGUMENT": 0,
1097         "T_PROGRESS": 0,
1098         "T_SATIATION": 0,
1099         "T_COMMAND": 0,
1100         "T_TYPE": type,
1101         "T_POSY": pos[0],
1102         "T_POSX": pos[1],
1103         "T_CARRIES": [],
1104         "carried": False,
1105         "T_MEMTHING": [],
1106         "T_MEMMAP": False,
1107         "T_MEMDEPTHMAP": False,
1108         "fovmap": False
1109     }
1110     if world_db["WORLD_ACTIVE"] and thing["T_LIFEPOINTS"]:
1111         build_fov_map(thing)
1112     return thing
1113
1114
1115 def id_setter(id, category, id_store=False, start_at_1=False):
1116     """Set ID of object of category to manipulate ID unused? Create new one.
1117     The ID is stored as id_store.id (if id_store is set). If the integer of the
1118     input is valid (if start_at_1, >= 0, else >= -1), but <0 or (if start_at_1)
1119     <1, calculate new ID: lowest unused ID >=0 or (if start_at_1) >= 1. None is
1120     always returned when no new object is created, else the new object's ID.
1121     """
1122     min = 0 if start_at_1 else -1
1123     if str == type(id):
1124         id = integer_test(id, min)
1125     if None != id:
1126         if id in world_db[category]:
1127             if id_store:
1128                 id_store.id = id
1129             return None
1130         else:
1131             if (start_at_1 and 0 == id) \
1132                or ((not start_at_1) and (id < 0)):
1133                 id = 0 if start_at_1 else -1
1134                 while 1:
1135                     id = id + 1
1136                     if id not in world_db[category]:
1137                         break
1138             if id_store:
1139                 id_store.id = id
1140     return id
1141
1142
1143 def command_plugin(str_plugin):
1144     """Run code in plugins/[str_plugin]."""
1145     if (str_plugin.replace("_", "").isalnum()
1146         and os.access("plugins/" + str_plugin, os.F_OK)):
1147         exec(open("plugins/" + str_plugin).read())
1148         return
1149     print("Bad plugin name:", str_plugin)
1150
1151
1152 def command_ping():
1153     """Send PONG line to server output file."""
1154     strong_write(io_db["file_out"], "PONG\n")
1155
1156
1157 def command_quit():
1158     """Abort server process."""
1159     if None == opts.replay:
1160         if world_db["WORLD_ACTIVE"]:
1161             save_world()
1162         atomic_write(io_db["path_record"], io_db["record_chunk"], do_append=True)
1163     raise SystemExit("received QUIT command")
1164
1165
1166 def command_thingshere(str_y, str_x):
1167     """Write to out file list of Things known to player at coordinate y, x."""
1168     if world_db["WORLD_ACTIVE"]:
1169         y = integer_test(str_y, 0, 255)
1170         x = integer_test(str_x, 0, 255)
1171         length = world_db["MAP_LENGTH"]
1172         if None != y and None != x and y < length and x < length:
1173             pos = (y * world_db["MAP_LENGTH"]) + x
1174             strong_write(io_db["file_out"], "THINGS_HERE START\n")
1175             if "v" == chr(world_db["Things"][0]["fovmap"][pos]):
1176                 for id in [id for tid in sorted(list(world_db["ThingTypes"]))
1177                               for id in world_db["Things"]
1178                               if not world_db["Things"][id]["carried"]
1179                               if world_db["Things"][id]["T_TYPE"] == tid
1180                               if y == world_db["Things"][id]["T_POSY"]
1181                               if x == world_db["Things"][id]["T_POSX"]]:
1182                     type = world_db["Things"][id]["T_TYPE"]
1183                     name = world_db["ThingTypes"][type]["TT_NAME"]
1184                     strong_write(io_db["file_out"], name + "\n")
1185             else:
1186                 for mt in [mt for tid in sorted(list(world_db["ThingTypes"]))
1187                               for mt in world_db["Things"][0]["T_MEMTHING"]
1188                               if mt[0] == tid if y == mt[1] if x == mt[2]]:
1189                     name = world_db["ThingTypes"][mt[0]]["TT_NAME"]
1190                     strong_write(io_db["file_out"], name + "\n")
1191             strong_write(io_db["file_out"], "THINGS_HERE END\n")
1192         else:
1193             print("Ignoring: Invalid map coordinates.")
1194     else:
1195         print("Ignoring: Command only works on existing worlds.")
1196
1197
1198 def set_command(action):
1199     """Set player's T_COMMAND, then call turn_over()."""
1200     id = [x for x in world_db["ThingActions"]
1201           if world_db["ThingActions"][x]["TA_NAME"] == action][0]
1202     world_db["Things"][0]["T_COMMAND"] = id
1203     turn_over()
1204
1205
1206 def play_wait():
1207     """Try "wait" as player's T_COMMAND."""
1208     set_command("wait")
1209
1210
1211 def play_pickup():
1212     """Try "pick_up" as player's T_COMMAND"."""
1213     t = world_db["Things"][0]
1214     ids = [id for id in world_db["Things"] if id
1215            if not world_db["Things"][id]["carried"]
1216            if world_db["Things"][id]["T_POSY"] == t["T_POSY"]
1217            if world_db["Things"][id]["T_POSX"] == t["T_POSX"]]
1218     if not len(ids):
1219          log("NOTHING to pick up.")
1220     else:
1221         set_command("pick_up")
1222
1223
1224 def play_drop(str_arg):
1225     """Try "drop" as player's T_COMMAND, int(str_arg) as T_ARGUMENT / slot."""
1226     t = world_db["Things"][0]
1227     if 0 == len(t["T_CARRIES"]):
1228         log("You have NOTHING to drop in your inventory.")
1229     else:
1230         val = integer_test(str_arg, 0, 255)
1231         if None != val and val < len(t["T_CARRIES"]):
1232             world_db["Things"][0]["T_ARGUMENT"] = val
1233             set_command("drop")
1234         else:
1235             print("Illegal inventory index.")
1236
1237
1238 def play_use(str_arg):
1239     """Try "use" as player's T_COMMAND, int(str_arg) as T_ARGUMENT / slot."""
1240     t = world_db["Things"][0]
1241     if 0 == len(t["T_CARRIES"]):
1242         log("You have NOTHING to use in your inventory.")
1243     else:
1244         val = integer_test(str_arg, 0, 255)
1245         if None != val and val < len(t["T_CARRIES"]):
1246             id = t["T_CARRIES"][val]
1247             type = world_db["Things"][id]["T_TYPE"]
1248             if not world_db["ThingTypes"][type]["TT_TOOL"] == "food":
1249                 log("You CAN'T consume this thing.")
1250                 return
1251             world_db["Things"][0]["T_ARGUMENT"] = val
1252             set_command("use")
1253         else:
1254             print("Illegal inventory index.")
1255
1256
1257 def play_move(str_arg):
1258     """Try "move" as player's T_COMMAND, str_arg as T_ARGUMENT / direction."""
1259     t = world_db["Things"][0]
1260     if not str_arg in directions_db:
1261         print("Illegal move direction string.")
1262         return
1263     dir = ord(directions_db[str_arg])
1264     move_result = mv_yx_in_dir_legal(chr(dir), t["T_POSY"], t["T_POSX"])
1265     if 1 == move_result[0]:
1266         pos = (move_result[1] * world_db["MAP_LENGTH"]) + move_result[2]
1267         if ord(".") == world_db["MAP"][pos]:
1268             world_db["Things"][0]["T_ARGUMENT"] = dir
1269             set_command("move")
1270             return
1271     log("You CAN'T move there.")
1272
1273
1274 def command_seedrandomness(seed_string):
1275     """Set rand seed to int(seed_string)."""
1276     val = integer_test(seed_string, 0, 4294967295)
1277     if None != val:
1278         rand.seed = val
1279
1280
1281 def command_makeworld(seed_string):
1282     """(Re-)build game world, i.e. map, things, to a new turn 1 from seed.
1283
1284     Seed rand with seed. Do more only with a "wait" ThingAction and
1285     world["PLAYER_TYPE"] matching ThingType of TT_START_NUMBER > 0. Then,
1286     world_db["Things"] emptied, call make_map() and set
1287     world_db["WORLD_ACTIVE"], world_db["TURN"] to 1. Build new Things
1288     according to ThingTypes' TT_START_NUMBERS, with Thing of ID 0 to ThingType
1289     of ID = world["PLAYER_TYPE"]. Place Things randomly, and actors not on each
1290     other. Init player's memory map. Write "NEW_WORLD" line to out file.
1291     Call log_help().
1292     """
1293
1294     def free_pos():
1295         i = 0
1296         while 1:
1297             err = "Space to put thing on too hard to find. Map too small?"
1298             while 1:
1299                 y = rand.next() % world_db["MAP_LENGTH"]
1300                 x = rand.next() % world_db["MAP_LENGTH"]
1301                 if "." == chr(world_db["MAP"][y * world_db["MAP_LENGTH"] + x]):
1302                     break
1303                 i += 1
1304                 if i == 65535:
1305                     raise SystemExit(err)
1306             # Replica of C code, wrongly ignores animatedness of new Thing.
1307             pos_clear = (0 == len([id for id in world_db["Things"]
1308                                    if world_db["Things"][id]["T_LIFEPOINTS"]
1309                                    if world_db["Things"][id]["T_POSY"] == y
1310                                    if world_db["Things"][id]["T_POSX"] == x]))
1311             if pos_clear:
1312                 break
1313         return (y, x)
1314
1315     val = integer_test(seed_string, 0, 4294967295)
1316     if None == val:
1317         return
1318     rand.seed = val
1319     player_will_be_generated = False
1320     playertype = world_db["PLAYER_TYPE"]
1321     for ThingType in world_db["ThingTypes"]:
1322         if playertype == ThingType:
1323             if 0 < world_db["ThingTypes"][ThingType]["TT_START_NUMBER"]:
1324                 player_will_be_generated = True
1325             break
1326     if not player_will_be_generated:
1327         print("Ignoring: No player type with start number >0 defined.")
1328         return
1329     wait_action = False
1330     for ThingAction in world_db["ThingActions"]:
1331         if "wait" == world_db["ThingActions"][ThingAction]["TA_NAME"]:
1332             wait_action = True
1333     if not wait_action:
1334         print("Ignoring beyond SEED_MAP: " +
1335               "No thing action with name 'wait' defined.")
1336         return
1337     world_db["Things"] = {}
1338     make_map()
1339     world_db["WORLD_ACTIVE"] = 1
1340     world_db["TURN"] = 1
1341     for i in range(world_db["ThingTypes"][playertype]["TT_START_NUMBER"]):
1342         id = id_setter(-1, "Things")
1343         world_db["Things"][id] = new_Thing(playertype, free_pos())
1344     if not world_db["Things"][0]["fovmap"]:
1345         empty_fovmap = bytearray(b" " * world_db["MAP_LENGTH"] ** 2)
1346         world_db["Things"][0]["fovmap"] = empty_fovmap
1347     update_map_memory(world_db["Things"][0])
1348     for type in world_db["ThingTypes"]:
1349         for i in range(world_db["ThingTypes"][type]["TT_START_NUMBER"]):
1350             if type != playertype:
1351                 id = id_setter(-1, "Things")
1352                 world_db["Things"][id] = new_Thing(type, free_pos())
1353     strong_write(io_db["file_out"], "NEW_WORLD\n")
1354     log_help()
1355
1356
1357 def command_maplength(maplength_string):
1358     """Redefine map length. Invalidate map, therefore lose all things on it."""
1359     val = integer_test(maplength_string, 1, 256)
1360     if None != val:
1361         world_db["MAP_LENGTH"] = val
1362         world_db["MAP"] = False
1363         set_world_inactive()
1364         world_db["Things"] = {}
1365         libpr.set_maplength(val)
1366
1367
1368 def command_worldactive(worldactive_string):
1369     """Toggle world_db["WORLD_ACTIVE"] if possible.
1370
1371     An active world can always be set inactive. An inactive world can only be
1372     set active with a "wait" ThingAction, and a player Thing (of ID 0), and a
1373     map. On activation, rebuild all Things' FOVs, and the player's map memory.
1374     Also call log_help().
1375     """
1376     val = integer_test(worldactive_string, 0, 1)
1377     if None != val:
1378         if 0 != world_db["WORLD_ACTIVE"]:
1379             if 0 == val:
1380                 set_world_inactive()
1381             else:
1382                 print("World already active.")
1383         elif 0 == world_db["WORLD_ACTIVE"]:
1384             wait_exists = False
1385             for ThingAction in world_db["ThingActions"]:
1386                 if "wait" == world_db["ThingActions"][ThingAction]["TA_NAME"]:
1387                     wait_exists = True
1388                     break
1389             player_exists = False
1390             for Thing in world_db["Things"]:
1391                 if 0 == Thing:
1392                     player_exists = True
1393                     break
1394             if wait_exists and player_exists and world_db["MAP"]:
1395                 for id in world_db["Things"]:
1396                     if world_db["Things"][id]["T_LIFEPOINTS"]:
1397                         build_fov_map(world_db["Things"][id])
1398                         if 0 == id:
1399                             update_map_memory(world_db["Things"][id], False)
1400                 if not world_db["Things"][0]["T_LIFEPOINTS"]:
1401                     empty_fovmap = bytearray(b" " * world_db["MAP_LENGTH"] ** 2)
1402                     world_db["Things"][0]["fovmap"] = empty_fovmap
1403                 world_db["WORLD_ACTIVE"] = 1
1404                 log_help()
1405             else:
1406                 print("Ignoring: Not all conditions for world activation met.")
1407
1408
1409 def test_for_id_maker(object, category):
1410     """Return decorator testing for object having "id" attribute."""
1411     def decorator(f):
1412         def helper(*args):
1413             if hasattr(object, "id"):
1414                 f(*args)
1415             else:
1416                 print("Ignoring: No " + category +
1417                       " defined to manipulate yet.")
1418         return helper
1419     return decorator
1420
1421
1422 def command_tid(id_string):
1423     """Set ID of Thing to manipulate. ID unused? Create new one.
1424
1425     Default new Thing's type to the first available ThingType, others: zero.
1426     """
1427     id = id_setter(id_string, "Things", command_tid)
1428     if None != id:
1429         if world_db["ThingTypes"] == {}:
1430             print("Ignoring: No ThingType to settle new Thing in.")
1431             return
1432         type = list(world_db["ThingTypes"].keys())[0]
1433         world_db["Things"][id] = new_Thing(type)
1434
1435
1436 test_Thing_id = test_for_id_maker(command_tid, "Thing")
1437
1438
1439 @test_Thing_id
1440 def command_tcommand(str_int):
1441     """Set T_COMMAND of selected Thing."""
1442     val = integer_test(str_int, 0)
1443     if None != val:
1444         if 0 == val or val in world_db["ThingActions"]:
1445             world_db["Things"][command_tid.id]["T_COMMAND"] = val
1446         else:
1447             print("Ignoring: ThingAction ID belongs to no known ThingAction.")
1448
1449
1450 @test_Thing_id
1451 def command_ttype(str_int):
1452     """Set T_TYPE of selected Thing."""
1453     val = integer_test(str_int, 0)
1454     if None != val:
1455         if val in world_db["ThingTypes"]:
1456             world_db["Things"][command_tid.id]["T_TYPE"] = val
1457         else:
1458             print("Ignoring: ThingType ID belongs to no known ThingType.")
1459
1460
1461 @test_Thing_id
1462 def command_tcarries(str_int):
1463     """Append int(str_int) to T_CARRIES of selected Thing.
1464
1465     The ID int(str_int) must not be of the selected Thing, and must belong to a
1466     Thing with unset "carried" flag. Its "carried" flag will be set on owning.
1467     """
1468     val = integer_test(str_int, 0)
1469     if None != val:
1470         if val == command_tid.id:
1471             print("Ignoring: Thing cannot carry itself.")
1472         elif val in world_db["Things"] \
1473                 and not world_db["Things"][val]["carried"]:
1474             world_db["Things"][command_tid.id]["T_CARRIES"].append(val)
1475             world_db["Things"][val]["carried"] = True
1476         else:
1477             print("Ignoring: Thing not available for carrying.")
1478     # Note that the whole carrying structure is different from the C version:
1479     # Carried-ness is marked by a "carried" flag, not by Things containing
1480     # Things internally.
1481
1482
1483 @test_Thing_id
1484 def command_tmemthing(str_t, str_y, str_x):
1485     """Add (int(str_t), int(str_y), int(str_x)) to selected Thing's T_MEMTHING.
1486
1487     The type must fit to an existing ThingType, and the position into the map.
1488     """
1489     type = integer_test(str_t, 0)
1490     posy = integer_test(str_y, 0, 255)
1491     posx = integer_test(str_x, 0, 255)
1492     if None != type and None != posy and None != posx:
1493         if type not in world_db["ThingTypes"] \
1494            or posy >= world_db["MAP_LENGTH"] or posx >= world_db["MAP_LENGTH"]:
1495             print("Ignoring: Illegal value for thing type or position.")
1496         else:
1497             memthing = (type, posy, posx)
1498             world_db["Things"][command_tid.id]["T_MEMTHING"].append(memthing)
1499
1500
1501 def setter_map(maptype):
1502     """Set (world or Thing's) map of maptype's int(str_int)-th line to mapline.
1503
1504     If no map of maptype exists yet, initialize it with ' ' bytes first.
1505     """
1506
1507     def valid_map_line(str_int, mapline):
1508         val = integer_test(str_int, 0, 255)
1509         if None != val:
1510             if val >= world_db["MAP_LENGTH"]:
1511                 print("Illegal value for map line number.")
1512             elif len(mapline) != world_db["MAP_LENGTH"]:
1513                 print("Map line length is unequal map width.")
1514             else:
1515                 return val
1516         return None
1517
1518     def nonThingMap_helper(str_int, mapline):
1519         val = valid_map_line(str_int, mapline)
1520         if None != val:
1521             length = world_db["MAP_LENGTH"]
1522             if not world_db["MAP"]:
1523                 map = bytearray(b' ' * (length ** 2))
1524             else:
1525                 map = world_db["MAP"]
1526             map[val * length:(val * length) + length] = mapline.encode()
1527             if not world_db["MAP"]:
1528                 world_db["MAP"] = map
1529
1530     @test_Thing_id
1531     def ThingMap_helper(str_int, mapline):
1532         val = valid_map_line(str_int, mapline)
1533         if None != val:
1534             length = world_db["MAP_LENGTH"]
1535             if not world_db["Things"][command_tid.id][maptype]:
1536                 map = bytearray(b' ' * (length ** 2))
1537             else:
1538                 map = world_db["Things"][command_tid.id][maptype]
1539             map[val * length:(val * length) + length] = mapline.encode()
1540             if not world_db["Things"][command_tid.id][maptype]:
1541                 world_db["Things"][command_tid.id][maptype] = map
1542
1543     return nonThingMap_helper if maptype == "MAP" else ThingMap_helper
1544
1545
1546
1547 def setter_tpos(axis):
1548     """Generate setter for T_POSX or  T_POSY of selected Thing.
1549
1550     If world is active, rebuilds animate things' fovmap, player's memory map.
1551     """
1552     @test_Thing_id
1553     def helper(str_int):
1554         val = integer_test(str_int, 0, 255)
1555         if None != val:
1556             if val < world_db["MAP_LENGTH"]:
1557                 world_db["Things"][command_tid.id]["T_POS" + axis] = val
1558                 if world_db["WORLD_ACTIVE"] \
1559                    and world_db["Things"][command_tid.id]["T_LIFEPOINTS"]:
1560                     build_fov_map(world_db["Things"][command_tid.id])
1561                     if 0 == command_tid.id:
1562                         update_map_memory(world_db["Things"][command_tid.id])
1563             else:
1564                 print("Ignoring: Position is outside of map.")
1565     return helper
1566
1567
1568 def command_ttid(id_string):
1569     """Set ID of ThingType to manipulate. ID unused? Create new one.
1570
1571     Default new ThingType's TT_SYMBOL to "?", TT_CORPSE_ID to self, TT_TOOL to
1572     "", others: 0.
1573     """
1574     id = id_setter(id_string, "ThingTypes", command_ttid)
1575     if None != id:
1576         world_db["ThingTypes"][id] = {
1577             "TT_NAME": "(none)",
1578             "TT_TOOLPOWER": 0,
1579             "TT_LIFEPOINTS": 0,
1580             "TT_PROLIFERATE": 0,
1581             "TT_START_NUMBER": 0,
1582             "TT_SYMBOL": "?",
1583             "TT_CORPSE_ID": id,
1584             "TT_TOOL": ""
1585         }
1586
1587
1588 test_ThingType_id = test_for_id_maker(command_ttid, "ThingType")
1589
1590
1591 @test_ThingType_id
1592 def command_ttname(name):
1593     """Set TT_NAME of selected ThingType."""
1594     world_db["ThingTypes"][command_ttid.id]["TT_NAME"] = name
1595
1596
1597 @test_ThingType_id
1598 def command_tttool(name):
1599     """Set TT_TOOL of selected ThingType."""
1600     world_db["ThingTypes"][command_ttid.id]["TT_TOOL"] = name
1601
1602
1603 @test_ThingType_id
1604 def command_ttsymbol(char):
1605     """Set TT_SYMBOL of selected ThingType. """
1606     if 1 == len(char):
1607         world_db["ThingTypes"][command_ttid.id]["TT_SYMBOL"] = char
1608     else:
1609         print("Ignoring: Argument must be single character.")
1610
1611
1612 @test_ThingType_id
1613 def command_ttcorpseid(str_int):
1614     """Set TT_CORPSE_ID of selected ThingType."""
1615     val = integer_test(str_int, 0)
1616     if None != val:
1617         if val in world_db["ThingTypes"]:
1618             world_db["ThingTypes"][command_ttid.id]["TT_CORPSE_ID"] = val
1619         else:
1620             print("Ignoring: Corpse ID belongs to no known ThignType.")
1621
1622
1623 def command_taid(id_string):
1624     """Set ID of ThingAction to manipulate. ID unused? Create new one.
1625
1626     Default new ThingAction's TA_EFFORT to 1, its TA_NAME to "wait".
1627     """
1628     id = id_setter(id_string, "ThingActions", command_taid, True)
1629     if None != id:
1630         world_db["ThingActions"][id] = {
1631             "TA_EFFORT": 1,
1632             "TA_NAME": "wait"
1633         }
1634
1635
1636 test_ThingAction_id = test_for_id_maker(command_taid, "ThingAction")
1637
1638
1639 @test_ThingAction_id
1640 def command_taname(name):
1641     """Set TA_NAME of selected ThingAction.
1642
1643     The name must match a valid thing action function. If after the name
1644     setting no ThingAction with name "wait" remains, call set_world_inactive().
1645     """
1646     if name == "wait" or name == "move" or name == "use" or name == "drop" \
1647        or name == "pick_up":
1648         world_db["ThingActions"][command_taid.id]["TA_NAME"] = name
1649         if 1 == world_db["WORLD_ACTIVE"]:
1650             wait_defined = False
1651             for id in world_db["ThingActions"]:
1652                 if "wait" == world_db["ThingActions"][id]["TA_NAME"]:
1653                     wait_defined = True
1654                     break
1655             if not wait_defined:
1656                 set_world_inactive()
1657     else:
1658         print("Ignoring: Invalid action name.")
1659     # In contrast to the original,naming won't map a function to a ThingAction.
1660
1661
1662 def command_ai():
1663     """Call ai() on player Thing, then turn_over()."""
1664     ai(world_db["Things"][0])
1665     turn_over()
1666
1667
1668 """Commands database.
1669
1670 Map command start tokens to ([0]) number of expected command arguments, ([1])
1671 the command's meta-ness (i.e. is it to be written to the record file, is it to
1672 be ignored in replay mode if read from server input file), and ([2]) a function
1673 to be called on it.
1674 """
1675 commands_db = {
1676     "PLUGIN": (1, True, command_plugin),
1677     "QUIT": (0, True, command_quit),
1678     "PING": (0, True, command_ping),
1679     "THINGS_HERE": (2, True, command_thingshere),
1680     "MAKE_WORLD": (1, False, command_makeworld),
1681     "SEED_RANDOMNESS": (1, False, command_seedrandomness),
1682     "TURN": (1, False, setter(None, "TURN", 0, 65535)),
1683     "PLAYER_TYPE": (1, False, setter(None, "PLAYER_TYPE", 0)),
1684     "MAP_LENGTH": (1, False, command_maplength),
1685     "WORLD_ACTIVE": (1, False, command_worldactive),
1686     "MAP": (2, False, setter_map("MAP")),
1687     "TA_ID": (1, False, command_taid),
1688     "TA_EFFORT": (1, False, setter("ThingAction", "TA_EFFORT", 0, 255)),
1689     "TA_NAME": (1, False, command_taname),
1690     "TT_ID": (1, False, command_ttid),
1691     "TT_NAME": (1, False, command_ttname),
1692     "TT_TOOL": (1, False, command_tttool),
1693     "TT_SYMBOL": (1, False, command_ttsymbol),
1694     "TT_CORPSE_ID": (1, False, command_ttcorpseid),
1695     "TT_TOOLPOWER": (1, False, setter("ThingType", "TT_TOOLPOWER", 0, 65535)),
1696     "TT_START_NUMBER": (1, False, setter("ThingType", "TT_START_NUMBER",
1697                                          0, 255)),
1698     "TT_PROLIFERATE": (1, False, setter("ThingType", "TT_PROLIFERATE",
1699                                         0, 65535)),
1700     "TT_LIFEPOINTS": (1, False, setter("ThingType", "TT_LIFEPOINTS", 0, 255)),
1701     "T_ID": (1, False, command_tid),
1702     "T_ARGUMENT": (1, False, setter("Thing", "T_ARGUMENT", 0, 255)),
1703     "T_PROGRESS": (1, False, setter("Thing", "T_PROGRESS", 0, 255)),
1704     "T_LIFEPOINTS": (1, False, setter("Thing", "T_LIFEPOINTS", 0, 255)),
1705     "T_SATIATION": (1, False, setter("Thing", "T_SATIATION", -32768, 32767)),
1706     "T_COMMAND": (1, False, command_tcommand),
1707     "T_TYPE": (1, False, command_ttype),
1708     "T_CARRIES": (1, False, command_tcarries),
1709     "T_MEMMAP": (2, False, setter_map("T_MEMMAP")),
1710     "T_MEMDEPTHMAP": (2, False, setter_map("T_MEMDEPTHMAP")),
1711     "T_MEMTHING": (3, False, command_tmemthing),
1712     "T_POSY": (1, False, setter_tpos("Y")),
1713     "T_POSX": (1, False, setter_tpos("X")),
1714     "wait": (0, False, play_wait),
1715     "move": (1, False, play_move),
1716     "pick_up": (0, False, play_pickup),
1717     "drop": (1, False, play_drop),
1718     "use": (1, False, play_use),
1719     "ai": (0, False, command_ai)
1720 }
1721 # TODO: Unhandled cases: (Un-)killing animates (esp. player!) with T_LIFEPOINTS.
1722
1723
1724 """World state database. With sane default values. (Randomness is in rand.)"""
1725 world_db = {
1726     "TURN": 0,
1727     "MAP_LENGTH": 64,
1728     "PLAYER_TYPE": 0,
1729     "WORLD_ACTIVE": 0,
1730     "MAP": False,
1731     "ThingActions": {},
1732     "ThingTypes": {},
1733     "Things": {}
1734 }
1735
1736 """Mapping of direction names to internal direction chars."""
1737 directions_db = {"east": "d", "south-east": "c", "south-west": "x",
1738                  "west": "s", "north-west": "w", "north-east": "e"}
1739
1740 """File IO database."""
1741 io_db = {
1742     "path_save": "save",
1743     "path_record": "record_save",
1744     "path_worldconf": "confserver/world",
1745     "path_server": "server/",
1746     "path_in": "server/in",
1747     "path_out": "server/out",
1748     "path_worldstate": "server/worldstate",
1749     "tmp_suffix": "_tmp",
1750     "kicked_by_rival": False,
1751     "worldstate_updateable": False
1752 }
1753
1754
1755 try:
1756     libpr = prep_library()
1757     rand = RandomnessIO()
1758     opts = parse_command_line_arguments()
1759     if opts.savefile:
1760         io_db["path_save"] = opts.savefile
1761         io_db["path_record"] = "record_" + opts.savefile
1762     setup_server_io()
1763     if opts.verbose:
1764         io_db["verbose"] = True
1765     if None != opts.replay:
1766         replay_game()
1767     else:
1768         play_game()
1769 except SystemExit as exit:
1770     print("ABORTING: " + exit.args[0])
1771 except:
1772     print("SOMETHING WENT WRONG IN UNEXPECTED WAYS")
1773     raise
1774 finally:
1775     cleanup_server_io()