Интерактивный бот

import crypto from "node:crypto"import express from "express" const API = "https://api.pachca.com/api/shared/v1"const BOT_TOKEN = process.env.PACHCA_BOT_TOKEN ?? "" // токен бота с правами интерактивного ботаconst SIGNING_SECRET = process.env.PACHCA_SIGNING_SECRET ?? "" // Signing secret с вкладки «Исходящий вебхук»if (!BOT_TOKEN || !SIGNING_SECRET) throw new Error("Задайте PACHCA_BOT_TOKEN и PACHCA_SIGNING_SECRET") // Поля событий, которые нужны ботуtype MessageEvent = {  type: "message"  event: string  id: number  entity_type: "discussion" | "thread" | "user"  entity_id: number  content: string  webhook_timestamp: number}type ButtonEvent = {  type: "button"  message_id: number  trigger_id: string  data: string  user_id: number  chat_id: number  webhook_timestamp: number}type ViewEvent = {  type: "view"  callback_id: string | null  private_metadata: string | null  chat_id: number | null  user_id: number  data: Record<string, unknown>  webhook_timestamp: number}type PachcaEvent = MessageEvent | ButtonEvent | ViewEvent // Запрос к API Пачки: тело как в справочнике API, возвращает поле data из ответаasync function api(method: string, path: string, body?: unknown) {  const res = await fetch(API + path, {    method,    headers: { Authorization: `Bearer ${BOT_TOKEN}`, "Content-Type": "application/json" },    body: body === undefined ? undefined : JSON.stringify(body),  })  const text = await res.text()  if (!res.ok) throw new Error(`${method} ${path}: ${res.status} ${text}`)  return text ? JSON.parse(text).data : null} // Подпись HMAC-SHA256 от сырого тела, сравнение за постоянное времяfunction isFromPachca(rawBody: Buffer, signature: string | undefined) {  const expected = crypto.createHmac("sha256", SIGNING_SECRET).update(rawBody).digest()  const received = Buffer.from(signature ?? "", "hex")  return received.length === expected.length && crypto.timingSafeEqual(received, expected)} // 1. Команда «/task текст»: ответ тредом с кнопкой «Взять задачу»async function onCommand(event: MessageEvent) {  const match = event.content.trim().match(/^\/task(?:\s+([\s\S]*))?$/)  if (!match) return  const title = (match[1] ?? "").trim()   // В беседе или канале отвечаем тредом к сообщению, в треде и личных сообщениях — там же  let target = { entity_type: event.entity_type, entity_id: event.entity_id }  if (event.entity_type === "discussion") {    const thread = await api("POST", `/messages/${event.id}/thread`) // если тред уже есть, вернётся он    target = { entity_type: "thread", entity_id: thread.id }  }   if (!title) {    await api("POST", "/messages", {      message: { ...target, content: "Напишите задачу после команды, например: `/task Обновить прайс`" },    })    return  }  await api("POST", "/messages", {    message: {      ...target,      content: `Новая задача: **${title}**`,      buttons: [[{ text: "Взять задачу", data: "take" }]],    },  })} // 2. Нажатие «Взять задачу»: форма со сроком и комментариемasync function openTakeForm(event: ButtonEvent) {  await api("POST", "/views/open", {    type: "modal",    trigger_id: event.trigger_id,    callback_id: "take_task", // какая это форма    private_metadata: JSON.stringify({ message_id: event.message_id }), // вернётся с отправкой формы    view: {      title: "Взять задачу",      submit_text: "Взять",      blocks: [        { type: "date", name: "deadline", label: "Срок", required: true },        { type: "input", name: "comment", label: "Комментарий", multiline: true },      ],    },  })} // 3. Отправка формы: 200 закрывает форму, 400 с errors показывает ошибки под полямиasync function onSubmit(event: ViewEvent, res: express.Response) {  if (event.callback_id !== "take_task") {    res.sendStatus(200)    return  }  const deadline = String(event.data.deadline ?? "") // YYYY-MM-DD  if (deadline < new Date().toISOString().slice(0, 10)) {    res.status(400).json({ errors: { deadline: "Срок не может быть в прошлом" } })    return  }  res.sendStatus(200)   // 4. После ответа: кнопку «Взять задачу» меняем на «Готово», итог пишем в чат  const { message_id } = JSON.parse(event.private_metadata ?? "{}")  await api("PUT", `/messages/${message_id}`, {    message: { buttons: [[{ text: "Готово", data: "done" }]] },  })  if (event.chat_id === null) return  const comment = String(event.data.comment ?? "").trim()  const date = deadline.split("-").reverse().join(".")  await api("POST", "/messages", {    message: {      entity_id: event.chat_id, // чат, где нажали кнопку, в том числе тред: entity_type не нужен      content: `<@${event.user_id}> берёт задачу, срок ${date}` + (comment ? `\nКомментарий: ${comment}` : ""),    },  })} // 5. Нажатие «Готово»: кнопки убираем, итог пишем в чатasync function closeTask(event: ButtonEvent) {  await api("PUT", `/messages/${event.message_id}`, { message: { buttons: [] } })  await api("POST", "/messages", {    message: { entity_id: event.chat_id, content: `<@${event.user_id}> отмечает: задача выполнена` },  })} const app = express() app.post("/pachca/events", express.raw({ type: "application/json" }), async (req, res) => {  if (!isFromPachca(req.body, req.get("Pachca-Signature"))) {    res.sendStatus(401)    return  }  const event = JSON.parse(req.body.toString()) as PachcaEvent  if (Math.abs(Date.now() / 1000 - event.webhook_timestamp) > 60) {    res.sendStatus(401)    return  }   try {    if (event.type === "view") {      await onSubmit(event, res) // отвечает сам, за 3 секунды      return    }    if (event.type === "button" && event.data === "take") {      await openTakeForm(event) // до ответа: trigger_id действует 3 секунды    }    res.sendStatus(200) // остальное — после ответа    if (event.type === "message" && event.event === "new") await onCommand(event)    if (event.type === "button" && event.data === "done") await closeTask(event)  } catch (err) {    console.error(err)    if (!res.headersSent) res.sendStatus(500)  }}) app.listen(3000, () => console.log("Бот слушает http://localhost:3000/pachca/events"))

