<?php
/**
 * This code is licensed under AGPLv3 license or Afterlogic Software License
 * if commercial version of the product was purchased.
 * For full statements of the licenses see LICENSE-AFTERLOGIC and LICENSE-AGPL3 files.
 */

namespace Afterlogic\DAV\FS\S3;

use Aws\Exception\MultipartUploadException;
use Aws\S3\MultipartUploader;

/**
 * @license https://www.gnu.org/licenses/agpl-3.0.html AGPL-3.0
 * @license https://afterlogic.com/products/common-licensing Afterlogic Software License
 * @copyright Copyright (c) 2019, Afterlogic Corp.
 */
class File extends \Afterlogic\DAV\FS\File
{
    use NodeTrait;
    use PropertyStorageTrait;

    protected $client;
    protected $bucket;
    protected $object;
    protected $storage;

    public function __construct($object, $bucket, $client, $storage = null)
    {
        $this->path = ltrim($object['Key'], '/');

        $this->bucket = $bucket;
        $this->client = $client;
        $this->object = $object;
        $this->storage = $storage;
    }

    public function delete()
    {
        $this->client->deleteObject([
            'Bucket' => $this->bucket,
            'Key' => $this->path
        ]);
        $this->deleteResourceData();
        $this->deleteShares();
        $this->deleteFavorites();
        $this->deleteHistoryDirectory();
    }

    public function put($data)
    {
        $rData = $data;
        if (!is_resource($data)) {
            $rData = fopen('php://memory', 'r+');
            fwrite($rData, $data);
            rewind($rData);
        }

        // Prepare the upload parameters.
        $uploader = new MultipartUploader($this->client, $rData, [
            'Bucket' => $this->bucket,
            'Key'    => $this->path
        ]);

        // Perform the upload.
        try {
            $result = $uploader->upload();
            if (isset($result['ETag'])) {
                return $result['ETag'];
            } else {
                return null;
            }
        } catch (MultipartUploadException $e) {
            return null;
        }
    }

    protected function getObject($bWithContentDisposition = false)
    {
        $fileName = \basename($this->path);

        $aArgs = [
            'Bucket' => $this->bucket,
            'Key' => $this->path,
            'ResponseContentType' => \Aurora\System\Utils::MimeContentType($fileName),
        ];

        if ($bWithContentDisposition) {
            $aArgs['ResponseContentDisposition'] = "attachment; filename=\"". $fileName . "\"";
        }

        $oS3Filestorage = \Aurora\Modules\S3Filestorage\Module::getInstance();
        $iPresignedLinkLifetime = 60;
        if ($oS3Filestorage) {
            $iPresignedLinkLifetime = $oS3Filestorage->getConfig('PresignedLinkLifeTimeMinutes', $iPresignedLinkLifetime);
        }

        return $this->client->createPresignedRequest(
            $this->client->getCommand(
                'GetObject',
                $aArgs
            ),
            '+' . $iPresignedLinkLifetime . ' minutes'
        );
    }

    public function getUrl($bWithContentDisposition = false)
    {
        $sUrl = null;
        $oObject = $this->getObject($bWithContentDisposition);
        if ($oObject) {
            $sUrl = (string) $oObject->getUri();
        }

        return $sUrl;
    }

    public function get()
    {
        $sUrl = $this->getUrl(false);
        if (!empty($sUrl)) {
            $context = stream_context_create(array(
                "ssl"=>array(
                    "verify_peer"=>false,
                    "verify_peer_name"=>false,
                )
            ));
            return fopen($sUrl, 'rb', false, $context);
        }
    }

    public function getWithRedirect()
    {
        $aPathInfo = pathinfo($this->path);
        if ((isset($aPathInfo['extension']) && strtolower($aPathInfo['extension']) === 'url') ||
            strtoupper(\MailSo\Base\Http::SingletonInstance()->GetMethod()) === 'COPY') {
            return $this->get();
        }

        $sUrl = $this->getUrl(true);
        if (!empty($sUrl)) {
            \Aurora\System\Api::Location($sUrl);
            exit;
        }
    }

    /**
     * Returns the last modification time, as a unix timestamp
     *
     * @return int
     */
    public function getLastModified()
    {
        if (isset($this->object)) {
            return $this->object['LastModified']->getTimestamp();
        }

        return 0;
    }

    /**
     * Returns the last modification time, as a unix timestamp
     *
     * @return int
     */
    public function getSize()
    {
        if (isset($this->object)) {
            return $this->object['Size'];
        }

        return 0;
    }

    public function getETag()
    {
        if (isset($this->object) && isset($this->object['ETag'])) {
            return $this->object['ETag'];
        }

        return '';
    }
}

• [D] Corporate
• [D] Personal
• [F] Directory.php
  Delete
• [F] File.php
  Delete
• [F] JmesQuery.php
  Delete
• [F] NodeTrait.php
  Delete
• [F] PropertyStorageTrait.php
  Delete