Periodically update contacts / update the contact type

This commit is contained in:
Michael 2019-01-05 22:04:32 +00:00
parent fc87c51bb4
commit e88734e218
1 changed files with 22 additions and 8 deletions

View File

@ -61,7 +61,7 @@ class APContact extends BaseObject
* Fetches a profile from a given url * Fetches a profile from a given url
* *
* @param string $url profile url * @param string $url profile url
* @param boolean $update true = always update, false = never update, null = update when not found * @param boolean $update true = always update, false = never update, null = update when not found or outdated
* @return array profile array * @return array profile array
*/ */
public static function getByURL($url, $update = null) public static function getByURL($url, $update = null)
@ -71,18 +71,22 @@ class APContact extends BaseObject
} }
if (empty($update)) { if (empty($update)) {
if (is_null($update)) {
$ref_update = DateTimeFormat::utc('now - 1 month');
} else {
$ref_update = DBA::NULL_DATETIME;
}
$apcontact = DBA::selectFirst('apcontact', [], ['url' => $url]); $apcontact = DBA::selectFirst('apcontact', [], ['url' => $url]);
if (DBA::isResult($apcontact)) { if (!DBA::isResult($apcontact)) {
return $apcontact; $apcontact = DBA::selectFirst('apcontact', [], ['alias' => $url]);
} }
$apcontact = DBA::selectFirst('apcontact', [], ['alias' => $url]); if (!DBA::isResult($apcontact)) {
if (DBA::isResult($apcontact)) { $apcontact = DBA::selectFirst('apcontact', [], ['addr' => $url]);
return $apcontact;
} }
$apcontact = DBA::selectFirst('apcontact', [], ['addr' => $url]); if (DBA::isResult($apcontact) && ($apcontact['updated'] > $ref_update)) {
if (DBA::isResult($apcontact)) {
return $apcontact; return $apcontact;
} }
@ -185,6 +189,16 @@ class APContact extends BaseObject
// Update some data in the contact table with various ways to catch them all // Update some data in the contact table with various ways to catch them all
$contact_fields = ['name' => $apcontact['name'], 'about' => $apcontact['about']]; $contact_fields = ['name' => $apcontact['name'], 'about' => $apcontact['about']];
// Fetch the type and match it with the contact type
$contact_types = array_keys(ActivityPub::ACCOUNT_TYPES, $apcontact['type']);
if (!empty($contact_types)) {
$contact_type = array_pop($contact_types);
if (is_int($contact_type)) {
$contact_fields['contact-type'] = $contact_type;
}
}
DBA::update('contact', $contact_fields, ['nurl' => Strings::normaliseLink($url)]); DBA::update('contact', $contact_fields, ['nurl' => Strings::normaliseLink($url)]);
$contacts = DBA::select('contact', ['uid', 'id'], ['nurl' => Strings::normaliseLink($url)]); $contacts = DBA::select('contact', ['uid', 'id'], ['nurl' => Strings::normaliseLink($url)]);