Jabe\Impl\ManagementServiceImpl

Complexity

Total Complexity

102

Size/Duplication

Total Lines	535
Duplicated Lines	0 %

Importance

Changes

0

73 Methods

Rating	Name	Duplication	Size	Complexity
A	createBatchQuery()	0	3	1
A	activateJobDefinitionByProcessDefinitionId()	0	17	4
A	activateJobByProcessDefinitionId()	0	5	1
A	createSchemaLogQuery()	0	3	1
A	setOverridingJobPriorityForJobDefinition()	0	3	1
A	createJobQuery()	0	3	1
A	suspendJobByProcessDefinitionId()	0	5	1
A	databaseSchemaUpgrade()	0	3	1
A	activateJobByJobDefinitionId()	0	5	1
A	getUniqueTaskWorkerCount()	0	3	1
A	setJobDuedate()	0	3	1
A	getProperties()	0	3	1
A	purge()	0	3	1
A	suspendJobByJobDefinitionId()	0	5	1
A	isTelemetryEnabled()	0	3	1
A	getLicenseKey()	0	3	1
A	setJobRetriesByJobDefinitionId()	0	3	1
A	createDeploymentStatisticsQuery()	0	3	1
A	createActivityStatisticsQuery()	0	3	1
A	updateJobSuspensionState()	0	3	1
A	toggleTelemetry()	0	3	1
A	deleteJob()	0	3	1
A	__construct()	0	3	1
A	getHistoryLevel()	0	3	1
A	getProcessApplicationForDeployment()	0	3	1
A	activateJobByProcessDefinitionKey()	0	5	1
A	setLicenseKey()	0	3	1
A	suspendJobDefinitionById()	0	17	4
A	getTelemetryData()	0	3	1
A	createTablePageQuery()	0	3	1
A	suspendJobDefinitionByProcessDefinitionId()	0	17	4
A	addApplicationServerInfoToTelemetry()	0	5	2
A	suspendJobById()	0	5	1
A	addWebappToTelemetry()	0	8	2
A	deleteProperty()	0	3	1
A	updateJobDefinitionSuspensionState()	0	3	1
A	suspendJobByProcessDefinitionKey()	0	5	1
A	activateJobById()	0	5	1
A	deleteTaskMetrics()	0	3	1
A	registerProcessApplication()	0	3	1
A	clearTelemetryData()	0	11	3
A	setJobRetriesAsync()	0	14	6
A	deleteBatch()	0	3	1
A	getJobExceptionStacktrace()	0	3	1
A	setLicenseKeyForTelemetry()	0	5	2
A	getTableName()	0	3	1
A	createMetricsQuery()	0	3	1
A	clearOverridingJobPriorityForJobDefinition()	0	3	1
A	getLicenseKeyFromTelemetry()	0	7	2
A	unregisterDeploymentForJobExecutor()	0	3	1
A	suspendBatchById()	0	3	1
A	createJobDefinitionQuery()	0	3	1
A	registerDeploymentForJobExecutor()	0	3	1
A	suspendJobByProcessInstanceId()	0	5	1
A	getRegisteredDeployments()	0	3	1
A	suspendJobDefinitionByProcessDefinitionKey()	0	17	4
A	createBatchStatisticsQuery()	0	3	1
A	executeJob()	0	3	1
A	activateJobDefinitionById()	0	17	4
A	deleteLicenseKey()	0	3	1
A	setJobPriority()	0	3	1
A	activateJobByProcessInstanceId()	0	5	1
A	createProcessDefinitionStatisticsQuery()	0	3	1
A	deleteMetrics()	0	3	1
A	reportDbMetricsNow()	0	3	1
A	unregisterProcessApplication()	0	3	1
A	recalculateJobDuedate()	0	3	1
A	activateBatchById()	0	3	1
A	activateJobDefinitionByProcessDefinitionKey()	0	17	4
A	setProperty()	0	3	1
A	setJobRetries()	0	3	1
A	getTableMetaData()	0	3	1
A	getTableCount()	0	3	1

