From: Christian Heller <c.heller@plomlompom.de>
Date: Mon, 23 Feb 2015 01:59:41 +0000 (+0100)
Subject: Server/py: Improve IO looping structure.
X-Git-Tag: tce~488
X-Git-Url: https://plomlompom.com/repos/%7B%7B%20web_path%20%7D%7D/decks/%7B%7Bdb.prefix%7D%7D/add_task?a=commitdiff_plain;h=01882d0a209c70d97ef1c290095de88b317b1dd5;p=plomrogue

Server/py: Improve IO looping structure.
---

diff --git a/plomrogue-server.py b/plomrogue-server.py
index c7d5dde..68404d6 100755
--- a/plomrogue-server.py
+++ b/plomrogue-server.py
@@ -51,6 +51,8 @@ def cleanup_server_io(io_db):
     helper("file_out", "path_out")
     helper("file_in", "path_in")
     helper("file_worldstate", "path_worldstate")
+    if "file_record" in io_db:
+        io_db["file_record"].close()
 
 
 def detect_atomic_leftover(path, tmp_suffix):
@@ -63,7 +65,7 @@ def detect_atomic_leftover(path, tmp_suffix):
         raise SystemExit(msg)
 
 
-def obey(cmd, io_db, prefix, replay_file=None, do_record=False):
+def obey(cmd, io_db, prefix, replay=False, do_record=False):
     """"""
     server_test(io_db)
     print("input " + prefix + ": " + cmd)
@@ -82,13 +84,13 @@ def obey(cmd, io_db, prefix, replay_file=None, do_record=False):
             record("# " + cmd, io_db)
         raise SystemExit("received QUIT command")
     elif "MAKE_WORLD" == tokens[0] and 2 == len(tokens):
-        if replay_file:
+        if replay:
             print("Due to replay mode, reading command as 'go on in record'.")
-            line = replay_file.readline()
+            line = io_db["file_record"].readline()
             if len(line) > 0:
-                obey(line.rstrip(), io_db,
-                     replay_file.prefix + str(file.line_n))
-                file.line_n = file.line_n + 1
+                obey(line.rstrip(), io_db, io_db["file_record"].prefix
+                     + str(io_db["file_record"].line_n))
+                io_db["file_record"].line_n = io_db["file_record"].line_n + 1
             else:
                 print("Reached end of record file.")
         else:
@@ -194,19 +196,18 @@ try:
         if not os.access(io_db["path_record"], os.F_OK):
             raise SystemExit("No record file found to replay.")
         world_db["turn"] = 0
-        file = open(io_db["path_record"], "r")
-        file.prefix = "recod file line "
-        file.line_n = 1
+        io_db["file_record"] = open(io_db["path_record"], "r")
+        io_db["file_record"].prefix = "recod file line "
+        io_db["file_record"].line_n = 1
         while world_db["turn"] < opts.replay:
-            obey(file.readline().rstrip(), io_db,
-                 file.prefix + str(file.line_n))
-            file.line_n = file.line_n + 1
-        try:
-            while 1:
-                obey(read_command(io_db), io_db, "in file", replay_file=file)
-        except SystemExit:
-            file.close()
-            raise
+            line = io_db["file_record"].readline()
+            if "" == line:
+                break
+            obey(line.rstrip(), io_db, io_db["file_record"].prefix
+                 + str(io_db["file_record"].line_n))
+            io_db["file_record"].line_n = io_db["file_record"].line_n + 1
+        while True:
+            obey(read_command(io_db), io_db, "in file", replay=True)
     else:
         if os.access(io_db["path_save"], os.F_OK):
             obey_lines_in_file(io_db["path_save"], "save")
@@ -218,7 +219,7 @@ try:
                                do_record=True)
             obey("MAKE_WORLD " + str(int(time.time())), io_db, "in file",
                  do_record=True)
-        while 1:
+        while True:
             obey(read_command(io_db), io_db, "in file", do_record=True)
 except SystemExit as exit:
     print("ABORTING: " + exit.args[0])