From fa2e044be8b6dcf9c44c19878d3e0954dc3c952a Mon Sep 17 00:00:00 2001
From: Awilum <sergey.romanenko@flextype.org>
Date: Sat, 14 Aug 2021 13:53:15 +0300
Subject: [PATCH] feat(endpoints): add Media endpoints #565

---
 src/flextype/core/Endpoints/Media.php | 239 ++++++++++++++++++++++++++
 1 file changed, 239 insertions(+)
 create mode 100644 src/flextype/core/Endpoints/Media.php

diff --git a/src/flextype/core/Endpoints/Media.php b/src/flextype/core/Endpoints/Media.php
new file mode 100644
index 00000000..f8eb9298
--- /dev/null
+++ b/src/flextype/core/Endpoints/Media.php
@@ -0,0 +1,239 @@
+<?php
+
+declare(strict_types=1);
+
+/**
+ * Flextype (https://flextype.org)
+ * Founded by Sergey Romanenko and maintained by Flextype Community.
+ */
+
+namespace Flextype\Endpoints;
+
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+
+use function media;
+use function count;
+use function password_verify;
+use function registry;
+use function tokens;
+
+class Content extends Api
+{
+    /**
+     * Fetch media.
+     *
+     * @param ServerRequestInterface $request  PSR7 request.
+     * @param ResponseInterface      $response PSR7 response.
+     *
+     * @return ResponseInterface Response.
+     */
+    public function fetch(ServerRequestInterface $request, ResponseInterface $response): ResponseInterface
+    {
+        // Get Request Query Params
+        $requestQueryParams = $request->getQueryParams();
+
+        // Validate Api Request
+        if (
+            count($result = $this->validateApiRequest([
+                'request' => $request,
+                'api' => 'media',
+                'params' => ['token', 'id'],
+            ])) > 0
+        ) {
+            return $this->getApiResponse($response, $this->getStatusCodeMessage($result['http_status_code']), $result['http_status_code']);
+        }
+
+        // Get media data
+        $contentData = media()->fetch($requestQueryParams['id'], $requestQueryParams['options'] ?? [])->toArray();
+
+        if (count($contentData) > 0) {
+            return $this->getApiResponse($response, $contentData, 200);
+        }
+        
+        return $this->getApiResponse($response, $this->getStatusCodeMessage(404), 404);
+    }
+
+    /**
+     * Create media.
+     *
+     * @param ServerRequestInterface $request  PSR7 request.
+     * @param ResponseInterface      $response PSR7 response.
+     *
+     * @return ResponseInterface Response.
+     */
+    public function create(ServerRequestInterface $request, ResponseInterface $response): ResponseInterface
+    {
+        // Get Request Parsed Body
+        $requestParsedBody = $request->getParsedBody();
+        
+        // Validate Api Request
+        if (
+            count($result = $this->validateApiRequest([
+                'request' => $request,
+                'api' => 'media',
+                'params' => ['token', 'id', 'access_token'],
+            ])) > 0
+        ) {
+            return $this->getApiResponse($response, $this->getStatusCodeMessage($result['http_status_code']), $result['http_status_code']);
+        }
+
+        // Create new media
+        media()->create($requestParsedBody['id'], $requestParsedBody['data'] ?? []);
+
+        // Fetch media
+        $contentData = media()->fetch($requestParsedBody['id'])->toArray();
+
+        // Return response
+        if (count($contentData) > 0) {
+            return $this->getApiResponse($response, $contentData, 200);
+        }
+
+        return $this->getApiResponse($response, [], 404);
+    }
+
+    /**
+     * Update media.
+     *
+     * @param ServerRequestInterface $request  PSR7 request.
+     * @param ResponseInterface      $response PSR7 response.
+     *
+     * @return ResponseInterface Response.
+     */
+    public function update(ServerRequestInterface $request, ResponseInterface $response): ResponseInterface
+    {
+        // Get Request Parsed Body
+        $requestParsedBody = $request->getParsedBody();
+        
+        // Validate Api Request
+        if (
+            count($result = $this->validateApiRequest([
+                'request' => $request,
+                'api' => 'media',
+                'params' => ['token', 'id', 'access_token'],
+            ])) > 0
+        ) {
+            return $this->getApiResponse($response, $this->getStatusCodeMessage($result['http_status_code']), $result['http_status_code']);
+        }
+
+        // Update media
+        media()->update($requestParsedBody['id'], $requestParsedBody['data'] ?? []);
+
+        // Fetch media
+        $contentData = media()->fetch($requestParsedBody['id'])->toArray();
+
+        // Return response
+        if (count($contentData) > 0) {
+            return $this->getApiResponse($response, $contentData, 200);
+        }
+
+        return $this->getApiResponse($response, [], 404);
+    }
+
+    /**
+     * Move media.
+     *
+     * @param ServerRequestInterface $request  PSR7 request.
+     * @param ResponseInterface      $response PSR7 response.
+     *
+     * @return ResponseInterface Response.
+     */
+    public function move(ServerRequestInterface $request, ResponseInterface $response): ResponseInterface
+    {
+        // Get Request Parsed Body
+        $requestParsedBody = $request->getParsedBody();
+        
+        // Validate Api Request
+        if (
+            count($result = $this->validateApiRequest([
+                'request' => $request,
+                'api' => 'media',
+                'params' => ['token', 'id', 'new_id', 'access_token'],
+            ])) > 0
+        ) {
+            return $this->getApiResponse($response, $this->getStatusCodeMessage($result['http_status_code']), $result['http_status_code']);
+        }
+
+        // Move media
+        media()->move($requestParsedBody['id'], $requestParsedBody['new_id']);
+
+        // Fetch media
+        $contentData = media()->fetch($requestParsedBody['new_id'])->toArray();
+
+        // Return response
+        if (count($contentData) > 0) {
+            return $this->getApiResponse($response, $contentData, 200);
+        }
+
+        return $this->getApiResponse($response, [], 404);
+    }
+
+    /**
+     * Copy media.
+     *
+     * @param ServerRequestInterface $request  PSR7 request.
+     * @param ResponseInterface      $response PSR7 response.
+     *
+     * @return ResponseInterface Response.
+     */
+    public function copy(ServerRequestInterface $request, ResponseInterface $response): ResponseInterface
+    {
+        // Get Request Parsed Body
+        $requestParsedBody = $request->getParsedBody();
+
+        // Validate Api Request
+        if (
+            count($result = $this->validateApiRequest([
+                'request' => $request,
+                'api' => 'media',
+                'params' => ['token', 'id', 'new_id', 'access_token'],
+            ])) > 0
+        ) {
+            return $this->getApiResponse($response, $this->getStatusCodeMessage($result['http_status_code']), $result['http_status_code']);
+        }
+
+        // Copy media
+        media()->copy($requestParsedBody['id'], $requestParsedBody['new_id']);
+
+        // Fetch media
+        $contentData = media()->fetch($requestParsedBody['new_id'])->toArray();
+
+        // Return response
+        if (count($contentData) > 0) {
+            return $this->getApiResponse($response, $contentData, 200);
+        }
+
+        return $this->getApiResponse($response, [], 404);
+    }
+
+    /**
+     * Delete media.
+     *
+     * @param ServerRequestInterface $request  PSR7 request.
+     * @param ResponseInterface      $response PSR7 response.
+     *
+     * @return ResponseInterface Response.
+     */
+    public function delete(ServerRequestInterface $request, ResponseInterface $response): ResponseInterface
+    {
+        // Get Request Parsed Body
+        $requestParsedBody = $request->getParsedBody();
+
+        // Validate Api Request
+        if (
+            count($result = $this->validateApiRequest([
+                'request' => $request,
+                'api' => 'media',
+                'params' => ['token', 'id', 'access_token'],
+            ])) > 0
+        ) {
+            return $this->getApiResponse($response, $this->getStatusCodeMessage($result['http_status_code']), $result['http_status_code']);
+        }
+
+        // Copy media
+        media()->delete($requestParsedBody['id']);
+
+        // Return success response
+        return $this->getApiResponse($response, [], 204);
+    }
+}