mirror of
git://holbrook.no/eth-monitor.git
synced 2024-11-16 10:16:48 +01:00
40 lines
902 B
Python
40 lines
902 B
Python
# 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)))
|