def on_after_open(item, query, params, connection, dataset):
if item.session:
user_id = item.session['user_info']['user_id']
users = item.task.users.copy(handlers=False)
users.set_where(id = user_id)
users.open()
for d in dataset:
if hasattr(d, "personal_message"):
if users.password_encryption.value and users.salt_encryption.value:
# pprint(d.personal_message.text)
salt = base64.b64decode(users.salt_encryption.value)
if d.personal_message.text:
d.personal_message.text = item.task.users.decrypt_text(
d.personal_message.text,
users.password_encryption.value,
salt
)
# pprint(d.personal_message.text)