File DynamoDbEventStore.php has 619 lines of code (exceeds 250 allowed). Consider refactoring.

Open

<?php
declare(strict_types=1);

namespace Gdbots\Pbjx\EventStore\DynamoDb;

Method doPipeAllEvents has 154 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    protected function doPipeAllEvents(?Microtime $since = null, ?Microtime $until = null, array $context = []): \Generator
    {
        $tableName = $this->getTableNameForRead($context);
        $reindexing = filter_var($context['reindexing'] ?? false, FILTER_VALIDATE_BOOLEAN);
        $skipErrors = filter_var($context['skip_errors'] ?? false, FILTER_VALIDATE_BOOLEAN);

Method getStreamSlice has 95 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    final public function getStreamSlice(StreamId $streamId, ?Microtime $since = null, int $count = 25, bool $forward = true, bool $consistent = false, array $context = []): StreamSlice
    {
        $context['stream_id'] = $streamId;
        $context = $this->enrichContext(__FUNCTION__, $context);
        $tableName = $this->getTableNameForRead($context);

File ElasticaEventSearch.php has 318 lines of code (exceeds 250 allowed). Consider refactoring.

Open

<?php
declare(strict_types=1);

namespace Gdbots\Pbjx\EventSearch\Elastica;

Function cancelJobs has a Cognitive Complexity of 22 (exceeds 5 allowed). Consider refactoring.

Open

    public function cancelJobs(array $jobIds, array $context = []): void
    {
        $context = $this->enrichContext(__FUNCTION__, $context);
        $tableName = $this->getTableName($context);

• Read up
  Read up

Function doPipeAllEvents has a Cognitive Complexity of 21 (exceeds 5 allowed). Consider refactoring.

Open

    protected function doPipeAllEvents(?Microtime $since = null, ?Microtime $until = null, array $context = []): \Generator
    {
        $tableName = $this->getTableNameForRead($context);
        $reindexing = filter_var($context['reindexing'] ?? false, FILTER_VALIDATE_BOOLEAN);
        $skipErrors = filter_var($context['skip_errors'] ?? false, FILTER_VALIDATE_BOOLEAN);

• Read up
  Read up

Function getStreamSlice has a Cognitive Complexity of 20 (exceeds 5 allowed). Consider refactoring.

Open

    final public function getStreamSlice(StreamId $streamId, ?Microtime $since = null, int $count = 25, bool $forward = true, bool $consistent = false, array $context = []): StreamSlice
    {
        $context['stream_id'] = $streamId;
        $context = $this->enrichContext(__FUNCTION__, $context);
        $tableName = $this->getTableNameForRead($context);

• Read up
  Read up

File DynamoDbScheduler.php has 280 lines of code (exceeds 250 allowed). Consider refactoring.

Open

<?php
declare(strict_types=1);

namespace Gdbots\Pbjx\Scheduler\DynamoDb;

Method sendAt has 65 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function sendAt(Message $command, int $timestamp, ?string $jobId = null, array $context = []): string
    {
        $context['causator'] = $command;
        $context = $this->enrichContext(__FUNCTION__, $context);
        $ttl = strtotime('+7 days', $timestamp);

Method startExecution has 63 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    protected function startExecution(
        string $stateMachineArn,
        int $timestamp,
        string $jobId,
        ?string $tenantId = null

Method searchEvents has 59 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    final public function searchEvents(Message $request, ParsedQuery $parsedQuery, Message $response, array $curies = [], array $context = []): void
    {
        $context = $this->enrichContext(__FUNCTION__, $context);
        $skipValidation = filter_var($context['skip_validation'] ?? true, FILTER_VALIDATE_BOOLEAN);
        $client = $this->getClientForRead($context);

Function trigger has a Cognitive Complexity of 17 (exceeds 5 allowed). Consider refactoring.

Open

    public function trigger(Message $message, string $suffix, ?PbjxEvent $event = null, bool $recursive = true, bool $throw = true): static
    {
        $suffix = '.' . trim($suffix, '.');
        if ('.' === $suffix) {
            throw new InvalidArgumentException('Trigger requires a non-empty suffix.');

• Read up
  Read up

Method run has 55 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    final public function run(int $maxRuntime = 300): void
    {
        if ($this->isRunning) {
            $this->logger->notice(sprintf('Consumer [%s] is already running.', $this->consumerName));
            return;

Method indexEvents has 54 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    final public function indexEvents(array $events, array $context = []): void
    {
        if (empty($events)) {
            return;
        }

Method getEvent has 54 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    final public function getEvent(Identifier $eventId, array $context = []): Message
    {
        $context = $this->enrichContext(__FUNCTION__, $context);
        $tableName = $this->getTableNameForRead($context);
        $key = $this->getItemKeyByEventId($eventId, $context);

Method putEvents has 54 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    final public function putEvents(StreamId $streamId, array $events, ?string $expectedEtag = null, array $context = []): void
    {
        if (!count($events)) {
            // ignore empty events array
            return;

Method create has 47 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function create(DynamoDbClient $client, string $tableName): void
    {
        try {
            $client->describeTable(['TableName' => $tableName]);
            return;

Method deleteEvents has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    final public function deleteEvents(array $eventIds, array $context = []): void
    {
        if (empty($eventIds)) {
            return;
        }

Method getItemKeyByEventId has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    protected function getItemKeyByEventId(Identifier $eventId, array $context = []): ?array
    {
        $tableName = $this->getTableNameForRead($context);
        $params = [
            'TableName'                 => $tableName,

Method updateAnalyzers has 45 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    protected function updateAnalyzers(Index $index, string $name): void
    {
        $settings = $index->getSettings();
        $customAnalyzers = $this->getCustomAnalyzers();
        $missingAnalyzers = [];