<?php

namespace Jabe\Impl;

use Doctrine\DBAL\Connection;
use Jabe\Application\{
    ProcessApplicationReferenceInterface,
    ProcessApplicationRegistrationInterface
};
use Jabe\{
    ManagementServiceInterface,
    ProcessEngineConfiguration
};
use Jabe\Batch\{
    BatchInterface,
    BatchQueryInterface,
    BatchStatisticsQueryInterface
};
use Jabe\History\HistoricProcessInstanceQueryInterface;
use Jabe\Impl\Batch\{
    BatchQueryImpl,
    BatchStatisticsQueryImpl,
    DeleteBatchCmd
};
use Jabe\Impl\Cfg\ProcessEngineConfigurationImpl;
use Jabe\Impl\Cmd\{
    ActivateBatchCmd,
    DeleteJobCmd,
    DeleteLicenseKeyCmd,
    DeleteMetricsCmd,
    DeletePropertyCmd,
    DeleteTaskMetricsCmd,
    GetHistoryLevelCmd,
    GetJobExceptionStacktraceCmd,
    GetLicenseKeyCmd,
    GetProcessApplicationForDeploymentCmd,
    GetPropertiesCmd,
    GetTableCountCmd,
    GetTableMetaDataCmd,
    GetTableNameCmd,
    GetTelemetryDataCmd,
    GetUniqueTaskWorkerCountCmd,
    IsTelemetryEnabledCmd,
    PurgeDatabaseAndCacheCmd,
    RecalculateJobDuedateCmd,
    RegisterDeploymentCmd,
    RegisterProcessApplicationCmd,
    ReportDbMetricsCmd,
    SetJobDefinitionPriorityCmd,
    SetJobDuedateCmd,
    SetJobPriorityCmd,
    SetJobRetriesCmd,
    SetJobsRetriesBatchCmd,
    SetJobsRetriesCmd,
    SetLicenseKeyCmd,
    SetPropertyCmd,
    SuspendBatchCmd,
    TelemetryConfigureCmd,
    UnregisterDeploymentCmd,
    UnregisterProcessApplicationCmd
};
use Jabe\Impl\Context\Context;
use Jabe\Impl\Db\Sql\{
    DbSqlSession,
    DbSqlSessionFactory
};
use Jabe\Impl\Interceptor\{
    CommandInterface,
    CommandContext
};
use Jabe\Impl\JobExecutor\ExecuteJobHelper;
use Jabe\Impl\Management\{
    PurgeReport,
    UpdateJobDefinitionSuspensionStateBuilderImpl,
    UpdateJobSuspensionStateBuilderImpl
};
use Jabe\Impl\Metrics\{
    MetricsQueryImpl,
    MetricsRegistry
};
use Jabe\Impl\Telemetry\Dto\LicenseKeyDataImpl;
use Jabe\Management\{
    ActivityStatisticsQueryInterface,
    DeploymentStatisticsQueryInterface,
    JobDefinitionQueryInterface,
    MetricsQueryInterface,
    ProcessDefinitionStatisticsQueryInterface,
    SchemaLogQueryInterface,
    TableMetaData,
    TablePageQueryInterface,
    UpdateJobDefinitionSuspensionStateSelectBuilderInterface,
    UpdateJobSuspensionStateSelectBuilderInterface
};
use Jabe\Runtime\{
    JobQueryInterface,
    ProcessInstanceQueryInterface
};
use Jabe\Telemetry\TelemetryDataInterface;

class ManagementServiceImpl extends ServiceImpl implements ManagementServiceInterface
{
    protected $processEngineConfiguration;

    public function __construct(ProcessEngineConfiguration $processEngineConfiguration)
    {
        $this->processEngineConfiguration = $processEngineConfiguration;
    }

    public function registerProcessApplication(string $deploymentId, ProcessApplicationReferenceInterface $reference): ProcessApplicationRegistrationInterface
    {
        return $this->commandExecutor->execute(new RegisterProcessApplicationCmd($deploymentId, $reference));
    }

