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/cmd.js

@@ -0,0 +1,4 @@
+const REST_COMMAND_GET_HEIGHT = 'getHeight';
+const REST_COMMAND_GET_BLOCK = 'getBlock';
+
+module.exports = { REST_COMMAND_GET_BLOCK, REST_COMMAND_GET_HEIGHT };

providers/xmr/clients/rest.js

@@ -0,0 +1,45 @@
+'use strict';
+
+const axios = require('axios');
+const Cache = require('../../../utils/cache');
+const { REST_COMMAND_GET_BLOCK, REST_COMMAND_GET_HEIGHT } = require('./cmd');
+
+module.exports = class MoneroRest {
+  constructor({ url }) {
+    this.url = url;
+    this.cache = new Cache();
+  }
+
+  async cmd(command, ...args) {
+    if (command === REST_COMMAND_GET_HEIGHT) {
+      const { data } = await axios.get(`${this.url}/blocks/api/get_stats`);
+
+      return data.height;
+    }
+    if (command === REST_COMMAND_GET_BLOCK) {
+      const { data } = await axios.get(
+        `${this.url}/blocks/api/get_block_data/${args[0]}`,
+      );
+
+      return data.block_data.result;
+    }
+  }
+
+  async getCurrentHeight() {
+    return this.cache.getWithCache(
+      REST_COMMAND_GET_HEIGHT,
+      () => this.cmd(REST_COMMAND_GET_HEIGHT),
+      60,
+    );
+  }
+
+  async getBlock(height) {
+    const block = await this.cmd(REST_COMMAND_GET_BLOCK, 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,24 @@
+'use strict';
+
+const axios = require('axios');
+
+module.exports = class MoneroRPC {
+  constructor({ wallet }) {
+    this.walletUrl = wallet;
+  }
+
+  async request({ method, params }) {
+    try {
+      const { data } = await axios.post(`${this.walletUrl}/json_rpc`, {
+        jsonrpc: '2.0',
+        method,
+        params,
+        id: new Date().getTime(),
+      });
+
+      return data.result;
+    } catch (e) {
+      return null;
+    }
+  }
+};

providers/xmr/index.js

@@ -0,0 +1,29 @@
+'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 await this.clientRest.getBlock(height);
+  }
+
+  async getHeight() {
+    return await this.clientRest.getCurrentHeight();
+  }
+
+  async request({ method, params }) {
+    return await this.clientRpc.request({ method, params });
+  }
+
+  async getPool() {
+    return [];
+  }
+};