fix indexer
This commit is contained in:
parent
198971a391
commit
ec484af8c4
|
|
@ -101,13 +101,16 @@ async def indexer_loop(memory, platform_found: bool, seqno: int) -> [bool, int]:
|
||||||
|
|
||||||
session.commit()
|
session.commit()
|
||||||
|
|
||||||
last_known_index = session.query(StoredContent).filter(
|
last_known_index_ = session.query(StoredContent).filter(
|
||||||
StoredContent.onchain_index != None
|
StoredContent.onchain_index != None
|
||||||
).order_by(StoredContent.onchain_index.desc()).first()
|
).order_by(StoredContent.onchain_index.desc()).first()
|
||||||
last_known_index = last_known_index.onchain_index if last_known_index else 0
|
last_known_index = last_known_index_.onchain_index if last_known_index_ else 0
|
||||||
last_known_index = max(last_known_index, 0)
|
last_known_index = max(last_known_index, 0)
|
||||||
make_log("Indexer", f"Last known index: {last_known_index}", level="debug")
|
make_log("Indexer", f"Last known index: {last_known_index}", level="debug")
|
||||||
|
if last_known_index_:
|
||||||
next_item_index = last_known_index + 1
|
next_item_index = last_known_index + 1
|
||||||
|
else:
|
||||||
|
next_item_index = 0
|
||||||
|
|
||||||
resolve_item_result = await toncenter.run_get_method(platform.address.to_string(1, 1, 1), 'get_nft_address_by_index', [['num', next_item_index]])
|
resolve_item_result = await toncenter.run_get_method(platform.address.to_string(1, 1, 1), 'get_nft_address_by_index', [['num', next_item_index]])
|
||||||
make_log("Indexer", f"Resolve item result: {resolve_item_result}", level="debug")
|
make_log("Indexer", f"Resolve item result: {resolve_item_result}", level="debug")
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue