aboutsummaryrefslogtreecommitdiffstats
path: root/apps/lookup_server_connector/lib/BackgroundJobs/RetryJob.php
diff options
context:
space:
mode:
Diffstat (limited to 'apps/lookup_server_connector/lib/BackgroundJobs/RetryJob.php')
-rw-r--r--apps/lookup_server_connector/lib/BackgroundJobs/RetryJob.php46
1 files changed, 23 insertions, 23 deletions
diff --git a/apps/lookup_server_connector/lib/BackgroundJobs/RetryJob.php b/apps/lookup_server_connector/lib/BackgroundJobs/RetryJob.php
index 1958e666503..08fe0b3fa2b 100644
--- a/apps/lookup_server_connector/lib/BackgroundJobs/RetryJob.php
+++ b/apps/lookup_server_connector/lib/BackgroundJobs/RetryJob.php
@@ -19,11 +19,7 @@ use OCP\IUser;
use OCP\IUserManager;
class RetryJob extends Job {
- private IClientService $clientService;
private string $lookupServer;
- private IConfig $config;
- private IUserManager $userManager;
- private IAccountManager $accountManager;
private Signer $signer;
protected int $retries = 0;
protected bool $retainJob = false;
@@ -36,20 +32,18 @@ class RetryJob extends Job {
* @param IAccountManager $accountManager
* @param Signer $signer
*/
- public function __construct(ITimeFactory $time,
- IClientService $clientService,
- IConfig $config,
- IUserManager $userManager,
- IAccountManager $accountManager,
- Signer $signer) {
+ public function __construct(
+ ITimeFactory $time,
+ private IClientService $clientService,
+ private IConfig $config,
+ private IUserManager $userManager,
+ private IAccountManager $accountManager,
+ Signer $signer,
+ ) {
parent::__construct($time);
- $this->clientService = $clientService;
- $this->config = $config;
- $this->userManager = $userManager;
- $this->accountManager = $accountManager;
$this->signer = $signer;
- $this->lookupServer = $config->getSystemValue('lookup_server', 'https://lookup.nextcloud.com');
+ $this->lookupServer = $this->config->getSystemValue('lookup_server', 'https://lookup.nextcloud.com');
if (!empty($this->lookupServer)) {
$this->lookupServer = rtrim($this->lookupServer, '/');
$this->lookupServer .= '/users';
@@ -66,7 +60,7 @@ class RetryJob extends Job {
return;
}
- $this->retries = (int) $this->config->getUserValue($this->argument['userId'], 'lookup_server_connector', 'update_retries', '0');
+ $this->retries = (int)$this->config->getUserValue($this->argument['userId'], 'lookup_server_connector', 'update_retries', '0');
if ($this->shouldRemoveBackgroundJob()) {
$jobList->remove($this, $this->argument);
@@ -90,10 +84,12 @@ class RetryJob extends Job {
* - max retries are reached (set to 5)
*/
protected function shouldRemoveBackgroundJob(): bool {
- return $this->config->getSystemValueBool('has_internet_connection', true) === false ||
- $this->config->getSystemValueString('lookup_server', 'https://lookup.nextcloud.com') === '' ||
- $this->config->getAppValue('files_sharing', 'lookupServerUploadEnabled', 'yes') !== 'yes' ||
- $this->retries >= 5;
+ // TODO: Remove global scale condition once lookup server is used for non-global scale federation
+ // return $this->config->getAppValue('files_sharing', 'lookupServerUploadEnabled', 'no') !== 'yes'
+ return !$this->config->getSystemValueBool('gs.enabled', false)
+ || $this->config->getSystemValueBool('has_internet_connection', true) === false
+ || $this->config->getSystemValueString('lookup_server', 'https://lookup.nextcloud.com') === ''
+ || $this->retries >= 5;
}
protected function shouldRun(): bool {
@@ -155,7 +151,7 @@ class RetryJob extends Job {
$user->getUID(),
'lookup_server_connector',
'update_retries',
- $this->retries + 1
+ (string)($this->retries + 1),
);
}
}
@@ -164,9 +160,13 @@ class RetryJob extends Job {
$account = $this->accountManager->getAccount($user);
$publicData = [];
- foreach ($account->getProperties() as $property) {
+ foreach ($account->getAllProperties() as $property) {
if ($property->getScope() === IAccountManager::SCOPE_PUBLISHED) {
- $publicData[$property->getName()] = $property->getValue();
+ $publicData[$property->getName()] = [
+ 'value' => $property->getValue(),
+ 'verified' => $property->getVerified(),
+ 'signature' => $property->getVerificationData(),
+ ];
}
}