From 3514588ac2e9b97cf2800d04c11432ab3a45c80c Mon Sep 17 00:00:00 2001 From: user Date: Wed, 5 Mar 2025 04:20:12 +0300 Subject: [PATCH] fix indexer --- app/core/background/indexer_service.py | 53 +++++++++++++------------- 1 file changed, 27 insertions(+), 26 deletions(-) diff --git a/app/core/background/indexer_service.py b/app/core/background/indexer_service.py index 36e3724..e8de258 100644 --- a/app/core/background/indexer_service.py +++ b/app/core/background/indexer_service.py @@ -217,33 +217,34 @@ async def indexer_loop(memory, platform_found: bool, seqno: int) -> [bool, int]: encrypted_stored_content.user_id = user_wallet_connection.user_id user = user_wallet_connection.user - user_uploader_wrapper = Wrapped_CBotChat(memory._telegram_bot, chat_id=user.telegram_id, user=user, db_session=session) - await user_uploader_wrapper.send_message( - user.translated('p_contentWasIndexed').format( - item_address=item_address.to_string(1, 1, 1), - item_index=item_index, - ), - message_type='notification', - reply_markup=get_inline_keyboard([ - [{ - 'text': user.translated('viewTrackAsClient_button'), - 'url': f"https://t.me/{CLIENT_TELEGRAM_BOT_USERNAME}?start=C{encrypted_stored_content.cid.serialize_v2()}" - }], - ]) - ) + if user: + user_uploader_wrapper = Wrapped_CBotChat(memory._telegram_bot, chat_id=user.telegram_id, user=user, db_session=session) + await user_uploader_wrapper.send_message( + user.translated('p_contentWasIndexed').format( + item_address=item_address.to_string(1, 1, 1), + item_index=item_index, + ), + message_type='notification', + reply_markup=get_inline_keyboard([ + [{ + 'text': user.translated('viewTrackAsClient_button'), + 'url': f"https://t.me/{CLIENT_TELEGRAM_BOT_USERNAME}?start=C{encrypted_stored_content.cid.serialize_v2()}" + }], + ]) + ) - try: - for hint_message in session.query(KnownTelegramMessage).filter( - and_( - KnownTelegramMessage.chat_id == user.telegram_id, - KnownTelegramMessage.type == 'hint', - cast(KnownTelegramMessage.meta['encrypted_content_hash'], String) == encrypted_stored_content.hash, - KnownTelegramMessage.deleted == False - ) - ).all(): - await user_uploader_wrapper.delete_message(hint_message.message_id) - except BaseException as e: - make_log("Indexer", f"Error while deleting hint messages: {e}" + '\n' + traceback.format_exc(), level="error") + try: + for hint_message in session.query(KnownTelegramMessage).filter( + and_( + KnownTelegramMessage.chat_id == user.telegram_id, + KnownTelegramMessage.type == 'hint', + cast(KnownTelegramMessage.meta['encrypted_content_hash'], String) == encrypted_stored_content.hash, + KnownTelegramMessage.deleted == False + ) + ).all(): + await user_uploader_wrapper.delete_message(hint_message.message_id) + except BaseException as e: + make_log("Indexer", f"Error while deleting hint messages: {e}" + '\n' + traceback.format_exc(), level="error") elif encrypted_stored_content.type.startswith('onchain') and encrypted_stored_content.onchain_index == item_index: encrypted_stored_content.type = "onchain/content" + ("_unknown" if (encrypted_stored_content.key_id is None) else "") encrypted_stored_content.owner_address = item_owner_address.to_string(1, 1, 1)