use Friendica\Core\Renderer;
use Friendica\Core\Session;
use Friendica\Core\System;
+use Friendica\Model\Tag;
use Friendica\Core\Worker;
use Friendica\Database\DBA;
use Friendica\Database\DBStructure;
use Friendica\Util\DateTimeFormat;
use Friendica\Util\Map;
use Friendica\Util\Network;
-use Friendica\Util\Security;
use Friendica\Util\Strings;
use Friendica\Worker\Delivery;
-use Text_LanguageDetect;
use Friendica\Repository\PermissionSet as RepPermissionSet;
+use LanguageDetection\Language;
class Item
{
const PT_VIDEO = 18;
const PT_DOCUMENT = 19;
const PT_EVENT = 32;
+ const PT_TAG = 64;
+ const PT_TO = 65;
+ const PT_CC = 66;
+ const PT_BTO = 67;
+ const PT_BCC = 68;
+ const PT_FOLLOWER = 69;
+ const PT_ANNOUNCEMENT = 70;
+ const PT_COMMENT = 71;
+ const PT_STORED = 72;
+ const PT_GLOBAL = 73;
+ const PT_RELAY = 74;
+ const PT_FETCHED = 75;
const PT_PERSONAL_NOTE = 128;
// Field list that is used to display the items
'allow_cid', 'allow_gid', 'deny_cid', 'deny_gid', 'item_id',
'author-id', 'author-link', 'author-name', 'author-avatar', 'author-network',
'owner-id', 'owner-link', 'owner-name', 'owner-avatar', 'owner-network',
+ 'causer-id', 'causer-link', 'causer-name', 'causer-avatar', 'causer-contact-type',
'contact-id', 'contact-uid', 'contact-link', 'contact-name', 'contact-avatar',
'writable', 'self', 'cid', 'alias', 'pinned',
'event-id', 'event-created', 'event-edited', 'event-start', 'event-finish',
'title', 'content-warning', 'body', 'location', 'coord', 'app',
'rendered-hash', 'rendered-html', 'object-type', 'object', 'target-type', 'target',
'author-id', 'author-link', 'author-name', 'author-avatar', 'author-network',
- 'owner-id', 'owner-link', 'owner-name', 'owner-avatar'];
+ 'owner-id', 'owner-link', 'owner-name', 'owner-avatar', 'causer-id'];
// List of all verbs that don't need additional content data.
// Never reorder or remove entries from this list. Just add new ones at the end, if needed.
return [];
}
- if (empty($condition) || !is_array($condition)) {
- $condition = ['iid' => $pinned];
- } else {
- reset($condition);
- $first_key = key($condition);
- if (!is_int($first_key)) {
- $condition['iid'] = $pinned;
- } else {
- $values_string = substr(str_repeat("?, ", count($pinned)), 0, -2);
- $condition[0] = '(' . $condition[0] . ") AND `iid` IN (" . $values_string . ")";
- $condition = array_merge($condition, $pinned);
- }
- }
+ $condition = DBA::mergeConditions(['iid' => $pinned], $condition);
return self::selectThreadForUser($uid, $selected, $condition, $params);
}
$fields = [];
$fields['item'] = ['id', 'uid', 'parent', 'uri', 'parent-uri', 'thr-parent',
- 'guid', 'uri-id', 'parent-uri-id', 'thr-parent-id', 'vid',
+ 'guid', 'uri-id', 'parent-uri-id', 'thr-parent-id', 'vid', 'causer-id',
'contact-id', 'owner-id', 'author-id', 'type', 'wall', 'gravity', 'extid',
'created', 'edited', 'commented', 'received', 'changed', 'psid',
'resource-id', 'event-id', 'attach', 'post-type', 'file',
$fields['owner'] = ['url' => 'owner-link', 'name' => 'owner-name', 'addr' => 'owner-addr',
'thumb' => 'owner-avatar', 'nick' => 'owner-nick', 'network' => 'owner-network'];
+ $fields['causer'] = ['url' => 'causer-link', 'name' => 'causer-name', 'addr' => 'causer-addr',
+ 'thumb' => 'causer-avatar', 'nick' => 'causer-nick', 'network' => 'causer-network',
+ 'contact-type' => 'causer-contact-type'];
+
$fields['contact'] = ['url' => 'contact-link', 'name' => 'contact-name', 'thumb' => 'contact-avatar',
'writable', 'self', 'id' => 'cid', 'alias', 'uid' => 'contact-uid',
'photo', 'name-date', 'uri-date', 'avatar-date', 'thumb', 'dfrn-id'];
- $fields['parent-item'] = ['guid' => 'parent-guid', 'network' => 'parent-network'];
+ $fields['parent-item'] = ['guid' => 'parent-guid', 'network' => 'parent-network', 'author-id' => 'parent-author-id'];
$fields['parent-item-author'] = ['url' => 'parent-author-link', 'name' => 'parent-author-name',
'network' => 'parent-author-network'];
$joins .= " LEFT JOIN `contact` AS `owner` ON `owner`.`id` = $master_table.`owner-id`";
}
}
+ if (strpos($sql_commands, "`causer`.") !== false) {
+ $joins .= " LEFT JOIN `contact` AS `causer` ON `causer`.`id` = `item`.`causer-id`";
+ }
if (strpos($sql_commands, "`group_member`.") !== false) {
$joins .= " STRAIGHT_JOIN `group_member` ON `group_member`.`contact-id` = $master_table.`contact-id`";
* @param array $item
* @return boolean item is valid
*/
- private static function isValid(array $item)
+ public static function isValid(array $item)
{
// When there is no content then we don't post it
if ($item['body'].$item['title'] == '') {
}
}
- if (Contact::isBlocked($item['author-id'])) {
+ if (!empty($item['author-id']) && Contact::isBlocked($item['author-id'])) {
Logger::notice('Author is blocked node-wide', ['author-link' => $item['author-link'], 'item-uri' => $item['uri']]);
return false;
}
return false;
}
- if (!empty($item['uid']) && Contact\User::isBlocked($item['author-id'], $item['uid'])) {
+ if (!empty($item['uid']) && !empty($item['author-id']) && Contact\User::isBlocked($item['author-id'], $item['uid'])) {
Logger::notice('Author is blocked by user', ['author-link' => $item['author-link'], 'uid' => $item['uid'], 'item-uri' => $item['uri']]);
return false;
}
- if (Contact::isBlocked($item['owner-id'])) {
+ if (!empty($item['owner-id']) && Contact::isBlocked($item['owner-id'])) {
Logger::notice('Owner is blocked node-wide', ['owner-link' => $item['owner-link'], 'item-uri' => $item['uri']]);
return false;
}
return false;
}
- if (!empty($item['uid']) && Contact\User::isBlocked($item['owner-id'], $item['uid'])) {
+ if (!empty($item['uid']) && !empty($item['owner-id']) && Contact\User::isBlocked($item['owner-id'], $item['uid'])) {
Logger::notice('Owner is blocked by user', ['owner-link' => $item['owner-link'], 'uid' => $item['uid'], 'item-uri' => $item['uri']]);
return false;
}
$item['plink'] = ($item['plink'] ?? '') ?: DI::baseUrl() . '/display/' . urlencode($item['guid']);
- $item['language'] = self::getLanguage($item);
-
$item['gravity'] = self::getGravity($item);
+ $item['language'] = self::getLanguage($item);
+
$default = ['url' => $item['author-link'], 'name' => $item['author-name'],
'photo' => $item['author-avatar'], 'network' => $item['network']];
$item['author-id'] = ($item['author-id'] ?? 0) ?: Contact::getIdForURL($item['author-link'], 0, null, $default);
'photo' => $item['owner-avatar'], 'network' => $item['network']];
$item['owner-id'] = ($item['owner-id'] ?? 0) ?: Contact::getIdForURL($item['owner-link'], 0, null, $default);
+ $actor = ($item['gravity'] == GRAVITY_PARENT) ? $item['owner-id'] : $item['author-id'];
+ if (!$item['origin'] && ($item['uid'] != 0) && Contact::isSharing($actor, $item['uid'])) {
+ $item['post-type'] = self::PT_FOLLOWER;
+ }
+
// Ensure that there is an avatar cache
Contact::checkAvatarCache($item['author-id']);
Contact::checkAvatarCache($item['owner-id']);
return 0;
}
- // We don't store the causer, we only have it here for the checks in the function above
- unset($item['causer-id']);
+ // We don't store the causer link, only the id
unset($item['causer-link']);
// We don't store these fields anymore in the item table
// It is mainly used in the "post_local" hook.
unset($item['api_source']);
- self::transformToForumPost($item);
+ if ($item['verb'] == Activity::ANNOUNCE) {
+ self::setOwnerforResharedItem($item);
+ }
// Check for hashtags in the body and repair or add hashtag links
$item['body'] = self::setHashtags($item['body']);
if (!in_array($item['verb'], self::ACTIVITIES)) {
$item['icid'] = self::insertContent($item);
+ if (empty($item['icid'])) {
+ // This most likely happens when identical posts arrives from different sources at the same time
+ Logger::warning('No content stored, quitting', ['guid' => $item['guid'], 'uri-id' => $item['uri-id'], 'causer-id' => ($item['causer-id'] ?? 0), 'post-type' => $item['post-type'], 'network' => $item['network']]);
+ return 0;
+ }
}
$body = $item['body'];
}
/**
- * Convert items to forum posts
+ * Change the owner of a parent item if it had been shared by a forum
*
* (public) forum posts in the new format consist of the regular post by the author
* followed by an announce message sent from the forum account.
- * This means we have to look out for an announce message send by a forum account.
+ * Changing the owner helps in grouping forum posts.
*
* @param array $item
* @return void
*/
- private static function transformToForumPost(array $item)
+ private static function setOwnerforResharedItem(array $item)
{
- if ($item["verb"] != Activity::ANNOUNCE) {
- // No announce message, so don't do anything
+ $parent = self::selectFirst(['id', 'owner-id', 'author-id', 'author-link', 'origin', 'post-type'],
+ ['uri-id' => $item['thr-parent-id'], 'uid' => $item['uid']]);
+ if (!DBA::isResult($parent)) {
+ Logger::error('Parent not found', ['uri-id' => $item['thr-parent-id'], 'uid' => $item['uid']]);
return;
}
- $pcontact = Contact::selectFirst(['nurl'], ['id' => $item['author-id'], 'contact-type' => Contact::TYPE_COMMUNITY]);
- if (empty($pcontact['nurl'])) {
- // The announce message wasn't created by a forum account, so we don't need to continue
+ $author = Contact::selectFirst(['url', 'contact-type'], ['id' => $item['author-id']]);
+ if (!DBA::isResult($author)) {
+ Logger::error('Author not found', ['id' => $item['author-id']]);
return;
}
- $contact = Contact::selectFirst(['id'], ['nurl' => $pcontact['nurl'], 'uid' => $item['uid']]);
- if (!empty($contact['id'])) {
- $condition = ['uri-id' => $item['parent-uri-id'], 'uid' => $item['uid']];
- Item::update(['owner-id' => $item['author-id'], 'contact-id' => $contact['id']], $condition);
- $forum_item = Item::selectFirst(['id'], $condition);
- if (!empty($forum_item['id'])) {
- // This will trigger notifications like "X shared a new post"
- UserItem::setNotification($forum_item['id']);
+ $cid = Contact::getIdForURL($author['url'], $item['uid']);
+ if (empty($cid) || !Contact::isSharing($cid, $item['uid'])) {
+ Logger::info('The resharer is not a following contact: quit', ['resharer' => $author['url'], 'uid' => $item['uid']]);
+ return;
+ }
- check_user_notification($forum_item['id']);
+ if ($author['contact-type'] != Contact::TYPE_COMMUNITY) {
+ if (Contact::isSharing($parent['owner-id'], $item['uid'])) {
+ Logger::info('The resharer is no forum: quit', ['resharer' => $item['author-id'], 'owner' => $parent['owner-id'], 'author' => $parent['author-id'], 'uid' => $item['uid']]);
+ return;
}
- LOgger::info('Convert message into a forum message', ['uri-id' => $item['uri-id'], 'parent-uri-id' => $item['parent-uri-id'], 'uid' => $item['uid'], 'owner-id' => $item['author-id'], 'contact-id' => $contact['id']]);
+ self::update(['post-type' => self::PT_ANNOUNCEMENT, 'causer-id' => $item['author-id']], ['id' => $parent['id']]);
+ Logger::info('Set announcement post-type', ['uri-id' => $item['uri-id'], 'thr-parent-id' => $item['thr-parent-id'], 'uid' => $item['uid']]);
+ return;
}
+
+ self::update(['owner-id' => $item['author-id'], 'contact-id' => $cid], ['id' => $parent['id']]);
+ Logger::info('Change owner of the parent', ['uri-id' => $item['uri-id'], 'thr-parent-id' => $item['thr-parent-id'], 'uid' => $item['uid'], 'owner-id' => $item['author-id'], 'contact-id' => $cid]);
}
/**
$uids = Tag::getUIDListByURIId($item['uri-id']);
foreach ($uids as $uid) {
- $stored = self::storeForUserByUriId($item['uri-id'], $uid);
- Logger::info('Stored item for users', ['uri-id' => $item['uri-id'], 'uid' => $uid, 'stored' => $stored]);
+ if (Contact::isSharing($item['author-id'], $uid)) {
+ $fields = [];
+ } else {
+ $fields = ['post-type' => self::PT_TAG];
+ }
+
+ $stored = self::storeForUserByUriId($item['uri-id'], $uid, $fields);
+ Logger::info('Stored item for users', ['uri-id' => $item['uri-id'], 'uid' => $uid, 'fields' => $fields, 'stored' => $stored]);
}
}
*
* @param integer $uri_id URI-ID of the given item
* @param integer $uid The user that will receive the item entry
+ * @param array $fields Additional fields to be stored
* @return integer stored item id
*/
- public static function storeForUserByUriId(int $uri_id, int $uid)
+ public static function storeForUserByUriId(int $uri_id, int $uid, array $fields = [])
{
$item = self::selectFirst(self::ITEM_FIELDLIST, ['uri-id' => $uri_id, 'uid' => 0]);
if (!DBA::isResult($item)) {
return 0;
}
+ $item['post-type'] = self::PT_STORED;
+
+ $item = array_merge($item, $fields);
+
$stored = self::storeForUser($item, $uid);
Logger::info('Public item stored for user', ['uri-id' => $item['uri-id'], 'uid' => $uid, 'stored' => $stored]);
return $stored;
unset($item['starred']);
unset($item['postopts']);
unset($item['inform']);
+ unset($item['post-type']);
if ($item['uri'] == $item['parent-uri']) {
$item['contact-id'] = $item['owner-id'];
} else {
unset($item['starred']);
unset($item['postopts']);
unset($item['inform']);
+ unset($item['post-type']);
$item['contact-id'] = Contact::getIdForURL($item['author-link']);
$public_shadow = self::insert($item, false, true);
*/
private static function getLanguage(array $item)
{
+ if (!in_array($item['gravity'], [GRAVITY_PARENT, GRAVITY_COMMENT])) {
+ return '';
+ }
+
$naked_body = BBCode::toPlaintext($item['body'], false);
- $ld = new Text_LanguageDetect();
- $ld->setNameMode(2);
- $languages = $ld->detect($naked_body, 3);
+ $ld = new Language();
+ $languages = $ld->detect($naked_body)->limit(0, 3)->close();
if (is_array($languages)) {
return json_encode($languages);
}
}
}
+ if (!$mention) {
+ $tags = Tag::getByURIId($item['uri-id'], [Tag::MENTION, Tag::EXCLUSIVE_MENTION]);
+ foreach ($tags as $tag) {
+ if (Strings::compareLink($link, $tag['url']) || Strings::compareLink($dlink, $tag['url'])) {
+ $mention = true;
+ DI::logger()->info('mention found in tag.', ['url' => $tag['url']]);
+ }
+ }
+ }
+
if (!$mention) {
if (($community_page || $prvgroup) &&
!$item['wall'] && !$item['origin'] && ($item['gravity'] == GRAVITY_PARENT)) {
'owner-id' => $owner_id, 'private' => $private, 'psid' => $psid];
self::update($fields, ['id' => $item_id]);
- self::updateThread($item_id);
-
Worker::add(['priority' => PRIORITY_HIGH, 'dont_fork' => true], 'Notifier', Delivery::POST, $item_id);
- /// @todo This code should be activated by the end of the year 2020
- // See also "createActivityFromItem"
- //Item::performActivity($item_id, 'announce', $uid);
+ Item::performActivity($item_id, 'announce', $uid);
return false;
}
$fields = ['uid', 'guid', 'created', 'edited', 'commented', 'received', 'changed', 'post-type',
'wall', 'private', 'pubmail', 'moderated', 'visible', 'starred', 'contact-id', 'uri-id',
'deleted', 'origin', 'forum_mode', 'network', 'author-id', 'owner-id'];
- $condition = ["`id` = ? AND (`parent` = ? OR `parent` = 0)", $itemid, $itemid];
- $item = self::selectFirst($fields, $condition);
+ $item = self::selectFirst($fields, ['id' => $itemid, 'gravity' => GRAVITY_PARENT]);
if (!DBA::isResult($item)) {
return;
}
DI::page()['htmlhead'] .= Renderer::replaceMacros(Renderer::getMarkupTemplate('videos_head.tpl'));
}
- $url_parts = explode('/', $the_url);
- $id = end($url_parts);
$as .= Renderer::replaceMacros(Renderer::getMarkupTemplate('video_top.tpl'), [
'$video' => [
- 'id' => $id,
+ 'id' => $item['author-id'],
'title' => DI::l10n()->t('View Video'),
'src' => $the_url,
'mime' => $mime,