Se atrapan errores STMP de una forma no muy elegante.

[software/sercom-old.git] / src / sc_fetch

diff --git a/src/sc_fetch b/src/sc_fetch
index 2f31525600f6fef65a50f2eb3c60d62be7dea52c..7a1e407a34450eef7118312c851a30bbbbb72c37 100755 (executable)
--- a/src/sc_fetch
+++ b/src/sc_fetch
@@ -1,6 +1,9 @@
 #!/usr/bin/php4
 <?php // vim: set binary noeol et sw=4 sts=4:
 
 #!/usr/bin/php4
 <?php // vim: set binary noeol et sw=4 sts=4:
 

+// Incluyo directorio del ejecutable como posible directorio de bibliotecas
+set_include_path(get_include_path().':'.dirname($argv[0]));
+

 require_once 'T/general.php';
 
 define('R_ERR', 0);
 require_once 'T/general.php';
 
 define('R_ERR', 0);


@@ -13,7 +16,7 @@ $mconf = $CONF['mail'];
 $gconf = $CONF['general'];
 
 $mailbox = @$mconf['mailbox'];
 $gconf = $CONF['general'];
 
 $mailbox = @$mconf['mailbox'];

-switch (@$mconf['protocol'] ? $mconf['protocol'] : 'mbox') {
+switch (@$mconf['protocol']) {

     case 'mbox':
         $mailbox = $mconf['server'];
         break;
     case 'mbox':
         $mailbox = $mconf['server'];
         break;


@@ -25,7 +28,7 @@ switch (@$mconf['protocol'] ? $mconf['protocol'] : 'mbox') {
         $mailbox = "{{$mconf['server']}$port/{$mconf['protocol']}$options}$mailbox";
         break;
     default:
         $mailbox = "{{$mconf['server']}$port/{$mconf['protocol']}$options}$mailbox";
         break;
     default:

-        die("Error: el protocolo {$mconf['protocol']} no está soportado.\n");
+        logsdie("Error: el protocolo {$mconf['protocol']} no está soportado");

 }
 
 #$mbox = imap_open($mailbox, @$mconf['user'], @$mconf['pass']);
 }
 
 #$mbox = imap_open($mailbox, @$mconf['user'], @$mconf['pass']);


@@ -65,47 +68,58 @@ for ($i = 1; $i <= imap_num_msg($mbox); $i++)
 
 $claves = $gconf['claves'];
 
 
 $claves = $gconf['claves'];
 

+// Errores tratando de conectar al mail
+$mbox_errcount = 0;
+

 // Sin cesar.
 while (1) {
     // Reseteo intervalo
     $intervalo = $gconf['intervalo'];
     // Abro mailbox o chillo.
 // Sin cesar.
 while (1) {
     // Reseteo intervalo
     $intervalo = $gconf['intervalo'];
     // Abro mailbox o chillo.

-    if (!($mbox = imap_open($mailbox, @$mconf['user'], @$mconf['pass']))) {
-        logs('No se pudo conectar al servidor ('.imap_last_error().')', L_ERR);
+    if (!($mbox = @imap_open($mailbox, @$mconf['user'], @$mconf['pass']))) {
+        if ($mbox_errcount * $intervalo > 120) { // 2 horas sin poder conectarse
+            logs('Hace 2 horas que no se puede conectar al servidor ('.imap_last_error().')', ERROR);
+            $mbox_errcount = 0;
+        } else {
+            logs('No se pudo conectar al servidor ('.imap_last_error().')', WARNING);
+        }
+        $mbox_errcount++;

         sleep($intervalo);
         sleep($intervalo);

+        continue;

     }
     }

-    logs('Conectado como '.@$mconf['user']." a $mailbox", L_DBG);
+    $mbox_errcount = 0;
+    logs('Conectado como '.@$mconf['user']." a $mailbox", DEBUG);

     if (imap_num_msg($mbox) and $hdr = imap_headerinfo($mbox, 1)) {
         logs("Nuevo mail '{$hdr->subject}' de {$hdr->fromaddress}");
         @list($padron, $ej, $ent, $codigo) = validar_cabecera($hdr);
         if ($padron) {
     if (imap_num_msg($mbox) and $hdr = imap_headerinfo($mbox, 1)) {
         logs("Nuevo mail '{$hdr->subject}' de {$hdr->fromaddress}");
         @list($padron, $ej, $ent, $codigo) = validar_cabecera($hdr);
         if ($padron) {

-            logs('Cabecera válida', L_DBG);
+            logs('Cabecera válida', DEBUG);

             $intento = new T_Intento($padron, $ej, $ent);
             if (!($err = $intento->validar_entrega($codigo, $claves))) {
                 logs('Entrega aceptada ('.$intento->to_line().')');
                 if (!($err = preparar_entrega($intento, $mbox, 1, $gconf['data_dir']))) {
             $intento = new T_Intento($padron, $ej, $ent);
             if (!($err = $intento->validar_entrega($codigo, $claves))) {
                 logs('Entrega aceptada ('.$intento->to_line().')');
                 if (!($err = preparar_entrega($intento, $mbox, 1, $gconf['data_dir']))) {

-                    logs('Intento preparado', L_DBG);
+                    logs('Intento preparado', DEBUG);

                     $res = $intento->hacer_entrega($hdr->fromaddress);
                     if (PEAR::isError($res)) {
                     $res = $intento->hacer_entrega($hdr->fromaddress);
                     if (PEAR::isError($res)) {

-                        logs('Error al hacer entrega (' . $res->getMessage() . ')', L_ERR);
-                        enviar_respuesta(R_ERR, $hdr->fromaddress, "Error al preparar entrega:\nError en la base de datos.\n\nSe envió un mensaje al administrador avisando del problema.", $intento);
-                        enviar_respuesta(R_ERR, $mconf['mail_admin'], "Error al preparar entrega:\n" . $res->getMessage(), $intento);
+                        logs('Error al hacer entrega (' . $res->getMessage() . ')', ERROR);
+                        enviar_respuesta(R_ERR, $hdr->fromaddress, "Error interno al preparar entrega.\n\nSe envió un mensaje al administrador avisando del problema.", $intento);
+                        enviar_respuesta(R_ERR, $mconf['admin'], "Error de la DB al preparar entrega:\n" . $res->getMessage(), $intento);

                     } else {
                     } else {

-                        logs('Intento encolado para compilar');
+                        logs('Intento encolado para compilar', DEBUG);

                         enviar_respuesta(R_OK, $hdr->fromaddress, null, $intento);
                         guardar_mbox($mbox, 1, $hdr, @$mconf['mbox_bak']);
                     }
                 } else {
                         enviar_respuesta(R_OK, $hdr->fromaddress, null, $intento);
                         guardar_mbox($mbox, 1, $hdr, @$mconf['mbox_bak']);
                     }
                 } else {

-                    logs("Error al preparar entrega ($err)", L_ERR);
-                    enviar_respuesta(R_ERR, $hdr->fromaddress, "Error al preparar entrega:\n$err", $intento);
-                    enviar_respuesta(R_ERR, $mconf['mail_admin'], "Error al preparar entrega:\n$err.\n\nSe envió un mensaje al administrador avisando del problema.", $intento);
+                    logs("Error al preparar entrega ($err)", ERROR);
+                    enviar_respuesta(R_ERR, $hdr->fromaddress, "Error interno al preparar entrega.\n\nSe envió un mensaje al administrador avisando del problema.", $intento);
+                    enviar_respuesta(R_ERR, $mconf['admin'], "Error al preparar entrega:\n$err", $intento);

                 }
             } else {
                 }
             } else {

-                logs("Entrega rechazada ($err)");
+                logs("Entrega rechazada ($err)", WARNING);

                 enviar_respuesta(R_ERR, $hdr->fromaddress, $err, $intento);
             }
         } else {
                 enviar_respuesta(R_ERR, $hdr->fromaddress, $err, $intento);
             }
         } else {

-            logs('Entrega rechazada (subject inválido)');
+            logs('Entrega rechazada (subject inválido)', WARNING);

             enviar_respuesta(R_ERR, $hdr->fromaddress, "Asunto (subject) inválido.\n\n"
                     . "Recuerde que el formato del asunto es estricto:\n"
                     . "[padrón] [ejercicio].[entrega] [código]\n\n"
             enviar_respuesta(R_ERR, $hdr->fromaddress, "Asunto (subject) inválido.\n\n"
                     . "Recuerde que el formato del asunto es estricto:\n"
                     . "[padrón] [ejercicio].[entrega] [código]\n\n"


@@ -115,14 +129,14 @@ while (1) {
             );
         }
         imap_delete($mbox, 1);
             );
         }
         imap_delete($mbox, 1);

-        logs('Mail borrado');
+        logs('Mail borrado', DEBUG);

         imap_expunge($mbox);
         imap_expunge($mbox);

-        logs('Mensajes purgandos', L_DBG);
+        logs('Mensajes purgandos', DEBUG);

         $intervalo = 0; // Que tome el próximo mail enseguida.
     } else {
         $intervalo = 0; // Que tome el próximo mail enseguida.
     } else {

-        logs('No hay mail nuevo', L_DBG);
+        logs('No hay mail nuevo', DEBUG);

     }
     }

-    logs('Cerrando conexión', L_DBG);
+    logs('Cerrando conexión', DEBUG);

     imap_close($mbox);
     sleep($intervalo);
 }
     imap_close($mbox);
     sleep($intervalo);
 }


@@ -147,18 +161,19 @@ imap_close($mbox);
 
 function enviar_respuesta($tipo, $to, $mensaje = '', $intento = null) {
     global $mconf;
 
 function enviar_respuesta($tipo, $to, $mensaje = '', $intento = null) {
     global $mconf;

-    $subject = $mconf['prefijo'] . ' Entrega ';
+    $subject = '[' . $mconf['prefijo'] . '] Entrega ';

     if ($tipo == R_OK) $estado = 'ACEPTADA';
     else               $estado = 'RECHAZADA';
     $subject .= $estado;
     $body .= "Estado: $estado\n";
     if ($mensaje) $body .= "\n$mensaje\n";
     if ($intento) $body .= "\n" . $intento->__toString() . "\n";
     if ($tipo == R_OK) $estado = 'ACEPTADA';
     else               $estado = 'RECHAZADA';
     $subject .= $estado;
     $body .= "Estado: $estado\n";
     if ($mensaje) $body .= "\n$mensaje\n";
     if ($intento) $body .= "\n" . $intento->__toString() . "\n";

-    logs("Envío de mail '$subject' a '$to'\n$body\n", L_DBG);
+    logs("Envío de mail '$subject' a '$to'\n$body\n", DEBUG);

     $headers = <<<EOT
 From: {$mconf['from']}
     $headers = <<<EOT
 From: {$mconf['from']}

-Reply-To: {$mconf['mail_admin']}
-X-Mailer: {$mconf['mailer']}
+Reply-To: {$mconf['admin']}
+Return-Path: {$mconf['admin']}
+X-Mailer: $NAME $VERSION

 X-Priority: 5
 EOT;
     mail($to, $subject, $body, $headers);
 X-Priority: 5
 EOT;
     mail($to, $subject, $body, $headers);


@@ -177,15 +192,15 @@ function validar_cabecera($hdr) {
 }
 
 function preparar_entrega($intento, $mbox, $msgid, $dir) {
 }
 
 function preparar_entrega($intento, $mbox, $msgid, $dir) {

-    logs('Acá debería verificar el cuerpo del mensaje', L_DBG);
+    logs('Acá debería verificar el cuerpo del mensaje', DEBUG);
+    $path = "$dir/" . $intento->path('intentos');

     $mail = imap_fetchstructure($mbox, $msgid);
     $mail = imap_fetchstructure($mbox, $msgid);

+    if (!mkdir_p($path)) return 'No se pudo crear el directorio';

     foreach ($mail->parts as $id => $part) {
         $fname = part_filename($part);
         if ($fname) {
     foreach ($mail->parts as $id => $part) {
         $fname = part_filename($part);
         if ($fname) {

-            logs("Escribiendo archivo '$fname' [enc={$part->encoding}]", L_DBG);
+            logs("Escribiendo archivo '$fname' [enc={$part->encoding}]", DEBUG);

             $body = imap_fetchbody($mbox, $msgid, $id + 1);
             $body = imap_fetchbody($mbox, $msgid, $id + 1);

-            $path = "$dir/" . $intento->path();
-            if (!mkdir_p($path)) return 'No se pudo crear el directorio';

             if (!file_put_contents("$path/$fname", decode_body($body, $part->encoding))) return "Error al guardar el archivo $fname";
         }
         //if (part_is_source($part) $has_sources = true;
             if (!file_put_contents("$path/$fname", decode_body($body, $part->encoding))) return "Error al guardar el archivo $fname";
         }
         //if (part_is_source($part) $has_sources = true;


@@ -247,7 +262,7 @@ function decode_body($body, $encoding) {
         case ENCQUOTEDPRINTABLE: return imap_qprint($body);
         case ENCOTHER:           return $body;
     }
         case ENCQUOTEDPRINTABLE: return imap_qprint($body);
         case ENCOTHER:           return $body;
     }

-    logs('Encoding no reconocido.', L_ERR);
+    logs('Encoding no reconocido.', WARNING);

     return $body;
 }
 
     return $body;
 }