Se agrega un timeout a sqlite para que espere si esta lockeada la DB.

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

diff --git a/src/sc_fetch b/src/sc_fetch
index 5d3c16a7a3c419e07ddc8b0d2e87b57c2c1e5e01..7a1e407a34450eef7118312c851a30bbbbb72c37 100755 (executable)
--- a/src/sc_fetch
+++ b/src/sc_fetch
@@ -161,7 +161,7 @@ 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;
     if ($tipo == R_OK) $estado = 'ACEPTADA';
     else               $estado = 'RECHAZADA';
     $subject .= $estado;


@@ -193,14 +193,14 @@ function validar_cabecera($hdr) {
 
 function preparar_entrega($intento, $mbox, $msgid, $dir) {
     logs('Acá debería verificar el cuerpo del mensaje', DEBUG);
 
 function preparar_entrega($intento, $mbox, $msgid, $dir) {
     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) {
             logs("Escribiendo archivo '$fname' [enc={$part->encoding}]", DEBUG);
             $body = imap_fetchbody($mbox, $msgid, $id + 1);
     foreach ($mail->parts as $id => $part) {
         $fname = part_filename($part);
         if ($fname) {
             logs("Escribiendo archivo '$fname' [enc={$part->encoding}]", DEBUG);
             $body = imap_fetchbody($mbox, $msgid, $id + 1);

-            $path = "$dir/" . $intento->path('intentos');
-            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;