Chamilo\CoreBundle\Controller\Api\CreateDropboxFileAction::__invoke()

Complexity

Conditions	14
Paths	58

Size

Total Lines	119
Code Lines	79

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    public function __invoke(
        Request $request,
        CDropboxFileRepository $repo,
        CourseRepository $courseRepo,
        SessionRepository $sessionRepo,
        EntityManagerInterface $em,
        UserHelper $userHelper
    ): JsonResponse {

        $cid = (int) $request->query->get('cid', 0);
        $sid = (int) $request->query->get('sid', 0);
        $gid = (int) $request->query->get('gid', 0);
        if ($cid <= 0) {
            throw new BadRequestHttpException('Missing or invalid "cid".');
        }
        $user = $userHelper->getCurrent();
        if (!$user) {
            throw new UnauthorizedHttpException('', 'Unauthorized.');
        }

        /** @var UploadedFile|null $file */
        $file = $request->files->get('uploadFile');
        if (!$file) {
            // Fallback: accept any uploaded file under a different key and remap it
            foreach ($request->files as $val) {
                if ($val instanceof UploadedFile) {
                    $file = $val;
                    $request->files->set('uploadFile', $val);
                    break;
                }
            }
        }
        if (!$file) {
            throw new BadRequestHttpException('"uploadFile" is required');
        }

        $parentId = (int) $request->request->get('parentResourceNodeId', 0);
        if ($parentId === 0) {
            $course = $courseRepo->find($cid);
            $parentId = $course?->getResourceNode()?->getId() ?? 0;
            if ($parentId === 0) {
                throw new BadRequestHttpException('parentResourceNodeId (categoryId) is required');
            }
        }

        $description = (string) $request->request->get('description', '');
        $categoryId  = (int) $request->request->get('categoryId', 0);
        /** @var string[] $tokens */
        $tokens      = (array) ($request->request->all('recipients') ?? []);

        // Ensure filename uniqueness
        $original  = $file->getClientOriginalName() ?: 'upload.bin';
        $candidate = $original;
        $i = 1;
        while ($repo->findOneBy(['filename' => $candidate])) {
            $pi   = pathinfo($original);
            $name = $pi['filename'] ?? 'file';
            $ext  = isset($pi['extension']) ? '.'.$pi['extension'] : '';
            $candidate = $name.'_'.$i.$ext;
            $i++;
        }

        $now = new DateTime();
        $e = new CDropboxFile();
        $e->setFiletype('file');
        $e->setParentResourceNode($parentId);
        $e->setUploadFile($file);

        $e->setCId($cid);
        $e->setSessionId($sid);
        $e->setUploaderId($user->getId());
        $e->setTitle($candidate);
        $e->setFilename($candidate);
        $e->setFilesize((int) ($file->getSize() ?: 0));
        $e->setDescription($description);
        $e->setAuthor((string) $user->getFullName());
        $e->setUploadDate($now);
        $e->setLastUploadDate($now);
        $e->setCatId($categoryId);

        // Link visibility (course/session/user/group)
        $e->setResourceLinkArray($this->buildLinks($tokens, $cid, $sid, $gid));

        $em->persist($e);
        $em->flush();

        // Extract real recipients; if none, leave it as a "Sent only" file (no recipients).
        $destUserIds = $this->extractUserIdsFromTokens($tokens);

        foreach ($destUserIds as $destUid) {
            // Create post (feedback/thread seed)
            $post = new CDropboxPost();
            $post->setCId($cid);
            $post->setSessionId($sid ?? 0);
            $post->setFileId($e->getIid());
            $post->setDestUserId($destUid);
            $post->setCatId($categoryId);
            $post->setFeedbackDate(new DateTime());
            $em->persist($post);

            // Create visibility for the recipient
            $p = new CDropboxPerson();
            $p->setCId($cid);
            $p->setUserId($destUid);
            $p->setFileId($e->getIid());
            $em->persist($p);
        }

        $em->flush();

        return new JsonResponse([
            'ok'         => true,
            'iid'        => (int) $e->getIid(),
            'title'      => $e->getTitle(),
            'filename'   => $e->getFilename(),
            'filesize'   => $e->getFilesize(),
            'categoryId' => $e->getCatId(),
            'message'    => 'File uploaded successfully',
        ], 201);
    }