小试牛刀-Telebot区块链游戏机器人(TS升级)

AI图片生成是通过huggingface上运行的AI模型接口实现(为什么不用国内的?答:少,且要钱).首先你需要在huggingface上注册一个token,当然如果你不想申请也可以直接用代码内的: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,然后使用post请求直接调用相关模型,具体使用方法可以在huggingface官网进行查看.

import TelegramBot from 'node-telegram-bot-api';
import { getCommandsText } from '../filter/Intercept'
import axios from 'axios';
// 定义 API_TOKEN 和数据接口
const API_TOKEN: string = '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'; // 替换为你的 API Token

interface QueryData {
    inputs: string;
}
// 处理分享链接命令
async function handleGenImg(bot:TelegramBot,message: TelegramBot.Message): Promise<void> {
    const inviterUserId = message.from?.id;
    const username = message.from?.username;
    
    const text=getCommandsText(message);

    query({inputs:text})
    .then((response) => {
        const helpText="<b>Beautiful!\nThis is the image you created! @"+{username}+"</b>\n"
        bot.sendPhoto(message.chat.id, response, {
            caption: helpText,
            parse_mode: 'HTML'
        });
    })
    .catch((error) => {
        console.error('Error:', error);
    });
}
// 注册命令处理程序
export function registerGenImgHandlers(bot:TelegramBot): void {
    bot.onText(/\/genimg/, async (msg) => {
        await handleGenImg(bot,msg);
    });
}


async function query(data: any): Promise<any> {
    try {
        const response = await axios.post(
            "https://api-inference.huggingface.co/models/alvdansen/littletinies",
            JSON.stringify(data),
            {
                headers: { Authorization: `Bearer ${API_TOKEN}` },
                responseType: 'arraybuffer'
            },
            
        );
        return response.data;
    } catch (error) {
        console.error('请求错误:', error);
        throw error;
    }
}

4.2 签到

用户签到即用户每天可点击一次按钮并获得奖励,这里注意用户点击后该用户id要进行记录,防止重复签到,实现代码如下:

async function dailyCheck(bot: TelegramBot, call: TelegramBot.CallbackQuery) {
    const fromUserId = call.from.id;
    const username = call.from.username;
    //防止连续点击
    if (!passGameTime(fromUserId)) {
        bot.sendMessage(call.message!.chat.id, "<b>Please do not send duplicate messages</b>", { parse_mode: 'HTML' });
        bot.answerCallbackQuery(call.id, { text: "", show_alert: false });
        return;
    }

    dailyCommandTime[fromUserId] = Date.now();

    if (await notHasWallet(String(fromUserId))) {
        bot.sendMessage(call.message!.chat.id, `<b>You not have wallet info, you need send [/create] create one game wallet! @${call.from.username}</b>`, { parse_mode: 'HTML' });
        bot.answerCallbackQuery(call.id, { text: "", show_alert: false });
        return;
    }
    //限定签到数量
    if (await checkDailyNumber()) {
        bot.sendMessage(call.message!.chat.id, `<b>There are only 50 people per day, please come again tomorrow! @${call.from.username}</b>`, { parse_mode: 'HTML' });
        bot.answerCallbackQuery(call.id, { text: "", show_alert: false });
        return;
    }

    if (await checkDaily(String(fromUserId))) {
        bot.sendMessage(call.message!.chat.id, `<b>You have already daily check! @${call.from.username}</b>`, { parse_mode: 'HTML' });
        bot.answerCallbackQuery(call.id, { text: "", show_alert: false });
        return;
    }
    //发送奖励
    const [ amount, tx ] = await drawDailyCheck(String(SEND_USER_ID), String(fromUserId));
    if (tx === "error") {
        bot.sendMessage(call.message!.chat.id, "<b>Daily Check Error!</b>", { parse_mode: 'HTML' });
        bot.answerCallbackQuery(call.id, { text: "", show_alert: false });
        return;
    }
    if (tx=="error:account"){
        bot.sendMessage(call.message!.chat.id, `<b>You must first send some BOGGY into the wallet before you can [DaliyCheck] and [invite] @${username}</b>`, { parse_mode: 'HTML' });
        bot.answerCallbackQuery(call.id, { text: "", show_alert: false });
        return;
    }
    //添加每日签到数据
    addDaily(String(fromUserId));

    const markup = {
        inline_keyboard: [
            [
                { text: "Check Tx", url: `https://solscan.io/tx/${tx}` }
            ]
        ]
    };

    bot.sendMessage(call.message!.chat.id, `<b>The Daily Check amount ${amount} BOGGY transfer end, Click 'Check Tx' Button Check @${call.from.username}</b>`, { reply_markup: markup, parse_mode: 'HTML' });
    bot.answerCallbackQuery(call.id, { text: "", show_alert: false });
}

