Added embed message option.

Author: mmqnym

README.md

@@ -19,6 +19,8 @@ CHAIN="ethereum" # 詳細的名稱清單請參考 https://docs.dexscreener.com/a
 PAIR_HASH="0x646946F0518c6Ba27f1B2C6b4387EC6035bC42e3" # 範例交易對，使用的是 "丹 - PFPAsia" 的非官方交易對
 UPDATE_FREQUENCY = 5000 # in milliseconds
 
+MESSAGE_TYPE="embed" # embed or text, default is text
+
 # TASKs
 UPDATE_STATUS="on" # 讓機器人將價格反應在狀態上，"on" 開啟 or "off" 關閉
 BOARDCAST="off" # 讓機器人發送價格訊息到 "TARGET_CHANNEL_IDS" 指定的頻道，"on" 開啟 or "off" 關閉
@@ -33,6 +35,8 @@ CHAIN="ethereum" # For a detailed list of names, please refer to https://docs.de
 PAIR_HASH="0x646946F0518c6Ba27f1B2C6b4387EC6035bC42e3" # Example pair hash for the unofficial "Dan - PFPAsia" pair
 UPDATE_FREQUENCY = 5000 # in milliseconds
 
+MESSAGE_TYPE="embed" # embed or text, default is text
+
 # TASKs
 UPDATE_STATUS="on" # Enable or disable the bot's ability to reflect prices in status. Use "on" or "off".
 BOARDCAST="off" # Enable or disable the bot's ability to send price messages to the channels specified in "TARGET_CHANNEL_IDS". Use "on" or "off".
@@ -53,5 +57,6 @@ docker compose up -d --build
 Alternatively, you can run the source code using Node:
 
 ```sh
+npm i
 npm run start
 ```

app.js

@@ -1,7 +1,13 @@
-const { Client, GatewayIntentBits, ActivityType } = require('discord.js');
-const { fetchPrice } = require('./utils');
+const { Client, GatewayIntentBits, ActivityType, EmbedBuilder } = require('discord.js');
+const { fetchPairData } = require('./utils');
 
-const client = new Client({ intents: [GatewayIntentBits.Guilds] });
+const client = new Client({ 
+  intents: [
+    GatewayIntentBits.Guilds,
+		GatewayIntentBits.GuildMessages,
+		GatewayIntentBits.MessageContent,
+  ] 
+});
 const dotenv = require('dotenv');
 
 dotenv.config()
