<?php
//*****************************************************************************
//* 
//* プログラム名：Webメール
//* プログラムID：WML000.inc
//* 機能			：メール解析系関数群
//* 作成者		：
//* 
//*****************************************************************************

/*
 * pop3-class.php By TOMO (2002/07/06) 
 *
 * [Version] : 1.1.0 (2002/07/06)
 * [URL]     : http://www.spencernetwork.org/
 * [E-MAIL]  : groove@spencernetwork.org
 *
 * pop3-class.php is free but without any warranty.
 * use this script at your own risk.
 *
 */

/* Interface 

[ Constractor ]

    pop3(string server, string user, string pass [, int port = 110])

[ Property ]

    bool apop
    bool debug
    int time_out
    string server 
    int port
    string user
    string pass

[ Method ]

    bool open(void)
    bool close(void)
    array get_stat(void)
    array get_list(int num = 0)
    array get_uidl(int num = 0)
    bool dele(int num)
    string top(int num, int line)
    string head(int num)
    string retr(int num)
    bool noop(void)
    bool rset(void)

*/

class pop3
{
	/* Public variables */
	var $apop;      // use APOP
	var $debug;     // print debug message
	var $time_out;  // fsockopen() time-out
	var $server;    // pop3 server
	var $port;      // pop3 port number
	var $user;      // login user
	var $pass;      // login password

	/* Private variables */
	var $_sock;

	function pop3($server, $user, $pass, $port = 110)
	{
		$this->apop     = FALSE;
		$this->debug    = FALSE;
		$this->time_out = 30;
		$this->server   = $server;
		$this->port     = $port;
		$this->user     = $user;
		$this->pass     = $pass;

		$this->_sock    = FALSE;
	}

	/* Public functions */
	function open()
	{
		if ($this->_sock) $this->close();

		$this->_debug("Trying to ".$this->server.":".$this->port." ...\n");
		$this->_sock = @fsockopen($this->server, $this->port, $errno, $errstr, $this->time_out);
		if (!$this->_sock) {
			$this->_debug("Error: Could not connect to ".$this->server."\n");
			$this->_debug("Error: ".$errstr." (".$errno.")\n");
			return FALSE;
		}
		if (!$this->_ok($resp)) {
			$this->_debug("Error: Could not connect to ".$this->server."\n");
			return FALSE;
		}

		if (ereg("<.+>", $resp, $match)) {
			$time_stamp = $match[0];
		} else {
			$time_stamp = '';
		}

		$this->_debug("Connected to ".$this->server."\n");

		if (!$this->_login($time_stamp)) {
			$this->_debug("Error: Login failed\n");
			return FALSE;
		}
		$this->_debug("Login succeeded\n");
		return TRUE;
	}

	function get_stat()
	{
		if (!$this->_putcmd('STAT')) {
			return FALSE;
		}
		if (!$this->_ok($resp)) {
			return FALSE;
		}
		list($num, $octet) = explode(' ', $resp);
		return array($num, $octet);
	}

	function get_list($num = 0)
	{
		return $this->_get_list('LIST', $num);
	}

	function dele($num)
	{
		if (!$this->_putcmd('DELE', $num)) {
			return FALSE;
		}
		return $this->_ok($resp);
	}

	function get_uidl($num = 0)
	{
		return $this->_get_list('UIDL', $num);
	}

	function top($num, $line)
	{
		if (!$this->_putcmd('TOP', $num.' '.$line)) {
			return FALSE;
		}
		if (!$this->_ok($resp)) {
			return FALSE;
		}
		return $this->_getresp();
	}

	function head($num)
	{
		return $this->top($num, 0);
	}

	function retr($num)
	{
		if (!$this->_putcmd('RETR', $num)) {
			return FALSE;
		}
		if (!$this->_ok($resp)) {
			return FALSE;
		}
		return $this->_getresp();
	}

	function noop()
	{
		if (!$this->_putcmd('NOOP')) {
			return FALSE;
		}
		return $this->_ok($resp);
	}

