2021-03-18 15:17:39 +01:00
|
|
|
<?php
|
|
|
|
use Cake\ORM\TableRegistry;
|
|
|
|
|
2021-06-18 11:09:19 +02:00
|
|
|
require_once(ROOT . DS . 'libraries' . DS . 'default' . DS . 'InboxProcessors' . DS . 'GenericInboxProcessor.php');
|
2021-03-18 15:17:39 +01:00
|
|
|
|
2021-06-18 11:09:19 +02:00
|
|
|
class SynchronisationInboxProcessor extends GenericInboxProcessor
|
2021-03-18 15:17:39 +01:00
|
|
|
{
|
|
|
|
protected $scope = 'Synchronisation';
|
|
|
|
protected $action = 'not-specified'; //overriden when extending
|
|
|
|
protected $description = ''; // overriden when extending
|
|
|
|
protected $registeredActions = [
|
|
|
|
'DataExchange'
|
|
|
|
];
|
|
|
|
|
|
|
|
public function __construct($loadFromAction=false) {
|
|
|
|
parent::__construct($loadFromAction);
|
|
|
|
}
|
|
|
|
|
|
|
|
public function create($requestData)
|
|
|
|
{
|
|
|
|
return parent::create($requestData);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2021-06-21 14:30:32 +02:00
|
|
|
class DataExchangeProcessor extends SynchronisationInboxProcessor implements GenericInboxProcessorActionI {
|
2021-03-18 15:17:39 +01:00
|
|
|
public $action = 'DataExchange';
|
|
|
|
protected $description;
|
|
|
|
|
|
|
|
public function __construct() {
|
|
|
|
parent::__construct();
|
2022-11-15 11:14:25 +01:00
|
|
|
$this->severity = $this->Inbox::SEVERITY_WARNING;
|
2021-03-18 15:17:39 +01:00
|
|
|
$this->description = __('Handle exchange of data between two cerebrate instances');
|
|
|
|
$this->Users = TableRegistry::getTableLocator()->get('Users');
|
|
|
|
}
|
|
|
|
|
|
|
|
protected function addValidatorRules($validator)
|
|
|
|
{
|
|
|
|
return $validator;
|
|
|
|
}
|
|
|
|
|
|
|
|
public function create($requestData) {
|
|
|
|
$this->validateRequestData($requestData);
|
|
|
|
$requestData['title'] = __('Data exchange requested for record `{0}`', 'recordname');
|
|
|
|
return parent::create($requestData);
|
|
|
|
}
|
|
|
|
|
2021-06-14 13:25:49 +02:00
|
|
|
public function process($id, $requestData, $inboxRequest)
|
2021-03-18 15:17:39 +01:00
|
|
|
{
|
|
|
|
$dataExchangeAccepted = false;
|
|
|
|
$saveResult = [];
|
|
|
|
if ($dataExchangeAccepted) {
|
|
|
|
$this->discard($id, $requestData);
|
|
|
|
}
|
|
|
|
return $this->genActionResult(
|
|
|
|
$saveResult,
|
|
|
|
$dataExchangeAccepted,
|
|
|
|
$dataExchangeAccepted ? __('Record `{0}` exchanged', 'recordname') : __('Could not exchange record `{0}`.', 'recordname'),
|
|
|
|
[]
|
|
|
|
);
|
|
|
|
}
|
|
|
|
|
|
|
|
public function discard($id, $requestData)
|
|
|
|
{
|
|
|
|
return parent::discard($id, $requestData);
|
|
|
|
}
|
|
|
|
}
|