eth-monitor/eth_monitor/callback.py

# standard imports
import logging

logg = logging.getLogger(__name__)


class BlockCallbackFilter:

    def __init__(self):
        self.filters = []


    def register(self, fltr):
        self.filters.append(fltr)


    def filter(self, conn, block):
        for fltr in self.filters:
            fltr.filter(conn, block)


def state_change_callback(k, old_state, new_state):
    logg.log(logging.STATETRACE, 'state change: {} {} -> {}'.format(k, old_state, new_state)) 


def filter_change_callback(k, old_state, new_state):
    logg.log(logging.STATETRACE, 'filter change: {} {} -> {}'.format(k, old_state, new_state)) 


def pre_callback(conn):
    logg.debug('starting sync loop iteration')


def post_callback(conn):
    logg.debug('ending sync loop iteration')


def block_callback(conn, block):
    logg.info('processing {} {}'.format(block, datetime.datetime.fromtimestamp(block.timestamp)))