-
Notifications
You must be signed in to change notification settings - Fork 1
/
litecoin.py
50 lines (34 loc) · 1.24 KB
/
litecoin.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
import json
import requests
import logging
from kafka import store_in_big_data
from settings import LTC_BLOCK_TOPIC, LTC_HOST, LTC_PORT
logger = logging.getLogger("default")
# not defined in ltc
def get_block_hash(height):
response = requests.get("http://{}:{}/rest/blockhashbyheight/{}.json".format(LTC_HOST, LTC_PORT, height))
if response.status_code != 200:
return
return json.loads(response.text)['blockhash']
def get_block(block_hash):
response = requests.get("http://{}:{}/rest/block/{}.json".format(LTC_HOST, LTC_PORT, block_hash))
if response.status_code != 200:
return
return json.loads(response.text)
def ltc():
last_height = 0
try:
with open('checkpoints/ltc', 'r') as file:
last_height = int(file.read().strip())
except:
pass
while True:
block_hash = get_block_hash(last_height)
if block_hash:
logger.info('storing block {}.'.format(block_hash))
if store_in_big_data(LTC_BLOCK_TOPIC, get_block(block_hash)):
last_height += 1
with open('checkpoints/ltc', 'w') as file:
file.write(str(last_height))
if __name__ == "__main__":
ltc()