Первый бот

curl -X POST https://api.pachca.com/api/shared/v1/messages \  -H "Authorization: Bearer $PACHCA_BOT_TOKEN" \  -H "Content-Type: application/json" \  -d '{    "message": {      "entity_type": "discussion",      "entity_id": 12345,      "content": "Привет! Ответьте в треде под этим сообщением, и я отвечу"    }  }'

const API = "https://api.pachca.com/api/shared/v1" async function sendMessage(chatId: number, content: string) {  const response = await fetch(`${API}/messages`, {    method: "POST",    headers: {      Authorization: `Bearer ${process.env.PACHCA_BOT_TOKEN}`,      "Content-Type": "application/json",    },    body: JSON.stringify({ message: { entity_type: "discussion", entity_id: chatId, content } }),  })  if (!response.ok) throw new Error(`${response.status}: ${await response.text()}`)  return (await response.json()).data // объект сообщения} sendMessage(12345, "Привет! Ответьте в треде под этим сообщением, и я отвечу").then((message) => {  console.log("id сообщения:", message.id)})

import os import httpx response = httpx.post(    "https://api.pachca.com/api/shared/v1/messages",    headers={"Authorization": f"Bearer {os.environ['PACHCA_BOT_TOKEN']}"},    json={        "message": {            "entity_type": "discussion",            "entity_id": 12345,            "content": "Привет! Ответьте в треде под этим сообщением, и я отвечу",        }    },)response.raise_for_status()message = response.json()["data"]  # объект сообщенияprint("id сообщения:", message["id"])

import crypto from "node:crypto"import express from "express" const API = "https://api.pachca.com/api/shared/v1"const TOKEN = process.env.PACHCA_BOT_TOKEN ?? "" // токен ботаconst SIGNING_SECRET = process.env.PACHCA_SIGNING_SECRET ?? "" // Signing secret с вкладки «Исходящий вебхук»if (!TOKEN) throw new Error("Задайте PACHCA_BOT_TOKEN") // Запрос к API Пачки: возвращает поле data из ответаasync function api(method: string, path: string, body?: unknown) {  const response = await fetch(`${API}${path}`, {    method,    headers: { Authorization: `Bearer ${TOKEN}`, "Content-Type": "application/json" },    body: body === undefined ? undefined : JSON.stringify(body),  })  if (!response.ok) throw new Error(`${method} ${path}: ${response.status} ${await response.text()}`)  return response.status === 204 ? null : (await response.json()).data} type PachcaEvent = {  type: string  event: string  id: number  entity_type: "discussion" | "thread" | "user"  entity_id: number  user_id: number} let botId: number | undefined // id бота, узнаём методом «Свой профиль» при первом событии async function handleEvent(event: PachcaEvent) {  if (event.type !== "message" || event.event !== "new") return  botId ??= (await api("GET", "/profile")).id  if (event.user_id === botId) return // своё сообщение   // Из беседы или канала отвечаем тредом под сообщением, из треда и личных сообщений — туда же  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 }  }  await api("POST", "/messages", { message: { ...target, content: "Получил ваше сообщение, разбираюсь" } })} const app = express() // express.raw: подпись считают от сырого тела запросаapp.post("/webhook", express.raw({ type: "application/json" }), (req, res) => {  const expected = crypto.createHmac("sha256", SIGNING_SECRET).update(req.body).digest()  const received = Buffer.from(String(req.headers["pachca-signature"] ?? ""), "hex")  if (!SIGNING_SECRET || received.length !== expected.length || !crypto.timingSafeEqual(received, expected)) {    return res.status(401).end() // секрет не задан или подпись не совпала: запрос не принимаем  }   const event = JSON.parse(req.body.toString())  if (Math.abs(Date.now() / 1000 - event.webhook_timestamp) > 60) {    return res.status(401).end() // запрос старше минуты: его могли перехватить и отправить повторно  }   res.status(200).end() // отвечаем сразу, а сообщение отправляем после ответа  handleEvent(event).catch(console.error)}) app.listen(3000)

npm install expressexport PACHCA_BOT_TOKEN="токен бота" PACHCA_SIGNING_SECRET="Signing secret"npx tsx bot.ts

import hashlibimport hmacimport jsonimport osimport threadingimport time import httpxfrom flask import Flask, request API = "https://api.pachca.com/api/shared/v1"HEADERS = {"Authorization": f"Bearer {os.environ['PACHCA_BOT_TOKEN']}"}  # токен ботаSIGNING_SECRET = os.environ.get("PACHCA_SIGNING_SECRET", "")  # Signing secret с вкладки «Исходящий вебхук»  def api(method, path, body=None):    """Запрос к API Пачки: возвращает поле data из ответа."""    response = httpx.request(method, API + path, headers=HEADERS, json=body)    response.raise_for_status()    return response.json()["data"] if response.content else None  bot_id = None  # id бота, узнаём методом «Свой профиль» при первом событии  def handle_event(event):    global bot_id    if event["type"] != "message" or event["event"] != "new":        return    if bot_id is None:        bot_id = api("GET", "/profile")["id"]    if event["user_id"] == bot_id:        return  # своё сообщение     # Из беседы или канала отвечаем тредом под сообщением, из треда и личных сообщений — туда же    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"]}    api("POST", "/messages", {"message": {**target, "content": "Получил ваше сообщение, разбираюсь"}})  app = Flask(__name__)  @app.post("/webhook")def webhook():    raw_body = request.get_data()  # подпись считают от сырого тела запроса    expected = hmac.new(SIGNING_SECRET.encode(), raw_body, hashlib.sha256).hexdigest()    received = request.headers.get("Pachca-Signature", "")    if not SIGNING_SECRET or not hmac.compare_digest(expected.encode(), received.encode()):        return "", 401  # секрет не задан или подпись не совпала: запрос не принимаем     event = json.loads(raw_body)    if abs(time.time() - event["webhook_timestamp"]) > 60:        return "", 401  # запрос старше минуты: его могли перехватить и отправить повторно     # Отвечаем сразу, а сообщение отправляем в фоне    threading.Thread(target=handle_event, args=(event,)).start()    return "", 200  if __name__ == "__main__":    app.run(port=3000)

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

import { EventSource } from "eventsource" api("GET", "/webhooks/events/stream").then(({ url }) => {  const stream = new EventSource(url)  // Событие бота приходит сообщением без имени: запись истории с id, event_type, payload и created_at  stream.addEventListener("message", (e) => {    const record = JSON.parse(e.data)    handleEvent(record.payload)      .then(() => api("DELETE", `/webhooks/events/${record.id}`)) // обработанное событие убираем из истории      .catch(console.error)  })})

from httpx_sse import connect_sse  def listen():    stream = api("GET", "/webhooks/events/stream")  # ссылка на поток и срок её действия    with httpx.Client(timeout=None) as client, connect_sse(client, "GET", stream["url"]) as source:        for sse in source.iter_sse():            if sse.event != "message":                continue  # служебные сообщения подключения            record = sse.json()  # запись истории событий: id, event_type, payload, created_at            handle_event(record["payload"])            api("DELETE", f"/webhooks/events/{record['id']}")  # обработанное событие убираем из истории  if __name__ == "__main__":    listen()