Class ilCmiXapiStatementsDeleteRequest. More...

Collaboration diagram for ilCmiXapiStatementsDeleteRequest:

Public Member Functions
	__construct (int $obj_id, int $type_id, string $activity_id, ?int $usr_id=null, ?string $scope=self::DELETE_SCOPE_FILTERED, ?ilCmiXapiStatementsReportFilter $filter=null)

	deleteData ()

	_lookUpDataCount ($scope=null)

	queryBatch (array $batchId)

Data Fields
const	DELETE_SCOPE_FILTERED = "filtered"

const	DELETE_SCOPE_ALL = "all"

const	DELETE_SCOPE_OWN = "own"

Protected Attributes
string	$scope

ilCmiXapiStatementsReportFilter	$filter

int	$objId

ilCmiXapiLrsType	$lrsType

string	$endpointDefault = ''

string	$endpointFallback = ''

array	$headers

array	$defaultHeaders

ilLogger	$log

Private Member Functions
	getBatchUrl (string $url, string $batchId)

	getDeleteStateUrls ($url)

	buildDeleteAll ()

	buildDeleteFiltered ()

	buildDeleteOwn ()

	buildDeleteStates ()

	checkDeleteState ()

	checkDeleteUsersForObject ()

	sendCurlRequest (string $method, string $url, array $headers=[], ?string $body=null)

	executeMultiCurl (array $requests)

Private Attributes
int	$usrId

string	$activityId

Detailed Description

Class ilCmiXapiStatementsDeleteRequest.

Author: Uwe Kohnle kohnl.nosp@m.e@in.nosp@m.terne.nosp@m.tleh.nosp@m.rer-g.nosp@m.mbh..nosp@m.de; Stefan Schneider

Definition at line 28 of file class.ilCmiXapiStatementsDeleteRequest.php.

Constructor & Destructor Documentation

◆ __construct()

ilCmiXapiStatementsDeleteRequest::__construct	(	int	$obj_id,
		int	$type_id,
		string	$activity_id,
		?int	$usr_id = `null`,
		?string	$scope = `self::DELETE_SCOPE_FILTERED`,
		?ilCmiXapiStatementsReportFilter	$filter = `null`
	)

Definition at line 56 of file class.ilCmiXapiStatementsDeleteRequest.php.

      {
        $this->objId = $obj_id;
        $this->lrsType = new ilCmiXapiLrsType($type_id);
        $this->activityId = $activity_id;
        $this->usrId = $usr_id;
        $this->scope = $scope;
        $this->filter = $filter;
 
        $this->endpointDefault = $this->lrsType->getLrsEndpoint();
        $this->headers = [
            'X-Experience-API-Version' => '1.0.3'
        ];
        $this->defaultHeaders = $this->headers;
        $this->defaultHeaders['Authorization'] = $this->lrsType->getBasicAuth();
 
        $this->log = ilLoggerFactory::getLogger('cmix');
    }

References $filter, $headers, $scope, ILIAS\Repository\filter(), and ilLoggerFactory\getLogger().

Here is the call graph for this function:

Member Function Documentation

◆ _lookUpDataCount()

ilCmiXapiStatementsDeleteRequest::_lookUpDataCount ( $scope = null )

Definition at line 180 of file class.ilCmiXapiStatementsDeleteRequest.php.

    {
        global $DIC;
        $pipeline = array();
        if (is_null($scope)) {
            $scope = $this->scope;
        }
        if ($scope === self::DELETE_SCOPE_OWN) {
            $f = $this->buildDeleteOwn();
            if (count($f) == 0) {
                return 0;
            }
        }
        if ($scope === self::DELETE_SCOPE_FILTERED) {
            $f = $this->buildDeleteFiltered();
        }
        if ($scope === self::DELETE_SCOPE_ALL) {
            $f = $this->buildDeleteAll();
        }
        $pipeline[] = array('$match' => $f);
        $pipeline[] = array('$count' => 'count');
        $pquery = urlencode(json_encode($pipeline));
        $query = "pipeline={$pquery}";
        $purl = $this->lrsType->getLrsEndpointStatementsAggregationLink();
        $url = ilUtil::appendUrlParameterString($purl, $query);
        try {
            $response = $this->sendCurlRequest('GET', $url, $this->defaultHeaders);
            if ($response['status'] === 200) {
                $cnt = json_decode($response['body'], true);
            }
            return (int) $cnt[0]->count;
        } catch (Exception $e) {
            throw new Exception("LRS Connection Problems");
            return 0;
        }
    }

