class-wpml-tp-sync-jobs-revision.php
1.58 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
<?php
class WPML_TM_Sync_Jobs_Revision {
/** @var WPML_TM_Jobs_Repository */
private $jobs_repository;
/** @var WPML_TP_Jobs_API */
private $tp_api;
/**
* WPML_TM_Sync_Jobs_Revision constructor.
*
* @param WPML_TM_Jobs_Repository $jobs_repository
* @param WPML_TP_Jobs_API $tp_api
*/
public function __construct( WPML_TM_Jobs_Repository $jobs_repository, WPML_TP_Jobs_API $tp_api ) {
$this->jobs_repository = $jobs_repository;
$this->tp_api = $tp_api;
}
/**
* @return WPML_TM_Job_Entity[]
* @throws WPML_TP_API_Exception
*/
public function sync() {
$result = array();
$tp_statuses_of_revised_jobs = $this->tp_api->get_revised_jobs();
if ( $tp_statuses_of_revised_jobs ) {
$revised_jobs = array();
foreach ( $tp_statuses_of_revised_jobs as $tp_job_status ) {
$revised_jobs[ $tp_job_status->get_tp_id() ] = $tp_job_status->get_revision();
}
$job_search = new WPML_TM_Jobs_Search_Params(
array(
'scope' => WPML_TM_Jobs_Search_Params::SCOPE_REMOTE,
'tp_id' => array_keys( $revised_jobs ),
)
);
/** @var WPML_TM_Job_Entity $job */
foreach ( $this->jobs_repository->get( $job_search ) as $job ) {
if ( isset( $revised_jobs[ $job->get_tp_id() ] ) && $job->get_revision() < $revised_jobs[ $job->get_tp_id() ] ) {
$job->set_status( WPML_TP_Job_States::map_tp_state_to_local( WPML_TP_Job_States::TRANSLATION_READY ) );
$job->set_revision( $revised_jobs[ $job->get_tp_id() ] );
$result[] = $job;
do_action( 'wpml_tm_revised_job_notification', $job->get_id() );
}
}
}
return $result;
}
}