Chamilo\CoreBundle\Migrations\Schema\V200\Version20250927180004::up()

Complexity

Conditions	6
Paths	10

Size

Total Lines	69
Code Lines	40

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    public function up(Schema $schema): void
    {
        /** @var PortfolioAttachmentRepository $attachmentRepo */
        $attachmentRepo = $this->container->get(PortfolioAttachmentRepository::class);

The method get() does not exist on null.

        /** @var PortfolioRepository $itemRepo */
        $itemRepo = $this->container->get(PortfolioRepository::class);

        /** @var PortfolioCommentRepository $itemRepo */
        $commentRepo = $this->container->get(PortfolioCommentRepository::class);

        $attachmentRows = $this->connection
            ->executeQuery('SELECT * FROM portfolio_attachment')
            ->fetchAllAssociative()
        ;

        foreach ($attachmentRows as $attachmentRow) {
            $userId = 0;
            $resource = null;
            $resourceRepo = null;

            if (PortfolioAttachment::TYPE_ITEM === (int) $attachmentRow['origin_type']) {
                $resourceRepo = $itemRepo;
                $resource = $itemRepo->find($attachmentRow['origin_id']);

                $itemRow = $this->connection
                    ->executeQuery("SELECT user_id FROM portfolio WHERE id = {$attachmentRow['origin_id']}")
                    ->fetchAssociative()
                ;

                $userId = $itemRow['user_id'] ?? 0;
            } elseif (PortfolioAttachment::TYPE_COMMENT === (int) $attachmentRow['origin_type']) {
                $resourceRepo = $commentRepo;
                $resource = $commentRepo->find($attachmentRow['origin_id']);

                $commentRow = $this->connection
                    ->executeQuery("SELECT author_id FROM portfolio_comment WHERE id = {$attachmentRow['origin_id']}")
                    ->fetchAssociative()
                ;

                $userId = $commentRow['author_id'] ?? 0;
            }

            if (!$resource) {
                continue;
            }

            $folderId = ((string) $userId)[0];
            $path = $attachmentRow['path'];

            $filePath = $this->getUpdateRootPath()."/app/upload/users/$folderId/$userId/portfolio_attachments/$path";

            $this->write('MIGRATIONS :: $filePath -- '.$filePath.' ...');

            if (!file_exists($filePath)) {
                continue;
            }

            $this->addLegacyFileToResource(
                $filePath,
                $resourceRepo,
                $resource,
                $attachmentRow['origin_id'],
                $attachmentRow['filename'],
                $attachmentRow['comment']
            );
        }

        $this->entityManager->flush();

The method flush() does not exist on null.

    }