@@ -25,18 +31,112 @@ const doTask = async () => {
 }
 
 const updateStatus = async () => {
-  const price = await fetchPrice()
-  client.user.setActivity(`$${price}`, { type: ActivityType.Watching })
+  const data = await fetchPairData()
+  client.user.setActivity(`$${data.pair.priceUsd}`, { type: ActivityType.Watching })
 }
 
 const boardcast = async () => {
-  const price = await fetchPrice()
+  const data = await fetchPairData()
 
-  // send message to all channels from specific channel ids
+  // Send message to all channels from specific channel ids
   const channelIds = process.env.TARGET_CHANNEL_IDS.split(',');
 
+  if (process.env.MESSAGE_TYPE === 'text') {
+    _boardcastText(channelIds, data);
+  } else {
+    _boardcastEmbed(channelIds, data);
+  }
+}
+
+const _boardcastEmbed = async (channelIds, data) => {
+  for (const channelId of channelIds) {
+    const channel = await client.channels.fetch(channelId);
+
+    // [Optional] Let the chaanel only keep latest message
+    const messages = await channel.messages.fetch({ limit: 100 });
+
+    let targetMsg = null;
+    // let ftPriceField = null;
+    let m5ChangeField = null;
+    
+    for (const message of messages.values()) {
+      const embedMsg = message.embeds[0];
+      if (embedMsg) {
+        m5ChangeField = embedMsg.fields.find(field => field.name === '5M');
+
+        if (m5ChangeField) {
+          targetMsg = message;
+          break;
+        }
+      }
+    }
+    // If you can't see any message, please check the bot's permission
+    // console.log(messages)
+
+    if (m5ChangeField &&
+        m5ChangeField.value === `${data.pair.priceChange.m5}%`) {
+      // same 5m change rate, no need to update
+      continue;
+    } else if (m5ChangeField && m5ChangeField.value !== `$${data.pair.priceChange.m5}`) {
+      // price changed, delete the old message
+      await targetMsg.delete();
+    }
+
+    // no existed message or price changed, send a new message
+    const embedMsg = new EmbedBuilder()
+      .setTitle('丹 Price')
+      .setURL(`https://dexscreener.com/${process.env.CHAIN}/${process.env.PAIR_HASH}`)
+      .setAuthor({ name: 'mmq88x', iconURL: 'https://i.imgur.com/8NJckwc.png', url: 'https://twitter.com/mmq88x' })
+      .setDescription(`這是現在 PFPAsia 最大流動池的即時價格監控機器人，你可以點擊標頭查看更詳細的資訊。\n` +
+                      `This is the realtime price monitoring bot of PFPAsia's largest pool now.` +
+                      `You can click on the title to view more detailed information.`)
+      .addFields(
+        { name: '<:coin:1207027215414460416> FT Price', value: `$${data.pair.priceUsd}` },
+        { name: '5M', value: `${data.pair.priceChange.m5}%`, inline: true },
+        { name: '1H', value: `${data.pair.priceChange.h1}%`, inline: true },
+        { name: '6H', value: `${data.pair.priceChange.h6}%`, inline: true },
+        { name: '24H', value: `${data.pair.priceChange.h24}%`, inline: false },
+        { name: '<:liquidity:1207026179639484506> Liquidity', value: `$${data.pair.liquidity.usd}`, inline: true },
+        { name: '<:diamond:1207023588000010321> Market cap', value: `$${data.pair.fdv}`, inline: true },
+      )
+      .setThumbnail('https://i.imgur.com/ys8mjvO.png')
+      .setFooter({ text: 'Update time', iconURL: 'https://i.imgur.com/ys8mjvO.png' })
+      .setColor([227, 23, 13])
+      .setTimestamp();
+
+    await channel.send({ embeds: [embedMsg] });
+    
+  }
+}
+
+const _boardcastText = async (channelIds, data) => {
   for (const channelId of channelIds) {
     const channel = await client.channels.fetch(channelId);
+
+    // [Optional] Let the chaanel only keep latest message
+    const messages = await channel.messages.fetch({ limit: 100 });
+    
+    // If you can't see any message, please check the bot's permission
+    // console.log(messages)
+    const price = data.pair.priceUsd;
+    const priceSameMsg = messages.find(
+      (msg) => msg.content === `丹 DAN Price: $${price}`
+    );
+
+    if (priceSameMsg) {
+      continue;
+    }
+
+    const priceDifferentMsg = messages.find(
+      (msg) => msg.content.startsWith('丹 DAN Price:') && msg.content !== `丹 DAN Price: $${price}`
+    );
+
+    if (priceDifferentMsg) {
+      await priceDifferentMsg.edit(`丹 DAN Price: ${price}`);
+      continue;
+    }
+
+    // No existed message from the bot, send a new message
     await channel.send(`丹 DAN Price: $${price}`);
   }
 }

example.env

@@ -4,8 +4,10 @@ DISCORD_TOKEN="Your Token"
 TARGET_CHANNEL_IDS="Your Channel ID" # Seperated by ',', ex: 123456789,987654321
 CHAIN="ethereum" # Detail: https://docs.dexscreener.com/api/reference
 PAIR_HASH="0x646946F0518c6Ba27f1B2C6b4387EC6035bC42e3"
-UPDATE_FREQUENCY = 5000 # in milliseconds
+UPDATE_FREQUENCY = 6000 # in milliseconds
+
+MESSAGE_TYPE="embed" # embed or text, default is text
 
 # TASKs
 UPDATE_STATUS="on" # on or off
-BOARDCAST="off" # on or off
+BOARDCAST="on" # on or off

utils.js

@@ -1,18 +1,17 @@
-const fetchPrice = async () => {
-    priceUsd = -1;
+const fetchPairData = async () => {
+    let data = null;
 
     try {
         const response = await fetch(
         `https://api.dexscreener.com/latest/dex/pairs/${process.env.CHAIN}/${process.env.PAIR_HASH}`
         );
-        const data = await response.json();
-        priceUsd = data.pair.priceUsd;
+        data = await response.json();
 
     } catch (error) {
         console.log(error);
     }
 
-    return priceUsd;
+    return data;
 }
 
-module.exports = { fetchPrice };
+module.exports = { fetchPairData };