NanoWalletBot/faucet.py at master · SergiySW/NanoWalletBot · GitHub

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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
#!/usr/bin/env python
# -*- coding: utf-8 -*-
#
# Nano Telegram bot
# @NanoWalletBot https://t.me/NanoWalletBot
#
# Source code:
# https://github.com/SergiySW/NanoWalletBot
#
# Released under the BSD 3-Clause License
#
#
# Legacy
# Run by cron every minute
#


from telegram.ext import Updater, CommandHandler, MessageHandler, Filters
from telegram import Bot, ParseMode
import logging
import urllib3, certifi, socket, json
import time, math

# Parse config
import ConfigParser
config = configparser.ConfigParser()
config.read('bot.cfg')
log_file_faucet = config.get('main', 'log_file_faucet')

# Enable logging
logging.basicConfig(format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
					level=logging.INFO, filename=log_file_faucet)

logger = logging.getLogger(__name__)

header = {'user-agent': 'RaiWalletBot/1.0'}


# MySQL requests
from common_mysql import mysql_select_accounts_list, mysql_select_blacklist, mysql_select_language, mysql_select_accounts_list_extra, mysql_set_faucet


# Common functions
from common import push_simple, bot_start


# Translation
with open('language.json') as lang_file:
	language = json.load(lang_file)
def lang(user_id, text_id):
	lang_id = mysql_select_language(user_id)
	try:
		return language[lang_id][text_id]
	except KeyError:
		return language['en'][text_id]

# Faucet
def faucet():
	http = urllib3.PoolManager(cert_reqs='CERT_REQUIRED',ca_certs=certifi.where())
	url = 'https://faucet.raiblockscommunity.net/userpay.php?json=1'
	response = http.request('GET', url, headers=header, timeout=120.0)
	json_paylist = json.loads(response.data)
	#save it
	with open('paylist.json', 'w') as outfile:
		json.dump(json_paylist, outfile)
	json_array = json_paylist['pending']

	bot = bot_start()
	# list from MySQL
	accounts_list_orig = mysql_select_accounts_list()
	accounts_list_extra = mysql_select_accounts_list_extra()
	accounts_list = accounts_list_orig + accounts_list_extra
	# blacklist
	BLACK_LIST = mysql_select_blacklist()
	for account in accounts_list:
		for paylist in json_array:
			if ((paylist['account'] == account[1]) and (account[0] not in BLACK_LIST)):
				claims = int(paylist['pending'])
				text = lang(account[0], 'faucet_claims').format("{:,}".format(claims))
				try:
					push_simple(bot, account[0], text)
				except Exception as e:
					logging.warning('Push failed for {0}\n{1}'.format(account[0], text))
				#print(text)
				logging.info('{0}\n{1}'.format(account[0], text))
				time.sleep(1.25)


# Faucet
def faucet_stats():
	time.sleep(5)
	http = urllib3.PoolManager(cert_reqs='CERT_REQUIRED',ca_certs=certifi.where())
	url = 'https://faucet.raiblockscommunity.net/userpay.php?json=1'
	response = http.request('GET', url, headers=header, timeout=40.0)
	json_paylist = json.loads(response.data)
	threshold = int(float(json_paylist['threshold']))
	reward = int(float(json_paylist['reward']))
	claimers = int(float(json_paylist['claimingnow']))
	mysql_set_faucet(threshold, reward, claimers)


#faucet()
faucet_stats()