async_current.py

#! /usr/bin/env python
# coding: utf-8
# Licensed under the MIT License.

from pymongo import MongoClient, DESCENDING, ASCENDING
from Block.RpcClient import RpcClient
from Storage.Mongo import Mongo
from bson.objectid import ObjectId
import time
import os
from multiprocessing import Pool, cpu_count
from binascii import unhexlify
from utils.tools import Tool
from binascii import unhexlify
# import argparse
from dotenv import load_dotenv, find_dotenv
import logzero
from logzero import logger
from apscheduler.schedulers.blocking import BlockingScheduler
from datetime import datetime

from handle import save_block
from utils.tools import get_random_node

logzero.logfile(os.getcwd() + "/log/main.log", maxBytes=1e10, backupCount=1)
load_dotenv(find_dotenv(), override=True)

m = Mongo(os.environ.get('MONGODB'), os.environ.get('DB'))
work_count = cpu_count()



def async_current():
    try:
        ## random node
        # node = get_best_node()
        # if node == '':
        #     return


        b = RpcClient()

        r = 0
        try:
            r = b.get_block_count()
        except Exception as e:
            b.url = get_random_node()
            r = b.get_block_count()
        
        m_block = m.connection()['block'].find_one({},{'index':1},sort = [('index',DESCENDING)]) or { 'index' : -1}
        print('r - 1 - m_block',r - 1 - m_block['index'])
        save_block(b, m_block['index'] + 1 , r - 2 - m_block['index'] )  

    except Exception as e:
        logger.exception(e)



def job():
    print(datetime.now().strftime("%Y-%m-%d %H:%M:%S"))

if __name__ == "__main__":
    try:
        # async_current()
        sched = BlockingScheduler()
        sched.add_job(async_current, 'interval', seconds=30)
        sched.start()
    except Exception as e:
        logger.exception(e)
        time.sleep(30)
        sched.start()