Update add_account with updated_by field

create_account.py

@@ -25,6 +25,7 @@ args = parser.parse_args()
 timeout = 60
 
 queuename = rc_util.encode_name(args.username)
+updated_by = rc_util.get_caller_info()
 
 if args.email == "":
     args.email = args.username
@@ -58,6 +59,7 @@ rc_util.add_account(
     email=args.email,
     full=args.full_name,
     reason=args.reason,
+    updated_by=updated_by,
 )
 print(f"Account for {args.username} requested.")
 

prod_rmq_agents/task_manager.py

@@ -277,7 +277,7 @@ def task_manager(ch, method, properties, body):
 
         update_db(username, {"reported": True})
 
-        rc_util.update_state(username, "ok")
+        rc_util.update_state(username, "ok", msg.get("updated_by"))
 
         tracking.pop(username)
 

rc_util.py

@@ -49,7 +49,9 @@ def timeout(seconds=30, error_message=os.strerror(errno.ETIME)):
     return decorator
 
 
-def add_account(username, queuename, email, full="", reason=""):
+def add_account(
+    username, queuename, email, full="", reason="", updated_by=None
+):
     rc_rmq.publish_msg(
         {
             "routing_key": "request." + queuename,
@@ -59,6 +61,7 @@ def add_account(username, queuename, email, full="", reason=""):
                 "fullname": full,
                 "reason": reason,
                 "queuename": queuename,
+                "updated_by": updated_by,
             },
         }
     )