class DFRN
{
- const TOP_LEVEL = 0; // Top level posting
- const REPLY = 1; // Regular reply that is stored locally
- const REPLY_RC = 2; // Reply that will be relayed
+ const TOP_LEVEL = 0; // Top level posting
+ const REPLY = 1; // Regular reply that is stored locally
+ const REPLY_RC = 2; // Reply that will be relayed
/**
* Generates an array of contact and user for DFRN imports
$mentioned = [];
if (!$item['parent']) {
- Logger::notice('Item without parent found.', ['type' => $type, 'item' => $item]);
+ Logger::warning('Item without parent found.', ['type' => $type, 'item' => $item]);
return null;
}
// update contact
$old = Contact::selectFirst(['photo', 'url'], ['id' => $importer['id'], 'uid' => $importer['importer_uid']]);
-
if (!DBA::isResult($old)) {
- Logger::notice("Query failed to execute, no result returned in " . __FUNCTION__);
+ Logger::warning('Existing contact had not been fetched', ['id' => $importer['id']]);
return false;
}
private static function getEntryType(array $importer, array $item): int
{
if ($item['thr-parent'] != $item['uri']) {
- $community = false;
-
- if ($importer['account-type'] == User::ACCOUNT_TYPE_COMMUNITY) {
- $sql_extra = '';
- $community = true;
- Logger::notice("possible community action");
- } else {
- $sql_extra = " AND `self` AND `wall`";
- }
-
// was the top-level post for this action written by somebody on this site?
// Specifically, the recipient?
- $parent = Post::selectFirst(['wall'],
- ["`uri` = ? AND `uid` = ?" . $sql_extra, $item['thr-parent'], $importer['importer_uid']]);
-
- $is_a_remote_action = DBA::isResult($parent);
-
- if ($is_a_remote_action) {
- return DFRN::REPLY_RC;
+ if (Post::exists(['uri' => $item['thr-parent'], 'uid' => $importer['importer_uid'], 'self' => true, 'wall' => true])) {
+ return self::REPLY_RC;
} else {
- return DFRN::REPLY;
+ return self::REPLY;
}
} else {
- return DFRN::TOP_LEVEL;
- }
- }
-
- /**
- * Send a "poke"
- *
- * @param array $item The new item record
- * @param array $importer Record of the importer user mixed with contact of the content
- * @return void
- * @throws \Friendica\Network\HTTPException\InternalServerErrorException
- * @todo set proper type-hints (array?)
- */
- private static function doPoke(array $item, array $importer)
- {
- $verb = urldecode(substr($item['verb'], strpos($item['verb'], '#')+1));
- if (!$verb) {
- return;
- }
- $xo = XML::parseString($item['object']);
-
- if (($xo->type == Activity\ObjectType::PERSON) && ($xo->id)) {
- // somebody was poked/prodded. Was it me?
- $Blink = '';
- foreach ($xo->link as $l) {
- $atts = $l->attributes();
- switch ($atts['rel']) {
- case 'alternate':
- $Blink = $atts['href'];
- break;
-
- default:
- break;
- }
- }
-
- if ($Blink && Strings::compareLink($Blink, DI::baseUrl() . '/profile/' . $importer['nickname'])) {
- $author = DBA::selectFirst('contact', ['id', 'name', 'thumb', 'url'], ['id' => $item['author-id']]);
-
- $parent = Post::selectFirst(['id'], ['uri' => $item['thr-parent'], 'uid' => $importer['importer_uid']]);
- $item['parent'] = $parent['id'];
-
- // send a notification
- DI::notify()->createFromArray(
- [
- 'type' => Notification\Type::POKE,
- 'otype' => Notification\ObjectType::PERSON,
- 'activity' => $verb,
- 'verb' => $item['verb'],
- 'uid' => $importer['importer_uid'],
- 'cid' => $author['id'],
- 'item' => $item,
- 'link' => DI::baseUrl() . '/display/' . urlencode($item['guid']),
- ]
- );
- }
+ return self::TOP_LEVEL;
}
}
* @param int $entrytype Is it a toplevel entry, a comment or a relayed comment?
* @param array $importer Record of the importer user mixed with contact of the content
* @param array $item the new item record
- * @param bool $is_like Is the verb a "like"?
*
* @return bool Should the processing of the entries be continued?
* @throws \Friendica\Network\HTTPException\InternalServerErrorException
*/
- private static function processVerbs(int $entrytype, array $importer, array &$item, bool &$is_like)
+ private static function processVerbs(int $entrytype, array $importer, array &$item)
{
Logger::info('Process verb ' . $item['verb'] . ' and object-type ' . $item['object-type'] . ' for entrytype ' . $entrytype);
- if (($entrytype == DFRN::TOP_LEVEL) && !empty($importer['id'])) {
+ if (($entrytype == self::TOP_LEVEL) && !empty($importer['id'])) {
// The filling of the the "contact" variable is done for legcy reasons
// The functions below are partly used by ostatus.php as well - where we have this variable
$contact = Contact::selectFirst([], ['id' => $importer['id']]);
|| ($item['verb'] == Activity::ATTENDMAYBE)
|| ($item['verb'] == Activity::ANNOUNCE)
) {
- $is_like = true;
$item['gravity'] = GRAVITY_ACTIVITY;
// only one like or dislike per person
// split into two queries for performance issues
$item['owner-link'] = $item['author-link'];
$item['owner-avatar'] = $item['author-avatar'];
$item['owner-id'] = $item['author-id'];
- } else {
- $is_like = false;
}
if (($item['verb'] == Activity::TAG) && ($item['object-type'] == Activity\ObjectType::TAGTERM)) {
if ($xt->type == Activity\ObjectType::NOTE) {
$item_tag = Post::selectFirst(['id', 'uri-id'], ['uri' => $xt->id, 'uid' => $importer['importer_uid']]);
-
if (!DBA::isResult($item_tag)) {
- Logger::notice("Query failed to execute, no result returned in " . __FUNCTION__);
+ Logger::warning('Post had not been fetched', ['uri' => $xt->id, 'uid' => $importer['importer_uid']]);
return false;
}
$item = $header;
- $item['protocol'] = $protocol;
-
$item['source'] = $xml;
// Get the uri
$entrytype = self::getEntryType($importer, $item);
// Now assign the rest of the values that depend on the type of the message
- if (in_array($entrytype, [DFRN::REPLY, DFRN::REPLY_RC])) {
+ if (in_array($entrytype, [self::REPLY, self::REPLY_RC])) {
+ $item['gravity'] = GRAVITY_COMMENT;
+
if (!isset($item['object-type'])) {
$item['object-type'] = Activity\ObjectType::COMMENT;
}
}
}
- // Ensure to have the correct share data
- $item = Item::addShareDataFromOriginal($item);
-
- if ($entrytype == DFRN::REPLY_RC) {
+ if ($entrytype == self::REPLY_RC) {
$item['wall'] = 1;
- } elseif ($entrytype == DFRN::TOP_LEVEL) {
+ } elseif ($entrytype == self::TOP_LEVEL) {
+ $item['gravity'] = GRAVITY_PARENT;
+
if (!isset($item['object-type'])) {
$item['object-type'] = Activity\ObjectType::NOTE;
}
}
}
- // Need to initialize variable, otherwise E_NOTICE will happen
- $is_like = false;
-
- if (!self::processVerbs($entrytype, $importer, $item, $is_like)) {
+ if (!self::processVerbs($entrytype, $importer, $item)) {
Logger::info("Exiting because 'processVerbs' told us so");
return;
}
// This check is done here to be able to receive connection requests in "processVerbs"
- if (($entrytype == DFRN::TOP_LEVEL) && $owner_unknown) {
+ if (($entrytype == self::TOP_LEVEL) && $owner_unknown) {
Logger::info("Item won't be stored because user " . $importer['importer_uid'] . " doesn't follow " . $item['owner-link'] . ".");
return;
}
return;
}
- if (in_array($entrytype, [DFRN::REPLY, DFRN::REPLY_RC])) {
+ if (in_array($entrytype, [self::REPLY, self::REPLY_RC])) {
+ if (($item['uid'] != 0) && !Post::exists(['uid' => $item['uid'], 'uri' => $item['thr-parent']])) {
+ if (DI::pConfig()->get($item['uid'], 'system', 'accept_only_sharer') == Item::COMPLETION_NONE) {
+ Logger::info('Completion is set to "none", so we stop here.', ['uid' => $item['uid'], 'owner-id' => $item['owner-id'], 'author-id' => $item['author-id'], 'gravity' => $item['gravity'], 'uri' => $item['uri']]);
+ return;
+ }
+ if (!Contact::isSharing($item['owner-id'], $item['uid']) && !Contact::isSharing($item['author-id'], $item['uid'])) {
+ Logger::info('Contact is not sharing with the user', ['uid' => $item['uid'], 'owner-id' => $item['owner-id'], 'author-id' => $item['author-id'], 'gravity' => $item['gravity'], 'uri' => $item['uri']]);
+ return;
+ }
+ if (($item['gravity'] == GRAVITY_ACTIVITY) && DI::pConfig()->get($item['uid'], 'system', 'accept_only_sharer') == Item::COMPLETION_COMMENT) {
+ Logger::info('Completion is set to "comment", but this is an activity. so we stop here.', ['uid' => $item['uid'], 'owner-id' => $item['owner-id'], 'author-id' => $item['author-id'], 'gravity' => $item['gravity'], 'uri' => $item['uri']]);
+ return;
+ }
+ Logger::debug('Post is accepted.', ['uid' => $item['uid'], 'owner-id' => $item['owner-id'], 'author-id' => $item['author-id'], 'gravity' => $item['gravity'], 'uri' => $item['uri']]);
+ } else {
+ Logger::debug('Thread parent exists.', ['uid' => $item['uid'], 'owner-id' => $item['owner-id'], 'author-id' => $item['author-id'], 'gravity' => $item['gravity'], 'uri' => $item['uri']]);
+ }
+
// Will be overwritten for sharing accounts in Item::insert
- if (empty($item['post-reason']) && ($entrytype == DFRN::REPLY)) {
+ if (empty($item['post-reason']) && ($entrytype == self::REPLY)) {
$item['post-reason'] = Item::PR_COMMENT;
}
return true;
}
- } else { // $entrytype == DFRN::TOP_LEVEL
- if (($importer['uid'] == 0) && ($importer['importer_uid'] != 0)) {
- Logger::info("Contact " . $importer['id'] . " isn't known to user " . $importer['importer_uid'] . ". The post will be ignored.");
- return;
- }
- if (!Strings::compareLink($item['owner-link'], $importer['url'])) {
- /*
- * The item owner info is not our contact. It's OK and is to be expected if this is a tgroup delivery,
- * but otherwise there's a possible data mixup on the sender's system.
- * the tgroup delivery code called from Item::insert will correct it if it's a forum,
- * but we're going to unconditionally correct it here so that the post will always be owned by our contact.
- */
- Logger::info('Correcting item owner.');
- $item['owner-link'] = $importer['url'];
- $item['owner-id'] = Contact::getIdForURL($importer['url'], 0);
- }
-
- if (($importer['rel'] == Contact::FOLLOWER) && (!self::tgroupCheck($importer['importer_uid'], $item))) {
- Logger::info("Contact " . $importer['id'] . " is only follower and tgroup check was negative.");
+ } else { // $entrytype == self::TOP_LEVEL
+ if (($item['uid'] != 0) && !Contact::isSharing($item['owner-id'], $item['uid']) && !Contact::isSharing($item['author-id'], $item['uid'])) {
+ Logger::info('Contact is not sharing with the user', ['uid' => $item['uid'], 'owner-id' => $item['owner-id'], 'author-id' => $item['author-id'], 'gravity' => $item['gravity'], 'uri' => $item['uri']]);
return;
}
if ($item['uid'] == 0) {
Item::distribute($posted_id);
}
-
- if (stristr($item['verb'], Activity::POKE)) {
- $item['id'] = $posted_id;
- self::doPoke($item, $importer);
- }
}
}
$header = [];
$header['uid'] = $importer['importer_uid'];
$header['network'] = Protocol::DFRN;
+ $header['protocol'] = $protocol;
$header['wall'] = 0;
$header['origin'] = 0;
$header['contact-id'] = $importer['id'];
- $header['direction'] = $direction;
+
+ $header = Diaspora::setDirection($header, $direction);
if ($direction === Conversation::RELAY) {
$header['post-reason'] = Item::PR_RELAY;
return Activity::POST;
}
- // @TODO Documentation missing
- private static function tgroupCheck(int $uid, array $item): bool
- {
- $mention = false;
-
- // check that the message originated elsewhere and is a top-level post
-
- if ($item['wall'] || $item['origin'] || ($item['uri'] != $item['thr-parent'])) {
- return false;
- }
-
- $user = DBA::selectFirst('user', ['account-type', 'nickname'], ['uid' => $uid]);
- if (!DBA::isResult($user)) {
- return false;
- }
-
- $link = Strings::normaliseLink(DI::baseUrl() . '/profile/' . $user['nickname']);
-
- /*
- * Diaspora uses their own hardwired link URL in @-tags
- * instead of the one we supply with webfinger
- */
- $dlink = Strings::normaliseLink(DI::baseUrl() . '/u/' . $user['nickname']);
-
- $cnt = preg_match_all('/[\@\!]\[url\=(.*?)\](.*?)\[\/url\]/ism', $item['body'], $matches, PREG_SET_ORDER);
- if ($cnt) {
- foreach ($matches as $mtch) {
- if (Strings::compareLink($link, $mtch[1]) || Strings::compareLink($dlink, $mtch[1])) {
- $mention = true;
- Logger::notice('mention found: ' . $mtch[2]);
- }
- }
- }
-
- if (!$mention) {
- return false;
- }
-
- return ($user['account-type'] == User::ACCOUNT_TYPE_COMMUNITY);
- }
-
/**
* This function returns true if $update has an edited timestamp newer
* than $existing, i.e. $update contains new data which should override
projects / friendica.git / blobdiff