Сводка из 1С в чат Битрикс24

curl -s -H "X-Api-Key: $VIBE_API_KEY" "$VIBE_URL/v1/onec/instances"

const res = await fetch(`${VIBE_URL}/v1/onec/instances`, {
  headers: { 'X-Api-Key': VIBE_API_KEY },
})
const { data } = await res.json()
const base = data.instances[0]

{
  "success": true,
  "data": {
    "instances": [
      {
        "instanceId": "3f2b8c1e-5d4a-4e7b-9c10-2a6f8d9e0b41",
        "name": "Бухгалтерия",
        "status": "ONLINE"
      }
    ]
  }
}

curl -s -H "X-Api-Key: $VIBE_API_KEY" \
  "$VIBE_URL/v1/onec/tools?instanceId=3f2b8c1e-5d4a-4e7b-9c10-2a6f8d9e0b41"

const res = await fetch(`${VIBE_URL}/v1/onec/tools?instanceId=${base.instanceId}`, {
  headers: { 'X-Api-Key': VIBE_API_KEY },
})
const { data: catalog } = await res.json()
for (const tool of catalog.tools) console.log(tool.method, '—', tool.title)

{
  "success": true,
  "data": {
    "loaded": true,
    "revision": "18",
    "updatedAt": "2026-09-08T12:00:00.000Z",
    "stale": false,
    "advertisedVersion": "18",
    "appliedVersion": "18",
    "tools": [
      {
        "method": "bank.list",
        "title": "Банки",
        "description": "Список банков",
        "inputSchema": {
          "type": "object",
          "additionalProperties": false,
          "properties": {
            "columns": {
              "type": "array",
              "items": { "type": "string", "enum": ["Код", "Наименование"] },
              "maxItems": 200,
              "uniqueItems": true
            },
            "limit": { "type": "integer", "minimum": 1, "maximum": 10000, "default": 1000 },
            "offset": { "type": "integer", "minimum": 0, "default": 0 }
          }
        }
      }
    ]
  }
}

curl -s -X POST -H "X-Api-Key: $VIBE_API_KEY" -H "Content-Type: application/json" \
  "$VIBE_URL/v1/onec/tools/bank.list/call?instanceId=3f2b8c1e-5d4a-4e7b-9c10-2a6f8d9e0b41" \
  -d '{ "columns": ["Код", "Наименование"], "limit": 1000, "offset": 0 }'

const res = await fetch(
  `${VIBE_URL}/v1/onec/tools/${encodeURIComponent('bank.list')}/call?instanceId=${base.instanceId}`,
  {
    method: 'POST',
    headers: { 'X-Api-Key': VIBE_API_KEY, 'Content-Type': 'application/json' },
    body: JSON.stringify({ columns: ['Код', 'Наименование'], limit: 1000, offset: 0 }),
  },
)
const { data: queued } = await res.json()

{
  "success": true,
  "data": {
    "operationId": "cl9x2k4t70000qz8h3m1vb7ry",
    "status": "pending",
    "expiresAt": "2026-09-14T12:15:00.000Z"
  }
}

curl -s -H "X-Api-Key: $VIBE_API_KEY" \
  "$VIBE_URL/v1/onec/operations/cl9x2k4t70000qz8h3m1vb7ry"

async function waitFor(operationId) {
  let delay = 1000
  for (;;) {
    const res = await fetch(`${VIBE_URL}/v1/onec/operations/${operationId}`, {
      headers: { 'X-Api-Key': VIBE_API_KEY },
    })
    const { data } = await res.json()
    if (data.status === 'succeeded') return data.result
    if (data.status === 'failed') throw new Error(`1С отказала: ${data.error.code}`)
    if (data.status === 'cancelled' || data.status === 'expired') throw new Error(`операция ${data.status}`)
    await new Promise(resolve => setTimeout(resolve, delay))
    delay = Math.min(delay * 2, 5000)
  }
}

