#!/usr/local/bin/php
<?
	function get_str($a){
		$res = "";

		for($i=0;$i<count($a);$i++){
			$res .= $a[$i];
		}

		return $res;
	}

function err($errmsg)
{
	fputs($log, $errmsg);
    fclose($in);
    fclose($log);
	die();
}

	$p_db = "ishop";
	$p_host = "localhost";
	$p_user = "is_user";
	$p_pass = "stupid";

	$p_log = "/tmp/";
	$p_log_ext = ".log";

	$dt_tt=mktime(); 				
	$dt_str=strftime("%y%m%d%H%M%S", $dt_tt); 

	$logname = date($dt_str);

   $log = fopen($p_log.$logname.$p_log_ext, "w");

   fputs($log, "ISparser log.\r\n");
   fputs($log, $dt_str."\r\n\r\n");
   
   $in = fopen("php://stdin","r") or err("Error open stdin."."\r\n");

	$endw = 0;
	$i = 0;

	$jfrom = 0;
	$jsubj = 0;
	$jbody = 0;
	$buf = array("*");
 	while ((!feof($in)) && ($endw==0)){
		$ch = fgetc($in);

		switch($ch){

			case ":": // 0x3A

					if((count($buf)-4) < 0){
						$endw = 1;
					}
					else 
					{
						$buf2 = array_slice($buf, count($buf)-4, 4);
						$sbuf2 = get_str($buf2);

						if($sbuf2=="From"){
							$jfrom = count($buf)-1+3;
						}

						if($sbuf2=="ject"){
							$jsubj = count($buf)-1+3;							
						}
					}
					break;

			case "<": // 0x3c

					if($jfrom!=0){
						$from = array_slice($buf, $jfrom, count($buf)-$jfrom+1-2);
						$jfrom = 0;
					}
					
					break;

			case "\n"://0x0A

					if($jsubj!=0){
						$subj = array_slice($buf, $jsubj, count($buf)-$jsubj+1-2);
						$jsubj = 0;
					}

					if(($buf[count($buf)-2] == "\n")&&($buf[count($buf)-1] == "\r")){
						if($jbody==0){
							$jbody = count($buf)+1;
						}
					}

					break;
		}
		array_push($buf, $ch);
	}

   fputs($log, "\$jbody=".$jbody."\r\n");

   $n = (count($buf)-2);
   fputs($log, "\$buf.size()-2=".$n."\r\n");

   $n = (count($buf)-2)-$jbody;
   fputs($log, "\$bodylen=".$n."\r\n");

	if($jbody!=0){
		$body = array_slice($buf, $jbody, count($buf)-$jbody);
		$jbody = 0;							
	}

   $n = count($body);
   fputs($log,  "\$body.size()=".$n."\r\n");

	if(($jsubj!=0)||($jfrom!=0)||($endw)){
		err("Parse Error."."\r\n");
	}

	if((count($subj)==0)){
		err("Empty subj."."\r\n");
	}
	if((count($from)==0)){
		err("Empty from."."\r\n");
	}
	if((count($body)==0)){
		err("Empty body."."\r\n");
	}

				$dt_tt=mktime(); 				
				$dt_str=strftime("%Y-%m-%d %H:%M:%S", $dt_tt); 
		        fputs($log,  "\$dt_str: ".$dt_str."\r\n");

				$dt_tt2=$dt_tt+30*60;
				$dt_str2 = strftime("%Y-%m-%d %H:%M:%S", $dt_tt2);
		        fputs($log,  "\$dt_str2: ".$dt_str2."\r\n");


	$ssubj = get_str($subj);
	$sfrom = get_str($from);
	$sbody = get_str($body);

   fputs($log,  "\$from: ".$sfrom."\r\n");
   fputs($log,  "\$subject: ".$ssubj."\r\n");

	$sfrom2 = str_replace("\"", "", $sfrom);
	$sbody2 = str_replace("\r\n", "\\n", $sbody);
	
	$q_ins = "INSERT INTO is_order VALUES (".
	"'',". // o_id
	"'".$ssubj."',". // o_number
	"'".$sfrom2."',". // o_client_name
	"'0',". // o_state
	"'0',". // o_source
	"'0',". // o_where
	"'0',". // o_type
	"'".$dt_str."',". // o_dt_receive
	"'".$dt_str2."',". // o_dt_valid_ringup
	"'',". // o_dt_ringup
	"'',". // o_manager
	"'',". // o_courier
	"'',". // o_doc_number
	"'',". // o_doc_type
	"'',". // o_note
	"'".$sbody2."'". // o_order_body
	");";
		
	fputs($log,  "\$q_ins: ".$q_ins."\r\n\r\n");	

//*
   $link = mysql_connect($p_host, $p_user, $p_pass) or err("Could not connect\r\n");

   mysql_select_db($p_db) or err("Could not select database\r\n");

   $result = mysql_query($q_ins) or err("Query failed\r\n");
//*/

	fputs($log,  "Close log."."\r\n");	

   fclose($in);
   fclose($log);
?>