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
 670
 671 def actor_pick_up(t):
 672     """Make t pick up (topmost?) Thing from ground into inventory.
 673
 674     Define topmostness by how low the thing's type ID is.
 675     """
 676     ids = [id for id in world_db["Things"] if world_db["Things"][id] != t
 677            if not world_db["Things"][id]["carried"]
 678            if world_db["Things"][id]["T_POSY"] == t["T_POSY"]
 679            if world_db["Things"][id]["T_POSX"] == t["T_POSX"]]
 680     if len(ids):
 681         lowest_tid = -1
 682         for iid in ids:
 683             tid = world_db["Things"][iid]["T_TYPE"]
 684             if lowest_tid == -1 or tid < lowest_tid:
 685                 id = iid
 686                 lowest_tid = tid
 687         world_db["Things"][id]["carried"] = True
 688         t["T_CARRIES"].append(id)
 689         if t == world_db["Things"][0]:
 690                 log("You PICK UP an object.")
 691
 692
 693 def actor_drop(t):
 694     """Make t rop Thing from inventory to ground indexed by T_ARGUMENT."""
 695     # TODO: Handle case where T_ARGUMENT matches nothing.
 696     if len(t["T_CARRIES"]):
 697         id = t["T_CARRIES"][t["T_ARGUMENT"]]
 698         t["T_CARRIES"].remove(id)
 699         world_db["Things"][id]["carried"] = False
 700         if t == world_db["Things"][0]:
 701             log("You DROP an object.")
 702
 703
 704 def actor_use(t):
 705     """Make t use (for now: consume) T_ARGUMENT-indexed Thing in inventory."""
 706     # TODO: Handle case where T_ARGUMENT matches nothing.
 707     if len(t["T_CARRIES"]):
 708         id = t["T_CARRIES"][t["T_ARGUMENT"]]
 709         type = world_db["Things"][id]["T_TYPE"]
 710         if world_db["ThingTypes"][type]["TT_TOOL"] == "food":
 711             t["T_CARRIES"].remove(id)
 712             del world_db["Things"][id]
 713             t["T_SATIATION"] += world_db["ThingTypes"][type]["TT_TOOLPOWER"]
 714             if t == world_db["Things"][0]:
 715                 log("You CONSUME this object.")
 716         elif t == world_db["Things"][0]:
 717             log("You try to use this object, but FAIL.")
 718
 719
 720 def thingproliferation(t, prol_map):
 721     """To chance of 1/TT_PROLIFERATE, create t offspring in open neighbor cell.
 722
 723     Naturally only works with TT_PROLIFERATE > 0. The neighbor cell must be be
 724     marked '.' in prol_map. If there are several map cell candidates, one is
 725     selected randomly.
 726     """
 727     prolscore = world_db["ThingTypes"][t["T_TYPE"]]["TT_PROLIFERATE"]
 728     if prolscore and (1 == prolscore or 1 == (rand.next() % prolscore)):
 729         candidates = []
 730         for dir in [directions_db[key] for key in sorted(directions_db.keys())]:
 731             mv_result = mv_yx_in_dir_legal(dir, t["T_POSY"], t["T_POSX"])
 732             if mv_result[0] and  ord('.') == prol_map[mv_result[1]
 733                                                       * world_db["MAP_LENGTH"]
 734                                                       + mv_result[2]]:
 735                 candidates.append((mv_result[1], mv_result[2]))
 736         if len(candidates):
 737             i = rand.next() % len(candidates)
 738             id = id_setter(-1, "Things")
 739             newT = new_Thing(t["T_TYPE"], (candidates[i][0], candidates[i][1]))
 740             world_db["Things"][id] = newT
 741
 742
 743 def try_healing(t):
 744     """If t's HP < max, increment them if well-nourished, maybe waiting."""
 745     if t["T_LIFEPOINTS"] < \
 746        world_db["ThingTypes"][t["T_TYPE"]]["TT_LIFEPOINTS"]:
 747         wait_id = [id for id in world_db["ThingActions"]
 748                       if world_db["ThingActions"][id]["TA_NAME"] == "wait"][0]
 749         wait_divider = 8 if t["T_COMMAND"] == wait_id else 1
 750         testval = int(abs(t["T_SATIATION"]) / wait_divider)
 751         if (testval <= 1 or 1 == (rand.next() % testval)):
 752             t["T_LIFEPOINTS"] += 1
 753             if t == world_db["Things"][0]:
 754                 log("You HEAL.")
 755
 756
 757 def hunger_per_turn(type_id):
 758     """The amount of satiation score lost per turn for things of given type."""
 759     return int(math.sqrt(world_db["ThingTypes"][type_id]["TT_LIFEPOINTS"]))
 760
 761
 762 def hunger(t):
 763     """Decrement t's satiation,dependent on it trigger lifepoint dec chance."""
 764     if t["T_SATIATION"] > -32768:
 765         t["T_SATIATION"] -= hunger_per_turn(t["T_TYPE"])
 766     if 0 != t["T_SATIATION"] and 0 == int(rand.next() / abs(t["T_SATIATION"])):
 767         if t == world_db["Things"][0]:
 768             if t["T_SATIATION"] < 0:
 769                 log("You SUFFER from hunger.")
 770             else:
 771                 log("You SUFFER from over-eating.")
 772         decrement_lifepoints(t)
 773
 774
 775 def get_dir_to_target(t, filter):
 776     """Try to set T_COMMAND/T_ARGUMENT for move to "filter"-determined target.
 777
 778     The path-wise nearest target is chosen, via the shortest available path.
 779     Target must not be t. On succcess, return positive value, else False.
 780     Filters:
 781     "a": Thing in FOV is animate, but of ThingType, starts out weaker than t
 782          is, and its corpse would be healthy food for t
 783     "f": move away from an enemy – any visible actor whose thing type has more
 784          TT_LIFEPOINTS than t LIFEPOINTS, and might find t's corpse healthy
 785          food – if it is closer than n steps, where n will shrink as t's hunger
 786          grows; if enemy is too close, move towards (attack) the enemy instead;
 787          if no fleeing is possible, nor attacking useful, wait; don't tread on
 788          non-enemies for fleeing
 789     "c": Thing in memorized map is consumable of sufficient nutrition for t
 790     "s": memory map cell with greatest-reachable degree of unexploredness
 791     """
 792
 793     def zero_score_map_where_char_on_memdepthmap(c):
 794         # OUTSOURCED FOR PERFORMANCE REASONS TO libplomrogue.so:
 795         # for i in [i for i in range(world_db["MAP_LENGTH"] ** 2)
 796         #           if t["T_MEMDEPTHMAP"][i] == mem_depth_c[0]]:
 797         #     set_map_score(i, 0)
 798         map = c_pointer_to_bytearray(t["T_MEMDEPTHMAP"])
 799         if libpr.zero_score_map_where_char_on_memdepthmap(c, map):
 800             raise RuntimeError("No score map allocated for "
 801                                "zero_score_map_where_char_on_memdepthmap().")
 802
 803     def set_map_score_at_thingpos(id, score):
 804         pos = world_db["Things"][id]["T_POSY"] * world_db["MAP_LENGTH"] \
 805                                      + world_db["Things"][id]["T_POSX"]
 806         set_map_score(pos, score)
 807
 808     def set_map_score(pos, score):
 809         test = libpr.set_map_score(pos, score)
 810         if test:
 811             raise RuntimeError("No score map allocated for set_map_score().")
 812
 813     def get_map_score(pos):
 814         result = libpr.get_map_score(pos)
 815         if result < 0:
 816             raise RuntimeError("No score map allocated for get_map_score().")
 817         return result
 818
 819     def animate_in_fov(Thing):
 820         if Thing["carried"] or Thing == t or not Thing["T_LIFEPOINTS"]:
 821             return False
 822         pos = Thing["T_POSY"] * world_db["MAP_LENGTH"] + Thing["T_POSX"]
 823         if ord("v") == t["fovmap"][pos]:
 824             return True
 825
 826     def good_attack_target(v):
 827         eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
 828         type = world_db["ThingTypes"][v["T_TYPE"]]
 829         type_corpse = world_db["ThingTypes"][type["TT_CORPSE_ID"]]
 830         if t["T_LIFEPOINTS"] > type["TT_LIFEPOINTS"] \
 831         and type_corpse["TT_TOOL"] == "food" \
 832         and type_corpse["TT_TOOLPOWER"] > eat_cost:
 833             return True
 834         return False
 835
 836     def good_flee_target(m):
 837         own_corpse_id = world_db["ThingTypes"][t["T_TYPE"]]["TT_CORPSE_ID"]
 838         corpse_type = world_db["ThingTypes"][own_corpse_id]
 839         targetness = 0 if corpse_type["TT_TOOL"] != "food" \
 840                        else corpse_type["TT_TOOLPOWER"]
 841         type = world_db["ThingTypes"][m["T_TYPE"]]
 842         if t["T_LIFEPOINTS"] < type["TT_LIFEPOINTS"] \
 843         and targetness > eat_vs_hunger_threshold(m["T_TYPE"]):
 844             return True
 845         return False
 846
 847     def seeing_thing():
 848         if t["fovmap"] and "a" == filter:
 849             for id in world_db["Things"]:
 850                 if animate_in_fov(world_db["Things"][id]):
 851                     if good_attack_target(world_db["Things"][id]):
 852                         return True
 853         elif t["fovmap"] and "f" == filter:
 854             for id in world_db["Things"]:
 855                 if animate_in_fov(world_db["Things"][id]):
 856                     if good_flee_target(world_db["Things"][id]):
 857                         return True
 858         elif t["T_MEMMAP"] and "c" == filter:
 859             eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
 860             for mt in t["T_MEMTHING"]:
 861                 if ' ' != chr(t["T_MEMMAP"][(mt[1] * world_db["MAP_LENGTH"])
 862                                             + mt[2]]) \
 863                    and world_db["ThingTypes"][mt[0]]["TT_TOOL"] == "food" \
 864                    and world_db["ThingTypes"][mt[0]]["TT_TOOLPOWER"] \
 865                        > eat_cost:
 866                     return True
 867         return False
 868
 869     def set_cells_passable_on_memmap_to_65534_on_scoremap():
 870         # OUTSOURCED FOR PERFORMANCE REASONS TO libplomrogue.so:
 871         # ord_dot = ord(".")
 872         # memmap = t["T_MEMMAP"]
 873         # for i in [i for i in range(world_db["MAP_LENGTH"] ** 2)
 874         #            if ord_dot == memmap[i]]:
 875         #     set_map_score(i, 65534) # i.e. 65535-1
 876         map = c_pointer_to_bytearray(t["T_MEMMAP"])
 877         if libpr.set_cells_passable_on_memmap_to_65534_on_scoremap(map):
 878             raise RuntimeError("No score map allocated for set_cells_passable"
 879                                "_on_memmap_to_65534_on_scoremap().")
 880
 881     def init_score_map():
 882         test = libpr.init_score_map()
 883         if test:
 884             raise RuntimeError("Malloc error in init_score_map().")
 885         ord_v = ord("v")
 886         ord_blank = ord(" ")
 887         set_cells_passable_on_memmap_to_65534_on_scoremap()
 888         if "a" == filter:
 889             for id in world_db["Things"]:
 890                 if animate_in_fov(world_db["Things"][id]) \
 891                 and good_attack_target(world_db["Things"][id]):
 892                     set_map_score_at_thingpos(id, 0)
 893         elif "f" == filter:
 894             for id in world_db["Things"]:
 895                 if animate_in_fov(world_db["Things"][id]) \
 896                 and good_flee_target(world_db["Things"][id]):
 897                     set_map_score_at_thingpos(id, 0)
 898         elif "c" == filter:
 899             eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
 900             for mt in [mt for mt in t["T_MEMTHING"]
 901                        if ord_blank != t["T_MEMMAP"][mt[1]
 902                                                      * world_db["MAP_LENGTH"]
 903                                                      + mt[2]]
 904                        if world_db["ThingTypes"][mt[0]]["TT_TOOL"] == "food"
 905                        if world_db["ThingTypes"][mt[0]]["TT_TOOLPOWER"]
 906                            > eat_cost]:
 907                 set_map_score(mt[1] * world_db["MAP_LENGTH"] + mt[2], 0)
 908         elif "s" == filter:
 909             zero_score_map_where_char_on_memdepthmap(mem_depth_c[0])
 910         if "a" != filter:
 911             for id in world_db["Things"]:
 912                 if animate_in_fov(world_db["Things"][id]):
 913                     if "f" == filter:
 914                         pos = world_db["Things"][id]["T_POSY"] \
 915                               * world_db["MAP_LENGTH"] \
 916                               + world_db["Things"][id]["T_POSX"]
 917                         if 0 == get_map_score(pos):
 918                             continue
 919                     set_map_score_at_thingpos(id, 65535)
 920
 921     def rand_target_dir(neighbors, cmp, dirs):
 922         candidates = []
 923         n_candidates = 0
 924         for i in range(len(dirs)):
 925             if cmp == neighbors[i]:
 926                 candidates.append(dirs[i])
 927                 n_candidates += 1
 928         return candidates[rand.next() % n_candidates] if n_candidates else 0
 929
 930     def get_neighbor_scores(dirs, eye_pos):
 931         scores = []
 932         if libpr.ready_neighbor_scores(eye_pos):
 933             raise RuntimeError("No score map allocated for " +
 934                                "ready_neighbor_scores.()")
 935         for i in range(len(dirs)):
 936             scores.append(libpr.get_neighbor_score(i))
 937         return scores
 938
 939     def get_dir_from_neighbors():
 940         dir_to_target = False
 941         dirs = "edcxsw"
 942         eye_pos = t["T_POSY"] * world_db["MAP_LENGTH"] + t["T_POSX"]
 943         neighbors = get_neighbor_scores(dirs, eye_pos)
 944         minmax_start = 0 if "f" == filter else 65535 - 1
 945         minmax_neighbor = minmax_start
 946         for i in range(len(dirs)):
 947             if ("f" == filter and get_map_score(eye_pos) < neighbors[i] and
 948                 minmax_neighbor < neighbors[i] and 65535 != neighbors[i]) \
 949                or ("f" != filter and minmax_neighbor > neighbors[i]):
 950                 minmax_neighbor = neighbors[i]
 951         if minmax_neighbor != minmax_start:
 952             dir_to_target = rand_target_dir(neighbors, minmax_neighbor, dirs)
 953         if "f" == filter:
 954             distance = get_map_score(eye_pos)
 955             fear_distance = world_db["MAP_LENGTH"]
 956             if t["T_SATIATION"] < 0 and math.sqrt(-t["T_SATIATION"]) > 0:
 957                 fear_distance = fear_distance / math.sqrt(-t["T_SATIATION"])
 958             attack_distance = 1
 959             if not dir_to_target:
 960                 if attack_distance >= distance:
 961                     dir_to_target = rand_target_dir(neighbors,
 962                                                     distance - 1, dirs)
 963                 elif fear_distance >= distance:
 964                     t["T_COMMAND"] = [id for id in world_db["ThingActions"]
 965                                       if
 966                                       world_db["ThingActions"][id]["TA_NAME"]
 967                                       == "wait"][0]
 968                     return 1
 969             elif dir_to_target and fear_distance < distance:
 970                 dir_to_target = 0
 971         return dir_to_target
 972
 973     dir_to_target = False
 974     mem_depth_c = b' '
 975     run_i = 9 + 1 if "s" == filter else 1
 976     while run_i and not dir_to_target and ("s" == filter or seeing_thing()):
 977         run_i -= 1
 978         init_score_map()
 979         mem_depth_c = b'9' if b' ' == mem_depth_c \
 980             else bytes([mem_depth_c[0] - 1])
 981         if libpr.dijkstra_map():
 982             raise RuntimeError("No score map allocated for dijkstra_map().")
 983         dir_to_target = get_dir_from_neighbors()
 984         libpr.free_score_map()
 985         if dir_to_target and str == type(dir_to_target):
 986             t["T_COMMAND"] = [id for id in world_db["ThingActions"]
 987                               if world_db["ThingActions"][id]["TA_NAME"]
 988                               == "move"][0]
 989             t["T_ARGUMENT"] = ord(dir_to_target)
 990     return dir_to_target
 991
 992
 993 def standing_on_food(t):
 994     """Return True/False whether t is standing on healthy consumable."""
 995     eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
 996     for id in [id for id in world_db["Things"] if world_db["Things"][id] != t
 997                if not world_db["Things"][id]["carried"]
 998                if world_db["Things"][id]["T_POSY"] == t["T_POSY"]
 999                if world_db["Things"][id]["T_POSX"] == t["T_POSX"]
1000                if world_db["ThingTypes"][world_db["Things"][id]["T_TYPE"]]
1001                   ["TT_TOOL"] == "food"
1002                if world_db["ThingTypes"][world_db["Things"][id]["T_TYPE"]]
1003                   ["TT_TOOLPOWER"] > eat_cost]:
1004         return True
1005     return False
1006
1007
1008 def get_inventory_slot_to_consume(t):
1009     """Return invent. slot of healthiest consumable(if any healthy),else -1."""
1010     cmp_food = -1
1011     selection = -1
1012     i = 0
1013     eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
1014     for id in t["T_CARRIES"]:
1015         type = world_db["Things"][id]["T_TYPE"]
1016         if world_db["ThingTypes"][type]["TT_TOOL"] == "food" \
1017            and world_db["ThingTypes"][type]["TT_TOOLPOWER"]:
1018             nutvalue = world_db["ThingTypes"][type]["TT_TOOLPOWER"]
1019             tmp_cmp = abs(t["T_SATIATION"] + nutvalue - eat_cost)
1020             if (cmp_food < 0 and tmp_cmp < abs(t["T_SATIATION"])) \
1021             or tmp_cmp < cmp_food:
1022                 cmp_food = tmp_cmp
1023                 selection = i
1024         i += 1
1025     return selection
1026
1027
1028 def ai(t):
1029     """Determine next command/argment for actor t via AI algorithms."""
1030     t["T_COMMAND"] = [id for id in world_db["ThingActions"]
1031                       if world_db["ThingActions"][id]["TA_NAME"] == "wait"][0]
1032     if get_dir_to_target(t, "f"):
1033         return
1034     sel = get_inventory_slot_to_consume(t)
1035     if -1 != sel:
1036         t["T_COMMAND"] = [id for id in world_db["ThingActions"]
1037                           if world_db["ThingActions"][id]["TA_NAME"]
1038                              == "use"][0]
1039         t["T_ARGUMENT"] = sel
1040     elif standing_on_food(t):
1041             t["T_COMMAND"] = [id for id in world_db["ThingActions"]
1042                               if world_db["ThingActions"][id]["TA_NAME"]
1043                               == "pick_up"][0]
1044     else:
1045         going_to_known_food_spot = get_dir_to_target(t, "c")
1046         if not going_to_known_food_spot:
1047             aiming_for_walking_food = get_dir_to_target(t, "a")
1048             if not aiming_for_walking_food:
1049                 get_dir_to_target(t, "s")
1050
1051
1052 def turn_over():
1053     """Run game world and its inhabitants until new player input expected."""
1054     id = 0
1055     whilebreaker = False
1056     while world_db["Things"][0]["T_LIFEPOINTS"]:
1057         proliferable_map = world_db["MAP"][:]
1058         for id in [id for id in world_db["Things"]
1059                    if not world_db["Things"][id]["carried"]]:
1060             y = world_db["Things"][id]["T_POSY"]
1061             x = world_db["Things"][id]["T_POSX"]
1062             proliferable_map[y * world_db["MAP_LENGTH"] + x] = ord('X')
1063         for id in [id for id in world_db["Things"]]:  # Only what's from start!
1064             if not id in world_db["Things"] or \
1065                world_db["Things"][id]["carried"]:   # May have been consumed or
1066                 continue                            # picked up during turn …
1067             Thing = world_db["Things"][id]
1068             if Thing["T_LIFEPOINTS"]:
1069                 if not Thing["T_COMMAND"]:
1070                     update_map_memory(Thing)
1071                     if 0 == id:
1072                         whilebreaker = True
1073                         break
1074                     ai(Thing)
1075                 try_healing(Thing)
1076                 hunger(Thing)
1077                 if Thing["T_LIFEPOINTS"]:
1078                     Thing["T_PROGRESS"] += 1
1079                     taid = [a for a in world_db["ThingActions"]
1080                               if a == Thing["T_COMMAND"]][0]
1081                     ThingAction = world_db["ThingActions"][taid]
1082                     if Thing["T_PROGRESS"] == ThingAction["TA_EFFORT"]:
1083                         eval("actor_" + ThingAction["TA_NAME"])(Thing)
1084                         Thing["T_COMMAND"] = 0
1085                         Thing["T_PROGRESS"] = 0
1086             thingproliferation(Thing, proliferable_map)
1087         if whilebreaker:
1088             break
1089         world_db["TURN"] += 1
1090
1091
1092 def new_Thing(type, pos=(0, 0)):
1093     """Return Thing of type T_TYPE, with fovmap if alive and world active."""
1094     thing = {
1095         "T_LIFEPOINTS": world_db["ThingTypes"][type]["TT_LIFEPOINTS"],
1096         "T_ARGUMENT": 0,
1097         "T_PROGRESS": 0,
1098         "T_SATIATION": 0,
1099         "T_COMMAND": 0,
1100         "T_TYPE": type,
1101         "T_POSY": pos[0],
1102         "T_POSX": pos[1],
1103         "T_CARRIES": [],
1104         "carried": False,
1105         "T_MEMTHING": [],
1106         "T_MEMMAP": False,
1107         "T_MEMDEPTHMAP": False,
1108         "fovmap": False
1109     }
1110     if world_db["WORLD_ACTIVE"] and thing["T_LIFEPOINTS"]:
1111         build_fov_map(thing)
1112     return thing
1113
1114
1115 def id_setter(id, category, id_store=False, start_at_1=False):
1116     """Set ID of object of category to manipulate ID unused? Create new one.
1117     The ID is stored as id_store.id (if id_store is set). If the integer of the
1118     input is valid (if start_at_1, >= 0, else >= -1), but <0 or (if start_at_1)
1119     <1, calculate new ID: lowest unused ID >=0 or (if start_at_1) >= 1. None is
1120     always returned when no new object is created, else the new object's ID.
1121     """
1122     min = 0 if start_at_1 else -1
1123     if str == type(id):
1124         id = integer_test(id, min)
1125     if None != id:
1126         if id in world_db[category]:
1127             if id_store:
1128                 id_store.id = id
1129             return None
1130         else:
1131             if (start_at_1 and 0 == id) \
1132                or ((not start_at_1) and (id < 0)):
1133                 id = 0 if start_at_1 else -1
1134                 while 1:
1135                     id = id + 1
1136                     if id not in world_db[category]:
1137                         break
1138             if id_store:
1139                 id_store.id = id
1140     return id
1141
1142
1143 def command_ping():
1144     """Send PONG line to server output file."""
1145     strong_write(io_db["file_out"], "PONG\n")
1146
1147
1148 def command_quit():
1149     """Abort server process."""
1150     if None == opts.replay:
1151         if world_db["WORLD_ACTIVE"]:
1152             save_world()
1153         atomic_write(io_db["path_record"], io_db["record_chunk"], do_append=True)
1154     raise SystemExit("received QUIT command")
1155
1156
1157 def command_thingshere(str_y, str_x):
1158     """Write to out file list of Things known to player at coordinate y, x."""
1159     if world_db["WORLD_ACTIVE"]:
1160         y = integer_test(str_y, 0, 255)
1161         x = integer_test(str_x, 0, 255)
1162         length = world_db["MAP_LENGTH"]
1163         if None != y and None != x and y < length and x < length:
1164             pos = (y * world_db["MAP_LENGTH"]) + x
1165             strong_write(io_db["file_out"], "THINGS_HERE START\n")
1166             if "v" == chr(world_db["Things"][0]["fovmap"][pos]):
1167                 for id in [id for tid in sorted(list(world_db["ThingTypes"]))
1168                               for id in world_db["Things"]
1169                               if not world_db["Things"][id]["carried"]
1170                               if world_db["Things"][id]["T_TYPE"] == tid
1171                               if y == world_db["Things"][id]["T_POSY"]
1172                               if x == world_db["Things"][id]["T_POSX"]]:
1173                     type = world_db["Things"][id]["T_TYPE"]
1174                     name = world_db["ThingTypes"][type]["TT_NAME"]
1175                     strong_write(io_db["file_out"], name + "\n")
1176             else:
1177                 for mt in [mt for tid in sorted(list(world_db["ThingTypes"]))
1178                               for mt in world_db["Things"][0]["T_MEMTHING"]
1179                               if mt[0] == tid if y == mt[1] if x == mt[2]]:
1180                     name = world_db["ThingTypes"][mt[0]]["TT_NAME"]
1181                     strong_write(io_db["file_out"], name + "\n")
1182             strong_write(io_db["file_out"], "THINGS_HERE END\n")
1183         else:
1184             print("Ignoring: Invalid map coordinates.")
1185     else:
1186         print("Ignoring: Command only works on existing worlds.")
1187
1188
1189 def set_command(action):
1190     """Set player's T_COMMAND, then call turn_over()."""
1191     id = [x for x in world_db["ThingActions"]
1192           if world_db["ThingActions"][x]["TA_NAME"] == action][0]
1193     world_db["Things"][0]["T_COMMAND"] = id
1194     turn_over()
1195
1196
1197 def play_wait():
1198     """Try "wait" as player's T_COMMAND."""
1199     set_command("wait")
1200
1201
1202 def play_pickup():
1203     """Try "pick_up" as player's T_COMMAND"."""
1204     t = world_db["Things"][0]
1205     ids = [id for id in world_db["Things"] if id
1206            if not world_db["Things"][id]["carried"]
1207            if world_db["Things"][id]["T_POSY"] == t["T_POSY"]
1208            if world_db["Things"][id]["T_POSX"] == t["T_POSX"]]
1209     if not len(ids):
1210          log("NOTHING to pick up.")
1211     else:
1212         set_command("pick_up")
1213
1214
1215 def play_drop(str_arg):
1216     """Try "drop" as player's T_COMMAND, int(str_arg) as T_ARGUMENT / slot."""
1217     t = world_db["Things"][0]
1218     if 0 == len(t["T_CARRIES"]):
1219         log("You have NOTHING to drop in your inventory.")
1220     else:
1221         val = integer_test(str_arg, 0, 255)
1222         if None != val and val < len(t["T_CARRIES"]):
1223             world_db["Things"][0]["T_ARGUMENT"] = val
1224             set_command("drop")
1225         else:
1226             print("Illegal inventory index.")
1227
1228
1229 def play_use(str_arg):
1230     """Try "use" as player's T_COMMAND, int(str_arg) as T_ARGUMENT / slot."""
1231     t = world_db["Things"][0]
1232     if 0 == len(t["T_CARRIES"]):
1233         log("You have NOTHING to use in your inventory.")
1234     else:
1235         val = integer_test(str_arg, 0, 255)
1236         if None != val and val < len(t["T_CARRIES"]):
1237             id = t["T_CARRIES"][val]
1238             type = world_db["Things"][id]["T_TYPE"]
1239             if not world_db["ThingTypes"][type]["TT_TOOL"] == "food":
1240                 log("You CAN'T consume this thing.")
1241                 return
1242             world_db["Things"][0]["T_ARGUMENT"] = val
1243             set_command("use")
1244         else:
1245             print("Illegal inventory index.")
1246
1247
1248 def play_move(str_arg):
1249     """Try "move" as player's T_COMMAND, str_arg as T_ARGUMENT / direction."""
1250     t = world_db["Things"][0]
1251     if not str_arg in directions_db:
1252         print("Illegal move direction string.")
1253         return
1254     dir = ord(directions_db[str_arg])
1255     move_result = mv_yx_in_dir_legal(chr(dir), t["T_POSY"], t["T_POSX"])
1256     if 1 == move_result[0]:
1257         pos = (move_result[1] * world_db["MAP_LENGTH"]) + move_result[2]
1258         if ord(".") == world_db["MAP"][pos]:
1259             world_db["Things"][0]["T_ARGUMENT"] = dir
1260             set_command("move")
1261             return
1262     log("You CAN'T move there.")
1263
1264
1265 def command_seedrandomness(seed_string):
1266     """Set rand seed to int(seed_string)."""
1267     val = integer_test(seed_string, 0, 4294967295)
1268     if None != val:
1269         rand.seed = val
1270
1271
1272 def command_makeworld(seed_string):
1273     """(Re-)build game world, i.e. map, things, to a new turn 1 from seed.
1274
1275     Seed rand with seed. Do more only with a "wait" ThingAction and
1276     world["PLAYER_TYPE"] matching ThingType of TT_START_NUMBER > 0. Then,
1277     world_db["Things"] emptied, call make_map() and set
1278     world_db["WORLD_ACTIVE"], world_db["TURN"] to 1. Build new Things
1279     according to ThingTypes' TT_START_NUMBERS, with Thing of ID 0 to ThingType
1280     of ID = world["PLAYER_TYPE"]. Place Things randomly, and actors not on each
1281     other. Init player's memory map. Write "NEW_WORLD" line to out file.
1282     Call log_help().
1283     """
1284
1285     def free_pos():
1286         i = 0
1287         while 1:
1288             err = "Space to put thing on too hard to find. Map too small?"
1289             while 1:
1290                 y = rand.next() % world_db["MAP_LENGTH"]
1291                 x = rand.next() % world_db["MAP_LENGTH"]
1292                 if "." == chr(world_db["MAP"][y * world_db["MAP_LENGTH"] + x]):
1293                     break
1294                 i += 1
1295                 if i == 65535:
1296                     raise SystemExit(err)
1297             # Replica of C code, wrongly ignores animatedness of new Thing.
1298             pos_clear = (0 == len([id for id in world_db["Things"]
1299                                    if world_db["Things"][id]["T_LIFEPOINTS"]
1300                                    if world_db["Things"][id]["T_POSY"] == y
1301                                    if world_db["Things"][id]["T_POSX"] == x]))
1302             if pos_clear:
1303                 break
1304         return (y, x)
1305
1306     val = integer_test(seed_string, 0, 4294967295)
1307     if None == val:
1308         return
1309     rand.seed = val
1310     player_will_be_generated = False
1311     playertype = world_db["PLAYER_TYPE"]
1312     for ThingType in world_db["ThingTypes"]:
1313         if playertype == ThingType:
1314             if 0 < world_db["ThingTypes"][ThingType]["TT_START_NUMBER"]:
1315                 player_will_be_generated = True
1316             break
1317     if not player_will_be_generated:
1318         print("Ignoring: No player type with start number >0 defined.")
1319         return
1320     wait_action = False
1321     for ThingAction in world_db["ThingActions"]:
1322         if "wait" == world_db["ThingActions"][ThingAction]["TA_NAME"]:
1323             wait_action = True
1324     if not wait_action:
1325         print("Ignoring beyond SEED_MAP: " +
1326               "No thing action with name 'wait' defined.")
1327         return
1328     world_db["Things"] = {}
1329     make_map()
1330     world_db["WORLD_ACTIVE"] = 1
1331     world_db["TURN"] = 1
1332     for i in range(world_db["ThingTypes"][playertype]["TT_START_NUMBER"]):
1333         id = id_setter(-1, "Things")
1334         world_db["Things"][id] = new_Thing(playertype, free_pos())
1335     if not world_db["Things"][0]["fovmap"]:
1336         empty_fovmap = bytearray(b" " * world_db["MAP_LENGTH"] ** 2)
1337         world_db["Things"][0]["fovmap"] = empty_fovmap
1338     update_map_memory(world_db["Things"][0])
1339     for type in world_db["ThingTypes"]:
1340         for i in range(world_db["ThingTypes"][type]["TT_START_NUMBER"]):
1341             if type != playertype:
1342                 id = id_setter(-1, "Things")
1343                 world_db["Things"][id] = new_Thing(type, free_pos())
1344     strong_write(io_db["file_out"], "NEW_WORLD\n")
1345     log_help()
1346
1347
1348 def command_maplength(maplength_string):
1349     """Redefine map length. Invalidate map, therefore lose all things on it."""
1350     val = integer_test(maplength_string, 1, 256)
1351     if None != val:
1352         world_db["MAP_LENGTH"] = val
1353         world_db["MAP"] = False
1354         set_world_inactive()
1355         world_db["Things"] = {}
1356         libpr.set_maplength(val)
1357
1358
1359 def command_worldactive(worldactive_string):
1360     """Toggle world_db["WORLD_ACTIVE"] if possible.
1361
1362     An active world can always be set inactive. An inactive world can only be
1363     set active with a "wait" ThingAction, and a player Thing (of ID 0), and a
1364     map. On activation, rebuild all Things' FOVs, and the player's map memory.
1365     Also call log_help().
1366     """
1367     val = integer_test(worldactive_string, 0, 1)
1368     if None != val:
1369         if 0 != world_db["WORLD_ACTIVE"]:
1370             if 0 == val:
1371                 set_world_inactive()
1372             else:
1373                 print("World already active.")
1374         elif 0 == world_db["WORLD_ACTIVE"]:
1375             wait_exists = False
1376             for ThingAction in world_db["ThingActions"]:
1377                 if "wait" == world_db["ThingActions"][ThingAction]["TA_NAME"]:
1378                     wait_exists = True
1379                     break
1380             player_exists = False
1381             for Thing in world_db["Things"]:
1382                 if 0 == Thing:
1383                     player_exists = True
1384                     break
1385             if wait_exists and player_exists and world_db["MAP"]:
1386                 for id in world_db["Things"]:
1387                     if world_db["Things"][id]["T_LIFEPOINTS"]:
1388                         build_fov_map(world_db["Things"][id])
1389                         if 0 == id:
1390                             update_map_memory(world_db["Things"][id], False)
1391                 if not world_db["Things"][0]["T_LIFEPOINTS"]:
1392                     empty_fovmap = bytearray(b" " * world_db["MAP_LENGTH"] ** 2)
1393                     world_db["Things"][0]["fovmap"] = empty_fovmap
1394                 world_db["WORLD_ACTIVE"] = 1
1395                 log_help()
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     "QUIT": (0, True, command_quit),
1668     "PING": (0, True, command_ping),
1669     "THINGS_HERE": (2, True, command_thingshere),
1670     "MAKE_WORLD": (1, False, command_makeworld),
1671     "SEED_RANDOMNESS": (1, False, command_seedrandomness),
1672     "TURN": (1, False, setter(None, "TURN", 0, 65535)),
1673     "PLAYER_TYPE": (1, False, setter(None, "PLAYER_TYPE", 0)),
1674     "MAP_LENGTH": (1, False, command_maplength),
1675     "WORLD_ACTIVE": (1, False, command_worldactive),
1676     "MAP": (2, False, setter_map("MAP")),
1677     "TA_ID": (1, False, command_taid),
1678     "TA_EFFORT": (1, False, setter("ThingAction", "TA_EFFORT", 0, 255)),
1679     "TA_NAME": (1, False, command_taname),
1680     "TT_ID": (1, False, command_ttid),
1681     "TT_NAME": (1, False, command_ttname),
1682     "TT_TOOL": (1, False, command_tttool),
1683     "TT_SYMBOL": (1, False, command_ttsymbol),
1684     "TT_CORPSE_ID": (1, False, command_ttcorpseid),
1685     "TT_TOOLPOWER": (1, False, setter("ThingType", "TT_TOOLPOWER", 0, 65535)),
1686     "TT_START_NUMBER": (1, False, setter("ThingType", "TT_START_NUMBER",
1687                                          0, 255)),
1688     "TT_PROLIFERATE": (1, False, setter("ThingType", "TT_PROLIFERATE",
1689                                         0, 65535)),
1690     "TT_LIFEPOINTS": (1, False, setter("ThingType", "TT_LIFEPOINTS", 0, 255)),
1691     "T_ID": (1, False, command_tid),
1692     "T_ARGUMENT": (1, False, setter("Thing", "T_ARGUMENT", 0, 255)),
1693     "T_PROGRESS": (1, False, setter("Thing", "T_PROGRESS", 0, 255)),
1694     "T_LIFEPOINTS": (1, False, setter("Thing", "T_LIFEPOINTS", 0, 255)),
1695     "T_SATIATION": (1, False, setter("Thing", "T_SATIATION", -32768, 32767)),
1696     "T_COMMAND": (1, False, command_tcommand),
1697     "T_TYPE": (1, False, command_ttype),
1698     "T_CARRIES": (1, False, command_tcarries),
1699     "T_MEMMAP": (2, False, setter_map("T_MEMMAP")),
1700     "T_MEMDEPTHMAP": (2, False, setter_map("T_MEMDEPTHMAP")),
1701     "T_MEMTHING": (3, False, command_tmemthing),
1702     "T_POSY": (1, False, setter_tpos("Y")),
1703     "T_POSX": (1, False, setter_tpos("X")),
1704     "wait": (0, False, play_wait),
1705     "move": (1, False, play_move),
1706     "pick_up": (0, False, play_pickup),
1707     "drop": (1, False, play_drop),
1708     "use": (1, False, play_use),
1709     "ai": (0, False, command_ai)
1710 }
1711 # TODO: Unhandled cases: (Un-)killing animates (esp. player!) with T_LIFEPOINTS.
1712
1713
1714 """World state database. With sane default values. (Randomness is in rand.)"""
1715 world_db = {
1716     "TURN": 0,
1717     "MAP_LENGTH": 64,
1718     "PLAYER_TYPE": 0,
1719     "WORLD_ACTIVE": 0,
1720     "MAP": False,
1721     "ThingActions": {},
1722     "ThingTypes": {},
1723     "Things": {}
1724 }
1725
1726 """Mapping of direction names to internal direction chars."""
1727 directions_db = {"east": "d", "south-east": "c", "south-west": "x",
1728                  "west": "s", "north-west": "w", "north-east": "e"}
1729
1730 """File IO database."""
1731 io_db = {
1732     "path_save": "save",
1733     "path_record": "record_save",
1734     "path_worldconf": "confserver/world",
1735     "path_server": "server/",
1736     "path_in": "server/in",
1737     "path_out": "server/out",
1738     "path_worldstate": "server/worldstate",
1739     "tmp_suffix": "_tmp",
1740     "kicked_by_rival": False,
1741     "worldstate_updateable": False
1742 }
1743
1744
1745 try:
1746     libpr = prep_library()
1747     rand = RandomnessIO()
1748     opts = parse_command_line_arguments()
1749     if opts.savefile:
1750         io_db["path_save"] = opts.savefile
1751         io_db["path_record"] = "record_" + opts.savefile
1752     setup_server_io()
1753     if opts.verbose:
1754         io_db["verbose"] = True
1755     if None != opts.replay:
1756         replay_game()
1757     else:
1758         play_game()
1759 except SystemExit as exit:
1760     print("ABORTING: " + exit.args[0])
1761 except:
1762     print("SOMETHING WENT WRONG IN UNEXPECTED WAYS")
1763     raise
1764 finally:
1765     cleanup_server_io()