sintonia/campcaster/src/modules/storageServer/var/LocStor.php

<?php
require_once "BasicStor.php";

/**
 * LocStor class
 *
 * Local storage interface
 *
 * @author  $Author$
 * @version $Revision$
 * @package Campcaster
 * @subpackage StorageServer
 */
class LocStor extends BasicStor {

    /* ---------------------------------------------------------------- store */

    /**
     *  Store or replace existing audio clip
     *
     *  @param string $sessid, session id
     *  @param string $gunid, global unique id
     *  @param string $metadata, metadata XML string
     *  @param string $fname, human readable menmonic file name
     *                      with extension corresponding to filetype
     *  @param string $chsum, md5 checksum of media file
     *  @param string $ftype audioclip | playlist | webstream
     *  @return struct {url:writable URL for HTTP PUT, token:access token
     */
    function storeAudioClipOpen(
        $sessid, $gunid, $metadata, $fname, $chsum, $ftype='audioclip'
    )
    {
        // test of gunid format:
        if (!$this->_checkGunid($gunid)) {
            return PEAR::raiseError(
                "LocStor::storeAudioClipOpen: Wrong gunid ($gunid)"
            );
        }
        // test if specified gunid exists:
        $ac =& StoredFile::recallByGunid($this, $gunid);
        if (!PEAR::isError($ac)) {
            // gunid exists - do replace
            $oid = $ac->getId();
            if (($res = $this->_authorize('write', $oid, $sessid)) !== TRUE) {
                return $res;
            }
            if ($ac->isAccessed()) {
                return PEAR::raiseError(
                    'LocStor::storeAudioClipOpen: is accessed'
                );
            }
            $res = $ac->replace(
                $oid, $ac->name, '', $metadata, 'string'
            );
            if (PEAR::isError($res)) {
                return $res;
            }
        } else {
            // gunid doesn't exists - do insert:
            $tmpFname = uniqid('');
            $parid = $this->_getHomeDirIdFromSess($sessid);
            if (PEAR::isError($parid)) {
                return $parid;
            }
            if (($res = $this->_authorize('write', $parid, $sessid)) !== TRUE) {
                return $res;
            }
            $oid = $this->addObj($tmpFname, $ftype, $parid);
            if (PEAR::isError($oid)) {
                return $oid;
            }
            $ac =& StoredFile::insert(
                $this, $oid, '', '', $metadata, 'string',
                $gunid, $ftype
            );
            if (PEAR::isError($ac)) {
                $res = $this->removeObj($oid);
                return $ac;
            }
            if (PEAR::isError($res)) {
                return $res;
            }
        }
        $res = $ac->setState('incomplete');
        if (PEAR::isError($res)) {
            return $res;
        }
        if ($fname == '') {
            $fname = "newFile";
        }
        $res = $this->bsRenameFile($oid, $fname);
        if (PEAR::isError($res)) {
            return $res;
        }
        return $this->bsOpenPut($chsum, $ac->gunid);
    }


    /**
     *  Store or replace existing audio clip
     *
     *  @param string $sessid
     *  @param string $token
     *  @return string gunid or PEAR::error
     */
    function storeAudioClipClose($sessid, $token)
    {
        $ac =& StoredFile::recallByToken($this, $token);
        if (PEAR::isError($ac)) {
            return $ac;
        }
        $arr = $r = $this->bsClosePut($token);
        if (PEAR::isError($r)) {
            $ac->delete();
            return $r;
        }
        $fname = $arr['fname'];
        //$owner = $arr['owner'];
        $res = $ac->replaceRawMediaData($fname);
        if (PEAR::isError($res)) {
            return $res;
        }
        if (file_exists($fname)) {
            @unlink($fname);
        }
        $res = $ac->setState('ready');
        if (PEAR::isError($res)) {
            return $res;
        }
        return $ac->gunid;
    }


    /**
     *  Check uploaded file
     *
     *  @param string $token, put token
     *  @return hash, (status: boolean, size: int - filesize)
     */
    function uploadCheck($token)
    {
        return $this->bsCheckPut($token);
    }


