nextcloud / server

lib/private/Repair.php

Indentation +188 added lines, -188 removed lines

@@ -83,210 +83,210 @@
 
 class Repair implements IOutput {
 
-	/** @var IRepairStep[] */
-	private $repairSteps;
+    /** @var IRepairStep[] */
+    private $repairSteps;
 
-	/** @var EventDispatcherInterface */
-	private $dispatcher;
+    /** @var EventDispatcherInterface */
+    private $dispatcher;
 
-	/** @var string */
-	private $currentStep;
+    /** @var string */
+    private $currentStep;
 
-	private $logger;
+    private $logger;
 
-	/**
-	 * Creates a new repair step runner
-	 *
-	 * @param IRepairStep[] $repairSteps array of RepairStep instances
-	 * @param EventDispatcherInterface $dispatcher
-	 */
-	public function __construct(array $repairSteps, EventDispatcherInterface $dispatcher, LoggerInterface $logger) {
-		$this->repairSteps = $repairSteps;
-		$this->dispatcher = $dispatcher;
-		$this->logger = $logger;
-	}
+    /**
+     * Creates a new repair step runner
+     *
+     * @param IRepairStep[] $repairSteps array of RepairStep instances
+     * @param EventDispatcherInterface $dispatcher
+     */
+    public function __construct(array $repairSteps, EventDispatcherInterface $dispatcher, LoggerInterface $logger) {
+        $this->repairSteps = $repairSteps;
+        $this->dispatcher = $dispatcher;
+        $this->logger = $logger;
+    }
 
-	/**
-	 * Run a series of repair steps for common problems
-	 */
-	public function run() {
-		if (count($this->repairSteps) === 0) {
-			$this->emit('\OC\Repair', 'info', ['No repair steps available']);
+    /**
+     * Run a series of repair steps for common problems
+     */
+    public function run() {
+        if (count($this->repairSteps) === 0) {
+            $this->emit('\OC\Repair', 'info', ['No repair steps available']);
 
-			return;
-		}
-		// run each repair step
-		foreach ($this->repairSteps as $step) {
-			$this->currentStep = $step->getName();
-			$this->emit('\OC\Repair', 'step', [$this->currentStep]);
-			try {
-				$step->run($this);
-			} catch (\Exception $e) {
-				$this->logger->error("Exception while executing repair step " . $step->getName(), ['exception' => $e]);
-				$this->emit('\OC\Repair', 'error', [$e->getMessage()]);
-			}
-		}
-	}
+            return;
+        }
+        // run each repair step
+        foreach ($this->repairSteps as $step) {
+            $this->currentStep = $step->getName();
+            $this->emit('\OC\Repair', 'step', [$this->currentStep]);
+            try {
+                $step->run($this);
+            } catch (\Exception $e) {
+                $this->logger->error("Exception while executing repair step " . $step->getName(), ['exception' => $e]);
+                $this->emit('\OC\Repair', 'error', [$e->getMessage()]);
+            }
+        }
+    }
 
-	/**
-	 * Add repair step
-	 *
-	 * @param IRepairStep|string $repairStep repair step
-	 * @throws \Exception
-	 */
-	public function addStep($repairStep) {
-		if (is_string($repairStep)) {
-			try {
-				$s = \OC::$server->query($repairStep);
-			} catch (QueryException $e) {
-				if (class_exists($repairStep)) {
-					$s = new $repairStep();
-				} else {
-					throw new \Exception("Repair step '$repairStep' is unknown");
-				}
-			}
+    /**
+     * Add repair step
+     *
+     * @param IRepairStep|string $repairStep repair step
+     * @throws \Exception
+     */
+    public function addStep($repairStep) {
+        if (is_string($repairStep)) {
+            try {
+                $s = \OC::$server->query($repairStep);
+            } catch (QueryException $e) {
+                if (class_exists($repairStep)) {
+                    $s = new $repairStep();
+                } else {
+                    throw new \Exception("Repair step '$repairStep' is unknown");
+                }
+            }
 
-			if ($s instanceof IRepairStep) {
-				$this->repairSteps[] = $s;
-			} else {
-				throw new \Exception("Repair step '$repairStep' is not of type \\OCP\\Migration\\IRepairStep");
-			}
-		} else {
-			$this->repairSteps[] = $repairStep;
-		}
-	}
+            if ($s instanceof IRepairStep) {
+                $this->repairSteps[] = $s;
+            } else {
+                throw new \Exception("Repair step '$repairStep' is not of type \\OCP\\Migration\\IRepairStep");
+            }
+        } else {
+            $this->repairSteps[] = $repairStep;
+        }
+    }
 
-	/**
-	 * Returns the default repair steps to be run on the
-	 * command line or after an upgrade.
-	 *
-	 * @return IRepairStep[]
-	 */
-	public static function getRepairSteps() {
-		return [
-			new Collation(\OC::$server->getConfig(), \OC::$server->getLogger(), \OC::$server->getDatabaseConnection(), false),
-			new RepairMimeTypes(\OC::$server->getConfig(), \OC::$server->getDatabaseConnection()),
-			new CleanTags(\OC::$server->getDatabaseConnection(), \OC::$server->getUserManager()),
-			new RepairInvalidShares(\OC::$server->getConfig(), \OC::$server->getDatabaseConnection()),
-			new MoveUpdaterStepFile(\OC::$server->getConfig()),
-			new MoveAvatars(
-				\OC::$server->getJobList(),
-				\OC::$server->getConfig()
-			),
-			new CleanPreviews(
-				\OC::$server->getJobList(),
-				\OC::$server->getUserManager(),
-				\OC::$server->getConfig()
-			),
-			new FixMountStorages(\OC::$server->getDatabaseConnection()),
-			new UpdateLanguageCodes(\OC::$server->getDatabaseConnection(), \OC::$server->getConfig()),
-			new InstallCoreBundle(
-				\OC::$server->query(BundleFetcher::class),
-				\OC::$server->getConfig(),
-				\OC::$server->query(Installer::class)
-			),
-			new AddLogRotateJob(\OC::$server->getJobList()),
-			new ClearFrontendCaches(\OC::$server->getMemCacheFactory(), \OC::$server->query(SCSSCacher::class), \OC::$server->query(JSCombiner::class)),
-			new ClearGeneratedAvatarCache(\OC::$server->getConfig(), \OC::$server->query(AvatarManager::class)),
-			new AddPreviewBackgroundCleanupJob(\OC::$server->getJobList()),
-			new AddCleanupUpdaterBackupsJob(\OC::$server->getJobList()),
-			new CleanupCardDAVPhotoCache(\OC::$server->getConfig(), \OC::$server->getAppDataDir('dav-photocache'), \OC::$server->getLogger()),
-			new AddClenupLoginFlowV2BackgroundJob(\OC::$server->getJobList()),
-			new RemoveLinkShares(\OC::$server->getDatabaseConnection(), \OC::$server->getConfig(), \OC::$server->getGroupManager(), \OC::$server->getNotificationManager(), \OC::$server->query(ITimeFactory::class)),
-			new ClearCollectionsAccessCache(\OC::$server->getConfig(), \OC::$server->query(IManager::class)),
-			\OC::$server->query(ResetGeneratedAvatarFlag::class),
-			\OC::$server->query(EncryptionLegacyCipher::class),
-			\OC::$server->query(EncryptionMigration::class),
-			\OC::$server->get(ShippedDashboardEnable::class),
-			\OC::$server->get(AddBruteForceCleanupJob::class),
-			\OC::$server->get(AddCheckForUserCertificatesJob::class),
-			\OC::$server->get(RepairDavShares::class),
-			\OC::$server->get(LookupServerSendCheck::class),
-		];
-	}
+    /**
+     * Returns the default repair steps to be run on the
+     * command line or after an upgrade.
+     *
+     * @return IRepairStep[]
+     */
+    public static function getRepairSteps() {
+        return [
+            new Collation(\OC::$server->getConfig(), \OC::$server->getLogger(), \OC::$server->getDatabaseConnection(), false),
+            new RepairMimeTypes(\OC::$server->getConfig(), \OC::$server->getDatabaseConnection()),
+            new CleanTags(\OC::$server->getDatabaseConnection(), \OC::$server->getUserManager()),
+            new RepairInvalidShares(\OC::$server->getConfig(), \OC::$server->getDatabaseConnection()),
+            new MoveUpdaterStepFile(\OC::$server->getConfig()),
+            new MoveAvatars(
+                \OC::$server->getJobList(),
+                \OC::$server->getConfig()
+            ),
+            new CleanPreviews(
+                \OC::$server->getJobList(),
+                \OC::$server->getUserManager(),
+                \OC::$server->getConfig()
+            ),
+            new FixMountStorages(\OC::$server->getDatabaseConnection()),
+            new UpdateLanguageCodes(\OC::$server->getDatabaseConnection(), \OC::$server->getConfig()),
+            new InstallCoreBundle(
+                \OC::$server->query(BundleFetcher::class),
+                \OC::$server->getConfig(),
+                \OC::$server->query(Installer::class)
+            ),
+            new AddLogRotateJob(\OC::$server->getJobList()),
+            new ClearFrontendCaches(\OC::$server->getMemCacheFactory(), \OC::$server->query(SCSSCacher::class), \OC::$server->query(JSCombiner::class)),
+            new ClearGeneratedAvatarCache(\OC::$server->getConfig(), \OC::$server->query(AvatarManager::class)),
+            new AddPreviewBackgroundCleanupJob(\OC::$server->getJobList()),
+            new AddCleanupUpdaterBackupsJob(\OC::$server->getJobList()),
+            new CleanupCardDAVPhotoCache(\OC::$server->getConfig(), \OC::$server->getAppDataDir('dav-photocache'), \OC::$server->getLogger()),
+            new AddClenupLoginFlowV2BackgroundJob(\OC::$server->getJobList()),
+            new RemoveLinkShares(\OC::$server->getDatabaseConnection(), \OC::$server->getConfig(), \OC::$server->getGroupManager(), \OC::$server->getNotificationManager(), \OC::$server->query(ITimeFactory::class)),
+            new ClearCollectionsAccessCache(\OC::$server->getConfig(), \OC::$server->query(IManager::class)),
+            \OC::$server->query(ResetGeneratedAvatarFlag::class),
+            \OC::$server->query(EncryptionLegacyCipher::class),
+            \OC::$server->query(EncryptionMigration::class),
+            \OC::$server->get(ShippedDashboardEnable::class),
+            \OC::$server->get(AddBruteForceCleanupJob::class),
+            \OC::$server->get(AddCheckForUserCertificatesJob::class),
+            \OC::$server->get(RepairDavShares::class),
+            \OC::$server->get(LookupServerSendCheck::class),
+        ];
+    }
 
-	/**
-	 * Returns expensive repair steps to be run on the
-	 * command line with a special option.
-	 *
-	 * @return IRepairStep[]
-	 */
-	public static function getExpensiveRepairSteps() {
-		return [
-			new OldGroupMembershipShares(\OC::$server->getDatabaseConnection(), \OC::$server->getGroupManager()),
-			\OC::$server->get(ValidatePhoneNumber::class),
-		];
-	}
+    /**
+     * Returns expensive repair steps to be run on the
+     * command line with a special option.
+     *
+     * @return IRepairStep[]
+     */
+    public static function getExpensiveRepairSteps() {
+        return [
+            new OldGroupMembershipShares(\OC::$server->getDatabaseConnection(), \OC::$server->getGroupManager()),
+            \OC::$server->get(ValidatePhoneNumber::class),
+        ];
+    }
 
-	/**
-	 * Returns the repair steps to be run before an
-	 * upgrade.
-	 *
-	 * @return IRepairStep[]
-	 */
-	public static function getBeforeUpgradeRepairSteps() {
-		/** @var Connection $connection */
-		$connection = \OC::$server->get(Connection::class);
-		/** @var ConnectionAdapter $connectionAdapter */
-		$connectionAdapter = \OC::$server->get(ConnectionAdapter::class);
-		$config = \OC::$server->getConfig();
-		$steps = [
-			new Collation(\OC::$server->getConfig(), \OC::$server->getLogger(), $connectionAdapter, true),
-			new SqliteAutoincrement($connection),
-			new SaveAccountsTableData($connectionAdapter, $config),
-			new DropAccountTermsTable($connectionAdapter),
-		];
+    /**
+     * Returns the repair steps to be run before an
+     * upgrade.
+     *
+     * @return IRepairStep[]
+     */
+    public static function getBeforeUpgradeRepairSteps() {
+        /** @var Connection $connection */
+        $connection = \OC::$server->get(Connection::class);
+        /** @var ConnectionAdapter $connectionAdapter */
+        $connectionAdapter = \OC::$server->get(ConnectionAdapter::class);
+        $config = \OC::$server->getConfig();
+        $steps = [
+            new Collation(\OC::$server->getConfig(), \OC::$server->getLogger(), $connectionAdapter, true),
+            new SqliteAutoincrement($connection),
+            new SaveAccountsTableData($connectionAdapter, $config),
+            new DropAccountTermsTable($connectionAdapter),
+        ];
 
-		return $steps;
-	}
+        return $steps;
+    }
 
-	/**
-	 * @param string $scope
-	 * @param string $method
-	 * @param array $arguments
-	 */
-	public function emit($scope, $method, array $arguments = []) {
-		if (!is_null($this->dispatcher)) {
-			$this->dispatcher->dispatch("$scope::$method",
-				new GenericEvent("$scope::$method", $arguments));
-		}
-	}
+    /**
+     * @param string $scope
+     * @param string $method
+     * @param array $arguments
+     */
+    public function emit($scope, $method, array $arguments = []) {
+        if (!is_null($this->dispatcher)) {
+            $this->dispatcher->dispatch("$scope::$method",
+                new GenericEvent("$scope::$method", $arguments));
+        }
+    }
 
-	public function info($string) {
-		// for now just emit as we did in the past
-		$this->emit('\OC\Repair', 'info', [$string]);
-	}
+    public function info($string) {
+        // for now just emit as we did in the past
+        $this->emit('\OC\Repair', 'info', [$string]);
+    }
 
-	/**
-	 * @param string $message
-	 */
-	public function warning($message) {
-		// for now just emit as we did in the past
-		$this->emit('\OC\Repair', 'warning', [$message]);
-	}
+    /**
+     * @param string $message
+     */
+    public function warning($message) {
+        // for now just emit as we did in the past
+        $this->emit('\OC\Repair', 'warning', [$message]);
+    }
 
-	/**
-	 * @param int $max
-	 */
-	public function startProgress($max = 0) {
-		// for now just emit as we did in the past
-		$this->emit('\OC\Repair', 'startProgress', [$max, $this->currentStep]);
-	}
+    /**
+     * @param int $max
+     */
+    public function startProgress($max = 0) {
+        // for now just emit as we did in the past
+        $this->emit('\OC\Repair', 'startProgress', [$max, $this->currentStep]);
+    }
 
-	/**
-	 * @param int $step
-	 * @param string $description
-	 */
-	public function advance($step = 1, $description = '') {
-		// for now just emit as we did in the past
-		$this->emit('\OC\Repair', 'advance', [$step, $description]);
-	}
+    /**
+     * @param int $step
+     * @param string $description
+     */
+    public function advance($step = 1, $description = '') {
+        // for now just emit as we did in the past
+        $this->emit('\OC\Repair', 'advance', [$step, $description]);
+    }
 
-	/**
-	 * @param int $max
-	 */
-	public function finishProgress() {
-		// for now just emit as we did in the past
-		$this->emit('\OC\Repair', 'finishProgress', []);
-	}
+    /**
+     * @param int $max
+     */
+    public function finishProgress() {
+        // for now just emit as we did in the past
+        $this->emit('\OC\Repair', 'finishProgress', []);
+    }
 }

