Se agrega reitento automático sin uso de caché de sesión (para forzar nueva sesión) cuando la sesión de SII es reportada con problema por API Gateway.

Author: estebandelaf

src/ApiClient.php

@@ -321,20 +321,78 @@ public function consume($resource, $data = [], array $headers = [], $method = nu
             $options[\GuzzleHttp\RequestOptions::JSON] = $data;
         }
 
-        // realizar consulta HTTP
-        try {
-            $this->last_response = $client->request($method, $this->last_url, $options);
-        } catch (\GuzzleHttp\Exception\GuzzleException $e) {
-            $this->last_response = $e->getResponse();
-            $this->throwException();
-        }
+        // realizar consulta HTTP con reintento por si falla la sesión del SII.
+        foreach ([true, false] as $auth_cache) {
+
+            // Forzar el valor de auth_cache en la llamada a la API.
+            $this->last_url = $this->forceUrlParams($this->last_url, [
+                'auth_cache' => (int)$auth_cache,
+            ]);
+
+            // Ejecutar consulta al SII.
+            try {
+                $this->last_response = $client->request($method, $this->last_url, $options);
+            } catch (\GuzzleHttp\Exception\GuzzleException $e) {
+                // Obtener la respuesta de la llamada.
+                $this->last_response = $e->getResponse();
+
+                // Si es un error HTTP 401 con problema de sesión pasamos a la otra iteración
+                // del ciclo foreach para reintentar sin caché de sesión del SII.
+                if ($this->getLastResponse()->getStatusCode() == 401) {
+                    if ($this->getLastResponse()->getHeaderLine('X-Stats-NavegadorSessionProblem')) {
+                        continue;
+                    }
+                }
+
+                // Si no es un error 401 con problema de sesión se lanza la excepción.
+                $this->throwException();
+            }
 
-        if ($this->getLastResponse()->getStatusCode() != 200) {
+            // Break obligatorio, ya que si la llamada es exitosa no se debe reintentar.
+            if ($this->getLastResponse()->getStatusCode() == 200) {
+                break;
+            }
+
+            // Si no se reintentó se lanza excepción por no ser código 200 (break anterior).
             $this->throwException();
         }
+
+        // Entregar respuesta (contenida en el mismo objeto del cliente).
         return $this;
     }
 
+    /**
+     * Fuerza parámetros específicos en la URL dada.
+     *
+     * @param string $url La URL original a modificar.
+     * @param array $params Arreglo asociativo de parámetros para añadir a la URL.
+     * @return string La URL modificada con los nuevos parámetros.
+     */
+    private function forceUrlParams(string $url, array $params): string
+    {
+        // Parsear la URL para extraer componentes.
+        $parsedUrl = parse_url($url);
+
+        // Parsear la cadena de consulta existente y obtener los parámetros actuales.
+        parse_str($parsedUrl['query'] ?? '', $queryParams);
+
+        // Fusionar los parámetros existentes con los nuevos parámetros forzados.
+        $queryParams = array_merge($queryParams, $params);
+
+        // Reconstruir la cadena de consulta con los nuevos parámetros.
+        $parsedUrl['query'] = http_build_query($queryParams);
+
+        // Reconstruir y devolver la URL completa.
+        return (isset($parsedUrl['scheme']) ? "{$parsedUrl['scheme']}://" : '') .
+            (isset($parsedUrl['user']) ? "{$parsedUrl['user']}" . (isset($parsedUrl['pass']) ? ":{$parsedUrl['pass']}" : '') .'@' : '') .
+            (isset($parsedUrl['host']) ? "{$parsedUrl['host']}" : '') .
+            (isset($parsedUrl['port']) ? ":{$parsedUrl['port']}" : '') .
+            (isset($parsedUrl['path']) ? "{$parsedUrl['path']}" : '') .
+            (isset($parsedUrl['query']) ? "?{$parsedUrl['query']}" : '') .
+            (isset($parsedUrl['fragment']) ? "#{$parsedUrl['fragment']}" : '')
+        ;
+    }
+
     /**
      * Extrae información detallada sobre un error a partir de la última respuesta HTTP.
      *