    /**
     *  Store webstream
     *
     *  @param string $sessid, session id
     *  @param string $gunid, global unique id
     *  @param string $metadata, metadata XML string
     *  @param string $fname, human readable menmonic file name
     *                      with extension corresponding to filetype
     *  @param string $url, wewbstream url
     *  @return string, gunid
     */
    function storeWebstream($sessid, $gunid, $metadata, $fname, $url)
    {
        $a = $this->storeAudioClipOpen(
            $sessid, $gunid, $metadata, $fname, md5(''), 'webstream');
        if (PEAR::isError($a)) {
            return $a;
        }
        $gunid = $this->storeAudioClipClose($sessid, $a['token']);
        if (PEAR::isError($gunid)) {
            return $gunid;
        }
        $ac =& StoredFile::recallByGunid($this, $gunid);
        if (PEAR::isError($ac)) {
            return $ac;
        }
        $oid = $ac->getId();
        $r = $this-> bsSetMetadataValue(
            $oid, 'ls:url', $url, NULL, NULL, 'metadata');
        if (PEAR::isError($r)) {
            return $r;
        }
        return $gunid;
    }


    /* --------------------------------------------------------------- access */
    /**
     *  Make access to audio clip
     *
     *  @param string $sessid
     *  @param string $gunid
     *  @param int $parent parent token
     *  @return array with: seekable filehandle, access token
     */
    function accessRawAudioData($sessid, $gunid, $parent='0')
    {
        $ac =& StoredFile::recallByGunid($this, $gunid);
        if (PEAR::isError($ac)) {
            return $ac;
        }
        if (($res = $this->_authorize('read', $ac->getId(), $sessid)) !== TRUE) {
            return $res;
        }
        return $ac->accessRawMediaData($parent);
    }


    /**
     *  Release access to audio clip
     *
     *  @param string $sessid
     *  @param string $token, access token
     *  @return boolean or PEAR::error
     */
    function releaseRawAudioData($sessid, $token)
    {
        $ac =& StoredFile::recallByToken($this, $token);
        if (PEAR::isError($ac)) {
            return $ac;
        }
        return $ac->releaseRawMediaData($token);
    }


    /* ------------------------------------------------------------- download */
    /**
     *  Create and return downloadable URL for audio file
     *
     *  @param string $sessid, session id
     *  @param string $gunid, global unique id
     *  @return array with strings:
     *      downloadable URL, download token, chsum, size, filename
     */
    function downloadRawAudioDataOpen($sessid, $gunid)
    {
        $ex = $this->existsAudioClip($sessid, $gunid);
        if (PEAR::isError($ex)) {
            return $ex;
        }
        $id = $this->_idFromGunid($gunid);
        if (is_null($id) || !$ex) {
            return PEAR::raiseError(
                "LocStor::downloadRawAudioDataOpen: gunid not found ($gunid)",
                GBERR_NOTF
            );
        }
        if (($res = $this->_authorize('read', $id, $sessid)) !== TRUE) {
            return $res;
        }
        return $this->bsOpenDownload($id);
    }


    /**
     *  Discard downloadable URL for audio file
     *
     *  @param string $token, download token
     *  @return string, gunid
     */
    function downloadRawAudioDataClose($token)
    {
        return $this->bsCloseDownload($token);
    }


    /**
     *  Create and return downloadable URL for metadata
     *
     *  @param string $sessid, session id
     *  @param string $gunid, global unique id
     *  @return array with strings:
     *      downloadable URL, download token, chsum, filename
     */
    function downloadMetadataOpen($sessid, $gunid)
    {
//        $res = $this->existsAudioClip($sessid, $gunid);
//        if(PEAR::isError($res)) return $res;
        $id = $this->_idFromGunid($gunid);
        if (is_null($id)) {
            return PEAR::raiseError(
             "LocStor::downloadMetadataOpen: gunid not found ($gunid)"
            );
        }
        if (($res = $this->_authorize('read', $id, $sessid)) !== TRUE) {
            return $res;
        }
        $res = $this->bsOpenDownload($id, 'metadata');
        #unset($res['filename']);
        return $res;
    }


    /**
     *  Discard downloadable URL for metadata
     *
     *  @param string $token, download token
     *  @return string, gunid
     */
    function downloadMetadataClose($token)
    {
        return $this->bsCloseDownload($token, 'metadata');
    }


    /**
     *  Return metadata as XML
     *
     *  @param string $sessid
     *  @param string $gunid
     *  @return string or PEAR::error
     */
    function getAudioClip($sessid, $gunid)
    {
        $ac =& StoredFile::recallByGunid($this, $gunid);
        if (PEAR::isError($ac)) {
            return $ac;
        }
        if (($res = $this->_authorize('read', $ac->getId(), $sessid)) !== TRUE) {
            return $res;
        }
        $md = $this->bsGetMetadata($ac->getId());
        if (PEAR::isError($md)) {
            return $md;
        }
        return $md;
    }


    /* ------------------------------------------------------- search, browse */

