CodeExplorer

group example

    // within either the header or footer set.     $language = $this->languageManager()->getLanguage($request->get('language'));
    [$js_assets_header, $js_assets_footer] = $this->assetResolver->getJsAssets($attached_assets, FALSE, $language);
    $scope = $request->get('scope');
    if (!isset($scope)) {
      throw new BadRequestHttpException('The URL must have a scope query argument.');
    }
    $assets = $scope === 'header' ? $js_assets_header : $js_assets_footer;
    // While the asset resolver will find settings, these are never aggregated,     // so filter them out.     unset($assets['drupalSettings']);
    return $this->grouper->group($assets);
  }

}

$filters = [
            new EqualsFilter('active', true),
            new MultiFilter(MultiFilter::CONNECTION_AND, [
                new EqualsFilter('stock', 10),
                new EqualsFilter('categories.type', 'test'),
            ]),
            new MultiFilter(MultiFilter::CONNECTION_OR),
        ];

        $builder = new JoinGroupBuilder();
        $groupedFilters = $builder->group($filters, $definition, ['product.categories']);

        static::assertCount(3, $groupedFilters);
        static::assertInstanceOf(EqualsFilter::class, $groupedFilters[0]);
        static::assertInstanceOf(EqualsFilter::class, $groupedFilters[1]);
        static::assertInstanceOf(JoinGroup::class, $groupedFilters[2]);
    }
}

        $conditions = $this->connection->fetchAllAssociative(
            'SELECT LOWER(HEX(rc.rule_id)) as array_key, rc.*, rs.script, rs.identifier, rs.updated_at as lastModified FROM rule_condition rc LEFT JOIN app_script_condition rs ON rc.script_id = rs.id AND rs.active = 1 WHERE rc.rule_id IN (:ids) ORDER BY rc.rule_id, rc.position',
            ['ids' => Uuid::fromHexToBytesList($ids)],
            ['ids' => ArrayParameterType::STRING]
        );

        $rules = FetchModeHelper::group($conditions);

        $update = new RetryableQuery(
            $this->connection,
            $this->connection->prepare('UPDATE `rule` SET payload = :payload, invalid = :invalid WHERE id = :id')
        );

        $updated = [];
        /** @var string $id */
        foreach ($rules as $id => $rule) {
            $invalid = false;
            $serialized = null;

return new Filter('properties', false, $aggregations, new AndFilter([]), [], false);
        }

        $grouped = $this->connection->fetchAllAssociative(
            'SELECT LOWER(HEX(property_group_id)) as property_group_id, LOWER(HEX(id)) as id FROM property_group_option WHERE id IN (:ids)',
            ['ids' => Uuid::fromHexToBytesList($ids)],
            ['ids' => ArrayParameterType::STRING]
        );

        $grouped = FetchModeHelper::group($grouped);

        $filters = [];
        foreach ($grouped as $options) {
            $options = array_column($options, 'id');

            $filters[] = new OrFilter([
                new EqualsAnyFilter('product.optionIds', $options),
                new EqualsAnyFilter('product.propertyIds', $options),
            ]);
        }

