GNUsocial/gnu-social
4
0
Fork 1
Code Issues Releases Wiki Activity

[TheFreeNetwork][fix_duplicates.php] Don't die because you couldn't federate an undo follow

Browse Source
This commit is contained in:
Diogo Cordeiro 2020-08-04 13:03:33 +01:00
parent 7d52440461
commit 09c3236afc
4 changed files with 41 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
modules/TheFreeNetwork/scripts/fix_duplicates.php
View File

@ -80,25 +80,35 @@ function fix_duplicates(string $profile_class, array &$seen): void
// Have we seen this profile before?
if (array_key_exists($uri, $seen)) {
// Was it on a previous protocol? Keep the highest preference protocol's one
if ($seen[$uri] !== $id) {
printfnq("Deleting Profile with id = {$id}\n");
$profile = Profile::getByID($id);
$profile->delete();
} else {
printfnq("Deleting {$profile_class} with id = {$id}\n");
$protocol_profile->delete();
try {
// Was it on a previous protocol? Keep the highest preference protocol's one
if ($seen[$uri] !== $id) {
printfnq("Deleting Profile with id = {$id}\n");
$profile = Profile::getByID($id);
$profile->delete();
} else {
printfnq("Deleting {$profile_class} with id = {$id}\n");
$protocol_profile->delete();
}
} catch (Exception $e) {
// Let it go
printfnq('FWIW: ' . $e->getMessage() . "\n");
}
} elseif (array_key_exists($uri, $seen_local)) {
// Was it in this protocol? Delete the older record.
if ($seen_local[$uri] !== $id) {
printfnq("Deleting Profile with id = {$seen_local[$uri]}\n");
$profile = Profile::getByID($seen_local[$uri]);
$profile->delete();
} else {
printfnq("Deleting {$profile_class} with id = {$seen_local[$uri]}\n");
$profile = $profile_class::getKV('profile_id', $seen_local[$uri]);
$profile->delete();
try {
// Was it in this protocol? Delete the older record.
if ($seen_local[$uri] !== $id) {
printfnq("Deleting Profile with id = {$seen_local[$uri]}\n");
$profile = Profile::getByID($seen_local[$uri]);
$profile->delete();
} else {
printfnq("Deleting {$profile_class} with id = {$seen_local[$uri]}\n");
$profile = $profile_class::getKV('profile_id', $seen_local[$uri]);
$profile->delete();
}
} catch (Exception $e) {
// Let it go
printfnq('FWIW: ' . $e->getMessage() . "\n");
}
// Update the profile id for this URI.
$seen_local[$uri] = $id;
@ -107,6 +117,8 @@ function fix_duplicates(string $profile_class, array &$seen): void
$seen_local[$uri] = $id;
}
}
$protocol_profile->free();
unset($protocol_profile);
// Merge the findings inside this protocol with the global seen to be used on the next protocol of the list.
$seen = array_merge($seen, $seen_local);

4
plugins/OStatus/OStatusPlugin.php
View File

@ -710,7 +710,7 @@ class OStatusPlugin extends Plugin
* @param Profile $profile subscriber
* @param Profile $other subscribee
*
* @return hook return code
* @return bool hook return code
*
* @throws Exception
*/
@ -735,7 +735,7 @@ class OStatusPlugin extends Plugin
* @param Profile $profile subscriber
* @param Profile $other subscribee
*
* @return hook return code
* @return bool hook return code
*
* @throws Exception
*/

2
plugins/OStatus/classes/Ostatus_profile.php
View File

@ -385,7 +385,7 @@ class Ostatus_profile extends Managed_DataObject
*
* @param mixed $entry XML string, Notice, or Activity
* @param Profile $actor
* @return boolean success
* @return bool success
*/
public function notifyActivity($entry, Profile $actor)
{

13
plugins/OStatus/lib/salmon.php
View File

@ -43,11 +43,16 @@ class Salmon
*
* @param string $endpoint_uri
* @param string $xml string representation of payload
* @param Profile $user profile whose keys we sign with (must be a local user)
* @return boolean success
* @param Profile $actor profile whose keys we sign with (must be a local user)
* @param Profile|null $target
* @return bool success
*/
public static function post($endpoint_uri, $xml, Profile $actor, Profile $target=null)
{
public static function post(
$endpoint_uri,
$xml,
Profile $actor,
?Profile $target = null
) {
if (empty($endpoint_uri)) {
common_debug('No endpoint URI for Salmon post to '.$actor->getUri());
return false;