diff --git a/rc_util.py b/rc_util.py index 9becf2f93878e982d3cb89ff2ccb355a8a28e8c3..fbb7c39ec8ee73fa6ef6ceb9d144bf170e4221e1 100644 --- a/rc_util.py +++ b/rc_util.py @@ -5,6 +5,7 @@ import signal import logging import argparse import pika +import pwd import uuid from rc_rmq import RCRMQ import json @@ -63,6 +64,7 @@ def add_account(username, queuename, email, full="", reason=""): ) rc_rmq.disconnect() + def certify_account(username, queuename, state="ok", service="all"): rc_rmq.publish_msg( { @@ -77,6 +79,7 @@ def certify_account(username, queuename, state="ok", service="all"): ) rc_rmq.disconnect() + def worker(ch, method, properties, body): msg = json.loads(body) username = msg["username"] @@ -260,3 +263,7 @@ def update_state(username, state, debug=False): ) return result + + +def get_caller_info(): + return f"{pwd.getpwuid(os.getuid()).pw_name}@{os.uname().nodename}"