aljaz/python-teos
1
0
Fork 0
mirror of https://github.com/aljazceru/python-teos.git synced 2025-12-18 14:44:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

Improves build from data persistance

Browse Source 
Fetches the missed block data to the watcher and responder queues so they can recover
This commit is contained in:
Sergi Delgado Segura
2019-10-30 12:24:02 -07:00
parent ccafc1999c
commit ddb3f26d88
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
pisa/pisad.py
View File

@@ -10,6 +10,7 @@ from pisa.builder import Builder
from pisa.conf import BTC_NETWORK from pisa.conf import BTC_NETWORK
from pisa.responder import Responder from pisa.responder import Responder
from pisa.db_manager import DBManager from pisa.db_manager import DBManager
from pisa.block_processor import BlockProcessor
from pisa.tools import can_connect_to_bitcoind, in_correct_network from pisa.tools import can_connect_to_bitcoind, in_correct_network
logger = Logger("Daemon") logger = Logger("Daemon")
@@ -55,11 +56,22 @@ if __name__ == '__main__':
else: else:
logger.info("Bootstrapping from backed up data") logger.info("Bootstrapping from backed up data")
block_processor = BlockProcessor()
last_block_watcher = db_manager.load_last_block_hash_watcher()
last_block_responder = db_manager.load_last_block_hash_responder()
missed_blocks_watcher = block_processor.get_missed_blocks(last_block_watcher)
missed_blocks_responder = missed_blocks_watcher if last_block_watcher == last_block_responder \
else block_processor.get_missed_blocks(last_block_watcher)
responder = Responder(db_manager) responder = Responder(db_manager)
responder.jobs, responder.tx_job_map = Builder.build_jobs(responder_jobs_data) responder.jobs, responder.tx_job_map = Builder.build_jobs(responder_jobs_data)
responder.block_queue = Builder.build_block_queue(last_block_responder)
watcher.responder = responder watcher.responder = responder
watcher.appointments, watcher.locator_uuid_map = Builder.build_appointments(watcher_appointments_data) watcher.appointments, watcher.locator_uuid_map = Builder.build_appointments(watcher_appointments_data)
watcher.block_queue = Builder.build_block_queue(last_block_responder)
# Create an instance of the Watcher and fire the API # Create an instance of the Watcher and fire the API
start_api(watcher) start_api(watcher)