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 committed by Diogo Peralta Cordeiro
parent f81b578a37
commit 4dfa7f374a
4 changed files with 41 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -80,6 +80,7 @@ function fix_duplicates(string $profile_class, array &$seen): void
// Have we seen this profile before? // Have we seen this profile before?
if (array_key_exists($uri, $seen)) { if (array_key_exists($uri, $seen)) {
try {
// Was it on a previous protocol? Keep the highest preference protocol's one // Was it on a previous protocol? Keep the highest preference protocol's one
if ($seen[$uri] !== $id) { if ($seen[$uri] !== $id) {
printfnq("Deleting Profile with id = {$id}\n"); printfnq("Deleting Profile with id = {$id}\n");
@ -89,7 +90,12 @@ function fix_duplicates(string $profile_class, array &$seen): void
printfnq("Deleting {$profile_class} with id = {$id}\n"); printfnq("Deleting {$profile_class} with id = {$id}\n");
$protocol_profile->delete(); $protocol_profile->delete();
} }
} catch (Exception $e) {
// Let it go
printfnq('FWIW: ' . $e->getMessage() . "\n");
}
} elseif (array_key_exists($uri, $seen_local)) { } elseif (array_key_exists($uri, $seen_local)) {
try {
// Was it in this protocol? Delete the older record. // Was it in this protocol? Delete the older record.
if ($seen_local[$uri] !== $id) { if ($seen_local[$uri] !== $id) {
printfnq("Deleting Profile with id = {$seen_local[$uri]}\n"); printfnq("Deleting Profile with id = {$seen_local[$uri]}\n");
@ -100,6 +106,10 @@ function fix_duplicates(string $profile_class, array &$seen): void
$profile = $profile_class::getKV('profile_id', $seen_local[$uri]); $profile = $profile_class::getKV('profile_id', $seen_local[$uri]);
$profile->delete(); $profile->delete();
} }
} catch (Exception $e) {
// Let it go
printfnq('FWIW: ' . $e->getMessage() . "\n");
}
// Update the profile id for this URI. // Update the profile id for this URI.
$seen_local[$uri] = $id; $seen_local[$uri] = $id;
} else { } else {
@ -107,6 +117,8 @@ function fix_duplicates(string $profile_class, array &$seen): void
$seen_local[$uri] = $id; $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. // 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); $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 $profile subscriber
* @param Profile $other subscribee * @param Profile $other subscribee
* *
* @return hook return code * @return bool hook return code
* *
* @throws Exception * @throws Exception
*/ */
@ -735,7 +735,7 @@ class OStatusPlugin extends Plugin
* @param Profile $profile subscriber * @param Profile $profile subscriber
* @param Profile $other subscribee * @param Profile $other subscribee
* *
* @return hook return code * @return bool hook return code
* *
* @throws Exception * @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 mixed $entry XML string, Notice, or Activity
* @param Profile $actor * @param Profile $actor
* @return boolean success * @return bool success
*/ */
public function notifyActivity($entry, Profile $actor) 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 $endpoint_uri
* @param string $xml string representation of payload * @param string $xml string representation of payload
* @param Profile $user profile whose keys we sign with (must be a local user) * @param Profile $actor profile whose keys we sign with (must be a local user)
* @return boolean success * @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)) { if (empty($endpoint_uri)) {
common_debug('No endpoint URI for Salmon post to '.$actor->getUri()); common_debug('No endpoint URI for Salmon post to '.$actor->getUri());
return false; return false;