continue;
            }

            if ( $limit_file && $struc['name'] !== $limit_file ) {
                continue;
            }

            $struc['perms']       = $this->gethchmod( $path . $entry );
            $struc['permsn']      = $this->getnumchmodfromh( $struc['perms'] );
            $struc['number']      = false;
            $struc['owner']       = $this->owner( $path . $entry );
            $struc['group']       = $this->group( $path . $entry );
            $struc['size']        = $this->size( $path . $entry );
            $struc['lastmodunix'] = $this->mtime( $path . $entry );
            $struc['lastmod']     = gmdate( 'M j', $struc['lastmodunix'] );
            $struc['time']        = gmdate( 'h:i:s', $struc['lastmodunix'] );
            $struc['type']        = $this->is_dir( $path . $entry ) ? 'd' : 'f';

            if ( 'd' === $struc['type'] ) {
                if ( $recursive ) {
                    $struc['files'] = $this->dirlist( $path . $struc['name'], $include_hidden, $recursive );
                } else {
                    $struc['files'] = array();
                }

        );

        $invalidSequenceGroup = FetchModeHelper::group($invalidSequence);

        $createdAt = (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT);

        $saleChannelRule = array_column($connection->fetchAllAssociative('SELECT `rule_id` FROM `sales_channel_rule`'), 'rule_id');

        foreach ($invalidSequenceGroup as $sequence) {
            $actionSequence = array_values(array_filter($sequence, fn ($sequence) => $sequence['action_name'] !== null))[0] ?? null;

            $parentCondition = array_values(array_filter($sequence, fn ($sequence) => $sequence['rule_id'] !== null && $sequence['parent_id'] === null))[0] ?? null;

            if ($actionSequence === null || $parentCondition === null) {

  public function optimize(array $css_assets, array $libraries) {
    // Group the assets.     $css_groups = $this->grouper->group($css_assets);

    // Now optimize (concatenate + minify) and dump each asset group, unless     // that was already done, in which case it should appear in     // drupal_css_cache_files.     // Drupal contrib can override this default CSS aggregator to keep the same     // grouping, optimizing and dumping, but change the strategy that is used to     // determine when the aggregate should be rebuilt (e.g. mtime, HTTPS …).     $map = $this->state->get('drupal_css_cache_files', []);
    $css_assets = [];
    foreach ($css_groups as $order => $css_group) {
      // We have to return a single asset, not a group of assets. It is now up

$query->setParameter('orderId', $orderId);
        }

        $query->andWhere('document_type.technical_name IN (:documentTypes)');
        $query->orderBy('document.created_at', 'DESC');

        $query->setParameter('documentTypes', $documentTypes, ArrayParameterType::STRING);

        $documents = $query->executeQuery()->fetchAllAssociative();

        $documentsGroupByType = FetchModeHelper::group($documents);

        $documentIds = [];
        foreach ($documentsGroupByType as $documents) {
            // Latest document of type             $document = $documents[0];

            if ($skipSentDocuments && $document['sent']) {
                continue;
            }

            $documentIds[] = $document['doc_id'];
        }

    private function getRoles(Connection $connection): array
    {
        $roles = $connection->fetchAllAssociative(' SELECT LOWER(HEX(`role`.id)) as id, CONCAT(`resource`.`resource`, \':\', `resource`.`privilege`) as priv FROM acl_role `role` LEFT JOIN acl_resource `resource` ON `role`.id = `resource`.acl_role_id ');

        return FetchModeHelper::group($roles);
    }

    private function tableExists(Connection $connection, string $table): bool
    {
        try {
            $connection->fetchOne('SELECT 1 FROM ' . $table . ' LIMIT 1');
        } catch (Exception) {
            return false;
        }

        return true;
    }

'Flow id: ' . $flow['id'] . "\n"
                    . $e->getMessage() . "\n"
                    . 'Error Code: ' . $e->getCode() . "\n"
                );

                continue;
            }

            $flows[$key]['payload'] = $payload;
        }

        return FetchModeHelper::group($flows);
    }
}

        /** @var array<string, list<IncludesInfo>> $allIncludes */
        $allIncludes = FetchModeHelper::group($includes);

        $executableScripts = [];
        foreach ($scripts as $script) {
            $appId = $script['app_id'];

            $includes = $allIncludes[$appId] ?? [];

            $dates = [...[$script['lastModified']], ...array_column($includes, 'lastModified')];

            /** @var \DateTimeInterface $lastModified */
            $lastModified = new \DateTimeImmutable(max($dates));

'name' => 'Set ' . $set,
                'baseFile' => 'de-DE',
                'iso' => $set,
            ];
            $this->snippetSetRepository->create([$createdSet], $this->context);
        }

        foreach ($customFieldSets as $customFieldSet) {
            $this->customFieldSetRepository->upsert([$customFieldSet], $this->context);
        }

        $snippets = FetchModeHelper::group(
            $this->connection->executeQuery(' SELECT snippet_set.iso, snippet.* FROM snippet LEFT JOIN snippet_set ON snippet_set.id = snippet.snippet_set_id ')->fetchAllAssociative()
        );

        $snippetCount = $this->connection->executeQuery('SELECT count(*) FROM snippet')->fetchFirstColumn();

        static::assertSame($expectedCount, (int) $snippetCount[0]);
        foreach ($snippets as $locale => $languageSnippets) {

foreach ($criteria->getFilters() as $filter) {
            $filters[] = new AndFilter([$filter]);
        }

        foreach ($criteria->getPostFilters() as $filter) {
            $filters[] = new AndFilter([$filter]);
        }

        // $additionalFields is used by the entity aggregator.         // For example, if an aggregation is to be created on a to-many-association that is already stored as a filter.         // The association is therefore referenced twice in the query and would have to be created as a sub-join in each case. But since only the filters are considered, the association is referenced only once.         return $this->joinGrouper->group($filters, $definition, $additionalFields);
    }

    private function hasScoreSorting(Criteria $criteria): bool
    {
        foreach ($criteria->getSorting() as $sorting) {
            if ($sorting->getField() === '_score') {
                return true;
            }
        }

        return false;
    }

$container->get('asset.css.collection_optimizer'),
      $container->get('asset.css.dumper'),
    );
  }

  /** * {@inheritdoc} */
  protected function getGroups(AttachedAssetsInterface $attached_assets, Request $request): array {
    $language = $this->languageManager()->getLanguage($request->get('language'));
    $assets = $this->assetResolver->getCssAssets($attached_assets, FALSE, $language);
    return $this->grouper->group($assets);
  }

}