References $DIC, Vendor\Package\$e, Vendor\Package\$f, $response, $scope, $url, ilUtil\appendUrlParameterString(), buildDeleteAll(), buildDeleteFiltered(), buildDeleteOwn(), and sendCurlRequest().

Here is the call graph for this function:

◆ buildDeleteAll()

ilCmiXapiStatementsDeleteRequest::buildDeleteAll ( )

private

Definition at line 288 of file class.ilCmiXapiStatementsDeleteRequest.php.

                                     : array
    {
        global $DIC;
        $f = array();
 
        $f['statement.object.objectType'] = 'Activity';
        $f['statement.object.id'] = [
            '$regex' => '^' . preg_quote($this->activityId) . ''
        ];
 
        $f['statement.actor.objectType'] = 'Agent';
 
        $f['$or'] = [];
        // foreach (ilXapiCmi5User::getUsersForObjectPlugin($this->getObjId()) as $usr_id) {
        // $f['$or'][] = ['statement.actor.mbox' => "mailto:".ilXapiCmi5User::getUsrIdentPlugin($usr_id,$this->getObjId())];
        foreach (ilCmiXapiUser::getUsersForObject($this->objId) as $cmixUser) {
            $f['$or'][] = ['statement.actor.mbox' => "mailto:{$cmixUser->getUsrIdent()}"];
        }
        if (count($f['$or']) == 0) {
            // Exception Handling!
            return [];
        } else {
            return $f;
        }
    }

References $DIC, Vendor\Package\$f, and ilCmiXapiUser\getUsersForObject().

Referenced by _lookUpDataCount(), and deleteData().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ buildDeleteFiltered()

ilCmiXapiStatementsDeleteRequest::buildDeleteFiltered ( )

private

Definition at line 314 of file class.ilCmiXapiStatementsDeleteRequest.php.

                                          : array
    {
        global $DIC;
        $f = array();
 
        $f['statement.object.objectType'] = 'Activity';
        $f['statement.object.id'] = [
            '$regex' => '^' . preg_quote($this->activityId) . ''
        ];
 
        $f['statement.actor.objectType'] = 'Agent';
        $f['$or'] = [];
        if ($this->filter->getActor()) {
            foreach (ilCmiXapiUser::getUsersForObject($this->objId) as $cmixUser) {
                if ($cmixUser->getUsrId() == $this->filter->getActor()->getUsrId()) {
                    $f['$or'][] = ['statement.actor.mbox' => "mailto:{$cmixUser->getUsrIdent()}"];
                }
            }
        } else { // check hasOutcomes Access?
            foreach (ilCmiXapiUser::getUsersForObject($this->objId) as $cmixUser) {
                $f['$or'][] = ['statement.actor.mbox' => "mailto:{$cmixUser->getUsrIdent()}"];
            }
        }
 
        if ($this->filter->getVerb()) {
            $f['statement.verb.id'] = $this->filter->getVerb();
        }
 
        if ($this->filter->getStartDate() || $this->filter->getEndDate()) {
            $f['statement.timestamp'] = array();
 
            if ($this->filter->getStartDate()) {
                $f['statement.timestamp']['$gt'] = $this->filter->getStartDate()->toXapiTimestamp();
            }
 
            if ($this->filter->getEndDate()) {
                $f['statement.timestamp']['$lt'] = $this->filter->getEndDate()->toXapiTimestamp();
            }
        }
 
        if (count($f['$or']) == 0) {
            // Exception Handling!
            return [];
        } else {
            return $f;
        }
    }

References $DIC, Vendor\Package\$f, ILIAS\Repository\filter(), and ilCmiXapiUser\getUsersForObject().

Referenced by _lookUpDataCount(), and deleteData().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ buildDeleteOwn()

ilCmiXapiStatementsDeleteRequest::buildDeleteOwn ( )

private

Definition at line 362 of file class.ilCmiXapiStatementsDeleteRequest.php.

                                     : array
    {
        global $DIC;
        $f = array();
        $f['statement.object.objectType'] = 'Activity';
        $f['statement.object.id'] = [
            '$regex' => '^' . preg_quote($this->activityId) . ''
        ];
        $f['statement.actor.objectType'] = 'Agent';
 
        $usrId = ($this->usrId !== null) ? $this->usrId : $DIC->user()->getId();
        $cmixUsers = ilCmiXapiUser::getInstancesByObjectIdAndUsrId($this->objId, $usrId);
        $f['$or'] = [];
        foreach ($cmixUsers as $cmixUser) {
            $f['$or'][] = ['statement.actor.mbox' => "mailto:{$cmixUser->getUsrIdent()}"];
        }
        if (count($f['$or']) == 0) {
            return [];
        } else {
            return $f;
        }
    }

