cerebrate/libraries/default/RequestProcessors/BroodRequestProcessor.php

<?php
use Cake\ORM\TableRegistry;

require_once(ROOT . DS . 'libraries' . DS . 'default' . DS . 'RequestProcessors' . DS . 'GenericRequestProcessor.php'); 

class BroodRequestProcessor extends GenericRequestProcessor
{
    protected $scope = 'Brood';
    protected $action = 'not-specified'; //overriden when extending
    protected $description = ''; // overriden when extending
    protected $registeredActions = [
        'ToolInterconnection',
        'OneWaySynchronization',
    ];

    public function __construct($loadFromAction=false) {
        parent::__construct($loadFromAction);
    }

    public function create($requestData)
    {
        return parent::create($requestData);
    }
}

class ToolInterconnectionProcessor extends BroodRequestProcessor implements GenericProcessorActionI {
    public $action = 'ToolInterconnection';
    protected $description;

    public function __construct() {
        parent::__construct();
        $this->description = __('Handle tool interconnection request from other cerebrate instance');
        $this->Broods = TableRegistry::getTableLocator()->get('Broods');
    }

    protected function addValidatorRules($validator)
    {
        return $validator;
    }
    
    public function create($requestData) {
        $this->validateRequestData($requestData);
        $requestData['title'] = __('Cerebrate instance {0} requested interconnection for tool {1}', 'Insert brood name', 'Insert tool name');
        return parent::create($requestData);
    }

    public function process($id, $requestData)
    {
        $connectionSuccessfull = false;
        $interConnectionResult = [];
        if ($connectionSuccessfull) {
            $this->discard($id, $requestData);
        }
        return $this->genActionResult(
            $interConnectionResult,
            $connectionSuccessfull,
            $connectionSuccessfull ? __('Interconnection for `{0}` created', 'Insert tool name') : __('Could interconnect tool `{0}`.', 'Insert tool name'),
            []
        );
    }

    public function discard($id, $requestData)
    {
        return parent::discard($id, $requestData);
    }
}

class OneWaySynchronizationProcessor extends BroodRequestProcessor implements GenericProcessorActionI {
    public $action = 'OneWaySynchronization';
    protected $description;

    public function __construct() {
        parent::__construct();
        $this->description = __('Handle cerebrate connection request for another cerebrate instance');
        $this->Broods = TableRegistry::getTableLocator()->get('Broods');
    }

    protected function addValidatorRules($validator)
    {
        return $validator;
    }
    
    public function create($requestData) {
        $this->validateRequestData($requestData);
        $requestData['title'] = __('Cerebrate instance {0} requested interconnection', 'Insert cerebrate name');
        return parent::create($requestData);
    }

    public function process($id, $requestData)
    {
        $connectionSuccessfull = false;
        $interConnectionResult = [];
        if ($connectionSuccessfull) {
            $this->discard($id, $requestData);
        }
        return $this->genActionResult(
            $interConnectionResult,
            $connectionSuccessfull,
            $connectionSuccessfull ? __('Interconnection with `{0}` created', 'Insert cerebrate name') : __('Could interconnect with `{0}`.', 'Insert cerebrate name'),
            []
        );
    }

    public function discard($id, $requestData)
    {
        return parent::discard($id, $requestData);
    }
}