    public function unregisterProcessApplication($deploymentIds, bool $removeProcessesFromCache): void
    {
        $this->commandExecutor->execute(new UnregisterProcessApplicationCmd($deploymentIds, $removeProcessesFromCache));
    }

    public function getProcessApplicationForDeployment(string $deploymentId): string
    {
        return $this->commandExecutor->execute(new GetProcessApplicationForDeploymentCmd($deploymentId));
    }

    public function getTableCount(): array
    {
        return $this->commandExecutor->execute(new GetTableCountCmd());
    }

    public function getTableName(string $activitiEntityClass): string
    {
        return $this->commandExecutor->execute(new GetTableNameCmd($activitiEntityClass));
    }

    public function getTableMetaData(string $tableName): TableMetaData
    {
        return $this->commandExecutor->execute(new GetTableMetaDataCmd($tableName));
    }

    public function executeJob(string $jobId): void
    {
        ExecuteJobHelper::executeJob($jobId, $this->commandExecutor);

The call to Jabe\Impl\JobExecutor\ExecuteJobHelper::executeJob() has too few arguments starting with configuration.

    }

    public function deleteJob(string $jobId): void
    {
        $this->commandExecutor->execute(new DeleteJobCmd($jobId));
    }

    public function setJobRetries($jobIds, int $retries): void
    {
        $this->commandExecutor->execute(new SetJobsRetriesCmd($jobIds, $retries));
    }

    public function setJobRetriesAsync($ids, $queryOrRetries, $historicQueryOrRetries = null, $retries = null): BatchInterface
    {
        if ($historicQueryOrRetries instanceof HistoricProcessInstanceQueryInterface) {
            return $this->commandExecutor->execute(
                new SetJobsRetriesByProcessBatchCmd($ids, $queryOrRetries, $historicQueryOrRetries, $retries)
            );
        } elseif ($queryOrRetries instanceof ProcessInstanceQueryInterface && $retries === null) {
            return $this->commandExecutor->execute(
                new SetJobsRetriesByProcessBatchCmd($ids, $queryOrRetries, null, $historicQueryOrRetries)
            );
        } elseif ($ids instanceof JobQueryInterface) {
            return $this->commandExecutor->execute(new SetJobsRetriesBatchCmd(null, $ids, $queryOrRetries));

null of type null is incompatible with the type array expected by parameter $ids of Jabe\Impl\Cmd\SetJobsRetriesBatchCmd::__construct().

        } elseif (is_array($ids)) {
            return $this->commandExecutor->execute(new SetJobsRetriesBatchCmd($ids, null, $queryOrRetries));

null of type null is incompatible with the type Jabe\Runtime\JobQueryInterface expected by parameter $jobQuery of Jabe\Impl\Cmd\SetJobsRetriesBatchCmd::__construct().

        }

In this branch, the function will implicitly return null which is incompatible with the type-hinted return Jabe\Batch\BatchInterface. Consider adding a return statement or allowing null as return value.

    }

    public function setJobRetriesByJobDefinitionId(string $jobDefinitionId, int $retries): void
    {
        $this->commandExecutor->execute(new SetJobRetriesCmd(null, $jobDefinitionId, $retries));
    }

    public function setJobDuedate(string $jobId, string $newDuedate, bool $cascade = false): void
    {
        $this->commandExecutor->execute(new SetJobDuedateCmd($jobId, $newDuedate, $cascade));
    }

    public function recalculateJobDuedate(string $jobId, bool $creationDateBased): void
    {
        $this->commandExecutor->execute(new RecalculateJobDuedateCmd($jobId, $creationDateBased));
    }

    public function setJobPriority(string $jobId, int $priority): void
    {
        $this->commandExecutor->execute(new SetJobPriorityCmd($jobId, $priority));
    }

    public function createTablePageQuery(): TablePageQueryInterface
    {
        return new TablePageQueryImpl($this->commandExecutor);
    }

