add new parameter to threads: last_author

3 files changed, 11 insertions, 6 deletions

diff --git a/src/db.py b/src/db.py
index 7fd0fd5..1050e6a 100644
--- a/src/db.py
+++ b/src/db.py
@@ -106,11 +106,12 @@ def thread_create(connection, author_id, body, title, send_raw=False):
     thread_id = uuid1().hex
     scheme = schema.thread(
         thread_id, author_id, title,
-        now, now, -1, False) # see below for why i set -1 instead of 0
+        now, now, -1, # see below for why i set -1 instead of 0
+        False, author_id)
 
     connection.execute("""
         INSERT INTO threads
-        VALUES (?,?,?,?,?,?,?)
+        VALUES (?,?,?,?,?,?,?,?)
     """, schema_values("thread", scheme))
     connection.commit()
     # the thread is initially commited with reply_count -1 so that i can
@@ -147,9 +148,10 @@ def thread_reply(connection, author_id, thread_id, body, send_raw=False, time_ov
     connection.execute("""
         UPDATE threads SET
         reply_count = ?,
+        last_author = ?,
         last_mod = ?
         WHERE thread_id = ?
-    """, (count, now, thread_id))
+    """, (count, author_id, now, thread_id))
 
     connection.commit()
     return scheme
diff --git a/src/schema.py b/src/schema.py
index 7044c37..aedb765 100644
--- a/src/schema.py
+++ b/src/schema.py
@@ -128,7 +128,8 @@ def thread(
         last_mod,     # floating point unix timestamp (of last post or post edit)
         created,      # floating point unix timestamp (when thread was made)
         reply_count,  # integer (incremental, starting with 0)
-        pinned):      # boolean
+        pinned,       # boolean
+        last_author): # uuid string
 
     return {
         "thread_id":   thread_id,
@@ -137,7 +138,8 @@ def thread(
         "last_mod":    last_mod,
         "created":     created,
         "reply_count": reply_count,
-        "pinned":      bool(pinned)
+        "pinned":      bool(pinned),
+        "last_author": last_author
     }
 
 
diff --git a/src/utils.py b/src/utils.py
index c533112..dbe4789 100644
--- a/src/utils.py
+++ b/src/utils.py
@@ -22,7 +22,8 @@ def schema_values(scheme, obj):
     elif scheme == "thread":
         return ordered_keys(obj,
             "thread_id", "author", "title",
-            "last_mod", "created", "reply_count", "pinned")
+            "last_mod", "created", "reply_count",
+            "pinned", "last_author")
 
     elif scheme == "message":
         return ordered_keys(obj,