ifiguero
/
pysmtp
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

number two

master
ifiguero 2023-10-02 16:58:43 -03:00
parent e8d4f7c3b2
commit 0cb5829da8
1 changed files with 12 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
mayordomo/__init__.py
View File

@ -190,25 +190,21 @@ async def cleanupSent():
returnvalue = True
oneMonth = datetime.now() - timedelta(days = 60)
try:
dest = await db.execute(select(Destinatario).where(Destinatario.timestamp<oneMonth, Destinatario.enviado>0).limit(1))
dest = await db.execute(select(Destinatario).where(Destinatario.timestamp<oneMonth, Destinatario.enviado>0).limit(1))
for destinatario in dest.scalars():
await log.debug('Deleting Dest: {}'.format(destinatario.id))
cartaid = destinatario.cartaid
await db.execute(delete(Destinatario).where(Destinatario.id==destinatario.id))
for destinatario in dest.scalars():
await log.debug('Deleting Dest: {}'.format(destinatario.id))
cartaid = destinatario.cartaid
await db.execute(delete(Destinatario).where(Destinatario.id==destinatario.id))
await db.commit()
result = await db.execute(select(Destinatario).where(Destinatario.cartaid==cartaid).limit(1))
more = result.scalar_one_or_none()
if more is None:
await log.info('Deleting Carta: {}'.format(cartaid))
await db.execute(delete(Carta).where(Carta.id==cartaid))
await db.commit()
result = await db.execute(select(Destinatario).where(Destinatario.cartaid==cartaid).limit(1))
more = result.scalar_one_or_none()
if more is None:
await log.info('Deleting Carta: {}'.format(cartaid))
await db.execute(delete(Carta).where(Carta.id==cartaid))
await db.commit()
returnvalue = False
returnvalue = False
except:
await log.error('Traceback {}'.format(traceback.format_exc()))
raise('Error al leer correos pendientes. Reiniciando servicio.')
return returnvalue