    public function createJobQuery(): JobQueryInterface
    {
        return new JobQueryImpl($this->commandExecutor);
    }

    public function createJobDefinitionQuery(): JobDefinitionQueryInterface
    {
        return new JobDefinitionQueryImpl($this->commandExecutor);
    }

    public function getJobExceptionStacktrace(string $jobId): string
    {
        return $this->commandExecutor->execute(new GetJobExceptionStacktraceCmd($jobId));
    }

    public function getProperties(): array
    {
        return $this->commandExecutor->execute(new GetPropertiesCmd());
    }

    public function setProperty(string $name, string $value): void
    {
        $this->commandExecutor->execute(new SetPropertyCmd($name, $value));
    }

    public function deleteProperty(string $name): void
    {
        $this->commandExecutor->execute(new DeletePropertyCmd($name));
    }

    public function setLicenseKey(string $licenseKey): void
    {
        $this->commandExecutor->execute(new SetLicenseKeyCmd($licenseKey));
    }

    public function getLicenseKey(): string
    {
        return $this->commandExecutor->execute(new GetLicenseKeyCmd());
    }

    public function deleteLicenseKey(): void
    {
        $this->commandExecutor->execute(new DeleteLicenseKeyCmd(true));
    }

    public function databaseSchemaUpgrade(Connection $connection, string $catalog, string $schema): string
    {
        return $this->commandExecutor->execute(new DbSchemaUpgradeCmd($connection, $catalog, $schema));
    }

    /**
     * Purges the database and the deployment cache.
     */
    public function purge(): PurgeReport
    {
        return $this->commandExecutor->execute(new PurgeDatabaseAndCacheCmd());
    }

    public function createProcessDefinitionStatisticsQuery(): ProcessDefinitionStatisticsQueryInterface
    {
        return new ProcessDefinitionStatisticsQueryImpl($this->commandExecutor);
    }

    public function createActivityStatisticsQuery(string $processDefinitionId): ActivityStatisticsQueryInterface
    {
        return new ActivityStatisticsQueryImpl($processDefinitionId, $this->commandExecutor);
    }

    public function createDeploymentStatisticsQuery(): DeploymentStatisticsQueryInterface
    {
        return new DeploymentStatisticsQueryImpl($this->commandExecutor);
    }

    public function getRegisteredDeployments(): array
    {
        return $this->commandExecutor->execute(new GetRegisteredDeploymentsCmd());
    }

    public function registerDeploymentForJobExecutor(string $deploymentId): void
    {
        $this->commandExecutor->execute(new RegisterDeploymentCmd($deploymentId));
    }

    public function unregisterDeploymentForJobExecutor(string $deploymentId): void
    {
        $this->commandExecutor->execute(new UnregisterDeploymentCmd($deploymentId));
    }

    public function activateJobDefinitionById(string $jobDefinitionId, bool $activateJobs = false, string $activationDate = null): void
    {
        if (!$activateJobs && $activationDate === null) {
            $this->updateJobDefinitionSuspensionState()
            ->byJobDefinitionId($jobDefinitionId)
            ->activate();
        } elseif ($activationDate === null) {
            $this->updateJobDefinitionSuspensionState()
                ->byJobDefinitionId($jobDefinitionId)
                ->includeJobs($activateJobs)
                ->activate();
        } else {
            $this->updateJobDefinitionSuspensionState()
                ->byJobDefinitionId($jobDefinitionId)
                ->includeJobs($activateJobs)
                ->executionDate($activationDate)
                ->activate();
        }
    }

    public function suspendJobDefinitionById(string $jobDefinitionId, bool $suspendJobs = false, string $suspensionDate = null): void
    {
        if (!$suspendJobs && $suspensionDate === null) {
            $this->updateJobDefinitionSuspensionState()
            ->byJobDefinitionId($jobDefinitionId)
            ->suspend();
        } elseif ($suspensionDate === null) {
            $this->updateJobDefinitionSuspensionState()
                ->byJobDefinitionId($jobDefinitionId)
                ->includeJobs($suspendJobs)
                ->suspend();
        } else {
            $this->updateJobDefinitionSuspensionState()
            ->byJobDefinitionId($jobDefinitionId)
            ->includeJobs($suspendJobs)
            ->executionDate($suspensionDate)
            ->suspend();
        }
    }

