ChainSync
A simple library to stream blocks and operations for digesting into other mediums.
Install
pip install chainsync
Requirements
pip install -r requirements.txt
Example - streaming blocks
from chainsync import ChainSync
from chainsync.adapters.steemv2 import SteemV2Adapter
adapter = SteemV2Adapter(endpoints=['https://api.steemit.com'])
chainsync = ChainSync(adapter)
for dataType, data in chainsync.stream(['blocks']):
print("{} - {}".format(data['block_num'], data['witness']))
Example - streaming operations
from chainsync import ChainSync
from chainsync.adapters.steemv2 import SteemV2Adapter
adapter = SteemV2Adapter(endpoints=['https://api.steemit.com'])
chainsync = ChainSync(adapter)
for dataType, data in chainsync.stream(['ops']):
print("{} - {}".format(data['block_num'], data['operation_type']))
Example - streaming operations with a whitelist
from chainsync import ChainSync
from chainsync.adapters.steemv2 import SteemV2Adapter
adapter = SteemV2Adapter(endpoints=['https://api.steemit.com'])
chainsync = ChainSync(adapter)
for dataType, op in chainsync.stream(['ops'], whitelist=['vote']):
print("{} - {} by {}".format(op['block_num'], op['operation_type'], op['voter']))
Example - custom adapters
A custom adapter can be supplied to allow parsing of a specific blockchain
from chainsync import ChainSync
from chainsync.adapters.decent import DecentAdapter
adapter = DecentAdapter(endpoints=['http://api.decent-db.com:8090'])
chainsync = ChainSync(adapter)
for block in chainsync.stream(['blocks']):
print("{} - {}".format(block['block_num'], block['witness']))
Adapters
Adapters can be added and configured to allow access to other similar blockchains.
A current list of adapters can be found in the ./chainsync/adapters
folder.