Pesquisa Prévia de Bens

// Execute somente no backend (Node.js 22+). Configure o token no servidor.
// const pedido = await consultarOficialData(process.env.OFICIALDATA_TOKEN, dados);
// Guarde pedido.protocolo. Depois use acompanharOficialData(token, pedido.protocolo).
// Cada POST inicia uma nova consulta, mesmo com dados iguais.
// Resposta perdida: confira o histórico antes de reenviar; outro POST é outro pedido.

export async function consultarOficialData(token, dados = {"cpf_cnpj":"12345678000190","uf":"SP","nome":"EMPRESA EXEMPLO LTDA","imovel_finalidade":2}) {
  const corpo = await enviar(token, "https://api.oficialdata.com.br/v1/consultas/pesquisa-previa-bens", dados);
  const protocolo = corpo.data?.[0]?.protocolo;
  if (corpo.code !== 202 || !protocolo) throw new Error(JSON.stringify(corpo));
  return { protocolo: String(protocolo), resposta: corpo };
}

export async function acompanharOficialData(token, protocolo) {
  if (!/^\d+$/.test(String(protocolo))) throw new Error('Informe o protocolo recebido.');
  const corpo = await enviar(token, "https://api.oficialdata.com.br" + '/v1/consultas/' + encodeURIComponent(protocolo));
  // code 202: aguarde intervalo_consulta_segundos e consulte novamente por GET.
  // code 200/6xx: confira o resultado. Não repita o POST para acompanhar.
  return { protocolo: String(protocolo), resposta: corpo };
}

async function enviar(token, url, dados) {
  if (!token) throw new Error('Informe o token de acesso.');
  const post = dados !== undefined;
  const resposta = await fetch(url, {
    method: post ? 'POST' : 'GET',
    headers: {
      Authorization: 'Bearer ' + token, Accept: 'application/json',
      ...(post && { 'Content-Type': 'application/json' }),
    },
    ...(post && { body: JSON.stringify(dados) }),
    signal: AbortSignal.timeout(30000),
  });
  const corpo = await resposta.json();
  // Não repita POST automaticamente após timeout: o pedido pode ter sido aceito.
  if (!resposta.ok) throw new Error('HTTP ' + resposta.status + ': ' + JSON.stringify(corpo));
  return corpo;
}

<?php

// Salve como oficialdata.php no backend Laravel. Configure o token no servidor.
// $consultar = require base_path('oficialdata.php');
// $pedido = $consultar(config('services.oficialdata.token'), $dados);
// Guarde $pedido['protocolo']; acompanhe com $consultar($token, null, $protocolo).
// Cada POST inicia uma nova consulta, mesmo com dados iguais.
// Resposta perdida: confira o histórico antes de reenviar; outro POST é outro pedido.
use Illuminate\Support\Facades\Http;

return function (string $token, ?array $dados = null, ?string $protocolo = null): array {
    if ($token === '') {
        throw new RuntimeException('Informe o token de acesso.');
    }
    $http = Http::withToken($token)->acceptJson()->timeout(30);
    if ($protocolo !== null) {
        if (! ctype_digit($protocolo)) {
            throw new RuntimeException('Informe o protocolo recebido.');
        }
        $resposta = $http->get("https://api.oficialdata.com.br".'/v1/consultas/'.rawurlencode($protocolo));
    } else {
        $dados ??= json_decode('{"cpf_cnpj":"12345678000190","uf":"SP","nome":"EMPRESA EXEMPLO LTDA","imovel_finalidade":2}', true, flags: JSON_THROW_ON_ERROR);
        $resposta = $http->post("https://api.oficialdata.com.br/v1/consultas/pesquisa-previa-bens", $dados);
    }
    // Não repita POST automaticamente após timeout: o pedido pode ter sido aceito.
    $resposta->throw();
    $corpo = $resposta->json();
    if ($protocolo === null) {
        $protocolo = $corpo['data'][0]['protocolo'] ?? null;
        if (($corpo['code'] ?? null) !== 202 || ! $protocolo) {
            throw new RuntimeException(json_encode($corpo, JSON_THROW_ON_ERROR));
        }
    }

    // code 202: aguarde intervalo_consulta_segundos e faça GET; code 200/6xx: leia o resultado.
    return ['protocolo' => (string) $protocolo, 'resposta' => $corpo];
};

{
    "code": 202,
    "code_message": "Consulta aceita e em execução.",
    "header": {
        "billable": true,
        "price": 12.19,
        "api_version": "v1"
    },
    "data_count": 1,
    "data": [
        {
            "protocolo": "4713",
            "estado": "processando",
            "consultar_em": "/v1/consultas/4713",
            "intervalo_consulta_segundos": 10
        }
    ],
    "site_receipts": [],
    "errors": []
}