dev: corrección reenviar en error

static/js/chatHandler.js

@@ -27,7 +27,6 @@ class ChatGPT{
                 presence_penalty: 0.0
             };
         }
-        this.retries = 0;
         this.execStart = 0;
 
         this.endpointChat = "/chat_stream";
@@ -43,11 +42,21 @@ class ChatGPT{
         });
         $(document).on("enviar:reintentar", (event, params) => {
             this.reintentos++;
-            this.enviar(params.mensaje)
+            this.enviar("")
+        });
+
+        $(document).on("enviar:error", (event, params) => {
+            if((params.rstat == 500 || params.rstat == 408) && this.reintentos < 3){
+                this.reintentos++;
+                this.enviar(params.message)
+            }
+            else{
+                let rstat = params.rstat !=""? params.rstat : 500;
+                let mensaje = params.mensaje !=""? params.mensaje : "Desconocido";;
+                $(document).trigger("precarga:error", {status: rstat, mensaje: mensaje})
+            }
         });
 
-        $(document).on("enviar:error", (event, params) => this.reenviar(params));
-        
         
     }
 
@@ -68,18 +77,22 @@ class ChatGPT{
             $(document).trigger("enviar:fallido",{jqXHR:params.jqXHR, status:params.status, error:params.error, execTime:params.execTime, mensaje:params.mensaje});
             return
         }
-        if(this.retries < 3 ){
+        if(this.reintentos < 3 ){
             $(document).trigger("enviar:reintentar",{jqXHR:params.jqXHR, status:params.status, error:params.error, execTime:params.execTime, mensaje:params.mensaje});
             $(document).trigger("enviar:enviar",{jqXHR:params.jqXHR, status:params.status, error:params.error, execTime:params.execTime, mensaje:params.mensaje});
 
         }else{
             $(document).trigger("enviar:fallido",{jqXHR:params.jqXHR, status:params.status, error:params.error, execTime:params.execTime, mensaje:params.mensaje});
+            // $(document).trigger("precarga:reintento"
         }
     }
 
     enviar(mensaje){
+        // Configuración de variables base
         let tempMensajes = [];
         let tokens = 0;
+
+        // Calculo de tokens y reconfiguración de mensajes para este caso
         for(let i = 0; i < this.convesacion.length; i++){
             let actMsg = this.convesacion[i];
             tempMensajes.push({role: actMsg.role, content: actMsg.content})
@@ -87,11 +100,24 @@ class ChatGPT{
         }
         
         console.log("Enviando: ", mensaje);
-        tempMensajes.push({role: "user", content: mensaje});
-        this.convesacion.push({role: "user", content: mensaje});
-        this.convesacion.push({});
-        $(document).trigger("precarga:inicio", mensaje);
+
+        
+        if(this.reintentos==0){
+            //si es el primer intento
+
+            // Inclusión del nuevo mensaje
+            tempMensajes.push({role: "user", content: mensaje});
+            // Si es un reintento no se incluye a la lista
+            this.convesacion.push({role: "user", content: mensaje});
+            // Evento para anunciar el inicio de un envio
+            $(document).trigger("precarga:inicio", mensaje);
+            
+        }
+
+        // se almacena this para uso futuro
         let self = this;
+
+        //se inicia la llamada async
         fetch(this.endpointChat, {
             method: "POST",
             body: JSON.stringify({
@@ -103,49 +129,67 @@ class ChatGPT{
             rb: response.body, 
             rstat: response.status
         })).then(({rb, rstat}) => {
-            if(!rb){
-                return false;
-            }
+            // se crea el lector async
             const reader = rb.getReader();
         
+            // stream
             return new ReadableStream({
               start(controller) {
                 function push() {
+                    // si hay data
                     reader.read().then(({done, value}) => {
                         
                         if(rstat != 200){
+                            // si se retornó un codigo no 200, se cierra el stream 
+                            // y se destruye el msg de respuesta
                             controller.close();
-                            // this.convesacion.pop()
-                            console.log("ERROOOOOOOORRRRROOORRROOOR")
-                            $(document).trigger("precarga:error", {status: rstat, mensaje: data.detail});
+                            this.convesacion.pop()
+                            $(document).trigger("enviar:error", {status: rstat, mensaje: mensaje, detail: data.detail});
                         }
+                        
 
                         if(done){
+                            // si finalizó el stream cierra
                             controller.close();
-                            console.log("terminado con errores")
+                            $(document).trigger("precarga:fin");
+                            localStorage.setItem("convesacion", JSON.stringify(self.convesacion))
+                            console.log("terminado", self.convesacion[self.convesacion.length-1].content)
                             return
                         }
 
+                        // se lee el mensaje y se separa si viene más de 1 json
                         let elements = new TextDecoder("utf-8").decode(value).split("}{");
                         let elLen = elements.length;
+
+                        // se procesa cada mensaje
                         for(let i in elements){
-                            let data =  elements[i];
+                            // se asigna el elemento actual a data
+                            let data = elements[i];
                             if(!data){
                                 continue;
                             }
                             
+                            // se parsea el json
                             data =JSON.parse((i>0?"{":"") + data + (i<elLen-1?"}":""));
                             
-                          
                             if(data.object == "chat.token"){
+                                // si el elemento es un token seguridad
                                 self.token = data.token;
+
                             }else if(data.choices[0].hasOwnProperty("delta")){
+                                // si el elemento es parte del mensaje
+
+                                // Se separa los datos base
                                 let temp = data.choices[0].delta;
                                 let key = Object.keys(temp)[0];
                                 let elActual = self.convesacion[self.convesacion.length-1]
+
+                                
                                 if(!elActual.hasOwnProperty(key)){elActual[key]="";}
                                 elActual[key] += temp[key]
+
                                 if(elActual.hasOwnProperty("content") && temp.content){
+                                    //si tiene contenido se incluye al mesaje y se avisa via evento
                                     $(document).trigger("precarga:mensaje", temp.content);
                                 }
                             }