1 篇博文 含有标签「Telegram BOT」

new Bot(process.env.BOT_TOKEN!, {
    client: {
        baseFetchConfig: {
            agent: isDevEnv ? new HttpsProxyAgent('http://127.0.0.1:7890') : null
        },
        environment: isDevEnv ? 'test' : 'prod'
    }
})

// 1. 调用 `sendInvoice` 发送发票，currency 参数指定为`XTR`
ctx.api.sendInvoice(ctx.chat!.id, 'Title', 'Description', `payload`, 'XTR', [{ label: 'Label', amount: 1 }])

// 2. 检查发票，等待字段 `pre_checkout_query` 的更新
bot.on('pre_checkout_query', (ctx) => {

// 3. 通过 `answerPreCheckoutQuery` 批准或取消订单
    ctx.answerPreCheckoutQuery(true)
    // ctx.answerPreCheckoutQuery(false, {
    //     error_message: 'An unexpected error occurred. Please try again later.'
    // })
})

// 4. 等待字段 `successful_payment` 的更新
bot.on(':successful_payment', ctx => {

// 5. 支付成功回调，存储成功支付的 `telegram_payment_charge_id`（未来可能需要用它来发起退款）
    console.log(ctx.message?.successful_payment.telegram_payment_charge_id)

// 6. 向用户交付其所购买的商品和服务，业务逻辑...
    ctx.reply('payment-success').catch(console.error)
})

function generatePaymentLink(
  toWallet: string,
  amount: number | string | bigint,
  comment: string,
  app: "tonhub" | "tonkeeper"
) {
  if (app === "tonhub") {
    return `https://tonhub.com/transfer/${toWallet}?amount=${toNano(
      amount
    )}&text=${comment}`;
  }

  return `https://app.tonkeeper.com/transfer/${toWallet}?amount=${toNano(
    amount
  )}&text=${comment}`;
}

const tonhubPaymentLink = generatePaymentLink(process.env.OWNER_WALLET!, amount, comment, 'tonhub')
const tonkeeperPaymentLink = generatePaymentLink(process.env.OWNER_WALLET!, amount, comment, 'tonkeeper')

const menu = new InlineKeyboard()
    .url("Click to pay in TonHub", tonhubPaymentLink)
    .row()
    .url("Click to pay in TonKeeper", tonkeeperPaymentLink)
    .row()
    .text(`I sent ${amount} TON`, "check_transaction");

await ctx.reply(
    `Tips`,
    { reply_markup: menu, parse_mode: "HTML" }
);

bot.callbackQuery("check_transaction", checkTransaction);

async function checkTransaction(ctx) {
  await verifyTransactionExistance(
    process.env.OWNER_WALLET,
    ctx.session.amount,
    ctx.session.comment
  );
}

async function verifyTransactionExistance(
  toWallet: Address,
  value: number,
  comment: string
) {
  const endpoint =
    process.env.NETWORK === "mainnet"
      ? "https://toncenter.com/api/v2/jsonRPC"
      : "https://testnet.toncenter.com/api/v2/jsonRPC";

  const httpClient = new HttpApi(endpoint, {
    apiKey: process.env.TONCENTER_TOKEN,
  });

  const transactions = await httpClient.getTransactions(toWallet, {
    limit: 100,
  });

  let incomingTransactions = transactions.filter(
    (tx) => Object.keys(tx.out_msgs).length === 0
  );

  for (let i = 0; i < incomingTransactions.length; i++) {
    let tx = incomingTransactions[i];
    // Skip the transaction if there is no comment in it
    if (!tx.in_msg?.msg_data) {
      continue;
    }

    // Convert transaction value from nano
    let txValue = fromNano(tx.in_msg.value);
    // Get transaction comment
    let txComment = tx.in_msg.message;
    if (txComment === comment && txValue === value.toString()) {
      return true;
    }
  }

  return false;
}