{
  "success": true,
  "data": {
    "operationId": "cl9x2k4t70000qz8h3m1vb7ry",
    "type": "getData",
    "status": "succeeded",
    "createdAt": "2026-09-14T12:00:00.000Z",
    "finishedAt": "2026-09-14T12:00:04.000Z",
    "expiresAt": "2026-09-14T12:15:00.000Z",
    "result": {
      "columns": ["Код", "Наименование"],
      "rows": [
        { "Код": "000012", "Наименование": "Банк Север" },
        { "Код": "000013", "Наименование": "Банк Юг" }
      ],
      "truncated": true,
      "nextOffset": 2
    }
  }
}

curl -s -X POST -H "X-Api-Key: $VIBE_API_KEY" -H "Content-Type: application/json" \
  "$VIBE_URL/v1/chats/me/messages" \
  -d '{ "message": "[b]Банки — Бухгалтерия[/b]\nСтрок: 2\n\n000012 · Банк Север\n000013 · Банк Юг" }'

const lines = rows.map(row => columns.map(c => row[c] ?? '').join(' · '))
await fetch(`${VIBE_URL}/v1/chats/me/messages`, {
  method: 'POST',
  headers: { 'X-Api-Key': VIBE_API_KEY, 'Content-Type': 'application/json' },
  body: JSON.stringify({
    message: `[b]${tool.title} — ${base.name}[/b]\nСтрок: ${rows.length}\n\n${lines.join('\n')}`,
  }),
})

{
  "success": true,
  "data": 36889
}

{
  "success": false,
  "error": {
    "code": "ONEC_NOT_CONNECTED",
    "message": "There is no 1C connection."
  }
}

// onec-to-chat.js — сводка из 1С в чат Битрикс24
//
// Запуск: VIBE_API_KEY=… ONEC_METHOD=bank.list node onec-to-chat.js
// Без ONEC_METHOD скрипт печатает каталог команд базы и выходит.
const VIBE_URL = process.env.VIBE_URL ?? 'https://vibecode.bitrix24.tech'
const VIBE_API_KEY = process.env.VIBE_API_KEY
if (!VIBE_API_KEY) throw new Error('Переменная окружения VIBE_API_KEY не задана')

const ONEC_INSTANCE_ID = process.env.ONEC_INSTANCE_ID ?? null   // база 1С, если их несколько
const ONEC_METHOD = process.env.ONEC_METHOD ?? null             // команда из каталога
const ONEC_COLUMNS = process.env.ONEC_COLUMNS?.split(',').map(s => s.trim()).filter(Boolean) ?? null
const ONEC_FILTERS = process.env.ONEC_FILTERS ? JSON.parse(process.env.ONEC_FILTERS) : null
const DIALOG_ID = process.env.DIALOG_ID ?? 'me'                 // me — ваш собственный чат
const PAGE = 1000
const MAX_ROWS = Number(process.env.MAX_ROWS ?? 1000)           // сколько строк читать всего
const MAX_LINES = 50                                            // сколько строк класть в сообщение
const MESSAGE_LIMIT = 20000

const headers = { 'X-Api-Key': VIBE_API_KEY, 'Content-Type': 'application/json' }
const sleep = ms => new Promise(resolve => setTimeout(resolve, ms))

// Любой 429 значит «запрос не принят» — повторять безопасно. Пауза из Retry-After,
// без него — растущая. Остальные отказы поднимаются с кодом ошибки.
async function api(path, init = {}) {
  for (let attempt = 0; ; attempt++) {
    const res = await fetch(`${VIBE_URL}${path}`, { ...init, headers })
    const body = await res.json().catch(() => null)
    if (res.status === 429 && attempt < 5) {
      const advised = Number(res.headers.get('Retry-After'))
      await sleep((Number.isFinite(advised) && advised > 0 ? Math.min(advised, 60) : 2 ** attempt) * 1000)
      continue
    }
    if (!body?.success) {
      const code = body?.error?.code ?? res.status
      throw new Error(`${path}: ${code} ${body?.error?.message ?? ''}`.trim())
    }
    return body.data
  }
}

async function pickBase() {
  const { instances } = await api('/v1/onec/instances')
  if (instances.length === 0) throw new Error('Ни одна база 1С ещё не подключилась')
  if (ONEC_INSTANCE_ID) {
    const base = instances.find(b => b.instanceId === ONEC_INSTANCE_ID)
    if (!base) throw new Error(`Базы ${ONEC_INSTANCE_ID} нет в списке подключённых`)
    return base
  }
  if (instances.length > 1) {
    const list = instances.map(b => `  ${b.instanceId}  ${b.name ?? 'без названия'}  ${b.status}`).join('\n')
    throw new Error(`Подключено несколько баз — задайте ONEC_INSTANCE_ID:\n${list}`)
  }
  return instances[0]
}

