tweet_live: comparison web/Zend/Service/WindowsAzure/Storage/Blob/Stream.php

equal deleted inserted replaced

--1:000000000000
+:4eba9c11703f
+<?php
+/**
+* Zend Framework
+*
+* LICENSE
+*
+* This source file is subject to the new BSD license that is bundled
+* with this package in the file LICENSE.txt.
+* It is also available through the world-wide-web at this URL:
+* http://framework.zend.com/license/new-bsd
+* If you did not receive a copy of the license and are unable to
+* obtain it through the world-wide-web, please send an email
+* to license@zend.com so we can send you a copy immediately.
+*
+* @category   Zend
+* @package    Zend_Service_WindowsAzure_Storage
+* @subpackage Blob
+* @copyright  Copyright (c) 2005-2010 Zend Technologies USA Inc. (http://www.zend.com)
+* @license    http://todo     name_todo
+* @version    $Id: Stream.php 23167 2010-10-19 17:53:31Z mabe $
+*/
+/**
+* @see Zend_Service_WindowsAzure_Storage_Blob
+*/
+require_once 'Zend/Service/WindowsAzure/Storage/Blob.php';
+/**
+* @see Zend_Service_WindowsAzure_Exception
+*/
+require_once 'Zend/Service/WindowsAzure/Exception.php';
+/**
+* @category   Zend
+* @package    Zend_Service_WindowsAzure_Storage
+* @subpackage Blob
+* @copyright  Copyright (c) 2005-2010 Zend Technologies USA Inc. (http://www.zend.com)
+* @license    http://framework.zend.com/license/new-bsd     New BSD License
+*/
+class Zend_Service_WindowsAzure_Storage_Blob_Stream
+{
+/**
+* Current file name
+*
+* @var string
+*/
+private $_fileName = null;
+/**
+* Temporary file name
+*
+* @var string
+*/
+private $_temporaryFileName = null;
+/**
+* Temporary file handle
+*
+* @var resource
+*/
+private $_temporaryFileHandle = null;
+/**
+* Blob storage client
+*
+* @var Zend_Service_WindowsAzure_Storage_Blob
+*/
+private $_storageClient = null;
+/**
+* Write mode?
+*
+* @var boolean
+*/
+private $_writeMode = false;
+/**
+* List of blobs
+*
+* @var array
+*/
+private $_blobs = null;
+/**
+* Retrieve storage client for this stream type
+*
+* @param string $path
+* @return Zend_Service_WindowsAzure_Storage_Blob
+*/
+protected function _getStorageClient($path = '')
+{
+if ($this->_storageClient === null) {
+$url = explode(':', $path);
+if (!$url) {
+throw new Zend_Service_WindowsAzure_Exception('Could not parse path "' . $path . '".');
+}
+$this->_storageClient = Zend_Service_WindowsAzure_Storage_Blob::getWrapperClient($url[0]);
+if (!$this->_storageClient) {
+throw new Zend_Service_WindowsAzure_Exception('No storage client registered for stream type "' . $url[0] . '://".');
+}
+}
+return $this->_storageClient;
+}
+/**
+* Extract container name
+*
+* @param string $path
+* @return string
+*/
+protected function _getContainerName($path)
+{
+$url = parse_url($path);
+if ($url['host']) {
+return $url['host'];
+}
+return '';
+}
+/**
+* Extract file name
+*
+* @param string $path
+* @return string
+*/
+protected function _getFileName($path)
+{
+$url = parse_url($path);
+if ($url['host']) {
+$fileName = isset($url['path']) ? $url['path'] : $url['host'];
+	    if (strpos($fileName, '/') === 0) {
+	        $fileName = substr($fileName, 1);
+	    }
+return $fileName;
+}
+return '';
+}
+/**
+* Open the stream
+*
+* @param  string  $path
+* @param  string  $mode
+* @param  integer $options
+* @param  string  $opened_path
+* @return boolean
+*/
+public function stream_open($path, $mode, $options, $opened_path)
+{
+$this->_fileName = $path;
+$this->_temporaryFileName = tempnam(sys_get_temp_dir(), 'azure');
+// Check the file can be opened
+$fh = @fopen($this->_temporaryFileName, $mode);
+if ($fh === false) {
+return false;
+}
+fclose($fh);
+// Write mode?
+if (strpbrk($mode, 'wax+')) {
+$this->_writeMode = true;
+	} else {
+$this->_writeMode = false;
+}
+// If read/append, fetch the file
+if (!$this->_writeMode || strpbrk($mode, 'ra+')) {
+$this->_getStorageClient($this->_fileName)->getBlob(
+$this->_getContainerName($this->_fileName),
+$this->_getFileName($this->_fileName),
+$this->_temporaryFileName
+);
+}
+// Open temporary file handle
+$this->_temporaryFileHandle = fopen($this->_temporaryFileName, $mode);
+// Ok!
+return true;
+}
+/**
+* Close the stream
+*
+* @return void
+*/
+public function stream_close()
+{
+@fclose($this->_temporaryFileHandle);
+// Upload the file?
+if ($this->_writeMode) {
+// Make sure the container exists
+$containerExists = $this->_getStorageClient($this->_fileName)->containerExists(
+$this->_getContainerName($this->_fileName)
+);
+if (!$containerExists) {
+$this->_getStorageClient($this->_fileName)->createContainer(
+$this->_getContainerName($this->_fileName)
+);
+}
+// Upload the file
+try {
+$this->_getStorageClient($this->_fileName)->putBlob(
+$this->_getContainerName($this->_fileName),
+$this->_getFileName($this->_fileName),
+$this->_temporaryFileName
+);
+} catch (Zend_Service_WindowsAzure_Exception $ex) {
+@unlink($this->_temporaryFileName);
+unset($this->_storageClient);
+throw $ex;
+}
+}
+@unlink($this->_temporaryFileName);
+unset($this->_storageClient);
+}
+/**
+* Read from the stream
+*
+* @param  integer $count
+* @return string
+*/
+public function stream_read($count)
+{
+if (!$this->_temporaryFileHandle) {
+return false;
+}
+return fread($this->_temporaryFileHandle, $count);
+}
+/**
+* Write to the stream
+*
+* @param  string $data
+* @return integer
+*/
+public function stream_write($data)
+{
+if (!$this->_temporaryFileHandle) {
+return 0;
+}
+$len = strlen($data);
+fwrite($this->_temporaryFileHandle, $data, $len);
+return $len;
+}
+/**
+* End of the stream?
+*
+* @return boolean
+*/
+public function stream_eof()
+{
+if (!$this->_temporaryFileHandle) {
+return true;
+}
+return feof($this->_temporaryFileHandle);
+}
+/**
+* What is the current read/write position of the stream?
+*
+* @return integer
+*/
+public function stream_tell()
+{
+return ftell($this->_temporaryFileHandle);
+}
+/**
+* Update the read/write position of the stream
+*
+* @param  integer $offset
+* @param  integer $whence
+* @return boolean
+*/
+public function stream_seek($offset, $whence)
+{
+if (!$this->_temporaryFileHandle) {
+return false;
+}
+return (fseek($this->_temporaryFileHandle, $offset, $whence) === 0);
+}
+/**
+* Flush current cached stream data to storage
+*
+* @return boolean
+*/
+public function stream_flush()
+{
+$result = fflush($this->_temporaryFileHandle);
+// Upload the file?
+if ($this->_writeMode) {
+// Make sure the container exists
+$containerExists = $this->_getStorageClient($this->_fileName)->containerExists(
+$this->_getContainerName($this->_fileName)
+);
+if (!$containerExists) {
+$this->_getStorageClient($this->_fileName)->createContainer(
+$this->_getContainerName($this->_fileName)
+);
+}
+// Upload the file
+try {
+$this->_getStorageClient($this->_fileName)->putBlob(
+$this->_getContainerName($this->_fileName),
+$this->_getFileName($this->_fileName),
+$this->_temporaryFileName
+);
+} catch (Zend_Service_WindowsAzure_Exception $ex) {
+@unlink($this->_temporaryFileName);
+unset($this->_storageClient);
+throw $ex;
+}
+}
+return $result;
+}
+/**
+* Returns data array of stream variables
+*
+* @return array
+*/
+public function stream_stat()
+{
+if (!$this->_temporaryFileHandle) {
+return false;
+}
+$stat = array();
+$stat['dev'] = 0;
+$stat['ino'] = 0;
+$stat['mode'] = 0;
+$stat['nlink'] = 0;
+$stat['uid'] = 0;
+$stat['gid'] = 0;
+$stat['rdev'] = 0;
+$stat['size'] = 0;
+$stat['atime'] = 0;
+$stat['mtime'] = 0;
+$stat['ctime'] = 0;
+$stat['blksize'] = 0;
+$stat['blocks'] = 0;
+$info = null;
+try {
+$info = $this->_getStorageClient($this->_fileName)->getBlobInstance(
+$this->_getContainerName($this->_fileName),
+$this->_getFileName($this->_fileName)
+);
+} catch (Zend_Service_WindowsAzure_Exception $ex) {
+// Unexisting file...
+}
+if ($info !== null) {
+$stat['size']  = $info->Size;
+$stat['atime'] = time();
+}
+return $stat;
+}
+/**
+* Attempt to delete the item
+*
+* @param  string $path
+* @return boolean
+*/
+public function unlink($path)
+{
+$this->_getStorageClient($path)->deleteBlob(
+$this->_getContainerName($path),
+$this->_getFileName($path)
+);
+}
+/**
+* Attempt to rename the item
+*
+* @param  string  $path_from
+* @param  string  $path_to
+* @return boolean False
+*/
+public function rename($path_from, $path_to)
+{
+if ($this->_getContainerName($path_from) != $this->_getContainerName($path_to)) {
+throw new Zend_Service_WindowsAzure_Exception('Container name can not be changed.');
+}
+if ($this->_getFileName($path_from) == $this->_getContainerName($path_to)) {
+return true;
+}
+$this->_getStorageClient($path_from)->copyBlob(
+$this->_getContainerName($path_from),
+$this->_getFileName($path_from),
+$this->_getContainerName($path_to),
+$this->_getFileName($path_to)
+);
+$this->_getStorageClient($path_from)->deleteBlob(
+$this->_getContainerName($path_from),
+$this->_getFileName($path_from)
+);
+return true;
+}
+/**
+* Return array of URL variables
+*
+* @param  string $path
+* @param  integer $flags
+* @return array
+*/
+public function url_stat($path, $flags)
+{
+$stat = array();
+$stat['dev'] = 0;
+$stat['ino'] = 0;
+$stat['mode'] = 0;
+$stat['nlink'] = 0;
+$stat['uid'] = 0;
+$stat['gid'] = 0;
+$stat['rdev'] = 0;
+$stat['size'] = 0;
+$stat['atime'] = 0;
+$stat['mtime'] = 0;
+$stat['ctime'] = 0;
+$stat['blksize'] = 0;
+$stat['blocks'] = 0;
+$info = null;
+try {
+$info = $this->_getStorageClient($path)->getBlobInstance(
+$this->_getContainerName($path),
+$this->_getFileName($path)
+);
+} catch (Zend_Service_WindowsAzure_Exception $ex) {
+// Unexisting file...
+}
+if ($info !== null) {
+$stat['size']  = $info->Size;
+$stat['atime'] = time();
+}
+return $stat;
+}
+/**
+* Create a new directory
+*
+* @param  string  $path
+* @param  integer $mode
+* @param  integer $options
+* @return boolean
+*/
+public function mkdir($path, $mode, $options)
+{
+if ($this->_getContainerName($path) == $this->_getFileName($path)) {
+// Create container
+try {
+$this->_getStorageClient($path)->createContainer(
+$this->_getContainerName($path)
+);
+} catch (Zend_Service_WindowsAzure_Exception $ex) {
+return false;
+}
+} else {
+throw new Zend_Service_WindowsAzure_Exception('mkdir() with multiple levels is not supported on Windows Azure Blob Storage.');
+}
+}
+/**
+* Remove a directory
+*
+* @param  string  $path
+* @param  integer $options
+* @return boolean
+*/
+public function rmdir($path, $options)
+{
+if ($this->_getContainerName($path) == $this->_getFileName($path)) {
+// Delete container
+try {
+$this->_getStorageClient($path)->deleteContainer(
+$this->_getContainerName($path)
+);
+} catch (Zend_Service_WindowsAzure_Exception $ex) {
+return false;
+}
+} else {
+throw new Zend_Service_WindowsAzure_Exception('rmdir() with multiple levels is not supported on Windows Azure Blob Storage.');
+}
+}
+/**
+* Attempt to open a directory
+*
+* @param  string $path
+* @param  integer $options
+* @return boolean
+*/
+public function dir_opendir($path, $options)
+{
+$this->_blobs = $this->_getStorageClient($path)->listBlobs(
+$this->_getContainerName($path)
+);
+return is_array($this->_blobs);
+}
+/**
+* Return the next filename in the directory
+*
+* @return string
+*/
+public function dir_readdir()
+{
+$object = current($this->_blobs);
+if ($object !== false) {
+next($this->_blobs);
+return $object->Name;
+}
+return false;
+}
+/**
+* Reset the directory pointer
+*
+* @return boolean True
+*/
+public function dir_rewinddir()
+{
+reset($this->_blobs);
+return true;
+}
+/**
+* Close a directory
+*
+* @return boolean True
+*/
+public function dir_closedir()
+{
+$this->_blobs = null;
+return true;
+}
+}