| 1 | <?php |
| 2 | |
| 3 | /** |
| 4 | * mail_fetch/fetch.php |
| 5 | * |
| 6 | * Fetch code. |
| 7 | * |
| 8 | * @copyright 1999-2020 The SquirrelMail Project Team |
| 9 | * @license http://opensource.org/licenses/gpl-license.php GNU Public License |
| 10 | * @version $Id$ |
| 11 | * @package plugins |
| 12 | * @subpackage mail_fetch |
| 13 | */ |
| 14 | |
| 15 | /** |
| 16 | * Include the SquirrelMail initialization file. |
| 17 | */ |
| 18 | require('../../include/init.php'); |
| 19 | |
| 20 | include_once(SM_PATH . 'functions/imap_general.php'); |
| 21 | include_once(SM_PATH . 'plugins/mail_fetch/functions.php' ); |
| 22 | |
| 23 | // don't load this page if this plugin is not enabled |
| 24 | // |
| 25 | global $plugins; |
| 26 | if (!in_array('mail_fetch', $plugins)) exit; |
| 27 | |
| 28 | /* globals */ |
| 29 | sqgetGlobalVar('delimiter', $delimiter, SQ_SESSION); |
| 30 | global $imap_stream_options; // in case not defined in config |
| 31 | /* end globals */ |
| 32 | |
| 33 | /** |
| 34 | * @param string $msg message |
| 35 | */ |
| 36 | function Mail_Fetch_Status($msg) { |
| 37 | echo html_tag( 'table', |
| 38 | html_tag( 'tr', |
| 39 | html_tag( 'td', sm_encode_html_special_chars( $msg ) , 'left' ) |
| 40 | ), |
| 41 | '', '', 'width="90%"' ); |
| 42 | flush(); |
| 43 | } |
| 44 | |
| 45 | /** |
| 46 | * @return array |
| 47 | */ |
| 48 | function Mail_Fetch_Servers() { |
| 49 | global $data_dir, $username; |
| 50 | |
| 51 | $mailfetch = array(); |
| 52 | $mailfetch['server_number'] = getPref($data_dir, $username, "mailfetch_server_number"); |
| 53 | if (!isset($mailfetch['server_number']) || ($mailfetch['server_number'] < 1)) { |
| 54 | $mailfetch['server_number'] = 0; |
| 55 | } |
| 56 | $mailfetch['cypher'] = getPref($data_dir, $username, "mailfetch_cypher"); |
| 57 | |
| 58 | for ($i = 0; $i < $mailfetch['server_number']; $i++) { |
| 59 | $mailfetch[$i]['server'] = getPref($data_dir, $username, "mailfetch_server_$i"); |
| 60 | $mailfetch[$i]['port'] = getPref($data_dir, $username, "mailfetch_port_$i"); |
| 61 | $mailfetch[$i]['alias'] = getPref($data_dir, $username, "mailfetch_alias_$i"); |
| 62 | $mailfetch[$i]['user'] = getPref($data_dir, $username, "mailfetch_user_$i"); |
| 63 | $mailfetch[$i]['pass'] = getPref($data_dir, $username, "mailfetch_pass_$i"); |
| 64 | if($mailfetch['cypher'] == 'on') { |
| 65 | $mailfetch[$i]['pass'] = decrypt($mailfetch[$i]['pass']); |
| 66 | } |
| 67 | if ($mailfetch[$i]['pass'] == '') { |
| 68 | sqgetGlobalVar("pass_$i", $mailfetch[$i]['pass'], SQ_POST); |
| 69 | } |
| 70 | $mailfetch[$i]['lmos'] = getPref($data_dir, $username, "mailfetch_lmos_$i"); |
| 71 | $mailfetch[$i]['login'] = getPref($data_dir, $username, "mailfetch_login_$i"); |
| 72 | $mailfetch[$i]['uidl'] = getPref($data_dir, $username, "mailfetch_uidl_$i"); |
| 73 | $mailfetch[$i]['subfolder'] = getPref($data_dir, $username, "mailfetch_subfolder_$i"); |
| 74 | if($mailfetch[$i]['alias'] == '') { |
| 75 | $mailfetch[$i]['alias'] == $mailfetch[$i]['server']; |
| 76 | } |
| 77 | // Authentication type (added in 1.5.2) |
| 78 | $mailfetch[$i]['auth'] = getPref($data_dir, $username, "mailfetch_auth_$i",MAIL_FETCH_AUTH_USER); |
| 79 | // Connection type (added in 1.5.2) |
| 80 | $mailfetch[$i]['type'] = getPref($data_dir, $username, "mailfetch_type_$i",MAIL_FETCH_USE_PLAIN); |
| 81 | } |
| 82 | return $mailfetch; |
| 83 | } |
| 84 | |
| 85 | /** |
| 86 | * @param array $mailfetch |
| 87 | */ |
| 88 | function Mail_Fetch_Select_Server($mailfetch) { |
| 89 | global $PHP_SELF; |
| 90 | |
| 91 | echo '<font size="-5"><br /></font>' . |
| 92 | '<form action="'.$PHP_SELF.'" method="post" target="_self">' . |
| 93 | html_tag( 'table', '', 'center', '', 'width="70%" cols="2"' ) . |
| 94 | html_tag( 'tr' ) . |
| 95 | html_tag( 'td', _("Select Server:") . ' ', 'right' ) . |
| 96 | html_tag( 'td', '', 'left' ) . |
| 97 | '<select name="server_to_fetch" size="1">' . |
| 98 | '<option value="all" selected="selected">..' . _("All") . "...\n"; |
| 99 | for ($i = 0;$i < $mailfetch['server_number'];$i++) { |
| 100 | echo "<option value=\"$i\">" . |
| 101 | sm_encode_html_special_chars($mailfetch[$i]['alias']) . |
| 102 | '</option>' . "\n"; |
| 103 | } |
| 104 | echo '</select>' . |
| 105 | '</td>' . |
| 106 | '</tr>'; |
| 107 | |
| 108 | //if password not set, ask for it |
| 109 | for ($i = 0;$i < $mailfetch['server_number'];$i++) { |
| 110 | if ($mailfetch[$i]['pass'] == '') { |
| 111 | echo html_tag( 'tr', |
| 112 | html_tag( 'td', _("Password for") . ' <b>' . |
| 113 | sm_encode_html_special_chars($mailfetch[$i]['alias']) . |
| 114 | '</b>: ', |
| 115 | 'right' ) . |
| 116 | html_tag( 'td', '<input type="password" name="pass_' . $i . '" />', 'left' ) |
| 117 | ); |
| 118 | } |
| 119 | } |
| 120 | echo html_tag( 'tr', |
| 121 | html_tag( 'td', ' ' ) . |
| 122 | html_tag( 'td', '<input type="submit" name="submit_mailfetch" value="' . _("Fetch Mail"). '" />', 'left' ) |
| 123 | ) . |
| 124 | '</table></form>'; |
| 125 | } |
| 126 | |
| 127 | $mailfetch = Mail_Fetch_Servers(); |
| 128 | displayPageHeader($color); |
| 129 | |
| 130 | echo '<br />'; |
| 131 | |
| 132 | echo html_tag( 'table', |
| 133 | html_tag( 'tr', |
| 134 | html_tag( 'td', '<b>' . _("Remote POP server Fetching Mail") . '</b>', 'center', $color[0] ) |
| 135 | ) , |
| 136 | 'center', '', 'width="95%" cols="1"' ); |
| 137 | |
| 138 | |
| 139 | /* there are no servers defined yet... */ |
| 140 | if($mailfetch['server_number'] == 0) { |
| 141 | //FIXME: do not echo directly to browser -- use templates only |
| 142 | echo '<p>' . _("No POP3 servers configured yet.") . '</p>'; |
| 143 | echo makeInternalLink('plugins/mail_fetch/options.php', |
| 144 | _("Click here to go to the options page.") ); |
| 145 | $oTemplate->display('footer.tpl'); |
| 146 | exit(); |
| 147 | } |
| 148 | |
| 149 | // get $server_to_fetch from globals, if not set display a choice to the user |
| 150 | if (! sqgetGlobalVar('server_to_fetch', $server_to_fetch, SQ_POST) ) { |
| 151 | Mail_Fetch_Select_Server($mailfetch); |
| 152 | $oTemplate->display('footer.tpl'); |
| 153 | exit(); |
| 154 | } |
| 155 | |
| 156 | if ( $server_to_fetch == 'all' ) { |
| 157 | $i_start = 0; |
| 158 | $i_stop = $mailfetch['server_number']; |
| 159 | } else { |
| 160 | $i_start = $server_to_fetch; |
| 161 | $i_stop = $i_start+1; |
| 162 | } |
| 163 | |
| 164 | for ($i_loop=$i_start;$i_loop<$i_stop;$i_loop++) { |
| 165 | $mailfetch_server = $mailfetch[$i_loop]['server']; |
| 166 | $mailfetch_port = $mailfetch[$i_loop]['port']; |
| 167 | $mailfetch_user = $mailfetch[$i_loop]['user']; |
| 168 | $mailfetch_pass = $mailfetch[$i_loop]['pass']; |
| 169 | $mailfetch_lmos = $mailfetch[$i_loop]['lmos']; |
| 170 | $mailfetch_login = $mailfetch[$i_loop]['login']; |
| 171 | $mailfetch_uidl = $mailfetch[$i_loop]['uidl']; |
| 172 | $mailfetch_subfolder = $mailfetch[$i_loop]['subfolder']; |
| 173 | $mailfetch_auth = $mailfetch[$i_loop]['auth']; |
| 174 | $mailfetch_type = $mailfetch[$i_loop]['type']; |
| 175 | |
| 176 | echo '<br />' . |
| 177 | html_tag( 'table', |
| 178 | html_tag( 'tr', |
| 179 | html_tag( 'td', '<b>' . |
| 180 | sprintf(_("Fetching from %s"), |
| 181 | sm_encode_html_special_chars($mailfetch[$i_loop]['alias'])) . |
| 182 | '</b>', |
| 183 | 'center' ) , |
| 184 | '', $color[9] ) , |
| 185 | '', '', 'width="90%"' ); |
| 186 | |
| 187 | flush(); |
| 188 | |
| 189 | $pop3 = new mail_fetch(array('host' => $mailfetch_server, |
| 190 | 'port' => $mailfetch_port, |
| 191 | 'auth' => $mailfetch_auth, |
| 192 | 'tls' => $mailfetch_type, |
| 193 | 'timeout' => 60)); |
| 194 | |
| 195 | if (!empty($pop3->error)) { |
| 196 | Mail_Fetch_Status($pop3->error); |
| 197 | continue; |
| 198 | } |
| 199 | |
| 200 | Mail_Fetch_Status(_("Opening IMAP server")); |
| 201 | $imap_stream = sqimap_login($username, false, $imapServerAddress, $imapPort, 10, $imap_stream_options); |
| 202 | |
| 203 | // check if destination folder is not set, is not subscribed and is not \noselect folder |
| 204 | if($mailfetch_subfolder == '' || |
| 205 | ! mail_fetch_check_folder($imap_stream,$mailfetch_subfolder)) { |
| 206 | $mailfetch_subfolder = 'INBOX'; |
| 207 | } |
| 208 | |
| 209 | Mail_Fetch_Status(_("Opening POP server")); |
| 210 | |
| 211 | /* log into pop server*/ |
| 212 | if (! $pop3->login($mailfetch_user, $mailfetch_pass)) { |
| 213 | Mail_Fetch_Status(_("Login Failed:") . ' ' . sm_encode_html_special_chars($pop3->error)); |
| 214 | continue; |
| 215 | } |
| 216 | |
| 217 | $aMsgStat = $pop3->command_stat(); |
| 218 | if (is_bool($aMsgStat)) { |
| 219 | Mail_Fetch_Status(_("Can't get mailbox status:") . ' ' . sm_encode_html_special_chars($pop3->error) ); |
| 220 | continue; |
| 221 | } |
| 222 | |
| 223 | $Count = $aMsgStat['count']; |
| 224 | |
| 225 | $i = 1; |
| 226 | |
| 227 | if ($Count>0) { |
| 228 | // If we leave messages on server, try using UIDL |
| 229 | if ($mailfetch_lmos == 'on') { |
| 230 | Mail_Fetch_Status(_("Fetching UIDL...")); |
| 231 | $msglist = $pop3->command_uidl(); |
| 232 | if (is_bool($msglist)) { |
| 233 | Mail_Fetch_Status(_("Server does not support UIDL.") . ' '.sm_encode_html_special_chars($pop3->error)); |
| 234 | // User asked to leave messages on server, but we can't do that. |
| 235 | $pop3->command_quit(); |
| 236 | continue; |
| 237 | // $mailfetch_lmos = 'off'; |
| 238 | } else { |
| 239 | // calculate number of new messages |
| 240 | for ($j = 1; $j <= sizeof($msglist); $j++) { |
| 241 | // do strict comparison ('1111.10' should not be equal to '1111.100') |
| 242 | if ($msglist[$j] === $mailfetch_uidl) { |
| 243 | $i = $j+1; |
| 244 | break; |
| 245 | } |
| 246 | } |
| 247 | } |
| 248 | } |
| 249 | // fetch list of messages with LIST |
| 250 | // we can use else control, but we can also set $mailfetch_lmos |
| 251 | // to off if server does not support UIDL. |
| 252 | if ($mailfetch_lmos != 'on') { |
| 253 | Mail_Fetch_Status(_("Fetching list of messages...")); |
| 254 | $msglist = $pop3->command_list(); |
| 255 | } |
| 256 | } |
| 257 | |
| 258 | if ($Count < $i) { |
| 259 | Mail_Fetch_Status(_("Login OK: No new messages")); |
| 260 | $pop3->command_quit(); |
| 261 | continue; |
| 262 | } |
| 263 | if ($Count == 0) { |
| 264 | Mail_Fetch_Status(_("Login OK: Inbox EMPTY")); |
| 265 | $pop3->command_quit(); |
| 266 | continue; |
| 267 | } else { |
| 268 | $newmsgcount = $Count - $i + 1; |
| 269 | Mail_Fetch_Status(sprintf(ngettext("Login OK: Inbox contains %s message", |
| 270 | "Login OK: Inbox contains %s messages",$newmsgcount), $newmsgcount)); |
| 271 | } |
| 272 | |
| 273 | if ($mailfetch_lmos == 'on') { |
| 274 | Mail_Fetch_Status(_("Leaving messages on server...")); |
| 275 | } else { |
| 276 | Mail_Fetch_Status(_("Deleting messages from server...")); |
| 277 | } |
| 278 | |
| 279 | for (; $i <= $Count; $i++) { |
| 280 | Mail_Fetch_Status(sprintf(_("Fetching message %s."), $i)); |
| 281 | |
| 282 | if (!ini_get('safe_mode')) |
| 283 | set_time_limit(20); // 20 seconds per message max |
| 284 | |
| 285 | $Message = $pop3->command_retr($i); |
| 286 | |
| 287 | if (is_bool($Message)) { |
| 288 | Mail_Fetch_Status(sm_encode_html_special_chars($pop3->error)); |
| 289 | continue; |
| 290 | } |
| 291 | |
| 292 | fputs($imap_stream, "A3$i APPEND \"$mailfetch_subfolder\" {" . strlen($Message) . "}\r\n"); |
| 293 | $Line = fgets($imap_stream, 1024); |
| 294 | if (substr($Line, 0, 1) == '+') { |
| 295 | fputs($imap_stream, $Message); |
| 296 | fputs($imap_stream, "\r\n"); |
| 297 | sqimap_read_data($imap_stream, "A3$i", false, $response, $message); |
| 298 | $response=(implode('',$response)); |
| 299 | $message=(implode('',$message)); |
| 300 | if ($response != 'OK') { |
| 301 | Mail_Fetch_Status(_("Error Appending Message!")." ".sm_encode_html_special_chars($message) ); |
| 302 | Mail_Fetch_Status(_("Closing POP")); |
| 303 | $pop3->command_quit(); |
| 304 | Mail_Fetch_Status(_("Logging out from IMAP")); |
| 305 | sqimap_logout($imap_stream); |
| 306 | |
| 307 | if ($mailfetch_lmos == 'on') { |
| 308 | Mail_Fetch_Status(_("Saving UIDL")); |
| 309 | setPref($data_dir,$username,"mailfetch_uidl_$i_loop", $msglist[$i-1]); |
| 310 | } |
| 311 | exit; |
| 312 | } else { |
| 313 | Mail_Fetch_Status(_("Message appended to mailbox")); |
| 314 | } |
| 315 | |
| 316 | if ($mailfetch_lmos != 'on') { |
| 317 | if( $pop3->command_dele($i) ) { |
| 318 | Mail_Fetch_Status(sprintf(_("Message %d deleted from remote server!"), $i)); |
| 319 | } else { |
| 320 | Mail_Fetch_Status(_("Delete failed:") . sm_encode_html_special_chars($pop3->error) ); |
| 321 | } |
| 322 | } |
| 323 | } else { |
| 324 | echo $Line; |
| 325 | Mail_Fetch_Status(_("Error Appending Message!")); |
| 326 | Mail_Fetch_Status(_("Closing POP")); |
| 327 | $pop3->command_quit(); |
| 328 | Mail_Fetch_Status(_("Logging out from IMAP")); |
| 329 | sqimap_logout($imap_stream); |
| 330 | |
| 331 | // not gurantee corect! |
| 332 | if ($mailfetch_lmos == 'on') { |
| 333 | Mail_Fetch_Status(_("Saving UIDL")); |
| 334 | setPref($data_dir,$username,"mailfetch_uidl_$i_loop", $msglist[$i-1]); |
| 335 | } |
| 336 | exit; |
| 337 | } |
| 338 | } |
| 339 | |
| 340 | Mail_Fetch_Status(_("Closing POP")); |
| 341 | $pop3->command_quit(); |
| 342 | Mail_Fetch_Status(_("Logging out from IMAP")); |
| 343 | sqimap_logout($imap_stream); |
| 344 | if ($mailfetch_lmos == 'on' && is_array($msglist)) { |
| 345 | Mail_Fetch_Status(_("Saving UIDL")); |
| 346 | setPref($data_dir,$username,"mailfetch_uidl_$i_loop", array_pop($msglist)); |
| 347 | } |
| 348 | |
| 349 | Mail_Fetch_Status(_("Done")); |
| 350 | } |
| 351 | |
| 352 | $oTemplate->display('footer.tpl'); |