References $DIC, Vendor\Package\$f, $usrId, and ilCmiXapiUser\getInstancesByObjectIdAndUsrId().

Referenced by _lookUpDataCount(), and deleteData().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ buildDeleteStates()

ilCmiXapiStatementsDeleteRequest::buildDeleteStates ( )

private

Definition at line 385 of file class.ilCmiXapiStatementsDeleteRequest.php.

                                        : array
    {
        global $DIC;
        $ret = array();
        $user = "";
        if ($this->scope === self::DELETE_SCOPE_FILTERED && $this->filter->getActor()) {
            foreach (ilCmiXapiUser::getUsersForObject($this->objId) as $cmixUser) {
                if ($cmixUser->getUsrId() == $this->filter->getActor()->getUsrId()) {
                    $user = $cmixUser->getUsrIdent();
                    $ret[] = 'activityId=' . urlencode($this->activityId) . '&agent=' . urlencode('{"mbox":"mailto:' . $user . '"}');
                }
            }
        }
 
        if ($this->scope === self::DELETE_SCOPE_OWN) {
            $usrId = ($this->usrId !== null) ? $this->usrId : $DIC->user()->getId();
            foreach (ilCmiXapiUser::getUsersForObject($this->objId) as $cmixUser) {
                if ((int) $cmixUser->getUsrId() === $usrId) {
                    $user = $cmixUser->getUsrIdent();
                    $ret[] = 'activityId=' . urlencode($this->activityId) . '&agent=' . urlencode('{"mbox":"mailto:' . $user . '"}');
                }
            }
        }
 
        if ($this->scope === self::DELETE_SCOPE_ALL) {
            //todo check cmix_del_object
            foreach (ilCmiXapiUser::getUsersForObject($this->objId) as $cmixUser) {
                $user = $cmixUser->getUsrIdent();
                $ret[] = 'activityId=' . urlencode($this->activityId) . '&agent=' . urlencode('{"mbox":"mailto:' . $user . '"}');
            }
        }
        return $ret;
    }

References $DIC, $usrId, ILIAS\Repository\filter(), and ilCmiXapiUser\getUsersForObject().

Referenced by getDeleteStateUrls().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ checkDeleteState()

ilCmiXapiStatementsDeleteRequest::checkDeleteState ( )

private

Definition at line 419 of file class.ilCmiXapiStatementsDeleteRequest.php.

                                       : bool
    {
        global $DIC;
        if ($this->scope === self::DELETE_SCOPE_ALL || $this->scope === self::DELETE_SCOPE_OWN) {
            return true;
        }
        if ($this->filter->getActor()) { // ToDo: only in Multicactor Mode?
            if ($this->filter->getVerb() || $this->filter->getStartDate() || $this->filter->getEndDate()) {
                return false;
            } else {
                return true;
            }
        }
        return false;
    }

References $DIC, and ILIAS\Repository\filter().

Referenced by checkDeleteUsersForObject(), and deleteData().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ checkDeleteUsersForObject()

ilCmiXapiStatementsDeleteRequest::checkDeleteUsersForObject ( )

private

Definition at line 435 of file class.ilCmiXapiStatementsDeleteRequest.php.

    {
        global $DIC;
        if ($this->scope === self::DELETE_SCOPE_ALL) {
            ilCmiXapiUser::deleteUsersForObject($this->objId);
            //            $model = ilCmiXapiDelModel::init();
            //            $model->deleteXapiObjectEntry($this->objId);
        }
        if ($this->scope === self::DELETE_SCOPE_OWN) {
            $usrId = ($this->usrId !== null) ? [$this->usrId] : [$DIC->user()->getId()];
            ilCmiXapiUser::deleteUsersForObject($this->objId, $usrId);
        }
        if ($this->scope === self::DELETE_SCOPE_FILTERED) {
            if ($this->checkDeleteState() && $this->filter) {
                $usrId = [$this->filter->getActor()->getUsrId()];
                ilCmiXapiUser::deleteUsersForObject($this->objId, $usrId);
            }
        }
    }

References $DIC, $usrId, checkDeleteState(), ilCmiXapiUser\deleteUsersForObject(), and ILIAS\Repository\filter().

Here is the call graph for this function:

◆ deleteData()