	function rset()
	{
		if (!$this->_putcmd('RSET')) {
			return FALSE;
		}
		return $this->_ok($resp);
	}

	function close()
	{
		if (!$this->_sock) {
			$this->_debug("Error: Socket is not opened\n");
			return FALSE;
		}

		if (!$this->_putcmd('QUIT')) {
			return FALSE;
		}
		if (!$this->_ok($resp)) {
			return FALSE;
		}

		$ret = fclose($this->_sock);
		if ($ret) {
			$this->_debug("Disconnected from remote host\n");
			return TRUE;
		} else {
			$this->_debug("Error: Could not disconnect from remote host\n");
			return FALSE;
		}
	}

	/* Private Functions */

	function _login($time_stamp)
	{
		if ($this->apop) {
			return $this->_login_apop($time_stamp);
		} else {
			return $this->_login_pop();
		}
	}

	function _login_pop()
	{
		if (!$this->_putcmd('USER', $this->user)) {
			return FALSE;
		}
		if (!$this->_ok($resp)) {
			return FALSE;
		}

		if (!$this->_putcmd('PASS', $this->pass)) {
			return FALSE;
		}
		if (!$this->_ok($resp)) {
			return FALSE;
		}

		return TRUE;
	}

	function _login_apop($time_stamp)
	{
		$digest = md5($time_stamp.$this->pass);

		if (!$this->_putcmd('APOP', $this->user." ".$digest)) {
			return FALSE;
		}
		if (!$this->_ok($resp)) {
			return FALSE;
		}

		return TRUE;
	}

	function _putcmd($cmd, $arg = '')
	{
		if (!$this->_sock) {
			$this->_debug("Error: Socket is not opened\n");
			return FALSE;
		}

		if ($arg != '') {
			$cmd = $cmd.' '.$arg;
		}

		if (!fputs($this->_sock, $cmd."\r\n")) {
			$this->_debug("Error: Could not put command $cmd\n");
			return FALSE;
		}

		$this->_debug('> '.$cmd."\n");

		return TRUE;
	}

	function _ok(&$resp)
	{
		if (!$this->_sock) {
			$this->_debug("Error: Socket is not opened\n");
			return FALSE;
		}

		$line = trim(fgets($this->_sock, 512));
		$this->_debug('< ' . $line . "\n");

		$tmp = split(' ', $line, 2);
		if (isset($tmp[1])) {
			$resp = $tmp[1];
		} else {
			$resp = '';
		}

		if (substr($line, 0, 1) != '+') {
			return FALSE;
		}

		return TRUE;
	}

	function _getresp()
	{
		if (!$this->_sock) {
			$this->_debug("Error: Socket is not opened\n");
			return FALSE;
		}

		$response = '';
		$line = '';
		while ($line != ".\r\n") {
			$line = ereg_replace("^\\.\\.", '.', $line);
			$response .= $line;
			$line = fgets($this->_sock, 512);
		}
		$this->_debug(str_replace("\r\n", "\n", $response));
		return $response;
	}

	function _debug($message)
	{
		if ($this->debug) {
			echo $message;
		}
	}

	function _get_list($cmd, $num = 0)
	{
		if ($num < 1) {
			$arg = '';
		} else {
			$arg = $num;
		}

		if (!$this->_putcmd($cmd, $arg)) {
			return FALSE;
		}
		if (!$this->_ok($resp)) {
			return FALSE;
		}

		if ($num < 1) {
			$resp = trim($this->_getresp());
		}

		if ($resp == '') {
			return array('');
		}

		$data = explode("\r\n", $resp );
		reset($data);
		while (list($key, $value) = each($data)) {
			list($no, $uid) = explode(' ', $value);
			$list[$no] = $uid;
		}
		return $list;
	}
}
require_once 'jcode.phps';
define("", "");

