}
function linkback_get_source($source, $target) {
+ // Check if we are pinging ourselves and ignore
+ $localprefix = common_config('site', 'server') . '/' . common_config('site', 'path');
+ if(linkback_lenient_target_match($source, $localprefix) === 0) {
+ common_debug('Ignoring self ping from ' . $source . ' to ' . $target);
+ return NULL;
+ }
+
$request = HTTPClient::start();
try {
$body = htmlspecialchars_decode($response->getBody());
// We're slightly more lenient in our link detection than the spec requires
- if(!linkback_lenient_target_match($body, $target)) {
+ if(linkback_lenient_target_match($body, $target) === FALSE) {
return NULL;
}
}
if(!$user) {
preg_match('/\/([^\/\?#]+)(?:#.*)?$/', $response->getEffectiveUrl(), $match);
- if(linkback_lenient_target_match(common_profile_url($match[1]), $response->getEffectiveUrl())) {
+ if(linkback_lenient_target_match(common_profile_url($match[1]), $response->getEffectiveUrl()) !== FALSE) {
$user = User::getKV('nickname', $match[1]);
}
}
function linkback_is_contained_in($entry, $target) {
foreach ((array)$entry['properties'] as $key => $values) {
- if(count(array_filter($values, function($x) use ($target) { return linkback_lenient_target_match($x, $target); })) > 0) {
+ if(count(array_filter($values, function($x) use ($target) { return linkback_lenient_target_match($x, $target) !== FALSE; })) > 0) {
return $entry['properties'];
}
if(isset($obj['type']) && array_intersect(array('h-cite', 'h-entry'), $obj['type']) &&
isset($obj['properties']) && isset($obj['properties']['url']) &&
count(array_filter($obj['properties']['url'],
- function($x) use ($target) { return linkback_lenient_target_match($x, $target); })) > 0
+ function($x) use ($target) { return linkback_lenient_target_match($x, $target) !== FALSE; })) > 0
) {
return $entry['properties'];
}
if($mf2['rels'] && $mf2['rels']['in-reply-to']) {
foreach($mf2['rels']['in-reply-to'] as $url) {
- if(linkback_lenient_target_match($url, $target)) {
+ if(linkback_lenient_target_match($url, $target) !== FALSE) {
return 'reply';
}
}
);
foreach((array)$entry as $key => $values) {
- if(count(array_filter($values, function($x) use ($target) { return linkback_lenient_target_match($x, $target); })) > 0) {
+ if(count(array_filter($values, function($x) use ($target) { return linkback_lenient_target_match($x, $target) != FALSE; })) > 0) {
if($classes[$key]) { return $classes[$key]; }
}
if(isset($obj['type']) && array_intersect(array('h-cite', 'h-entry'), $obj['type']) &&
isset($obj['properties']) && isset($obj['properties']['url']) &&
count(array_filter($obj['properties']['url'],
- function($x) use ($target) { return linkback_lenient_target_match($x, $target); })) > 0
+ function($x) use ($target) { return linkback_lenient_target_match($x, $target) != FALSE; })) > 0
) {
if($classes[$key]) { return $classes[$key]; }
}
// We found a match, return it immediately
if(isset($item['properties']['url']) && in_array($url, $item['properties']['url'])) {
return $item['properties'];
-
- // Let's keep all the hcards for later, to return one of them at least
- $hcards[] = $item['properties'];
}
+
+ // Let's keep all the hcards for later, to return one of them at least
+ $hcards[] = $item['properties'];
}
// No match immediately for the url we expected, but there were h-cards found
}
function linkback_notice($source, $notice_or_user, $entry, $author, $mf2) {
- $content = $entry['content'] ? $entry['content'][0]['html'] :
- ($entry['summary'] ? $entry['sumary'][0] : $entry['name'][0]);
+ $content = isset($entry['content']) ? $entry['content'][0]['html'] :
+ (isset($entry['summary']) ? $entry['summary'][0] : $entry['name'][0]);
$rendered = common_purify($content);
if($notice_or_user instanceof Notice && $entry['type'] == 'mention') {
- $name = $entry['name'] ? $entry['name'][0] : substr(common_strip_html($content), 0, 20).'…';
+ $name = isset($entry['name']) ? $entry['name'][0] : substr(common_strip_html($content), 0, 20).'…';
$rendered = _m('linked to this from <a href="'.htmlspecialchars($source).'">'.htmlspecialchars($name).'</a>');
}
}
}
- if($entry['published'] || $entry['updated']) {
- $options['created'] = $entry['published'] ? common_sql_date($entry['published'][0]) : common_sql_date($entry['updated'][0]);
+ if (isset($entry['published']) || isset($entry['updated'])) {
+ $options['created'] = isset($entry['published'])
+ ? common_sql_date(strtotime($entry['published'][0]))
+ : common_sql_date(strtotime($entry['updated'][0]));
}
- if($entry['photo']) {
+ if (isset($entry['photo']) && common_valid_http_url($entry['photo'])) {
$options['urls'][] = $entry['photo'][0];
+ } elseif (isset($entry['photo'])) {
+ common_debug('Linkback got invalid HTTP URL for photo: '._ve($entry['photo']));
}
foreach((array)$entry['category'] as $tag) {
return array($content, $options);
}
+function linkback_avatar($profile, $url) {
+ // Ripped from OStatus plugin for now
+ $temp_filename = tempnam(sys_get_temp_dir(), 'linback_avatar');
+ try {
+ $imgData = HTTPClient::quickGet($url);
+ // Make sure it's at least an image file. ImageFile can do the rest.
+ if (false === getimagesizefromstring($imgData)) {
+ return false;
+ }
+ file_put_contents($temp_filename, $imgData);
+ unset($imgData); // No need to carry this in memory.
+
+ $imagefile = new ImageFile(null, $temp_filename);
+ $filename = Avatar::filename($profile->id,
+ image_type_to_extension($imagefile->type),
+ null,
+ common_timestamp());
+ rename($temp_filename, Avatar::path($filename));
+ } catch (Exception $e) {
+ unlink($temp_filename);
+ throw $e;
+ }
+ // @todo FIXME: Hardcoded chmod is lame, but seems to be necessary to
+ // keep from accidentally saving images from command-line (queues)
+ // that can't be read from web server, which causes hard-to-notice
+ // problems later on:
+ //
+ // http://status.net/open-source/issues/2663
+ chmod(Avatar::path($filename), 0644);
+
+ $profile->setOriginal($filename);
+}
+
function linkback_profile($entry, $mf2, $response, $target) {
- if(isset($entry['properties']['author']) && isset($entry['properties']['author'][0]['properties'])) {
- $author = $entry['properties']['author'][0]['properties'];
+ if(isset($entry['author']) && isset($entry['author'][0]['properties'])) {
+ $author = $entry['author'][0]['properties'];
} else {
$author = linkback_hcard($mf2, $response->getEffectiveUrl());
}
if(!$author) {
- $author = array('name' => array($entry['name']));
+ $author = array('name' => $entry['name']);
}
- if(!$author['url']) {
+ if (!isset($author['url']) || empty($author['url'])) {
$author['url'] = array($response->getEffectiveUrl());
}
try {
$profile = Profile::fromUri($author['url'][0]);
- } catch(UnknownUriException $ex) {}
-
- if(!($profile instanceof Profile)) {
+ } catch(UnknownUriException $ex) {
$profile = Profile::getKV('profileurl', $author['url'][0]);
}
- if(!($profile instanceof Profile)) {
+ // XXX: Is this a good way to create the profile?
+ if (!$profile instanceof Profile) {
$profile = new Profile();
$profile->profileurl = $author['url'][0];
$profile->fullname = $author['name'][0];
- $profile->nickname = $author['nickname'] ? $author['nickname'][0] : str_replace(' ', '', $author['name'][0]);
+ $profile->nickname = isset($author['nickname']) ? $author['nickname'][0] : str_replace(' ', '', $author['name'][0]);
$profile->created = common_sql_now();
$profile->insert();
+
+ if($author['photo'] && $author['photo'][0]) {
+ linkback_avatar($profile, $author['photo'][0]);
+ }
}
return array($profile, $author);
try { $dupe->saveKnownTags($options['tags']); } catch (ServerException $ex) {}
try { $dupe->saveKnownUrls($options['urls']); } catch (ServerException $ex) {}
- if($options['reply_to']) { $dupe->reply_to = $options['reply_to']; }
- if($options['repost_of']) { $dupe->repost_of = $options['repost_of']; }
+ if (isset($options['reply_to'])) {
+ $dupe->reply_to = $options['reply_to'];
+ }
+ if (isset($options['repeat_of'])) {
+ $dupe->repeat_of = $options['repeat_of'];
+ }
+ if ($dupe->reply_to != $orig->reply_to || $dupe->repeat_of != $orig->repeat_of) {
+ $parent = Notice::getKV('id', $dupe->repeat_of ?: $dupe->reply_to);
+ if($parent instanceof Notice) {
+ // If we changed the reply_to or repeat_of we might live in a new conversation now
+ $dupe->conversation = $parent->conversation;
+ }
+ }
if($dupe->update($orig)) { $saved = $dupe; }
+ if($dupe->conversation != $orig->conversation && Conversation::noticeCount($orig->conversation) < 1) {
+ // Delete empty conversation
+ $emptyConversation = Conversation::getKV('id', $orig->conversation);
+ $emptyConversation->delete();
+ }
} catch (Exception $e) {
common_log(LOG_ERR, "Linkback update of remote message $source failed: " . $e->getMessage());
return false;
// notice's nickname and %3$s is the content of the favorited notice.)
$act->content = sprintf(_('%1$s favorited something by %2$s: %3$s'),
$profile->getNickname(), $notice_or_user->getProfile()->getNickname(),
- $notice_or_user->rendered ?: $notice_or_user->content);
+ $notice_or_user->getRendered());
if($entry['rsvp']) {
$act->content = $options['rendered'];
}
projects / quix0rs-gnu-social.git / blobdiff