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.
19 """"Interface to libplomrogue's pseudo-randomness generator."""
21 def set_seed(self, seed):
22 libpr.seed_rrand(1, seed)
25 return libpr.seed_rrand(0, 0)
30 seed = property(get_seed, set_seed)
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
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)
49 def strong_write(file, string):
50 """Apply write(string), then flush()."""
55 def setup_server_io():
56 """Fill IO files DB with proper file( path)s. Write process IO test string.
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"].
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):
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"])
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):
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()
103 """Send "msg" to log."""
104 strong_write(io_db["file_out"], "LOG " + msg + "\n")
107 def obey(command, prefix, replay=False, do_record=False):
108 """Call function from commands_db mapped to command's first token.
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.
123 print("input " + prefix + ": " + command)
125 tokens = shlex.split(command, comments=True)
126 except ValueError as err:
127 print("Can't tokenize command string: " + str(err) + ".")
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.")
136 print("Due to replay mode, reading command as 'go on in record'.")
137 line = io_db["file_record"].readline()
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
143 print("Reached end of record file.")
145 commands_db[tokens[0]][2](*tokens[1:])
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"],
151 if world_db["WORLD_ACTIVE"]:
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.")
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"]
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)
171 if delete and os.access(path, os.F_OK):
173 os.rename(path_tmp, path)
177 """Save all commands needed to reconstruct current world state."""
180 string = string.replace("\u005C", '\u005C\u005C')
181 return '"' + string.replace('"', '\u005C"') + '"'
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) \
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"
204 def helper(category, id_string, special_keys={}):
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)
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)
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")
247 for line in file.readlines():
248 obey(line.rstrip(), name + "file line " + str(line_n),
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,
259 parser.add_argument('-l', nargs="?", const="save", dest='savefile',
261 parser.add_argument('-v', dest='verbose', action='store_true')
262 opts, unknown = parser.parse_known_args()
267 """Ensure valid server out file belonging to current process.
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.
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")
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)
287 """Return next newline-delimited command from server in file.
289 Keep building return string until a newline is encountered. Pause between
290 unsuccessful reads, and after too much waiting, run server_test().
292 wait_on_fail = 0.03333
297 add = io_db["file_in"].readline()
299 command = command + add
300 if len(command) > 0 and "\n" == command[-1]:
301 command = command[:-1]
304 time.sleep(wait_on_fail)
305 if now + max_wait < time.time():
311 def try_worldstate_update():
312 """Write worldstate file if io_db["worldstate_updateable"] is set."""
313 if io_db["worldstate_updateable"]:
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"
322 if [] == world_db["Things"][0]["T_CARRIES"]:
323 inventory = "(none)\n"
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))
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"]
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
368 """Replay game from record file.
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().
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()
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
392 try_worldstate_update()
393 obey(read_command(), "in file", replay=True)
397 """Play game by server input file commands. Before, load save file found.
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().
404 if os.access(io_db["path_save"], os.F_OK):
405 obey_lines_in_file(io_db["path_save"], "save")
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 ",
412 obey("MAKE_WORLD " + str(int(time.time())), "in file", do_record=True)
414 try_worldstate_update()
415 obey(read_command(), "in file", do_record=True)
419 """(Re-)make island map.
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).
428 def is_neighbor(coordinates, type):
431 length = world_db["MAP_LENGTH"]
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])) \
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)])) \
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)])):
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(".")
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):
462 world_db["MAP"][pos] = ord(".")
463 n_trees = int((length ** 2) / 16)
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")
474 # This all-too-precise replica of the original C code misses iter_limit().
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
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."""
488 def age_some_memdepthmap_on_nonfov_cells():
489 # OUTSOURCED FOR PERFORMANCE REASONS TO libplomrogue.so:
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)
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))
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]
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"])
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))
529 def set_world_inactive():
530 """Set world_db["WORLD_ACTIVE"] to 0 and remove worldstate file."""
532 if os.access(io_db["path_worldstate"], os.F_OK):
533 os.remove(io_db["path_worldstate"])
534 world_db["WORLD_ACTIVE"] = 0
537 def integer_test(val_string, min, max=None):
538 """Return val_string if integer >= min & (if max set) <= max, else None."""
540 val = int(val_string)
541 if val < min or (max is not None and val > max):
545 msg = "Ignoring: Please use integer >= " + str(min)
547 msg += " and <= " + str(max)
553 def setter(category, key, min, max=None):
554 """Build setter for world_db([category + "s"][id])[key] to >=min/<=max."""
557 val = integer_test(val_string, min, max)
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
573 val = integer_test(val_string, min, max)
575 world_db[category + "s"][id_store.id][key] = val
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().")
589 """Send quick usage info to log."""
590 log("LOG See README file for help.")
593 def decrement_lifepoints(t):
594 """Decrement t's lifepoints by 1, and if to zero, corpse it.
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.
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))
611 log("See README on how to start over.")
614 t["T_MEMMAP"] = False
615 t["T_MEMDEPTHMAP"] = False
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)
624 raise RuntimeError("Too much wrapping in mv_yx_in_dir_legal_wrap()!")
625 return (test, libpr.result_y(), libpr.result_x())
629 """Make t do nothing (but loudly, if player avatar)."""
630 if t == world_db["Things"][0]:
635 """If passable, move/collide(=attack) thing into T_ARGUMENT's direction."""
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]]
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 + ".")
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])
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]
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]
667 if t == world_db["Things"][0]:
668 log("You move " + dir + ".")
669 elif t == world_db["Things"][0]:
670 log("You fail to move " + dir + ".")
673 def actor_pick_up(t):
674 """Make t pick up (topmost?) Thing from ground into inventory.
676 Define topmostness by how low the thing's type ID is.
678 ids = [id for id in world_db["Things"] if world_db["Things"][id] != t
679 if not world_db["Things"][id]["carried"]
680 if world_db["Things"][id]["T_POSY"] == t["T_POSY"]
681 if world_db["Things"][id]["T_POSX"] == t["T_POSX"]]
685 tid = world_db["Things"][iid]["T_TYPE"]
686 if lowest_tid == -1 or tid < lowest_tid:
689 world_db["Things"][id]["carried"] = True
690 t["T_CARRIES"].append(id)
691 if t == world_db["Things"][0]:
692 log("You pick up an object.")
693 elif t == world_db["Things"][0]:
694 log("You try to pick up an object, but there is none.")
698 """Make t rop Thing from inventory to ground indexed by T_ARGUMENT."""
699 # TODO: Handle case where T_ARGUMENT matches nothing.
700 if len(t["T_CARRIES"]):
701 id = t["T_CARRIES"][t["T_ARGUMENT"]]
702 t["T_CARRIES"].remove(id)
703 world_db["Things"][id]["carried"] = False
704 if t == world_db["Things"][0]:
705 log("You drop an object.")
706 elif t == world_db["Things"][0]:
707 log("You try to drop an object, but you own none.")
711 """Make t use (for now: consume) T_ARGUMENT-indexed Thing in inventory."""
712 # TODO: Handle case where T_ARGUMENT matches nothing.
713 if len(t["T_CARRIES"]):
714 id = t["T_CARRIES"][t["T_ARGUMENT"]]
715 type = world_db["Things"][id]["T_TYPE"]
716 if world_db["ThingTypes"][type]["TT_TOOL"] == "food":
717 t["T_CARRIES"].remove(id)
718 del world_db["Things"][id]
719 t["T_SATIATION"] += world_db["ThingTypes"][type]["TT_TOOLPOWER"]
720 if t == world_db["Things"][0]:
721 log("You consume this object.")
722 elif t == world_db["Things"][0]:
723 log("You try to use this object, but fail.")
724 elif t == world_db["Things"][0]:
725 log("You try to use an object, but you own none.")
728 def thingproliferation(t, prol_map):
729 """To chance of 1/TT_PROLIFERATE, create t offspring in open neighbor cell.
731 Naturally only works with TT_PROLIFERATE > 0. The neighbor cell must be be
732 marked '.' in prol_map. If there are several map cell candidates, one is
735 prolscore = world_db["ThingTypes"][t["T_TYPE"]]["TT_PROLIFERATE"]
736 if prolscore and (1 == prolscore or 1 == (rand.next() % prolscore)):
738 for dir in [directions_db[key] for key in sorted(directions_db.keys())]:
739 mv_result = mv_yx_in_dir_legal(dir, t["T_POSY"], t["T_POSX"])
740 if mv_result[0] and ord('.') == prol_map[mv_result[1]
741 * world_db["MAP_LENGTH"]
743 candidates.append((mv_result[1], mv_result[2]))
745 i = rand.next() % len(candidates)
746 id = id_setter(-1, "Things")
747 newT = new_Thing(t["T_TYPE"], (candidates[i][0], candidates[i][1]))
748 world_db["Things"][id] = newT
752 """If t's HP < max, increment them if well-nourished, maybe waiting."""
753 if t["T_LIFEPOINTS"] < \
754 world_db["ThingTypes"][t["T_TYPE"]]["TT_LIFEPOINTS"]:
755 wait_id = [id for id in world_db["ThingActions"]
756 if world_db["ThingActions"][id]["TA_NAME"] == "wait"][0]
757 wait_divider = 8 if t["T_COMMAND"] == wait_id else 1
758 testval = int(abs(t["T_SATIATION"]) / wait_divider)
759 if (testval <= 1 or 1 == (rand.next() % testval)):
760 t["T_LIFEPOINTS"] += 1
761 if t == world_db["Things"][0]:
765 def hunger_per_turn(type_id):
766 """The amount of satiation score lost per turn for things of given type."""
767 return int(math.sqrt(world_db["ThingTypes"][type_id]["TT_LIFEPOINTS"]))
771 """Decrement t's satiation,dependent on it trigger lifepoint dec chance."""
772 if t["T_SATIATION"] > -32768:
773 t["T_SATIATION"] -= hunger_per_turn(t["T_TYPE"])
774 if 0 != t["T_SATIATION"] and 0 == int(rand.next() / abs(t["T_SATIATION"])):
775 if t == world_db["Things"][0]:
776 if t["T_SATIATION"] < 0:
777 log("You suffer from hunger.")
779 log("You suffer from over-eating.")
780 decrement_lifepoints(t)
783 def get_dir_to_target(t, filter):
784 """Try to set T_COMMAND/T_ARGUMENT for move to "filter"-determined target.
786 The path-wise nearest target is chosen, via the shortest available path.
787 Target must not be t. On succcess, return positive value, else False.
789 "a": Thing in FOV is animate, but of ThingType, starts out weaker than t
790 is, and its corpse would be healthy food for t
791 "f": move away from an enemy – any visible actor whose thing type has more
792 TT_LIFEPOINTS than t LIFEPOINTS, and might find t's corpse healthy
793 food – if it is closer than n steps, where n will shrink as t's hunger
794 grows; if enemy is too close, move towards (attack) the enemy instead;
795 if no fleeing is possible, nor attacking useful, wait; don't tread on
796 non-enemies for fleeing
797 "c": Thing in memorized map is consumable of sufficient nutrition for t
798 "s": memory map cell with greatest-reachable degree of unexploredness
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_at_thingpos(id, score):
812 pos = world_db["Things"][id]["T_POSY"] * world_db["MAP_LENGTH"] \
813 + world_db["Things"][id]["T_POSX"]
814 set_map_score(pos, score)
816 def set_map_score(pos, score):
817 test = libpr.set_map_score(pos, score)
819 raise RuntimeError("No score map allocated for set_map_score().")
821 def get_map_score(pos):
822 result = libpr.get_map_score(pos)
824 raise RuntimeError("No score map allocated for get_map_score().")
827 def animate_in_fov(Thing):
828 if Thing["carried"] or Thing == t or not Thing["T_LIFEPOINTS"]:
830 pos = Thing["T_POSY"] * world_db["MAP_LENGTH"] + Thing["T_POSX"]
831 if ord("v") == t["fovmap"][pos]:
834 def good_attack_target(v):
835 eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
836 type = world_db["ThingTypes"][v["T_TYPE"]]
837 type_corpse = world_db["ThingTypes"][type["TT_CORPSE_ID"]]
838 if t["T_LIFEPOINTS"] > type["TT_LIFEPOINTS"] \
839 and type_corpse["TT_TOOL"] == "food" \
840 and type_corpse["TT_TOOLPOWER"] > eat_cost:
844 def good_flee_target(m):
845 own_corpse_id = world_db["ThingTypes"][t["T_TYPE"]]["TT_CORPSE_ID"]
846 corpse_type = world_db["ThingTypes"][own_corpse_id]
847 targetness = 0 if corpse_type["TT_TOOL"] != "food" \
848 else corpse_type["TT_TOOLPOWER"]
849 type = world_db["ThingTypes"][m["T_TYPE"]]
850 if t["T_LIFEPOINTS"] < type["TT_LIFEPOINTS"] \
851 and targetness > eat_vs_hunger_threshold(m["T_TYPE"]):
856 if t["fovmap"] and "a" == filter:
857 for id in world_db["Things"]:
858 if animate_in_fov(world_db["Things"][id]):
859 if good_attack_target(world_db["Things"][id]):
861 elif t["fovmap"] and "f" == filter:
862 for id in world_db["Things"]:
863 if animate_in_fov(world_db["Things"][id]):
864 if good_flee_target(world_db["Things"][id]):
866 elif t["T_MEMMAP"] and "c" == filter:
867 eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
868 for mt in t["T_MEMTHING"]:
869 if ' ' != chr(t["T_MEMMAP"][(mt[1] * world_db["MAP_LENGTH"])
871 and world_db["ThingTypes"][mt[0]]["TT_TOOL"] == "food" \
872 and world_db["ThingTypes"][mt[0]]["TT_TOOLPOWER"] \
877 def set_cells_passable_on_memmap_to_65534_on_scoremap():
878 # OUTSOURCED FOR PERFORMANCE REASONS TO libplomrogue.so:
880 # memmap = t["T_MEMMAP"]
881 # for i in [i for i in range(world_db["MAP_LENGTH"] ** 2)
882 # if ord_dot == memmap[i]]:
883 # set_map_score(i, 65534) # i.e. 65535-1
884 map = c_pointer_to_bytearray(t["T_MEMMAP"])
885 if libpr.set_cells_passable_on_memmap_to_65534_on_scoremap(map):
886 raise RuntimeError("No score map allocated for set_cells_passable"
887 "_on_memmap_to_65534_on_scoremap().")
889 def init_score_map():
890 test = libpr.init_score_map()
892 raise RuntimeError("Malloc error in init_score_map().")
895 set_cells_passable_on_memmap_to_65534_on_scoremap()
897 for id in world_db["Things"]:
898 if animate_in_fov(world_db["Things"][id]) \
899 and good_attack_target(world_db["Things"][id]):
900 set_map_score_at_thingpos(id, 0)
902 for id in world_db["Things"]:
903 if animate_in_fov(world_db["Things"][id]) \
904 and good_flee_target(world_db["Things"][id]):
905 set_map_score_at_thingpos(id, 0)
907 eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
908 for mt in [mt for mt in t["T_MEMTHING"]
909 if ord_blank != t["T_MEMMAP"][mt[1]
910 * world_db["MAP_LENGTH"]
912 if world_db["ThingTypes"][mt[0]]["TT_TOOL"] == "food"
913 if world_db["ThingTypes"][mt[0]]["TT_TOOLPOWER"]
915 set_map_score(mt[1] * world_db["MAP_LENGTH"] + mt[2], 0)
917 zero_score_map_where_char_on_memdepthmap(mem_depth_c[0])
919 for id in world_db["Things"]:
920 if animate_in_fov(world_db["Things"][id]):
922 pos = world_db["Things"][id]["T_POSY"] \
923 * world_db["MAP_LENGTH"] \
924 + world_db["Things"][id]["T_POSX"]
925 if 0 == get_map_score(pos):
927 set_map_score_at_thingpos(id, 65535)
929 def rand_target_dir(neighbors, cmp, dirs):
932 for i in range(len(dirs)):
933 if cmp == neighbors[i]:
934 candidates.append(dirs[i])
936 return candidates[rand.next() % n_candidates] if n_candidates else 0
938 def get_neighbor_scores(dirs, eye_pos):
940 if libpr.ready_neighbor_scores(eye_pos):
941 raise RuntimeError("No score map allocated for " +
942 "ready_neighbor_scores.()")
943 for i in range(len(dirs)):
944 scores.append(libpr.get_neighbor_score(i))
947 def get_dir_from_neighbors():
948 dir_to_target = False
950 eye_pos = t["T_POSY"] * world_db["MAP_LENGTH"] + t["T_POSX"]
951 neighbors = get_neighbor_scores(dirs, eye_pos)
952 minmax_start = 0 if "f" == filter else 65535 - 1
953 minmax_neighbor = minmax_start
954 for i in range(len(dirs)):
955 if ("f" == filter and get_map_score(eye_pos) < neighbors[i] and
956 minmax_neighbor < neighbors[i] and 65535 != neighbors[i]) \
957 or ("f" != filter and minmax_neighbor > neighbors[i]):
958 minmax_neighbor = neighbors[i]
959 if minmax_neighbor != minmax_start:
960 dir_to_target = rand_target_dir(neighbors, minmax_neighbor, dirs)
962 distance = get_map_score(eye_pos)
963 fear_distance = world_db["MAP_LENGTH"]
964 if t["T_SATIATION"] < 0 and math.sqrt(-t["T_SATIATION"]) > 0:
965 fear_distance = fear_distance / math.sqrt(-t["T_SATIATION"])
967 if not dir_to_target:
968 if attack_distance >= distance:
969 dir_to_target = rand_target_dir(neighbors,
971 elif fear_distance >= distance:
972 t["T_COMMAND"] = [id for id in world_db["ThingActions"]
974 world_db["ThingActions"][id]["TA_NAME"]
977 elif dir_to_target and fear_distance < distance:
981 dir_to_target = False
983 run_i = 9 + 1 if "s" == filter else 1
984 while run_i and not dir_to_target and ("s" == filter or seeing_thing()):
987 mem_depth_c = b'9' if b' ' == mem_depth_c \
988 else bytes([mem_depth_c[0] - 1])
989 if libpr.dijkstra_map():
990 raise RuntimeError("No score map allocated for dijkstra_map().")
991 dir_to_target = get_dir_from_neighbors()
992 libpr.free_score_map()
993 if dir_to_target and str == type(dir_to_target):
994 t["T_COMMAND"] = [id for id in world_db["ThingActions"]
995 if world_db["ThingActions"][id]["TA_NAME"]
997 t["T_ARGUMENT"] = ord(dir_to_target)
1001 def standing_on_food(t):
1002 """Return True/False whether t is standing on healthy consumable."""
1003 eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
1004 for id in [id for id in world_db["Things"] if world_db["Things"][id] != t
1005 if not world_db["Things"][id]["carried"]
1006 if world_db["Things"][id]["T_POSY"] == t["T_POSY"]
1007 if world_db["Things"][id]["T_POSX"] == t["T_POSX"]
1008 if world_db["ThingTypes"][world_db["Things"][id]["T_TYPE"]]
1009 ["TT_TOOL"] == "food"
1010 if world_db["ThingTypes"][world_db["Things"][id]["T_TYPE"]]
1011 ["TT_TOOLPOWER"] > eat_cost]:
1016 def get_inventory_slot_to_consume(t):
1017 """Return invent. slot of healthiest consumable(if any healthy),else -1."""
1021 eat_cost = eat_vs_hunger_threshold(t["T_TYPE"])
1022 for id in t["T_CARRIES"]:
1023 type = world_db["Things"][id]["T_TYPE"]
1024 if world_db["ThingTypes"][type]["TT_TOOL"] == "food" \
1025 and world_db["ThingTypes"][type]["TT_TOOLPOWER"]:
1026 nutvalue = world_db["ThingTypes"][type]["TT_TOOLPOWER"]
1027 tmp_cmp = abs(t["T_SATIATION"] + nutvalue - eat_cost)
1028 if (cmp_food < 0 and tmp_cmp < abs(t["T_SATIATION"])) \
1029 or tmp_cmp < cmp_food:
1037 """Determine next command/argment for actor t via AI algorithms."""
1038 t["T_COMMAND"] = [id for id in world_db["ThingActions"]
1039 if world_db["ThingActions"][id]["TA_NAME"] == "wait"][0]
1040 if get_dir_to_target(t, "f"):
1042 sel = get_inventory_slot_to_consume(t)
1044 t["T_COMMAND"] = [id for id in world_db["ThingActions"]
1045 if world_db["ThingActions"][id]["TA_NAME"]
1047 t["T_ARGUMENT"] = sel
1048 elif standing_on_food(t):
1049 t["T_COMMAND"] = [id for id in world_db["ThingActions"]
1050 if world_db["ThingActions"][id]["TA_NAME"]
1053 going_to_known_food_spot = get_dir_to_target(t, "c")
1054 if not going_to_known_food_spot:
1055 aiming_for_walking_food = get_dir_to_target(t, "a")
1056 if not aiming_for_walking_food:
1057 get_dir_to_target(t, "s")
1061 """Run game world and its inhabitants until new player input expected."""
1063 whilebreaker = False
1064 while world_db["Things"][0]["T_LIFEPOINTS"]:
1065 proliferable_map = world_db["MAP"][:]
1066 for id in [id for id in world_db["Things"]
1067 if not world_db["Things"][id]["carried"]]:
1068 y = world_db["Things"][id]["T_POSY"]
1069 x = world_db["Things"][id]["T_POSX"]
1070 proliferable_map[y * world_db["MAP_LENGTH"] + x] = ord('X')
1071 for id in [id for id in world_db["Things"]]: # Only what's from start!
1072 if not id in world_db["Things"] or \
1073 world_db["Things"][id]["carried"]: # May have been consumed or
1074 continue # picked up during turn …
1075 Thing = world_db["Things"][id]
1076 if Thing["T_LIFEPOINTS"]:
1077 if not Thing["T_COMMAND"]:
1078 update_map_memory(Thing)
1085 if Thing["T_LIFEPOINTS"]:
1086 Thing["T_PROGRESS"] += 1
1087 taid = [a for a in world_db["ThingActions"]
1088 if a == Thing["T_COMMAND"]][0]
1089 ThingAction = world_db["ThingActions"][taid]
1090 if Thing["T_PROGRESS"] == ThingAction["TA_EFFORT"]:
1091 eval("actor_" + ThingAction["TA_NAME"])(Thing)
1092 Thing["T_COMMAND"] = 0
1093 Thing["T_PROGRESS"] = 0
1094 thingproliferation(Thing, proliferable_map)
1097 world_db["TURN"] += 1
1100 def new_Thing(type, pos=(0, 0)):
1101 """Return Thing of type T_TYPE, with fovmap if alive and world active."""
1103 "T_LIFEPOINTS": world_db["ThingTypes"][type]["TT_LIFEPOINTS"],
1115 "T_MEMDEPTHMAP": False,
1118 if world_db["WORLD_ACTIVE"] and thing["T_LIFEPOINTS"]:
1119 build_fov_map(thing)
1123 def id_setter(id, category, id_store=False, start_at_1=False):
1124 """Set ID of object of category to manipulate ID unused? Create new one.
1125 The ID is stored as id_store.id (if id_store is set). If the integer of the
1126 input is valid (if start_at_1, >= 0, else >= -1), but <0 or (if start_at_1)
1127 <1, calculate new ID: lowest unused ID >=0 or (if start_at_1) >= 1. None is
1128 always returned when no new object is created, else the new object's ID.
1130 min = 0 if start_at_1 else -1
1132 id = integer_test(id, min)
1134 if id in world_db[category]:
1139 if (start_at_1 and 0 == id) \
1140 or ((not start_at_1) and (id < 0)):
1141 id = 0 if start_at_1 else -1
1144 if id not in world_db[category]:
1152 """Send PONG line to server output file."""
1153 strong_write(io_db["file_out"], "PONG\n")
1157 """Abort server process."""
1158 if None == opts.replay:
1159 if world_db["WORLD_ACTIVE"]:
1161 atomic_write(io_db["path_record"], io_db["record_chunk"], do_append=True)
1162 raise SystemExit("received QUIT command")
1165 def command_thingshere(str_y, str_x):
1166 """Write to out file list of Things known to player at coordinate y, x."""
1167 if world_db["WORLD_ACTIVE"]:
1168 y = integer_test(str_y, 0, 255)
1169 x = integer_test(str_x, 0, 255)
1170 length = world_db["MAP_LENGTH"]
1171 if None != y and None != x and y < length and x < length:
1172 pos = (y * world_db["MAP_LENGTH"]) + x
1173 strong_write(io_db["file_out"], "THINGS_HERE START\n")
1174 if "v" == chr(world_db["Things"][0]["fovmap"][pos]):
1175 for id in [id for tid in sorted(list(world_db["ThingTypes"]))
1176 for id in world_db["Things"]
1177 if not world_db["Things"][id]["carried"]
1178 if world_db["Things"][id]["T_TYPE"] == tid
1179 if y == world_db["Things"][id]["T_POSY"]
1180 if x == world_db["Things"][id]["T_POSX"]]:
1181 type = world_db["Things"][id]["T_TYPE"]
1182 name = world_db["ThingTypes"][type]["TT_NAME"]
1183 strong_write(io_db["file_out"], name + "\n")
1185 for mt in [mt for tid in sorted(list(world_db["ThingTypes"]))
1186 for mt in world_db["Things"][0]["T_MEMTHING"]
1187 if mt[0] == tid if y == mt[1] if x == mt[2]]:
1188 name = world_db["ThingTypes"][mt[0]]["TT_NAME"]
1189 strong_write(io_db["file_out"], name + "\n")
1190 strong_write(io_db["file_out"], "THINGS_HERE END\n")
1192 print("Ignoring: Invalid map coordinates.")
1194 print("Ignoring: Command only works on existing worlds.")
1197 def set_command(action):
1198 """Set player's T_COMMAND, then call turn_over()."""
1199 id = [x for x in world_db["ThingActions"]
1200 if world_db["ThingActions"][x]["TA_NAME"] == action][0]
1201 world_db["Things"][0]["T_COMMAND"] = id
1206 """Try "wait" as player's T_COMMAND."""
1211 """Try "pick_up" as player's T_COMMAND"."""
1212 t = world_db["Things"][0]
1213 ids = [id for id in world_db["Things"] if id
1214 if not world_db["Things"][id]["carried"]
1215 if world_db["Things"][id]["T_POSY"] == t["T_POSY"]
1216 if world_db["Things"][id]["T_POSX"] == t["T_POSX"]]
1218 log("Nothing to pick up.")
1220 set_command("pick_up")
1223 def play_drop(str_arg):
1224 """Try "drop" as player's T_COMMAND, int(str_arg) as T_ARGUMENT / slot."""
1225 t = world_db["Things"][0]
1226 if 0 == len(t["T_CARRIES"]):
1227 log("You have nothing to drop in your inventory.")
1229 val = integer_test(str_arg, 0, 255)
1230 if None != val and val < len(t["T_CARRIES"]):
1231 world_db["Things"][0]["T_ARGUMENT"] = val
1234 print("Illegal inventory index.")
1237 def play_use(str_arg):
1238 """Try "use" as player's T_COMMAND, int(str_arg) as T_ARGUMENT / slot."""
1239 t = world_db["Things"][0]
1240 if 0 == len(t["T_CARRIES"]):
1241 log("You have nothing to use in your inventory.")
1243 val = integer_test(str_arg, 0, 255)
1244 if None != val and val < len(t["T_CARRIES"]):
1245 id = t["T_CARRIES"][val]
1246 type = world_db["Things"][id]["T_TYPE"]
1247 if not world_db["ThingTypes"][type]["TT_TOOL"] == "food":
1248 log("You can't consume this thing.")
1250 world_db["Things"][0]["T_ARGUMENT"] = val
1253 print("Illegal inventory index.")
1256 def play_move(str_arg):
1257 """Try "move" as player's T_COMMAND, str_arg as T_ARGUMENT / direction."""
1258 t = world_db["Things"][0]
1259 if not str_arg in directions_db:
1260 print("Illegal move direction string.")
1262 dir = ord(directions_db[str_arg])
1263 move_result = mv_yx_in_dir_legal(chr(dir), t["T_POSY"], t["T_POSX"])
1264 if 1 == move_result[0]:
1265 pos = (move_result[1] * world_db["MAP_LENGTH"]) + move_result[2]
1266 if ord(".") == world_db["MAP"][pos]:
1267 world_db["Things"][0]["T_ARGUMENT"] = dir
1270 log("You can't move there.")
1273 def command_seedrandomness(seed_string):
1274 """Set rand seed to int(seed_string)."""
1275 val = integer_test(seed_string, 0, 4294967295)
1280 def command_makeworld(seed_string):
1281 """(Re-)build game world, i.e. map, things, to a new turn 1 from seed.
1283 Seed rand with seed. Do more only with a "wait" ThingAction and
1284 world["PLAYER_TYPE"] matching ThingType of TT_START_NUMBER > 0. Then,
1285 world_db["Things"] emptied, call make_map() and set
1286 world_db["WORLD_ACTIVE"], world_db["TURN"] to 1. Build new Things
1287 according to ThingTypes' TT_START_NUMBERS, with Thing of ID 0 to ThingType
1288 of ID = world["PLAYER_TYPE"]. Place Things randomly, and actors not on each
1289 other. Init player's memory map. Write "NEW_WORLD" line to out file.
1296 err = "Space to put thing on too hard to find. Map too small?"
1298 y = rand.next() % world_db["MAP_LENGTH"]
1299 x = rand.next() % world_db["MAP_LENGTH"]
1300 if "." == chr(world_db["MAP"][y * world_db["MAP_LENGTH"] + x]):
1304 raise SystemExit(err)
1305 # Replica of C code, wrongly ignores animatedness of new Thing.
1306 pos_clear = (0 == len([id for id in world_db["Things"]
1307 if world_db["Things"][id]["T_LIFEPOINTS"]
1308 if world_db["Things"][id]["T_POSY"] == y
1309 if world_db["Things"][id]["T_POSX"] == x]))
1314 val = integer_test(seed_string, 0, 4294967295)
1318 player_will_be_generated = False
1319 playertype = world_db["PLAYER_TYPE"]
1320 for ThingType in world_db["ThingTypes"]:
1321 if playertype == ThingType:
1322 if 0 < world_db["ThingTypes"][ThingType]["TT_START_NUMBER"]:
1323 player_will_be_generated = True
1325 if not player_will_be_generated:
1326 print("Ignoring: No player type with start number >0 defined.")
1329 for ThingAction in world_db["ThingActions"]:
1330 if "wait" == world_db["ThingActions"][ThingAction]["TA_NAME"]:
1333 print("Ignoring beyond SEED_MAP: " +
1334 "No thing action with name 'wait' defined.")
1336 world_db["Things"] = {}
1338 world_db["WORLD_ACTIVE"] = 1
1339 world_db["TURN"] = 1
1340 for i in range(world_db["ThingTypes"][playertype]["TT_START_NUMBER"]):
1341 id = id_setter(-1, "Things")
1342 world_db["Things"][id] = new_Thing(playertype, free_pos())
1343 if not world_db["Things"][0]["fovmap"]:
1344 empty_fovmap = bytearray(b" " * world_db["MAP_LENGTH"] ** 2)
1345 world_db["Things"][0]["fovmap"] = empty_fovmap
1346 update_map_memory(world_db["Things"][0])
1347 for type in world_db["ThingTypes"]:
1348 for i in range(world_db["ThingTypes"][type]["TT_START_NUMBER"]):
1349 if type != playertype:
1350 id = id_setter(-1, "Things")
1351 world_db["Things"][id] = new_Thing(type, free_pos())
1352 strong_write(io_db["file_out"], "NEW_WORLD\n")
1356 def command_maplength(maplength_string):
1357 """Redefine map length. Invalidate map, therefore lose all things on it."""
1358 val = integer_test(maplength_string, 1, 256)
1360 world_db["MAP_LENGTH"] = val
1361 world_db["MAP"] = False
1362 set_world_inactive()
1363 world_db["Things"] = {}
1364 libpr.set_maplength(val)
1367 def command_worldactive(worldactive_string):
1368 """Toggle world_db["WORLD_ACTIVE"] if possible.
1370 An active world can always be set inactive. An inactive world can only be
1371 set active with a "wait" ThingAction, and a player Thing (of ID 0), and a
1372 map. On activation, rebuild all Things' FOVs, and the player's map memory.
1373 Also call log_help().
1375 val = integer_test(worldactive_string, 0, 1)
1377 if 0 != world_db["WORLD_ACTIVE"]:
1379 set_world_inactive()
1381 print("World already active.")
1382 elif 0 == world_db["WORLD_ACTIVE"]:
1384 for ThingAction in world_db["ThingActions"]:
1385 if "wait" == world_db["ThingActions"][ThingAction]["TA_NAME"]:
1388 player_exists = False
1389 for Thing in world_db["Things"]:
1391 player_exists = True
1393 if wait_exists and player_exists and world_db["MAP"]:
1394 for id in world_db["Things"]:
1395 if world_db["Things"][id]["T_LIFEPOINTS"]:
1396 build_fov_map(world_db["Things"][id])
1398 update_map_memory(world_db["Things"][id], False)
1399 if not world_db["Things"][0]["T_LIFEPOINTS"]:
1400 empty_fovmap = bytearray(b" " * world_db["MAP_LENGTH"] ** 2)
1401 world_db["Things"][0]["fovmap"] = empty_fovmap
1402 world_db["WORLD_ACTIVE"] = 1
1405 print("Ignoring: Not all conditions for world activation met.")
1408 def test_for_id_maker(object, category):
1409 """Return decorator testing for object having "id" attribute."""
1412 if hasattr(object, "id"):
1415 print("Ignoring: No " + category +
1416 " defined to manipulate yet.")
1421 def command_tid(id_string):
1422 """Set ID of Thing to manipulate. ID unused? Create new one.
1424 Default new Thing's type to the first available ThingType, others: zero.
1426 id = id_setter(id_string, "Things", command_tid)
1428 if world_db["ThingTypes"] == {}:
1429 print("Ignoring: No ThingType to settle new Thing in.")
1431 type = list(world_db["ThingTypes"].keys())[0]
1432 world_db["Things"][id] = new_Thing(type)
1435 test_Thing_id = test_for_id_maker(command_tid, "Thing")
1439 def command_tcommand(str_int):
1440 """Set T_COMMAND of selected Thing."""
1441 val = integer_test(str_int, 0)
1443 if 0 == val or val in world_db["ThingActions"]:
1444 world_db["Things"][command_tid.id]["T_COMMAND"] = val
1446 print("Ignoring: ThingAction ID belongs to no known ThingAction.")
1450 def command_ttype(str_int):
1451 """Set T_TYPE of selected Thing."""
1452 val = integer_test(str_int, 0)
1454 if val in world_db["ThingTypes"]:
1455 world_db["Things"][command_tid.id]["T_TYPE"] = val
1457 print("Ignoring: ThingType ID belongs to no known ThingType.")
1461 def command_tcarries(str_int):
1462 """Append int(str_int) to T_CARRIES of selected Thing.
1464 The ID int(str_int) must not be of the selected Thing, and must belong to a
1465 Thing with unset "carried" flag. Its "carried" flag will be set on owning.
1467 val = integer_test(str_int, 0)
1469 if val == command_tid.id:
1470 print("Ignoring: Thing cannot carry itself.")
1471 elif val in world_db["Things"] \
1472 and not world_db["Things"][val]["carried"]:
1473 world_db["Things"][command_tid.id]["T_CARRIES"].append(val)
1474 world_db["Things"][val]["carried"] = True
1476 print("Ignoring: Thing not available for carrying.")
1477 # Note that the whole carrying structure is different from the C version:
1478 # Carried-ness is marked by a "carried" flag, not by Things containing
1479 # Things internally.
1483 def command_tmemthing(str_t, str_y, str_x):
1484 """Add (int(str_t), int(str_y), int(str_x)) to selected Thing's T_MEMTHING.
1486 The type must fit to an existing ThingType, and the position into the map.
1488 type = integer_test(str_t, 0)
1489 posy = integer_test(str_y, 0, 255)
1490 posx = integer_test(str_x, 0, 255)
1491 if None != type and None != posy and None != posx:
1492 if type not in world_db["ThingTypes"] \
1493 or posy >= world_db["MAP_LENGTH"] or posx >= world_db["MAP_LENGTH"]:
1494 print("Ignoring: Illegal value for thing type or position.")
1496 memthing = (type, posy, posx)
1497 world_db["Things"][command_tid.id]["T_MEMTHING"].append(memthing)
1500 def setter_map(maptype):
1501 """Set (world or Thing's) map of maptype's int(str_int)-th line to mapline.
1503 If no map of maptype exists yet, initialize it with ' ' bytes first.
1506 def valid_map_line(str_int, mapline):
1507 val = integer_test(str_int, 0, 255)
1509 if val >= world_db["MAP_LENGTH"]:
1510 print("Illegal value for map line number.")
1511 elif len(mapline) != world_db["MAP_LENGTH"]:
1512 print("Map line length is unequal map width.")
1517 def nonThingMap_helper(str_int, mapline):
1518 val = valid_map_line(str_int, mapline)
1520 length = world_db["MAP_LENGTH"]
1521 if not world_db["MAP"]:
1522 map = bytearray(b' ' * (length ** 2))
1524 map = world_db["MAP"]
1525 map[val * length:(val * length) + length] = mapline.encode()
1526 if not world_db["MAP"]:
1527 world_db["MAP"] = map
1530 def ThingMap_helper(str_int, mapline):
1531 val = valid_map_line(str_int, mapline)
1533 length = world_db["MAP_LENGTH"]
1534 if not world_db["Things"][command_tid.id][maptype]:
1535 map = bytearray(b' ' * (length ** 2))
1537 map = world_db["Things"][command_tid.id][maptype]
1538 map[val * length:(val * length) + length] = mapline.encode()
1539 if not world_db["Things"][command_tid.id][maptype]:
1540 world_db["Things"][command_tid.id][maptype] = map
1542 return nonThingMap_helper if maptype == "MAP" else ThingMap_helper
1546 def setter_tpos(axis):
1547 """Generate setter for T_POSX or T_POSY of selected Thing.
1549 If world is active, rebuilds animate things' fovmap, player's memory map.
1552 def helper(str_int):
1553 val = integer_test(str_int, 0, 255)
1555 if val < world_db["MAP_LENGTH"]:
1556 world_db["Things"][command_tid.id]["T_POS" + axis] = val
1557 if world_db["WORLD_ACTIVE"] \
1558 and world_db["Things"][command_tid.id]["T_LIFEPOINTS"]:
1559 build_fov_map(world_db["Things"][command_tid.id])
1560 if 0 == command_tid.id:
1561 update_map_memory(world_db["Things"][command_tid.id])
1563 print("Ignoring: Position is outside of map.")
1567 def command_ttid(id_string):
1568 """Set ID of ThingType to manipulate. ID unused? Create new one.
1570 Default new ThingType's TT_SYMBOL to "?", TT_CORPSE_ID to self, TT_TOOL to
1573 id = id_setter(id_string, "ThingTypes", command_ttid)
1575 world_db["ThingTypes"][id] = {
1576 "TT_NAME": "(none)",
1579 "TT_PROLIFERATE": 0,
1580 "TT_START_NUMBER": 0,
1587 test_ThingType_id = test_for_id_maker(command_ttid, "ThingType")
1591 def command_ttname(name):
1592 """Set TT_NAME of selected ThingType."""
1593 world_db["ThingTypes"][command_ttid.id]["TT_NAME"] = name
1597 def command_tttool(name):
1598 """Set TT_TOOL of selected ThingType."""
1599 world_db["ThingTypes"][command_ttid.id]["TT_TOOL"] = name
1603 def command_ttsymbol(char):
1604 """Set TT_SYMBOL of selected ThingType. """
1606 world_db["ThingTypes"][command_ttid.id]["TT_SYMBOL"] = char
1608 print("Ignoring: Argument must be single character.")
1612 def command_ttcorpseid(str_int):
1613 """Set TT_CORPSE_ID of selected ThingType."""
1614 val = integer_test(str_int, 0)
1616 if val in world_db["ThingTypes"]:
1617 world_db["ThingTypes"][command_ttid.id]["TT_CORPSE_ID"] = val
1619 print("Ignoring: Corpse ID belongs to no known ThignType.")
1622 def command_taid(id_string):
1623 """Set ID of ThingAction to manipulate. ID unused? Create new one.
1625 Default new ThingAction's TA_EFFORT to 1, its TA_NAME to "wait".
1627 id = id_setter(id_string, "ThingActions", command_taid, True)
1629 world_db["ThingActions"][id] = {
1635 test_ThingAction_id = test_for_id_maker(command_taid, "ThingAction")
1638 @test_ThingAction_id
1639 def command_taname(name):
1640 """Set TA_NAME of selected ThingAction.
1642 The name must match a valid thing action function. If after the name
1643 setting no ThingAction with name "wait" remains, call set_world_inactive().
1645 if name == "wait" or name == "move" or name == "use" or name == "drop" \
1646 or name == "pick_up":
1647 world_db["ThingActions"][command_taid.id]["TA_NAME"] = name
1648 if 1 == world_db["WORLD_ACTIVE"]:
1649 wait_defined = False
1650 for id in world_db["ThingActions"]:
1651 if "wait" == world_db["ThingActions"][id]["TA_NAME"]:
1654 if not wait_defined:
1655 set_world_inactive()
1657 print("Ignoring: Invalid action name.")
1658 # In contrast to the original,naming won't map a function to a ThingAction.
1662 """Call ai() on player Thing, then turn_over()."""
1663 ai(world_db["Things"][0])
1667 """Commands database.
1669 Map command start tokens to ([0]) number of expected command arguments, ([1])
1670 the command's meta-ness (i.e. is it to be written to the record file, is it to
1671 be ignored in replay mode if read from server input file), and ([2]) a function
1675 "QUIT": (0, True, command_quit),
1676 "PING": (0, True, command_ping),
1677 "THINGS_HERE": (2, True, command_thingshere),
1678 "MAKE_WORLD": (1, False, command_makeworld),
1679 "SEED_RANDOMNESS": (1, False, command_seedrandomness),
1680 "TURN": (1, False, setter(None, "TURN", 0, 65535)),
1681 "PLAYER_TYPE": (1, False, setter(None, "PLAYER_TYPE", 0)),
1682 "MAP_LENGTH": (1, False, command_maplength),
1683 "WORLD_ACTIVE": (1, False, command_worldactive),
1684 "MAP": (2, False, setter_map("MAP")),
1685 "TA_ID": (1, False, command_taid),
1686 "TA_EFFORT": (1, False, setter("ThingAction", "TA_EFFORT", 0, 255)),
1687 "TA_NAME": (1, False, command_taname),
1688 "TT_ID": (1, False, command_ttid),
1689 "TT_NAME": (1, False, command_ttname),
1690 "TT_TOOL": (1, False, command_tttool),
1691 "TT_SYMBOL": (1, False, command_ttsymbol),
1692 "TT_CORPSE_ID": (1, False, command_ttcorpseid),
1693 "TT_TOOLPOWER": (1, False, setter("ThingType", "TT_TOOLPOWER", 0, 65535)),
1694 "TT_START_NUMBER": (1, False, setter("ThingType", "TT_START_NUMBER",
1696 "TT_PROLIFERATE": (1, False, setter("ThingType", "TT_PROLIFERATE",
1698 "TT_LIFEPOINTS": (1, False, setter("ThingType", "TT_LIFEPOINTS", 0, 255)),
1699 "T_ID": (1, False, command_tid),
1700 "T_ARGUMENT": (1, False, setter("Thing", "T_ARGUMENT", 0, 255)),
1701 "T_PROGRESS": (1, False, setter("Thing", "T_PROGRESS", 0, 255)),
1702 "T_LIFEPOINTS": (1, False, setter("Thing", "T_LIFEPOINTS", 0, 255)),
1703 "T_SATIATION": (1, False, setter("Thing", "T_SATIATION", -32768, 32767)),
1704 "T_COMMAND": (1, False, command_tcommand),
1705 "T_TYPE": (1, False, command_ttype),
1706 "T_CARRIES": (1, False, command_tcarries),
1707 "T_MEMMAP": (2, False, setter_map("T_MEMMAP")),
1708 "T_MEMDEPTHMAP": (2, False, setter_map("T_MEMDEPTHMAP")),
1709 "T_MEMTHING": (3, False, command_tmemthing),
1710 "T_POSY": (1, False, setter_tpos("Y")),
1711 "T_POSX": (1, False, setter_tpos("X")),
1712 "wait": (0, False, play_wait),
1713 "move": (1, False, play_move),
1714 "pick_up": (0, False, play_pickup),
1715 "drop": (1, False, play_drop),
1716 "use": (1, False, play_use),
1717 "ai": (0, False, command_ai)
1719 # TODO: Unhandled cases: (Un-)killing animates (esp. player!) with T_LIFEPOINTS.
1722 """World state database. With sane default values. (Randomness is in rand.)"""
1734 """Mapping of direction names to internal direction chars."""
1735 directions_db = {"east": "d", "south-east": "c", "south-west": "x",
1736 "west": "s", "north-west": "w", "north-east": "e"}
1738 """File IO database."""
1740 "path_save": "save",
1741 "path_record": "record_save",
1742 "path_worldconf": "confserver/world",
1743 "path_server": "server/",
1744 "path_in": "server/in",
1745 "path_out": "server/out",
1746 "path_worldstate": "server/worldstate",
1747 "tmp_suffix": "_tmp",
1748 "kicked_by_rival": False,
1749 "worldstate_updateable": False
1754 libpr = prep_library()
1755 rand = RandomnessIO()
1756 opts = parse_command_line_arguments()
1758 io_db["path_save"] = opts.savefile
1759 io_db["path_record"] = "record_" + opts.savefile
1762 io_db["verbose"] = True
1763 if None != opts.replay:
1767 except SystemExit as exit:
1768 print("ABORTING: " + exit.args[0])
1770 print("SOMETHING WENT WRONG IN UNEXPECTED WAYS")