system/proxy.py

from http.server import BaseHTTPRequestHandler, HTTPServer
import http.client
import socket

# Configuración del servidor backend
BACKEND_HOST = "localhost"
BACKEND_PORT = 8080

class TransparentProxy(BaseHTTPRequestHandler):
    def do_GET(self):
        self.proxy_request()

    def do_POST(self):
        self.proxy_request()

    def proxy_request(self):
        # Modifica la ruta para añadir /v1
        modified_path = f"/v1{self.path}"
        print(f"Redirigiendo la solicitud {self.command} a: {modified_path}")

        # Establece una conexión al backend con un timeout extendido
        conn = http.client.HTTPConnection(BACKEND_HOST, BACKEND_PORT, timeout=300)  # Timeout de 5 minutos

        try:
            # Leer datos del cuerpo si existen
            content_length = self.headers.get('Content-Length')
            if content_length:
                post_data = self.rfile.read(int(content_length))
                conn.request(self.command, modified_path, body=post_data, headers=self.headers)
            else:
                conn.request(self.command, modified_path, headers=self.headers)

            # Obtener la respuesta del backend
            backend_response = conn.getresponse()

            # Enviar la respuesta al cliente
            self.send_response(backend_response.status, backend_response.reason)

            # Reenviar todos los encabezados del backend al cliente
            for key, value in backend_response.getheaders():
                self.send_header(key, value)
            self.end_headers()

            # Reenviar el cuerpo de la respuesta en modo streaming
            while True:
                chunk = backend_response.read(1024)
                if not chunk:
                    break
                self.wfile.write(chunk)
                self.wfile.flush()  # Asegura que cada fragmento se envía inmediatamente al cliente

        except socket.timeout:
            self.send_error(504, "Gateway Timeout: El backend no respondió en el tiempo esperado.")
            print("Error: Tiempo de espera agotado en la solicitud al backend.")

        except Exception as e:
            self.send_error(500, f"Error en el proxy: {e}")
            print(f"Error al manejar la solicitud: {e}")

        finally:
            conn.close()

def run(server_class=HTTPServer, handler_class=TransparentProxy, port=7860):
    server_address = ('', port)
    httpd = server_class(server_address, handler_class)
    print(f"Proxy corriendo en el puerto {port}")
    httpd.serve_forever()

if __name__ == "__main__":
    run()