Cloudflare 的 worker 运行 telegram bot 自动回复关键字 将回复的消息延迟删除

查看相关主题:

前言

在群里搞了一个关键字回复机器人. Github 上面大把的项目. 略.
但是一直没有自动延迟删除回复消息的功能.
我的概念里面 worker 是 http 请求时才会运行的, 也就是说, 有人在群里发了消息, 这个worker才会运行. 那自然就做不了延迟删除消息了.

灵感

今天突发奇想, 问了一下AI, "cloudflare 的 worker 怎么实现定时任务". 

接下来就是无趣的面向GPT开发
粘贴 的代码是一个基于 cloudflare worker 的 telegram bot.  
我要实现bot回复的消息延迟5~10分钟删除的功能.

我给这个 worker 绑定了一个 KV :  BOT_MSG, 用于保存发出的消息的数据.

我给这个 worker 设置了定时5分钟的 cron trigger.

请改进这段代码

贴一下代码吧.
const TOKEN = 'your_bot_token'
const WEBHOOK = '/endpoint'
const SECRET = 'you_should_generate_random_string'

const DELETE_AFTER_MS = 5 * 60 * 1000 // 5分钟

/**
 * 将已发送的消息存入 KV
 * key: msg:{delete_at}:{chat_id}:{message_id}
 */
async function saveMessage(env, chatId, messageId) {
  const deleteAt = String(Date.now() + DELETE_AFTER_MS).padStart(16, '0')
  const key = `msg:${deleteAt}:${chatId}:${messageId}`
  await env.BOT_MSG.put(key, '1', {
    expirationTtl: 20 * 60 // 20分钟兜底清理
  })
}

/**
 * Cron 触发：删除所有到期的消息
 */
async function handleScheduled(env) {
  const now = Date.now()
  const { keys } = await env.BOT_MSG.list({ prefix: 'msg:' })

  for (const { name } of keys) {
    // key 格式: msg:{delete_at}:{chat_id}:{message_id}
    const [, deleteAt, chatId, messageId] = name.split(':')
    if (parseInt(deleteAt) <= now) {
      await deleteMessage(chatId, messageId)
      await env.BOT_MSG.delete(name)
    }
  }
}

/**
 * 调用 Telegram API 删除消息
 */
async function deleteMessage(chatId, messageId) {
  return (await fetch(apiUrl('deleteMessage', {
    chat_id: chatId,
    message_id: messageId
  }))).json()
}

// ─── Export ────

export default {
  async fetch(request, env, ctx) {
    const url = new URL(request.url)
    if (url.pathname === WEBHOOK) {
      return handleWebhook(request, env)
    } else if (url.pathname === '/registerWebhook') {
      return registerWebhook(url, WEBHOOK, SECRET)
    } else if (url.pathname === '/unRegisterWebhook') {
      return unRegisterWebhook()
    } else {
      return new Response('No handler for this request')
    }
  },

  async scheduled(event, env, ctx) {
    ctx.waitUntil(handleScheduled(env))
  }
}

// ─── Webhook ────

async function handleWebhook(request, env) {
  if (request.headers.get('X-Telegram-Bot-Api-Secret-Token') !== SECRET) {
    return new Response('Unauthorized', { status: 403 })
  }
  const update = await request.json()
  await onUpdate(update, env)
  return new Response('Ok')
}

async function onUpdate(update, env) {
  if ('message' in update) {
    await onMessage(update.message, env)
  }
}

