Base.php

Go to the documentation of this file.

<?php

namespace ILIAS\OrgUnit\Webservices\SOAP;

use ilOrgUnitSOAPServicesPlugin;
use ilSoapAdministration;
use ilSoapMethod;
use ilSoapPluginException;

abstract class Base extends ilSoapAdministration implements ilSoapMethod
{
    public const TYPE_INT_ARRAY = 'tns:intArray';
    public const TYPE_STRING = 'xsd:string';
    public const TYPE_INT = 'xsd:int';
    public const TYPE_DOUBLE_ARRAY = 'tns:doubleArray';
    public const SID = 'sid';
    public const ORGU_REF_ID = 'orgu_ref_id';
    public const POSITION_ID = 'position_id';
    public const USR_IDS = 'usr_ids';
    public const USR_ID = 'usr_id';
    protected \ilOrgUnitPositionDBRepository $positionRepo;
    protected \ilOrgUnitUserAssignmentDBRepository $assignmentRepo;

    public function getServiceStyle(): string
    {
        return 'rpc';
    }

    public function getServiceUse(): string
    {
        return 'encoded';
    }

    protected function initIliasAndCheckSession(string $session_id): void
    {
        $this->initAuth($session_id);
        $this->initIlias();
        if (!$this->checkSession($session_id)) {
            throw new ilSoapPluginException($this->getMessage());
        }
    }

    protected function checkParameters(array $params): void
    {
        for ($i = 0, $iMax = count($this->getInputParams()); $i < $iMax; $i++) {
            if (!isset($params[$i])) {
                $names = implode(', ', array_keys($this->getInputParams()));
                throw new ilSoapPluginException("Request is missing at least one of the following parameters: $names");
            }
        }
    }

    public function getServiceNamespace(): string
    {
        return 'urn:' . ilOrgUnitSOAPServicesPlugin::PLUGIN_NAME;
    }

    abstract protected function getAdditionalInputParams(): array;

    public function getInputParams(): array
    {
        return array_merge(
            array(
                self::SID => self::TYPE_STRING,
            ),
            $this->getAdditionalInputParams()
        );
    }

    abstract protected function run(array $params);

    public function execute(array $params)
    {
        $this->checkParameters($params);
        $session_id = (isset($params[0])) ? $params[0] : '';
        $this->init($session_id);

        // Check Permissions
        global $DIC;
        if (!$DIC->access()->checkAccess('write', '', \ilObjOrgUnit::getRootOrgRefId())) {
            $this->addError('Permission denied');
        }

        $clean_params = array();
        $i = 1;
        foreach ($this->getAdditionalInputParams() as $key => $type) {
            $clean_params[$key] = $params[$i];
            $i++;
        }

        return $this->run($clean_params);
    }

    public function addError(string $message)
    {
        throw $this->raiseError($message, 'ERROR');
    }

    private function init(string $session_id): void
    {
        $this->initIliasAndCheckSession($session_id); // Throws exception if session is not valid

        if (!isset($_GET["wsdl"])) {
            $dic = \ilOrgUnitLocalDIC::dic();
            $this->positionRepo = $dic["repo.Positions"];
            $this->assignmentRepo = $dic["repo.UserAssignments"];
        }
    }
}