sausin / laravel-ovh

namespace Sausin\LaravelOvh;

use DateTime;

use DateTimeInterface;

use InvalidArgumentException;

use League\Flysystem\Config;

use Nimbusoft\Flysystem\OpenStack\SwiftAdapter;

use OpenStack\Common\Error\BadResponseError;

use OpenStack\ObjectStore\v1\Models\Container;

     *

     * @param  Container $container

     * @param  OVHConfiguration $config

     * @param  string|null $prefix

     */

    public function __construct(Container $container, OVHConfiguration $config, ?string $prefix = null)

    {

        parent::__construct($container, $prefix);

        $this->config = $config;

    }

    /**

     * Gets the endpoint url of the bucket.

     *

     * @param  string|null $path

     * @return string

     */

    protected function getEndpoint(?string $path = null): string

    {

        $url = !empty($this->config->getEndpoint())

            // Allows assigning custom endpoint url

            ? rtrim($this->config->getEndpoint(), '/').'/'

            // If no custom endpoint assigned, use traditional swift v1 endpoint

            : sprintf(

                'https://storage.%s.cloud.ovh.net/v1/AUTH_%s/%s/',

                $this->config->getRegion(),

                $this->config->getProjectId(),

                $this->config->getContainerName()

            );

        if (!empty($path)) {

            $url .= $this->applyPathPrefix($path);

        }

        return $url;

    }

    /**

     * Custom function to comply with the Storage::url() function in laravel

     * without checking the existence of a file (faster).

     *

     * @param  string $path

     * @return string

     */

    public function getUrl($path)

    {

        return $this->getEndpoint($path);

    }

    /**

     * Custom function to get an url with confirmed file existence.

     *

     * @param  string $path

     * @return string

     * @throws BadResponseError

     */

    public function getUrlConfirm($path): string

    {

        // check if object exists

        try {

            $this->has($path);

        } catch (BadResponseError $e) {

            throw $e;

        }

        return $this->getEndpoint($path);

    }

    /**

     * Generate a temporary URL for private containers.

     *

     * For more information, refer to OpenStack's documentation on Temporary URL middleware:

     * https://docs.openstack.org/swift/stein/api/temporary_url_middleware.html

     *

     * @param  string $path

     * @param  DateTimeInterface $expiresAt

     * @param  array $options

     * @return string

     */

    public function getTemporaryUrl(string $path, DateTimeInterface $expiresAt, array $options = []): string

    {

        // Ensure Temp URL Key is provided for the Disk

        if (empty($this->config->getTempUrlKey())) {

            throw new InvalidArgumentException("No Temp URL Key provided for container '".$this->container->name."'");

        }

        // Get the method

        $method = $options['method'] ?? 'GET';

        // The url on the OVH host

        $codePath = sprintf(

            '/v1/AUTH_%s/%s/%s',

            $this->config->getProjectId(),

            $this->config->getContainerName(),

            $this->applyPathPrefix($path)

        );

        // Body for the HMAC hash

        $body = sprintf("%s\n%s\n%s", $method, $expiresAt->getTimestamp(), $codePath);

        // The actual hash signature

        $signature = hash_hmac('sha1', $body, $this->config->getTempUrlKey());

        // Return signed url

        return sprintf(

            '%s?temp_url_sig=%s&temp_url_expires=%s',

            $this->getEndpoint($path),

            $signature,

            $expiresAt->getTimestamp()

        );

    }

    /**

     * Generate a FormPost signature to upload files directly to your OVH container.

     *

     * For more information, refer to OpenStack's documentation on FormPost middleware:

     * https://docs.openstack.org/swift/stein/api/form_post_middleware.html

     *

     * @param  string $path

     * @param  DateTimeInterface $expiresAt

     * @param  string|null $redirect

     * @param  int $maxFileCount

     * @param  int $maxFileSize Defaults to 25MB (25 * 1024 * 1024)

     * @return string

     */

    public function getFormPostSignature(string $path, DateTimeInterface $expiresAt, ?string $redirect = null, int $maxFileCount = 1, int $maxFileSize = 26214400): string

    {

        // Ensure Temp URL Key is provided for the Disk

        if (empty($this->config->getTempUrlKey())) {

            throw new InvalidArgumentException("No Temp URL Key provided for container '".$this->container->name."'");

        }

        // Ensure that 'expires' timestamp is in the future

        if ((new DateTime()) >= $expiresAt) {

            throw new InvalidArgumentException('Expiration time of FormPost signature must be in the future.');

        }

        // Ensure $path doesn't begin with a slash

        $path = $this->applyPathPrefix($path);

        // The url on the OVH host

        $codePath = sprintf(

            '/v1/AUTH_%s/%s/%s',

            $this->config->getProjectId(),

            $this->config->getContainerName(),

            $path

        );

        // Body for the HMAC hash

        $body = sprintf("%s\n%s\n%s\n%s\n%s", $codePath, $redirect ?? '', $maxFileSize, $maxFileCount, $expiresAt->getTimestamp());

        // The actual hash signature

        return hash_hmac('sha1', $body, $this->config->getTempUrlKey());

    }

    /**

     * Expose the container to allow for modification to metadata.

     *

     * @return Container

     */

    public function getContainer(): Container

    {

        return $this->container;

    }

    /**

     * Include support for object deletion.

     *

     * @param  string $path

     * @param  Config $config

     * @return array

     * @see SwiftAdapter

     */

    protected function getWriteData($path, $config): array

    {

        $data = parent::getWriteData($path, $config);

        if ($config->has('deleteAfter')) {

            // Apply object expiration timestamp if given

            $data['deleteAfter'] = $config->get('deleteAfter');

        } elseif ($config->has('deleteAt')) {

            // Apply object expiration time if given

            $data['deleteAt'] = $config->get('deleteAt');

        } elseif (!empty($this->config->getDeleteAfter())) {

            // Apply default object expiration time from package config

            $data['deleteAfter'] = $this->config->getDeleteAfter();

        }

        return $data;

    }

}