add updater info

Author: CrysR

src/webapp/database.py

@@ -327,6 +327,7 @@ class BatchTable(Base):
     deleted_at = Column(DateTime(timezone=True), nullable=True)
     created_at = Column(DateTime(timezone=True), server_default=func.now())
     updated_at = Column(DateTime(timezone=True), onupdate=func.now())
+    updated_by = Column(Uuid(as_uuid=True), nullable=True)
     # Within a given institution, there should be no duplicated batch names.
     __table_args__ = (UniqueConstraint("name", "inst_id", name="batch_name_inst_uc"),)
 

src/webapp/routers/data.py

@@ -82,7 +82,10 @@ class BatchInfo(BaseModel):
     # Date in form YYMMDD. Deletion of a batch will apply to all files in a batch,
     # unless the file is present in other batches.
     deletion_request_time: str | None = None
-    created_date: datetime | None = None
+    created_at: datetime | None = None
+    updated_at: datetime | None = None
+    # The following is the user who last updated this batch.
+    updated_by: str | None = None
 
 
 class DataInfo(BaseModel):
@@ -212,7 +215,9 @@ def get_all_batches(
                 "deleted": False if elem.deleted is None else elem.deleted,
                 "completed": False if elem.completed is None else elem.completed,
                 "deletion_request_time": elem.deleted_at,
-                "created_date": elem.created_at,
+                "created_at": elem.created_at,
+                "updated_by": uuid_to_str(query_result[0][0].updated_by),
+                "updated_at": query_result[0][0].updated_at,
             }
         )
     return result_batches
@@ -296,6 +301,7 @@ def read_inst_all_output_files(
     }
 
 
+# TODO: rename this function to better reflect its behavior.
 @router.post("/{inst_id}/update-data")
 def update_data(
     inst_id: str,
@@ -420,7 +426,9 @@ def read_batch_info(
         "deleted": False if res.deleted is None else res.deleted,
         "completed": False if res.completed is None else res.completed,
         "deletion_request_time": res.deleted_at,
-        "created_date": res.created_at,
+        "created_at": res.created_at,
+        "updated_at": res.updated_at,
+        "updated_by": uuid_to_str(res.updated_by),
     }
     data_infos = []
     for elem in res.files:
@@ -548,7 +556,9 @@ def create_batch(
         "deleted": False,
         "completed": False,
         "deletion_request_time": None,
-        "created_date": query_result[0][0].created_at,
+        "created_at": query_result[0][0].created_at,
+        "updated_by": uuid_to_str(query_result[0][0].updated_by),
+        "updated_at": query_result[0][0].updated_at,
     }
 
 
@@ -676,6 +686,7 @@ def update_batch(
         existing_batch.deleted_at = func.now()
     if "completed" in update_data:
         existing_batch.completed = update_data["completed"]
+    existing_batch.updated_by = str_to_uuid(current_user.user_id)
     local_session.get().commit()
     res = (
         local_session.get()
@@ -698,7 +709,9 @@ def update_batch(
         "deleted": res[0][0].deleted,
         "completed": res[0][0].completed,
         "deletion_request_time": res[0][0].deleted_at,
-        "created_date": res[0][0].created_at,
+        "created_at": res[0][0].created_at,
+        "updated_by": uuid_to_str(query_result[0][0].updated_by),
+        "updated_at": query_result[0][0].updated_at,
     }
 
 

src/webapp/routers/data_test.py

@@ -83,7 +83,7 @@ def same_orderless(a: DataOverview, b: DataOverview):
                 or a_elem["deleted"] != b_elem["deleted"]
                 or a_elem["completed"] != b_elem["completed"]
                 or a_elem["deletion_request_time"] != b_elem["deletion_request_time"]
-                or a_elem["created_date"] != b_elem["created_date"]
+                or a_elem["created_at"] != b_elem["created_at"]
             ):
                 return False
         if not found:
@@ -236,7 +236,7 @@ def test_read_inst_all_input_files(client: TestClient):
                     "deleted": False,
                     "completed": False,
                     "deletion_request_time": None,
-                    "created_date": "2024-12-24T20:22:20.132022",
+                    "created_at": "2024-12-24T20:22:20.132022",
                 }
             ],
             "files": [
@@ -304,7 +304,7 @@ def test_read_inst_all_output_files(client: TestClient):
                     "deleted": False,
                     "completed": False,
                     "deletion_request_time": None,
-                    "created_date": "2024-12-24T20:22:20.132022",
+                    "created_at": "2024-12-24T20:22:20.132022",
                 }
             ],
             "files": [
@@ -379,7 +379,7 @@ def test_read_batch_info(client: TestClient):
                     "deleted": False,
                     "completed": False,
                     "deletion_request_time": None,
-                    "created_date": "2024-12-24T20:22:20.132022",
+                    "created_at": "2024-12-24T20:22:20.132022",
                 }
             ],
             "files": [