Integrar com Bling, Tiny, n8n, Zapier, Make e WooCommerce

// integracao.mjs: recebe o aviso "integracao.documentos" (DANFE gerado a partir do Bling ou do Tiny) e baixa os PDFs
// npm install express; node integracao.mjs
import crypto from 'node:crypto';
import { writeFile } from 'node:fs/promises';
import express from 'express';

const SEGREDO = process.env.CONVERTAJA_WEBHOOK_SECRET; // whsec_…, em Minha conta → API (o mesmo dos webhooks da API)

function assinaturaValida(corpoCru, cabecalho, segredo, toleranciaSeg = 300) {
  const partes = Object.fromEntries(String(cabecalho || '').split(',').map((p) => p.split('=')));
  const t = Number(partes.t);
  if (!t || !partes.v1 || Math.abs(Date.now() / 1000 - t) > toleranciaSeg) return false;
  const esperado = crypto.createHmac('sha256', segredo).update(`${t}.${corpoCru}`).digest('hex');
  const a = Buffer.from(esperado);
  const b = Buffer.from(String(partes.v1));
  return a.length === b.length && crypto.timingSafeEqual(a, b);
}

const app = express();
app.post('/webhooks/convertaja', express.raw({ type: 'application/json' }), (req, res) => {
  const corpo = req.body.toString('utf8');
  if (!assinaturaValida(corpo, req.get('X-Convertaja-Signature'), SEGREDO)) return res.sendStatus(400);
  const evento = JSON.parse(corpo);
  res.sendStatus(200);
  if (evento.type === 'integracao.documentos') {
    // data: { provider: "bling" | "tiny", nota_id, numero, chave, files: [{ name, size, url }], expires_at }
    for (const f of evento.data.files) {
      fetch(f.url).then((r) => r.arrayBuffer()).then((buf) => writeFile(f.name, Buffer.from(buf))).catch(console.error);
    }
  } else if (evento.type === 'integracao.falhou') {
    console.error(`DANFE da nota ${evento.data.nota_id} (${evento.data.provider}) falhou: ${evento.data.error}`);
  }
});
app.listen(8080);

# integracao.py: recebe "integracao.documentos" (DANFE gerado a partir do Bling ou do Tiny) e baixa os PDFs
# pip install flask requests; python integracao.py
import hashlib
import hmac
import os
import time

import requests
from flask import Flask, abort, request

SEGREDO = os.environ["CONVERTAJA_WEBHOOK_SECRET"]  # whsec_…, em Minha conta → API


def assinatura_valida(corpo_cru: bytes, cabecalho: str, segredo: str, tolerancia: int = 300) -> bool:
    try:
        partes = dict(p.split("=", 1) for p in (cabecalho or "").split(","))
        t = int(partes.get("t", "0"))
    except ValueError:
        return False
    if not t or not partes.get("v1") or abs(time.time() - t) > tolerancia:
        return False
    esperado = hmac.new(segredo.encode(), f"{t}.".encode() + corpo_cru, hashlib.sha256).hexdigest()
    return hmac.compare_digest(esperado, partes["v1"])


app = Flask(__name__)


@app.post("/webhooks/convertaja")
def webhook():
    corpo = request.get_data()
    if not assinatura_valida(corpo, request.headers.get("X-Convertaja-Signature", ""), SEGREDO):
        abort(400)
    evento = request.get_json()
    if evento["type"] == "integracao.documentos":
        for f in evento["data"]["files"]:  # links válidos por 7 dias
            with open(f["name"], "wb") as out:
                out.write(requests.get(f["url"], timeout=60).content)
    elif evento["type"] == "integracao.falhou":
        print("Falhou:", evento["data"]["nota_id"], evento["data"]["error"])
    return "", 200


if __name__ == "__main__":
    app.run(port=8080)

