mirror of
https://github.com/nextcloud/server.git
synced 2024-12-30 17:08:35 +00:00
72 lines
1.8 KiB
PHP
72 lines
1.8 KiB
PHP
<?php
|
|
/**
|
|
* SPDX-FileCopyrightText: 2017 Nextcloud GmbH and Nextcloud contributors
|
|
* SPDX-License-Identifier: AGPL-3.0-or-later
|
|
*/
|
|
namespace OCA\User_LDAP\Migration;
|
|
|
|
use OCA\User_LDAP\Mapping\GroupMapping;
|
|
use OCA\User_LDAP\Mapping\UserMapping;
|
|
use OCP\BackgroundJob\IJobList;
|
|
use OCP\IConfig;
|
|
use OCP\Migration\IOutput;
|
|
use OCP\Migration\IRepairStep;
|
|
|
|
class UUIDFixInsert implements IRepairStep {
|
|
|
|
public function __construct(
|
|
protected IConfig $config,
|
|
protected UserMapping $userMapper,
|
|
protected GroupMapping $groupMapper,
|
|
protected IJobList $jobList,
|
|
) {
|
|
}
|
|
|
|
/**
|
|
* Returns the step's name
|
|
*
|
|
* @return string
|
|
* @since 9.1.0
|
|
*/
|
|
public function getName() {
|
|
return 'Insert UUIDFix background job for user and group in batches';
|
|
}
|
|
|
|
/**
|
|
* Run repair step.
|
|
* Must throw exception on error.
|
|
*
|
|
* @param IOutput $output
|
|
* @throws \Exception in case of failure
|
|
* @since 9.1.0
|
|
*/
|
|
public function run(IOutput $output) {
|
|
$installedVersion = $this->config->getAppValue('user_ldap', 'installed_version', '1.2.1');
|
|
if (version_compare($installedVersion, '1.2.1') !== -1) {
|
|
return;
|
|
}
|
|
|
|
foreach ([$this->userMapper, $this->groupMapper] as $mapper) {
|
|
$offset = 0;
|
|
$batchSize = 50;
|
|
$jobClass = $mapper instanceof UserMapping ? UUIDFixUser::class : UUIDFixGroup::class;
|
|
do {
|
|
$retry = false;
|
|
$records = $mapper->getList($offset, $batchSize);
|
|
if (count($records) === 0) {
|
|
continue;
|
|
}
|
|
try {
|
|
$this->jobList->add($jobClass, ['records' => $records]);
|
|
$offset += $batchSize;
|
|
} catch (\InvalidArgumentException $e) {
|
|
if (str_contains($e->getMessage(), 'Background job arguments can\'t exceed 4000')) {
|
|
$batchSize = (int)floor(count($records) * 0.8);
|
|
$retry = true;
|
|
}
|
|
}
|
|
} while (count($records) === $batchSize || $retry);
|
|
}
|
|
}
|
|
}
|