lib/private/Repair/NC22/LookupServerSendCheck.php

Indentation +19 added lines, -19 removed lines

@@ -34,29 +34,29 @@
 
 class LookupServerSendCheck implements IRepairStep {
 
-	/** @var IJobList */
-	private $jobList;
+    /** @var IJobList */
+    private $jobList;
 
-	/** @var IConfig */
-	private $config;
+    /** @var IConfig */
+    private $config;
 
-	public function __construct(IJobList $jobList, IConfig $config) {
-		$this->jobList = $jobList;
-		$this->config = $config;
-	}
+    public function __construct(IJobList $jobList, IConfig $config) {
+        $this->jobList = $jobList;
+        $this->config = $config;
+    }
 
-	public function getName(): string {
-		return 'Add background job to set the lookup server share state for users';
-	}
+    public function getName(): string {
+        return 'Add background job to set the lookup server share state for users';
+    }
 
-	private function shouldRun(): bool {
-		$versionFromBeforeUpdate = $this->config->getSystemValue('version', '0.0.0.0');
+    private function shouldRun(): bool {
+        $versionFromBeforeUpdate = $this->config->getSystemValue('version', '0.0.0.0');
 
-		// was added to 22.0.0.3
-		return version_compare($versionFromBeforeUpdate, '22.0.0.3', '<');
-	}
+        // was added to 22.0.0.3
+        return version_compare($versionFromBeforeUpdate, '22.0.0.3', '<');
+    }
 
-	public function run(IOutput $output): void {
-		$this->jobList->add(LookupServerSendCheckBackgroundJob::class);
-	}
+    public function run(IOutput $output): void {
+        $this->jobList->add(LookupServerSendCheckBackgroundJob::class);
+    }
 }

