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