| Server IP : 66.29.137.217 / Your IP : 18.116.60.124 Web Server : LiteSpeed System : Linux premium294.web-hosting.com 4.18.0-513.11.1.lve.el8.x86_64 #1 SMP Thu Jan 18 16:21:02 UTC 2024 x86_64 User : gltevjme ( 1095) PHP Version : 7.0.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /home/gltevjme/ideyshare.name.ng/app/libraries/vendor/league/flysystem-azure/src/ |
Upload File : |
<?php
namespace League\Flysystem\Azure;
use League\Flysystem\Adapter\AbstractAdapter;
use League\Flysystem\Adapter\Polyfill\NotSupportingVisibilityTrait;
use League\Flysystem\Config;
use League\Flysystem\Util;
use MicrosoftAzure\Storage\Blob\Internal\IBlob;
use MicrosoftAzure\Storage\Blob\Models\BlobPrefix;
use MicrosoftAzure\Storage\Blob\Models\BlobProperties;
use MicrosoftAzure\Storage\Blob\Models\CopyBlobResult;
use MicrosoftAzure\Storage\Blob\Models\CreateBlobOptions;
use MicrosoftAzure\Storage\Blob\Models\ListBlobsOptions;
use MicrosoftAzure\Storage\Blob\Models\ListBlobsResult;
use MicrosoftAzure\Storage\Common\ServiceException;
class AzureAdapter extends AbstractAdapter
{
use NotSupportingVisibilityTrait;
/**
* @var string
*/
protected $container;
/**
* @var IBlob
*/
protected $client;
/**
* @var string[]
*/
protected static $metaOptions = [
'CacheControl',
'ContentType',
'Metadata',
'ContentLanguage',
'ContentEncoding',
];
/**
* Constructor.
*
* @param IBlob $azureClient
* @param string $container
*/
public function __construct(IBlob $azureClient, $container, $prefix = null)
{
$this->client = $azureClient;
$this->container = $container;
$this->setPathPrefix($prefix);
}
/**
* {@inheritdoc}
*/
public function write($path, $contents, Config $config)
{
return $this->upload($path, $contents, $config);
}
/**
* {@inheritdoc}
*/
public function writeStream($path, $resource, Config $config)
{
return $this->upload($path, $resource, $config);
}
/**
* {@inheritdoc}
*/
public function update($path, $contents, Config $config)
{
return $this->upload($path, $contents, $config);
}
/**
* {@inheritdoc}
*/
public function updateStream($path, $resource, Config $config)
{
return $this->upload($path, $resource, $config);
}
/**
* {@inheritdoc}
*/
public function rename($path, $newpath)
{
$this->copy($path, $newpath);
return $this->delete($path);
}
public function copy($path, $newpath)
{
$path = $this->applyPathPrefix($path);
$newpath = $this->applyPathPrefix($newpath);
$this->client->copyBlob($this->container, $newpath, $this->container, $path);
return true;
}
/**
* {@inheritdoc}
*/
public function delete($path)
{
$path = $this->applyPathPrefix($path);
$this->client->deleteBlob($this->container, $path);
return true;
}
/**
* {@inheritdoc}
*/
public function deleteDir($dirname)
{
$dirname = $this->applyPathPrefix($dirname);
$options = new ListBlobsOptions();
$options->setPrefix($dirname . '/');
/** @var ListBlobsResult $listResults */
$listResults = $this->client->listBlobs($this->container, $options);
foreach ($listResults->getBlobs() as $blob) {
/** @var \MicrosoftAzure\Storage\Blob\Models\Blob $blob */
$this->client->deleteBlob($this->container, $blob->getName());
}
return true;
}
/**
* {@inheritdoc}
*/
public function createDir($dirname, Config $config)
{
$this->write(rtrim($dirname, '/').'/', ' ', $config);
return ['path' => $dirname, 'type' => 'dir'];
}
/**
* {@inheritdoc}
*/
public function has($path)
{
$path = $this->applyPathPrefix($path);
try {
$this->client->getBlobMetadata($this->container, $path);
} catch (ServiceException $e) {
if ($e->getCode() !== 404) {
throw $e;
}
return false;
}
return true;
}
/**
* {@inheritdoc}
*/
public function read($path)
{
$path = $this->applyPathPrefix($path);
/** @var \MicrosoftAzure\Storage\Blob\Models\GetBlobResult $blobResult */
$blobResult = $this->client->getBlob($this->container, $path);
$properties = $blobResult->getProperties();
$content = $this->streamContentsToString($blobResult->getContentStream());
return $this->normalizeBlobProperties($path, $properties) + ['contents' => $content];
}
/**
* {@inheritdoc}
*/
public function readStream($path)
{
$path = $this->applyPathPrefix($path);
/** @var \MicrosoftAzure\Storage\Blob\Models\GetBlobResult $blobResult */
$blobResult = $this->client->getBlob($this->container, $path);
$properties = $blobResult->getProperties();
return $this->normalizeBlobProperties($path, $properties) + ['stream' => $blobResult->getContentStream()];
}
/**
* {@inheritdoc}
*/
public function listContents($directory = '', $recursive = false)
{
$directory = $this->applyPathPrefix($directory);
// Append trailing slash only for directory other than root (which after normalization is an empty string).
// Listing for / doesn't work properly otherwise.
if (strlen($directory)) {
$directory = rtrim($directory, '/') . '/';
}
$options = new ListBlobsOptions();
$options->setPrefix($directory);
if (!$recursive) {
$options->setDelimiter('/');
}
/** @var ListBlobsResult $listResults */
$listResults = $this->client->listBlobs($this->container, $options);
$contents = [];
foreach ($listResults->getBlobs() as $blob) {
$contents[] = $this->normalizeBlobProperties($blob->getName(), $blob->getProperties());
}
if (!$recursive) {
$contents = array_merge($contents, array_map([$this, 'normalizeBlobPrefix'], $listResults->getBlobPrefixes()));
}
return Util::emulateDirectories($contents);
}
/**
* {@inheritdoc}
*/
public function getMetadata($path)
{
$path = $this->applyPathPrefix($path);
/** @var \MicrosoftAzure\Storage\Blob\Models\GetBlobPropertiesResult $result */
$result = $this->client->getBlobProperties($this->container, $path);
return $this->normalizeBlobProperties($path, $result->getProperties());
}
/**
* {@inheritdoc}
*/
public function getSize($path)
{
return $this->getMetadata($path);
}
/**
* {@inheritdoc}
*/
public function getMimetype($path)
{
return $this->getMetadata($path);
}
/**
* {@inheritdoc}
*/
public function getTimestamp($path)
{
return $this->getMetadata($path);
}
/**
* Builds the normalized output array.
*
* @param string $path
* @param int $timestamp
* @param mixed $content
*
* @return array
*/
protected function normalize($path, $timestamp, $content = null)
{
$data = [
'path' => $path,
'timestamp' => (int) $timestamp,
'dirname' => Util::dirname($path),
'type' => 'file',
];
if (is_string($content)) {
$data['contents'] = $content;
}
return $data;
}
/**
* Builds the normalized output array from a Blob object.
*
* @param string $path
* @param BlobProperties $properties
*
* @return array
*/
protected function normalizeBlobProperties($path, BlobProperties $properties)
{
if (substr($path, -1) === '/') {
return ['type' => 'dir', 'path' => $this->removePathPrefix(rtrim($path, '/'))];
}
$path = $this->removePathPrefix($path);
return [
'path' => $path,
'timestamp' => (int) $properties->getLastModified()->format('U'),
'dirname' => Util::dirname($path),
'mimetype' => $properties->getContentType(),
'size' => $properties->getContentLength(),
'type' => 'file',
];
}
/**
* Builds the normalized output array from a BlobPrefix object.
*
* @param BlobPrefix $blobPrefix
*
* @return array
*/
protected function normalizeBlobPrefix(BlobPrefix $blobPrefix)
{
return ['type' => 'dir', 'path' => $this->removePathPrefix(rtrim($blobPrefix->getName(), '/'))];
}
/**
* Retrieves content streamed by Azure into a string.
*
* @param resource $resource
*
* @return string
*/
protected function streamContentsToString($resource)
{
return stream_get_contents($resource);
}
/**
* Upload a file.
*
* @param string $path Path
* @param string|resource $contents Either a string or a stream.
* @param Config $config Config
*
* @return array
*/
protected function upload($path, $contents, Config $config)
{
$path = $this->applyPathPrefix($path);
/** @var CopyBlobResult $result */
$result = $this->client->createBlockBlob($this->container, $path, $contents, $this->getOptionsFromConfig($config));
return $this->normalize($path, $result->getLastModified()->format('U'), $contents);
}
/**
* Retrieve options from a Config instance.
*
* @param Config $config
*
* @return CreateBlobOptions
*/
protected function getOptionsFromConfig(Config $config)
{
$options = new CreateBlobOptions();
foreach (static::$metaOptions as $option) {
if (!$config->has($option)) {
continue;
}
call_user_func([$options, "set$option"], $config->get($option));
}
if ($mimetype = $config->get('mimetype')) {
$options->setContentType($mimetype);
}
return $options;
}
}