eliseuamaro/gnu-social
1
0
Fork 0
forked from GNUsocial/gnu-social
Code Issues Pull Requests Releases Wiki Activity

[TheFreeNetwork][fix_duplicates.php] Small improvements on queries performed

Browse Source
This commit is contained in:
Diogo Cordeiro 2020-08-04 12:38:51 +01:00
parent e206995268
commit 7d52440461
1 changed files with 22 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -40,13 +40,12 @@ require_once INSTALLDIR . '/scripts/commandline.inc';
/**
* Remote profiles are inspected from the most to the least
* relevant according to the protocols they belong.
* preferred according to the protocols they belong and age.
* Invariants:
* - `seen_local` array: The most recent profile inside of a certain protocol
* - global `seen` array: The most relevant profile (if there were duplicates, the first protocol of the list is the one to have its profile maintained)
* We do so while maintaining a global 'seen' array makes it
* easy to satisfy a policy of maintaining only the duplicated
* profiles that are either the most relevant or the newest
* - `seen_local` array: The most recent profile inside of a certain protocol are kept
* - global `seen` array: The most relevant profile (if there were duplicates, the first protocol of the list is the one to have its profile maintained) are kept
* These two variables make it easy to satisfy a policy of maintaining
* only the profiles that are either the most relevant or the newest
* ones intra-protocol wise.
*/
@ -62,41 +61,42 @@ function run(): void
function fix_duplicates(string $profile_class, array &$seen): void
{
$db = new $profile_class();
$db->selectAdd('profile_id');
$db->selectAdd('uri');
$db->whereAdd('profile_id IS NOT NULL'); // ignore groups
$protocol_profile = new $profile_class();
$protocol_profile->selectAdd();
$protocol_profile->selectAdd('profile_id');
$protocol_profile->selectAdd('uri');
$protocol_profile->whereAdd('profile_id IS NOT NULL'); // ignore groups
if (!$db->find()) {
if (!$protocol_profile->find()) {
// This protocol wasn't used apparently
return;
}
$seen_local = [];
while ($db->fetch()) {
$id = $db->profile_id;
$uri = $db->uri;
while ($protocol_profile->fetch()) {
$id = $protocol_profile->profile_id;
$uri = $protocol_profile->uri;
// 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) {
printfv("Deleting Profile with id = {$id}\n");
$profile = Profile::getKV('id', $id);
printfnq("Deleting Profile with id = {$id}\n");
$profile = Profile::getByID($id);
$profile->delete();
} else {
printfv("Deleting {$profile_class} with id = {$id}\n");
$profile = $profile_class::getKV('profile_id', $id);
$profile->delete();
printfnq("Deleting {$profile_class} with id = {$id}\n");
$protocol_profile->delete();
}
} elseif (array_key_exists($uri, $seen_local)) {
// Was it in this protocol? Delete the older record.
if ($seen_local[$uri] !== $id) {
printfv("Deleting Profile with id = {$seen_local[$uri]}\n");
$profile = Profile::getKV('id', $seen_local[$uri]);
printfnq("Deleting Profile with id = {$seen_local[$uri]}\n");
$profile = Profile::getByID($seen_local[$uri]);
$profile->delete();
} else {
printfv("Deleting {$profile_class} with id = {$seen_local[$uri]}\n");
printfnq("Deleting {$profile_class} with id = {$seen_local[$uri]}\n");
$profile = $profile_class::getKV('profile_id', $seen_local[$uri]);
$profile->delete();
}