34 lines
887 B
Python
34 lines
887 B
Python
|
# standard imports
|
|||
|
|
import logging
|
|||
|
|
|
|||
|
|
# local ipmorts
|
|||
|
|
from chaind.adapters.fs import ChaindFsAdapter
|
|||
|
|
from chaind.eth.cache import EthCacheTx
|
|||
|
|
|
|||
|
|
logg = logging.getLogger(__name__)
|
|||
|
|
|
|||
|
|
|
|||
|
|
class DispatchProcessor:
|
|||
|
|
|
|||
|
|
def __init__(self, chain_spec, queue_dir, dispatcher):
|
|||
|
|
self.dispatcher = dispatcher
|
|||
|
|
self.chain_spec = chain_spec,
|
|||
|
|
self.queue_dir = queue_dir
|
|||
|
|
|
|||
|
|
|
|||
|
|
def process(self, rpc, limit=50):
|
|||
|
|
adapter = ChaindFsAdapter(
|
|||
|
|
self.chain_spec,
|
|||
|
|
self.queue_dir,
|
|||
|
|
EthCacheTx,
|
|||
|
|
self.dispatcher,
|
|||
|
|
)
|
|||
|
|
|
|||
|
|
upcoming = adapter.upcoming(limit=limit)
|
|||
|
|
logg.info('processor has {} candidates for {}, processing with limit {}'.format(len(upcoming), self.chain_spec, limit))
|
|||
|
|
i = 0
|
|||
|
|
for tx_hash in upcoming:
|
|||
|
|
if adapter.dispatch(tx_hash):
|
|||
|
|
i += 1
|
|||
|
|
return i
|