bitPickups/friendica_2020-09-1_sharedHosting
1
0
Fork 0
Code Pull requests Activity

We now send participations when receiving public posts

Browse source
This commit is contained in:
Michael 2017-12-29 18:52:26 +00:00
parent d38cf3cc13
commit 80a41922a9
1 changed files with 49 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

49
src/Protocol/Diaspora.php
View file

@ -2688,6 +2688,8 @@ class Diaspora
self::fetchGuid($datarray); self::fetchGuid($datarray);
$message_id = item_store($datarray); $message_id = item_store($datarray);
self::sendParticipation($contact, $datarray);
if ($message_id) { if ($message_id) {
logger("Stored reshare ".$datarray["guid"]." with message id ".$message_id, LOGGER_DEBUG); logger("Stored reshare ".$datarray["guid"]." with message id ".$message_id, LOGGER_DEBUG);
return true; return true;
@ -2926,6 +2928,8 @@ class Diaspora
self::fetchGuid($datarray); self::fetchGuid($datarray);
$message_id = item_store($datarray); $message_id = item_store($datarray);
self::sendParticipation($contact, $datarray);
if ($message_id) { if ($message_id) {
logger("Stored item ".$datarray["guid"]." with message id ".$message_id, LOGGER_DEBUG); logger("Stored item ".$datarray["guid"]." with message id ".$message_id, LOGGER_DEBUG);
return true; return true;
@ -3215,6 +3219,51 @@ class Diaspora
return $return_code; return $return_code;
} }
/**
* @brief sends a participation (Used to get all further updates)
*
* @param array $contact Target of the communication
* @param array $item Item array
*
* @return int The result of the transmission
*/
private static function sendParticipation($contact, $item)
{
// Don't send notifications for private postings
if ($item['private']) {
return;
}
$cachekey = "diaspora:sendParticipation:".$item['guid'];
$result = Cache::get($cachekey);
if (!is_null($result)) {
return;
}
// Fetch some user id to have a valid handle to transmit the participation.
// In fact it doesn't matter which user sends this - but it is needed by the protocol.
$condition = ['verified' => true, 'blocked' => false, 'account_removed' => false, 'account_expired' => false];
$first_user = dba::select('user', ['uid'], $condition, ['limit' => 1]);
$owner = User::getOwnerDataById($first_user['uid']);
$parent_type = (self::isReshare($item['body']) ? 'Reshare' : 'StatusMessage');
$author = self::myHandle($owner);
$message = array("author" => $author,
"guid" => get_guid(32),
"parent_type" => $parent_type,
"parent_guid" => $item["guid"]);
logger("Send participation for ".$parent_type." ".$item["guid"]." by ".$author, LOGGER_DEBUG);
// It doesn't matter what we store, we only want to avoid sending repeated notifications for the same item
Cache::set($cachekey, $item["guid"], CACHE_QUARTER_HOUR);
return self::buildAndTransmit($owner, $contact, "participation", $message);
}
/** /**
* @brief sends an account migration * @brief sends an account migration
* *