core/BackgroundJobs/LookupServerSendCheckBackgroundJob.php

Indentation +15 added lines, -15 removed lines

@@ -33,19 +33,19 @@
 
 class LookupServerSendCheckBackgroundJob extends QueuedJob {
 
-	/** @var IConfig */
-	protected $config;
-	/** @var IUserManager */
-	private $userManager;
-
-	public function __construct(IConfig $config, IUserManager $userManager) {
-		$this->config = $config;
-		$this->userManager = $userManager;
-	}
-
-	public function run($arguments) {
-		$this->userManager->callForSeenUsers(function (IUser $user) {
-			$this->config->setUserValue($user->getUID(), 'lookup_server_connector', 'dataSend', '1');
-		});
-	}
+    /** @var IConfig */
+    protected $config;
+    /** @var IUserManager */
+    private $userManager;
+
+    public function __construct(IConfig $config, IUserManager $userManager) {
+        $this->config = $config;
+        $this->userManager = $userManager;
+    }
+
+    public function run($arguments) {
+        $this->userManager->callForSeenUsers(function (IUser $user) {
+            $this->config->setUserValue($user->getUID(), 'lookup_server_connector', 'dataSend', '1');
+        });
+    }
 }

Spacing +1 added lines, -1 removed lines

@@ -44,7 +44,7 @@
 	}
 
 	public function run($arguments) {
-		$this->userManager->callForSeenUsers(function (IUser $user) {
+		$this->userManager->callForSeenUsers(function(IUser $user) {
 			$this->config->setUserValue($user->getUID(), 'lookup_server_connector', 'dataSend', '1');
 		});
 	}

apps/lookup_server_connector/lib/BackgroundJobs/RetryJob.php

Indentation +182 added lines, -182 removed lines

@@ -44,186 +44,186 @@
 use OCP\IUserManager;
 
 class RetryJob extends Job {
-	/** @var IClientService */
-	private $clientService;
-	/** @var string */
-	private $lookupServer;
-	/** @var IConfig */
-	private $config;
-	/** @var IUserManager */
-	private $userManager;
-	/** @var IAccountManager */
-	private $accountManager;
-	/** @var Signer */
-	private $signer;
-	/** @var int */
-	protected $retries = 0;
-	/** @var bool */
-	protected $retainJob = false;
-
-	/**
-	 * @param ITimeFactory $time
-	 * @param IClientService $clientService
-	 * @param IConfig $config
-	 * @param IUserManager $userManager
-	 * @param IAccountManager $accountManager
-	 * @param Signer $signer
-	 */
-	public function __construct(ITimeFactory $time,
-								IClientService $clientService,
-								IConfig $config,
-								IUserManager $userManager,
-								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');
-		if (!empty($this->lookupServer)) {
-			$this->lookupServer = rtrim($this->lookupServer, '/');
-			$this->lookupServer .= '/users';
-		}
-	}
-
-	/**
-	 * run the job, then remove it from the jobList
-	 *
-	 * @param IJobList $jobList
-	 * @param ILogger|null $logger
-	 */
-	public function execute(IJobList $jobList, ILogger $logger = null): void {
-		if (!isset($this->argument['userId'])) {
-			// Old background job without user id, just drop it.
-			$jobList->remove($this, $this->argument);
-			return;
-		}
-
-		$this->retries = (int) $this->config->getUserValue($this->argument['userId'], 'lookup_server_connector', 'update_retries', 0);
-
-		if ($this->shouldRemoveBackgroundJob()) {
-			$jobList->remove($this, $this->argument);
-			return;
-		}
-
-		if ($this->shouldRun()) {
-			parent::execute($jobList, $logger);
-			if (!$this->retainJob) {
-				$jobList->remove($this, $this->argument);
-			}
-		}
-	}
-
-	/**
-	 * Check if we should kill the background job:
-	 *
-	 * - internet connection is disabled
-	 * - no valid lookup server URL given
-	 * - lookup server was disabled by the admin
-	 * - max retries are reached (set to 5)
-	 *
-	 * @return bool
-	 */
-	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;
-	}
-
-	protected function shouldRun(): bool {
-		$delay = 100 * 6 ** $this->retries;
-		return ($this->time->getTime() - $this->lastRun) > $delay;
-	}
-
-	protected function run($argument): void {
-		$user = $this->userManager->get($this->argument['userId']);
-		if (!$user instanceof IUser) {
-			// User does not exist anymore
-			return;
-		}
-
-		$data = $this->getUserAccountData($user);
-		$signedData = $this->signer->sign('lookupserver', $data, $user);
-		$client = $this->clientService->newClient();
-
-		try {
-			if (count($data) === 1) {
-				$dataOnLookupServer = $this->config->getUserValue($user->getUID(), 'lookup_server_connector', 'dataSend', '0') === '1';
-
-				if (!$dataOnLookupServer) {
-					// We never send data to the lookupserver so no need to delete it
-					return;
-				}
-
-				// There is data on the lookup server so we must delete it
-				$client->delete($this->lookupServer,
-					[
-						'body' => json_encode($signedData),
-						'timeout' => 10,
-						'connect_timeout' => 3,
-					]
-				);
-
-				$this->config->setUserValue($user->getUID(), 'lookup_server_connector', 'dataSend', '0');
-			} else {
-				$client->post($this->lookupServer,
-					[
-						'body' => json_encode($signedData),
-						'timeout' => 10,
-						'connect_timeout' => 3,
-					]
-				);
-				$this->config->setUserValue($user->getUID(), 'lookup_server_connector', 'dataSend', '1');
-			}
-
-			// Reset retry counter
-			$this->config->deleteUserValue(
-				$user->getUID(),
-				'lookup_server_connector',
-				'update_retries'
-			);
-		} catch (\Exception $e) {
-			// An error occurred, retry later
-			$this->retainJob = true;
-			$this->config->setUserValue(
-				$user->getUID(),
-				'lookup_server_connector',
-				'update_retries',
-				$this->retries + 1
-			);
-		}
-	}
-
-	protected function getUserAccountData(IUser $user): array {
-		$account = $this->accountManager->getAccount($user);
-
-		$publicData = [];
-		foreach ($account->getProperties() as $property) {
-			if ($property->getScope() === IAccountManager::SCOPE_PUBLISHED) {
-				$publicData[$property->getName()] = $property->getValue();
-			}
-		}
-
-		$data = ['federationId' => $user->getCloudId()];
-		if (!empty($publicData)) {
-			$data['name'] = $publicData[IAccountManager::PROPERTY_DISPLAYNAME]['value'] ?? '';
-			$data['email'] = $publicData[IAccountManager::PROPERTY_EMAIL]['value'] ?? '';
-			$data['address'] = $publicData[IAccountManager::PROPERTY_ADDRESS]['value'] ?? '';
-			$data['website'] = $publicData[IAccountManager::PROPERTY_WEBSITE]['value'] ?? '';
-			$data['twitter'] = $publicData[IAccountManager::PROPERTY_TWITTER]['value'] ?? '';
-			$data['phone'] = $publicData[IAccountManager::PROPERTY_PHONE]['value'] ?? '';
-			$data['twitter_signature'] = $publicData[IAccountManager::PROPERTY_TWITTER]['signature'] ?? '';
-			$data['website_signature'] = $publicData[IAccountManager::PROPERTY_WEBSITE]['signature'] ?? '';
-			$data['verificationStatus'] = [
-				IAccountManager::PROPERTY_WEBSITE => $publicData[IAccountManager::PROPERTY_WEBSITE]['verified'] ?? '',
-				IAccountManager::PROPERTY_TWITTER => $publicData[IAccountManager::PROPERTY_TWITTER]['verified'] ?? '',
-			];
-		}
-
-		return $data;
-	}
+    /** @var IClientService */
+    private $clientService;
+    /** @var string */
+    private $lookupServer;
+    /** @var IConfig */
+    private $config;
+    /** @var IUserManager */
+    private $userManager;
+    /** @var IAccountManager */
+    private $accountManager;
+    /** @var Signer */
+    private $signer;
+    /** @var int */
+    protected $retries = 0;
+    /** @var bool */
+    protected $retainJob = false;
+
+    /**
+     * @param ITimeFactory $time
+     * @param IClientService $clientService
+     * @param IConfig $config
+     * @param IUserManager $userManager
+     * @param IAccountManager $accountManager
+     * @param Signer $signer
+     */
+    public function __construct(ITimeFactory $time,
+                                IClientService $clientService,
+                                IConfig $config,
+                                IUserManager $userManager,
+                                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');
+        if (!empty($this->lookupServer)) {
+            $this->lookupServer = rtrim($this->lookupServer, '/');
+            $this->lookupServer .= '/users';
+        }
+    }
+
+    /**
+     * run the job, then remove it from the jobList
+     *
+     * @param IJobList $jobList
+     * @param ILogger|null $logger
+     */
+    public function execute(IJobList $jobList, ILogger $logger = null): void {
+        if (!isset($this->argument['userId'])) {
+            // Old background job without user id, just drop it.
+            $jobList->remove($this, $this->argument);
+            return;
+        }
+
+        $this->retries = (int) $this->config->getUserValue($this->argument['userId'], 'lookup_server_connector', 'update_retries', 0);
+
+        if ($this->shouldRemoveBackgroundJob()) {
+            $jobList->remove($this, $this->argument);
+            return;
+        }
+
+        if ($this->shouldRun()) {
+            parent::execute($jobList, $logger);
+            if (!$this->retainJob) {
+                $jobList->remove($this, $this->argument);
+            }
+        }
+    }
+
+    /**
+     * Check if we should kill the background job:
+     *
+     * - internet connection is disabled
+     * - no valid lookup server URL given
+     * - lookup server was disabled by the admin
+     * - max retries are reached (set to 5)
+     *
+     * @return bool
+     */
+    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;
+    }
+
+    protected function shouldRun(): bool {
+        $delay = 100 * 6 ** $this->retries;
+        return ($this->time->getTime() - $this->lastRun) > $delay;
+    }
+
+    protected function run($argument): void {
+        $user = $this->userManager->get($this->argument['userId']);
+        if (!$user instanceof IUser) {
+            // User does not exist anymore
+            return;
+        }
+
+        $data = $this->getUserAccountData($user);
+        $signedData = $this->signer->sign('lookupserver', $data, $user);
+        $client = $this->clientService->newClient();
+
+        try {
+            if (count($data) === 1) {
+                $dataOnLookupServer = $this->config->getUserValue($user->getUID(), 'lookup_server_connector', 'dataSend', '0') === '1';
+
+                if (!$dataOnLookupServer) {
+                    // We never send data to the lookupserver so no need to delete it
+                    return;
+                }
+
+                // There is data on the lookup server so we must delete it
+                $client->delete($this->lookupServer,
+                    [
+                        'body' => json_encode($signedData),
+                        'timeout' => 10,
+                        'connect_timeout' => 3,
+                    ]
+                );
+
+                $this->config->setUserValue($user->getUID(), 'lookup_server_connector', 'dataSend', '0');
+            } else {
+                $client->post($this->lookupServer,
+                    [
+                        'body' => json_encode($signedData),
+                        'timeout' => 10,
+                        'connect_timeout' => 3,
+                    ]
+                );
+                $this->config->setUserValue($user->getUID(), 'lookup_server_connector', 'dataSend', '1');
+            }
+
+            // Reset retry counter
+            $this->config->deleteUserValue(
+                $user->getUID(),
+                'lookup_server_connector',
+                'update_retries'
+            );
+        } catch (\Exception $e) {
+            // An error occurred, retry later
+            $this->retainJob = true;
+            $this->config->setUserValue(
+                $user->getUID(),
+                'lookup_server_connector',
+                'update_retries',
+                $this->retries + 1
+            );
+        }
+    }
+
+    protected function getUserAccountData(IUser $user): array {
+        $account = $this->accountManager->getAccount($user);
+
+        $publicData = [];
+        foreach ($account->getProperties() as $property) {
+            if ($property->getScope() === IAccountManager::SCOPE_PUBLISHED) {
+                $publicData[$property->getName()] = $property->getValue();
+            }
+        }
+
+        $data = ['federationId' => $user->getCloudId()];
+        if (!empty($publicData)) {
+            $data['name'] = $publicData[IAccountManager::PROPERTY_DISPLAYNAME]['value'] ?? '';
+            $data['email'] = $publicData[IAccountManager::PROPERTY_EMAIL]['value'] ?? '';
+            $data['address'] = $publicData[IAccountManager::PROPERTY_ADDRESS]['value'] ?? '';
+            $data['website'] = $publicData[IAccountManager::PROPERTY_WEBSITE]['value'] ?? '';
+            $data['twitter'] = $publicData[IAccountManager::PROPERTY_TWITTER]['value'] ?? '';
+            $data['phone'] = $publicData[IAccountManager::PROPERTY_PHONE]['value'] ?? '';
+            $data['twitter_signature'] = $publicData[IAccountManager::PROPERTY_TWITTER]['signature'] ?? '';
+            $data['website_signature'] = $publicData[IAccountManager::PROPERTY_WEBSITE]['signature'] ?? '';
+            $data['verificationStatus'] = [
+                IAccountManager::PROPERTY_WEBSITE => $publicData[IAccountManager::PROPERTY_WEBSITE]['verified'] ?? '',
+                IAccountManager::PROPERTY_TWITTER => $publicData[IAccountManager::PROPERTY_TWITTER]['verified'] ?? '',
+            ];
+        }
+
+        return $data;
+    }
 }