    /**
     *  Search in metadata database
     *
     *  @param string $sessid
     *  @param hash $criteria, with following structure:<br>
     *   <ul>
     *     <li>filetype - string, type of searched files,
     *       meaningful values: 'audioclip', 'webstream', 'playlist', 'all'</li>
     *     <li>operator - string, type of conditions join
     *       (any condition matches / all conditions match),
     *       meaningful values: 'and', 'or', ''
     *       (may be empty or ommited only with less then 2 items in
     *       &quot;conditions&quot; field)
     *     </li>
     *     <li>limit : int - limit for result arrays (0 means unlimited)</li>
     *     <li>offset : int - starting point (0 means without offset)</li>
     *     <li>orderby : string - metadata category for sorting (optional)
     *          or array of strings for multicolumn orderby
     *          [default: dc:creator, dc:source, dc:title]
     *     </li>
     *     <li>desc : boolean - flag for descending order (optional)
     *          or array of boolean for multicolumn orderby
     *          (it corresponds to elements of orderby field)
     *          [default: all ascending]
     *     </li>
     *     <li>conditions - array of hashes with structure:
     *       <ul>
     *           <li>cat - string, metadata category name</li>
     *           <li>op - string, operator - meaningful values:
     *               'full', 'partial', 'prefix', '=', '&lt;',
     *               '&lt;=', '&gt;', '&gt;='</li>
     *           <li>val - string, search value</li>
     *       </ul>
     *     </li>
     *   </ul>
     *  @return array of hashes, fields:
     *   <ul>
     *       <li>cnt : integer - number of matching gunids
     *              of files have been found</li>
     *       <li>results : array of hashes:
     *          <ul>
     *           <li>gunid: string</li>
     *           <li>type: string - audioclip | playlist | webstream</li>
     *           <li>title: string - dc:title from metadata</li>
     *           <li>creator: string - dc:creator from metadata</li>
     *           <li>source: string - dc:source from metadata</li>
     *           <li>length: string - dcterms:extent in extent format</li>
     *          </ul>
     *      </li>
     *   </ul>
     *  @see BasicStor::localSearch
      */
    function searchMetadata($sessid, $criteria)
    {
        if (($res = $this->_authorize('read', $this->storId, $sessid)) !== TRUE) {
            return $res;
        }
        $criteria['resultMode'] = 'xmlrpc';
        $res = $this->localSearch($criteria, $sessid);
        return $res;
    }


    /**
     * Enter description here...
     *
     * @param array $criteria
     * @param mixed $sessid - this variable isnt used
     * @return unknown
     */
    function localSearch($criteria, $sessid='')
    {
        $limit  = intval(isset($criteria['limit']) ? $criteria['limit'] : 0);
        $offset = intval(isset($criteria['offset']) ? $criteria['offset'] : 0);
        $res = $r = $this->bsLocalSearch($criteria, $limit, $offset);
        if (PEAR::isError($r)) {
            return $r;
        }
        return $res;
    }


    /**
     *  Return values of specified metadata category
     *
     *  @param string $category, metadata category name
     *          with or without namespace prefix (dc:title, author)
     *  @param hash $criteria, see searchMetadata method
     *  @param string $sessid
     *  @return hash, fields:
     *       results : array with found values
     *       cnt : integer - number of matching values
     *  @see BasicStor::bsBrowseCategory
     */
    function browseCategory($category, $criteria=NULL, $sessid='')
    {
        $limit  = intval(isset($criteria['limit']) ? $criteria['limit'] : 0);
        $offset = intval(isset($criteria['offset']) ? $criteria['offset'] : 0);
        $res = $this->bsBrowseCategory($category, $limit, $offset, $criteria);
        return $res;
    }


    /* ----------------------------------------------------------------- etc. */
    /**
     *  Check if audio clip exists
     *
     *  @param string $sessid
     *  @param string $gunid
     *  @return boolean
     */
    function existsAudioClip($sessid, $gunid)
    {
        $ex = $this->existsFile($sessid, $gunid, 'audioclip');
        // webstreams are subset of audioclips - moved to BasicStor
        // if($ex === FALSE ){
        //    $ex = $this->existsFile($sessid, $gunid, 'webstream');
        // }
        if ($ex === FALSE ) {
            return FALSE;
        }
        if (PEAR::isError($ex)) {
            return $ex;
        }
        $ac =& StoredFile::recallByGunid($this, $gunid);
        if (PEAR::isError($ac)) {
            return $ac;
        }
        return $ac->exists();
    }


