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

Complexity

Conditions	13
Paths	9

Size

Total Lines	123
Code Lines	77

Duplication

Lines	0
Ratio	0 %

Importance

Changes	3
Bugs	0	Features	0

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

The method get() does not exist on null.

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

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

        $commentRows = $this->connection
            ->executeQuery('SELECT * FROM portfolio_comment ORDER BY id ASC')
            ->fetchAllAssociative()
        ;

        foreach ($commentRows as $commentRow) {
            /** @var PortfolioComment $comment */
            $comment = $commentRepo->find($commentRow['id']);

            /** @var User $author */
            $author = $userRepo->find($commentRow['author_id']);

            /** @var Portfolio $item */
            $item = $portfolioRepo->find($commentRow['item_id']);

            /** @var PortfolioComment $parent */
            $parent = $commentRow['parent_id'] ? $commentRepo->find($commentRow['parent_id']) : null;
            $visibility = (int) $commentRow['visibility'];
            $creationDate = new DateTime($commentRow['date']);
            $resourceParent = $parent ?: $item;

            $comment->setParent($resourceParent);

            $resourceNode = $portfolioRepo->addResourceNode(
                $comment,
                $author,
                $resourceParent,
            );

            $this->entityManager->persist($resourceNode);

The method persist() does not exist on null.

            $this->entityManager->flush();

            $resourceNode
                ->setCreatedAt($creationDate)
                ->setUpdatedAt($creationDate)
            ;

            $this->entityManager->flush();

            $courseLinkVisibility = match ($visibility) {
                PortfolioComment::VISIBILITY_VISIBLE => ResourceLink::VISIBILITY_PUBLISHED,
                default => ResourceLink::VISIBILITY_PENDING,
            };

            $itemsProperty = $this->connection
                ->executeQuery(
                    "SELECT * FROM c_item_property
                        WHERE tool = 'portfolio_comment' AND ref = {$comment->getId()}"
                )
                ->fetchAllAssociative()
            ;

            if (empty($itemsProperty)) {
                $itemRow = $this->connection
                    ->executeQuery("SELECT * FROM portfolio WHERE id = {$commentRow['item_id']}")
                    ->fetchAssociative()
                ;

                if ($itemRow && !empty($itemRow['c_id'])) {
                    $course = $this->findCourse($itemRow['c_id']);
                    $session = $itemRow['session_id'] ? $this->findSession($itemRow['session_id']) : null;
                    $creationDate = new DateTime($itemRow['creation_date']);
                    $updateDate = new DateTime($itemRow['update_date']);

                    $courseLink = $comment->addCourseLink(
                        $course,
                        $session,
                        null,
                        $courseLinkVisibility,
                        $creationDate,
                        $updateDate
                    );

                    $this->entityManager->persist($courseLink);
                }
            } else {
                foreach ($itemsProperty as $itemProperty) {
                    $course = $itemProperty['c_id'] ? $this->findCourse($itemProperty['c_id']) : null;
                    $session = $itemProperty['session_id'] ? $this->findSession($itemProperty['session_id']) : null;
                    $toUser = $itemProperty['to_user_id'] ? $userRepo->find($itemProperty['to_user_id']) : null;
                    $insertDate = new DateTime($itemProperty['insert_date'], new DateTimeZone('UTC'));
                    $editDate = new DateTime($itemProperty['lastedit_date'], new DateTimeZone('UTC'));

                    $resourceNode->setUpdatedAt($editDate);

                    if ($toUser) {
                        $userLink = $comment->addUserLink(
                            $toUser,
                            $course,
                            $session,
                            null,
                            $insertDate,
                            $editDate,
                        );

                        $this->entityManager->persist($userLink);
                    } else {
                        $courseLink = $comment->addCourseLink(
                            $course,
                            $session,
                            null,
                            $courseLinkVisibility,
                            $insertDate,
                            $editDate
                        );

                        $this->entityManager->persist($courseLink);
                    }
                }
            }

            $this->entityManager->flush();
        }