import shutil
import datetime
import subprocess
+import email.MIMEMultipart
# Módulos locales
import sercom
-import sercom.sqlobject
-from sercom.sqlobject import *
+import sercom.sqlo
+from sercom.sqlo import *
class secure_process:
def __init__(self, chroot, uid, gid, cpu):
def chroot_dir(intento):
return os.path.join(intento.path, 'chroot')
-def compilar(intento):
+def compilar(intento, mail):
global log
# Busco makefile
makefile = os.path.join(intento.entrega.ejercicio.path, 'Makefile')
# Compilo
log.debug('Ejecutando: make -f %s', makefile)
intento.inicioCompila = datetime.datetime.now()
- make = subprocess.Popen(('make', '-f', makefile), stdout=subprocess.PIPE,
- stderr=subprocess.PIPE, cwd=intento.path)
+ make = subprocess.Popen(('make', '-f', makefile), stderr=subprocess.PIPE,
+ cwd=intento.path)
make.wait()
intento.finCompila = datetime.datetime.now()
log.debug('Fin del comando: make -f %s', makefile)
# Verifico compilación
- if make.returncode:
- log.debug('Error al compilar, código de retorno: %d, salida estándar: '
- '%s, salida de error: %s)', make.returncode, make.stdout.read(),
- make.stderr.read())
- intento.compila = False
- #TODO enviar_respuesta(R_ERR, $mail, "ERROR AL COMPILAR!\n\n$err\n\nCódigo de retorno: $ret\n", $intento);
- return False
- log.debug('Compilado OK')
- intento.compila = True
- #TODO mail acumulativo
- return True
+ stderr = make.stderr.read()
+ intento.compila = not make.returncode
+ msg = 'Compilación: '
+ if intento.compila and not stderr:
+ msg += 'BIEN'
+ elif intento.compila:
+ msg += 'CON ADVERTENCIAS'
+ else:
+ msg += 'ERROR (código de retorno: %d)' % make.returncode
+ mail.body += msg
+ if stderr:
+ msg += '''Salida:
+------------------------------------------------------------------------
+%s
+------------------------------------------------------------------------
+
+''' % stderr
+ mail.body += "\n(se adjunta salida, archivo 'make.stderr')\n"
+ mail.attachText(stderr, 'make.stderr')
+ mail.body += '\n\n'
+ intento.observaciones = msg + '\n\n'
+ log.debug(msg)
def preparar(intento):
# Creo chroot - TODO copiarlo de algún lado donde ande el valgrind?
# Borro chroot entero
shutil.rmtree(chroot_dir(intento))
-def probar(intento, caso_de_prueba):
+def probar(intento, caso_de_prueba, mail):
# Cosas útiles
global log, conn, conf, uid, gid
# Para manejo de SIGCHLD
seq.append(buff)
return seq
+class MailIntento(email.MIMEMultipart.MIMEMultipart, object):
+ def __init__(self, intento):
+ global conf
+ from email.MIMEMultipart import MIMEMultipart
+ from email.MIMEMessage import MIMEMessage
+ from email.MIMEText import MIMEText
+ MIMEMultipart.__init__(self)
+ self.subject = '[%s] Resultado del intento %d del ejercicio %d.%d' % \
+ (conf.get('mail', 'prefijo'), intento.numero,
+ intento.entrega.nroEjercicio, intento.entrega.entrega)
+ self['From'] = conf.get('mail', 'from')
+ self['To'] = intento.mailRespuesta
+ self['Reply-To'] = conf.get('mail', 'admin')
+ self['Return-Path'] = conf.get('mail', 'admin')
+ self['X-Mailer'] = 'sercom 0.3'
+ self['X-Priority'] = '5'
+ self.epilogue = 'Para ver correctamente este e-mail su cliente debe ' \
+ 'soportar MIME.\n\n'
+ self.prologue = '' # Garantiza que termine en \n el mensaje
+ self.attach(MIMEMessage(MIMEText('', 'plain', 'iso-8859-1')))
+ self.resultado = None
+ def __set_body(self, body):
+ self.get_payload(0).get_payload(0).set_payload(body)
+ def __get_body(self):
+ return self.get_payload(0).get_payload(0).get_payload()
+ body = property(__get_body, __set_body, doc='Cuerpo del mensaje.')
+ def attachText(self, text, nombre=None):
+ from email.MIMEText import MIMEText
+ attach = MIMEText(text, 'plain', 'iso-8859-1')
+ if nombre:
+ attach.add_header('Content-Disposition', 'attachment', filename=nombre)
+ self.attach(attach)
+ def send(self, resultado=None):
+ import smtplib
+ global conf
+ smtp = smtplib.SMTP(conf.get('mail', 'smtp'))
+ if resultado:
+ self.subject += ': ' + resultado
+ self['Subject'] = self.subject
+ smtp.sendmail(self['From'], self['To'], self.as_string())
+ smtp.close()
+
# Manejadores de señales
signal.signal(signal.SIGTERM, sigterm)
signal.signal(signal.SIGINT, sigterm)
intervalo = float(conf.get('general', 'intervalo'))
# Utilizo el directorio de datos como base para todos los SQLObjects
-sercom.sqlobject.dir_base = conf.get('general', 'data_dir')
+sercom.sqlo.dir_base = conf.get('general', 'data_dir')
# Hasta que nos maten
while continuar:
time.sleep(intervalo)
continue
log.info('Nuevo intento a probar (%s)', intento)
+ mail = MailIntento(intento)
# Compila
- if not compilar(intento):
- #TODO mandar mail
+ compilar(intento, mail)
+ if not intento.compila:
+ mail.send('NO COMPILA')
continue
# Ejecución de casos de prueba
intento.inicioPruebas = datetime.datetime.now()
# Preparo chroot
preparar(intento)
# Pruebo y agrego prueba a la lista
- pruebas.append(probar(intento, caso_de_prueba))
+ prueba = probar(intento, caso_de_prueba, mail)
+ mail.body += 'Prueba %s: %s (%s)\n' % (prueba.casoDePrueba.nombre, prueba.pasada, prueba.observaciones)
+ pruebas.append(prueba)
# Limpio chroot
limpiar(intento)
+ #TODO Si es publica, veo si se hizo ok o no y voy creando mail
intento.finPruebas = datetime.datetime.now()
+ mail.send('NO SEP')
# Limpio directorio
log.debug('Borrando ejecutable y código objeto (*.o)')
os.remove(os.path.join(intento.path, 'tp'))
[os.remove(obj) for obj in glob.glob(os.path.join(intento.path, '*.o'))]
- #TODO Armar mail de respuesta al alumno
- for prueba in pruebas:
- #TODO Si es publica, veo si se hizo ok o no y voy creando mail
- pass
- time.sleep(intervalo)
+ # time.sleep(intervalo) #XXX Puede servir para enlentecer el server
projects / software / sercom-old.git / blobdiff