    /**
     *  Check if file exists in the storage
     *
     *  @param string $sessid
     *  @param string $gunid
     *  @param string $ftype, internal file type
     *  @return boolean
     */
    function existsFile($sessid, $gunid, $ftype=NULL)
    {
        $id = $this->_idFromGunid($gunid);
        if (is_null($id)) {
            return FALSE;
        }
        if (($res = $this->_authorize('read', $id, $sessid)) !== TRUE) {
            return $res;
        }
        $ex = $this->bsExistsFile($id, $ftype);
        return $ex;
    }


    /**
     *  Delete existing audio clip
     *
     *  @param string $sessid
     *  @param string $gunid
     *  @param boolean $forced, if true don't use trash
     *  @return boolean or PEAR::error
     */
    function deleteAudioClip($sessid, $gunid, $forced=FALSE)
    {
        $ac =& StoredFile::recallByGunid($this, $gunid);
        if (PEAR::isError($ac)) {
            if ($ac->getCode()==GBERR_FOBJNEX && $forced) {
                return TRUE;
            }
            return $ac;
        }
        if (($res = $this->_authorize('write', $ac->getId(), $sessid)) !== TRUE) {
            return $res;
        }
        $res = $this->bsDeleteFile($ac->getId(), $forced);
        if (PEAR::isError($res)) {
            return $res;
        }
        return TRUE;
    }


    /**
     *  Update existing audio clip metadata
     *
     *  @param string $sessid
     *  @param string $gunid
     *  @param string $metadata, metadata XML string
     *  @return boolean or PEAR::error
     */
    function updateAudioClipMetadata($sessid, $gunid, $metadata)
    {
        $ac =& StoredFile::recallByGunid($this, $gunid);
        if (PEAR::isError($ac)) {
            return $ac;
        }
        if (($res = $this->_authorize('write', $ac->getId(), $sessid)) !== TRUE) {
            return $res;
        }
        return $ac->replaceMetaData($metadata, 'string');
    }


    /*====================================================== playlist methods */
    /**
     *  Create a new empty playlist.
     *
     *  @param string $sessid, session ID
     *  @param string $playlistId, playlist global unique ID
     *  @param string $fname, human readable mnemonic file name
     *  @return string, playlist global unique ID
     */
    function createPlaylist($sessid, $playlistId, $fname)
    {
        $ex = $this->existsPlaylist($sessid, $playlistId);
        if (PEAR::isError($ex)) {
            return $ex;
        }
        if ($ex) {
            return PEAR::raiseError(
                'LocStor::createPlaylist: already exists'
            );
        }
        $tmpFname = uniqid('');
        $parid = $this->_getHomeDirIdFromSess($sessid);
        if (PEAR::isError($parid)) {
            return $parid;
        }
        if (($res = $this->_authorize('write', $parid, $sessid)) !== TRUE) {
            return $res;
        }
        $oid = $this->addObj($tmpFname , 'playlist', $parid);
        if (PEAR::isError($oid)) {
            return $oid;
        }
        $ac =&  StoredFile::insert($this, $oid, '', '',
            dirname(__FILE__).'/emptyPlaylist.xml',
            'file', $playlistId, 'playlist'
        );
        if (PEAR::isError($ac)) {
            $res = $this->removeObj($oid);
            return $ac;
        }
        if ($fname == '') {
            $fname = "newFile.xml";
        }
        $res = $this->bsRenameFile($oid, $fname);
        if (PEAR::isError($res)) {
            return $res;
        }
        $res = $ac->setState('ready');
        if (PEAR::isError($res)) {
            return $res;
        }
        $res = $ac->setMime('application/smil');
        if (PEAR::isError($res)) {
            return $res;
        }
        return $ac->gunid;
    }


    /**
     *  Open a Playlist metafile for editing.
     *  Open readable URL and mark file as beeing edited.
     *
     *  @param string $sessid, session ID
     *  @param string $playlistId, playlist global unique ID
     *  @return struct
     *      {url:readable URL for HTTP GET, token:access token, chsum:checksum}
     */
    function editPlaylist($sessid, $playlistId)
    {
        $ex = $this->existsPlaylist($sessid, $playlistId);
        if (PEAR::isError($ex)) {
            return $ex;
        }
        if (!$ex) {
            return PEAR::raiseError(
                'LocStor::editPlaylist: playlist not exists'
            );
        }
        if ($this->_isEdited($playlistId) !== FALSE) {
            return PEAR::raiseError(
                'LocStor::editPlaylist: playlist already edited'
            );
        }
        $ac =& StoredFile::recallByGunid($this, $playlistId);
        if (PEAR::isError($ac)) {
            return $ac;
        }
        $id = $ac->getId();
        if (($res = $this->_authorize('write', $id, $sessid)) !== TRUE) {
            return $res;
        }
        $res = $this->bsOpenDownload($id, 'metadata');
        if (PEAR::isError($res)) {
            return $res;
        }
        $r = $this->_setEditFlag($playlistId, TRUE, $sessid);
        if (PEAR::isError($r)) {
            return $r;
        }
        unset($res['filename']);
        return $res;
    }


