src/main.py

@@ -9,5 +9,3 @@ def main():
 
 if __name__ == "__main__":
     main()
-
-    #self.tasks["scrapper"].start(self.scrapper.start_scraping)

src/services/scrapper.py

@@ -33,10 +33,6 @@ class Scrapper:
 
     def start_scraping(self):
         """Inicia el proceso de scraping"""
-        if self.running:
-            print("El scrapping ya está en ejecución.")
-            return
-
         self.running = True
         url = self.get_url_from_ui()
         if url:  
@@ -48,13 +44,12 @@ class Scrapper:
             
     def stop_scraping(self):
         """Detiene el proceso de scraping"""
-        print("Deteniendo el proceso de scraping...")  
-        # Detener las tareas  
-        self.scraping_task.stop_thread()  
-        self.db_task.stop()  
+        self.running = False
+        print("Scrapping detenido. Proceso finalizado.")
 
-        # Inserta un sentinel (None) en la cola para detener el hilo de inserción  
-        self.link_queue.put(None)  
+        #Vaciar la cola para detener el hilo de inserción
+        while not self.link_queue.empty():
+            self.link_queue.get()
 
         # Actualiza la pestaña "Scrapping" con un mensaje  
         tab = self.ui_instance.tabs["Scrapping"]  
@@ -64,7 +59,6 @@ class Scrapper:
         text_widget.insert("end", "Scrapping finalizado.\n")  
         text_widget.see("end")  
         text_widget.configure(state="disabled")
-        print("Scrapping detenido. Proceso finalizado.")   
 
     def scrape_page(self, url):
         """Scrapea una web y busca los enlaces"""
@@ -86,17 +80,15 @@ class Scrapper:
                         break
                     self.link_queue.put((url, link))
 
-                # Procesar los enlaces de forma secuencial en lugar de crear nuevos hilos  
                 for link in links:
                     if not self.running:
                         break
-                    self.scrape_page(link)  
+                    threading.Thread(target=self.scrape_page, args=(link,), daemon=True).start()
             else:
                 print(f"Error al acceder a {url}: {response.status_code}")
         except Exception as e:
             print(f"Error al scrapear {url}: {e}")
 
-
     def update_ui(self, url, links):  
         """Actualiza la pestaña 'Scrapping' con los enlaces encontrados"""  
         tab = self.ui_instance.tabs["Scrapping"]  
@@ -110,16 +102,15 @@ class Scrapper:
         text_widget.configure(state="disabled")
 
 
+
     def insert_links_to_db(self):  
         """Inserta los enlaces en la base de datos desde la cola"""  
-        while True:  
+        while self.running or not self.link_queue.empty():  
             try:  
-                # Obtener un enlace de la cola  
-                item = self.link_queue.get(timeout=1)  
-                if item is None:  # Si encuentra el sentinel, detiene el hilo  
+            # Obtener un enlace de la cola  
+                if not self.running and self.link_queue.empty():
                     break
-
-                parent_url, link = item  
+                parent_url, link = self.link_queue.get(timeout=1)  # Espera 1 segundo si la cola está vacía  
                 connection = mysql.connector.connect(**self.db_config)  
                 cursor = connection.cursor()  
                 cursor.execute("CREATE TABLE IF NOT EXISTS links (id INT AUTO_INCREMENT PRIMARY KEY, url TEXT, parent_url TEXT)")  
@@ -140,6 +131,23 @@ class Scrapper:
         except AttributeError:  
             print("No se pudo obtener la URL desde la interfaz")  
             return None  
-
+"""
+    def save_links_to_db(self, url, links):
+        Guarda los enlaces en la base de datos
+        try:
+            connection = mysql.connector.connect(**self.db_config)
+            cursor = connection.cursor()
+            cursor.execute("CREATE TABLE IF NOT EXISTS links (id INT AUTO_INCREMENT PRIMARY KEY, url TEXT, parent_url TEXT)")
+            
+            for link in links:
+                print(f"Guardando enlace: {link} (parent: {url})")  # Verifica los datos  
+                cursor.execute("INSERT INTO links (url, parent_url) VALUES (%s, %s)", (link, url))
+
+            connection.commit()
+            cursor.close()
+            connection.close()
+        except Exception as e:
+            print(f"Error al gaurdar en la base de datos: {e}")
+"""
     
     

src/services/system_monitor.py

@@ -9,7 +9,6 @@ class SystemMonitor:
         self.parent_frame = parent_frame  
         self.max_data_points = 60  
         self.running = False  
-        self.previous_net_io = psutil.net_io_counters()
         self.metrics = {  
             "CPU Usage": {  
                 "data": [],  
@@ -21,9 +20,9 @@ class SystemMonitor:
                 "fetch_func": lambda: psutil.virtual_memory().percent,  
                 "interval": 1  
             },
-            "Network Usage (KB/s)": {
+            "Processes": {
                 "data": [],
-                "fetch_func": self.get_network_usage,
+                "fetch_func": self.get_process_count,
                 "interval": 1
             }
         }  
@@ -78,19 +77,10 @@ class SystemMonitor:
         def redraw():  
             graph["line"].set_data(x, data)  
             graph["axis"].set_xlim(0, len(data))  
-            graph["axis"].set_ylim(0, max(data) * 1.2 if data else 100) 
             graph["figure"].canvas.draw()  
 
         self.parent_frame.after(0, redraw)  
 
-    def get_network_usage(self):  
-        """Calcula la velocidad de transferencia de red en KB/s."""  
-        current_net_io = psutil.net_io_counters()  
-        sent_bytes = current_net_io.bytes_sent - self.previous_net_io.bytes_sent  
-        recv_bytes = current_net_io.bytes_recv - self.previous_net_io.bytes_recv  
-        self.previous_net_io = current_net_io  # Actualiza los datos previos  
-
-        # Convierte a KB/s  
-        total_kb = (sent_bytes + recv_bytes) / 1024
-        #print(f"Network Usage: {total_kb} KB/s")
-        return total_kb 
+    def get_process_count(self):  
+        """Obtiene el número de procesos actuales."""  
+        return len(psutil.pids())

src/services/threads_manager.py

@@ -38,7 +38,7 @@ class ThreadsManager:
         self.tasks["time"].start(self.update_time)
         self.tasks["temperature"].start(self.update_temperature)
         self.tasks["emails"].start(self.update_emails)
-        
+        self.tasks["scrapper"].start(self.scrapper.start_scraping)
 
         if self.system_monitor:
             for metric in self.system_monitor.metrics.keys():