my-dev
/
uploader-bot
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

dev@locazia: fix indexer

This commit is contained in:
user 2024-03-12 00:26:04 +03:00
parent 480f54dbde
commit 9055b03114
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
app/core/background/indexer_service.py
View File

@ -11,6 +11,7 @@ from app.core._blockchain.ton.toncenter import toncenter
from app.core._utils.send_status import send_status from app.core._utils.send_status import send_status
from app.core.logger import make_log from app.core.logger import make_log
from app.core.models.node_storage import StoredContent from app.core.models.node_storage import StoredContent
from app.core._utils.resolve_content import resolve_content
from app.core.models.wallet_connection import WalletConnection from app.core.models.wallet_connection import WalletConnection
from app.core._keyboards import get_inline_keyboard from app.core._keyboards import get_inline_keyboard
from app.core.models._telegram import Wrapped_CBotChat from app.core.models._telegram import Wrapped_CBotChat
@ -89,7 +90,7 @@ async def indexer_loop(memory, platform_found: bool, seqno: int) -> [bool, int]:
item_values_slice = item_values.begin_parse() item_values_slice = item_values.begin_parse()
item_content_hash_int = item_values_slice.read_uint(256) item_content_hash_int = item_values_slice.read_uint(256)
item_content_hash = item_content_hash_int.to_bytes(32, 'big') item_content_hash = item_content_hash_int.to_bytes(32, 'big')
item_content_hash_str = b58encode(item_content_hash).decode() # item_content_hash_str = b58encode(item_content_hash).decode()
item_metadata = item_values_slice.refs[0] item_metadata = item_values_slice.refs[0]
item_content = item_values_slice.refs[1] item_content = item_values_slice.refs[1]
item_metadata_str = item_metadata.bits.array.decode() item_metadata_str = item_metadata.bits.array.decode()
@ -97,6 +98,10 @@ async def indexer_loop(memory, platform_found: bool, seqno: int) -> [bool, int]:
item_content_cover_cid_str = item_content.refs[1].bits.array.decode() item_content_cover_cid_str = item_content.refs[1].bits.array.decode()
item_content_metadata_cid_str = item_content.refs[2].bits.array.decode() item_content_metadata_cid_str = item_content.refs[2].bits.array.decode()
item_content_cid, err = resolve_content(item_content_cid_str)
item_content_hash = item_content_cid.content_hash
item_content_hash_str = item_content_cid.content_hash_b58
item_metadata_packed = { item_metadata_packed = {
'license_type': item_license_type, 'license_type': item_license_type,
'item_address': item_address.to_string(1, 1, 1), 'item_address': item_address.to_string(1, 1, 1),