Power Automate

Obtén el contenido del ficheroCopy Anchor Link

Después del desencadenador, añade SharePoint → Get file content con File Identifier igual al Identifier del desencadenador. La acción se llamará Get_file_content en las expresiones.

Añade la acción HTTPCopy Anchor Link

Y como Body:

{
  "file_base64": "@{base64(body('Get_file_content'))}",
  "filename": "@{triggerOutputs()?['body/{FilenameWithExtension}']}",
  "options": {
    "expect": "invoice",
    "export": ["xlsx"],
    "language": "es",
    "metadata": { "source": "power-automate" }
  }
}

La cabecera Idempotency-Key usa el identificador de la ejecución: si la acción HTTP reintenta por su política de reintentos, Constaia devuelve la respuesta guardada sin cobrar dos veces. Más en Idempotencia. Las opciones están en POST /v1/analyze.

Comprueba el código de estadoCopy Anchor Link

Si el análisis no termina en 30 s (PDFs largos), la API responde 202 con status: "queued" o "processing" y sin veredicto. Añade una Condition con @{outputs('HTTP')?['statusCode']} igual a 200 antes de seguir, o usa "async": true y recibe el resultado por webhook (más abajo).

Los errores (4xx, 5xx) hacen fallar la acción HTTP. Para tratarlos, añade una rama con Configure run after → has failed y lee body('HTTP')?['error']?['code'] y body('HTTP')?['error']?['request_id']. Los códigos están en Errores.

Analiza la respuesta con Parse JSONCopy Anchor Link

Añade Parse JSON con Content @{body('HTTP')} y este esquema (solo la parte que usas; las propiedades que no declares siguen disponibles en body('HTTP')):

{
  "type": "object",
  "properties": {
    "id": { "type": "string" },
    "status": { "type": "string" },
    "document": {
      "type": ["object", "null"],
      "properties": {
        "type": { "type": "string" },
        "label": { "type": "string" },
        "confidence": { "type": "number" }
      }
    },
    "verdict": {
      "type": ["object", "null"],
      "properties": {
        "status": { "type": "string" },
        "reasons": {
          "type": "array",
          "items": {
            "type": "object",
            "properties": {
              "code": { "type": "string" },
              "severity": { "type": "string" },
              "message": { "type": "string" }
            }
          }
        }
      }
    },
    "fields": { "type": "object" },
    "warnings": { "type": "array", "items": { "type": "string" } },
    "exports": { "type": "object" }
  }
}

Enruta con un SwitchCopy Anchor Link

Añade un Switch sobre @{body('Parse_JSON')?['verdict']?['status']} con tres casos:

Cada campo extraído es un objeto con value, confidence, validated y source. Más en Veredictos y Exportaciones.

Crea el flujo receptorCopy Anchor Link

Crea un flujo con el desencadenador When a HTTP request is received. En Who can trigger the flow? elige Anyone (Constaia no se autentica en Microsoft Entra) y usa como Request Body JSON Schema:

{
  "type": "object",
  "properties": {
    "type": { "type": "string" },
    "created_at": { "type": "string" },
    "data": { "type": "object", "properties": { "id": { "type": "string" } } }
  }
}

Guarda el flujo, copia la URL generada y regístrala en el panel o con POST /v1/webhook-endpoints (ver Webhooks). Si el flujo no tiene una acción Response, el desencadenador responde 202 Accepted de inmediato, lo que Constaia cuenta como entrega correcta.

Vuelve a leer el análisisCopy Anchor Link

Power Automate no tiene una función para calcular el HMAC-SHA256 de la firma, así que no te fíes del cuerpo del evento:

1. Condition: @{startsWith(triggerBody()?['data']?['id'], 'an_')} es true.
2. HTTP GET a https://api.constaia.com/v1/analyses/@{triggerBody()?['data']?['id']} con la cabecera Authorization.
3. Parse JSON con el esquema de arriba y el mismo Switch.

La API solo devuelve análisis de tu cuenta: un evento falsificado como mucho te hace releer un análisis tuyo. Para batch.completed, data.id empieza por bat_ y la lectura es GET /v1/batches/{id}.

Descarta duplicadosCopy Anchor Link

Constaia reintenta las entregas fallidas durante unos 3 días con el mismo webhook-id, disponible en @{triggerOutputs()?['headers']?['webhook-id']}. Guárdalo (por ejemplo, en una lista de SharePoint o una tabla de Dataverse) y termina el flujo si ya existe.