# HG changeset patch
# User John "Elwin" Edwards <elwin@sdf.org>
# Date 1347853462 25200
# Node ID 7f7b3da664d6474edfc7ca864d9a2d4414961734
# Parent  5297ccba4e70724b6ecba68b51aee71b444bdb41
Begin adding arogue5 support to the recorder script.

rlgalldb.py's arogue5 object is a nonfunctional stub, but at least it
doesn't crash and the other games still work.

diff -r 5297ccba4e70 -r 7f7b3da664d6 py/rlgalldb.py
--- a/py/rlgalldb.py	Sat Sep 15 17:23:13 2012 +0000
+++ b/py/rlgalldb.py	Sun Sep 16 20:44:22 2012 -0700
@@ -143,34 +143,9 @@
   of.write(tblend)
   return
 
-def readentries(entfile, entlist):
-  "Reads a list of entries from a file object"
-  while True:
-    nextentry = entfile.readline()
-    if not nextentry:
-      break
-    if nextentry[-1] != '\n': # The line is incomplete
-      break
-    entlist.append(nextentry.split(None, 4))
-  return
-
 class Game:
-  pass
-
-class RogueGame(Game):
-  def __init__(self, name, uname, suffix):
-    self.name = name
-    self.uname = uname
-    self.scores = logdir + uname + ".log"
-    self.logspec = ["endt", "score", "name", "xl", "fate"]
-    self.sqltypes = {"endt": "timestamptz", "score": "int", 
-            "name": "varchar(20)", "xl": "int", "fate": "text",
-            "ttyrecs": "text ARRAY", "startt": "timestamptz"}
-    self.logdelim = " "
-  # Class variables, used by some methods
-  fields = ["name", "score", "xl", "fate", "endt"]
-  rankfields = ["rank", "score", "name", "xl", "fate", "endt"]
-  pfields = ["score", "xl", "fate", "endt"]
+  def __init__(self, name, uname):
+    pass
   def logtoDict(self, entry):
     "Processes a log entry string, returning a dict."
     ndict = {"game": self}
@@ -178,6 +153,8 @@
     for item, value in zip(self.logspec, entrylist):
       if self.sqltypes[item] == "int":
         ndict[item] = int(value)
+      if self.sqltypes[item] == "bool":
+        ndict[item] = bool(int(value))
       elif self.sqltypes[item] == "timestamptz":
         ndict[item] = datetime.fromtimestamp(int(value), utc)
       else:
@@ -194,6 +171,49 @@
         break
       entlist.append(self.logtoDict(nextentry))
     return
+  # TODO how does this work with postprocess?
+  def loadnew(self):
+    conn = getconn()
+    if conn == None:
+      return []
+    cur = conn.cursor()
+    # Get the previous offset
+    cur.execute(offselstr, [self.uname])
+    offset = cur.fetchone()[0]
+    newlist = []
+    try:
+      scr = open(self.scores)
+      scr.seek(offset)
+      self.getEntryDicts(scr, newlist)
+    except IOError:
+      noffset = offset # Can't read anything, assume no new games
+    else:
+      noffset = scr.tell()
+      scr.close()
+      cur.execute(newoffstr, [noffset, self.uname])
+    # The new players must already be added to the players table.
+    updatenames = set([ e["name"] for e in newlist ])
+    self.postprocess(newlist)
+    self.putIntoDB(newlist, conn)
+    cur.close()
+    conn.close()
+    return updatenames
+# End Game class definition
+
+class RogueGame(Game):
+  def __init__(self, name, uname, suffix):
+    self.name = name
+    self.uname = uname
+    self.scores = logdir + uname + ".log"
+    self.logspec = ["endt", "score", "name", "xl", "fate"]
+    self.sqltypes = {"endt": "timestamptz", "score": "int", 
+            "name": "varchar(20)", "xl": "int", "fate": "text",
+            "ttyrecs": "text ARRAY", "startt": "timestamptz"}
+    self.logdelim = " "
+  # Class variables, used by some methods
+  fields = ["name", "score", "xl", "fate", "endt"]
+  rankfields = ["rank", "score", "name", "xl", "fate", "endt"]
+  pfields = ["score", "xl", "fate", "endt"]
   def getRecent(self, n=20):
     "Gets the n most recent games out of the database, returning a list \
      of dicts."
@@ -325,40 +345,45 @@
         itsEntries[i]["ttyrecs"] = recs
     cur.close()
     conn.close()
-  def loadnew(self):
-    conn = getconn()
-    if conn == None:
-      return []
-    cur = conn.cursor()
-    # Get the previous offset
-    cur.execute(offselstr, [self.uname])
-    offset = cur.fetchone()[0]
-    newlist = []
-    try:
-      scr = open(self.scores)
-      scr.seek(offset)
-      self.getEntryDicts(scr, newlist)
-    except IOError:
-      noffset = offset # Can't read anything, assume no new games
-    else:
-      noffset = scr.tell()
-      scr.close()
-      cur.execute(newoffstr, [noffset, self.uname])
-    # The new players must already be added to the players table.
-    updatenames = set([ e["name"] for e in newlist ])
-    self.postprocess(newlist)
-    self.putIntoDB(newlist, conn)
-    cur.close()
-    conn.close()
-    return updatenames
 # End RogueGame class definition
 
+class ARogueGame(Game):
+  def __init__(self, name, uname, suffix):
+    self.name = name
+    self.uname = uname
+    self.scores = logdir + uname + ".log"
+    self.logspec = ["endt", "score", "name", "xl", "class", "depth", 
+                    "maxdepth", "quest", "hadquest", "fate"]
+    self.sqltypes = {"endt": "timestamptz", "score": "int", 
+            "name": "varchar(20)", "xl": "int", "class": "text", "depth": "int",
+            "maxdepth": "int", "quest": "int", "hadquest": "bool",
+            "fate": "text", "ttyrecs": "text ARRAY", "startt": "timestamptz"}
+    self.logdelim = " "
+  # Class variables
+  fields = ["name", "score", "class", "xl", "fate", "endt"]
+  rankfields = ["rank", "score", "name", "class", "xl", "fate", "endt"]
+  pfields = ["score", "class", "xl", "fate", "endt"]
+  def postprocess(self, gamelist):
+    "Not Implemented"
+    return
+  def putIntoDB(self, dictlist, conn):
+    "Not Implemented"
+    conn.commit()
+    return
+  def getHigh(self, n=10, offset=0):
+    return []
+  def getRecent(self, n=20):
+    return []
+  def getPlayer(self, player):
+    return []
+
 rogue3 = RogueGame("Rogue V3", "rogue3", "r3")
 rogue4 = RogueGame("Rogue V4", "rogue4", "r4")
 rogue5 = RogueGame("Rogue V5", "rogue5", "r5")
 srogue = RogueGame("Super-Rogue", "srogue", "sr")
+arogue5 = ARogueGame("Advanced Rogue 5", "arogue5", "ar5")
 
-gamelist = [rogue3, rogue4, rogue5, srogue]
+gamelist = [rogue3, rogue4, rogue5, srogue, arogue5]
 
 def playerpage(pname):
   "Generate a player's HTML page"