Completed
Push — master ( f93802...a3beff )
by Paweł
34:14
created

ContentPushController::pushContentAction()   A

Complexity

Conditions 2
Paths 2

Size

Total Lines 19
Code Lines 11

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 10
CRAP Score 2.003

Importance

Changes 0
Metric Value
dl 0
loc 19
ccs 10
cts 11
cp 0.9091
rs 9.4285
c 0
b 0
f 0
cc 2
eloc 11
nc 2
nop 1
crap 2.003
1
<?php
2
3
declare(strict_types=1);
4
5
/*
6
 * This file is part of the Superdesk Web Publisher Content Bundle.
7
 *
8
 * Copyright 2016 Sourcefabric z.ú. and contributors.
9
 *
10
 * For the full copyright and license information, please see the
11
 * AUTHORS and LICENSE files distributed with this source code.
12
 *
13
 * @copyright 2016 Sourcefabric z.ú
14
 * @license http://www.superdesk.org/license
15
 */
16
17
namespace SWP\Bundle\ContentBundle\Controller;
18
19
use Hoa\Mime\Mime;
20
use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route;
21
use Sensio\Bundle\FrameworkExtraBundle\Configuration\Method;
22
use SWP\Bundle\ContentBundle\ArticleEvents;
23
use SWP\Bundle\ContentBundle\Event\ArticleEvent;
24
use SWP\Bundle\ContentBundle\Form\Type\MediaFileType;
25
use SWP\Bundle\ContentBundle\Model\ArticleMedia;
26
use SWP\Component\Bridge\Model\PackageInterface;
27
use SWP\Component\Common\Response\ResponseContext;
28
use SWP\Component\Common\Response\SingleResourceResponse;
29
use Symfony\Bundle\FrameworkBundle\Controller\Controller;
30
use Symfony\Component\HttpFoundation\Request;
31
use Nelmio\ApiDocBundle\Annotation\ApiDoc;
32
use Symfony\Component\Routing\Exception\ResourceNotFoundException;
33
34
class ContentPushController extends Controller
35
{
36
    /**
37
     * Receives HTTP Push Request's payload which is then processed by the pipeline.
38
     *
39
     * @ApiDoc(
40
     *     resource=true,
41
     *     description="Adds a new content from HTTP Push",
42
     *     statusCodes={
43
     *         201="Returned on successful post."
44
     *     }
45
     * )
46
     * @Route("/api/{version}/content/push", options={"expose"=true}, defaults={"version"="v1"}, name="swp_api_content_push")
47
     * @Method("POST")
48
     */
49 6
    public function pushContentAction(Request $request)
50
    {
51 6
        $package = $this->handlePackage($request);
52
53 6
        $article = $this->get('swp_content.transformer.package_to_article')->transform($package);
54 6
        $articleRepository = $this->get('swp.repository.article');
55
56
        // In case of resending article - remove previous one
57 6
        $existingArticle = $articleRepository->findOneBy(['slug' => $article->getSlug()]);
58 6
        if (null !== $existingArticle) {
59
            $articleRepository->remove($existingArticle);
60
        }
61
62 6
        $this->get('event_dispatcher')->dispatch(ArticleEvents::PRE_CREATE, new ArticleEvent($article, $package));
63 6
        $articleRepository->add($article);
64 6
        $this->get('event_dispatcher')->dispatch(ArticleEvents::POST_CREATE, new ArticleEvent($article));
65
66 6
        return new SingleResourceResponse(['status' => 'OK'], new ResponseContext(201));
67
    }
68
69
    /**
70
     * Receives HTTP Push Request's assets payload which is then processed and stored.
71
     *
72
     * @ApiDoc(
73
     *     resource=true,
74
     *     description="Adds new assets from HTTP Push",
75
     *     statusCodes={
76
     *         201="Returned on successful post.",
77
     *         500="Returned on invalid file.",
78
     *         200="Returned on form errors"
79
     *     },
80
     *     input="SWP\Bundle\ContentBundle\Form\Type\MediaFileType"
81
     * )
82
     * @Route("/api/{version}/assets/push", options={"expose"=true}, defaults={"version"="v1"}, name="swp_api_assets_push")
83
     * @Method("POST")
84
     */
85
    public function pushAssetsAction(Request $request)
86
    {
87
        $form = $this->createForm(MediaFileType::class);
88
        $form->handleRequest($request);
89
        if ($form->isSubmitted() && $form->isValid()) {
90
            $mediaManager = $this->container->get('swp_content_bundle.manager.media');
91
            $uploadedFile = $form->getData()['media'];
92
            $mediaId = $request->request->get('media_id');
93
            if ($uploadedFile->isValid()) {
94
                $media = $mediaManager->handleUploadedFile(
95
                    $uploadedFile,
96
                    ArticleMedia::handleMediaId($mediaId)
97
                );
98
99
                return new SingleResourceResponse([
100
                    'media_id' => $mediaId,
101
                    'URL' => $mediaManager->getMediaPublicUrl($media),
102
                    'media' => base64_encode($mediaManager->getFile($media)),
103
                    'mime_type' => Mime::getMimeFromExtension($media->getFileExtension()),
104
                    'filemeta' => [],
105
                ], new ResponseContext(201));
106
            }
107
108
            throw new \Exception('Uploaded file is not valid:'.$uploadedFile->getErrorMessage());
109
        }
110
111
        return new SingleResourceResponse($form);
112
    }
113
114
    /**
115
     * Checks if media exists in storage.
116
     *
117
     * @ApiDoc(
118
     *     resource=true,
119
     *     description="Gets a single media file",
120
     *     statusCodes={
121
     *         404="Returned when file doesn't exist.",
122
     *         200="Returned on form errors"
123
     *     }
124
     * )
125
     * @Route("/api/{version}/assets/push/{mediaId}", options={"expose"=true}, defaults={"version"="v1"}, requirements={"mediaId"=".+"}, name="swp_api_assets_get")
126
     * @Route("/api/{version}/assets/get/{mediaId}", options={"expose"=true}, defaults={"version"="v1"}, requirements={"mediaId"=".+"}, name="swp_api_assets_get_1")
127
     * @Method("GET")
128
     */
129
    public function getAssetsAction($mediaId)
130
    {
131
        $objectManager = $this->container->get('swp.object_manager.media');
132
        $pathBuilder = $this->container->get('swp_multi_tenancy.path_builder');
133
        $mediaBasepath = $this->container->getParameter('swp_multi_tenancy.persistence.phpcr.media_basepath');
134
135
        $media = $objectManager->find(null, $pathBuilder->build($mediaBasepath).'/'.ArticleMedia::handleMediaId($mediaId));
136
        if (null === $media) {
137
            throw new ResourceNotFoundException('Media don\'t exists in storage');
138
        }
139
140
        $mediaManager = $this->container->get('swp_content_bundle.manager.media');
141
142
        return new SingleResourceResponse([
143
            'media_id' => $mediaId,
144
            'URL' => $mediaManager->getMediaPublicUrl($media),
145
            'media' => base64_encode($mediaManager->getFile($media)),
146
            'mime_type' => Mime::getMimeFromExtension($media->getFileExtension()),
147
            'filemeta' => [],
148
        ]);
149
    }
150
151
    /**
152
     * @param Request $request
153
     *
154
     * @return PackageInterface
155
     */
156 6
    private function handlePackage(Request $request) : PackageInterface
157
    {
158 6
        $content = $request->getContent();
159 6
        $package = $this->get('swp_bridge.transformer.json_to_package')->transform($content);
160
161 6
        $packageRepository = $this->get('swp.repository.package');
162 6
        $existingPackage = $packageRepository->findOneBy(['guid' => $package->getGuid()]);
163 6
        if (null !== $existingPackage) {
164
            $packageRepository->remove($existingPackage);
165
        }
166 6
        $packageRepository->add($package);
167
168 6
        return $package;
169
    }
170
}
171