-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #5 from davodm/telegram
Telegram handler added for daily recap
- Loading branch information
Showing
4 changed files
with
123 additions
and
7 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,92 @@ | ||
| const { getRecap } = require("./src/api"); | ||
| const { abbreviateNumber, numFormat } = require("./src/number"); | ||
| const { updateLastRunTime } = require("./src/dynamodb"); | ||
| const { createImageFromTemplate, getRandomTheme } = require("./src/html"); | ||
| const { getENV } = require("./src/env"); | ||
| const TelegramBot = require("node-telegram-bot-api"); | ||
| const bot = new TelegramBot(getENV("TELEGRAM_BOT_TOKEN")); | ||
|
|
||
| exports.handler = async function (event, context) { | ||
| // Prevent timeout from waiting event loop - Chromium | ||
| context.callbackWaitsForEmptyEventLoop = false; | ||
| try { | ||
| // Run daily recap | ||
| await dailyRecap(); | ||
| // Update last run time on DynamoDB | ||
| updateLastRunTime("telegram", { type: "daily-recap" }); | ||
| // Log | ||
| console.log("Daily recap published successfully on telegram!"); | ||
| } catch (err) { | ||
| console.error(err); | ||
| } | ||
| }; | ||
|
|
||
| /** | ||
| * Generate a weekly recap image and publish it on Instagram | ||
| */ | ||
| async function dailyRecap() { | ||
| try { | ||
| // Get Data from API | ||
| const data = await getRecap("daily"); | ||
| // USDT Token | ||
| // const usd= data.find((item) => item.has_iran && item.symbol === 'USDT'); | ||
| // Total Trade Volume | ||
| const totalVol = data | ||
| .filter((item) => item.has_iran) | ||
| .reduce((acc, item) => acc + item.irr.volume, 0); | ||
| // Filter Data | ||
| const tokens = data | ||
| .filter((item) => item.has_iran) | ||
| .map((item) => { | ||
| return { | ||
| name: item.name_en, | ||
| price: "$" + numFormat(item.usd.price_avg), | ||
| volume: | ||
| abbreviateNumber(Math.round(item.irr.volume), 1, true) + " IRR", | ||
| icon: item.icon, | ||
| }; | ||
| }) | ||
| .slice(0, 10); | ||
|
|
||
| // Create Image | ||
| const image = await createImageFromTemplate( | ||
| "table-" + getRandomTheme(), | ||
| { | ||
| tokens, | ||
| headers: ["Token", "Average Price", "Traded Volume"], | ||
| title: "Daily Recap", | ||
| subtitle: `Total traded volume today: ${abbreviateNumber( | ||
| Math.round(totalVol), | ||
| 0, | ||
| true | ||
| )} IRR`, | ||
| lastUpdate: new Date().toISOString().slice(0, 10), | ||
| }, | ||
| "daily.jpg" | ||
| ); | ||
|
|
||
| console.log("generated image:", image); | ||
|
|
||
| if (!image) { | ||
| throw new Error("Image not generated!"); | ||
| } | ||
| // Get Caption from AI | ||
| const caption = ` | ||
| 📈 Today's Crypto Market Recap | ${new Date().toISOString().slice(0, 10)} | ||
| 📊 Total Traded Volume Today: ${numFormat(Math.round(totalVol))} IRR | ||
| Source: @irancrypto_market | ||
| Follow us on <a href="http://instagram.com/irancryptomarket">Instagram @irancryptomarket</a> | ||
| `; | ||
|
|
||
| // Publish the image on Telegram channel | ||
| await bot.sendPhoto(getENV("TELEGRAM_CHANNEL_ID"), image, { | ||
| caption: caption, | ||
| parse_mode: "html", | ||
| disable_web_page_preview: true, | ||
| }); | ||
| } catch (err) { | ||
| throw err; | ||
| } | ||
| } |