ilCmiXapiStatementsDeleteRequest::deleteData ( )

Definition at line 130 of file class.ilCmiXapiStatementsDeleteRequest.php.

                                : array
    {
        global $DIC;
 
        $deleteState = true;
 
        $f = null;
        if ($this->scope === self::DELETE_SCOPE_FILTERED) {
            $deleteState = $this->checkDeleteState();
            $f = $this->buildDeleteFiltered();
        }
        if ($this->scope === self::DELETE_SCOPE_ALL) {
            $f = $this->buildDeleteAll();
        }
        if ($this->scope === self::DELETE_SCOPE_OWN) {
            $f = $this->buildDeleteOwn();
        }
        if ($f === false) {
            $this->log->debug('error: could not build filter');
            return array();
        }
        $cf = array('filter' => $f);
        $body = json_encode($cf);
        $this->defaultHeaders['Content-Type'] = 'application/json; charset=utf-8';
        $defaultUrl = $this->lrsType->getLrsEndpointDeleteLink();
        $promisesStatements = [
            'default' => $this->sendCurlRequest('POST', $defaultUrl, $this->defaultHeaders, $body),
        ];
        $promisesStates = array();
        if ($deleteState) {
            $urls = $this->getDeleteStateUrls($this->lrsType->getLrsEndpointStateLink());
            foreach ($urls as $i => $v) {
                $promisesStates['default' . $i] = $this->sendCurlRequest('DELETE', $v, $this->defaultHeaders, $body);
            }
        }
        $response = array();
        $response['statements'] = array();
        $response['states'] = array();
 
        try { // maybe everything into one promise?
            $response['statements'] = $this->executeMultiCurl($promisesStatements);
            if ($deleteState && count($promisesStates) > 0) {
                $response['states'] = $this->executeMultiCurl($promisesStates);
            }
        } catch (Exception $e) {
            $this->log->debug('error:' . $e->getMessage());
        }
        return $response;
    }

References $DIC, Vendor\Package\$e, Vendor\Package\$f, $response, buildDeleteAll(), buildDeleteFiltered(), buildDeleteOwn(), checkDeleteState(), executeMultiCurl(), getDeleteStateUrls(), and sendCurlRequest().

Here is the call graph for this function:

◆ executeMultiCurl()

ilCmiXapiStatementsDeleteRequest::executeMultiCurl ( array $requests )

private

Definition at line 488 of file class.ilCmiXapiStatementsDeleteRequest.php.

                                                      : array
    {
        $mh = curl_multi_init();
        $handles = [];
 
        // cURL Handles vorbereiten
        foreach ($requests as $key => $req) {
            if (!is_array($req)) {
                // Falls $req direkt URL + Method enthält (z. B. ['method' => 'DELETE', 'url' => '...'])
                $method = $req['method'] ?? 'GET';
                $url = $req['url'] ?? '';
                $headers = $req['headers'] ?? $this->defaultHeaders;
                $body = $req['body'] ?? null;
            } else {
                // wenn wir direkt die Parameter übergeben
                $method = $req['method'] ?? 'GET';
                $url = $req['url'] ?? '';
                $headers = $req['headers'] ?? $this->defaultHeaders;
                $body = $req['body'] ?? null;
            }
 
            $ch = curl_init($url);
            $formattedHeaders = [];
            foreach ($headers as $k => $v) {
                $formattedHeaders[] = "$k: $v";
            }
 
            curl_setopt_array($ch, [
                CURLOPT_RETURNTRANSFER => true,
                CURLOPT_CUSTOMREQUEST => $method,
                CURLOPT_HTTPHEADER => $formattedHeaders,
                CURLOPT_CONNECTTIMEOUT => 10,
                CURLOPT_TIMEOUT => 60,
                CURLOPT_SSL_VERIFYPEER => true
            ]);
 
            if ($body !== null && in_array($method, ['POST', 'PUT', 'PATCH'])) {
                curl_setopt($ch, CURLOPT_POSTFIELDS, $body);
            }
 
            $handles[$key] = $ch;
            curl_multi_add_handle($mh, $ch);
        }
 
        // Alle gleichzeitig ausführen
        $running = 0;
        do {
            curl_multi_exec($mh, $running);
            curl_multi_select($mh);
        } while ($running > 0);
 
        // Ergebnisse einsammeln
        $responses = [];
        foreach ($handles as $key => $ch) {
            $responses[$key] = [
                'state' => 'fulfilled',
                'value' => (object) [
                    'status' => curl_getinfo($ch, CURLINFO_HTTP_CODE),
                    'body' => curl_multi_getcontent($ch),
                    'error' => curl_error($ch) ?: null
                ]
            ];
 
            curl_multi_remove_handle($mh, $ch);
            curl_close($ch);
        }
 
        curl_multi_close($mh);
 
        return $responses;
    }