    /**
     *  Store a new Playlist metafile in place of the old one.
     *
     *  @param string $sessid, session ID
     *  @param string $playlistToken, playlist access token
     *  @param string $newPlaylist, new playlist as XML string
     *  @return string, playlistId
     */
    function savePlaylist($sessid, $playlistToken, $newPlaylist)
    {
        $playlistId = $this->bsCloseDownload($playlistToken, 'metadata');
        if (PEAR::isError($playlistId)) {
            return $playlistId;
        }
        $ac =& StoredFile::recallByGunid($this, $playlistId);
        if (PEAR::isError($ac)) {
            return $ac;
        }
        $res = $ac->replaceMetaData($newPlaylist, 'string', 'playlist');
        if (PEAR::isError($res)) {
            return $res;
        }
        $r = $this->_setEditFlag($playlistId, FALSE, $sessid);
        if (PEAR::isError($r)) {
            return $r;
        }
        return $playlistId;
    }


    /**
     *  RollBack playlist changes to the locked state
     *
     *  @param string $playlistToken, playlist access token
     *  @param string $sessid, session ID
     *  @return string gunid of playlist
     */
    function revertEditedPlaylist($playlistToken, $sessid='')
    {
        $gunid = $this->bsCloseDownload($playlistToken, 'metadata');
        if (PEAR::isError($gunid)) {
            return $gunid;
        }
        $ac =& StoredFile::recallByGunid($this, $gunid);
        if (PEAR::isError($ac)) {
            return $ac;
        }
        $id = $ac->getId();
        $mdata = $ac->getMetaData();
        if (PEAR::isError($mdata)) {
            return $mdata;
        }
        $res = $ac->replaceMetaData($mdata, 'string');
        if (PEAR::isError($res)) {
            return $res;
        }
        $this->_setEditFlag($gunid, FALSE, $sessid);
        return $gunid;
    }


    /**
     *  Delete a Playlist metafile.
     *
     *  @param string $sessid, session ID
     *  @param string $playlistId, playlist global unique ID
     *  @param boolean $forced, if true don't use trash
     *  @return boolean
     */
    function deletePlaylist($sessid, $playlistId, $forced=FALSE)
    {
        $ex = $this->existsPlaylist($sessid, $playlistId);
        if (PEAR::isError($ex)) {
            return $ex;
        }
        if (!$ex) {
            if ($forced) {
                return TRUE;
            }
            return PEAR::raiseError(
                'LocStor::deletePlaylist: playlist not exists',
                GBERR_FILENEX
            );
        }
        $ac =& StoredFile::recallByGunid($this, $playlistId);
        if (PEAR::isError($ac)) {
            return $ac;
        }
        if (($res = $this->_authorize('write', $ac->getId(), $sessid)) !== TRUE) {
            return $res;
        }
        $res = $this->bsDeleteFile($ac->getId(), $forced);
        if (PEAR::isError($res)) {
            return $res;
        }
        return TRUE;
    }


    /**
     *  Access (read) a Playlist metafile.
     *
     *  @param string $sessid, session ID
     *  @param string $playlistId, playlist global unique ID
     *  @param boolean $recursive, flag for recursive access content
     *                  inside playlist (optional, default: false)
     *  @param int $parent parent token
     *  @return struct {
     *      url: readable URL for HTTP GET,
     *      token: access token,
     *      chsum: checksum,
     *      content: array of structs - recursive access (optional)
     *      filename: string mnemonic filename
     *  }
     */
    function accessPlaylist($sessid, $playlistId, $recursive=FALSE, $parent='0')
    {
        if ($recursive) {
            require_once"AccessRecur.php";
            $r = AccessRecur::accessPlaylist($this, $sessid, $playlistId);
            if (PEAR::isError($r)) {
                return $r;
            }
            return $r;
        }
        $ex = $this->existsPlaylist($sessid, $playlistId);
        if (PEAR::isError($ex)) {
            return $ex;
        }
        if (!$ex) {
            return PEAR::raiseError(
                "LocStor::accessPlaylist: playlist not found ($playlistId)",
                GBERR_NOTF
            );
        }
        $id = $this->_idFromGunid($playlistId);
        if (($res = $this->_authorize('read', $id, $sessid)) !== TRUE) {
            return $res;
        }
        $res = $this->bsOpenDownload($id, 'metadata', $parent);
        #unset($res['filename']);
        return $res;
    }