    public function activateJobDefinitionByProcessDefinitionId(string $processDefinitionId, bool $activateJobs = false, string $activationDate = null): void
    {
        if (!$activateJobs && $activationDate === null) {
            $this->updateJobDefinitionSuspensionState()
            ->byProcessDefinitionId($processDefinitionId)
            ->activate();
        } elseif ($activationDate === null) {
            $this->updateJobDefinitionSuspensionState()
                ->byProcessDefinitionId($processDefinitionId)
                ->includeJobs($activateJobs)
                ->activate();
        } else {
            $this->updateJobDefinitionSuspensionState()
            ->byProcessDefinitionId($processDefinitionId)
            ->includeJobs($activateJobs)
            ->executionDate($activationDate)
            ->activate();
        }
    }

    public function suspendJobDefinitionByProcessDefinitionId(string $processDefinitionId, bool $suspendJobs = false, string $suspensionDate = null): void
    {
        if (!$suspendJobs && $suspensionDate === null) {
            $this->updateJobDefinitionSuspensionState()
                ->byProcessDefinitionId($processDefinitionId)
                ->suspend();
        } elseif ($suspensionDate === null) {
            $this->updateJobDefinitionSuspensionState()
                ->byProcessDefinitionId($processDefinitionId)
                ->includeJobs($suspendJobs)
                ->suspend();
        } else {
            $this->updateJobDefinitionSuspensionState()
                ->byProcessDefinitionId($processDefinitionId)
                ->includeJobs($suspendJobs)
                ->executionDate($suspensionDate)
                ->suspend();
        }
    }

    public function activateJobDefinitionByProcessDefinitionKey(string $processDefinitionKey, bool $activateJobs = false, string $activationDate = null): void
    {
        if (!$activateJobs && $activationDate === null) {
            $this->updateJobDefinitionSuspensionState()
                ->byProcessDefinitionKey($processDefinitionKey)
                ->activate();
        } elseif ($activationDate === null) {
            $this->updateJobDefinitionSuspensionState()
                ->byProcessDefinitionKey($processDefinitionKey)
                ->includeJobs($activateJobs)
                ->activate();
        } else {
            $this->updateJobDefinitionSuspensionState()
                ->byProcessDefinitionKey($processDefinitionKey)
                ->includeJobs($activateJobs)
                ->executionDate($activationDate)
                ->activate();
        }
    }

    public function suspendJobDefinitionByProcessDefinitionKey(string $processDefinitionKey, bool $suspendJobs = false, string $suspensionDate = null): void
    {
        if (!$suspendJobs && $suspensionDate === null) {
            $this->updateJobDefinitionSuspensionState()
            ->byProcessDefinitionKey($processDefinitionKey)
            ->suspend();
        } elseif ($suspensionDate === null) {
            $this->updateJobDefinitionSuspensionState()
                ->byProcessDefinitionKey($processDefinitionKey)
                ->includeJobs($suspendJobs)
                ->suspend();
        } else {
            $this->updateJobDefinitionSuspensionState()
            ->byProcessDefinitionKey($processDefinitionKey)
            ->includeJobs($suspendJobs)
            ->executionDate($suspensionDate)
            ->suspend();
        }
    }

    public function updateJobDefinitionSuspensionState(): UpdateJobDefinitionSuspensionStateSelectBuilderInterface
    {
        return new UpdateJobDefinitionSuspensionStateBuilderImpl($this->commandExecutor);
    }

    public function activateJobById(string $jobId): void
    {
        $this->updateJobSuspensionState()
            ->byJobId(jobId)

The constant Jabe\Impl\jobId was not found. Maybe you did not declare it correctly or list all dependencies?

            ->activate();
    }

