libredte\lib\Core\Package\Billing\Component\Integration\Worker\SiiLazy\Job\ConsumeWebserviceJob::callServiceFunction()

Complexity

Conditions	9
Paths	6

Size

Total Lines	104
Code Lines	49

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	21
CRAP Score	24.8039

Importance

Changes

0

<?php
    private function callServiceFunction(
        string $wsdl,
        string $function,
        array $args,
        array $soapClientOptions,
        int $retry
    ): XmlInterface {
        // Preparar cliente SOAP.
        try {
            $soap = new SoapClient($wsdl, $soapClientOptions);
        } catch (SoapFault $e) {
            $message = $e->getMessage();
            if (
                isset($e->getTrace()[0]['args'][1])
                && is_string($e->getTrace()[0]['args'][1])
            ) {
                $message .= ': ' . $e->getTrace()[0]['args'][1];
            }
            throw new SiiConsumeWebserviceException(sprintf(
                'Ocurrió un error al crear el cliente SOAP para la API del SII con el WSDL %s. %s',
                $wsdl,
                $message
            ));
        }

        // Argumentos adicionales para la llamada al servicio web SOAP mediante
        // __soapCall().
        $options = null;

        // En el WSDL indicadas como soap:header.
        $requestHeaders = [];

        // Si el SII enviase cabeceras SOAP devuelta.
        $responseHeaders = [];

        // Para almacenar la respuesta de la llamada a la API SOAP del SII.
        $responseBody = null;

        // Para ir almacenando los errores, si existen, de cada intento.
        $errors = [];

        // Ejecutar la función que se ha solicitado del servicio web a través
        // del cliente SOAP preparado previamente.
        // Se realizarán $retry intentos de consulta. O sea, si $retry > 0 se
        // hará una consulta más $retry - 1 reintentos.
        for ($i = 0; $i < $retry; $i++) {
            try {
                // Se realiza la llamada a la función en el servicio web.
                $responseBody = $soap->__soapCall(
                    $function,
                    $args,
                    $options,
                    $requestHeaders,
                    $responseHeaders
                );
                // Si la llamada no falló (no hubo excepción), se rompe el
                // ciclo de reintentos.
                break;
            } catch (SoapFault $e) {
                $message = $e->getMessage();
                if (
                    isset($e->getTrace()[0]['args'][1])
                    && is_string($e->getTrace()[0]['args'][1])
                ) {
                    $message .= ': ' . $e->getTrace()[0]['args'][1];
                }
                $errors[] = sprintf(
                    'Error al ejecutar la función %s en el servicio web SOAP del SII ($i = %d): %s',
                    $function,
                    $i,
                    $message
                );
                $responseBody = null;
                // El reitento será con "exponential backoff", por lo que se
                // hace una pausa de 0.2 * $retry segundos antes de volver a
                // intentar llamar a la función del servicio web.
                usleep(200000 * $retry);
            }
        }

        // Si la respuesta es `null` significa que ninguno de los intentos de
        // llamadas a la función del servicio web fue exitoso.
        if ($responseBody === null) {
            throw new SiiConsumeWebserviceException(sprintf(
                'No se obtuvo respuesta de la función %s del servicio web SOAP del SII después de %d intentos. %s',
                $function,
                $retry,
                implode(' ', $errors)
            ));
        }

        // El SII indica que la respuesta que envía es:
        //   Content-Type: text/xml;charset=utf-8
        // Sin embargo, parece que indica que es UTF-8 pero envía contenido
        // codificado con ISO-8859-1 (que es lo esperable del SII). Lo que hace
        // que los caracteres especiales se obtengan como "�", por lo cual se
        // reemplazan en la respuesta por "?" para que sea "un poco" más
        // legible la respuesta del SII.
        $responseBody = str_replace(['�', '�'], '?', $responseBody);

        // Entregar el resultado como un documento XML.
        $xmlDocument = new XmlDocument();
        $xmlDocument->loadXml($responseBody);
        return $xmlDocument;
    }