# 如何设置 Solana Telegram 机器人
Solana 区块链上每秒大约发生 400 笔交易。这些交易包括代币转移、NFT 销售、代币交换、竞标、DAO 投票、投注等等。但是面对如此多的数据，您如何跟踪您关心的变化？这就是 webhook 的作用所在。Webhook 允许您跟踪这些变化并随时了解您关心的事情。本指南将向您展示如何设置 Telegram 机器人，以便使用 Cloudflare 工作器将链上更新直接发送给用户或频道 。
## 设置 Telegram 机器人的步骤
1. 设置 Telegram 频道和 Telegram 机器人。
2. 创建一个 Cloudflare 工作器，作为发送更新的 webhook 和 Telegram 机器人之间的连接。
3. 创建 Helius webhook。
4. 通过 Helius Webhook API 编辑 webhook 跟踪的地址。此步骤仅适用于跟踪整个 NFT 集合。
## **设置 Telegram 机器人**
Telegram 机器人是自动执行某些任务（尤其是更新）的好方法。以下是设置步骤。
1. **与 BotFather 开始对话：**在 Telegram 搜索栏中搜索“BotFather”，然后单击它即可开始对话。
2. **创建新机器人：**输入并发送“/newbot”。BotFather 现在将指导您命名机器人并为其指定用户名。
3. **访问令牌：**完成后，BotFather 将提供访问令牌。请安全地记下它，因为我们稍后将在本教程中使用它。
对于频道更新：
1. **创建电报频道：**转到菜单（☰）并选择“新频道”。
2. **邀请机器人：**设置好频道后，点击频道名称，选择“管理员”，然后添加您的机器人。
3. 查找聊天 ID：
4. 要确定您频道的聊天 ID，请按以下步骤操作：
5. **发送消息：**首先，向您创建的频道发送消息。
6. **使用 Telegram API**：在浏览器中导航到**\ /getUpdates，将\**替换为您从 BotFather 收到的令牌。
7. **找到聊天 ID：**在返回的数据中，您会发现一个名为聊天的字段，里面有一个id，它是您频道的聊天 ID。
8. 请记住安全地记下此聊天 ID，因为您将需要它进行进一步的配置。
## **创建 Cloudflare 工作器**
Cloudflare 工作者允许您部署在线托管且将永久运行的代码，以便不断警惕来自您的 Web 挂钩的更新。
1. **登录 Cloudflare：**首先登录您的 Cloudflare 帐户。如果您还没有帐户，可以免费注册。
2. **访问 Workers 部分：**从 Cloudflare 仪表板，导航到“Workers”选项卡。
3. **创建新的 Worker：**点击“创建 Worker”按钮。这将带您进入 Worker 编辑器。
1. **编辑工人代码：**
2. 在编辑器中，您将看到一个脚本模板。将默认代码替换为您的 Telegram 机器人提供的 Cloudflare 代码。
3. 在代码中找到BOT\_TOKEN和CHAT\_ID的变量。这些是占位符，将用于通过您的机器人将消息发送到正确的聊天。
4. **配置环境变量：**
5. 在 Cloudflare Workers 仪表板中，导航到您的工作器的“设置”选项卡。
6. 在这里，您可以添加机器人的令牌、聊天令牌和 Helius API 密钥作为环境变量。这有助于将敏感数据排除在主代码之外并确保其安全。
7. 确保正确命名这些环境变量以匹配代码中的预期（例如，BOT\_TOKEN，CHAT\_ID等）。
8. **部署 Worker：**确保代码和环境变量设置正确后，点击“保存并部署”按钮。您的 Worker 将被部署并分配一个唯一的公共 URL。
9. **记下公共 URL：**部署后，请务必记下分配给您的工作人员的公共 URL。您将使用此 URL 作为 Telegram 机器人的 webhook 端点。
## **Cloudflare Worker 代码：**
```
const TELEGRAM_BOT_TOKEN = BOT_TOKEN;
const TELEGRAM_CHAT_ID = CHAT_ID;
const HELIUS_API_KEY=API_KEY;
const HELIUS_RPC_URL = `https://mainnet.helius-rpc.com/?api-key=${HELIUS_API_KEY}`;
addEventListener('fetch', event => {
event.respondWith(handleRequest(event.request))
})
async function handleRequest(request) {
if (request.method === 'POST') {
const requestBody = await request.json();
console.log('Received POST request with body:', requestBody);
//THIS IS FOR NFT UPDATES (comment this section out if you are doing something else)
// Extract transaction description, timestamp, signature, and mint address
// const NFTdescription = requestBody[0].description;
// const NFTtimestamp = new Date(requestBody[0].timestamp * 1000).toLocaleString(); // Convert Unix timestamp to readable date-time
// const NFTsignature = `https://solscan.io/tx/${requestBody[0].signature}`
// const NFTmintAddress = requestBody[0].events.nft.nfts[0].mint;
// const NFTimageUrl = await getAssetImageUrl(NFTmintAddress);// Get NFT image URL
// // Construct the message
// const messageToSendNFT =
// `----NEW UPDATE---\n`+
// `Description:\n${NFTdescription}\n` +
// `Mint Address:\n${NFTmintAddress}\n` +
// `Signature:\n${NFTsignature}\n` +
// `Timestamp:\n${NFTtimestamp}`;
// await sendToTelegramNFT(messageToSendNFT, NFTimageUrl); // Send to Telegram
//THIS IS FOR TRANSFER UPDATES (comment this section out if you are doing something else)
// Extract transaction description, timestamp, signature
const Transferdescription = requestBody[0].description;
const Transfertimestamp = new Date(requestBody[0].timestamp * 1000).toLocaleString(); // Convert Unix timestamp to readable date-time
const Transfersignature = `https://xray.helius.xyz/tx/${requestBody[0].signature}`
// Construct the message
const messageToSendTransfer =
`----NEW UPDATE---\n`+
`Description:\n${Transferdescription}\n` +
`Signature:\n${Transfersignature}\n` +
`Timestamp:\n${Transfertimestamp}`;
await sendToTelegramTransfer(messageToSendTransfer); // Send to Telegram
return new Response('Logged POST request body.', {status: 200});
} else {
return new Response('Method not allowed.', {status: 405});
}
}
// This function is used to send NFT Updates to the bot
async function sendToTelegramNFT(message, imageUrl) {
const telegramUrl = `https://api.telegram.org/bot${TELEGRAM_BOT_TOKEN}/sendPhoto`;
const response = await fetch(telegramUrl, {
method: 'POST',
headers: {
'Content-Type': 'application/json',
},
body: JSON.stringify({
chat_id: TELEGRAM_CHAT_ID,
photo: imageUrl,
caption: message,
parse_mode: "HTML"
}),
});
const responseData = await response.json();
if (!response.ok) {
console.error('Failed to send photo to Telegram:', responseData);
}
}
//This function is used to send Transfer Updates to the Bot
async function sendToTelegramTransfer(message) {
const telegramUrl = `https://api.telegram.org/bot${TELEGRAM_BOT_TOKEN}/sendMessage`;
const response = await fetch(telegramUrl, {
method: 'POST',
headers: {
'Content-Type': 'application/json',
},
body: JSON.stringify({
chat_id: TELEGRAM_CHAT_ID,
text: message,
parse_mode: "HTML"
}),
});
const responseData = await response.json();
if (!response.ok) {
console.error('Failed to send message to Telegram:', responseData);
}
}
//This function gets images associated to NFTs that are features in updates.
async function getAssetImageUrl(mintAddress) {
const response = await fetch(HELIUS_RPC_URL, {
method: 'POST',
headers: {
'Content-Type': 'application/json',
},
body: JSON.stringify({
jsonrpc: '2.0',
id: 'my-id',
method: 'getAsset',
params: {
id: mintAddress,
},
}),
});
const { result } = await response.json();
return result.content.links.image;
}
```
## **设置 Helius Webhook**
Helius webhook 弥补了 Solana 区块链和 Telegram 频道之间的差异。在此示例中，我将设置一个 webhook 来跟踪某个钱包进行的所有交易。
1. **注册：**访问dashboard.helius.dev并创建一个免费帐户。
2. **创建 Webhook：**在您的仪表板中，选择创建一个新的 webhook。您可以选择决定其类型 - 原始、增强、Discord 或帐户。对于特定分类的更新，建议使用“增强”。选择此项时，请指定您感兴趣的更新，例如NFT\_SALES或NFT\_LISTING。
3. **提供 Worker 链接和 Solana 地址：**确保您提供已部署 Cloudflare Worker 的链接。此外，请提及您希望监控的特定 Solana 帐户地址（可以是用户的钱包或集合中的铸币列表）。
如有不明白或者不清楚的地方，请加入官方电报群：