| Server IP : 78.140.185.180 / Your IP : 3.14.248.120 Web Server : LiteSpeed System : Linux cpanel13.v.fozzy.com 4.18.0-513.11.1.lve.el8.x86_64 #1 SMP Thu Jan 18 16:21:02 UTC 2024 x86_64 User : builderbox ( 1072) PHP Version : 7.3.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /home/builderbox/www/vendor/league/flysystem-rackspace/src/ |
Upload File : |
<?php
namespace League\Flysystem\Rackspace;
use Guzzle\Http\Exception\BadResponseException;
use Guzzle\Http\Exception\ClientErrorResponseException;
use League\Flysystem\Adapter\AbstractAdapter;
use League\Flysystem\Adapter\Polyfill\NotSupportingVisibilityTrait;
use League\Flysystem\Adapter\Polyfill\StreamedCopyTrait;
use League\Flysystem\Config;
use League\Flysystem\Util;
use OpenCloud\ObjectStore\Resource\Container;
use OpenCloud\ObjectStore\Resource\DataObject;
class RackspaceAdapter extends AbstractAdapter
{
use StreamedCopyTrait;
use NotSupportingVisibilityTrait;
/**
* @var Container
*/
protected $container;
/**
* @var string
*/
protected $prefix;
/**
* Constructor.
*
* @param Container $container
* @param string $prefix
*/
public function __construct(Container $container, $prefix = null)
{
$this->setPathPrefix($prefix);
$this->container = $container;
}
/**
* Get the container.
*
* @return Container
*/
public function getContainer()
{
return $this->container;
}
/**
* Get an object.
*
* @param string $path
*
* @return DataObject
*/
protected function getObject($path)
{
$location = $this->applyPathPrefix($path);
return $this->container->getObject($location);
}
/**
* Get the metadata of an object.
*
* @param string $path
*
* @return DataObject
*/
protected function getPartialObject($path)
{
$location = $this->applyPathPrefix($path);
return $this->container->getPartialObject($location);
}
/**
* {@inheritdoc}
*/
public function write($path, $contents, Config $config)
{
$location = $this->applyPathPrefix($path);
$headers = [];
if ($config && $config->has('headers')) {
$headers = $config->get('headers');
}
$response = $this->container->uploadObject($location, $contents, $headers);
return $this->normalizeObject($response);
}
/**
* {@inheritdoc}
*/
public function update($path, $contents, Config $config)
{
$object = $this->getObject($path);
$object->setContent($contents);
$object->setEtag(null);
$response = $object->update();
if (! $response->getLastModified()) {
return false;
}
return $this->normalizeObject($response);
}
/**
* {@inheritdoc}
*/
public function rename($path, $newpath)
{
$object = $this->getObject($path);
$newlocation = $this->applyPathPrefix($newpath);
$destination = '/'.$this->container->getName().'/'.ltrim($newlocation, '/');
$response = $object->copy($destination);
if ($response->getStatusCode() !== 201) {
return false;
}
$object->delete();
return true;
}
/**
* {@inheritdoc}
*/
public function delete($path)
{
try {
$location = $this->applyPathPrefix($path);
$this->container->deleteObject($location);
} catch (BadResponseException $exception) {
return false;
}
return true;
}
/**
* {@inheritdoc}
*/
public function deleteDir($dirname)
{
$paths = [];
$prefix = '/'.$this->container->getName().'/';
$location = $this->applyPathPrefix($dirname);
$objects = $this->container->objectList(['prefix' => $location]);
foreach ($objects as $object) {
$paths[] = $prefix.ltrim($object->getName(), '/');
}
$service = $this->container->getService();
$response = $service->bulkDelete($paths);
if ($response->getStatusCode() === 200) {
return true;
}
return false;
}
/**
* {@inheritdoc}
*/
public function createDir($dirname, Config $config)
{
$headers = $config->get('headers', []);
$headers['Content-Type'] = 'application/directory';
$extendedConfig = (new Config())->setFallback($config);
$extendedConfig->set('headers', $headers);
return $this->write($dirname, '', $extendedConfig);
}
/**
* {@inheritdoc}
*/
public function writeStream($path, $resource, Config $config)
{
return $this->write($path, $resource, $config);
}
/**
* {@inheritdoc}
*/
public function updateStream($path, $resource, Config $config)
{
return $this->update($path, $resource, $config);
}
/**
* {@inheritdoc}
*/
public function has($path)
{
try {
$location = $this->applyPathPrefix($path);
$exists = $this->container->objectExists($location);
} catch (ClientErrorResponseException $e) {
return false;
}
return $exists;
}
/**
* {@inheritdoc}
*/
public function read($path)
{
$object = $this->getObject($path);
$data = $this->normalizeObject($object);
$data['contents'] = (string) $object->getContent();
return $data;
}
/**
* {@inheritdoc}
*/
public function readStream($path)
{
$object = $this->getObject($path);
$data = $this->normalizeObject($object);
$responseBody = $object->getContent();
$data['stream'] = $responseBody->getStream();
rewind($data['stream']);
$responseBody->detachStream();
return $data;
}
/**
* {@inheritdoc}
*/
public function listContents($directory = '', $recursive = false)
{
$response = [];
$marker = null;
$location = $this->applyPathPrefix($directory);
while(true) {
$objectList = $this->container->objectList(['prefix' => $location, 'marker' => $marker]);
if ($objectList->count() === 0) {
break;
}
$response = array_merge($response, iterator_to_array($objectList));
$marker = end($response)->getName();
}
return Util::emulateDirectories(array_map([$this, 'normalizeObject'], $response));
}
/**
* {@inheritdoc}
*/
protected function normalizeObject(DataObject $object)
{
$name = $object->getName();
$name = $this->removePathPrefix($name);
$mimetype = explode('; ', $object->getContentType());
return [
'type' => ((in_array('application/directory', $mimetype)) ? 'dir' : 'file'),
'dirname' => Util::dirname($name),
'path' => $name,
'timestamp' => strtotime($object->getLastModified()),
'mimetype' => reset($mimetype),
'size' => $object->getContentLength(),
];
}
/**
* {@inheritdoc}
*/
public function getMetadata($path)
{
$object = $this->getPartialObject($path);
return $this->normalizeObject($object);
}
/**
* {@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);
}
}