class_pop3_session.php

webmail系统 php + mysql

<?

class pop3_session {
	var $pop_connection,
		$pop_server,
		$pop_port,
		$pop_error_msg,
		$pop_user,
		$pop_pass,
		$pop_server;


	function pop_get_line() {
		global $enable_debug;

		$buffer = fgets($this->pop_connection,10240);
		$buffer = eregi_replace("\r","",$buffer);
		$buffer = eregi_replace("\n","",$buffer);

		if($enable_debug) {
			$output = (eregi("^(\+OK)|^(\-ERR)",$buffer))?"<- <b>".htmlspecialchars($buffer)."</b>":htmlspecialchars($buffer);
			echo("<font style=\"font-size:12px; font-family: Courier New; background-color: white; color: black;\"> $output</font><br>\r\n");flush();
		}
		return $buffer;
	}

	function pop_send_command($cmd) {
		global $enable_debug;
		if($this->pop_connection) {
			if($enable_debug) {
				$output = (eregi("^(PASS)",$cmd))?"PASS ****":$cmd;
				echo("<font style=\"font-size:12px; font-family: Courier New; background-color: white; color: black;\">-&gt; <em><b>".htmlspecialchars($output)."</b></em></font><br>\r\n");flush();
			}
			fwrite($this->pop_connection,"$cmd\r\n");
			return 1;
		}
		return 0;
	}

	function pop_connect() {
		$this->pop_connection = fsockopen($this->pop_server, $this->pop_port, &$errno, &$errstr, 60);
		if($this->pop_connection) {
			$buffer = $this->pop_get_line();
			if(ereg("^(\+OK)",$buffer)) return 1;
			else return 0;
		}
		return 0;
	}

	function pop_auth() {
		global $userfolder,$error_permiss,$temporary_directory,$idle_timeout;
		if($this->pop_connection) {
			$this->pop_send_command("USER ".$this->pop_user);
			$buffer = $this->pop_get_line();
			if(ereg("^(\+OK)",$buffer)) {
				$this->pop_send_command("PASS ".$this->pop_pass);
				$buffer = $this->pop_get_line();

				if(ereg("^(\+OK)",$buffer)) { 
					if(!file_exists($userfolder))
						if(!@mkdir($userfolder,0777)) die("<h1><br><br><br><center>$error_permiss</center></h1>");
					if(!file_exists($userfolder."inbox"))
						mkdir($userfolder."inbox",0777);
					if(!file_exists($userfolder."trash"))
						mkdir($userfolder."trash",0777);
					if(!file_exists($userfolder."sent"))
						mkdir($userfolder."sent",0777);
					if(!file_exists($userfolder."sent"))
						mkdir($userfolder."sent",0777);
					if(!file_exists($userfolder."_attachments"))
						mkdir($userfolder."_attachments",0777);
					if(!file_exists($userfolder."_infos"))
						mkdir($userfolder."_infos",0777);
					$sessiondir = $temporary_directory."_sessions/";

					// Clean old sessions
					$all=opendir($sessiondir); 
					while ($file=readdir($all)) { 
						$thisfile = $sessiondir.$file;
						if (is_file($thisfile)) {
							$idle = intval((time()-@filemtime($thisfile))/60);
							if(($idle_timeout+10) < $idle)
								@unlink($thisfile);
						}
					}
					closedir($all); 
					unset($all);

					return 1;
				}
				else { $this->pop_error_msg = $buffer; return 0; }
			} else return 0;
		}
		return 0;
	}

	function pop_retr_msg($mnum,$mid,$msize=10000,$check=1) {
		global $pop_use_top,$userfolder,$appname,$appversion,$error_retrieving;
		$md = new mime_decode();
		if($check) {
			$this->pop_send_command("TOP $mnum 0");
			$buffer = $this->pop_get_line();
			if(ereg("^(\+OK)",$buffer)) {
				unset($header);
				while (!feof($this->pop_connection)) {
					$buffer = $this->pop_get_line();
					if(trim($buffer) == ".") break;
					if(strlen($buffer) > 3) 
						$header .= "$buffer\r\n";
				}
				$mail_info = $md->get_mail_info($header);
				$mailmid = $mail_info["message-id"];
				if($mid != md5($mailmid)) {
					$this->pop_error_msg = $error_retrieving;
					return 0;
				}
			} else return 0;
		}
		$command = ($pop_use_top)?"TOP $mnum $msize":"RETR $mnum";
		$this->pop_send_command($command);
		$buffer = $this->pop_get_line();

		if(!ereg("^(\+OK)",$buffer)) { $this->pop_error_msg = $buffer; return 0; }
		while (!feof($this->pop_connection)) {
			$buffer = str_replace("\n","",$this->pop_get_line());
			if(trim($buffer) == ".") break;
			$msg .= "$buffer\r\n";
		}

		$msg = "X-Decoded-By: $appname $appversion\r\n".$msg;
		$parts = $md->fetch_structure($msg);
		$header = $parts["header"];
		$mail_info = $md->get_mail_info($header);
		$flocalname = $userfolder."inbox/".md5($mail_info["subject"].$mail_info["message-id"].$mail_info["date"]).".eml";

		$tmpfile = fopen($flocalname,"wb+");
		fwrite($tmpfile,$msg);
		fclose($tmpfile);
		return $msg;
	}