    /**
     *  Release the resources obtained earlier by accessPlaylist().
     *
     *  @param string $sessid, session ID
     *  @param string $playlistToken, playlist access token
     *  @param boolean $recursive, flag for recursive access content
     *                  inside playlist (optional, default: false)
     *  @return string, playlist ID
     */
    function releasePlaylist($sessid, $playlistToken, $recursive=FALSE)
    {
        if ($recursive) {
            require_once"AccessRecur.php";
            $r = AccessRecur::releasePlaylist($this, $sessid, $playlistToken);
            if (PEAR::isError($r)) {
                return $r;
            }
            return $r;
        }
        return $this->bsCloseDownload($playlistToken, 'metadata');
    }


    /**
     *  Create a tarfile with playlist export - playlist and all matching
     *  sub-playlists and media files (if desired)
     *
     *  @param sessid - string, session ID
     *  @param plids - array of strings, playlist global unique IDs
     *          (one gunid is accepted too)
     *  @param type - string, playlist format, values: lspl | smil | m3u
     *  @param standalone - boolean, if only playlist should be exported or
     *          with all related files
     *  @return hasharray with  fields:
     *      url string: readable url,
     *      token string: access token
     *      chsum string: md5 checksum,
     */
    function exportPlaylistOpen($sessid, $plids, $type='lspl', $standalone=FALSE)
    {
        $res = $r =$this->bsExportPlaylistOpen($plids, $type, !$standalone);
        if ($this->dbc->isError($r)) {
            return $r;
        }
        $url = $this->getUrlPart()."access/".basename($res['fname']);
        $chsum = md5_file($res['fname']);
        $size = filesize($res['fname']);
        return array(
            'url' => $url,
            'token' => $res['token'],
            'chsum' => $chsum,
        );
    }


    /**
     *  Close playlist export previously opened by the exportPlaylistOpen method
     *
     *  @param token - string, access token obtained from exportPlaylistOpen
     *            method call
     *  @return boolean true or error object
     */
    function exportPlaylistClose($token)
    {
        return $this->bsExportPlaylistClose($token);
    }


    /**
     *  Open writable handle for import playlist in LS Archive format
     *
     *  @param string $sessid, session id
     *  @param string $chsum, md5 checksum of imported file
     *  @return hasharray with:
     *      url string: writable URL
     *      token string: PUT token
     */
    function importPlaylistOpen($sessid, $chsum)
    {
        $userid = $r =$this->getSessUserId($sessid);
        if ($this->dbc->isError($r)) {
            return $r;
        }
        $r = $this->bsOpenPut($chsum, NULL, $userid);
        if (PEAR::isError($r)) {
            return $r;
        }
        return $r;
    }


    /**
     *  Close import-handle and import playlist
     *
     *  @param string $token, import token obtained by importPlaylistOpen method
     *  @return string, result file global id (or error object)
     */
    function importPlaylistClose($token)
    {
        $arr = $r = $this->bsClosePut($token);
        if (PEAR::isError($r)) {
            return $r;
        }
        $fname = $arr['fname'];
        $owner = $arr['owner'];
        $parid = $r= $this->_getHomeDirId($owner);
        if (PEAR::isError($r)) {
            if (file_exists($fname)) {
                @unlink($fname);
            }
            return $r;
        }
        $res = $r = $this->bsImportPlaylist($parid, $fname);
        if (file_exists($fname)) {
            @unlink($fname);
        }
        if (PEAR::isError($r)) {
            return $r;
        }
        return $this->_gunidFromId($res);
    }


    /**
     *  Check whether a Playlist metafile with the given playlist ID exists.
     *
     *  @param string $sessid, session ID
     *  @param string $playlistId, playlist global unique ID
     *  @return boolean
     */
    function existsPlaylist($sessid, $playlistId)
    {
        return $this->existsFile($sessid, $playlistId, 'playlist');
    }


