config.py

@@ -68,5 +68,21 @@ 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
     }
 }

rpcs.py

@@ -30,3 +30,37 @@ 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']