Mejora navegación en nube y cambio de fecha por grupos y en la nube

Author: danitxu79

db_manager.py

@@ -403,7 +403,7 @@ def bulk_upsert_drive_photos(self, photos_list, root_folder_id=None):
                 p.get('thumbnailLink'),
                 p.get('webContentLink'),
                 parent,
-                root_folder_id # <--- Guardamos el ID de la carpeta origen
+                root_folder_id
             ))
 
         with self.conn:
@@ -413,5 +413,28 @@ def bulk_upsert_drive_photos(self, photos_list, root_folder_id=None):
                 ON CONFLICT(id) DO UPDATE SET
                 name=excluded.name,
                 thumbnail_link=excluded.thumbnail_link,
-                root_folder_id=excluded.root_folder_id
+                root_folder_id=excluded.root_folder_id,
+                parent_id=excluded.parent_id  -- <--- ¡ESTA LÍNEA ES NUEVA Y CRÍTICA!
             """, data_to_insert)
+
+
+    def clear_drive_data(self):
+        """
+        SEGURIDAD: Elimina todos los registros de fotos de la nube de la base de datos local.
+        """
+        with self.conn:
+            self.conn.execute("DELETE FROM drive_photos")
+            # Opcional: VACUUM para reducir tamaño del archivo, aunque puede ser lento
+            # self.conn.execute("VACUUM")
+
+    def get_drive_photos_by_parent(self, parent_id):
+        # IMPORTANTE: Esta consulta busca fotos cuyo PADRE DIRECTO sea la carpeta clickeada
+        cursor = self.conn.execute("SELECT * FROM drive_photos WHERE parent_id = ?", (parent_id,))
+        return [dict(row) for row in cursor.fetchall()]
+
+    def update_drive_photo_date(self, file_id, new_iso_date):
+        """
+        Actualiza la fecha de una foto de Drive localmente para reorganizarla.
+        """
+        with self.conn:
+            self.conn.execute("UPDATE drive_photos SET created_time = ? WHERE id = ?", (new_iso_date, file_id))

drive_auth.py

@@ -13,50 +13,74 @@
 class DriveAuthenticator:
     def __init__(self):
         self.creds = None
-        # Ruta donde guardaremos la sesión del usuario para no pedirla siempre
         self.token_path = os.path.join(os.path.dirname(__file__), 'user_token.pickle')
-        # Tu archivo maestro (que el usuario no toca)
         self.secrets_path = resource_path('client_secrets.json')
 
-    def get_service(self):
-        """Intenta loguear silenciosamente, o abre navegador si hace falta."""
+    def has_credentials(self):
+        """Verifica si existe el archivo de token."""
+        return os.path.exists(self.token_path)
 
-        # 1. Cargar sesión guardada si existe
+    def logout(self):
+        """Cierra sesión borrando el token local."""
+        self.creds = None
+        if os.path.exists(self.token_path):
+            try:
+                os.remove(self.token_path)
+                return True
+            except Exception as e:
+                print(f"Error borrando token: {e}")
+                return False
+        return True
+
+    def get_service(self, silent=False):
+        """
+        Obtiene el servicio de Drive.
+        Si silent=True, NO abrirá el navegador si el token es inválido,
+        simplemente devolverá None.
+        """
+        # 1. Cargar sesión guardada
         if os.path.exists(self.token_path):
-            with open(self.token_path, 'rb') as token:
-                self.creds = pickle.load(token)
+            try:
+                with open(self.token_path, 'rb') as token:
+                    self.creds = pickle.load(token)
+            except Exception:
+                self.creds = None
 
-        # 2. Si no hay credenciales válidas, hacemos el login visual
+        # 2. Validar credenciales
         if not self.creds or not self.creds.valid:
             if self.creds and self.creds.expired and self.creds.refresh_token:
                 try:
-                    # Intenta refrescar el token sin abrir el navegador
                     self.creds.refresh(Request())
                 except Exception:
-                    self._start_browser_login()
+                    self.creds = None
             else:
+                self.creds = None
+
+        # 3. Si no hay credenciales válidas:
+        if not self.creds:
+            if silent:
+                # Si es modo silencioso (arranque), no hacemos nada más
+                return None
+            else:
+                # Si NO es silencioso (botón conectar), abrimos navegador
                 self._start_browser_login()
 
-            # 3. Guardar la sesión para la próxima vez
+        # Guardar token refrescado o nuevo
+        if self.creds and self.creds.valid:
             with open(self.token_path, 'wb') as token:
                 pickle.dump(self.creds, token)
+            return build('drive', 'v3', credentials=self.creds)
 
-        # 4. Retornar el servicio listo para usar
-        return build('drive', 'v3', credentials=self.creds)
+        return None
 
     def _start_browser_login(self):
-        """Lanza el flujo de 'Logueate con Google' en el navegador."""
         if not os.path.exists(self.secrets_path):
-            raise FileNotFoundError("Falta el archivo de configuración interna (client_secrets.json).")
-
-        flow = InstalledAppFlow.from_client_secrets_file(
-            self.secrets_path, SCOPES)
+            raise FileNotFoundError("Falta client_secrets.json")
 
-        # CAMBIO CLAVE: Especificar success_message para asegurar que el usuario vea que acabó
-        # y el servidor sepa que debe cerrarse.
+        flow = InstalledAppFlow.from_client_secrets_file(self.secrets_path, SCOPES)
         self.creds = flow.run_local_server(
             port=0,
-            success_message='La autenticación se ha completado. Puedes cerrar esta ventana.'
+            success_message='Autenticación completada. Puedes cerrar esta ventana.'
         )
 
 

drive_manager.py

@@ -196,7 +196,7 @@ def list_images_recursively(self, folder_id):
                     q=query,
                     pageSize=1000,
                     pageToken=page_token,
-                    fields="nextPageToken, files(id, name, mimeType, thumbnailLink, webContentLink, createdTime)"
+                    fields="nextPageToken, files(id, name, mimeType, thumbnailLink, webContentLink, createdTime, parents)"
                 ).execute()
             except Exception as e:
                 print(f"⚠️ Error listando imágenes en {folder_id}: {e}")