function auth($userid, $passwd, $realem = '', $crypt = 1){

	if (!isset($_SERVER['PHP_AUTH_USER']) || !isset($_SERVER['PHP_AUTH_PW'])) {
		@header("WWW-Authenticate: Basic realm=\"".$realem."\"");
		@header("HTTP/1.0 401 Unauthorized");
		return FALSE;
	}
	$auth_id = $_SERVER['PHP_AUTH_USER'];
	switch ($crypt) {
		case 1:
			$auth_pw = md5($_SERVER['PHP_AUTH_PW']);
			break;
		case 2:
			$auth_pw = crypt($_SERVER['PHP_AUTH_PW'], substr($passwd, 0, 2));
			break;
		default:
			$auth_pw = $_SERVER['PHP_AUTH_PW'];
			break;
	}

	if (strcmp($auth_id, $userid) == 0 && strcmp($auth_pw, $passwd) == 0) {
		return TRUE;
	}

	@header("WWW-Authenticate: Basic realm=\"".$realem."\"");
	@header("HTTP/1.0 401 Unauthorized");
	return FALSE;
}

function link_url($str){
	$regex = "((https?://|ftp://)([0-9A-Za-z:_?./~%;()=+#-]|&amp;)+)";
	$str = eregi_replace($regex, "<a href=\"\\1\" target=\"_blank\">\\1</a>", $str);
	$regex_mail = "((mailto:)?([0-9A-Za-z._-]+@[0-9A-Za-z.-]+))";
	$str = eregi_replace($regex_mail, "<a href=\"mailto:\\3\">\\1</a>", $str);
	return $str;
}

function jstrhead($str, $len){
	$b = unpack('C*', $str);
	$n = count($b);
	$h = '';

	for ($i = 1, $l = 0; $i <= $n; ++$i) {
		if ($b[$i] >= 0x80) {  //Japanese
				if ($b[$i] != 0x8E) {				//EUC-JP
					++$l;
				}
				$c = chr($b[$i]).chr($b[++$i]);
		} else {  //ASCII
			$c = chr($b[$i]);
		}
		if (++$l > $len) break;
		$h .= $c;
	}

	return $h;
}

function decode_body($body, $enc){
	switch (strtolower($enc)) {
		case 'quoted-printable':
			$body = quoted_printable_decode($body);
			break;
		case 'base64':
			$body = base64_decode($body);
			break;
		default;
			break;
	}
	return $body;
}

function decode_mimeheader($str, $charset_to = 0){
	// combine multiple-line
	$ret_str = ereg_replace("\r\n[\t ]+", "", $str);

	// regex for encoded-word
	$expr = "^.*(=\\?([^?]+)\\?([BbQq])\\?([^?]*)\\?=).*$";

	while (ereg($expr, $ret_str, $match)) {

		// encoding
		switch (strtolower($match[3])) {
			case 'b':
				$dec_data = base64_decode($match[4]);
				break;
			case 'q':
				$dec_data = quoted_printable_decode($match[4]);
				break;
			default:
				$dec_data = $match[4];
				break;
		}

		// charset
		$charset_from = check_jcode_encoding($match[2]);

		// convert charet
		$dec_data = JcodeConvert($dec_data, $charset_from, $charset_to);

		// replace encoded-word
		$ret_str = str_replace($match[1], $dec_data, $ret_str);
	}

	return $ret_str;
}

function color_mail($body, $header = "")
{
	$body   = htmlspecialchars($body, ENT_QUOTES);
	$header = htmlspecialchars($header, ENT_QUOTES);

	$line_body   = split("\r?\n", $body);
	$line_header = split("\r?\n", $header);

	$line_body_max   = count($line_body);
	$line_header_max = count($line_header);

	for ($cnt = 0; $cnt < $line_header_max; ++$cnt) {
		$line_header[$cnt] = _color_header($line_header[$cnt]);
	}

	for ($cnt = 0; $cnt < $line_body_max; ++$cnt) {
		$line_body[$cnt] = _color_body($line_body[$cnt]);
	}

	$str = implode("\n", $line_header) . "\n\n" . implode("\n", $line_body);
	$str = _color_signature($str);

	return $str;
}

