Command.php
1.74 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
<?php
namespace WPML\TM\Upgrade\Commands\SynchronizeSourceIdOfATEJobs;
use WPML\Utils\Pager;
use WPML\TM\Upgrade\Commands\MigrateAteRepository;
use WPML\Collect\Support\Collection;
use WPML\Upgrade\CommandsStatus;
use function WPML\Container\make;
class Command implements \IWPML_Upgrade_Command {
const CHUNK_SIZE = 1000;
/** @var Repository */
private $repository;
/** @var \WPML_TM_ATE_API */
private $api;
/** @var Pager */
private $pager;
/** @var CommandsStatus */
private $commandStatus;
/** @var bool $result */
private $result = false;
/**
* Command constructor.
*
* @param Repository $repository
* @param \WPML_TM_ATE_API $api
* @param Pager $pager
* @param CommandsStatus $commandStatus
*/
public function __construct(
Repository $repository,
\WPML_TM_ATE_API $api,
Pager $pager,
CommandsStatus $commandStatus
) {
$this->repository = $repository;
$this->api = $api;
$this->pager = $pager;
$this->commandStatus = $commandStatus;
}
public function run_admin() {
if ( ! $this->hasBeenMigrateATERepositoryUpgradeRun() ) {
return false;
}
$chunks = $this->repository->getPairs()->chunk( self::CHUNK_SIZE );
$this->result = $this->pager->iterate(
$chunks,
function ( Collection $pairs ) {
return $this->api->migrate_source_id( $pairs->toArray() );
}
) === 0;
return $this->result;
}
public function run_ajax() {
return null;
}
public function run_frontend() {
return null;
}
/**
* @return bool
*/
public function get_results() {
return $this->result;
}
/**
* @return mixed
*/
private function hasBeenMigrateATERepositoryUpgradeRun() {
return $this->commandStatus->hasBeenExecuted( MigrateAteRepository::class );
}
}