search

aaroncox / chainsync

a framework for streaming blockchain transactions/operations into other mediums
MIT License
15 stars 10 forks source link

chainsync.stream(['ops']) doesn't seem to work. #3

Open s-n-d-p opened 6 years ago

s-n-d-p commented 6 years ago

The following example in README doesn't produce any output:-

`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']))`

aaroncox commented 6 years ago

Sorry I missed this - you posted while I was out of commission (with a nasty cold) and didn't see it until just now.

This isn't working for me either - and I'm not entirely sure why. Enabling the debugging code on it, it looks like https://api.steemit.com is returning an empty result set for every block... it wouldn't surprise me if maybe they disabled this call on their API nodes due to it's performance.

See the output below, and note the empty result: []:

[2018-05-17 22:49:19.525459] http request - 0.092 kb / 0.203 sec - [{'jsonrpc': '2.0', 'method': 'condenser_api.get_ops_in_block', 'params': [22526479, False], 'id': 7}] []
[{'jsonrpc': '2.0', 'result': [], 'id': 7}]

I'll ask around as to what happened.