function is_valid_uid($uid)
{

	$len = strlen($uid);
	if ($len < 1 || $len > 70) {
		return FALSE;
	}

	if (ereg("[^\x21-\x7E]", $uid)) {
		return FALSE;
	}

	return TRUE;
}

function format_date($date)
{
	return date('Y/m/d&\\nb\\sp;H:i', strtotime($date));
}
function format_date2($date)
{
	return date('YmdHi', strtotime($date));
}

function format_size($size)
{
	return sprintf('%0.1f', $size / 1024).'KB';
}

function get_name($str)
{
	if (ereg('(.+)<.+@.+>.*', $str, $match)) {
		if (ereg('.*"([^"]+)".*', $match[1], $match2)) {
			return $match2[1];
		}
		return $match[1];
	}

	if (ereg('.+\\((.+)\\)', $str, $match)) {
		return $match[1];
	}

	if (ereg('<?([0-9A-Za-z._-]+)@[0-9A-Za-z.-]+>?', $str, $match)) {
		return $match[1];
	}

	return $str;
}

function parse_ctype($ctype)
{
	$type    = '';
	$subtype = '';
	$value = parse_header_value($ctype);
	list($type, $subtype) = split("/", $value['value'], 2);
	$ret['type']    = $type;
	$ret['subtype'] = $subtype;
	$ret['param']   = $value['param'];
	return $ret;
}

function parse_header_value($header)
{
	$v = split(";", $header, 2);
	$h['value'] = trim($v[0]);
	if (!isset($v[1])) {
		return $h;
	}

	$param = split(";", $v[1]);
	$n = count($param);
	for ($i = 0; $i < $n; ++$i) {
		$param_name  = '';
		$param_value = '';
		list($param_name, $param_value) = split("=", $param[$i], 2);
		$h['param'][strtolower(trim($param_name))]
			= ereg_replace('^"([^"]+)"$', "\\1", trim($param_value));
	}

	return $h;
}

function parse_header($header)
{
	$header = trim(ereg_replace("[\r\n]+[\t ]+", "", $header));
	$array_header = split("[\r\n]+", $header);
	$header_num = count($array_header);
	for ($i = 0; $i < $header_num; ++$i) {
		$header_name  = '';
		$header_value = '';
		list($header_name, $header_value) = split(":", $array_header[$i], 2);
		$header_list[strtolower($header_name)] = trim($header_value);
	}
	return $header_list;
}

//*********************
//  Private Functions
//*********************

function _color_body($str)
{
	$quote = "(&gt; ?)";
	for ($i = 5; $i > 0; --$i) {
		$regex = "(^".$quote."{".$i."}.*$)";
		$str   = ereg_replace($regex, "<font class=\"quot".$i."\">\\1</font>", $str);
	}

	$str = _color_option($str);

	return $str;
}

function _color_header($str)
{
	$regex = "(^[^: \t]*[: \t])(.+$)";
	return ereg_replace($regex, "<font class=\"header_all_name\">\\1</font><font class=\"header_all\">\\2</font>", $str);
}

function _color_option($str)
{
	$regex = "(^#.*)"; // Starting with "#"
	return ereg_replace($regex, "<font class=\"option\">\\1</font>", $str);
}

function _color_signature($str)
{
	$regex = "(\r?\n-- \r?\n.+$)"; // See draft-ietf-usefor-article
	return ereg_replace($regex, "<font class=\"signature\">\\1</font>", $str);
}

function check_jcode_encoding($str_encoding)
{
	switch (strtolower($str_encoding)) {
		case 'euc-jp':
			$jc_encoding = 1;
			break;
		case 'shift_jis':
			$jc_encoding = 2;
			break;
		case 'iso-2022-jp':
			$jc_encoding = 3;
			break;
		case 'utf-8':
			global $table_utf8_jis;
			include_once('code_table.ucs2jis');
			$jc_encoding = 4;
			break;
		default:
			$jc_encoding = 0;
			break;
	}
	return $jc_encoding;
}

?>