<?php
// integracao.php: recebe "integracao.documentos" (DANFE gerado a partir do Bling ou do Tiny) e baixa os PDFs
function assinatura_valida(string $corpoCru, string $cabecalho, string $segredo, int $tolerancia = 300): bool {
  $partes = [];
  foreach (explode(',', $cabecalho) as $par) {
    [$chave, $valor] = array_pad(explode('=', $par, 2), 2, '');
    $partes[$chave] = $valor;
  }
  $t = (int) ($partes['t'] ?? 0);
  if (!$t || empty($partes['v1']) || abs(time() - $t) > $tolerancia) return false;
  return hash_equals(hash_hmac('sha256', $t . '.' . $corpoCru, $segredo), $partes['v1']);
}

$corpo = file_get_contents('php://input');
if (!assinatura_valida($corpo, $_SERVER['HTTP_X_CONVERTAJA_SIGNATURE'] ?? '', getenv('CONVERTAJA_WEBHOOK_SECRET'))) {
  http_response_code(400);
  exit;
}
$evento = json_decode($corpo, true);
if ($evento['type'] === 'integracao.documentos') {
  foreach ($evento['data']['files'] as $f) { // links válidos por 7 dias
    file_put_contents(basename($f['name']), file_get_contents($f['url']));
  }
} elseif ($evento['type'] === 'integracao.falhou') {
  error_log("DANFE da nota {$evento['data']['nota_id']} falhou: {$evento['data']['error']}");
}
http_response_code(200);

# O mesmo pedido que o nó HTTP do n8n, o Webhooks by Zapier ou o módulo HTTP do Make fazem:
# XML da nota por URL (ex.: link do ERP ou do Google Drive) → DANFE 10×15, resposta na mesma chamada
curl -X POST "https://convertaja.com.br/v1/tools/xml-nfe-para-pdf?wait=true" \
  -H "Authorization: Bearer $CONVERTAJA_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "files": [{ "url": "https://seusite.com.br/notas/4521.xml" }],
    "options": { "layout": "simplificado" }
  }'

// XML da nota por URL → DANFE 10×15 (o mesmo pedido de um fluxo no n8n, Zapier ou Make)
const res = await fetch('https://convertaja.com.br/v1/tools/xml-nfe-para-pdf?wait=true', {
  method: 'POST',
  headers: { Authorization: `Bearer ${process.env.CONVERTAJA_KEY}`, 'Content-Type': 'application/json' },
  body: JSON.stringify({
    files: [{ url: 'https://seusite.com.br/notas/4521.xml' }],
    options: { layout: 'simplificado' }, // ou "a4"
  }),
});
const job = await res.json();
console.log(job.status, job.info, job.download_url);

import os
import requests

# XML da nota por URL → DANFE 10×15 (o mesmo pedido de um fluxo no n8n, Zapier ou Make)
res = requests.post(
    "https://convertaja.com.br/v1/tools/xml-nfe-para-pdf",
    params={"wait": "true"},
    headers={"Authorization": f"Bearer {os.environ['CONVERTAJA_KEY']}"},
    json={
        "files": [{"url": "https://seusite.com.br/notas/4521.xml"}],
        "options": {"layout": "simplificado"},  # ou "a4"
    },
    timeout=90,
)
job = res.json()
print(job["status"], job.get("info"), job.get("download_url"))

<?php
// XML da nota por URL → DANFE 10×15 (ex.: num plugin WooCommerce, ao concluir o pedido)
$ch = curl_init('https://convertaja.com.br/v1/tools/xml-nfe-para-pdf?wait=true');
curl_setopt_array($ch, [
  CURLOPT_POST => true,
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_TIMEOUT => 90,
  CURLOPT_HTTPHEADER => ['Authorization: Bearer ' . getenv('CONVERTAJA_KEY'), 'Content-Type: application/json'],
  CURLOPT_POSTFIELDS => json_encode([
    'files' => [['url' => 'https://seusite.com.br/notas/4521.xml']],
    'options' => ['layout' => 'simplificado'], // ou 'a4'
  ]),
]);
$job = json_decode(curl_exec($ch), true);
echo "{$job['status']} {$job['info']} {$job['download_url']}\n";