<?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;