async function pickTool(query) {
  const catalog = await api(`/v1/onec/tools${query}`)
  if (!catalog.loaded) throw new Error('База ещё не прислала каталог команд — администратору нужно его загрузить')
  if (!ONEC_METHOD) {
    console.log('Команды базы:')
    for (const t of catalog.tools) console.log(`  ${t.method} — ${t.title}`)
    return null
  }
  const tool = catalog.tools.find(t => t.method === ONEC_METHOD)
  if (!tool) throw new Error(`Команды ${ONEC_METHOD} нет в каталоге базы`)
  const allowed = tool.inputSchema?.properties?.columns?.items?.enum ?? []
  const unknown = (ONEC_COLUMNS ?? []).filter(c => !allowed.includes(c))
  if (unknown.length > 0) throw new Error(`Колонок нет в команде: ${unknown.join(', ')}. Доступны: ${allowed.join(', ')}`)
  return tool
}

async function waitFor(operationId) {
  let delay = 1000
  for (;;) {
    const op = await api(`/v1/onec/operations/${operationId}`)
    if (op.status === 'succeeded') return op.result
    if (op.status === 'failed') throw new Error(`1С отказала: ${op.error?.code} ${op.error?.message ?? ''}`)
    if (op.status === 'cancelled') throw new Error('Операция отменена: отключение 1С, смена настроек или потеря доступа')
    if (op.status === 'expired') throw new Error('1С не прислала данные до expiresAt — проверьте, что база в сети')
    await sleep(delay)
    delay = Math.min(delay * 2, 5000)
  }
}

// more — у 1С остались строки сверх MAX_ROWS: в сводке это отмечается знаком «+».
async function readRows(tool, query) {
  const rows = []
  let columns = []
  let offset = 0
  for (;;) {
    const body = {
      ...(ONEC_COLUMNS ? { columns: ONEC_COLUMNS } : {}),
      ...(ONEC_FILTERS ? { filters: ONEC_FILTERS } : {}),
      limit: Math.min(PAGE, MAX_ROWS - rows.length),
      offset,
    }
    const queued = await api(`/v1/onec/tools/${encodeURIComponent(tool.method)}/call${query}`, {
      method: 'POST',
      body: JSON.stringify(body),
    })
    const result = await waitFor(queued.operationId)
    columns = result.columns
    rows.push(...result.rows)
    const hasNext = result.truncated && result.nextOffset !== null && result.rows.length > 0
    if (!hasNext) return { columns, rows, more: false }
    if (rows.length >= MAX_ROWS) return { columns, rows, more: true }
    offset = result.nextOffset
  }
}

function buildMessage(tool, base, { columns, rows, more }) {
  const head = `[b]${tool.title} — ${base.name ?? 'база 1С'}[/b]\nСтрок: ${rows.length}${more ? '+' : ''}\n`
  const lines = rows.slice(0, MAX_LINES).map(row => columns.map(c => row[c] ?? '').join(' · '))
  let text = `${head}\n${lines.join('\n')}`
  const rest = rows.length - lines.length
  if (rest > 0 || more) text += `\n\n…и ещё ${rest}${more ? '+' : ''}`
  return text.length > MESSAGE_LIMIT ? `${text.slice(0, MESSAGE_LIMIT - 1)}…` : text
}

async function main() {
  const base = await pickBase()
  const query = `?instanceId=${encodeURIComponent(base.instanceId)}`
  const tool = await pickTool(query)
  if (!tool) return

  const data = await readRows(tool, query)
  const message = buildMessage(tool, base, data)
  const messageId = await api(`/v1/chats/${encodeURIComponent(DIALOG_ID)}/messages`, {
    method: 'POST',
    body: JSON.stringify({ message }),
  })
  console.log(`Отправлено сообщение ${messageId}: ${data.rows.length} строк из «${tool.title}»`)
}

main().catch(error => {
  console.error(error.message)
  process.exitCode = 1
})