    /**
     *  Check whether a Playlist metafile with the given playlist ID
     *  is available for editing, i.e., exists and is not marked as
     *  beeing edited.
     *
     *  @param string $sessid, session ID
     *  @param string $playlistId, playlist global unique ID
     *  @param boolean $getUid, optional flag for returning editedby uid
     *  @return boolean
     */
    function playlistIsAvailable($sessid, $playlistId, $getUid=FALSE)
    {
        $ex = $this->existsPlaylist($sessid, $playlistId);
        if (PEAR::isError($ex)) {
            return $ex;
        }
        if (!$ex) {
            return PEAR::raiseError(
                'LocStor::playlistIsAvailable: playlist not exists'
            );
        }
        $ie = $this->_isEdited($playlistId);
        if ($ie === FALSE) {
            return TRUE;
        }
        if ($getUid) {
            return $ie;
        }
        return FALSE;
    }


    /* ------------------------------------------------------- render methods */
    /**
     *  Render playlist to ogg file (open handle)
     *
     *  @param string $sessid -  session id
     *  @param string $plid -  playlist gunid
     *  @return hasharray:
     *      token: string - render token
     */
    function renderPlaylistToFileOpen($sessid, $plid)
    {
        require_once "Renderer.php";
        $r = Renderer::rnRender2FileOpen($this, $plid);
        if (PEAR::isError($r)) {
            return $r;
        }
        return $r;
    }


    /**
     *  Render playlist to ogg file (check results)
     *
     *  @param string $token  -  render token
     *  @return hasharray:
     *      status : string - success | working | fault
     *      url : string - readable url
     */
    function renderPlaylistToFileCheck($token)
    {
        require_once "Renderer.php";
        $r = Renderer::rnRender2FileCheck($this, $token);
        if (PEAR::isError($r)) {
            return $r;
        }
        return array('status'=>$r['status'], 'url'=>$r['url']);
    }


    /**
     *  Render playlist to ogg file (close handle)
     *
     *  @param string $token  -  render token
     *  @return boolean status
     */
    function renderPlaylistToFileClose($token)
    {
        require_once "Renderer.php";
        $r = Renderer::rnRender2FileClose($this, $token);
        if (PEAR::isError($r)) {
            return $r;
        }
        return array(TRUE);
    }


    /**
     *  Render playlist to storage media clip (open handle)
     *
     *  @param string $sessid  -  session id
     *  @param string $plid  -  playlist gunid
     *  @return string -  render token
     */
    function renderPlaylistToStorageOpen($sessid, $plid)
    {
        require_once "Renderer.php";
        $owner = $this->getSessUserId($sessid);
        if ($this->dbc->isError($owner)) {
            return $owner;
        }
        $r = Renderer::rnRender2FileOpen($this, $plid, $owner);
        if (PEAR::isError($r)) {
            return $r;
        }
        return $r;
    }


    /**
     *  Render playlist to storage media clip (check results)
     *
     *  @param string $token -  render token
     *  @return hasharray:
     *      status : string - success | working | fault
     *      gunid  : string - gunid of result file
     */
    function renderPlaylistToStorageCheck($token)
    {
        require_once "Renderer.php";
        $r = Renderer::rnRender2StorageCheck($this, $token);
        if (PEAR::isError($r)) {
            return $r;
        }
        return $r;
    }


    /**
     *  Render playlist to RSS file (open handle)
     *
     *  @param string $sessid -  session id
     *  @param string $plid -  playlist gunid
     *  @return string -  render token
     */
    function renderPlaylistToRSSOpen($sessid, $plid)
    {
        $token = '123456789abcdeff';
        $fakeFile = "{$this->accessDir}/$token.rss";
        file_put_contents($fakeFile, "fake rendered file");
        return array('token'=>$token);
    }


    /**
     *  Render playlist to RSS file (check results)
     *
     *  @param string $token -  render token
     *  @return hasharray :
     *      status : string - success | working | fault
     *      url    : string - readable url
     */
    function renderPlaylistToRSSCheck($token)
    {
        $fakeFile = "{$this->accessDir}/$token.rss";
        if ($token != '123456789abcdeff' || !file_exists($fakeFile)) {
            return PEAR::raiseError(
                "LocStor::renderPlaylistToRSSCheck: invalid token ($token)"
            );
        }
        $fakeFUrl = $this->getUrlPart()."access/$token.rss";
        return array(
            'status'=> 'success',
            'url'   => $fakeFUrl,
        );
    }


    /**
     *  Render playlist to RSS file (close handle)
     *
     *  @param string $token -  render token
     *  @return boolean status
     */
    function renderPlaylistToRSSClose($token)
    {
        if ($token != '123456789abcdeff') {
            return PEAR::raiseError(
                "LocStor::renderPlaylistToRSSClose: invalid token"
            );
        }
        $fakeFile = "{$this->accessDir}/$token.rss";
        unlink($fakeFile);
        return TRUE;
    }