    public function activateJobByProcessInstanceId(string $processInstanceId): void
    {
        $this->updateJobSuspensionState()
            ->byProcessInstanceId($processInstanceId)
            ->activate();
    }

    public function activateJobByJobDefinitionId(string $jobDefinitionId): void
    {
        $this->updateJobSuspensionState()
            ->byJobDefinitionId($jobDefinitionId)
            ->activate();
    }

    public function activateJobByProcessDefinitionId(string $processDefinitionId): void
    {
        $this->updateJobSuspensionState()
            ->byProcessDefinitionId($processDefinitionId)
            ->activate();
    }

    public function activateJobByProcessDefinitionKey(string $processDefinitionKey): void
    {
        $this->updateJobSuspensionState()
            ->byProcessDefinitionKey($processDefinitionKey)
            ->activate();
    }

    public function suspendJobById(string $jobId): void
    {
        $this->updateJobSuspensionState()
            ->byJobId($jobId)
            ->suspend();
    }

    public function suspendJobByJobDefinitionId(string $jobDefinitionId): void
    {
        $this->updateJobSuspensionState()
            ->byJobDefinitionId($jobDefinitionId)
            ->suspend();
    }

    public function suspendJobByProcessInstanceId(string $processInstanceId): void
    {
        $this->updateJobSuspensionState()
            ->byProcessInstanceId($processInstanceId)
            ->suspend();
    }

    public function suspendJobByProcessDefinitionId(string $processDefinitionId): void
    {
        $this->updateJobSuspensionState()
            ->byProcessDefinitionId($processDefinitionId)
            ->suspend();
    }

    public function suspendJobByProcessDefinitionKey(string $processDefinitionKey): void
    {
        $this->updateJobSuspensionState()
            ->byProcessDefinitionKey($processDefinitionKey)
            ->suspend();
    }

    public function updateJobSuspensionState(): UpdateJobSuspensionStateSelectBuilderInterface
    {
        return new UpdateJobSuspensionStateBuilderImpl($this->commandExecutor);
    }

    public function getHistoryLevel(): int
    {
        return $this->commandExecutor->execute(new GetHistoryLevelCmd());
    }

    public function createMetricsQuery(): MetricsQueryInterface
    {
        return new MetricsQueryImpl($this->commandExecutor);
    }

    public function deleteMetrics(string $timestamp = null, string $reporter = null): void
    {
        $this->commandExecutor->execute(new DeleteMetricsCmd($timestamp, $reporter));
    }

    public function reportDbMetricsNow(): void
    {
        $this->commandExecutor->execute(new ReportDbMetricsCmd());
    }

    public function getUniqueTaskWorkerCount(string $startTime, string $endTime): int
    {
        return $this->commandExecutor->execute(new GetUniqueTaskWorkerCountCmd($startTime, $endTime));
    }

    public function deleteTaskMetrics(string $timestamp): void
    {
        $this->commandExecutor->execute(new DeleteTaskMetricsCmd($timestamp));
    }

    public function setOverridingJobPriorityForJobDefinition(string $jobDefinitionId, int $priority, bool $cascade = false): void
    {
        $this->commandExecutor->execute(new SetJobDefinitionPriorityCmd($jobDefinitionId, $priority, $cascade));
    }

    public function clearOverridingJobPriorityForJobDefinition(string $jobDefinitionId): void
    {
        $this->commandExecutor->execute(new SetJobDefinitionPriorityCmd($jobDefinitionId, null, false));
    }

    public function createBatchQuery(): BatchQueryInterface
    {
        return new BatchQueryImpl($this->commandExecutor);
    }

    public function deleteBatch(string $batchId, bool $cascade): void
    {
        $this->commandExecutor->execute(new DeleteBatchCmd($batchId, $cascade));
    }

    public function suspendBatchById(string $batchId): void
    {
        $this->commandExecutor->execute(new SuspendBatchCmd($batchId));
    }

