some upgrades
This commit is contained in:
parent
7dfa5e1da7
commit
a51b0d21b5
16
config.py
16
config.py
|
@ -68,21 +68,5 @@ fee = {
|
|||
'USDT': 0.02,
|
||||
'ETH': 0.06,
|
||||
'XHV': 0.06
|
||||
},
|
||||
"MERCHANT": {
|
||||
'BTC': 0.01,
|
||||
'BTCLN': 0.01,
|
||||
'BTCT': 0.005,
|
||||
'LTC': 0.01,
|
||||
'BCH': 0.01,
|
||||
'DCR': 0.01,
|
||||
'DASH': 0.01,
|
||||
'XRP': 0.01,
|
||||
'DOGE': 0.01,
|
||||
'XMR': 0.01,
|
||||
'ZEC': 0.01,
|
||||
'USDT': 0.01,
|
||||
'ETH': 0.01,
|
||||
'XHV': 0.01
|
||||
}
|
||||
}
|
||||
|
|
34
rpcs.py
34
rpcs.py
|
@ -30,37 +30,3 @@ class RPCHost(object):
|
|||
if 'error' in responseJSON and responseJSON['error'] != None:
|
||||
raise Exception('Error in RPC call: ' + str(responseJSON['error']))
|
||||
return responseJSON['result']
|
||||
|
||||
# class
|
||||
class RPCXMR(object):
|
||||
def __init__(self, url, user, password):
|
||||
self._session = requests.Session()
|
||||
self._url = url
|
||||
self._user = user
|
||||
self._pass = password
|
||||
self._headers = {}
|
||||
|
||||
def call(self, rpcMethod, params):
|
||||
payload = json.dumps({"method": rpcMethod, "params": params, "jsonrpc": "2.0"})
|
||||
tries = 3
|
||||
hadConnectionFailures = False
|
||||
while True:
|
||||
try:
|
||||
response = self._session.post(self._url, headers=self._headers, data=payload, auth=HTTPDigestAuth(self._user, self._pass), timeout=15)
|
||||
except requests.exceptions.ConnectionError:
|
||||
tries -= 1
|
||||
if tries == 0:
|
||||
raise Exception('Failed to connect for remote procedure call.')
|
||||
hadFailedConnections = True
|
||||
print("Couldn't connect for remote procedure call, will sleep for two seconds and then try again ({} more tries)".format(tries))
|
||||
#time.sleep(2)
|
||||
else:
|
||||
if hadConnectionFailures:
|
||||
print('Connected for remote procedure call after retry.')
|
||||
break
|
||||
if not response.status_code in (200, 500):
|
||||
raise Exception('RPC connection failure: ' + str(response.status_code) + ' ' + response.reason)
|
||||
responseJSON = response.json()
|
||||
if 'error' in responseJSON and responseJSON['error'] != None:
|
||||
raise Exception('Error in RPC call: ' + str(responseJSON['error']))
|
||||
return responseJSON['result']
|
Loading…
Reference in New Issue