Jugando con IMAP en Python
Hace no mucho parecía que POP iba a ser el protocolo preferido para el correo. Sin embargo, con la movilidad permanente y la necesidad de consultar nuestro correo en cualquier parte parece que todo ha cambiado y las soluciones preferidas son los sistemas de correo basados en proveedores con sus aplicaciones (y típicamente su reflejo en webmail para el escritorio. Si nuestro proveedor no tiene aplicación, parece que la solución más adecuada es el IMAP.
POP estaba orientado a la descarga, e IMAP estaba pensando para que el correo permaneciera en el servidor y se accediera a él mediante conexión.
A mi me gusta seguir viviendo la ficción de que una parte de mi correo es más o menos privada y eso pasa por usar los servidores del trabajo (o de un proveedor privado) con algunos inconvenientes: por un lado, malas herramientas de filtrado y gestión del correo; por otra parte, limitaciones en el espacio (todavía hay otra, y es la capacidad de buscar que pude solucionar -más o menos- con mairix).
Estas limitaciones me llevaron a montar un servidorcillo de correo (lo que viene llamándose en los últimos tiempos hacer un Hillary Clinton). Empecé montando los servicios por mi cuenta hasta que probé Zentyal que no es exactamente lo que necesito (tiene muchas más cosas y está pensada para algo más grande, pero me libera de algunas tareas de gestión). Miro con simpatía iniciativas como mailinabox o el fallido -por ahora- ownmailbox. Zentyal me proporciona un sistema con SOGo, Dovecot, filtrado (pronto, espero, otra entrada específica sobre el tema), antispam (no va demasiado bien, al menos en mi experiencia) y algunas herramientas más.
De todas formas, lo que quiero presentar hoy aquí puede ser de utilidad para cualquier cuenta de correo. Se trata de borrar algunos mensajes de una carpeta IMAP basado en reglas sencillas: en nuestro caso, recibimos mensajes de diversas tareas de cron que repetitivamente (sobre todo cuando todo va bien) llegan a nuestro correo. Lo que haremos será recorrer las carpetas donde se reciben las copias de seguridad y borrarlas.
La primera tarea es buscar un poco para ver si existe algún proyecto que nos ayude en la tarea de programación. Python incluye la imaplib que permite hacer las tareas necesarias. El proceso será:
- Leer la configuración de las cuentas que vamos a examinar
- Solicitar las contraseñas
- Seleccionar los mensajes y borrarlos
Además, para añadirle un poco de gracia a la cosa hemos añadido un uso muy básico de threading de manera que se hace el borrado de manera concurrente en las cuentas que haya configuradas. El código de la versión actual del programita se puede encontrar en deleteCronMesgs.py.
Comenzamos leyendo la configuración
config = ConfigParser.ConfigParser()
config.read([os.path.expanduser('~/IMAP.cfg')])En este fichero está la información de las cuentas de correo, tantas como sea necesario:
[IMAP1]
server:imap.server.com
user:myAccount@server.com
[IMAP2]
server:imap.otherServer.com
user:myUsernameAhora recorremos las cuentas configuradas y pedimos la contraseña (se podrían poner también en el fichero de configuración pero no termino de sentirme confortable con eso)
for section in config.sections():
SERVER = config.get(section, 'server')
USER = config.get(section, 'user')
print SERVER
PASSWORD = getpass.getpass()El código para borrar los mensajes se encuentra en la función mailFolder y para ello realiza los siguientes pasos:
Primero nos conectamos al servidor, con los datos leídos del fichero de configuración y del teclado.
M = imaplib.IMAP4_SSL(SERVER)
M.login(USER , password)Seleccionamos la carpeta sobre la que vamos a trabajar (en este caso el INBOX) y en ella buscamos los mensajes que nos interesan (los que contienen la cadena ‘Cron Daemon’ en el campo ‘FROM’):
M.select()
typ,data = M.search(None,'FROM', 'Cron Daemon')En search se devuelven dos valores, el estado (¿ha ido todo bien?) y una lista que contiene una cadena de caracteres con los números que identifican a los mensajes que cumplen las condiciones de búsqueda.
Ahora, para borrarlos recorremos la lista y actualizamos la marca (flag) para que refleje la condición de borrado:
if data[0]:
for num in data[0].split():
M.store(num, '+FLAGS', '\\Deleted')Además hemos incluido código para ir contando cuántos mensajes borramos y mostrar una actualización cada diez (que no mostramos aquí). Finalmente, cerramos la conexión y terminamos:
M.close()
M.logout()La parte concurrente es muy sencilla, consta de tres pasos.
Para cada cuenta de correo se crea un hilo:
t = threading.Thread(target=mailFolder, args=(SERVER, USER, PASSWORD,space*i))En target está la función que se ejecutará cuando se active el hilo y en args los parámetros de esa función.
Ahora acivamos los hilos (hemos separado la creación de la activación para que no haya interferencias de la salida que refleja la actividad con la entrada; podríamos prescindir de la realmientación y lanzarlas sobre la marcha):
for t in threads:
t.start()Finalmente, necesitamos esperar a que terminen los hilos, con un par de instrucciones como:
for t in threads:
t.join()Siguientes pasos: no tengo claro que el código de los hilos vaya a sobrevivir. Estuvo bien recordar un poquito (¡muy poquito!) de concurrencia pero en este caso no tiene demasiado interés. Tendría sentido poder incluir más reglas de borrado para otros mensajes e incluirlo en la configuración en lugar de en el propio código (por ejemplo, una lista de cademas para buscar o incluso algo más sofisticado).
También me gustaría explorar sistemas alternativos de autentificación (GMail permite utilizar OAuth, si no me equivoco). Como mínimo, poder tener la contraseña cifrada en el fichero de configuración y tener sólo una contraseña manestra.
¿Ideas? ¿Comentarios? Estaremos escuchando en @mbpfernand0 o en @fernand0.
Actualización (2015-12-07) quise terminar esta entrada rápido y olvidé otro ejemplo que tengo a mano. En este caso se trataría de borrar basado en el contenido. Recibimos ciertos mensajes repetidos que querríamos eliminar de nuestras coias de seguridad. Para examinar el contenido de los mensajes utilizaríamos:
typ, data = M.fetch(num, '(BODY.PEEK[TEXT])')Para determinar si el mensaje en cuestión es repetido, calculamos el hash (que tenemos precalculado) y lo comparamos:
m = hashlib.md5()
m.update(data[0][1])
if (binascii.hexlify(m.digest())==HASH):
M.store(num, '+FLAGS', '\\Deleted')
i = i + 1