Friendica/friendica-github
1
0
Fork 0
mirror of https://github.com/friendica/friendica synced 2025-04-26 21:10:16 +00:00
Code Issues Projects Releases Packages Wiki Activity

Reduce the amount of "UpdateContact" worker calls

Browse source
This commit is contained in:
Michael 2022-12-28 14:56:12 +00:00
parent 4bb0fdc9a9
commit e0e2e45b91
6 changed files with 89 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

50
src/Model/Contact.php
View file

@ -329,7 +329,7 @@ class Contact
// Add internal fields
$removal = [];
if (!empty($fields)) {
foreach (['id', 'next-update', 'network'] as $internal) {
foreach (['id', 'next-update', 'network', 'local-data'] as $internal) {
if (!in_array($internal, $fields)) {
$fields[] = $internal;
$removal[] = $internal;
@ -358,8 +358,10 @@ class Contact
return [];
}
$background_update = DI::config()->get('system', 'update_active_contacts') ? $contact['local-data'] : true;
// Update the contact in the background if needed
if (Probe::isProbable($contact['network']) && ($contact['next-update'] < DateTimeFormat::utcNow())) {
if ($background_update && !self::isLocal($url) && Probe::isProbable($contact['network']) && ($contact['next-update'] < DateTimeFormat::utcNow())) {
Worker::add(['priority' => Worker::PRIORITY_LOW, 'dont_fork' => true], 'UpdateContact', $contact['id']);
}
@ -1266,12 +1268,14 @@ class Contact
return 0;
}
$contact = self::getByURL($url, false, ['id', 'network', 'uri-id', 'next-update'], $uid);
$contact = self::getByURL($url, false, ['id', 'network', 'uri-id', 'next-update', 'local-data'], $uid);
if (!empty($contact)) {
$contact_id = $contact['id'];
if (Probe::isProbable($contact['network']) && ($contact['next-update'] < DateTimeFormat::utcNow())) {
$background_update = DI::config()->get('system', 'update_active_contacts') ? $contact['local-data'] : true;
if ($background_update && !self::isLocal($url) && Probe::isProbable($contact['network']) && ($contact['next-update'] < DateTimeFormat::utcNow())) {
Worker::add(['priority' => Worker::PRIORITY_LOW, 'dont_fork' => true], 'UpdateContact', $contact['id']);
}
@ -2481,6 +2485,44 @@ class Contact
return true;
}
/**
* Perform a contact update if the contact is outdated
*
* @param integer $id contact id
* @return bool
*/
public static function updateByIdIfNeeded(int $id): bool
{
$contact = self::selectFirst(['url'], ["`id` = ? AND `next-update` < ?", $id, DateTimeFormat::utcNow()]);
if (empty($contact['url'])) {
return false;
}
if (self::isLocal($contact['url'])) {
return true;
}
$stamp = (float)microtime(true);
self::updateFromProbe($id);
Logger::debug('Contact data is updated.', ['duration' => round((float)microtime(true) - $stamp, 3), 'id' => $id, 'url' => $contact['url'], 'callstack' => System::callstack(20)]);
return true;
}
/**
* Perform a contact update if the contact is outdated
*
* @param string $url contact url
* @return bool
*/
public static function updateByUrlIfNeeded(string $url): bool
{
$id = self::getIdForURL($url, 0, false);
if (!empty($id)) {
return self::updateByIdIfNeeded($id);
}
return (bool)self::getIdForURL($url);
}
/**
* Updates contact record by provided id and optional network
*