References $defaultHeaders, $headers, $mh, XapiProxy\$req, $url, and ILIAS\Repository\object().

Referenced by deleteData().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getBatchUrl()

ilCmiXapiStatementsDeleteRequest::getBatchUrl	(	string	$url,
		string	$batchId
	)

private

Definition at line 267 of file class.ilCmiXapiStatementsDeleteRequest.php.

                                                              : string
    {
        $f = array();
        $f['_id'] = [
            '$oid' => $batchId
        ];
        $f = urlencode(json_encode($f));
        $f = "filter={$f}";
        return ilUtil::appendUrlParameterString($url, $f);
    }

References Vendor\Package\$f, $url, and ilUtil\appendUrlParameterString().

Referenced by queryBatch().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getDeleteStateUrls()

ilCmiXapiStatementsDeleteRequest::getDeleteStateUrls ( $url )

private

Definition at line 278 of file class.ilCmiXapiStatementsDeleteRequest.php.

                                             : array
    {
        $ret = array();
        $states = $this->buildDeleteStates();
        foreach ($states as $i => $v) {
            $ret[] = ilUtil::appendUrlParameterString($url, $v);
        }
        return $ret;
    }

References $url, ilUtil\appendUrlParameterString(), and buildDeleteStates().

Referenced by deleteData().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ queryBatch()

ilCmiXapiStatementsDeleteRequest::queryBatch ( array $batchId )

Definition at line 217 of file class.ilCmiXapiStatementsDeleteRequest.php.

                                              : array
    {
        global $DIC;
        $defaultUrl = $this->getBatchUrl($this->lrsType->getLrsEndpointBatchLink(), $batchId[0]);
 
        // Header formatieren
        $headers = [];
        foreach ($this->defaultHeaders as $key => $value) {
            $headers[] = "$key: $value";
        }
 
        $ch = curl_init($defaultUrl);
        curl_setopt_array($ch, [
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_HTTPHEADER => $headers,
            CURLOPT_TIMEOUT => 30,
            CURLOPT_SSL_VERIFYPEER => true,
            CURLOPT_FOLLOWLOCATION => true,
        ]);
 
        $response = [];
        try {
            $body = curl_exec($ch);
            $error = curl_error($ch);
            $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
            curl_close($ch);
 
            if ($error) {
                throw new Exception("cURL error: $error");
            }
 
            $response['default'] = [
                'state' => ($httpCode >= 200 && $httpCode < 300) ? 'fulfilled' : 'rejected',
                'value' => (object) [
                    'status' => $httpCode,
                    'body' => $body
                ]
            ];
 
        } catch (Exception $e) {
            $this->log->debug('error:' . $e->getMessage());
            $response['default'] = [
                'state' => 'rejected',
                'reason' => $e->getMessage()
            ];
        }
 
        return $response;
    }

References $DIC, Vendor\Package\$e, $headers, $response, and getBatchUrl().

Here is the call graph for this function:

◆ sendCurlRequest()

ilCmiXapiStatementsDeleteRequest::sendCurlRequest	(	string	$method,
		string	$url,
		array	$headers = `[]`,
		?string	$body = `null`
	)

private

Definition at line 454 of file class.ilCmiXapiStatementsDeleteRequest.php.

                                                                                                            : array
    {
        $ch = curl_init($url);
 
        $formattedHeaders = [];
        foreach ($headers as $key => $value) {
            $formattedHeaders[] = "$key: $value";
        }
 
        curl_setopt_array($ch, [
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_CUSTOMREQUEST => $method,
            CURLOPT_HTTPHEADER => $formattedHeaders,
            CURLOPT_CONNECTTIMEOUT => 10,
            CURLOPT_TIMEOUT => 60,
            CURLOPT_SSL_VERIFYPEER => true,
        ]);
 
        if ($body !== null && in_array($method, ['POST', 'PUT', 'PATCH'])) {
            curl_setopt($ch, CURLOPT_POSTFIELDS, $body);
        }
 
        $responseBody = curl_exec($ch);
        $statusCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        $error = curl_error($ch);
 
        curl_close($ch);
 
        return [
            'status' => $statusCode,
            'body' => $responseBody,
            'error' => $error ?: null,
        ];
    }