// ─── Message Handler ────
async function onMessage(message, env) {
  const text = message.text.toLowerCase();
  const originalText = message.text;

  // 检测英文关键词
  const hasHappy = text.includes('happy');
  const hasNew = text.includes('new');
  const hasYear = text.includes('year');

  if (hasHappy && hasNew && hasYear) {
    const result = await sendPlainText(message.chat.id, 'Happy New Year to you, too! 🎁', message.message_id);
    if (result?.ok && result?.result?.message_id) {
      await saveMessage(env, message.chat.id, result.result.message_id)
    }
    return;
  }

  // 检测中文关键字
  const has新 = originalText.includes('新');
  const has年 = originalText.includes('年');
  const has快 = originalText.includes('快');
  const has乐 = originalText.includes('乐');

  if (has新 && has年 && has快 && has乐) {
    const result = await sendPlainText(message.chat.id, '也祝你新年快乐! 🧧', message.message_id);
    if (result?.ok && result?.result?.message_id) {
      await saveMessage(env, message.chat.id, result.result.message_id)
    }
    return;
  }

  // 233群的 脚本 关键字
  const has脚本 = originalText.includes('脚本');
  if (has脚本) {
    const replyText = `
安装 sing-box 脚本 (第一次运行默认就安装 Reality 协议):
<code>bash &lt;(wget -qO- -o- https://github.com/233boy/sing-box/raw/main/install.sh)</code>

安装 Xray 脚本 (第一次运行默认就安装 Reality 协议):
<code>bash &lt;(wget -qO- -o- https://github.com/233boy/Xray/raw/main/install.sh)</code>
<tg-spoiler>
安装 V2Ray 脚本 (不要用 第一次运行默认装出来的 VMESS+TCP):
bash &lt;(wget -qO- -o- https://github.com/233boy/v2ray/raw/master/install.sh)
</tg-spoiler>
`;
    const result = await sendPlainText(message.chat.id, replyText, message.message_id);
    if (result?.ok && result?.result?.message_id) {
      await saveMessage(env, message.chat.id, result.result.message_id)
    }
    return;
  }
}

// ─── Telegram API Helpers ────

async function sendPlainText(chatId, text, replyToMessageId = null) {
  return (await fetch(apiUrl('sendMessage', {
    chat_id: chatId,
    text,
    reply_to_message_id: replyToMessageId,
    parse_mode: 'HTML'
  }))).json()
}

async function registerWebhook(requestUrl, suffix, secret) {
  const webhookUrl = `${requestUrl.protocol}//${requestUrl.hostname}${suffix}`
  const r = await (await fetch(apiUrl('setWebhook', { url: webhookUrl, secret_token: secret }))).json()
  return new Response('ok' in r && r.ok ? 'Ok' : JSON.stringify(r, null, 2))
}

async function unRegisterWebhook() {
  const r = await (await fetch(apiUrl('setWebhook', { url: '' }))).json()
  return new Response('ok' in r && r.ok ? 'Ok' : JSON.stringify(r, null, 2))
}

function apiUrl(methodName, params = null) {
  let query = ''
  if (params) {
    query = '?' + new URLSearchParams(params).toString()
  }
  return `https://api.telegram.org/bot${TOKEN}/${methodName}${query}`
}

========

后记

本次用到的GPT是

评论

发表评论

The Hot3 in Last 7 Days

酒馆SillyTavern 玩英文角色卡 也能以中文输出 设置世界书Lorebooks

图片
之前 我们实现了 让酒馆SillyTavern输出中文 . 不过, 我们在寻找/试用角色卡的时候, 常常要试用大量的角色卡, 而有些角色卡你说上一两句话就不想继续用了. 如果每个角色卡都那样操作一遍输出中文的话, 会觉得有点麻烦. 那么, 有没有什么方法可以设置一次, 就应用到每一个角色卡呢? 我们可以使用 世界书Lorebooks 这个功能. 在酒馆界面中, 点击 世界书 - 新建 随便用一个你喜欢的名字 * 这个名字只是为了方便管理. 不影响最终效果. 这时, 你应该看到刚刚新建的世界书被选中. (如果不是, 需要你在下拉菜单中选择) 然后 点击 右边的 新条目 按钮 设定这个新条目 1. 条目的标题, 随便设置什么. * 这个标题只是为了方便管理, 不影响最终效果. 2. 触发策略, 设置为 蓝色 * 意思是, 不需要关键词触发. 3. 插入位置, 设置为"角色定义前" * 如果效果不好, 可以试着改为 "角色定义后" 4. 展开条目设定 5. 设置条目的内容为 {{char}}用中文输出全部信息, 包括语言和场景描述. {{char}}输出内容中不要有大段的非中文内容. 现在, 设置你的全局世界书为你刚刚新建的这个世界书. 然后试着和你的新添加的角色卡对话看看? 我们来看看命令行里实际发生了什么. 对比 之前的方案 , 可以看到命令行日志中的效果是一样的, 也就是说, 发送给AI的格式是一样的. ======== 未完待续
Read more »

搭 Docker版 Sub-Store订阅转换专家 带 http-meta 实现 集合订阅 测延迟 排序 筛选 生成新订阅 定时任务上传Gist

