src/sc_fetch

   1 #!/usr/bin/php4
   2 <?php // vim: set binary noeol et sw=4 sts=4:
   3
   4 require_once 'T/general.php';
   5
   6 define('R_ERR', 0);
   7 define('R_OK',  1);
   8
   9 // cargo extensión IMAP
  10 T_dl('imap');
  11
  12 $mconf = $CONF['mail'];
  13 $gconf = $CONF['general'];
  14
  15 $mailbox = @$mconf['mailbox'];
  16 switch (@$mconf['protocol'] ? $mconf['protocol'] : 'mbox') {
  17     case 'mbox':
  18         $mailbox = $mconf['server'];
  19         break;
  20     case 'pop':
  21     case 'imap':
  22     case 'nntp':
  23         $port    = @$mconf['port'] ? ":{$mconf['port']}" : '';
  24         $options = @$mconf['options'] ? "/{$mconf['options']}" : '';
  25         $mailbox = "{{$mconf['server']}$port/{$mconf['protocol']}$options}$mailbox";
  26         break;
  27     default:
  28         logsdie("Error: el protocolo {$mconf['protocol']} no está soportado");
  29 }
  30
  31 #$mbox = imap_open($mailbox, @$mconf['user'], @$mconf['pass']);
  32
  33 /*
  34 echo "Mailboxes\n";
  35 $folders = imap_list($mbox, $mailbox, '*');
  36
  37 if ($folders == false) {
  38     echo "Call failed\n";
  39 } else {
  40     while (list ($key, $val) = each($folders)) {
  41         echo "$val\n";
  42     }
  43 }
  44 */
  45
  46 /*
  47 echo "Headers in INBOX\n";
  48 $headers = imap_headers($mbox);
  49
  50 if ($headers) {
  51     while (list ($key, $val) = each ($headers)) {
  52         echo "$val\n";
  53     }
  54 } else {
  55     echo "Call failed\n";
  56 }
  57
  58 for ($i = 1; $i <= imap_num_msg($mbox); $i++)
  59 {
  60     $header = imap_headerinfo($mbox, $i);
  61     echo $header->fromaddress . "\n";
  62     #var_dump(imap_headerinfo($mbox, $i, 80, 80));
  63 }
  64 */
  65
  66 $claves = $gconf['claves'];
  67
  68 // Errores tratando de conectar al mail
  69 $mbox_errcount = 0;
  70
  71 // Sin cesar.
  72 while (1) {
  73     // Reseteo intervalo
  74     $intervalo = $gconf['intervalo'];
  75     // Abro mailbox o chillo.
  76     if (!($mbox = imap_open($mailbox, @$mconf['user'], @$mconf['pass']))) {
  77         if ($mbox_errcount * $intervalo > 120) { // 2 horas sin poder conectarse
  78             logs('Hace 2 horas que no se puede conectar al servidor ('.imap_last_error().')', ERROR);
  79             $mbox_errcount = 0;
  80         } else {
  81             logs('No se pudo conectar al servidor ('.imap_last_error().')', WARNING);
  82         }
  83         $mbox_errcount++;
  84         sleep($intervalo);
  85         continue;
  86     }
  87     $mbox_errcount = 0;
  88     logs('Conectado como '.@$mconf['user']." a $mailbox", DEBUG);
  89     if (imap_num_msg($mbox) and $hdr = imap_headerinfo($mbox, 1)) {
  90         logs("Nuevo mail '{$hdr->subject}' de {$hdr->fromaddress}");
  91         @list($padron, $ej, $ent, $codigo) = validar_cabecera($hdr);
  92         if ($padron) {
  93             logs('Cabecera válida', DEBUG);
  94             $intento = new T_Intento($padron, $ej, $ent);
  95             if (!($err = $intento->validar_entrega($codigo, $claves))) {
  96                 logs('Entrega aceptada ('.$intento->to_line().')');
  97                 if (!($err = preparar_entrega($intento, $mbox, 1, $gconf['data_dir']))) {
  98                     logs('Intento preparado', DEBUG);
  99                     $res = $intento->hacer_entrega($hdr->fromaddress);
 100                     if (PEAR::isError($res)) {
 101                         logs('Error al hacer entrega (' . $res->getMessage() . ')', ERROR);
 102                         enviar_respuesta(R_ERR, $hdr->fromaddress, "Error interno al preparar entrega.\n\nSe envió un mensaje al administrador avisando del problema.", $intento);
 103                         enviar_respuesta(R_ERR, $mconf['admin'], "Error de la DB al preparar entrega:\n" . $res->getMessage(), $intento);
 104                     } else {
 105                         logs('Intento encolado para compilar', DEBUG);
 106                         enviar_respuesta(R_OK, $hdr->fromaddress, null, $intento);
 107                         guardar_mbox($mbox, 1, $hdr, @$mconf['mbox_bak']);
 108                     }
 109                 } else {
 110                     logs("Error al preparar entrega ($err)", ERROR);
 111                     enviar_respuesta(R_ERR, $hdr->fromaddress, "Error interno al preparar entrega.\n\nSe envió un mensaje al administrador avisando del problema.", $intento);
 112                     enviar_respuesta(R_ERR, $mconf['admin'], "Error al preparar entrega:\n$err", $intento);
 113                 }
 114             } else {
 115                 logs("Entrega rechazada ($err)", WARNING);
 116                 enviar_respuesta(R_ERR, $hdr->fromaddress, $err, $intento);
 117             }
 118         } else {
 119             logs('Entrega rechazada (subject inválido)', WARNING);
 120             enviar_respuesta(R_ERR, $hdr->fromaddress, "Asunto (subject) inválido.\n\n"
 121                     . "Recuerde que el formato del asunto es estricto:\n"
 122                     . "[padrón] [ejercicio].[entrega] [código]\n\n"
 123                     . "Donde [padrón] es su número de padrón, [ejercicio] es el número de\n"
 124                     . "ejercicio (1 a 4), [entrega] el número de entrega (1 o 2) y [código]\n"
 125                     . "es el código verificador que le fue asignado por la cátedra.\n"
 126             );
 127         }
 128         imap_delete($mbox, 1);
 129         logs('Mail borrado', DEBUG);
 130         imap_expunge($mbox);
 131         logs('Mensajes purgandos', DEBUG);
 132         $intervalo = 0; // Que tome el próximo mail enseguida.
 133     } else {
 134         logs('No hay mail nuevo', DEBUG);
 135     }
 136     logs('Cerrando conexión', DEBUG);
 137     imap_close($mbox);
 138     sleep($intervalo);
 139 }
 140
 141
 142 /*
 143 do {
 144     $mail = imap_fetchstructure($mbox, 1);
 145     var_dump($mail);exit;
 146     for ($mail->parts as $id => $part) {
 147         if ($part->type == TYPEAPPLICATION) {
 148         }
 149     }
 150 } while (!validate_header($header));
 151
 152
 153 file_put_contents('attach', fetchbody_decoded($mbox, 4, 2))
 154     or die("no se puede escribir archivo de salida\n");
 155
 156 imap_close($mbox);
 157 */
 158
 159 function enviar_respuesta($tipo, $to, $mensaje = '', $intento = null) {
 160     global $mconf;
 161     $subject = '[' . strtoupper($NAME) . '] Entrega ';
 162     if ($tipo == R_OK) $estado = 'ACEPTADA';
 163     else               $estado = 'RECHAZADA';
 164     $subject .= $estado;
 165     $body .= "Estado: $estado\n";
 166     if ($mensaje) $body .= "\n$mensaje\n";
 167     if ($intento) $body .= "\n" . $intento->__toString() . "\n";
 168     logs("Envío de mail '$subject' a '$to'\n$body\n", DEBUG);
 169     $headers = <<<EOT
 170 From: {$mconf['from']}
 171 Reply-To: {$mconf['admin']}
 172 X-Mailer: $NAME $VERSION
 173 X-Priority: 5
 174 EOT;
 175     mail($to, $subject, $body, $headers);
 176     return true;
 177 }
 178
 179 /**
 180  * @returns array($padron, $ej, $entrega, $codigo) o false si no es válida.
 181  */
 182 function validar_cabecera($hdr) {
 183     // Subject: padron nro_ej nro_entrega clave_alumno
 184     if (preg_match('/^\s*(\d{5})\s+([1-4])\.([12])\s+(.*)$/', $hdr->subject, $m)) {
 185         return array_slice($m, 1, 5);
 186     }
 187     return false;
 188 }
 189
 190 function preparar_entrega($intento, $mbox, $msgid, $dir) {
 191     logs('Acá debería verificar el cuerpo del mensaje', DEBUG);
 192     $mail = imap_fetchstructure($mbox, $msgid);
 193     foreach ($mail->parts as $id => $part) {
 194         $fname = part_filename($part);
 195         if ($fname) {
 196             logs("Escribiendo archivo '$fname' [enc={$part->encoding}]", DEBUG);
 197             $body = imap_fetchbody($mbox, $msgid, $id + 1);
 198             $path = "$dir/" . $intento->path();
 199             if (!mkdir_p($path)) return 'No se pudo crear el directorio';
 200             if (!file_put_contents("$path/$fname", decode_body($body, $part->encoding))) return "Error al guardar el archivo $fname";
 201         }
 202         //if (part_is_source($part) $has_sources = true;
 203         //elseif (part_mime_type($part) == 'application/zip') $has_sources = true;
 204     }
 205     return '';
 206 }
 207
 208 function part_is_source($part) {
 209     if (part_mime_type($part) == 'application/zip') return true;
 210 /*    if (part_mime_type($part) == 'application/octet-stream') {
 211         $extension = (part_filename($part));
 212         if (,  {
 213         }
 214     } */
 215     return false;
 216 }
 217
 218 function part_filename($part) {
 219     if (!@$part->dparameters or !is_array($part->dparameters)) {
 220         return '';
 221     }
 222     foreach ($part->dparameters as $param) {
 223         if ($param->attribute == 'FILENAME') {
 224             return $param->value;
 225         }
 226     }
 227     return '';
 228 }
 229
 230 function part_mime_type($part) {
 231     switch ($part->type) {
 232         case TYPETEXT:
 233             return 'text/'.strtolower($part->subtype);
 234         case TYPEMULTIPART:
 235             return 'multipart/'.strtolower($part->subtype);
 236         case TYPEMESSAGE:
 237             return 'message/'.strtolower($part->subtype);
 238         case TYPEAPPLICATION:
 239             return 'application/'.strtolower($part->subtype);
 240         case TYPEAUDIO:
 241             return 'audio/'.strtolower($part->subtype);
 242         case TYPEIMAGE:
 243             return 'image/'.strtolower($part->subtype);
 244         case TYPEVIDEO:
 245             return 'video/'.strtolower($part->subtype);
 246         case TYPEOTHER:
 247         default:
 248             return 'other/'.strtolower($part->subtype);
 249     }
 250 }
 251
 252 function decode_body($body, $encoding) {
 253     switch ($encoding) {
 254         case ENC7BIT:            return fix_eol($body);
 255         case ENC8BIT:            return fix_eol($body); //imap_8bit($body);
 256         case ENCBINARY:          return imap_binary($body);
 257         case ENCBASE64:          return imap_base64($body);
 258         case ENCQUOTEDPRINTABLE: return imap_qprint($body);
 259         case ENCOTHER:           return $body;
 260     }
 261     logs('Encoding no reconocido.', WARNING);
 262     return $body;
 263 }
 264
 265 function mkdir_p($target) {
 266     if (is_dir($target) or empty($target))               return 1;
 267     if (file_exists($target) and !is_dir($target))       return 0;
 268     if (mkdir_p(substr($target,0,strrpos($target,'/')))) return mkdir($target);
 269     return 0;
 270 }
 271
 272 function guardar_mbox($mbox, $msgid, $hdr, $mbox_fname) {
 273     if ($mbox_fname) {
 274         $fo = @fopen($mbox_fname, 'a');
 275         if (!$fo) {
 276             logserr("No se pudo abrir mbox '$mbox_fname'");
 277             return false;
 278         }
 279         fputs($fo, sprintf("From %s@%s %s\n", $hdr->from[0]->mailbox, $hdr->from[0]->host, date('D M j H:i:s Y')));
 280         fputs($fo, fix_eol(imap_fetchheader($mbox, $msgid, FT_PREFETCHTEXT)));
 281         fputs("\n");
 282         fputs($fo, fix_eol(imap_body($mbox, $msgid)));
 283         fclose($fo);
 284     }
 285     return true;
 286 }
 287
 288 function fix_eol($str) {
 289     return str_replace("\r\n", "\n", $str);
 290 }
 291
 292 ?>