X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FModel%2FAPContact.php;h=71f3cfae47bac438192582cc77ef8605d84c35b7;hb=fe0339dabee4333355d96b700849bbdadf97ea06;hp=e5dd27e0e36f55dcae1a5bfd4bdbabea753742ee;hpb=14fde5dc9b1915392601fb94efc6224c01f2b216;p=friendica.git diff --git a/src/Model/APContact.php b/src/Model/APContact.php index e5dd27e0e3..71f3cfae47 100644 --- a/src/Model/APContact.php +++ b/src/Model/APContact.php @@ -7,15 +7,14 @@ namespace Friendica\Model; use Friendica\BaseObject; +use Friendica\Content\Text\HTML; use Friendica\Core\Logger; use Friendica\Database\DBA; use Friendica\Protocol\ActivityPub; use Friendica\Util\Network; use Friendica\Util\JsonLD; use Friendica\Util\DateTimeFormat; -use Friendica\Content\Text\HTML; - -require_once 'boot.php'; +use Friendica\Util\Strings; class APContact extends BaseObject { @@ -62,7 +61,7 @@ class APContact extends BaseObject * Fetches a profile from a given 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 */ public static function getByURL($url, $update = null) @@ -72,18 +71,22 @@ class APContact extends BaseObject } 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]); - if (DBA::isResult($apcontact)) { - return $apcontact; + if (!DBA::isResult($apcontact)) { + $apcontact = DBA::selectFirst('apcontact', [], ['alias' => $url]); } - $apcontact = DBA::selectFirst('apcontact', [], ['alias' => $url]); - if (DBA::isResult($apcontact)) { - return $apcontact; + if (!DBA::isResult($apcontact)) { + $apcontact = DBA::selectFirst('apcontact', [], ['addr' => $url]); } - $apcontact = DBA::selectFirst('apcontact', [], ['addr' => $url]); - if (DBA::isResult($apcontact)) { + if (DBA::isResult($apcontact) && ($apcontact['updated'] > $ref_update)) { return $apcontact; } @@ -106,6 +109,10 @@ class APContact extends BaseObject $compacted = JsonLD::compact($data); + if (empty($compacted['@id'])) { + return false; + } + $apcontact = []; $apcontact['url'] = $compacted['@id']; $apcontact['uuid'] = JsonLD::fetchElement($compacted, 'diaspora:guid'); @@ -130,7 +137,7 @@ class APContact extends BaseObject $apcontact['about'] = HTML::toBBCode(JsonLD::fetchElement($compacted, 'as:summary')); $apcontact['photo'] = JsonLD::fetchElement($compacted, 'as:icon', '@id'); - if (is_array($apcontact['photo'])) { + if (is_array($apcontact['photo']) || !empty($compacted['as:icon']['as:url']['@id'])) { $apcontact['photo'] = JsonLD::fetchElement($compacted['as:icon'], 'as:url', '@id'); } @@ -150,8 +157,9 @@ class APContact extends BaseObject $apcontact['pubkey'] = trim(JsonLD::fetchElement($compacted, 'w3id:publicKey', 'w3id:publicKeyPem')); + $apcontact['manually-approve'] = (int)JsonLD::fetchElement($compacted, 'as:manuallyApprovesFollowers'); + // To-Do - // manuallyApprovesFollowers // Unhandled // @context, tag, attachment, image, nomadicLocations, signature, following, followers, featured, movedTo, liked @@ -182,18 +190,41 @@ class APContact extends BaseObject // Update some data in the contact table with various ways to catch them all $contact_fields = ['name' => $apcontact['name'], 'about' => $apcontact['about']]; - DBA::update('contact', $contact_fields, ['nurl' => normalise_link($url)]); - $contacts = DBA::select('contact', ['uid', 'id'], ['nurl' => normalise_link($url)]); + // 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; + + if ($contact_fields['contact-type'] != Contact::ACCOUNT_TYPE_COMMUNITY) { + // Resetting the 'forum' and 'prv' field when it isn't a forum + $contact_fields['forum'] = false; + $contact_fields['prv'] = false; + } else { + // Otherwise set the corresponding forum type + $contact_fields['forum'] = !$apcontact['manually-approve']; + $contact_fields['prv'] = $apcontact['manually-approve']; + } + } + } + + DBA::update('contact', $contact_fields, ['nurl' => Strings::normaliseLink($url)]); + + $contacts = DBA::select('contact', ['uid', 'id'], ['nurl' => Strings::normaliseLink($url)]); while ($contact = DBA::fetch($contacts)) { Contact::updateAvatar($apcontact['photo'], $contact['uid'], $contact['id']); } DBA::close($contacts); // Update the gcontact table - DBA::update('gcontact', $contact_fields, ['nurl' => normalise_link($url)]); + // These two fields don't exist in the gcontact table + unset($contact_fields['forum']); + unset($contact_fields['prv']); + DBA::update('gcontact', $contact_fields, ['nurl' => Strings::normaliseLink($url)]); - Logger::log('Updated profile for ' . $url, LOGGER_DEBUG); + Logger::log('Updated profile for ' . $url, Logger::DEBUG); return $apcontact; }