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 set_command(action):
1198     """Set player's T_COMMAND, then call turn_over()."""
1199     id = [x for x in world_db["ThingActions"]
1200           if world_db["ThingActions"][x]["TA_NAME"] == action][0]
1201     world_db["Things"][0]["T_COMMAND"] = id
1202     turn_over()
1203
1204
1205 def play_wait():
1206     """Try "wait" as player's T_COMMAND."""
1207     set_command("wait")
1208
1209
1210 def play_pickup():
1211     """Try "pick_up" as player's T_COMMAND"."""
1212     t = world_db["Things"][0]
1213     ids = [id for id in world_db["Things"] if id
1214            if not world_db["Things"][id]["carried"]
1215            if world_db["Things"][id]["T_POSY"] == t["T_POSY"]
1216            if world_db["Things"][id]["T_POSX"] == t["T_POSX"]]
1217     if not len(ids):
1218          log("Nothing to pick up.")
1219     else:
1220         set_command("pick_up")
1221
1222
1223 def play_drop(str_arg):
1224     """Try "drop" as player's T_COMMAND, int(str_arg) as T_ARGUMENT / slot."""
1225     t = world_db["Things"][0]
1226     if 0 == len(t["T_CARRIES"]):
1227         log("You have nothing to drop in your inventory.")
1228     else:
1229         val = integer_test(str_arg, 0, 255)
1230         if None != val and val < len(t["T_CARRIES"]):
1231             world_db["Things"][0]["T_ARGUMENT"] = val
1232             set_command("drop")
1233         else:
1234             print("Illegal inventory index.")
1235
1236
1237 def play_use(str_arg):
1238     """Try "use" as player's T_COMMAND, int(str_arg) as T_ARGUMENT / slot."""
1239     t = world_db["Things"][0]
1240     if 0 == len(t["T_CARRIES"]):
1241         log("You have nothing to use in your inventory.")
1242     else:
1243         val = integer_test(str_arg, 0, 255)
1244         if None != val and val < len(t["T_CARRIES"]):
1245             id = t["T_CARRIES"][val]
1246             type = world_db["Things"][id]["T_TYPE"]
1247             if not world_db["ThingTypes"][type]["TT_TOOL"] == "food":
1248                 log("You can't consume this thing.")
1249                 return
1250             world_db["Things"][0]["T_ARGUMENT"] = val
1251             set_command("use")
1252         else:
1253             print("Illegal inventory index.")
1254
1255
1256 def play_move(str_arg):
1257     """Try "move" as player's T_COMMAND, str_arg as T_ARGUMENT / direction."""
1258     t = world_db["Things"][0]
1259     if not str_arg in directions_db:
1260         print("Illegal move direction string.")
1261         return
1262     dir = ord(directions_db[str_arg])
1263     move_result = mv_yx_in_dir_legal(chr(dir), t["T_POSY"], t["T_POSX"])
1264     if 1 == move_result[0]:
1265         pos = (move_result[1] * world_db["MAP_LENGTH"]) + move_result[2]
1266         if ord(".") == world_db["MAP"][pos]:
1267             world_db["Things"][0]["T_ARGUMENT"] = dir
1268             set_command("move")
1269             return
1270     log("You can't move there.")
1271
1272
1273 def command_seedrandomness(seed_string):
1274     """Set rand seed to int(seed_string)."""
1275     val = integer_test(seed_string, 0, 4294967295)
1276     if None != val:
1277         rand.seed = val
1278
1279
1280 def command_makeworld(seed_string):
1281     """(Re-)build game world, i.e. map, things, to a new turn 1 from seed.
1282
1283     Seed rand with seed. Do more only with a "wait" ThingAction and
1284     world["PLAYER_TYPE"] matching ThingType of TT_START_NUMBER > 0. Then,
1285     world_db["Things"] emptied, call make_map() and set
1286     world_db["WORLD_ACTIVE"], world_db["TURN"] to 1. Build new Things
1287     according to ThingTypes' TT_START_NUMBERS, with Thing of ID 0 to ThingType
1288     of ID = world["PLAYER_TYPE"]. Place Things randomly, and actors not on each
1289     other. Init player's memory map. Write "NEW_WORLD" line to out file.
1290     Call log_help().
1291     """
1292
1293     def free_pos():
1294         i = 0
1295         while 1:
1296             err = "Space to put thing on too hard to find. Map too small?"
1297             while 1:
1298                 y = rand.next() % world_db["MAP_LENGTH"]
1299                 x = rand.next() % world_db["MAP_LENGTH"]
1300                 if "." == chr(world_db["MAP"][y * world_db["MAP_LENGTH"] + x]):
1301                     break
1302                 i += 1
1303                 if i == 65535:
1304                     raise SystemExit(err)
1305             # Replica of C code, wrongly ignores animatedness of new Thing.
1306             pos_clear = (0 == len([id for id in world_db["Things"]
1307                                    if world_db["Things"][id]["T_LIFEPOINTS"]
1308                                    if world_db["Things"][id]["T_POSY"] == y
1309                                    if world_db["Things"][id]["T_POSX"] == x]))
1310             if pos_clear:
1311                 break
1312         return (y, x)
1313
1314     val = integer_test(seed_string, 0, 4294967295)
1315     if None == val:
1316         return
1317     rand.seed = val
1318     player_will_be_generated = False
1319     playertype = world_db["PLAYER_TYPE"]
1320     for ThingType in world_db["ThingTypes"]:
1321         if playertype == ThingType:
1322             if 0 < world_db["ThingTypes"][ThingType]["TT_START_NUMBER"]:
1323                 player_will_be_generated = True
1324             break
1325     if not player_will_be_generated:
1326         print("Ignoring: No player type with start number >0 defined.")
1327         return
1328     wait_action = False
1329     for ThingAction in world_db["ThingActions"]:
1330         if "wait" == world_db["ThingActions"][ThingAction]["TA_NAME"]:
1331             wait_action = True
1332     if not wait_action:
1333         print("Ignoring beyond SEED_MAP: " +
1334               "No thing action with name 'wait' defined.")
1335         return
1336     world_db["Things"] = {}
1337     make_map()
1338     world_db["WORLD_ACTIVE"] = 1
1339     world_db["TURN"] = 1
1340     for i in range(world_db["ThingTypes"][playertype]["TT_START_NUMBER"]):
1341         id = id_setter(-1, "Things")
1342         world_db["Things"][id] = new_Thing(playertype, free_pos())
1343     if not world_db["Things"][0]["fovmap"]:
1344         empty_fovmap = bytearray(b" " * world_db["MAP_LENGTH"] ** 2)
1345         world_db["Things"][0]["fovmap"] = empty_fovmap
1346     update_map_memory(world_db["Things"][0])
1347     for type in world_db["ThingTypes"]:
1348         for i in range(world_db["ThingTypes"][type]["TT_START_NUMBER"]):
1349             if type != playertype:
1350                 id = id_setter(-1, "Things")
1351                 world_db["Things"][id] = new_Thing(type, free_pos())
1352     strong_write(io_db["file_out"], "NEW_WORLD\n")
1353     log_help()
1354
1355
1356 def command_maplength(maplength_string):
1357     """Redefine map length. Invalidate map, therefore lose all things on it."""
1358     val = integer_test(maplength_string, 1, 256)
1359     if None != val:
1360         world_db["MAP_LENGTH"] = val
1361         world_db["MAP"] = False
1362         set_world_inactive()
1363         world_db["Things"] = {}
1364         libpr.set_maplength(val)
1365
1366
1367 def command_worldactive(worldactive_string):
1368     """Toggle world_db["WORLD_ACTIVE"] if possible.
1369
1370     An active world can always be set inactive. An inactive world can only be
1371     set active with a "wait" ThingAction, and a player Thing (of ID 0), and a
1372     map. On activation, rebuild all Things' FOVs, and the player's map memory.
1373     Also call log_help().
1374     """
1375     val = integer_test(worldactive_string, 0, 1)
1376     if None != val:
1377         if 0 != world_db["WORLD_ACTIVE"]:
1378             if 0 == val:
1379                 set_world_inactive()
1380             else:
1381                 print("World already active.")
1382         elif 0 == world_db["WORLD_ACTIVE"]:
1383             wait_exists = False
1384             for ThingAction in world_db["ThingActions"]:
1385                 if "wait" == world_db["ThingActions"][ThingAction]["TA_NAME"]:
1386                     wait_exists = True
1387                     break
1388             player_exists = False
1389             for Thing in world_db["Things"]:
1390                 if 0 == Thing:
1391                     player_exists = True
1392                     break
1393             if wait_exists and player_exists and world_db["MAP"]:
1394                 for id in world_db["Things"]:
1395                     if world_db["Things"][id]["T_LIFEPOINTS"]:
1396                         build_fov_map(world_db["Things"][id])
1397                         if 0 == id:
1398                             update_map_memory(world_db["Things"][id], False)
1399                 if not world_db["Things"][0]["T_LIFEPOINTS"]:
1400                     empty_fovmap = bytearray(b" " * world_db["MAP_LENGTH"] ** 2)
1401                     world_db["Things"][0]["fovmap"] = empty_fovmap
1402                 world_db["WORLD_ACTIVE"] = 1
1403                 log_help()
1404             else:
1405                 print("Ignoring: Not all conditions for world activation met.")
1406
1407
1408 def test_for_id_maker(object, category):
1409     """Return decorator testing for object having "id" attribute."""
1410     def decorator(f):
1411         def helper(*args):
1412             if hasattr(object, "id"):
1413                 f(*args)
1414             else:
1415                 print("Ignoring: No " + category +
1416                       " defined to manipulate yet.")
1417         return helper
1418     return decorator
1419
1420
1421 def command_tid(id_string):
1422     """Set ID of Thing to manipulate. ID unused? Create new one.
1423
1424     Default new Thing's type to the first available ThingType, others: zero.
1425     """
1426     id = id_setter(id_string, "Things", command_tid)
1427     if None != id:
1428         if world_db["ThingTypes"] == {}:
1429             print("Ignoring: No ThingType to settle new Thing in.")
1430             return
1431         type = list(world_db["ThingTypes"].keys())[0]
1432         world_db["Things"][id] = new_Thing(type)
1433
1434
1435 test_Thing_id = test_for_id_maker(command_tid, "Thing")
1436
1437
1438 @test_Thing_id
1439 def command_tcommand(str_int):
1440     """Set T_COMMAND of selected Thing."""
1441     val = integer_test(str_int, 0)
1442     if None != val:
1443         if 0 == val or val in world_db["ThingActions"]:
1444             world_db["Things"][command_tid.id]["T_COMMAND"] = val
1445         else:
1446             print("Ignoring: ThingAction ID belongs to no known ThingAction.")
1447
1448
1449 @test_Thing_id
1450 def command_ttype(str_int):
1451     """Set T_TYPE of selected Thing."""
1452     val = integer_test(str_int, 0)
1453     if None != val:
1454         if val in world_db["ThingTypes"]:
1455             world_db["Things"][command_tid.id]["T_TYPE"] = val
1456         else:
1457             print("Ignoring: ThingType ID belongs to no known ThingType.")
1458
1459
1460 @test_Thing_id
1461 def command_tcarries(str_int):
1462     """Append int(str_int) to T_CARRIES of selected Thing.
1463
1464     The ID int(str_int) must not be of the selected Thing, and must belong to a
1465     Thing with unset "carried" flag. Its "carried" flag will be set on owning.
1466     """
1467     val = integer_test(str_int, 0)
1468     if None != val:
1469         if val == command_tid.id:
1470             print("Ignoring: Thing cannot carry itself.")
1471         elif val in world_db["Things"] \
1472                 and not world_db["Things"][val]["carried"]:
1473             world_db["Things"][command_tid.id]["T_CARRIES"].append(val)
1474             world_db["Things"][val]["carried"] = True
1475         else:
1476             print("Ignoring: Thing not available for carrying.")
1477     # Note that the whole carrying structure is different from the C version:
1478     # Carried-ness is marked by a "carried" flag, not by Things containing
1479     # Things internally.
1480
1481
1482 @test_Thing_id
1483 def command_tmemthing(str_t, str_y, str_x):
1484     """Add (int(str_t), int(str_y), int(str_x)) to selected Thing's T_MEMTHING.
1485
1486     The type must fit to an existing ThingType, and the position into the map.
1487     """
1488     type = integer_test(str_t, 0)
1489     posy = integer_test(str_y, 0, 255)
1490     posx = integer_test(str_x, 0, 255)
1491     if None != type and None != posy and None != posx:
1492         if type not in world_db["ThingTypes"] \
1493            or posy >= world_db["MAP_LENGTH"] or posx >= world_db["MAP_LENGTH"]:
1494             print("Ignoring: Illegal value for thing type or position.")
1495         else:
1496             memthing = (type, posy, posx)
1497             world_db["Things"][command_tid.id]["T_MEMTHING"].append(memthing)
1498
1499
1500 def setter_map(maptype):
1501     """Set (world or Thing's) map of maptype's int(str_int)-th line to mapline.
1502
1503     If no map of maptype exists yet, initialize it with ' ' bytes first.
1504     """
1505
1506     def valid_map_line(str_int, mapline):
1507         val = integer_test(str_int, 0, 255)
1508         if None != val:
1509             if val >= world_db["MAP_LENGTH"]:
1510                 print("Illegal value for map line number.")
1511             elif len(mapline) != world_db["MAP_LENGTH"]:
1512                 print("Map line length is unequal map width.")
1513             else:
1514                 return val
1515         return None
1516
1517     def nonThingMap_helper(str_int, mapline):
1518         val = valid_map_line(str_int, mapline)
1519         if None != val:
1520             length = world_db["MAP_LENGTH"]
1521             if not world_db["MAP"]:
1522                 map = bytearray(b' ' * (length ** 2))
1523             else:
1524                 map = world_db["MAP"]
1525             map[val * length:(val * length) + length] = mapline.encode()
1526             if not world_db["MAP"]:
1527                 world_db["MAP"] = map
1528
1529     @test_Thing_id
1530     def ThingMap_helper(str_int, mapline):
1531         val = valid_map_line(str_int, mapline)
1532         if None != val:
1533             length = world_db["MAP_LENGTH"]
1534             if not world_db["Things"][command_tid.id][maptype]:
1535                 map = bytearray(b' ' * (length ** 2))
1536             else:
1537                 map = world_db["Things"][command_tid.id][maptype]
1538             map[val * length:(val * length) + length] = mapline.encode()
1539             if not world_db["Things"][command_tid.id][maptype]:
1540                 world_db["Things"][command_tid.id][maptype] = map
1541
1542     return nonThingMap_helper if maptype == "MAP" else ThingMap_helper
1543
1544
1545
1546 def setter_tpos(axis):
1547     """Generate setter for T_POSX or  T_POSY of selected Thing.
1548
1549     If world is active, rebuilds animate things' fovmap, player's memory map.
1550     """
1551     @test_Thing_id
1552     def helper(str_int):
1553         val = integer_test(str_int, 0, 255)
1554         if None != val:
1555             if val < world_db["MAP_LENGTH"]:
1556                 world_db["Things"][command_tid.id]["T_POS" + axis] = val
1557                 if world_db["WORLD_ACTIVE"] \
1558                    and world_db["Things"][command_tid.id]["T_LIFEPOINTS"]:
1559                     build_fov_map(world_db["Things"][command_tid.id])
1560                     if 0 == command_tid.id:
1561                         update_map_memory(world_db["Things"][command_tid.id])
1562             else:
1563                 print("Ignoring: Position is outside of map.")
1564     return helper
1565
1566
1567 def command_ttid(id_string):
1568     """Set ID of ThingType to manipulate. ID unused? Create new one.
1569
1570     Default new ThingType's TT_SYMBOL to "?", TT_CORPSE_ID to self, TT_TOOL to
1571     "", others: 0.
1572     """
1573     id = id_setter(id_string, "ThingTypes", command_ttid)
1574     if None != id:
1575         world_db["ThingTypes"][id] = {
1576             "TT_NAME": "(none)",
1577             "TT_TOOLPOWER": 0,
1578             "TT_LIFEPOINTS": 0,
1579             "TT_PROLIFERATE": 0,
1580             "TT_START_NUMBER": 0,
1581             "TT_SYMBOL": "?",
1582             "TT_CORPSE_ID": id,
1583             "TT_TOOL": ""
1584         }
1585
1586
1587 test_ThingType_id = test_for_id_maker(command_ttid, "ThingType")
1588
1589
1590 @test_ThingType_id
1591 def command_ttname(name):
1592     """Set TT_NAME of selected ThingType."""
1593     world_db["ThingTypes"][command_ttid.id]["TT_NAME"] = name
1594
1595
1596 @test_ThingType_id
1597 def command_tttool(name):
1598     """Set TT_TOOL of selected ThingType."""
1599     world_db["ThingTypes"][command_ttid.id]["TT_TOOL"] = name
1600
1601
1602 @test_ThingType_id
1603 def command_ttsymbol(char):
1604     """Set TT_SYMBOL of selected ThingType. """
1605     if 1 == len(char):
1606         world_db["ThingTypes"][command_ttid.id]["TT_SYMBOL"] = char
1607     else:
1608         print("Ignoring: Argument must be single character.")
1609
1610
1611 @test_ThingType_id
1612 def command_ttcorpseid(str_int):
1613     """Set TT_CORPSE_ID of selected ThingType."""
1614     val = integer_test(str_int, 0)
1615     if None != val:
1616         if val in world_db["ThingTypes"]:
1617             world_db["ThingTypes"][command_ttid.id]["TT_CORPSE_ID"] = val
1618         else:
1619             print("Ignoring: Corpse ID belongs to no known ThignType.")
1620
1621
1622 def command_taid(id_string):
1623     """Set ID of ThingAction to manipulate. ID unused? Create new one.
1624
1625     Default new ThingAction's TA_EFFORT to 1, its TA_NAME to "wait".
1626     """
1627     id = id_setter(id_string, "ThingActions", command_taid, True)
1628     if None != id:
1629         world_db["ThingActions"][id] = {
1630             "TA_EFFORT": 1,
1631             "TA_NAME": "wait"
1632         }
1633
1634
1635 test_ThingAction_id = test_for_id_maker(command_taid, "ThingAction")
1636
1637
1638 @test_ThingAction_id
1639 def command_taname(name):
1640     """Set TA_NAME of selected ThingAction.
1641
1642     The name must match a valid thing action function. If after the name
1643     setting no ThingAction with name "wait" remains, call set_world_inactive().
1644     """
1645     if name == "wait" or name == "move" or name == "use" or name == "drop" \
1646        or name == "pick_up":
1647         world_db["ThingActions"][command_taid.id]["TA_NAME"] = name
1648         if 1 == world_db["WORLD_ACTIVE"]:
1649             wait_defined = False
1650             for id in world_db["ThingActions"]:
1651                 if "wait" == world_db["ThingActions"][id]["TA_NAME"]:
1652                     wait_defined = True
1653                     break
1654             if not wait_defined:
1655                 set_world_inactive()
1656     else:
1657         print("Ignoring: Invalid action name.")
1658     # In contrast to the original,naming won't map a function to a ThingAction.
1659
1660
1661 def command_ai():
1662     """Call ai() on player Thing, then turn_over()."""
1663     ai(world_db["Things"][0])
1664     turn_over()
1665
1666
1667 """Commands database.
1668
1669 Map command start tokens to ([0]) number of expected command arguments, ([1])
1670 the command's meta-ness (i.e. is it to be written to the record file, is it to
1671 be ignored in replay mode if read from server input file), and ([2]) a function
1672 to be called on it.
1673 """
1674 commands_db = {
1675     "QUIT": (0, True, command_quit),
1676     "PING": (0, True, command_ping),
1677     "THINGS_HERE": (2, True, command_thingshere),
1678     "MAKE_WORLD": (1, False, command_makeworld),
1679     "SEED_RANDOMNESS": (1, False, command_seedrandomness),
1680     "TURN": (1, False, setter(None, "TURN", 0, 65535)),
1681     "PLAYER_TYPE": (1, False, setter(None, "PLAYER_TYPE", 0)),
1682     "MAP_LENGTH": (1, False, command_maplength),
1683     "WORLD_ACTIVE": (1, False, command_worldactive),
1684     "MAP": (2, False, setter_map("MAP")),
1685     "TA_ID": (1, False, command_taid),
1686     "TA_EFFORT": (1, False, setter("ThingAction", "TA_EFFORT", 0, 255)),
1687     "TA_NAME": (1, False, command_taname),
1688     "TT_ID": (1, False, command_ttid),
1689     "TT_NAME": (1, False, command_ttname),
1690     "TT_TOOL": (1, False, command_tttool),
1691     "TT_SYMBOL": (1, False, command_ttsymbol),
1692     "TT_CORPSE_ID": (1, False, command_ttcorpseid),
1693     "TT_TOOLPOWER": (1, False, setter("ThingType", "TT_TOOLPOWER", 0, 65535)),
1694     "TT_START_NUMBER": (1, False, setter("ThingType", "TT_START_NUMBER",
1695                                          0, 255)),
1696     "TT_PROLIFERATE": (1, False, setter("ThingType", "TT_PROLIFERATE",
1697                                         0, 65535)),
1698     "TT_LIFEPOINTS": (1, False, setter("ThingType", "TT_LIFEPOINTS", 0, 255)),
1699     "T_ID": (1, False, command_tid),
1700     "T_ARGUMENT": (1, False, setter("Thing", "T_ARGUMENT", 0, 255)),
1701     "T_PROGRESS": (1, False, setter("Thing", "T_PROGRESS", 0, 255)),
1702     "T_LIFEPOINTS": (1, False, setter("Thing", "T_LIFEPOINTS", 0, 255)),
1703     "T_SATIATION": (1, False, setter("Thing", "T_SATIATION", -32768, 32767)),
1704     "T_COMMAND": (1, False, command_tcommand),
1705     "T_TYPE": (1, False, command_ttype),
1706     "T_CARRIES": (1, False, command_tcarries),
1707     "T_MEMMAP": (2, False, setter_map("T_MEMMAP")),
1708     "T_MEMDEPTHMAP": (2, False, setter_map("T_MEMDEPTHMAP")),
1709     "T_MEMTHING": (3, False, command_tmemthing),
1710     "T_POSY": (1, False, setter_tpos("Y")),
1711     "T_POSX": (1, False, setter_tpos("X")),
1712     "wait": (0, False, play_wait),
1713     "move": (1, False, play_move),
1714     "pick_up": (0, False, play_pickup),
1715     "drop": (1, False, play_drop),
1716     "use": (1, False, play_use),
1717     "ai": (0, False, command_ai)
1718 }
1719 # TODO: Unhandled cases: (Un-)killing animates (esp. player!) with T_LIFEPOINTS.
1720
1721
1722 """World state database. With sane default values. (Randomness is in rand.)"""
1723 world_db = {
1724     "TURN": 0,
1725     "MAP_LENGTH": 64,
1726     "PLAYER_TYPE": 0,
1727     "WORLD_ACTIVE": 0,
1728     "MAP": False,
1729     "ThingActions": {},
1730     "ThingTypes": {},
1731     "Things": {}
1732 }
1733
1734 """Mapping of direction names to internal direction chars."""
1735 directions_db = {"east": "d", "south-east": "c", "south-west": "x",
1736                  "west": "s", "north-west": "w", "north-east": "e"}
1737
1738 """File IO database."""
1739 io_db = {
1740     "path_save": "save",
1741     "path_record": "record_save",
1742     "path_worldconf": "confserver/world",
1743     "path_server": "server/",
1744     "path_in": "server/in",
1745     "path_out": "server/out",
1746     "path_worldstate": "server/worldstate",
1747     "tmp_suffix": "_tmp",
1748     "kicked_by_rival": False,
1749     "worldstate_updateable": False
1750 }
1751
1752
1753 try:
1754     libpr = prep_library()
1755     rand = RandomnessIO()
1756     opts = parse_command_line_arguments()
1757     if opts.savefile:
1758         io_db["path_save"] = opts.savefile
1759         io_db["path_record"] = "record_" + opts.savefile
1760     setup_server_io()
1761     if opts.verbose:
1762         io_db["verbose"] = True
1763     if None != opts.replay:
1764         replay_game()
1765     else:
1766         play_game()
1767 except SystemExit as exit:
1768     print("ABORTING: " + exit.args[0])
1769 except:
1770     print("SOMETHING WENT WRONG IN UNEXPECTED WAYS")
1771     raise
1772 finally:
1773     cleanup_server_io()