Skip to content

Commit

Permalink
Aggiungi log verboso. Di defaul attivo per il momento
Browse files Browse the repository at this point in the history
  • Loading branch information
@yakky
yakky committed Oct 19, 2016
1 parent f812231 commit 579a9ab
Show file tree
Hide file tree
Showing 6 changed files with 149 additions and 85 deletions.
1 change: 1 addition & 0 deletions .gitignore
View file
Expand Up @@ -11,3 +11,4 @@ assets/
/*.sql
.sass-cache
.venv
/log/debug.log
3 changes: 3 additions & 0 deletions config/email.cnf.sample
View file
Expand Up @@ -11,6 +11,9 @@ backend = django.core.mail.backends.filebased.EmailBackend

# Configurazione

# Attivare il log di debug
log_debug = 1

## FILE
file_path = /tmp/mail/

Expand Down
21 changes: 21 additions & 0 deletions jorvik/settings.py
View file
Expand Up @@ -158,13 +158,32 @@
LOGGING = {
'version': 1,
'disable_existing_loggers': False,
'formatters': {
'verbose': {
'format': '%(levelname)s %(asctime)s %(module)s %(process)d %(thread)d %(message)s'
},
'simple': {
'format': '%(levelname)s %(message)s'
},
},
'handlers': {
'console': {
'level': 'DEBUG',
'class': 'logging.StreamHandler',
'formatter': 'simple'
},
'file': {
'level': 'DEBUG',
'class': 'logging.FileHandler',
'filename': os.path.join(BASE_DIR, 'log/debug.log'),
},
},
'loggers': {
'posta.models': {
'handlers': ['file'],
'level': 'DEBUG',
'propagate': True,
},
'two_factor': {
'handlers': ['console'],
'level': 'INFO',
Expand Down Expand Up @@ -214,6 +233,8 @@
EMAIL_SSL_KEYFILE = EMAIL_CONF.get('email', 'ssl_keyfile')
EMAIL_SSL_CERTFILE = EMAIL_CONF.get('email', 'ssl_certfile')

POSTA_LOG_DEBUG = EMAIL_CONF.getboolean('email', 'log_debug', fallback=True)

DEFAULT_FROM_EMAIL = 'Gaia <noreply@gaia.cri.it>'
GRAVATAR_DEFAULT_IMAGE = 'identicon'

Expand Down
Empty file added log/.directory
View file
Empty file.
2 changes: 1 addition & 1 deletion posta/cron.py
View file
Expand Up @@ -5,7 +5,7 @@

class CronSmaltisciCodaPosta(CronJobBase):

RUN_EVERY_MINS = 5
RUN_EVERY_MINS = 1

schedule = Schedule(run_every_mins=RUN_EVERY_MINS)
code = 'posta.smaltisci'
Expand Down
207 changes: 123 additions & 84 deletions posta/models.py
View file
@@ -1,21 +1,29 @@
"""
Questo modulo definisce i modelli del modulo di Posta di Gaia.
"""
import logging

from smtplib import SMTPException, SMTPResponseException, SMTPServerDisconnected, SMTPRecipientsRefused
from django.core.mail import send_mail, EmailMessage, EmailMultiAlternatives, get_connection
from django.db.models import QuerySet
from django.db.transaction import atomic
from django.template import Context
from django.template.loader import get_template
from django.utils.encoding import force_text
from django.utils.html import strip_tags

from base.models import *
from base.tratti import *
from social.models import ConGiudizio
from lxml import html

logger = logging.getLogger(__name__)


class Messaggio(ModelloSemplice, ConMarcaTemporale, ConGiudizio, ConAllegati):

logging = getattr(settings, 'POSTA_LOG_DEBUG', False)

SUPPORTO_EMAIL = 'supporto@gaia.cri.it'
SUPPORTO_NOME = 'Supporto Gaia'
NOREPLY_EMAIL = 'noreply@gaia.cri.it'
Expand Down Expand Up @@ -134,6 +142,8 @@ def invia(self, connection=None, utenza=False):
plain_text = strip_tags(self.corpo)
successo = True

if self.logging:
logger.debug('[POSTA] MSG %s: Inizio' % (self.pk,))
# E-mail al supporto
if not self.oggetti_destinatario.all().exists():
try:
Expand All @@ -148,109 +158,133 @@ def invia(self, connection=None, utenza=False):
)
msg.attach_alternative(self.corpo, "text/html")
msg.send()
except SMTPException:
except SMTPException as e:
if self.logging:
logger.debug('[POSTA] MSG %s: errore grave %s' % (self.pk, e))
successo = False

# E-mail a delle persone
if self.logging:
logger.debug('[POSTA] MSG %s: Destinatari=%d' % (self.pk, self.oggetti_destinatario.filter(inviato=False).count()))
for d in self.oggetti_destinatario.filter(inviato=False):
destinatari = []
if hasattr(d, 'persona') and d.persona and d.persona.email:
destinatari.append(d.persona.email)
if hasattr(d.persona, 'utenza') and d.persona.utenza and d.persona.utenza.email:
if utenza and d.persona.utenza.email != d.persona.email:
destinatari.append(d.persona.utenza.email)

# Non diamo per scontato che esistano destinatari
if destinatari:
# Assicurati che la connessione sia aperta
connection.open()

# Evita duplicati in invii lunghi (se ci sono problemi con lock)...
d.refresh_from_db()
if d.inviato:
print("%s (*) msg=%d, dest=%d, protezione invio duplicato" % (
datetime.now().isoformat(' '),
self.pk,
d.pk,
))
continue

try:
msg = EmailMultiAlternatives(
subject=self.oggetto,
body=plain_text,
from_email=mittente,
reply_to=[reply_to],
to=destinatari,
attachments=self.allegati_pronti(),
connection=connection,
)
msg.attach_alternative(self.corpo, "text/html")
msg.send()
d.inviato = True

except SMTPException as e:

if isinstance(e, SMTPRecipientsRefused):
try:
if any([code == 250 for email, code in e.recipients.items()]):
# Almeno un'email è partita, il messaggio si considera inviato
d.inviato = True
successo = True
else:
with atomic():
destinatari = []
if hasattr(d, 'persona') and d.persona and d.persona.email:
destinatari.append(d.persona.email)
if hasattr(d.persona, 'utenza') and d.persona.utenza and d.persona.utenza.email:
if utenza and d.persona.utenza.email != d.persona.email:
destinatari.append(d.persona.utenza.email)

if self.logging:
logger.debug('[POSTA]: MSG %s: Num=%d Destinatari=%s' % (self.pk, len(destinatari), d.pk))
# Non diamo per scontato che esistano destinatari
if destinatari:
# Assicurati che la connessione sia aperta
connection.open()

# Evita duplicati in invii lunghi (se ci sono problemi con lock)...
d.refresh_from_db()
if d.inviato:
if self.logging:
logger.debug('[POSTA]: MSG %s: destinatario duplicato: msg=%s, dest=%s' % (self.pk, self.oggetto, ','.join(destinatari)))
print("%s (*) msg=%d, dest=%d, protezione invio duplicato" % (
datetime.now().isoformat(' '),
self.pk,
d.pk,
))
continue

try:
msg = EmailMultiAlternatives(
subject=self.oggetto,
body=plain_text,
from_email=mittente,
reply_to=[reply_to],
to=destinatari,
attachments=self.allegati_pronti(),
connection=connection,
)
msg.attach_alternative(self.corpo, "text/html")
msg.send()
d.inviato = True

except SMTPException as e:
if self.logging:
logger.debug('[POSTA]: MSG %s: eccezione %s' % (self.pk, e,))

if isinstance(e, SMTPRecipientsRefused):
try:
if any([code == 250 for email, code in e.recipients.items()]):
# Almeno un'email è partita, il messaggio si considera inviato
d.inviato = True
successo = True
else:
# E-mail di destinazione rotta: ignora.
d.inviato = True
d.invalido = True
except AttributeError:
# E-mail di destinazione rotta: ignora.
d.inviato = True
d.invalido = True
except AttributeError:

elif isinstance(e, SMTPResponseException) and e.smtp_code == 501:
# E-mail di destinazione rotta: ignora.
d.inviato = True
d.invalido = True

elif isinstance(e, SMTPResponseException) and e.smtp_code == 501:
# E-mail di destinazione rotta: ignora.
elif isinstance(e, SMTPServerDisconnected):
# Se il server si e' disconnesso, riconnetti.
successo = False # Questo messaggio verra' inviato al prossimo tentativo.
connection.close() # Chiudi handle alla connessione
connection.open() # Riconnettiti

else:
successo = False # Altro errore... riprova piu' tardi.

d.errore = str(e)

except TypeError as e:
if self.logging:
logger.debug('[POSTA]: MSG %s: eccezione %s' % (self.pk, e,))
d.inviato = True
d.invalido = True
d.errore = "Nessun indirizzo e-mail. Saltato"

elif isinstance(e, SMTPServerDisconnected):
# Se il server si e' disconnesso, riconnetti.
successo = False # Questo messaggio verra' inviato al prossimo tentativo.
connection.close() # Chiudi handle alla connessione
connection.open() # Riconnettiti

else:
successo = False # Altro errore... riprova piu' tardi.

d.errore = str(e)

except TypeError as e:
d.inviato = True
d.invalido = True
d.errore = "Nessun indirizzo e-mail. Saltato"

except AttributeError as e:
d.inviato = True
d.invalido = True
d.errore = "Destinatario non valido. Saltato"

except UnicodeEncodeError as e:
d.inviato = True
d.invalido = True
d.errore = "Indirizzo e-mail non valido. Saltato."

if not d.inviato or d.invalido:
print("%s (!) errore invio id=%d, destinatario=%d, errore=%s" % (
datetime.now().isoformat(' '),
self.pk,
d.pk,
d.errore,
))
d.tentativo = datetime.now()
d.save()
except AttributeError as e:
if self.logging:
logger.debug('[POSTA]: MSG %s: eccezione %s' % (self.pk, e,))
d.inviato = True
d.invalido = True
d.errore = "Destinatario non valido. Saltato"

except UnicodeEncodeError as e:
if self.logging:
logger.debug('[POSTA]: MSG %s: eccezione %s' % (self.pk, e,))
d.inviato = True
d.invalido = True
d.errore = "Indirizzo e-mail non valido. Saltato."

if not d.inviato or d.invalido:
if self.logging:
logger.debug('[POSTA]: MSG %s: errore invio destinatario=%s, errore=%s' % (self.pk, d.pk, d.errore))
print("%s (!) errore invio id=%d, destinatario=%d, errore=%s" % (
datetime.now().isoformat(' '),
self.pk,
d.pk,
d.errore,
))
d.tentativo = datetime.now()
d.save()
if self.logging:
logger.debug('[POSTA]: MSG %s: salvataggio destinatario=%s' % (self.pk, d.pk))

if successo:
self.terminato = datetime.now()

self.ultimo_tentativo = datetime.now()
if self.logging:
logger.debug('[POSTA]: MSG %s: termine invio successo=%s, inviato=%s invalido=%s errore=%s' % (self.pk, successo, d.inviato, d.invalido, d.errore))
logger.debug('[POSTA]: MSG %s: salvataggio terminato=%s ultimo_tentativo=%s' % (self.pk, self.terminato, self.ultimo_tentativo))
self.save()

def aggiungi_destinatario(self, persona):
Expand Down Expand Up @@ -309,6 +343,11 @@ def smaltisci_coda(cls, dimensione_massima=50):
connection = get_connection()
for messaggio in da_smaltire:
totale += 1
if cls.logging:
logger.debug('[POSTA]: MSG %s: pickup destinatari=(totale=%d, in_attesa=%d)' % (
messaggio.pk, messaggio.oggetti_destinatario.all().count(),
messaggio.oggetti_destinatario.filter(inviato=False).count(),
))
print("%s invio messaggio id=%d, destinatari=(totale=%d, in_attesa=%d)" % (
datetime.now().isoformat(' '),
messaggio.pk,
Expand Down

0 comments on commit 579a9ab

Please sign in to comment.