    /*================================================= storage admin methods */

    /* ------------------------------------------------------- backup methods */

    /**
     *  Create backup of storage (open handle)
     *
     *  @param string $sessid  -  session id
     *  @param array $criteria - see search criteria
     *  @return hasharray:
     *           token  : string - backup token
     */
    function createBackupOpen($sessid, $criteria='')
    {
        require_once "Backup.php";
        $bu = $r = new Backup($this);
        if (PEAR::isError($r)) {
            return $r;
        }
        $r = $bu->openBackup($sessid,$criteria);
        if ($r === FALSE) {
            return PEAR::raiseError(
                "LocStor::createBackupOpen: false returned from Backup"
            );
        }
        return $r;
    }


    /**
     *  Create backup of storage (check results)
     *
     *  @param string $token -  backup token
     *  @return hasharray with field:
     *      status : string - susccess | working | fault
     *      faultString: string - description of fault
     *      token  : stirng - backup token
     *      url    : string - access url
     */
    function createBackupCheck($token)
    {
        require_once "Backup.php";
        $bu = $r = new Backup($this);
        if (PEAR::isError($r)) {
            return $r;
        }
        return $bu->checkBackup($token);
    }


    /**
     *  Create backup of storage (list results)
     *
     *  @param string $sessid - session id
     *  @param status $stat (optional)
     *      if this parameter is not set, then return with all unclosed backups
     *  @return array of hasharray with field:
     *      status : string - susccess | working | fault
     *      token  : stirng - backup token
     *      url    : string - access url
     */
    function createBackupList($sessid, $stat='')
    {
        require_once "Backup.php";
        $bu = $r = new Backup($this);
        if (PEAR::isError($r)) {
            return $r;
        }
        return $bu->listBackups($stat);
    }


    /**
     *  Create backup of storage (close handle)
     *
     *  @param string $token -  backup token
     *  @return boolean status
     */
    function createBackupClose($token)
    {
        require_once "Backup.php";
        $bu = $r = new Backup($this);
        if (PEAR::isError($r)) {
            return $r;
        }
        return $bu->closeBackup($token);
    }


    /* ------------------------------------------------------ restore methods */

    /**
     *  Restore a backup file (open handle)
     *
     *  @param  string $sessid - session id
     *  @param  string $chsum, md5 checksum of imported file
     * @return array
     * 		array with:
     *      url string: writable URL
     *      fname string: writable local filename
     *      token string: PUT token
     */
    function restoreBackupOpen($sessid, $chsum)
    {
        $userid = $r =$this->getSessUserId($sessid);
        if ($this->dbc->isError($r)) {
            return $r;
        }
        $r = $this->bsOpenPut($chsum, NULL, $userid);
        if (PEAR::isError($r)) {
            return $r;
        }
        return $r;
    }


    /**
     *  Restore a backup file (close put handle)
     *
     *  @param string $sessid - session id
     *  @param string $token -  put token
     *  @return string $token - restore token
     */
    function restoreBackupClosePut($sessid, $token) {
        $arr = $r = $this->bsClosePut($token);
        if (PEAR::isError($r)) {
            return $r;
        }
        $fname = $arr['fname'];
        require_once 'Restore.php';
        $rs = new Restore($this);
        if (PEAR::isError($rs)) {
            return $rs;
        }
        return $rs->openRestore($sessid, $fname);
    }

    /**
     *  Restore a backup file (check state)
     *  
     *  @param string $token -  restore token
     *  @return array status - fields:
     * 							token:  string - restore token
     *                          status: string - working | fault | success
     *                          faultString: string - description of fault
     */
    function restoreBackupCheck($token)
    {
        require_once 'Restore.php';
        $rs = new Restore($this);
        if (PEAR::isError($rs)) {
            return $rs;
        }
        return $rs->checkRestore($token);
    }


    /**
     *  Restore a backup file (close handle)
     *
     *  @param string $token -  restore token
     *  @return array status - fields:
     * 							token:  string - restore token
     *                          status: string - working | fault | success
     */
    function restoreBackupClose($token) {
    	require_once 'Restore.php';
    	$rs = new Restore($this);
    	if (PEAR::isError($rs)) {
    	    return $rs;
    	}
    	return $rs->closeRestore($token);
    }


    /*===================================================== auxiliary methods */
    /**
     *  Dummy method - only returns Campcaster version
     *
     *  @return string
     */
    function getVersion()
    {
        //return $this->config['version'];
        return LS_VERSION;
    }

} // class LocStor
?>