4.3 邀请

邀请实际是通过在机器人链接后拼接命令,格式为:https://t.me/{机器人名}?start={邀请人id},这样当邀请人点击你的链接并使用start命令启动机器人时,则可以获取到链接后的邀请人Id,然后给邀请人发消息并发送代币奖励.实现代码如下:

// 检查是否有邀请码
if (checkCommandsParams(message, "start")) {
    const inviterUserId = getCommandsParams(message);
    const fromUserId = message.from?.id??0;
    //连续点击监测
    if (!passGameTime(fromUserId)) {
        bot.sendMessage(message.chat.id, "<b>Please do not send duplicate messages</b>", { parse_mode: 'HTML' });
        return;
    }

    dailyCommandTime[fromUserId] = Date.now();
    //自己邀请自己检测
    if (Number(inviterUserId) === fromUserId) {
        bot.sendMessage(message.chat.id, "<b>You cannot invite yourself!</b>", { parse_mode: 'HTML' });
        return;
    }
    //游戏钱包检测
    if (await notHasWallet(inviterUserId)) {
        bot.sendMessage(message.chat.id, "<b>The inviter has not created a wallet and cannot receive rewards</b>", { parse_mode: 'HTML' });
        return;
    }
    //已被邀请检测
    if (await hasShildUser(String(fromUserId))) {
        bot.sendMessage(message.chat.id, "<b>Invited users cannot receive rewards</b>", { parse_mode: 'HTML' });
        return;
    }
    //发送奖励
    const [amount, tx ] = await drawDailyCheck(String(SEND_USER_ID), inviterUserId);
    if (tx === "error") {
        bot.sendMessage(message.chat.id, "<b>send rewards Error!</b>", { parse_mode: 'HTML' });
        return;
    }
    if (tx == "error:account"){
        bot.sendMessage(message.chat.id, `<b>You must first send some BOGGY into the wallet before you can [DaliyCheck] and [invite] @${username}</b>`, { parse_mode: 'HTML' });
        return;
    }

    const markup = {
        inline_keyboard: [
            [
                { text: "Check Tx", url: `https://solscan.io/tx/${tx}` }
            ]
        ]
    };

    bot.sendMessage(message.chat.id, `<b>You have accepted the inviter's invitation and the reward ${amount} BOGGY has been sent to the inviter. Click 'Check Tx' Button Check @${message.from?.username}</b>`, { reply_markup: markup, parse_mode: 'HTML' });
    bot.sendMessage(inviterUserId, `<b>The Invited amount ${amount} BOGGY transfer end, Click 'Check Tx' Button Check</b>`, { reply_markup: markup, parse_mode: 'HTML' });
    addShildUser(String(fromUserId), inviterUserId);

4.4 WalletConnect连接

用户输入/wclink命令后,则调用initWalletConnect进行配对,并发送连接请求,同时通过传入的approval监听用户的连接情况,实现代码如下:

import Client, { SignClient } from "@walletconnect/sign-client";

import TelegramBot from "node-telegram-bot-api";
const metadata={
  name: 'BoggyGame',
  description: 'BoggyGame Bot',
  url: 'https://www.boggycoin.com',
  icons: [
    "https://i.postimg.cc/sftPCk3M/photo-2024-07-12-14-12-43.jpg"
  ]
}
const projectId="申请的ProjectId"
let signClient: Client | null = null;
async function getSignClient() {
  if (!signClient) {
    signClient = await SignClient.init({
      projectId: projectId, // 替换为你的项目ID
      metadata: metadata
    });
  }
  return signClient;
}

export async function initWalletConnect(onApproval: (approval: any,signClient:any,bot:any,message:any) => void,bot:TelegramBot,message:TelegramBot.Message):Promise<String|undefined> {
    const signClient = await getSignClient()

    // 创建会话并发送签名请求
    const {topic} = await signClient.core.pairing.create()
    const { uri,approval } = await signClient.connect({
      pairingTopic: topic,
      requiredNamespaces: {
        solana: {
          methods: [
            "solana_signTransaction",
            "solana_signMessage"
          ],
          chains: [
            "solana:5eykt4UsFv8P8NJdTREpY1vzqKqZKvdp"
          ],
          events: []
        }
      }
    })
    // 调用回调函数处理 approval
    if (approval) {
        onApproval(approval,signClient,bot,message);
    }
    
    return uri;

}