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("" . $mail->getMessage() . "
");
} else {
echo("Message successfully sent!
");
}
}
}
?>