plugins/mail_fetch/fetch.php

   1 <?php
   2
   3 /**
   4  * mail_fetch/fetch.php
   5  *
   6  * Copyright (c) 1999-2003 The SquirrelMail Project Team
   7  * Licensed under the GNU GPL. For full terms see the file COPYING.
   8  *
   9  * Fetch code.
  10  *
  11  * $Id$
  12  */
  13
  14 define('SM_PATH','../../');
  15
  16 require_once(SM_PATH . 'include/validate.php');
  17 require_once(SM_PATH . 'functions/page_header.php');
  18 require_once(SM_PATH . 'functions/imap.php');
  19 require_once(SM_PATH . 'include/load_prefs.php');
  20 require_once(SM_PATH . 'plugins/mail_fetch/class.POP3.php');
  21 require_once(SM_PATH . 'plugins/mail_fetch/functions.php' );
  22 require_once(SM_PATH . 'functions/html.php' );
  23
  24 /* globals */
  25 sqgetGlobalVar('username',   $username,   SQ_SESSION);
  26 sqgetGlobalVar('key',        $key,        SQ_COOKIE);
  27 sqgetGlobalVar('onetimepad', $onetimepad, SQ_SESSION);
  28 sqgetGlobalVar('delimiter',  $delimiter,  SQ_SESSION);
  29 /* end globals */
  30
  31     function Mail_Fetch_Status($msg) {
  32         echo html_tag( 'table',
  33                    html_tag( 'tr',
  34                        html_tag( 'td', htmlspecialchars( $msg ) , 'left' )
  35                    ),
  36                  '', '', 'width="90%"' );
  37         flush();
  38     }
  39
  40     function Mail_Fetch_Servers() {
  41         $mailfetch['server_number'] = getPref($data_dir, $username, "mailfetch_server_number");
  42         if (!isset($mailfetch['server_number']) || ($mailfetch['server_number'] < 1)) {
  43             $mailfetch['server_number'] = 0;
  44         }
  45         $mailfetch['cypher'] = getPref($data_dir, $username, "mailfetch_cypher");
  46         for ($i = 0; $i < $mailfetch['server_number']; $i++) {
  47             $mailfetch[$i]['server'] = getPref($data_dir, $username, "mailfetch_server_$i");
  48             $mailfetch[$i]['port']   = getPref($data_dir, $username, "mailfetch_port_$i");
  49             $mailfetch[$i]['alias']  = getPref($data_dir, $username, "mailfetch_alias_$i");
  50             $mailfetch[$i]['user']   = getPref($data_dir, $username, "mailfetch_user_$i");
  51             $mailfetch[$i]['pass']   = getPref($data_dir, $username, "mailfetch_pass_$i");
  52             if($mailfetch['cypher'] == 'on') {
  53                 $mailfetch[$i]['pass'] = decrypt($mailfetch[$i]['pass']);
  54             }
  55             if ($mailfetch[$i]['pass'] == '') {
  56                 sqgetGlobalVar("pass_$i", $mailfetch[$i]['pass'], SQ_POST);
  57             }
  58             $mailfetch[$i]['lmos']   = getPref($data_dir, $username, "mailfetch_lmos_$i");
  59             $mailfetch[$i]['login']  = getPref($data_dir, $username, "mailfetch_login_$i");
  60             $mailfetch[$i]['uidl']   = getPref($data_dir, $username, "mailfetch_uidl_$i");
  61             $mailfetch[$i]['subfolder'] = getPref($data_dir, $username, "mailfetch_subfolder_$i");
  62             if($mailfetch[$i]['alias'] == '') {
  63                 $mailfetch[$i]['alias'] == $mailfetch[$i]['server'];
  64             }
  65         }
  66         return $mailfetch;
  67     }
  68
  69     function Mail_Fetch_Select_Server($mailfetch) {
  70         echo '<font size=-5><br></font>' .
  71              "<form action=\"$PHP_SELF\" method=\"post\" target=\"_self\">" .
  72              html_tag( 'table', '', 'center', '', 'width="70%" cols="2"' ) .
  73                  html_tag( 'tr' ) .
  74                      html_tag( 'td', _("Select Server:") . ' &nbsp; &nbsp;', 'right' ) .
  75                      html_tag( 'td', '', 'left' ) .
  76                          '<select name="server_to_fetch" size="1">' .
  77                          '<option value="all" selected>..' . _("All") . "...\n";
  78         for ($i = 0;$i < $mailfetch['server_number'];$i++) {
  79              echo "<option value=\"$i\">" .
  80                  htmlspecialchars($mailfetch[$i]['alias']) .
  81                   '</option>' . "\n";
  82         }
  83         echo            '</select>' .
  84                     '</td>' .
  85                 '</tr>';
  86
  87         //if password not set, ask for it
  88         for ($i = 0;$i < $mailfetch['server_number'];$i++) {
  89              if ($mailfetch[$i]['pass'] == '') {
  90                   echo html_tag( 'tr',
  91                               html_tag( 'td', _("Password for") . ' <b>' .
  92                                   htmlspecialchars($mailfetch[$i]['alias']) .
  93                                   '</b>: &nbsp; &nbsp; ',
  94                               'right' ) .
  95                               html_tag( 'td', '<input type="password" name="pass_' . $i . '">', 'left' )
  96                           );
  97              }
  98         }
  99         echo html_tag( 'tr',
 100                    html_tag( 'td', '&nbsp;' ) .
 101                    html_tag( 'td', '<input type=submit name=submit_mailfetch value="' . _("Fetch Mail"). '">', 'left' )
 102                ) .
 103              '</table></form>';
 104     }
 105
 106     $mailfetch = Mail_Fetch_Servers();
 107     displayPageHeader($color, 'None');
 108
 109     echo '<br><center>';
 110
 111     echo html_tag( 'table',
 112                html_tag( 'tr',
 113                    html_tag( 'td', '<b>' . _("Remote POP server Fetching Mail") . '</b>', 'center', $color[0] )
 114                ) ,
 115            'center', '', 'width="95%" cols="1"' );
 116
 117     // get $server_to_fetch from globals, if not set display a choice to the user
 118     if (! sqgetGlobalVar('server_to_fetch', $server_to_fetch, SQ_POST) ) {
 119         Mail_Fetch_Select_Server($mailfetch);
 120         exit();
 121     }
 122
 123     if ( $server_to_fetch == 'all' ) {
 124         $i_start = 0;
 125         $i_stop  = $mailfetch['server_number'];
 126     } else {
 127         $i_start = $server_to_fetch;
 128         $i_stop  = $i_start+1;
 129     }
 130
 131     for ($i_loop=$i_start;$i_loop<$i_stop;$i_loop++) {
 132         $mailfetch_server = $mailfetch[$i_loop]['server'];
 133         $mailfetch_port   = $mailfetch[$i_loop]['port'];
 134         $mailfetch_user   = $mailfetch[$i_loop]['user'];
 135         $mailfetch_pass   = $mailfetch[$i_loop]['pass'];
 136         $mailfetch_lmos   = $mailfetch[$i_loop]['lmos'];
 137         $mailfetch_login  = $mailfetch[$i_loop]['login'];
 138         $mailfetch_uidl   = $mailfetch[$i_loop]['uidl'];
 139         $mailfetch_subfolder = $mailfetch[$i_loop]['subfolder'];
 140         if($mailfetch_subfolder == '') {
 141             $mailfetch_subfolder == 'INBOX';
 142         }
 143
 144         $pop3 = new POP3($mailfetch_server, 60);
 145
 146         echo '<br>' .
 147         html_tag( 'table',
 148             html_tag( 'tr',
 149                 html_tag( 'td', '<b>' . _("Fetching from ") .
 150                     htmlspecialchars($mailfetch[$i_loop]['alias']) .
 151                     '</b>',
 152                 'center' ) ,
 153             '', $color[9] ) ,
 154         '', '', 'width="90%"' );
 155
 156         flush();
 157
 158         if (!$pop3->connect($mailfetch_server,$mailfetch_port)) {
 159             Mail_Fetch_Status(_("Oops, ") . $pop3->ERROR );
 160             continue;
 161         }
 162
 163         Mail_Fetch_Status(_("Opening IMAP server"));
 164         $imap_stream = sqimap_login($username, $key, $imapServerAddress, $imapPort, 10);
 165
 166         Mail_Fetch_Status(_("Opening POP server"));
 167         $Count = $pop3->login($mailfetch_user, $mailfetch_pass);
 168         if (($Count == false || $Count == -1) && $pop3->ERROR != '') {
 169             Mail_Fetch_Status(_("Login Failed:") . ' ' . $pop3->ERROR );
 170             continue;
 171         }
 172
 173         //   register_shutdown_function($pop3->quit());
 174
 175         $msglist = $pop3->uidl();
 176
 177         $i = 1;
 178         for ($j = 1; $j < sizeof($msglist); $j++) {
 179            if ($msglist[$j] == $mailfetch_uidl) {
 180                 $i = $j+1;
 181                 break;
 182            }
 183         }
 184
 185         if ($Count < $i) {
 186             Mail_Fetch_Status(_("Login OK: No new messages"));
 187             $pop3->quit();
 188             continue;
 189         }
 190         if ($Count == 0) {
 191             Mail_Fetch_Status(_("Login OK: Inbox EMPTY"));
 192             $pop3->quit();
 193             continue;
 194         } else {
 195             $newmsgcount = $Count - $i + 1;
 196             Mail_Fetch_Status(_("Login OK: Inbox contains [") . $newmsgcount . _("] messages"));
 197         }
 198
 199         Mail_Fetch_Status(_("Fetching UIDL..."));
 200         // Faster to get them all at once
 201         $mailfetch_uidl = $pop3->uidl();
 202
 203         if (! is_array($mailfetch_uidl) && $mailfetch_lmos == 'on')
 204             Mail_Fetch_Status(_("Server does not support UIDL."));
 205
 206         if ($mailfetch_lmos == 'on') {
 207             Mail_Fetch_Status(_("Leaving Mail on Server..."));
 208         } else {
 209             Mail_Fetch_Status(_("Deleting messages from server..."));
 210         }
 211
 212         for (; $i <= $Count; $i++) {
 213             Mail_Fetch_Status(_("Fetching message ") . "$i" );
 214             set_time_limit(20); // 20 seconds per message max
 215             $Message = '';
 216             $MessArray = $pop3->get($i);
 217
 218             while ( (!$MessArray) or (gettype($MessArray) != "array")) {
 219                  Mail_Fetch_Status(_("Oops, ") . $pop3->ERROR);
 220                  // re-connect pop3
 221                  Mail_Fetch_Status(_("Server error...Disconnect"));
 222                  $pop3->quit();
 223                  Mail_Fetch_Status(_("Reconnect from dead connection"));
 224                  if (!$pop3->connect($mailfetch_server)) {
 225                      Mail_Fetch_Status(_("Oops, ") . $pop3->ERROR );
 226                      Mail_Fetch_Status(_("Saving UIDL"));
 227                      setPref($data_dir,$username,"mailfetch_uidl_$i_loop", $mailfetch_uidl[$i-1]);
 228
 229                      continue;
 230                  }
 231                  $Count = $pop3->login($mailfetch_user, $mailfetch_pass);
 232                  if (($Count == false || $Count == -1) && $pop3->ERROR != '') {
 233                      Mail_Fetch_Status(_("Login Failed:") . ' ' . $pop3->ERROR );
 234                      Mail_Fetch_Status(_("Saving UIDL"));
 235                      setPref($data_dir,$username,"mailfetch_uidl_$i_loop", $mailfetch_uidl[$i-1]);
 236
 237                      continue;
 238                  }
 239                  Mail_Fetch_Status(_("Refetching message ") . "$i" );
 240                  $MessArray = $pop3->get($i);
 241
 242             } // end while
 243
 244             while (list($lineNum, $line) = each ($MessArray)) {
 245                  $Message .= $line;
 246             }
 247
 248             fputs($imap_stream, "A3$i APPEND \"$mailfetch_subfolder\" {" . strlen($Message) . "}\r\n");
 249             $Line = fgets($imap_stream, 1024);
 250             if (substr($Line, 0, 1) == '+') {
 251                 fputs($imap_stream, $Message);
 252                 fputs($imap_stream, "\r\n");
 253                 sqimap_read_data($imap_stream, "A3$i", false, $response, $message);
 254                 if ($response != 'OK') {
 255                     Mail_Fetch_Status(_("Error Appending Message!")." ".$message );
 256                     Mail_Fetch_Status(_("Closing POP"));
 257                     $pop3->quit();
 258                     Mail_Fetch_Status(_("Logging out from IMAP"));
 259                     sqimap_logout($imap_stream);
 260
 261                     Mail_Fetch_Status(_("Saving UIDL"));
 262                     setPref($data_dir,$username,"mailfetch_uidl_$i_loop", $mailfetch_uidl[$i-1]);
 263                     exit;
 264                 } else {
 265                     Mail_Fetch_Status(_("Message appended to mailbox"));
 266                 }
 267
 268                 if ($mailfetch_lmos != 'on') {
 269                    if( $pop3->delete($i) ) {
 270                         Mail_Fetch_Status(_("Message ") . $i . _(" deleted from Remote Server!"));
 271                    } else {
 272                         Mail_Fetch_Status(_("Delete failed:") . $pop3->ERROR );
 273                    }
 274                 }
 275             } else {
 276                 echo $Line;
 277                 Mail_Fetch_Status(_("Error Appending Message!"));
 278                 Mail_Fetch_Status(_("Closing POP"));
 279                 $pop3->quit();
 280                 Mail_Fetch_Status(_("Logging out from IMAP"));
 281                 sqimap_logout($imap_stream);
 282
 283                 // not gurantee corect!
 284                 Mail_Fetch_Status(_("Saving UIDL"));
 285                 setPref($data_dir,$username,"mailfetch_uidl_$i_loop", $mailfetch_uidl[$i-1]);
 286                 exit;
 287             }
 288         }
 289
 290         Mail_Fetch_Status(_("Closing POP"));
 291         $pop3->quit();
 292         Mail_Fetch_Status(_("Logging out from IMAP"));
 293         sqimap_logout($imap_stream);
 294         if (is_array($mailfetch_uidl)) {
 295             Mail_Fetch_Status(_("Saving UIDL"));
 296             setPref($data_dir,$username,"mailfetch_uidl_$i_loop", array_pop($mailfetch_uidl));
 297         }
 298
 299         Mail_Fetch_Status(_("Done"));
 300
 301    }
 302
 303 ?>
 304 </center>
 305 </body>
 306 </html>