debug

Consumer.py

@@ -7,7 +7,7 @@ import json
 from agent.agent_graph.StateTasks import ProblemState
 import argparse
 import redis
-
+from app import decrypt_token_from_json , get_key
 argparse_model = argparse.ArgumentParser()
 argparse_model.add_argument("--id", type=int, default=0, help="Consumer ID")
 
@@ -75,7 +75,8 @@ def callback(ch, method, properties, body):
     print(f"MSG AT CONSUMER {consumer_id}" )
 
     # simulate processing
-    print(f"TYPE {type(recieved_msg)}, CONTENT {recieved_msg}")
+    token = decrypt_token_from_json(recieved_msg['ht_token_encrypted_dumped'], get_key())
+    print(f"TYPE {type(recieved_msg)}, CONTENT {recieved_msg} , TOKEN {token}")
     #model_call(recieved_msg)
 
     # (put your logic here)