adding monero provider

package.json

@@ -1,6 +1,6 @@
 {
   "name": "bc-listener",
-  "version": "2.6.0",
+  "version": "2.6.1",
   "description": "BlockChain listener",
   "main": "index.js",
   "scripts": {
@@ -17,6 +17,7 @@
   },
   "homepage": "https://github.com/YouToken/bc-listener#readme",
   "dependencies": {
+    "axios": "^0.24.0",
     "bignumber.js": "^9.0.1",
     "bitcoin-core": "^3.0.0",
     "eosjs": "^21.0.4",

providers/xmr/clients/rest.js

@@ -0,0 +1,39 @@
+'use strict';
+const request = require('superagent');
+const Cache = require('../../../utils/cache');
+
+module.exports = class MoneroRest {
+  constructor({url}) {
+    this.url = url;
+    this.cache = new Cache();
+  }
+
+  async cmd(command, ...args) {
+    if (command === 'getHeight') {
+      return request
+        .get(`${this.url}/blocks/api/get_stats`)
+        .then(response => JSON.parse(response.text))
+        .then(response => response.height);
+    }
+    if (command === 'getblock') {
+      return request
+        .get(`${this.url}/blocks/api/get_block_data/${args[0]}`)
+        .then(response => JSON.parse(response.text))
+        .then(response => response.block_data.result);
+    }
+  }
+
+  async getCurrentHeight() {
+    return this.cache.getWithCache('getHeight', () => this.cmd('getHeight'), 60);
+  }
+
+  async getBlock(height) {
+    let block = await this.cmd('getblock', height);
+    return {
+      height,
+      hash: block.block_header.hash,
+      prev_hash: block.block_header.prev_hash,
+      txs: block.block_header.tx_hashes || []
+    }
+  }
+}

providers/xmr/clients/rpc.js

@@ -0,0 +1,30 @@
+'use strict';
+const axios = require('axios');
+const _ = require('lodash')
+
+module.exports = class MoneroRPC {
+  constructor({wallet}) {
+    this.walletUrl = wallet;
+  }
+
+  async request({method, params}) {
+    try {
+      const res = await axios
+        .post(`${this.walletUrl}/json_rpc`, JSON.stringify({
+          jsonrpc: "2.0",
+          method,
+          params,
+          id: new Date().getTime()
+        }), {
+          headers: {
+            'Content-Type': 'application/json',
+          },
+        });
+
+      return _.get(res, 'data.result');
+    } catch (e) {
+      console.error(e);
+    }
+  }
+
+}

providers/xmr/index.js

@@ -0,0 +1,30 @@
+'use strict';
+
+const Provider = require('../provider');
+const MoneroRest = require('./clients/rest');
+const MoneroRPC = require('./clients/rpc');
+
+module.exports = class XMR extends Provider {
+
+  constructor(options) {
+    super(options.currency || 'xmr');
+    this.clientRest = new MoneroRest(options);
+    this.clientRpc = new MoneroRPC(options);
+  }
+
+  async getBlock(height) {
+    return this.clientRest.getBlock(height);
+  }
+
+  async getHeight() {
+    return this.clientRest.getCurrentHeight();
+  }
+
+  async request({method, params}) {
+    return this.clientRpc.request({method, params});
+  }
+
+  async getPool() {
+    return [];
+  }
+};