XapiProxy.php

Go to the documentation of this file.

<?php
    namespace XapiProxy;
 
    require_once __DIR__ . '/XapiProxyPolyFill.php';
 
    class XapiProxy extends XapiProxyPolyFill
    {
        private $xapiProxyRequest;
        private $xapiProxyResponse;
 
        public function __construct($client, $token, $plugin = false)
        {
            parent::__construct($client, $token, $plugin);
            $this->log()->debug($this->msg('proxy initialized'));
        }
 
        public function setRequestParams($request)
        {
            preg_match(self::PARTS_REG, $request->getUri(), $this->cmdParts);
        }
 
        public function token()
        {
            return $this->token;
        }
 
        public function client()
        {
            return $this->client;
        }
 
        public function lrsType()
        {
            return $this->lrsType;
        }
 
        public function replacedValues()
        {
            return $this->replacedValues;
        }
 
        public function specificAllowedStatements()
        {
            return $this->specificAllowedStatements;
        }
 
        public function blockSubStatements()
        {
            return $this->blockSubStatements;
        }
 
        public function cmdParts()
        {
            return $this->cmdParts;
        }
 
        public function method()
        {
            return $this->method;
        }
 
        public function getDefaultLrsEndpoint()
        {
            return $this->defaultLrsEndpoint;
        }
 
        public function getDefaultLrsKey()
        {
            return $this->defaultLrsKey;
        }
 
        public function getDefaultLrsSecret()
        {
            return $this->defaultLrsSecret;
        }
 
        public function getFallbackLrsEndpoint()
        {
            return $this->fallbackLrsEndpoint;
        }
 
        public function getFallbackLrsKey()
        {
            return $this->fallbackLrsKey;
        }
 
        public function getFallbackLrsSecret()
        {
            return $this->fallbackLrsSecret;
        }
 
        public function setXapiProxyRequest($xapiProxyRequest)
        {
            $this->xapiProxyRequest = $xapiProxyRequest;
        }
 
        public function getXapiProxyRequest()
        {
            return $this->xapiProxyRequest;
        }
 
        public function setXapiProxyResponse($xapiProxyResponse)
        {
            $this->xapiProxyResponse = $xapiProxyResponse;
        }
 
        public function getXapiProxyResponse()
        {
            return $this->xapiProxyResponse;
        }
 
        public function processStatements($request, $body)
        {
            // everything is allowed
            if (!is_array($this->specificAllowedStatements) && !$this->blockSubStatements) {
                $this->log()->debug($this->msg("all statement are allowed"));
                return null;
            }
            $obj = json_decode($body, false);
            // single statement object
            if (is_object($obj) && isset($obj->verb)) {
                $this->log()->debug($this->msg("json is object and statement"));
                $isSubStatement = $this->isSubStatementCheck($obj);
                $verb = $obj->verb->id;
                if ($this->blockSubStatements && $isSubStatement) {
                    $this->log()->debug($this->msg("sub-statement is NOT allowed, fake response - " . $verb));
                    $this->xapiProxyResponse->fakeResponseBlocked(null);
                }
                // $specificAllowedStatements
                if (!is_array($this->specificAllowedStatements)) {
                    return null;
                }
                if (in_array($verb, $this->specificAllowedStatements)) {
                    $this->log()->debug($this->msg("statement is allowed, do nothing - " . $verb));
                    return null;
                } else {
                    $this->log()->debug($this->msg("statement is NOT allowed, fake response - " . $verb));
                    $this->xapiProxyResponse->fakeResponseBlocked(null);
                }
            }
            // array of statement objects
            if (is_array($obj) && count($obj) > 0 && isset($obj[0]->verb)) {
                $this->log()->debug($this->msg("json is array of statements"));
                $ret = array();
                $up = array();
                for ($i = 0; $i < count($obj); $i++) {
                    array_push($ret, $obj[$i]->id); // push every statementid for fakePostResponse
                    $isSubStatement = $this->isSubStatementCheck($obj[$i]);
                    $verb = $obj[$i]->verb->id;
                    if ($this->blockSubStatements && $isSubStatement) {
                        $this->log()->debug($this->msg("sub-statement is NOT allowed - " . $verb));
                    } else {
                        if (!is_array($this->specificAllowedStatements) || (is_array($this->specificAllowedStatements) && in_array($verb, $this->specificAllowedStatements))) {
                            $this->log()->debug($this->msg("statement is allowed - " . $verb));
                            array_push($up, $obj[$i]);
                        }
                    }
                }
                if (count($up) === 0) { // nothing allowed
                    $this->log()->debug($this->msg("no allowed statements in array - fake response..."));
                    $this->xapiProxyResponse->fakeResponseBlocked($ret);
                } elseif (count($up) !== count($ret)) { // mixed request with allowed and not allowed statements
                    $this->log()->debug($this->msg("mixed with allowed and unallowed statements"));
                    return array($up,$ret);
                } else {
                    // just return nothing
                    return null;
                }
            }
            return null;
        }
 
        public function modifyBody($body)
        {
            $obj = json_decode($body, false);
 
            if (json_last_error() != JSON_ERROR_NONE) {
                // JSON is not valid
                $this->log()->error($this->msg(json_last_error_msg()));
                return $body;
            }
 
            // $log->debug(json_encode($obj, JSON_PRETTY_PRINT)); // only in DEBUG mode for better performance
            if (is_object($obj)) {
                if (is_array($this->replacedValues)) {
                    foreach ($this->replacedValues as $key => $value) {
                        $this->setValue($obj, $key, $value);
                    }
                }
                $this->handleStatementEvaluation($obj); // ToDo
            }
 
            if (is_array($obj)) {
                for ($i = 0; $i < count($obj); $i++) {
                    if (is_array($this->replacedValues)) {
                        foreach ($this->replacedValues as $key => $value) {
                            $this->setValue($obj[$i], $key, $value);
                        }
                    }
                    $this->handleStatementEvaluation($obj[$i]); // ToDo
                }
            }
            return json_encode($obj);
        }
        
        private function handleStatementEvaluation($xapiStatement)
        {
            global $DIC;
            if ($this->plugin) {
                require_once __DIR__ . '/../class.ilObjXapiCmi5.php';
                // ToDo: handle terminate -> delete session
                $this->setStatus($xapiStatement);
            } else {
                /* @var $object */
                $object = \ilObjectFactory::getInstanceByObjId($this->authToken->getObjId());
                if ((string) $object->getLaunchMode() === (string) \ilObjCmiXapi::LAUNCH_MODE_NORMAL) {
                    // ToDo: check function hasContextActivitiesParentNotEqualToObject!
                    $statementEvaluation = new \ilXapiStatementEvaluation($this->log(), $object);
                    $statementEvaluation->evaluateStatement($xapiStatement, $this->authToken->getUsrId());
 
                    if ($this->authToken->getUsrId() != ANONYMOUS_USER_ID) {
                        \ilLPStatusWrapper::_updateStatus(
                            $this->authToken->getObjId(),
                            $this->authToken->getUsrId()
                        );
                    }
                }
                if ($xapiStatement->verb->id == self::TERMINATED_VERB) {
                    // ToDo : only cmi5 or also xapi? authToken object still used after that?
                    $this->authToken->delete();
                }
            }
        }
 
        private function setValue(&$obj, $path, $value)
        {
            $path_components = explode('.', $path);
            if (count($path_components) == 1) {
                if (property_exists($obj, $path_components[0])) {
                    $obj->{$path_components[0]} = $value;
                }
            } else {
                if (property_exists($obj, $path_components[0])) {
                    $this->setValue($obj->{array_shift($path_components)}, implode('.', $path_components), $value);
                }
            }
        }
 
        private function setStatus($obj)
        {
            if (isset($obj->verb) && isset($obj->actor) && isset($obj->object)) {
                $verb = $obj->verb->id;
                $score = 'NOT_SET';
                if (array_key_exists($verb, $this->sniffVerbs)) {
                    // check context
                    if ($this->isSubStatementCheck($obj)) {
                        $this->log()->debug($this->msg("statement is sub-statement, ignore status verb " . $verb));
                        return;
                    }
                    if (isset($obj->result) && isset($obj->result->score) && isset($obj->result->score->scaled)) {
                        $score = $obj->result->score->scaled;
                    }
                    $this->log()->debug($this->msg("handleLPStatus: " . $this->sniffVerbs[$verb] . " : " . $score));
                    \ilObjXapiCmi5::handleLPStatusFromProxy($this->client, $this->token, $this->sniffVerbs[$verb], $score);//UK check
                }
            }
        }
    
        private function isSubStatementCheck($obj)
        {
            $object = \ilObjectFactory::getInstanceByObjId($this->authToken->getObjId()); // get ActivityId in Constructor for better performance, is also used in handleEvaluationStatement
            $objActivityId = $object->getActivityId();
            $statementActivityId = $obj->object->id;
            if ($statementActivityId != $objActivityId) {
                $this->log()->debug($this->msg("statement object id " . $statementActivityId . " != activityId " . $objActivityId));
                $this->log()->debug($this->msg("is Substatement"));
                return true;
            } else {
                $this->log()->debug($this->msg("is not Substatement"));
                return false;
            }
        }
    }