$items = Item::select(['id'], $condition, ['limit' => [($page - 1) * 20, 20], 'order' => ['created' => true]]);
while ($item = Item::fetch($items)) {
- $object = self::createObjectFromItemID($item['id']);
- unset($object['@context']);
- $list[] = $object;
+ $activity = self::createActivityFromItem($item['id'], true);
+ // Only list "Create" activity objects here, no reshares
+ if (is_array($activity['object']) && ($activity['type'] == 'Create')) {
+ $list[] = $activity['object'];
+ }
}
if (!empty($list)) {
$terms = Term::tagArrayFromItemId($item['id'], [Term::MENTION, Term::IMPLICIT_MENTION]);
+ // Directly mention the original author upon a quoted reshare.
+ // Else just ensure that the original author receives the reshare.
+ $announce = self::getAnnounceArray($item);
+ if (!empty($announce['comment'])) {
+ $data['to'][] = $announce['actor']['url'];
+ } elseif (!empty($announce)) {
+ $data['cc'][] = $announce['actor']['url'];
+ }
+
if (!$item['private']) {
$data = array_merge($data, self::fetchPermissionBlockFromConversation($item));
public static function ItemArrayFromMail($mail_id)
{
$mail = DBA::selectFirst('mail', [], ['id' => $mail_id]);
+ if (!DBA::isResult($mail)) {
+ return [];
+ }
$reply = DBA::selectFirst('mail', ['uri'], ['parent-uri' => $mail['parent-uri'], 'reply' => false]);
$mail = self::ItemArrayFromMail($mail_id);
$object = self::createNote($mail);
- $object['to'] = $object['cc'];
- unset($object['cc']);
-
- $object['tag'] = [['type' => 'Mention', 'href' => $object['to'][0], 'name' => 'test']];
-
if (!$object_mode) {
$data = ['@context' => ActivityPub::CONTEXT];
} else {
unset($data['bcc']);
$object['to'] = $data['to'];
+ $object['tag'] = [['type' => 'Mention', 'href' => $object['to'][0], 'name' => '']];
+
unset($object['cc']);
unset($object['bcc']);
// Only check for a reshare, if it is a real reshare and no quoted reshare
if (strpos($item['body'], "[share") === 0) {
- $announce = api_share_as_retweet($item);
- $reshared = !empty($announce['plink']);
+ $announce = self::getAnnounceArray($item);
+ $reshared = !empty($announce);
}
if ($reshared) {
/// @todo Create "conversation" entry
}
- /**
- * Creates an object array for a given item id
- *
- * @param integer $item_id
- *
- * @return array with the object data
- * @throws \Friendica\Network\HTTPException\InternalServerErrorException
- * @throws \ImagickException
- */
- public static function createObjectFromItemID($item_id)
- {
- $item = Item::selectFirst([], ['id' => $item_id, 'parent-network' => Protocol::NATIVE_SUPPORT]);
-
- if (!DBA::isResult($item)) {
- return false;
- }
-
- $data = ['@context' => ActivityPub::CONTEXT];
- $data = array_merge($data, self::createNote($item));
-
- return $data;
- }
-
/**
* Creates a location entry for a given item array
*
$tags[] = ['type' => 'Mention', 'href' => $term['url'], 'name' => $mention];
}
}
+
+ $announce = self::getAnnounceArray($item);
+ // Mention the original author upon commented reshares
+ if (!empty($announce['comment'])) {
+ $tags[] = ['type' => 'Mention', 'href' => $announce['actor']['url'], 'name' => '@' . $announce['actor']['addr']];
+ }
+
return $tags;
}
*/
public static function createNote($item)
{
+ if (empty($item)) {
+ return [];
+ }
+
if ($item['event-type'] == 'event') {
$type = 'Event';
} elseif (!empty($item['title'])) {
private static function createAnnounce($item, $data)
{
$orig_body = $item['body'];
- $announce = api_share_as_retweet($item);
- if (empty($announce['plink'])) {
+ $announce = self::getAnnounceArray($item);
+ if (empty($announce)) {
$data['type'] = 'Create';
$data['object'] = self::createNote($item);
return $data;
}
- // Fetch the original id of the object
- $activity = ActivityPub::fetchContent($announce['plink'], $item['uid']);
- if (!empty($activity)) {
- $ldactivity = JsonLD::compact($activity);
- $id = JsonLD::fetchElement($ldactivity, '@id');
- $type = str_replace('as:', '', JsonLD::fetchElement($ldactivity, '@type'));
- if (!empty($id)) {
- if (empty($announce['share-pre-body'])) {
- // Pure announce, without a quote
- $data['type'] = 'Announce';
- $data['object'] = $id;
- return $data;
- }
-
- // Quote
- $data['type'] = 'Create';
- $item['body'] = trim($announce['share-pre-body']) . "\n" . $id;
- $data['object'] = self::createNote($item);
-
- /// @todo Finally descide how to implement this in AP. This is a possible way:
- $data['object']['attachment'][] = ['type' => $type, 'id' => $id];
-
- $data['object']['source']['content'] = $orig_body;
- return $data;
- }
+ if (empty($announce['comment'])) {
+ // Pure announce, without a quote
+ $data['type'] = 'Announce';
+ $data['object'] = $announce['object']['uri'];
+ return $data;
}
- $item['body'] = $orig_body;
+ // Quote
$data['type'] = 'Create';
+ $item['body'] = $announce['comment'] . "\n" . $announce['object']['plink'];
$data['object'] = self::createNote($item);
+
+ /// @todo Finally descide how to implement this in AP. This is a possible way:
+ $data['object']['attachment'][] = self::createNote($announce['object']);
+
+ $data['object']['source']['content'] = $orig_body;
return $data;
}
+ /**
+ * Return announce related data if the item is an annunce
+ *
+ * @param array $item
+ *
+ * @return array
+ */
+ public static function getAnnounceArray($item)
+ {
+ $reshared = Item::getShareArray($item);
+ if (empty($reshared['guid'])) {
+ return [];
+ }
+
+ $reshared_item = Item::selectFirst([], ['guid' => $reshared['guid']]);
+ if (!DBA::isResult($reshared_item)) {
+ return [];
+ }
+
+ if (!in_array($reshared_item['network'], [Protocol::ACTIVITYPUB, Protocol::DFRN])) {
+ return [];
+ }
+
+ $profile = APContact::getByURL($reshared_item['author-link'], false);
+ if (empty($profile)) {
+ return [];
+ }
+
+ return ['object' => $reshared_item, 'actor' => $profile, 'comment' => $reshared['comment']];
+ }
+
/**
* Creates an activity id for a given contact id
*