图片
需求 https://github.com/2dust/v2rayN/issues/4247/ 有人希望在 v2rayN 中添加自动测延迟, 再自动切换服务器的功能. 我觉得, 如果节点很多(比如到处搜集免费节点的人, 节点总数有可能成千上万), 那么这个测速+筛选的工作不应该由翻墙客户端来做, 应该由一个单独的实体来做. 我找了一圈信息, 最终决定用 Sub-Store 完成这个任务. 搭 Docke版 Sub-Store 教程  https://surge.tel/22/2953/ Docker镜像的说明 https://hub.docker.com/r/xream/sub-store 我也记录一下自己的操作 安装 Docker curl -fsSL https://get.docker.com | bash -s docker  运行 Sub-Store 镜像 docker run -it -d --restart=always -e "SUB_STORE_BACKEND_SYNC_CRON= 55 23 * * * " -e SUB_STORE_FRONTEND_BACKEND_PATH=/ TQg8veJHzYt38utxXtav  -p 127.0.0.1:3001:3001 -v /root/sub-store-data:/opt/app/data --name sub-store xream/sub-store:http-meta * 其中,  TQg8veJHzYt38utxXtav  是你的后端API秘密路径, 你应该自己生成一个随机的, 足够长的字符串, 不要直接使用我的这个. 55 23 * * *  表示同步任务每天 23:55 执行. 如果你想每小时的第55分钟执行一次, 那么使用  55 * * * *   你可以 查看 docker 的运行状态, 确认sub-store运行起来了. docker stats * 如果你是在自己的 电脑 上面搭, 那么, Docker环境用你自己习惯的方式. 需要注意, 镜像为  xream/sub-store:http-meta 如果没带上 http-meta 那么镜像中就没有 http-meta, 那么就不能测速...
Read more »

酒馆SillyTavern 用中文讲故事 修改角色卡 修改AI生成的历史记录

图片
在之前的故事中 , 我是以"我只能听懂中文"作为发出的第一句话, 开始了整篇中文故事. https://imghost.lvedong.eu.org/Seraphina-月影草的故事.pdf 一方面这有一点出戏; 另一方面, 如果每个故事都要以这样的方式开始, 你会不会觉得有一点麻烦? 还有一点, 在角色的"角色描述" 和 "第一条消息"是大段英文的前提下, 用户发出第一条"使用中文输出", AI有可能仍然生成英文或者生成夹中夹英的结果. 让我们来探索其它让酒馆生成中文故事的方法. 方案一 前面我们探索过 酒馆SillyTavern实际上和AI之间通信的数据格式 . AI是根据我们发过去的内容, "续写"一段文字. 所以如果我们发给AI的数据是中文的, 那么AI"续写"的内容也会是中文. 按这样的思路, 我们把酒馆角色的 角色描述 和 第一条消息 都翻译为中文. 改成下面这样 (我是随便找的机翻, 故意没有仔细修正, 这是普通人的真实体验) * 注意 <START>, {{user}}, {{char}} 这种是酒馆系统专用保留字. 要对照原文查一下, 如果保留字被翻译了, 需要你还原. 角色描述 [塞拉菲娜的性格 = “关怀”、“保护”、“富有同情心”、“治愈”、“养育”、“神奇”、“警惕”、“抱歉”、“温柔”、“担心”、“专注”、“温暖”、“细心”、“有韧性”、“善良”、“平静”、“优雅”、“善解人意”、“忠诚”、“坚强”、“敏锐”、“优雅”] [塞拉菲娜的身体=“粉色头发”、“长发”、“琥珀色眼睛”、“白色牙齿”、“粉色嘴唇”、“白皙皮肤”、“柔软皮肤”、“黑色太阳裙”] <START> {{user}}： “描述一下你的性格特征？” {{char}}: *塞拉菲娜 温柔的笑容绽放，她思考了一会儿，眼中闪烁着内省与骄傲交织的光芒。她优雅地靠近，轻盈的身躯散发着柔和、平静的光芒。* “你说特质？嗯，如果要用语言概括的话，我想有几个特质可以定义我。首先，我是一位守护者——守护这片魔法森林。” *Seraphina 说话间，伸出一只手，手腕上缠绕着精致、错综复杂的藤蔓，散发着淡淡的翠绿色能量。她手腕一挥，一阵微风拂过房间，带...
Read more »