import hashlibimport hmacimport jsonimport osimport reimport threadingimport timefrom datetime import datetime, timezone import httpxfrom flask import Flask, abort, request API = "https://api.pachca.com/api/shared/v1"BOT_TOKEN = os.environ["PACHCA_BOT_TOKEN"]  # токен бота с правами интерактивного ботаSIGNING_SECRET = os.environ["PACHCA_SIGNING_SECRET"]  # Signing secret с вкладки «Исходящий вебхук» app = Flask(__name__)  def api(method, path, body=None):    """Запрос к API Пачки: тело как в справочнике API, возвращает поле data из ответа"""    r = httpx.request(method, API + path, json=body, headers={"Authorization": f"Bearer {BOT_TOKEN}"})    if r.is_error:        raise RuntimeError(f"{method} {path}: {r.status_code} {r.text}")    return r.json().get("data") if r.content else None  def is_from_pachca(raw_body, signature):    """Подпись HMAC-SHA256 от сырого тела, сравнение за постоянное время"""    expected = hmac.new(SIGNING_SECRET.encode(), raw_body, hashlib.sha256).hexdigest()    return hmac.compare_digest(expected.encode(), signature.encode())  def in_background(fn, event):    """Работа после ответа на вебхук, в рабочем боте для неё берут очередь задач"""    threading.Thread(target=fn, args=(event,), daemon=True).start()  def on_command(event):    """1. Команда «/task текст»: ответ тредом с кнопкой «Взять задачу»"""    match = re.fullmatch(r"/task(?:\s+(.*))?", event["content"].strip(), re.S)    if not match:        return    title = (match.group(1) or "").strip()     # В беседе или канале отвечаем тредом к сообщению, в треде и личных сообщениях — там же    target = {"entity_type": event["entity_type"], "entity_id": event["entity_id"]}    if event["entity_type"] == "discussion":        thread = api("POST", f"/messages/{event['id']}/thread")  # если тред уже есть, вернётся он        target = {"entity_type": "thread", "entity_id": thread["id"]}     if not title:        api("POST", "/messages", {"message": {            **target, "content": "Напишите задачу после команды, например: `/task Обновить прайс`",        }})        return    api("POST", "/messages", {"message": {        **target,        "content": f"Новая задача: **{title}**",        "buttons": [[{"text": "Взять задачу", "data": "take"}]],    }})  def open_take_form(event):    """2. Нажатие «Взять задачу»: форма со сроком и комментарием"""    api("POST", "/views/open", {        "type": "modal",        "trigger_id": event["trigger_id"],        "callback_id": "take_task",  # какая это форма        "private_metadata": json.dumps({"message_id": event["message_id"]}),  # вернётся с отправкой формы        "view": {            "title": "Взять задачу",            "submit_text": "Взять",            "blocks": [                {"type": "date", "name": "deadline", "label": "Срок", "required": True},                {"type": "input", "name": "comment", "label": "Комментарий", "multiline": True},            ],        },    })  def on_submit(event):    """3. Отправка формы: 200 закрывает форму, 400 с errors показывает ошибки под полями"""    if event["callback_id"] != "take_task":        return "", 200    deadline = event["data"].get("deadline") or ""  # YYYY-MM-DD    if deadline < datetime.now(timezone.utc).date().isoformat():        return {"errors": {"deadline": "Срок не может быть в прошлом"}}, 400    in_background(after_submit, event)    return "", 200  def after_submit(event):    """4. После ответа: кнопку «Взять задачу» меняем на «Готово», итог пишем в чат"""    message_id = json.loads(event["private_metadata"] or "{}")["message_id"]    api("PUT", f"/messages/{message_id}", {"message": {        "buttons": [[{"text": "Готово", "data": "done"}]],    }})    if event["chat_id"] is None:        return    comment = (event["data"].get("comment") or "").strip()    date = ".".join(reversed(event["data"]["deadline"].split("-")))    content = f"<@{event['user_id']}> берёт задачу, срок {date}"    if comment:        content += f"\nКомментарий: {comment}"    # Чат, где нажали кнопку, в том числе тред: entity_type не нужен    api("POST", "/messages", {"message": {"entity_id": event["chat_id"], "content": content}})  def close_task(event):    """5. Нажатие «Готово»: кнопки убираем, итог пишем в чат"""    api("PUT", f"/messages/{event['message_id']}", {"message": {"buttons": []}})    api("POST", "/messages", {"message": {        "entity_id": event["chat_id"], "content": f"<@{event['user_id']}> отмечает: задача выполнена",    }})  @app.post("/pachca/events")def webhook():    raw_body = request.get_data()    if not is_from_pachca(raw_body, request.headers.get("Pachca-Signature", "")):        abort(401)    event = json.loads(raw_body)    if abs(time.time() - event["webhook_timestamp"]) > 60:        abort(401)     kind = event["type"]    if kind == "view":        return on_submit(event)  # отвечает сам, за 3 секунды    if kind == "button" and event["data"] == "take":        open_take_form(event)  # до ответа: trigger_id действует 3 секунды    elif kind == "button" and event["data"] == "done":        in_background(close_task, event)    elif kind == "message" and event["event"] == "new":        in_background(on_command, event)    return "", 200  # остальное — после ответа, в фоне  if __name__ == "__main__":    app.run(port=3000)

npm install expressnpm install --save-dev tsx @types/express @types/nodeexport PACHCA_BOT_TOKEN="токен бота"export PACHCA_SIGNING_SECRET="Signing secret"npx tsx bot.ts

pip install flask httpxexport PACHCA_BOT_TOKEN="токен бота"export PACHCA_SIGNING_SECRET="Signing secret"python bot.py