Page MenuHomePhabricator
Files F14864441

D14036.id40714.diff
No OneTemporary
Actions

D14036.id40714.diff
View Options

diff --git a/apps/ecash-herald/package.json b/apps/ecash-herald/package.json
--- a/apps/ecash-herald/package.json
+++ b/apps/ecash-herald/package.json
@@ -9,7 +9,8 @@
"junit": "mocha test --reporter mocha-junit-reporter",
"generateMocks": "node scripts/generateMocks",
"sendTestTgMsgs": "node scripts/sendTestTgMsgs",
- "getCoingeckoPrices": "node scripts/getCoingeckoPrices"
+ "getCoingeckoPrices": "node scripts/getCoingeckoPrices",
+ "sendMsgByBlock": "node scripts/sendMsgByBlock"
},
"keywords": [
"ecash",
diff --git a/apps/ecash-herald/scripts/sendMsgByBlock.js b/apps/ecash-herald/scripts/sendMsgByBlock.js
new file mode 100644
--- /dev/null
+++ b/apps/ecash-herald/scripts/sendMsgByBlock.js
@@ -0,0 +1,99 @@
+// Copyright (c) 2023 The Bitcoin developers
+// Distributed under the MIT software license, see the accompanying
+// file COPYING or http://www.opensource.org/licenses/mit-license.php.
+'use strict';
+
+/**
+ * sendMsgByBlockheight.js
+ *
+ * A script to allow developer to generate and broadcast an ecash-herald message
+ * by blockheight
+ *
+ * Use cases
+ * - Developing and testing a feature that is not in any of the current test blocks
+ * - Proof of concept for future version of app where you may want to send "missed" msgs
+ * if the app is down for some period of time
+ *
+ * Example use
+ *
+ * Send msg to test channel for default blockheight (genesis block)
+ * node scripts/sendMsgByBlock.js
+ *
+ * Send msg to test channel for blockheight 700000
+ * node scripts/sendMsgByBlock.js 700000
+ */
+
+// App functions
+const { handleBlockConnected } = require('../src/events');
+const { sendBlockSummary } = require('../src/telegram');
+
+// Default to the genesis block
+let blockhashOrHeight = 0;
+
+// Look for blockheight specified from command line
+if (process.argv && typeof process.argv[2] !== 'undefined') {
+ // user input if available, commas removed
+ blockhashOrHeight = parseInt(process.argv[2].replace(/,/g, ''));
+}
+
+// Initialize chronik
+const config = require('../config');
+const { ChronikClient } = require('chronik-client');
+const chronik = new ChronikClient(config.chronik);
+
+// Initialize telegram bot to send msgs to dev channel
+const secrets = require('../secrets');
+const TelegramBot = require('node-telegram-bot-api');
+const { dev } = secrets;
+const { botId, channelId } = dev.telegram;
+// Create a bot that uses 'polling' to fetch new updates
+const telegramBotDev = new TelegramBot(botId, { polling: true });
+
+// Mock price API call to prevent rate limiting during testing
+const axios = require('axios');
+const MockAdapter = require('axios-mock-adapter');
+
+async function sendMsgByBlock(
+ chronik,
+ telegramBot,
+ channelId,
+ blockhashOrHeight,
+) {
+ // Mock price API
+ const mock = new MockAdapter(axios, { onNoMatch: 'throwException' });
+ const mockResult = {
+ bitcoin: { usd: 25000.0 },
+ ecash: { usd: 0.00003333 },
+ ethereum: { usd: 1900.0 },
+ };
+ mock.onGet().reply(200, mockResult);
+
+ const returnedMocks = await handleBlockConnected(
+ chronik,
+ telegramBot,
+ channelId,
+ blockhashOrHeight,
+ true,
+ );
+
+ const { blockSummaryTgMsgs, blockSummaryTgMsgsApiFailure } = returnedMocks;
+
+ // Send msg with successful price API call
+ await sendBlockSummary(blockSummaryTgMsgs, telegramBot, channelId);
+
+ // Send msg with failed price API call
+ await sendBlockSummary(
+ blockSummaryTgMsgsApiFailure,
+ telegramBot,
+ channelId,
+ );
+
+ console.log(
+ '\x1b[32m%s\x1b[0m',
+ `✔ Sent telegram msg for block ${blockhashOrHeight}`,
+ );
+
+ process.exit(0);
+}
+
+sendMsgByBlock(chronik, telegramBotDev, channelId, blockhashOrHeight);

File Metadata

Mime Type
text/plain
Expires
Tue, May 20, 19:41 (9 h, 15 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
5861868
Default Alt Text
D14036.id40714.diff (3 KB)

Event Timeline