    public function activateBatchById(string $batchId): void
    {
        $this->commandExecutor->execute(new ActivateBatchCmd($batchId));
    }

    public function createBatchStatisticsQuery(): BatchStatisticsQueryInterface
    {
        return new BatchStatisticsQueryImpl($this->commandExecutor);
    }

    public function createSchemaLogQuery(): SchemaLogQueryInterface
    {
        return new SchemaLogQueryImpl($this->commandExecutor);
    }

    public function toggleTelemetry(bool $enabled): void
    {
        $this->commandExecutor->execute(new TelemetryConfigureCmd($enabled));
    }

    public function isTelemetryEnabled(): bool
    {
        return $this->commandExecutor->execute(new IsTelemetryEnabledCmd());
    }

    public function getTelemetryData(): TelemetryDataInterface
    {
        return $this->commandExecutor->execute(new GetTelemetryDataCmd());
    }

    /**
     * Adds the web application name to the telemetry data of the engine.
     *
     * @param webapp
     *          the web application that is used with the engine
     * @return whether the web application was successfully added or not
     */
    public function addWebappToTelemetry(string $webapp): bool
    {
        $telemetryRegistry = $this->processEngineConfiguration->getTelemetryRegistry();
        if ($telemetryRegistry !== null) {
            $telemetryRegistry->addWebapp($webapp);
            return true;

The expression return true returns the type true which is incompatible with the documented return type Jabe\Impl\whether.

        }
        return false;

The expression return false returns the type false which is incompatible with the documented return type Jabe\Impl\whether.

    }

    /**
     * Adds the application server information to the telemetry data of the engine.
     *
     * @param appServerInfo
     *          a String containing information about the application server
     */
    public function addApplicationServerInfoToTelemetry(string $appServerInfo): void
    {
        $telemetryRegistry = $this->processEngineConfiguration->getTelemetryRegistry();
        if ($telemetryRegistry !== null) {
            $telemetryRegistry->setApplicationServer($appServerInfo);

$appServerInfo of type string is incompatible with the type Jabe\Impl\Telemetry\Dto\ApplicationServerImpl expected by parameter $applicationServer of Jabe\Impl\Telemetry\TelemetryRegistry::setApplicationServer().

        }
    }

    /**
     * Sets license key information to the telemetry data of the engine.
     *
     * @param licenseKeyData
     *          a data object containing various pieces of information
     *          about the installed license
     */
    public function setLicenseKeyForTelemetry(LicenseKeyDataImpl $licenseKeyData): void
    {
        $telemetryRegistry = $this->processEngineConfiguration->getTelemetryRegistry();
        if ($telemetryRegistry !== null) {
            $telemetryRegistry->setLicenseKey($licenseKeyData);
        }
    }

    public function getLicenseKeyFromTelemetry(): LicenseKeyDataImpl
    {
        $telemetryRegistry = $this->processEngineConfiguration->getTelemetryRegistry();
        if ($telemetryRegistry !== null) {
            return $telemetryRegistry->getLicenseKey();

The expression return $telemetryRegistry->getLicenseKey() could return the type null which is incompatible with the type-hinted return Jabe\Impl\Telemetry\Dto\LicenseKeyDataImpl. Consider adding an additional type-check to rule them out.

        }
        return null;

The expression return null returns the type null which is incompatible with the type-hinted return Jabe\Impl\Telemetry\Dto\LicenseKeyDataImpl.

    }

    public function clearTelemetryData(): void
    {
        $telemetryRegistry = $this->processEngineConfiguration->getTelemetryRegistry();
        if ($telemetryRegistry !== null) {
            $telemetryRegistry->clear();
        }
        $metricsRegistry = $this->processEngineConfiguration->getMetricsRegistry();

The method getMetricsRegistry() does not exist on Jabe\ProcessEngineConfiguration.

        if ($metricsRegistry !== null) {
            $metricsRegistry->clearTelemetryMetrics();
        }
        $this->deleteMetrics(null);
    }
}