	function pop_dele_msg($mnum,$mid,$msize,$send_to_trash = 1) {
		global $userfolder,$error_retrieving;
		$this->pop_send_command("TOP $mnum 0");
		$buffer = $this->pop_get_line();
		if(ereg("^(\+OK)",$buffer)) {
			unset($header);
			while (!feof($this->pop_connection)) {
				$buffer = $this->pop_get_line();
				if(trim($buffer) == ".") break;
				if(strlen($buffer) > 3) 
					$header .= "$buffer\r\n";
			}
			$md = new mime_decode();
			$mail_info = $md->get_mail_info($header);
			if($mid != md5($mail_info["message-id"])) {
				$this->pop_error_msg = $error_retrieving;
				return 0;
			}
			$filename = md5($mail_info["subject"].$mail_info["message-id"].$mail_info["date"]).".eml";
			$flocalname = $userfolder."inbox/$filename";
			$flocaltrashname = $userfolder."trash/$filename";
			if ($send_to_trash && !file_exists($flocalname)) {
				$tempmail = $this->pop_retr_msg($mnum,$mid,$msize,0);
				$tempmail = $md->set_as($tempmail,0);
				$tmpfile = fopen($flocalname,"wb+");
				fwrite($tmpfile,$tempmail);
				fclose($tmpfile);
			}
			if($send_to_trash)
				@copy($flocalname,$flocaltrashname);
			@unlink($flocalname);
			$this->pop_send_command("DELE $mnum");
			$buffer = $this->pop_get_line();
			if(!ereg("^(\+OK)",$buffer)) {
				$this->pop_error_msg = $buffer;
				return 0;
			} else return 1;
		}
		$this->pop_error_msg = $buffer;
		return 0;
	}

	function pop_list_msgs() {
		global $userfolder,$use_progress_bar;
		$msglist = Array();
		$this->pop_send_command("LIST");
		unset($buffer);
		$buffer = $this->pop_get_line();
		if(ereg("^(\+OK)",$buffer)) {
			$counter = 0;
			while (!feof($this->pop_connection)) {
				$buffer = $this->pop_get_line();
				if(trim($buffer) == ".") break;
				$msgs = split(" ",$buffer);
				if(is_numeric($msgs[0])) {
					$msglist[$counter]["id"] = $counter+1; //$msgs[0];
					$msglist[$counter]["msg"] = $msgs[0];
					$msglist[$counter]["size"] = $msgs[1];
					$counter++;
				}
			}
			if(count($msglist) == 0) return $msglist;

			$md = new mime_decode();
			for($i=0;$i<count($msglist);$i++) {
				$this->pop_send_command("TOP ".$msglist[$i]["msg"]." 0");
				$buffer = $this->pop_get_line();
				if(ereg("^(\+OK)",$buffer)) {
					while (!feof($this->pop_connection)) {
						$buffer = $this->pop_get_line();
						if(trim($buffer) == ".") break;
						if(strlen($buffer) > 3) 
							$header .= "$buffer\r\n";
					}
					$mail_info = $md->get_mail_info($header);
					$msglist[$i]["date"] = $mail_info["date"];
					$msglist[$i]["subject"] = $mail_info["subject"];
					$msglist[$i]["message-id"] = $mail_info["message-id"];
					$msglist[$i]["from"] = $mail_info["from"];
					$msglist[$i]["fromname"] = $mail_info["from"][0]["name"];
					$msglist[$i]["to"] = $mail_info["to"];
					$msglist[$i]["cc"] = $mail_info["cc"];
					$msglist[$i]["headers"] = $header;
					$msglist[$i]["attach"] = (eregi("(multipart/mixed|multipart/related|application)",$mail_info["content-type"]))?1:0;
					$flocalname = $userfolder."inbox/".md5($mail_info["subject"].$mail_info["message-id"].$mail_info["date"]).".eml";
					$msglist[$i]["localname"] = $flocalname;
					$msglist[$i]["read"] = file_exists($flocalname)?1:0;
				}
				$header = "";
			}
		}
		
		return $msglist;
	}
	function pop_disconnect() {
		$this->pop_send_command("QUIT");
		$tmp = $this->pop_get_line();
        fclose($this->pop_connection);
		return 1;
	}
}
?>