D-Net

<?php

 require_once "Mail.php";

if (!class_exists('TBase')) {

	$DS = '/';

        $GLOBALS['THRIFT_ROOT'] = dirname(__FILE__) . $DS . 'models' . $DS . 'thrift';

        require_once($GLOBALS['THRIFT_ROOT'] . $DS . 'Thrift.php');

        require_once($GLOBALS['THRIFT_ROOT'] . $DS . 'protocol' . $DS . 'TBinaryProtocol.php');

        require_once($GLOBALS['THRIFT_ROOT'] . $DS . 'transport' . $DS . 'TSocket.php');

        require_once($GLOBALS['THRIFT_ROOT'] . $DS . 'transport' . $DS . 'TBufferedTransport.php');

        require_once($GLOBALS['THRIFT_ROOT'] . $DS . 'packages' . $DS . 'openaire' . $DS . 'OpenAireConnector.php');

	function init() {

		$host = 'localhost';

                $port = '7911';

                $socket = new TSocket($host, $port);

                $socket->setRecvTimeout(10000);

                $_transport = new TBufferedTransport($socket);

                $protocol = new TBinaryProtocol($_transport);

                $_client = new OpenAireConnectorClient($protocol);

                return array("client" => $_client, "transport" => $_transport);

	}

	function callThrift(&$thriftHandle, $methodName, $params) {

		$thriftHandle["transport"]->open();

		$result = call_user_func_array(array($thriftHandle['client'], $methodName), $params);

		$thriftHandle["transport"]->close();

		return $result;

	}

	function getMessage($sc39) {

		$file = 'message-'.($sc39?'sc39':'nonsc39').'.txt';

		$fp = fopen($file, 'r');

		$text = fread($fp, filesize($file));

		fclose($fp);

		return $text;

	}

	function getSubject($sc39) {

		$file = 'subject-'.($sc39?'sc39':'nonsc39').'.txt';

		$fp = fopen($file, 'r');

		$text = fread($fp, filesize($file));

		fclose($fp);

		return $text;

	}

	function getUrl($projectId) {

		$url = 'http://www.openaire.eu/en/component/openaire/project_info/default/625?id='.$projectId;

		$url .= '&confirm='.getHash($projectId);

		return $url;

	}

	function getHash($projectId) {

		return hash_hmac('sha1', $projectId, 'asupercoolsecret');

	}

	function replaceVars($message, $project) {

		$message = str_replace('$projectName', $project->acronym, $message);

		$message = str_replace('$grantAgreementNumber', $project->grandAgreement, $message);

		$message = str_replace('$projectInfoURL', getUrl($project->projectId), $message);

		$message = str_replace('$coordinatorName', $project->coordinator->name.' '.$project->coordinator->surname, $message);

		return $message;

	}

	$thrift = init();

	$projects = callThrift($thrift, 'getProjectsWithNonHarverstedDocuments', array(true, true));

	foreach (array_slice($projects, 0, 1)  as $project) {

		$to = $project->coordinator->email;

		$message = getMessage($project->sc39);

		$subject = getSubject($project->sc39);

		$headers = array('From' => 'test.openaire@gmail.com', 'To' => $to, 'Subject' => $subject);

		$subject = replaceVars($subject, $project);

		$message = replaceVars($message, $project);

		$host = "smtp.gmail.com";

		$port = "587";

		$username = "test.openaire@gmail.com";

		$password = "^($*@$)*!$";

		$smtp = Mail::factory('smtp', array ('host' => $host, 'port' => $port, 'auth' => true, 'debug'=>true, 'username' => $username, 'password' => $password));

//$to = "antleb@di.uoa.gr";

echo 'to: '.$to;

echo $subject;

echo 'message: '.$message;

		$mail = $smtp->send($to, $headers, $message);

		if (PEAR::isError($mail)) {

			echo("<p>" . $mail->getMessage() . "</p>");

		} else {

			echo("<p>Message successfully sent!</p>");

		}

	}

}

?>