<?php

// Purpose : to check an email address, record any emails going through
// This script creates a table 'email_stats_log' and populats it it senders name, email address, recipients name, email address, subject, date, size
// Use with Cron to check email 

$mysql_host="localhost"; // mySQL Host address (often 'localhost')
$mysql_database=""; // database name
$mysql_username=""; // database user name
$mysql_password=""; // password

$email_address=""; // email address to check
$email_server=""; // mail server address
$email_password=""; // email address password

//  No need to edit beyond here

// Function to check if a table exists
function Table_Exists($table_name){
	$Table = mysql_query("show tables like '" . $table_name . "'");
	
	if(mysql_fetch_row($Table) === false)
		return(false);
	
	return(true);
}

// Table structure
$email_stats_table="CREATE TABLE `email_stats_log` (
  `id` int(11) NOT NULL auto_increment,
  `to_email` varchar(255) NOT NULL default '',
  `to_name` varchar(255) NOT NULL default '',
  `from_name` varchar(255) NOT NULL default '',
  `from_email` varchar(255) NOT NULL default '',
  `subject` varchar(255) NOT NULL default '',
  `date` datetime NOT NULL default '0000-00-00 00:00:00',
  `size` varchar(255) NOT NULL default '',
  PRIMARY KEY  (`id`)
) ENGINE=MyISAM  DEFAULT CHARSET=latin1 COMMENT='List of emails received' AUTO_INCREMENT=1 ;";

// Open connection to mailbox
$mbox = imap_open("{".$email_server.":110/pop3}INBOX", "$email_address", "$email_password") or die("Can't connect: " . imap_last_error());

if ($headers = imap_headers($mbox) or die("Can't open: " . imap_last_error())) {

	$number_of_emails = sizeof($headers); 

	// loop through email headers
	for($i = 1; $i < $number_of_emails+1; $i++) {
	
		$mailHeader = @imap_headerinfo($mbox, $i);
	
		//$message_number = $mailHeader->Msgno;
		$to = $mailHeader->to;
		$from = $mailHeader->from;
		$subject = strip_tags($mailHeader->subject);
		$date = date("Y-m-d H:i:s", strtotime($mailHeader->date));
		$size = $mailHeader->Size;
	
		foreach ($to as $id => $object) {
			$to_name = $object->personal;
			$to_email = $object->mailbox . "@" . $object->host;
		}
	
		foreach ($from as $id => $object) {
			$from_name = $object->personal;
			$from_email = $object->mailbox . "@" . $object->host;
		}
	
		unset($id);

		// Connect to the clients database
		$link = mysql_connect($mysql_host,$mysql_username,$mysql_password) or die('Could not connect to Client database');
		mysql_select_db($mysql_database,$link) or die('Could not open client database');

		// Create mySQL table if it doesn't exist
		if (!Table_Exists('email_stats_log')) {
			mysql_query($email_stats_table, $link);
		}	
	
		// Check to see if this is already recoreded in the database
		$query = "SELECT id FROM email_stats_log WHERE to_email='$to_email' AND to_name='$to_name' AND from_name='$from_name' AND from_email='$from_email' AND subject='$subject' AND date='$date' AND size='$size'";
		$result = mysql_query($query, $link) or die('Failed to get ID of page');
		
		while ($record = mysql_fetch_array($result))
		{
			$id=$record["id"];
		}
	
		if(!$id) {
			$query = "INSERT INTO email_stats_log (to_email,to_name,from_name,from_email,subject,date,size) VALUES ('$to_email','$to_name','$from_name','$from_email','$subject','$date','$size')";
			$result = mysql_query($query, $link) or die('Saving the page failed');
		}
	
	}
}
imap_close($mbox);

?>