dcCore dcCore instance
public $table; ///< string done pings table name
/**
Object constructor
@param core dcCore dcCore instance
*/
public function __construct($core)
{
$this->core =& $core;
$this->con =& $this->core->con;
$this->table = $this->core->prefix.'ping';
}
/// @name Send trackbacks
//@{
/**
Get all pings sent for a given post.
@param post_id integer Post ID
@return record
*/
public function getPostPings($post_id)
{
$strReq = 'SELECT ping_url, ping_dt '.
'FROM '.$this->table.' '.
'WHERE post_id = '.(integer) $post_id;
return $this->con->select($strReq);
}
/**
Sends a ping to given $url.
@param url string URL to ping
@param post_id integer Post ID
@param post_title string Post title
@param post_excerpt string Post excerpt
@param post_url string Post URL
*/
public function ping($url,$post_id,$post_title,$post_excerpt,$post_url)
{
if ($this->core->blog === null) {
return false;
}
$post_id = (integer) $post_id;
# Check for previously done trackback
$strReq = 'SELECT post_id, ping_url FROM '.$this->table.' '.
'WHERE post_id = '.$post_id.' '.
"AND ping_url = '".$this->con->escape($url)."' ";
$rs = $this->con->select($strReq);
if (!$rs->isEmpty()) {
throw new Exception(sprintf(__('%s has still been pinged'),$url));
}
$ping_parts = explode('|',$url);
# Let's walk by the trackback way
if (count($ping_parts) < 2) {
$data = array(
'title' => $post_title,
'excerpt' => $post_excerpt,
'url' => $post_url,
'blog_name' => trim(html::escapeHTML(html::clean($this->core->blog->name)))
//,'__debug' => false
);
# Ping
try
{
$http = self::initHttp($url,$path);
$http->post($path,$data,'UTF-8');
$res = $http->getContent();
}
catch (Exception $e)
{
throw new Exception(__('Unable to ping URL'));
}
$pattern =
'|.*(.*)(.*)'.
'((.*)(.*))?'.
'|msU';
if (!preg_match($pattern,$res,$match))
{
throw new Exception(sprintf(__('%s is not a ping URL'),$url));
}
$ping_error = trim($match[1]);
$ping_msg = (!empty($match[4])) ? $match[4] : '';
}
# Damnit ! Let's play pingback
else {
try {
$xmlrpc = new xmlrpcClient($ping_parts[0]);
$res = $xmlrpc->query('pingback.ping', $post_url, $ping_parts[1]);
$ping_error = '0';
}
catch (xmlrpcException $e) {
$ping_error = $e->getCode();
$ping_msg = $e->getMessage();
}
catch (Exception $e) {
throw new Exception(__('Unable to ping URL'));
}
}
if ($ping_error != '0') {
throw new Exception(sprintf(__('%s, ping error:'),$url).' '.$ping_msg);
} else {
# Notify ping result in database
$cur = $this->con->openCursor($this->table);
$cur->post_id = $post_id;
$cur->ping_url = $url;
$cur->ping_dt = date('Y-m-d H:i:s');
$cur->insert();
}
}
//@}
private function pingAlreadyDone($post_id, $from_url)
{
$params = array(
'post_id' => $post_id,
'comment_site' => $from_url,
'comment_trackback' => 1,
);
$rs = $this->core->blog->getComments($params, true);
if ($rs && !$rs->isEmpty()) {
return ($rs->f(0));
}
return false;
}
private function addBacklink($post_id, $url, $blog_name, $title, $excerpt, &$comment)
{
if (empty($blog_name)) {
$blog_name = 'Anonymous blog';
}
$comment =
"\n".
''.($title ? $title : $blog_name)."
\n".
''.$excerpt.'
';
$cur = $this->core->con->openCursor($this->core->prefix.'comment');
$cur->comment_author = (string) $blog_name;
$cur->comment_site = (string) $url;
$cur->comment_content = (string) $comment;
$cur->post_id = $post_id;
$cur->comment_trackback = 1;
$cur->comment_status = $this->core->blog->settings->system->trackbacks_pub ? 1 : -1;
$cur->comment_ip = http::realIP();
# --BEHAVIOR-- publicBeforeTrackbackCreate
$this->core->callBehavior('publicBeforeTrackbackCreate',$cur);
if ($cur->post_id) {
$comment_id = $this->core->blog->addComment($cur);
# --BEHAVIOR-- publicAfterTrackbackCreate
$this->core->callBehavior('publicAfterTrackbackCreate',$cur,$comment_id);
}
}
/// @name Receive trackbacks
//@{
/**
Receives a trackback and insert it as a comment of given post.
@param post_id integer Post ID
*/
public function receive($post_id)
{
header('Content-Type: text/xml; charset=UTF-8');
if (empty($_POST)) {
http::head(405,'Method Not Allowed');
echo
''."\n".
"\n".
" 1\n".
" POST request needed\n".
"";
return;
}
$post_id = (integer) $post_id;
$title = !empty($_POST['title']) ? $_POST['title'] : '';
$excerpt = !empty($_POST['excerpt']) ? $_POST['excerpt'] : '';
$url = !empty($_POST['url']) ? $_POST['url'] : '';
$blog_name = !empty($_POST['blog_name']) ? $_POST['blog_name'] : '';
$charset = '';
$comment = '';
$err = false;
$msg = '';
if ($this->core->blog === null)
{
$err = true;
$msg = 'No blog.';
}
elseif ($url == '')
{
$err = true;
$msg = 'URL parameter is required.';
}
elseif ($blog_name == '') {
$err = true;
$msg = 'Blog name is required.';
}
if (!$err)
{
$post = $this->core->blog->getPosts(array('post_id'=>$post_id,'post_type'=>''));
if ($post->isEmpty())
{
$err = true;
$msg = 'No such post.';
}
elseif (!$post->trackbacksActive())
{
$err = true;
$msg = 'Trackbacks are not allowed for this post or weblog.';
}
$url = trim(html::clean($url));
if ($this->pingAlreadyDone($post->post_id, $url)) {
$err = true;
$msg = 'The trackback has already been registered';
}
}
if (!$err)
{
$charset = self::getCharsetFromRequest();
if (!$charset) {
$charset = self::detectCharset($title.' '.$excerpt.' '.$blog_name);
}
if (strtolower($charset) != 'utf-8') {
$title = iconv($charset,'UTF-8',$title);
$excerpt = iconv($charset,'UTF-8',$excerpt);
$blog_name = iconv($charset,'UTF-8',$blog_name);
}
$title = trim(html::clean($title));
$title = html::decodeEntities($title);
$title = html::escapeHTML($title);
$title = text::cutString($title,60);
$excerpt = trim(html::clean($excerpt));
$excerpt = html::decodeEntities($excerpt);
$excerpt = preg_replace('/\s+/ms',' ',$excerpt);
$excerpt = text::cutString($excerpt,252);
$excerpt = html::escapeHTML($excerpt).'...';
$blog_name = trim(html::clean($blog_name));
$blog_name = html::decodeEntities($blog_name);
$blog_name = html::escapeHTML($blog_name);
$blog_name = text::cutString($blog_name,60);
try
{
$this->addBacklink($post_id, $url, $blog_name, $title, $excerpt, $comment);
}
catch (Exception $e)
{
$err = 1;
$msg = 'Something went wrong : '.$e->getMessage();
}
}
$resp =
''."\n".
"\n".
' '.(integer) $err."\n";
if ($msg) {
$resp .= ' '.$msg."\n";
}
if (!empty($_POST['__debug'])) {
$resp .=
" \n".
' '.$title."\n".
' '.$excerpt."\n".
' '.$url."\n".
' '.$blog_name."\n".
' '.$charset."\n".
' '.$comment."\n".
" \n";
}
echo $resp."";
}
//@}
/// @name Receive pingbacks
//@{
/**
Receives a pingback and insert it as a comment of given post.
@param from_url string Source URL
@param to_url string Target URL
*/
public function receive_pb($from_url, $to_url)
{
$reg = '!^'.preg_quote($this->core->blog->url).'(.*)!';
$type = $args = $next = '';
# Are you dumb?
if (!preg_match($reg, $to_url, $m)) {
throw new Exception(__('Any chance you ping one of my contents? No? Really?'), 0);
}
# Does the targeted URL look like a registered post type?
$url_part = $m[1];
$p_type = '';
$post_types = $this->core->getPostTypes();
foreach ($post_types as $k => $v) {
$reg = '!^'.preg_quote(str_replace('%s', '', $v['public_url'])).'(.*)!';
if (preg_match($reg, $url_part, $n)) {
$p_type = $k;
$post_url = $n[1];
break;
}
}
if (empty($p_type)) {
throw new Exception(__('Sorry but you can not ping this type of content.'), 33);
}
# Time to see if we've got a winner...
$params = array(
'post_type' => $p_type,
'post_url' => $post_url,
);
$posts = $this->core->blog->getPosts($params);
# Missed!
if ($posts->isEmpty()) {
throw new Exception(__('Oops. Kinda "not found" stuff. Please check the target URL twice.'), 33);
}
# Nice try. But, sorry, no.
if (!$posts->trackbacksActive()) {
throw new Exception(__('Sorry, dude. This entry does not accept pingback at the moment.'), 33);
}
if ($this->pingAlreadyDone($posts->post_id, $from_url)) {
throw new Exception(__('Don\'t repeat yourself, please.'), 48);
}
# OK. We've found our champion. Time to check the remote part.
try {
$http = self::initHttp($from_url, $from_path);
# First round : just to be sure the ping comes from an acceptable resource type.
$http->setHeadersOnly(true);
$http->get($from_path);
$c_type = explode(';', $http->getHeader('content-type'));
# Bad luck. Bye, bye...
if (!in_array($c_type[0],array('text/html', 'application/xhtml+xml'))) {
throw new Exception(__('Your source URL does not look like a supported content type. Sorry. Bye, bye!'), 0);
}
# Second round : let's go fetch and parse the remote content
$http->setHeadersOnly(false);
$http->get($from_path);
$remote_content = $http->getContent();
$charset = self::getCharsetFromRequest($http->getHeader('content-type'));
if (!$charset) {
$charset = self::detectCharset($remote_content);
}
if (strtolower($charset) != 'utf-8') {
$remote_content = iconv($charset,'UTF-8',$remote_content);
}
# We want a title...
if (!preg_match('!([^<].*?)!mis', $remote_content, $m)) {
throw new Exception(__('Where\'s your title?'), 0);
}
$title = trim(html::clean($m[1]));
$title = html::decodeEntities($title);
$title = html::escapeHTML($title);
$title = text::cutString($title,60);
preg_match('!]*?>(.*)? !msi', $remote_content, $m);
$source = $m[1];
$source = preg_replace('![\r\n\s]+!ms',' ',$source);
$source = preg_replace( "/<\/*(h\d|p|th|td|li|dt|dd|pre|caption|input|textarea|button)[^>]*>/", "\n\n", $source );
$source = strip_tags($source, '