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.
18 """"Interface to libplomrogue's pseudo-randomness generator."""
20 def set_seed(self, seed):
21 libpr.seed_rrand(1, seed)
24 return libpr.seed_rrand(0, 0)
29 seed = property(get_seed, set_seed)
33 """Prepare ctypes library at ./libplomrogue.so"""
34 libpath = ("./libplomrogue.so")
35 if not os.access(libpath, os.F_OK):
36 raise SystemExit("No library " + libpath + ", run ./redo first?")
37 libpr = ctypes.cdll.LoadLibrary(libpath)
38 libpr.seed_rrand.restype = ctypes.c_uint32
42 def c_pointer_to_bytearray(ba):
43 """Return C char * pointer to ba."""
44 type = ctypes.c_char * len(ba)
45 return type.from_buffer(ba)
48 def strong_write(file, string):
49 """Apply write(string), then flush()."""
54 def setup_server_io():
55 """Fill IO files DB with proper file( path)s. Write process IO test string.
57 Ensure IO files directory at server/. Remove any old input file if found.
58 Set up new input file for reading, and new output file for writing. Start
59 output file with process hash line of format PID + " " + floated UNIX time
60 (io_db["teststring"]). Raise SystemExit if file is found at path of either
61 record or save file plus io_db["tmp_suffix"].
63 def detect_atomic_leftover(path, tmp_suffix):
64 path_tmp = path + tmp_suffix
65 msg = "Found file '" + path_tmp + "' that may be a leftover from an " \
66 "aborted previous attempt to write '" + path + "'. Aborting " \
67 "until matter is resolved by removing it from its current path."
68 if os.access(path_tmp, os.F_OK):
70 io_db["teststring"] = str(os.getpid()) + " " + str(time.time())
71 io_db["save_wait"] = 0
72 io_db["verbose"] = False
73 io_db["record_chunk"] = ""
74 os.makedirs(io_db["path_server"], exist_ok=True)
75 io_db["file_out"] = open(io_db["path_out"], "w")
76 strong_write(io_db["file_out"], io_db["teststring"] + "\n")
77 if os.access(io_db["path_in"], os.F_OK):
78 os.remove(io_db["path_in"])
79 io_db["file_in"] = open(io_db["path_in"], "w")
80 io_db["file_in"].close()
81 io_db["file_in"] = open(io_db["path_in"], "r")
82 detect_atomic_leftover(io_db["path_save"], io_db["tmp_suffix"])
83 detect_atomic_leftover(io_db["path_record"], io_db["tmp_suffix"])
86 def cleanup_server_io():
87 """Close and (if io_db["kicked_by_rival"] false) remove files in io_db."""
88 def helper(file_key, path_key):
90 io_db[file_key].close()
91 if not io_db["kicked_by_rival"] \
92 and os.access(io_db[path_key], os.F_OK):
93 os.remove(io_db[path_key])
94 helper("file_in", "path_in")
95 helper("file_out", "path_out")
96 helper("file_worldstate", "path_worldstate")
97 if "file_record" in io_db:
98 io_db["file_record"].close()
101 def obey(command, prefix, replay=False, do_record=False):
102 """Call function from commands_db mapped to command's first token.
104 Tokenize command string with shlex.split(comments=True). If replay is set,
105 a non-meta command from the commands_db merely triggers obey() on the next
106 command from the records file. If not, non-meta commands set
107 io_db["worldstate_updateable"] to world_db["WORLD_ACTIVE"], and, if
108 do_record is set, are recorded to io_db["record_chunk"], and save_world()
109 is called (and io_db["record_chunk"] written) if 15 seconds have passed
110 since the last time it was called. The prefix string is inserted into the
111 server's input message between its beginning 'input ' and ':'. All activity
112 is preceded by a server_test() call. Commands that start with a lowercase
113 letter are ignored when world_db["WORLD_ACTIVE"] is False/0.
117 print("input " + prefix + ": " + command)
119 tokens = shlex.split(command, comments=True)
120 except ValueError as err:
121 print("Can't tokenize command string: " + str(err) + ".")
123 if len(tokens) > 0 and tokens[0] in commands_db \
124 and len(tokens) == commands_db[tokens[0]][0] + 1:
125 if commands_db[tokens[0]][1]:
126 commands_db[tokens[0]][2](*tokens[1:])
127 elif tokens[0][0].islower() and not world_db["WORLD_ACTIVE"]:
128 print("Ignoring lowercase-starting commands when world inactive.")
130 print("Due to replay mode, reading command as 'go on in record'.")
131 line = io_db["file_record"].readline()
133 obey(line.rstrip(), io_db["file_record"].prefix
134 + str(io_db["file_record"].line_n))
135 io_db["file_record"].line_n = io_db["file_record"].line_n + 1
137 print("Reached end of record file.")
139 commands_db[tokens[0]][2](*tokens[1:])
141 io_db["record_chunk"] += command + "\n"
142 if time.time() > io_db["save_wait"] + 15:
143 atomic_write(io_db["path_record"], io_db["record_chunk"],
145 if world_db["WORLD_ACTIVE"]:
147 io_db["record_chunk"] = ""
148 io_db["save_wait"] = time.time()
149 io_db["worldstate_updateable"] = world_db["WORLD_ACTIVE"]
150 elif 0 != len(tokens):
151 print("Invalid command/argument, or bad number of tokens.")
154 def atomic_write(path, text, do_append=False, delete=True):
155 """Atomic write of text to file at path, appended if do_append is set."""
156 path_tmp = path + io_db["tmp_suffix"]
160 if os.access(path, os.F_OK):
161 shutil.copyfile(path, path_tmp)
162 file = open(path_tmp, mode)
163 strong_write(file, text)
165 if delete and os.access(path, os.F_OK):
167 os.rename(path_tmp, path)
171 """Save all commands needed to reconstruct current world state."""
174 string = string.replace("\u005C", '\u005C\u005C')
175 return '"' + string.replace('"', '\u005C"') + '"'
180 if key == "MAP" or world_db["Things"][id][key]:
181 map = world_db["MAP"] if key == "MAP" \
182 else world_db["Things"][id][key]
183 length = world_db["MAP_LENGTH"]
184 for i in range(length):
185 line = map[i * length:(i * length) + length].decode()
186 string = string + key + " " + str(i) + " " + quote(line) \
193 for memthing in world_db["Things"][id]["T_MEMTHING"]:
194 string = string + "T_MEMTHING " + str(memthing[0]) + " " + \
195 str(memthing[1]) + " " + str(memthing[2]) + "\n"
198 def helper(category, id_string, special_keys={}):
200 for id in sorted(world_db[category].keys()):
201 string = string + id_string + " " + str(id) + "\n"
202 for key in sorted(world_db[category][id].keys()):
203 if not key in special_keys:
204 x = world_db[category][id][key]
205 argument = quote(x) if str == type(x) else str(x)
206 string = string + key + " " + argument + "\n"
207 elif special_keys[key]:
208 string = string + special_keys[key](id)
212 for key in sorted(world_db.keys()):
213 if (not isinstance(world_db[key], dict)) and key != "MAP" and \
214 key != "WORLD_ACTIVE":
215 string = string + key + " " + str(world_db[key]) + "\n"
216 string = string + mapsetter("MAP")()
217 string = string + helper("ThingActions", "TA_ID")
218 string = string + helper("ThingTypes", "TT_ID", {"TT_CORPSE_ID": False})
219 for id in sorted(world_db["ThingTypes"].keys()):
220 string = string + "TT_ID " + str(id) + "\n" + "TT_CORPSE_ID " + \
221 str(world_db["ThingTypes"][id]["TT_CORPSE_ID"]) + "\n"
222 string = string + helper("Things", "T_ID",
223 {"T_CARRIES": False, "carried": False,
224 "T_MEMMAP": mapsetter("T_MEMMAP"),
225 "T_MEMTHING": memthing, "fovmap": False,
226 "T_MEMDEPTHMAP": mapsetter("T_MEMDEPTHMAP")})
227 for id in sorted(world_db["Things"].keys()):
228 if [] != world_db["Things"][id]["T_CARRIES"]:
229 string = string + "T_ID " + str(id) + "\n"
230 for carried in sorted(world_db["Things"][id]["T_CARRIES"]):
231 string = string + "T_CARRIES " + str(carried) + "\n"
232 string = string + "SEED_RANDOMNESS " + str(rand.seed) + "\n" + \
233 "WORLD_ACTIVE " + str(world_db["WORLD_ACTIVE"])
234 atomic_write(io_db["path_save"], string)
237 def obey_lines_in_file(path, name, do_record=False):
238 """Call obey() on each line of path's file, use name in input prefix."""
239 file = open(path, "r")
241 for line in file.readlines():
242 obey(line.rstrip(), name + "file line " + str(line_n),
248 def parse_command_line_arguments():
249 """Return settings values read from command line arguments."""
250 parser = argparse.ArgumentParser()
251 parser.add_argument('-s', nargs='?', type=int, dest='replay', const=1,
253 parser.add_argument('-l', nargs="?", const="save", dest='savefile',
255 parser.add_argument('-v', dest='verbose', action='store_true')
256 opts, unknown = parser.parse_known_args()
261 """Ensure valid server out file belonging to current process.
263 This is done by comparing io_db["teststring"] to what's found at the start
264 of the current file at io_db["path_out"]. On failure, set
265 io_db["kicked_by_rival"] and raise SystemExit.
267 if not os.access(io_db["path_out"], os.F_OK):
268 raise SystemExit("Server output file has disappeared.")
269 file = open(io_db["path_out"], "r")
270 test = file.readline().rstrip("\n")
272 if test != io_db["teststring"]:
273 io_db["kicked_by_rival"] = True
274 msg = "Server test string in server output file does not match. This" \
275 " indicates that the current server process has been " \
276 "superseded by another one."
277 raise SystemExit(msg)
281 """Return next newline-delimited command from server in file.
283 Keep building return string until a newline is encountered. Pause between
284 unsuccessful reads, and after too much waiting, run server_test().
286 wait_on_fail = 0.03333
291 add = io_db["file_in"].readline()
293 command = command + add
294 if len(command) > 0 and "\n" == command[-1]:
295 command = command[:-1]
298 time.sleep(wait_on_fail)
299 if now + max_wait < time.time():
305 def try_worldstate_update():
306 """Write worldstate file if io_db["worldstate_updateable"] is set."""
307 if io_db["worldstate_updateable"]:
309 def draw_visible_Things(map, run):
310 for id in world_db["Things"]:
311 type = world_db["Things"][id]["T_TYPE"]
312 consumable = world_db["ThingTypes"][type]["TT_TOOL"] == "food"
313 alive = world_db["ThingTypes"][type]["TT_LIFEPOINTS"]
314 if (0 == run and not consumable and not alive) \
315 or (1 == run and consumable and not alive) \
316 or (2 == run and alive):
317 y = world_db["Things"][id]["T_POSY"]
318 x = world_db["Things"][id]["T_POSX"]
319 fovflag = world_db["Things"][0]["fovmap"][(y * length) + x]
320 if 'v' == chr(fovflag):
321 c = world_db["ThingTypes"][type]["TT_SYMBOL"]
322 map[(y * length) + x] = ord(c)
324 def write_map(string, map):
325 for i in range(length):
326 line = map[i * length:(i * length) + length].decode()
327 string = string + line + "\n"
331 if [] == world_db["Things"][0]["T_CARRIES"]:
332 inventory = "(none)\n"
334 for id in world_db["Things"][0]["T_CARRIES"]:
335 type_id = world_db["Things"][id]["T_TYPE"]
336 name = world_db["ThingTypes"][type_id]["TT_NAME"]
337 inventory = inventory + name + "\n"
338 string = str(world_db["TURN"]) + "\n" + \
339 str(world_db["Things"][0]["T_LIFEPOINTS"]) + "\n" + \
340 str(world_db["Things"][0]["T_SATIATION"]) + "\n" + \
341 inventory + "%\n" + \
342 str(world_db["Things"][0]["T_POSY"]) + "\n" + \
343 str(world_db["Things"][0]["T_POSX"]) + "\n" + \
344 str(world_db["MAP_LENGTH"]) + "\n"
345 length = world_db["MAP_LENGTH"]
346 fov = bytearray(b' ' * (length ** 2))
347 for pos in range(length ** 2):
348 if 'v' == chr(world_db["Things"][0]["fovmap"][pos]):
349 fov[pos] = world_db["MAP"][pos]
351 draw_visible_Things(fov, i)
352 string = write_map(string, fov)
353 mem = world_db["Things"][0]["T_MEMMAP"][:]
355 for mt in world_db["Things"][0]["T_MEMTHING"]:
356 consumable = world_db["ThingTypes"][mt[0]]["TT_TOOL"] == "food"
357 if (i == 0 and not consumable) or (i == 1 and consumable):
358 c = world_db["ThingTypes"][mt[0]]["TT_SYMBOL"]
359 mem[(mt[1] * length) + mt[2]] = ord(c)
360 string = write_map(string, mem)
361 atomic_write(io_db["path_worldstate"], string, delete=False)
362 strong_write(io_db["file_out"], "WORLD_UPDATED\n")
363 io_db["worldstate_updateable"] = False
367 """Replay game from record file.
369 Use opts.replay as breakpoint turn to which to replay automatically before
370 switching to manual input by non-meta commands in server input file
371 triggering further reads of record file. Ensure opts.replay is at least 1.
372 Run try_worldstate_update() before each interactive obey()/read_command().
376 print("Replay mode. Auto-replaying up to turn " + str(opts.replay) +
377 " (if so late a turn is to be found).")
378 if not os.access(io_db["path_record"], os.F_OK):
379 raise SystemExit("No record file found to replay.")
380 io_db["file_record"] = open(io_db["path_record"], "r")
381 io_db["file_record"].prefix = "record file line "
382 io_db["file_record"].line_n = 1
383 while world_db["TURN"] < opts.replay:
384 line = io_db["file_record"].readline()
387 obey(line.rstrip(), io_db["file_record"].prefix
388 + str(io_db["file_record"].line_n))
389 io_db["file_record"].line_n = io_db["file_record"].line_n + 1
391 try_worldstate_update()
392 obey(read_command(), "in file", replay=True)
396 """Play game by server input file commands. Before, load save file found.
398 If no save file is found, a new world is generated from the commands in the
399 world config plus a 'MAKE WORLD [current Unix timestamp]'. Record this
400 command and all that follow via the server input file. Run
401 try_worldstate_update() before each interactive obey()/read_command().
403 if os.access(io_db["path_save"], os.F_OK):
404 obey_lines_in_file(io_db["path_save"], "save")
406 if not os.access(io_db["path_worldconf"], os.F_OK):
407 msg = "No world config file from which to start a new world."
408 raise SystemExit(msg)
409 obey_lines_in_file(io_db["path_worldconf"], "world config ",
411 obey("MAKE_WORLD " + str(int(time.time())), "in file", do_record=True)
413 try_worldstate_update()
414 obey(read_command(), "in file", do_record=True)
418 """(Re-)make island map.
420 Let "~" represent water, "." land, "X" trees: Build island shape randomly,
421 start with one land cell in the middle, then go into cycle of repeatedly
422 selecting a random sea cell and transforming it into land if it is neighbor
423 to land. The cycle ends when a land cell is due to be created at the map's
424 border. Then put some trees on the map (TODO: more precise algorithm desc).
427 def is_neighbor(coordinates, type):
430 length = world_db["MAP_LENGTH"]
432 diag_west = x + (ind > 0)
433 diag_east = x + (ind < (length - 1))
434 pos = (y * length) + x
435 if (y > 0 and diag_east
436 and type == chr(world_db["MAP"][pos - length + ind])) \
438 and type == chr(world_db["MAP"][pos + 1])) \
439 or (y < (length - 1) and diag_east
440 and type == chr(world_db["MAP"][pos + length + ind])) \
441 or (y > 0 and diag_west
442 and type == chr(world_db["MAP"][pos - length - (not ind)])) \
444 and type == chr(world_db["MAP"][pos - 1])) \
445 or (y < (length - 1) and diag_west
446 and type == chr(world_db["MAP"][pos + length - (not ind)])):
450 world_db["MAP"] = bytearray(b'~' * (world_db["MAP_LENGTH"] ** 2))
451 length = world_db["MAP_LENGTH"]
452 add_half_width = (not (length % 2)) * int(length / 2)
453 world_db["MAP"][int((length ** 2) / 2) + add_half_width] = ord(".")
455 y = rand.next() % length
456 x = rand.next() % length
457 pos = (y * length) + x
458 if "~" == chr(world_db["MAP"][pos]) and is_neighbor((y, x), "."):
459 if y == 0 or y == (length - 1) or x == 0 or x == (length - 1):
461 world_db["MAP"][pos] = ord(".")
462 n_trees = int((length ** 2) / 16)
464 while (i_trees <= n_trees):
465 single_allowed = rand.next() % 32
466 y = rand.next() % length
467 x = rand.next() % length
468 pos = (y * length) + x
469 if "." == chr(world_db["MAP"][pos]) \
470 and ((not single_allowed) or is_neighbor((y, x), "X")):
471 world_db["MAP"][pos] = ord("X")
473 # This all-too-precise replica of the original C code misses iter_limit().
476 def update_map_memory(t, age_map=True):
477 """Update t's T_MEMMAP with what's in its FOV now,age its T_MEMMEPTHMAP."""
479 def age_some_memdepthmap_on_nonfov_cells():
480 # OUTSOURCED FOR PERFORMANCE REASONS TO libplomrogue.so:
484 # for pos in [pos for pos in range(world_db["MAP_LENGTH"] ** 2)
485 # if not ord_v == t["fovmap"][pos]
486 # if ord_0 <= t["T_MEMDEPTHMAP"][pos]
487 # if ord_9 > t["T_MEMDEPTHMAP"][pos]
488 # if not rand.next() % (2 **
489 # (t["T_MEMDEPTHMAP"][pos] - 48))]:
490 # t["T_MEMDEPTHMAP"][pos] += 1
491 memdepthmap = c_pointer_to_bytearray(t["T_MEMDEPTHMAP"])
492 fovmap = c_pointer_to_bytearray(t["fovmap"])
493 libpr.age_some_memdepthmap_on_nonfov_cells(memdepthmap, fovmap)
495 if not t["T_MEMMAP"]:
496 t["T_MEMMAP"] = bytearray(b' ' * (world_db["MAP_LENGTH"] ** 2))
497 if not t["T_MEMDEPTHMAP"]:
498 t["T_MEMDEPTHMAP"] = bytearray(b' ' * (world_db["MAP_LENGTH"] ** 2))
501 for pos in [pos for pos in range(world_db["MAP_LENGTH"] ** 2)
502 if ord_v == t["fovmap"][pos]]:
503 t["T_MEMDEPTHMAP"][pos] = ord_0
504 t["T_MEMMAP"][pos] = world_db["MAP"][pos]
506 age_some_memdepthmap_on_nonfov_cells()
507 t["T_MEMTHING"] = [mt for mt in t["T_MEMTHING"]
508 if ord_v != t["fovmap"][(mt[1] * world_db["MAP_LENGTH"])
510 for id in [id for id in world_db["Things"]
511 if not world_db["Things"][id]["carried"]]:
512 type = world_db["Things"][id]["T_TYPE"]
513 if not world_db["ThingTypes"][type]["TT_LIFEPOINTS"]:
514 y = world_db["Things"][id]["T_POSY"]
515 x = world_db["Things"][id]["T_POSX"]
516 if ord_v == t["fovmap"][(y * world_db["MAP_LENGTH"]) + x]:
517 t["T_MEMTHING"].append((type, y, x))
520 def set_world_inactive():
521 """Set world_db["WORLD_ACTIVE"] to 0 and remove worldstate file."""
523 if os.access(io_db["path_worldstate"], os.F_OK):
524 os.remove(io_db["path_worldstate"])
525 world_db["WORLD_ACTIVE"] = 0
528 def integer_test(val_string, min, max=None):
529 """Return val_string if integer >= min & (if max set) <= max, else None."""
531 val = int(val_string)
532 if val < min or (max is not None and val > max):
536 msg = "Ignoring: Please use integer >= " + str(min)
538 msg += " and <= " + str(max)
544 def setter(category, key, min, max=None):
545 """Build setter for world_db([category + "s"][id])[key] to >=min/<=max."""
548 val = integer_test(val_string, min, max)
552 if category == "Thing":
553 id_store = command_tid
554 decorator = test_Thing_id
555 elif category == "ThingType":
556 id_store = command_ttid
557 decorator = test_ThingType_id
558 elif category == "ThingAction":
559 id_store = command_taid
560 decorator = test_ThingAction_id
564 val = integer_test(val_string, min, max)
566 world_db[category + "s"][id_store.id][key] = val
570 def build_fov_map(t):
571 """Build Thing's FOV map."""
572 t["fovmap"] = bytearray(b'v' * (world_db["MAP_LENGTH"] ** 2))
573 fovmap = c_pointer_to_bytearray(t["fovmap"])
574 map = c_pointer_to_bytearray(world_db["MAP"])
575 if libpr.build_fov_map(t["T_POSY"], t["T_POSX"], fovmap, map):
576 raise RuntimeError("Malloc error in build_fov_Map().")
580 """Send quick usage info to log."""
581 strong_write(io_db["file_out"], "LOG See README file for help.\n")
584 def decrement_lifepoints(t):
585 """Decrement t's lifepoints by 1, and if to zero, corpse it.
587 If t is the player avatar, only blank its fovmap, so that the client may
588 still display memory data. On non-player things, erase fovmap and memory.
589 Dying actors drop all their things.
591 t["T_LIFEPOINTS"] -= 1
592 if 0 == t["T_LIFEPOINTS"]:
593 for id in t["T_CARRIES"]:
594 t["T_CARRIES"].remove(id)
595 world_db["Things"][id]["T_POSY"] = t["T_POSY"]
596 world_db["Things"][id]["T_POSX"] = t["T_POSX"]
597 world_db["Things"][id]["carried"] = False
598 t["T_TYPE"] = world_db["ThingTypes"][t["T_TYPE"]]["TT_CORPSE_ID"]
599 if world_db["Things"][0] == t:
600 t["fovmap"] = bytearray(b' ' * (world_db["MAP_LENGTH"] ** 2))
601 strong_write(io_db["file_out"], "LOG You die.\n")
602 strong_write(io_db["file_out"],
603 "LOG See README on how to start over.\n")
606 t["T_MEMMAP"] = False
607 t["T_MEMDEPTHMAP"] = False
611 def mv_yx_in_dir_legal(dir, y, x):
612 """Wrapper around libpr.mv_yx_in_dir_legal to simplify its use."""
613 dir_c = dir.encode("ascii")[0]
614 test = libpr.mv_yx_in_dir_legal_wrap(dir_c, y, x)
616 raise RuntimeError("Too much wrapping in mv_yx_in_dir_legal_wrap()!")
617 return (test, libpr.result_y(), libpr.result_x())
621 """Make t do nothing (but loudly, if player avatar)."""
622 if t == world_db["Things"][0]:
623 strong_write(io_db["file_out"], "LOG You wait.\n")
627 """If passable, move/collide(=attack) thing into T_ARGUMENT's direction."""
629 move_result = mv_yx_in_dir_legal(chr(t["T_ARGUMENT"]),
630 t["T_POSY"], t["T_POSX"])
631 if 1 == move_result[0]:
632 pos = (move_result[1] * world_db["MAP_LENGTH"]) + move_result[2]
633 hitted = [id for id in world_db["Things"]
634 if world_db["Things"][id] != t
635 if world_db["Things"][id]["T_LIFEPOINTS"]
636 if world_db["Things"][id]["T_POSY"] == move_result[1]
637 if world_db["Things"][id]["T_POSX"] == move_result[2]]
640 if t == world_db["Things"][0]:
641 hitted_type = world_db["Things"][hit_id]["T_TYPE"]
642 hitted_name = world_db["ThingTypes"][hitted_type]["TT_NAME"]
643 strong_write(io_db["file_out"], "LOG You wound "
644 + hitted_name + ".\n")
646 hitter_name = world_db["ThingTypes"][t["T_TYPE"]]["TT_NAME"]
647 strong_write(io_db["file_out"], "LOG " + hitter_name +
649 decrement_lifepoints(world_db["Things"][hit_id])
651 passable = "." == chr(world_db["MAP"][pos])
652 dir = [dir for dir in directions_db
653 if directions_db[dir] == chr(t["T_ARGUMENT"])][0]
655 t["T_POSY"] = move_result[1]
656 t["T_POSX"] = move_result[2]
657 for id in t["T_CARRIES"]:
658 world_db["Things"][id]["T_POSY"] = move_result[1]
659 world_db["Things"][id]["T_POSX"] = move_result[2]
661 if t == world_db["Things"][0]:
662 strong_write(io_db["file_out"], "LOG You move " + dir + ".\n")
663 elif t == world_db["Things"][0]:
664 strong_write(io_db["file_out"], "LOG You fail to move " + dir + ".\n")
667 def actor_pick_up(t):
668 """Make t pick up (topmost?) Thing from ground into inventory."""
669 # Topmostness is actually not defined so far. Picks most nutritious Thing.
670 ids = [id for id in world_db["Things"] if world_db["Things"][id] != t
671 if not world_db["Things"][id]["carried"]
672 if world_db["Things"][id]["T_POSY"] == t["T_POSY"]
673 if world_db["Things"][id]["T_POSX"] == t["T_POSX"]]
678 type = world_db["Things"][id]["T_TYPE"]
679 if world_db["ThingTypes"][type]["TT_TOOL"] == "food" \
680 and world_db["ThingTypes"][type]["TT_TOOLPOWER"] > nutritious:
681 nutritious = world_db["ThingTypes"][type]["TT_TOOLPOWER"]
683 world_db["Things"][highest_id]["carried"] = True
684 t["T_CARRIES"].append(highest_id)
685 if t == world_db["Things"][0]:
686 strong_write(io_db["file_out"], "LOG You pick up an object.\n")
687 elif t == world_db["Things"][0]:
688 err = "You try to pick up an object, but there is none."
689 strong_write(io_db["file_out"], "LOG " + err + "\n")
693 """Make t rop Thing from inventory to ground indexed by T_ARGUMENT."""
694 # TODO: Handle case where T_ARGUMENT matches nothing.
695 if len(t["T_CARRIES"]):
696 id = t["T_CARRIES"][t["T_ARGUMENT"]]
697 t["T_CARRIES"].remove(id)
698 world_db["Things"][id]["carried"] = False
699 if t == world_db["Things"][0]:
700 strong_write(io_db["file_out"], "LOG You drop an object.\n")
701 elif t == world_db["Things"][0]:
702 err = "You try to drop an object, but you own none."
703 strong_write(io_db["file_out"], "LOG " + err + "\n")
707 """Make t use (for now: consume) T_ARGUMENT-indexed Thing in inventory."""
708 # TODO: Handle case where T_ARGUMENT matches nothing.
709 if len(t["T_CARRIES"]):
710 id = t["T_CARRIES"][t["T_ARGUMENT"]]
711 type = world_db["Things"][id]["T_TYPE"]
712 if world_db["ThingTypes"][type]["TT_TOOL"] == "food":
713 t["T_CARRIES"].remove(id)
714 del world_db["Things"][id]
715 t["T_SATIATION"] += world_db["ThingTypes"][type]["TT_TOOLPOWER"]
716 if t == world_db["Things"][0]:
717 strong_write(io_db["file_out"],
718 "LOG You consume this object.\n")
719 elif t == world_db["Things"][0]:
720 strong_write(io_db["file_out"],
721 "LOG You try to use this object, but fail.\n")
722 elif t == world_db["Things"][0]:
723 strong_write(io_db["file_out"],
724 "LOG You try to use an object, but you own none.\n")
727 def thingproliferation(t, prol_map):
728 """To chance of 1/TT_PROLIFERATE, create t offspring in open neighbor cell.
730 Naturally only works with TT_PROLIFERATE > 0. The neighbor cell must be be
731 marked '.' in prol_map. If there are several map cell candidates, one is
734 prolscore = world_db["ThingTypes"][t["T_TYPE"]]["TT_PROLIFERATE"]
735 if prolscore and (1 == prolscore or 1 == (rand.next() % prolscore)):
737 for dir in [directions_db[key] for key in sorted(directions_db.keys())]:
738 mv_result = mv_yx_in_dir_legal(dir, t["T_POSY"], t["T_POSX"])
739 if mv_result[0] and ord('.') == prol_map[mv_result[1]
740 * world_db["MAP_LENGTH"]
742 candidates.append((mv_result[1], mv_result[2]))
744 i = rand.next() % len(candidates)
745 id = id_setter(-1, "Things")
746 newT = new_Thing(t["T_TYPE"], (candidates[i][0], candidates[i][1]))
747 world_db["Things"][id] = newT
751 """Grow t's HP to a 1/32 chance if < HP max, satiation > 0, and waiting.
753 On success, decrease satiation score by 32.
755 if t["T_SATIATION"] > 0 \
756 and t["T_LIFEPOINTS"] < \
757 world_db["ThingTypes"][t["T_TYPE"]]["TT_LIFEPOINTS"] \
758 and 0 == (rand.next() % 31) \
759 and t["T_COMMAND"] == [id for id in world_db["ThingActions"]
760 if world_db["ThingActions"][id]["TA_NAME"] ==
762 t["T_LIFEPOINTS"] += 1
763 t["T_SATIATION"] -= 32
764 if t == world_db["Things"][0]:
765 strong_write(io_db["file_out"], "LOG You heal.\n")
769 """Decrement t's satiation,dependent on it trigger lifepoint dec chance."""
770 if t["T_SATIATION"] > -32768:
771 t["T_SATIATION"] -= 1
772 testbase = t["T_SATIATION"] if t["T_SATIATION"] >= 0 else -t["T_SATIATION"]
773 if not world_db["ThingTypes"][t["T_TYPE"]]["TT_LIFEPOINTS"]:
774 raise RuntimeError("A thing that should not hunger is hungering.")
775 stomach = int(32767 / world_db["ThingTypes"][t["T_TYPE"]]["TT_LIFEPOINTS"])
776 if int(int(testbase / stomach) / ((rand.next() % stomach) + 1)):
777 if t == world_db["Things"][0]:
778 strong_write(io_db["file_out"], "LOG You suffer from hunger.\n")
779 decrement_lifepoints(t)
782 def get_dir_to_target(t, filter):
783 """Try to set T_COMMAND/T_ARGUMENT for move to "filter"-determined target.
785 The path-wise nearest target is chosen, via the shortest available path.
786 Target must not be t. On succcess, return positive value, else False.
788 "a": Thing in FOV is below a certain distance, animate, but of ThingType
789 that is not t's, and starts out weaker than t is; build path as
790 avoiding things of t's ThingType
791 "f": neighbor cell (not inhabited by any animate Thing) further away from
792 animate Thing not further than x steps away and in FOV and of a
793 ThingType that is not t's, and starts out stronger or as strong as t
794 is currently; or (cornered), if no such flight cell, but Thing of
795 above criteria is too near,1 a cell closer to it, or, if less near,
797 "c": Thing in memorized map is consumable
798 "s": memory map cell with greatest-reachable degree of unexploredness
801 def zero_score_map_where_char_on_memdepthmap(c):
802 # OUTSOURCED FOR PERFORMANCE REASONS TO libplomrogue.so:
803 # for i in [i for i in range(world_db["MAP_LENGTH"] ** 2)
804 # if t["T_MEMDEPTHMAP"][i] == mem_depth_c[0]]:
805 # set_map_score(i, 0)
806 map = c_pointer_to_bytearray(t["T_MEMDEPTHMAP"])
807 if libpr.zero_score_map_where_char_on_memdepthmap(c, map):
808 raise RuntimeError("No score map allocated for "
809 "zero_score_map_where_char_on_memdepthmap().")
811 def set_map_score(pos, score):
812 test = libpr.set_map_score(pos, score)
814 raise RuntimeError("No score map allocated for set_map_score().")
816 def get_map_score(pos):
817 result = libpr.get_map_score(pos)
819 raise RuntimeError("No score map allocated for get_map_score().")
823 if t["fovmap"] and ("a" == filter or "f" == filter):
824 for id in world_db["Things"]:
825 Thing = world_db["Things"][id]
826 if Thing != t and Thing["T_LIFEPOINTS"] and \
827 t["T_TYPE"] != Thing["T_TYPE"] and \
828 'v' == chr(t["fovmap"][(Thing["T_POSY"]
829 * world_db["MAP_LENGTH"])
831 ThingType = world_db["ThingTypes"][Thing["T_TYPE"]]
832 if ("f" == filter and ThingType["TT_LIFEPOINTS"] >=
834 or ("a" == filter and ThingType["TT_LIFEPOINTS"] <
837 elif t["T_MEMMAP"] and "c" == filter:
838 for mt in t["T_MEMTHING"]:
839 if ' ' != chr(t["T_MEMMAP"][(mt[1] * world_db["MAP_LENGTH"])
841 and world_db["ThingTypes"][mt[0]]["TT_TOOL"] == "food":
845 def set_cells_passable_on_memmap_to_65534_on_scoremap():
846 # OUTSOURCED FOR PERFORMANCE REASONS TO libplomrogue.so:
848 # memmap = t["T_MEMMAP"]
849 # for i in [i for i in range(world_db["MAP_LENGTH"] ** 2)
850 # if ord_dot == memmap[i]]:
851 # set_map_score(i, 65534) # i.e. 65535-1
852 map = c_pointer_to_bytearray(t["T_MEMMAP"])
853 if libpr.set_cells_passable_on_memmap_to_65534_on_scoremap(map):
854 raise RuntimeError("No score map allocated for set_cells_passable"
855 "_on_memmap_to_65534_on_scoremap().")
857 def init_score_map():
858 test = libpr.init_score_map()
860 raise RuntimeError("Malloc error in init_score_map().")
863 set_cells_passable_on_memmap_to_65534_on_scoremap()
865 for id in world_db["Things"]:
866 Thing = world_db["Things"][id]
867 pos = Thing["T_POSY"] * world_db["MAP_LENGTH"] \
869 if t != Thing and Thing["T_LIFEPOINTS"] and \
870 t["T_TYPE"] != Thing["T_TYPE"] and \
871 ord_v == t["fovmap"][pos] and \
872 t["T_LIFEPOINTS"] > \
873 world_db["ThingTypes"][Thing["T_TYPE"]]["TT_LIFEPOINTS"]:
874 set_map_score(pos, 0)
875 elif t["T_TYPE"] == Thing["T_TYPE"]:
876 set_map_score(pos, 65535)
878 for id in [id for id in world_db["Things"]
879 if world_db["Things"][id]["T_LIFEPOINTS"]]:
880 Thing = world_db["Things"][id]
881 pos = Thing["T_POSY"] * world_db["MAP_LENGTH"] \
883 if t["T_TYPE"] != Thing["T_TYPE"] and \
884 ord_v == t["fovmap"][pos] and \
885 t["T_LIFEPOINTS"] <= \
886 world_db["ThingTypes"][Thing["T_TYPE"]]["TT_LIFEPOINTS"]:
887 set_map_score(pos, 0)
889 for mt in [mt for mt in t["T_MEMTHING"]
890 if ord_blank != t["T_MEMMAP"][mt[1]
891 * world_db["MAP_LENGTH"]
893 if world_db["ThingTypes"][mt[0]]["TT_TOOL"] == "food"]:
894 set_map_score(mt[1] * world_db["MAP_LENGTH"] + mt[2], 0)
896 zero_score_map_where_char_on_memdepthmap(mem_depth_c[0])
898 def rand_target_dir(neighbors, cmp, dirs):
901 for i in range(len(dirs)):
902 if cmp == neighbors[i]:
903 candidates.append(dirs[i])
905 return candidates[rand.next() % n_candidates] if n_candidates else 0
907 def get_neighbor_scores(dirs, eye_pos):
909 if libpr.ready_neighbor_scores(eye_pos):
910 raise RuntimeError("No score map allocated for " +
911 "ready_neighbor_scores.()")
912 for i in range(len(dirs)):
913 scores.append(libpr.get_neighbor_score(i))
916 def get_dir_from_neighbors():
917 dir_to_target = False
919 eye_pos = t["T_POSY"] * world_db["MAP_LENGTH"] + t["T_POSX"]
920 neighbors = get_neighbor_scores(dirs, eye_pos)
922 inhabited = [world_db["Things"][id]["T_POSY"]
923 * world_db["MAP_LENGTH"]
924 + world_db["Things"][id]["T_POSX"]
925 for id in world_db["Things"]
926 if world_db["Things"][id]["T_LIFEPOINTS"]]
927 for i in range(len(dirs)):
928 mv_yx_in_dir_legal(dirs[i], t["T_POSY"], t["T_POSX"])
929 pos_cmp = libpr.result_y() * world_db["MAP_LENGTH"] \
931 for pos in [pos for pos in inhabited if pos == pos_cmp]:
934 minmax_start = 0 if "f" == filter else 65535 - 1
935 minmax_neighbor = minmax_start
936 for i in range(len(dirs)):
937 if ("f" == filter and get_map_score(eye_pos) < neighbors[i] and
938 minmax_neighbor < neighbors[i] and 65535 != neighbors[i]) \
939 or ("f" != filter and minmax_neighbor > neighbors[i]):
940 minmax_neighbor = neighbors[i]
941 if minmax_neighbor != minmax_start:
942 dir_to_target = rand_target_dir(neighbors, minmax_neighbor, dirs)
944 if not dir_to_target:
945 if 1 == get_map_score(eye_pos):
946 dir_to_target = rand_target_dir(neighbors, 0, dirs)
947 elif 3 >= get_map_score(eye_pos):
948 t["T_COMMAND"] = [id for id in world_db["ThingActions"]
950 world_db["ThingActions"][id]["TA_NAME"]
953 elif dir_to_target and 3 < get_map_score(eye_pos):
955 elif "a" == filter and 10 <= get_map_score(eye_pos):
959 dir_to_target = False
961 run_i = 9 + 1 if "s" == filter else 1
962 while run_i and not dir_to_target and ("s" == filter or seeing_thing()):
965 mem_depth_c = b'9' if b' ' == mem_depth_c \
966 else bytes([mem_depth_c[0] - 1])
967 if libpr.dijkstra_map():
968 raise RuntimeError("No score map allocated for dijkstra_map().")
969 dir_to_target = get_dir_from_neighbors()
970 libpr.free_score_map()
971 if dir_to_target and str == type(dir_to_target):
972 t["T_COMMAND"] = [id for id in world_db["ThingActions"]
973 if world_db["ThingActions"][id]["TA_NAME"]
975 t["T_ARGUMENT"] = ord(dir_to_target)
979 def standing_on_food(t):
980 """Return True/False whether t is standing on a consumable."""
981 for id in [id for id in world_db["Things"] if world_db["Things"][id] != t
982 if world_db["Things"][id]["T_POSY"] == t["T_POSY"]
983 if world_db["Things"][id]["T_POSX"] == t["T_POSX"]
984 if world_db["ThingTypes"][world_db["Things"][id]["T_TYPE"]]
985 ["TT_TOOL"] == "food"]:
990 def get_inventory_slot_to_consume(t):
991 """Return slot Id of strongest consumable in t's inventory, else -1."""
995 for id in t["T_CARRIES"]:
996 type = world_db["Things"][id]["T_TYPE"]
997 if world_db["ThingTypes"][type]["TT_TOOL"] == "food" \
998 and world_db["ThingTypes"][type]["TT_TOOLPOWER"] > cmp_food:
999 cmp_food = world_db["ThingTypes"][type]["TT_TOOLPOWER"]
1006 """Determine next command/argment for actor t via AI algorithms.
1008 AI will look for, and move towards, enemies (animate Things not of their
1009 own ThingType); if they see none, they will consume consumables in their
1010 inventory; if there are none, they will pick up what they stand on if they
1011 stand on consumables; if they stand on none, they will move towards the
1012 next consumable they see or remember on the map; if they see or remember
1013 none, they will explore parts of the map unseen since ever or for at least
1014 one turn; if there is nothing to explore, they will simply wait.
1016 t["T_COMMAND"] = [id for id in world_db["ThingActions"]
1017 if world_db["ThingActions"][id]["TA_NAME"] == "wait"][0]
1018 if not get_dir_to_target(t, "f"):
1019 sel = get_inventory_slot_to_consume(t)
1021 t["T_COMMAND"] = [id for id in world_db["ThingActions"]
1022 if world_db["ThingActions"][id]["TA_NAME"]
1024 t["T_ARGUMENT"] = sel
1025 elif standing_on_food(t):
1026 t["T_COMMAND"] = [id for id in world_db["ThingActions"]
1027 if world_db["ThingActions"][id]["TA_NAME"]
1029 elif (not get_dir_to_target(t, "c")) and \
1030 (not get_dir_to_target(t, "a")):
1031 get_dir_to_target(t, "s")
1035 """Run game world and its inhabitants until new player input expected."""
1037 whilebreaker = False
1038 while world_db["Things"][0]["T_LIFEPOINTS"]:
1039 proliferable_map = world_db["MAP"][:]
1040 for id in [id for id in world_db["Things"]
1041 if not world_db["Things"][id]["carried"]]:
1042 y = world_db["Things"][id]["T_POSY"]
1043 x = world_db["Things"][id]["T_POSX"]
1044 proliferable_map[y * world_db["MAP_LENGTH"] + x] = ord('X')
1045 for id in [id for id in world_db["Things"]]: # Only what's from start!
1046 if not id in world_db["Things"] or \
1047 world_db["Things"][id]["carried"]: # May have been consumed or
1048 continue # picked up during turn …
1049 Thing = world_db["Things"][id]
1050 if Thing["T_LIFEPOINTS"]:
1051 if not Thing["T_COMMAND"]:
1052 update_map_memory(Thing)
1059 if Thing["T_LIFEPOINTS"]:
1060 Thing["T_PROGRESS"] += 1
1061 taid = [a for a in world_db["ThingActions"]
1062 if a == Thing["T_COMMAND"]][0]
1063 ThingAction = world_db["ThingActions"][taid]
1064 if Thing["T_PROGRESS"] == ThingAction["TA_EFFORT"]:
1065 eval("actor_" + ThingAction["TA_NAME"])(Thing)
1066 Thing["T_COMMAND"] = 0
1067 Thing["T_PROGRESS"] = 0
1068 thingproliferation(Thing, proliferable_map)
1071 world_db["TURN"] += 1
1074 def new_Thing(type, pos=(0, 0)):
1075 """Return Thing of type T_TYPE, with fovmap if alive and world active."""
1077 "T_LIFEPOINTS": world_db["ThingTypes"][type]["TT_LIFEPOINTS"],
1089 "T_MEMDEPTHMAP": False,
1092 if world_db["WORLD_ACTIVE"] and thing["T_LIFEPOINTS"]:
1093 build_fov_map(thing)
1097 def id_setter(id, category, id_store=False, start_at_1=False):
1098 """Set ID of object of category to manipulate ID unused? Create new one.
1099 The ID is stored as id_store.id (if id_store is set). If the integer of the
1100 input is valid (if start_at_1, >= 0, else >= -1), but <0 or (if start_at_1)
1101 <1, calculate new ID: lowest unused ID >=0 or (if start_at_1) >= 1. None is
1102 always returned when no new object is created, else the new object's ID.
1104 min = 0 if start_at_1 else -1
1106 id = integer_test(id, min)
1108 if id in world_db[category]:
1113 if (start_at_1 and 0 == id) \
1114 or ((not start_at_1) and (id < 0)):
1115 id = 0 if start_at_1 else -1
1118 if id not in world_db[category]:
1126 """Send PONG line to server output file."""
1127 strong_write(io_db["file_out"], "PONG\n")
1131 """Abort server process."""
1132 if None == opts.replay:
1133 if world_db["WORLD_ACTIVE"]:
1135 atomic_write(io_db["path_record"], io_db["record_chunk"], do_append=True)
1136 raise SystemExit("received QUIT command")
1139 def command_thingshere(str_y, str_x):
1140 """Write to out file list of Things known to player at coordinate y, x."""
1141 if world_db["WORLD_ACTIVE"]:
1142 y = integer_test(str_y, 0, 255)
1143 x = integer_test(str_x, 0, 255)
1144 length = world_db["MAP_LENGTH"]
1145 if None != y and None != x and y < length and x < length:
1146 pos = (y * world_db["MAP_LENGTH"]) + x
1147 strong_write(io_db["file_out"], "THINGS_HERE START\n")
1148 if "v" == chr(world_db["Things"][0]["fovmap"][pos]):
1149 for id in world_db["Things"]:
1150 if y == world_db["Things"][id]["T_POSY"] \
1151 and x == world_db["Things"][id]["T_POSX"] \
1152 and not world_db["Things"][id]["carried"]:
1153 type = world_db["Things"][id]["T_TYPE"]
1154 name = world_db["ThingTypes"][type]["TT_NAME"]
1155 strong_write(io_db["file_out"], name + "\n")
1157 for mt in world_db["Things"][0]["T_MEMTHING"]:
1158 if y == mt[1] and x == mt[2]:
1159 name = world_db["ThingTypes"][mt[0]]["TT_NAME"]
1160 strong_write(io_db["file_out"], name + "\n")
1161 strong_write(io_db["file_out"], "THINGS_HERE END\n")
1163 print("Ignoring: Invalid map coordinates.")
1165 print("Ignoring: Command only works on existing worlds.")
1168 def play_commander(action, args=False):
1169 """Setter for player's T_COMMAND and T_ARGUMENT, then calling turn_over().
1171 T_ARGUMENT is set to direction char if action=="wait",or 8-bit int if args.
1175 id = [x for x in world_db["ThingActions"]
1176 if world_db["ThingActions"][x]["TA_NAME"] == action][0]
1177 world_db["Things"][0]["T_COMMAND"] = id
1180 def set_command_and_argument_int(str_arg):
1181 val = integer_test(str_arg, 0, 255)
1183 world_db["Things"][0]["T_ARGUMENT"] = val
1186 def set_command_and_argument_movestring(str_arg):
1187 if str_arg in directions_db:
1188 world_db["Things"][0]["T_ARGUMENT"] = ord(directions_db[str_arg])
1191 print("Ignoring: Argument must be valid direction string.")
1193 if action == "move":
1194 return set_command_and_argument_movestring
1196 return set_command_and_argument_int
1201 def command_seedrandomness(seed_string):
1202 """Set rand seed to int(seed_string)."""
1203 val = integer_test(seed_string, 0, 4294967295)
1208 def command_makeworld(seed_string):
1209 """(Re-)build game world, i.e. map, things, to a new turn 1 from seed.
1211 Seed rand with seed. Do more only with a "wait" ThingAction and
1212 world["PLAYER_TYPE"] matching ThingType of TT_START_NUMBER > 0. Then,
1213 world_db["Things"] emptied, call make_map() and set
1214 world_db["WORLD_ACTIVE"], world_db["TURN"] to 1. Build new Things
1215 according to ThingTypes' TT_START_NUMBERS, with Thing of ID 0 to ThingType
1216 of ID = world["PLAYER_TYPE"]. Place Things randomly, and actors not on each
1217 other. Init player's memory map. Write "NEW_WORLD" line to out file.
1224 err = "Space to put thing on too hard to find. Map too small?"
1226 y = rand.next() % world_db["MAP_LENGTH"]
1227 x = rand.next() % world_db["MAP_LENGTH"]
1228 if "." == chr(world_db["MAP"][y * world_db["MAP_LENGTH"] + x]):
1232 raise SystemExit(err)
1233 # Replica of C code, wrongly ignores animatedness of new Thing.
1234 pos_clear = (0 == len([id for id in world_db["Things"]
1235 if world_db["Things"][id]["T_LIFEPOINTS"]
1236 if world_db["Things"][id]["T_POSY"] == y
1237 if world_db["Things"][id]["T_POSX"] == x]))
1242 val = integer_test(seed_string, 0, 4294967295)
1246 player_will_be_generated = False
1247 playertype = world_db["PLAYER_TYPE"]
1248 for ThingType in world_db["ThingTypes"]:
1249 if playertype == ThingType:
1250 if 0 < world_db["ThingTypes"][ThingType]["TT_START_NUMBER"]:
1251 player_will_be_generated = True
1253 if not player_will_be_generated:
1254 print("Ignoring: No player type with start number >0 defined.")
1257 for ThingAction in world_db["ThingActions"]:
1258 if "wait" == world_db["ThingActions"][ThingAction]["TA_NAME"]:
1261 print("Ignoring beyond SEED_MAP: " +
1262 "No thing action with name 'wait' defined.")
1264 world_db["Things"] = {}
1266 world_db["WORLD_ACTIVE"] = 1
1267 world_db["TURN"] = 1
1268 for i in range(world_db["ThingTypes"][playertype]["TT_START_NUMBER"]):
1269 id = id_setter(-1, "Things")
1270 world_db["Things"][id] = new_Thing(playertype, free_pos())
1271 if not world_db["Things"][0]["fovmap"]:
1272 empty_fovmap = bytearray(b" " * world_db["MAP_LENGTH"] ** 2)
1273 world_db["Things"][0]["fovmap"] = empty_fovmap
1274 update_map_memory(world_db["Things"][0])
1275 for type in world_db["ThingTypes"]:
1276 for i in range(world_db["ThingTypes"][type]["TT_START_NUMBER"]):
1277 if type != playertype:
1278 id = id_setter(-1, "Things")
1279 world_db["Things"][id] = new_Thing(type, free_pos())
1280 strong_write(io_db["file_out"], "NEW_WORLD\n")
1284 def command_maplength(maplength_string):
1285 """Redefine map length. Invalidate map, therefore lose all things on it."""
1286 val = integer_test(maplength_string, 1, 256)
1288 world_db["MAP_LENGTH"] = val
1289 world_db["MAP"] = False
1290 set_world_inactive()
1291 world_db["Things"] = {}
1292 libpr.set_maplength(val)
1295 def command_worldactive(worldactive_string):
1296 """Toggle world_db["WORLD_ACTIVE"] if possible.
1298 An active world can always be set inactive. An inactive world can only be
1299 set active with a "wait" ThingAction, and a player Thing (of ID 0), and a
1300 map. On activation, rebuild all Things' FOVs, and the player's map memory.
1301 Also call log_help().
1303 val = integer_test(worldactive_string, 0, 1)
1305 if 0 != world_db["WORLD_ACTIVE"]:
1307 set_world_inactive()
1309 print("World already active.")
1310 elif 0 == world_db["WORLD_ACTIVE"]:
1312 for ThingAction in world_db["ThingActions"]:
1313 if "wait" == world_db["ThingActions"][ThingAction]["TA_NAME"]:
1316 player_exists = False
1317 for Thing in world_db["Things"]:
1319 player_exists = True
1321 if wait_exists and player_exists and world_db["MAP"]:
1322 for id in world_db["Things"]:
1323 if world_db["Things"][id]["T_LIFEPOINTS"]:
1324 build_fov_map(world_db["Things"][id])
1326 update_map_memory(world_db["Things"][id], False)
1327 if not world_db["Things"][0]["T_LIFEPOINTS"]:
1328 empty_fovmap = bytearray(b" " * world_db["MAP_LENGTH"] ** 2)
1329 world_db["Things"][0]["fovmap"] = empty_fovmap
1330 world_db["WORLD_ACTIVE"] = 1
1333 print("Ignoring: Not all conditions for world activation met.")
1336 def test_for_id_maker(object, category):
1337 """Return decorator testing for object having "id" attribute."""
1340 if hasattr(object, "id"):
1343 print("Ignoring: No " + category +
1344 " defined to manipulate yet.")
1349 def command_tid(id_string):
1350 """Set ID of Thing to manipulate. ID unused? Create new one.
1352 Default new Thing's type to the first available ThingType, others: zero.
1354 id = id_setter(id_string, "Things", command_tid)
1356 if world_db["ThingTypes"] == {}:
1357 print("Ignoring: No ThingType to settle new Thing in.")
1359 type = list(world_db["ThingTypes"].keys())[0]
1360 world_db["Things"][id] = new_Thing(type)
1363 test_Thing_id = test_for_id_maker(command_tid, "Thing")
1367 def command_tcommand(str_int):
1368 """Set T_COMMAND of selected Thing."""
1369 val = integer_test(str_int, 0)
1371 if 0 == val or val in world_db["ThingActions"]:
1372 world_db["Things"][command_tid.id]["T_COMMAND"] = val
1374 print("Ignoring: ThingAction ID belongs to no known ThingAction.")
1378 def command_ttype(str_int):
1379 """Set T_TYPE of selected Thing."""
1380 val = integer_test(str_int, 0)
1382 if val in world_db["ThingTypes"]:
1383 world_db["Things"][command_tid.id]["T_TYPE"] = val
1385 print("Ignoring: ThingType ID belongs to no known ThingType.")
1389 def command_tcarries(str_int):
1390 """Append int(str_int) to T_CARRIES of selected Thing.
1392 The ID int(str_int) must not be of the selected Thing, and must belong to a
1393 Thing with unset "carried" flag. Its "carried" flag will be set on owning.
1395 val = integer_test(str_int, 0)
1397 if val == command_tid.id:
1398 print("Ignoring: Thing cannot carry itself.")
1399 elif val in world_db["Things"] \
1400 and not world_db["Things"][val]["carried"]:
1401 world_db["Things"][command_tid.id]["T_CARRIES"].append(val)
1402 world_db["Things"][val]["carried"] = True
1404 print("Ignoring: Thing not available for carrying.")
1405 # Note that the whole carrying structure is different from the C version:
1406 # Carried-ness is marked by a "carried" flag, not by Things containing
1407 # Things internally.
1411 def command_tmemthing(str_t, str_y, str_x):
1412 """Add (int(str_t), int(str_y), int(str_x)) to selected Thing's T_MEMTHING.
1414 The type must fit to an existing ThingType, and the position into the map.
1416 type = integer_test(str_t, 0)
1417 posy = integer_test(str_y, 0, 255)
1418 posx = integer_test(str_x, 0, 255)
1419 if None != type and None != posy and None != posx:
1420 if type not in world_db["ThingTypes"] \
1421 or posy >= world_db["MAP_LENGTH"] or posx >= world_db["MAP_LENGTH"]:
1422 print("Ignoring: Illegal value for thing type or position.")
1424 memthing = (type, posy, posx)
1425 world_db["Things"][command_tid.id]["T_MEMTHING"].append(memthing)
1428 def setter_map(maptype):
1429 """Set (world or Thing's) map of maptype's int(str_int)-th line to mapline.
1431 If no map of maptype exists yet, initialize it with ' ' bytes first.
1434 def valid_map_line(str_int, mapline):
1435 val = integer_test(str_int, 0, 255)
1437 if val >= world_db["MAP_LENGTH"]:
1438 print("Illegal value for map line number.")
1439 elif len(mapline) != world_db["MAP_LENGTH"]:
1440 print("Map line length is unequal map width.")
1445 def nonThingMap_helper(str_int, mapline):
1446 val = valid_map_line(str_int, mapline)
1448 length = world_db["MAP_LENGTH"]
1449 if not world_db["MAP"]:
1450 map = bytearray(b' ' * (length ** 2))
1452 map = world_db["MAP"]
1453 map[val * length:(val * length) + length] = mapline.encode()
1454 if not world_db["MAP"]:
1455 world_db["MAP"] = map
1458 def ThingMap_helper(str_int, mapline):
1459 val = valid_map_line(str_int, mapline)
1461 length = world_db["MAP_LENGTH"]
1462 if not world_db["Things"][command_tid.id][maptype]:
1463 map = bytearray(b' ' * (length ** 2))
1465 map = world_db["Things"][command_tid.id][maptype]
1466 map[val * length:(val * length) + length] = mapline.encode()
1467 if not world_db["Things"][command_tid.id][maptype]:
1468 world_db["Things"][command_tid.id][maptype] = map
1470 return nonThingMap_helper if maptype == "MAP" else ThingMap_helper
1474 def setter_tpos(axis):
1475 """Generate setter for T_POSX or T_POSY of selected Thing.
1477 If world is active, rebuilds animate things' fovmap, player's memory map.
1480 def helper(str_int):
1481 val = integer_test(str_int, 0, 255)
1483 if val < world_db["MAP_LENGTH"]:
1484 world_db["Things"][command_tid.id]["T_POS" + axis] = val
1485 if world_db["WORLD_ACTIVE"] \
1486 and world_db["Things"][command_tid.id]["T_LIFEPOINTS"]:
1487 build_fov_map(world_db["Things"][command_tid.id])
1488 if 0 == command_tid.id:
1489 update_map_memory(world_db["Things"][command_tid.id])
1491 print("Ignoring: Position is outside of map.")
1495 def command_ttid(id_string):
1496 """Set ID of ThingType to manipulate. ID unused? Create new one.
1498 Default new ThingType's TT_SYMBOL to "?", TT_CORPSE_ID to self, TT_TOOL to
1501 id = id_setter(id_string, "ThingTypes", command_ttid)
1503 world_db["ThingTypes"][id] = {
1504 "TT_NAME": "(none)",
1507 "TT_PROLIFERATE": 0,
1508 "TT_START_NUMBER": 0,
1515 test_ThingType_id = test_for_id_maker(command_ttid, "ThingType")
1519 def command_ttname(name):
1520 """Set TT_NAME of selected ThingType."""
1521 world_db["ThingTypes"][command_ttid.id]["TT_NAME"] = name
1525 def command_tttool(name):
1526 """Set TT_TOOL of selected ThingType."""
1527 world_db["ThingTypes"][command_ttid.id]["TT_TOOL"] = name
1531 def command_ttsymbol(char):
1532 """Set TT_SYMBOL of selected ThingType. """
1534 world_db["ThingTypes"][command_ttid.id]["TT_SYMBOL"] = char
1536 print("Ignoring: Argument must be single character.")
1540 def command_ttcorpseid(str_int):
1541 """Set TT_CORPSE_ID of selected ThingType."""
1542 val = integer_test(str_int, 0)
1544 if val in world_db["ThingTypes"]:
1545 world_db["ThingTypes"][command_ttid.id]["TT_CORPSE_ID"] = val
1547 print("Ignoring: Corpse ID belongs to no known ThignType.")
1550 def command_taid(id_string):
1551 """Set ID of ThingAction to manipulate. ID unused? Create new one.
1553 Default new ThingAction's TA_EFFORT to 1, its TA_NAME to "wait".
1555 id = id_setter(id_string, "ThingActions", command_taid, True)
1557 world_db["ThingActions"][id] = {
1563 test_ThingAction_id = test_for_id_maker(command_taid, "ThingAction")
1566 @test_ThingAction_id
1567 def command_taname(name):
1568 """Set TA_NAME of selected ThingAction.
1570 The name must match a valid thing action function. If after the name
1571 setting no ThingAction with name "wait" remains, call set_world_inactive().
1573 if name == "wait" or name == "move" or name == "use" or name == "drop" \
1574 or name == "pick_up":
1575 world_db["ThingActions"][command_taid.id]["TA_NAME"] = name
1576 if 1 == world_db["WORLD_ACTIVE"]:
1577 wait_defined = False
1578 for id in world_db["ThingActions"]:
1579 if "wait" == world_db["ThingActions"][id]["TA_NAME"]:
1582 if not wait_defined:
1583 set_world_inactive()
1585 print("Ignoring: Invalid action name.")
1586 # In contrast to the original,naming won't map a function to a ThingAction.
1590 """Call ai() on player Thing, then turn_over()."""
1591 ai(world_db["Things"][0])
1595 """Commands database.
1597 Map command start tokens to ([0]) number of expected command arguments, ([1])
1598 the command's meta-ness (i.e. is it to be written to the record file, is it to
1599 be ignored in replay mode if read from server input file), and ([2]) a function
1603 "QUIT": (0, True, command_quit),
1604 "PING": (0, True, command_ping),
1605 "THINGS_HERE": (2, True, command_thingshere),
1606 "MAKE_WORLD": (1, False, command_makeworld),
1607 "SEED_RANDOMNESS": (1, False, command_seedrandomness),
1608 "TURN": (1, False, setter(None, "TURN", 0, 65535)),
1609 "PLAYER_TYPE": (1, False, setter(None, "PLAYER_TYPE", 0)),
1610 "MAP_LENGTH": (1, False, command_maplength),
1611 "WORLD_ACTIVE": (1, False, command_worldactive),
1612 "MAP": (2, False, setter_map("MAP")),
1613 "TA_ID": (1, False, command_taid),
1614 "TA_EFFORT": (1, False, setter("ThingAction", "TA_EFFORT", 0, 255)),
1615 "TA_NAME": (1, False, command_taname),
1616 "TT_ID": (1, False, command_ttid),
1617 "TT_NAME": (1, False, command_ttname),
1618 "TT_TOOL": (1, False, command_tttool),
1619 "TT_SYMBOL": (1, False, command_ttsymbol),
1620 "TT_CORPSE_ID": (1, False, command_ttcorpseid),
1621 "TT_TOOLPOWER": (1, False, setter("ThingType", "TT_TOOLPOWER", 0, 65535)),
1622 "TT_START_NUMBER": (1, False, setter("ThingType", "TT_START_NUMBER",
1624 "TT_PROLIFERATE": (1, False, setter("ThingType", "TT_PROLIFERATE",
1626 "TT_LIFEPOINTS": (1, False, setter("ThingType", "TT_LIFEPOINTS", 0, 255)),
1627 "T_ID": (1, False, command_tid),
1628 "T_ARGUMENT": (1, False, setter("Thing", "T_ARGUMENT", 0, 255)),
1629 "T_PROGRESS": (1, False, setter("Thing", "T_PROGRESS", 0, 255)),
1630 "T_LIFEPOINTS": (1, False, setter("Thing", "T_LIFEPOINTS", 0, 255)),
1631 "T_SATIATION": (1, False, setter("Thing", "T_SATIATION", -32768, 32767)),
1632 "T_COMMAND": (1, False, command_tcommand),
1633 "T_TYPE": (1, False, command_ttype),
1634 "T_CARRIES": (1, False, command_tcarries),
1635 "T_MEMMAP": (2, False, setter_map("T_MEMMAP")),
1636 "T_MEMDEPTHMAP": (2, False, setter_map("T_MEMDEPTHMAP")),
1637 "T_MEMTHING": (3, False, command_tmemthing),
1638 "T_POSY": (1, False, setter_tpos("Y")),
1639 "T_POSX": (1, False, setter_tpos("X")),
1640 "wait": (0, False, play_commander("wait")),
1641 "move": (1, False, play_commander("move")),
1642 "pick_up": (0, False, play_commander("pick_up")),
1643 "drop": (1, False, play_commander("drop", True)),
1644 "use": (1, False, play_commander("use", True)),
1645 "ai": (0, False, command_ai)
1647 # TODO: Unhandled cases: (Un-)killing animates (esp. player!) with T_LIFEPOINTS.
1650 """World state database. With sane default values. (Randomness is in rand.)"""
1662 """Mapping of direction names to internal direction chars."""
1663 directions_db = {"east": "d", "south-east": "c", "south-west": "x",
1664 "west": "s", "north-west": "w", "north-east": "e"}
1666 """File IO database."""
1668 "path_save": "save",
1669 "path_record": "record_save",
1670 "path_worldconf": "confserver/world",
1671 "path_server": "server/",
1672 "path_in": "server/in",
1673 "path_out": "server/out",
1674 "path_worldstate": "server/worldstate",
1675 "tmp_suffix": "_tmp",
1676 "kicked_by_rival": False,
1677 "worldstate_updateable": False
1682 libpr = prep_library()
1683 rand = RandomnessIO()
1684 opts = parse_command_line_arguments()
1686 io_db["path_save"] = opts.savefile
1687 io_db["path_record"] = "record_" + opts.savefile
1690 io_db["verbose"] = True
1691 if None != opts.replay:
1695 except SystemExit as exit:
1696 print("ABORTING: " + exit.args[0])
1698 print("SOMETHING WENT WRONG IN UNEXPECTED WAYS")