OwncloudFolder.class.php

<?php

class OwncloudFolder extends VirtualFolderType {

    protected $did_propfind = false;

    public static function availableInRange($range_id_or_object, $user_id)
    {
        return $range_id_or_object == 'OwnCloudPlugin';
    }

    public function isWritable($user_id)
    {
        return true;
    }

    public function isEditable($user_id)
    {
        return true;
    }

    public function isSubfolderAllowed($user_id)
    {
        return true;
    }

    public function isFileDownloadable($file_id, $user_id)
    {
        return true;
    }

    public function isFileEditable($fileref_or_id, $user_id)
    {
        return true;
    }

    public function isFileWritable($fileref_or_id, $user_id)
    {
        return true;
    }


    public function store()
    {        
        $old_id = $this->parent_id . '/' . rawurlencode($this->name);

        if ($this->getId() != $old_id) {

            $webdav = $this->getWebDavURL();
            $header = array();
            $header[] = "Authorization: Bearer ".\Owncloud\OAuth::getAccessToken();
            $header[] = "Destination: ". $webdav . $this->id;
    
            $r = curl_init();
            curl_setopt($r, CURLOPT_CUSTOMREQUEST, "MOVE");
            curl_setopt($r, CURLOPT_URL, $webdav . $old_id);
            curl_setopt($r, CURLOPT_HTTPHEADER, ($header));
            curl_setopt($r, CURLOPT_RETURNTRANSFER, 1);    
            curl_exec($r);
            $status = curl_getinfo($r, CURLINFO_HTTP_CODE);
            curl_close($r);

            return ($status >= 200) && ($status < 300);

        }
        return false;
    }

    public function delete()
    {
        return $this->deleteFile($this->id);
    }

    public function deleteFile($file_ref_id)
    {
        $webdav = $this->getWebDavURL();

        $header = array();
        $header[] = "Authorization: Bearer ".\Owncloud\OAuth::getAccessToken();

        $r = curl_init();
        curl_setopt($r, CURLOPT_CUSTOMREQUEST, "DELETE");
        curl_setopt($r, CURLOPT_URL, $webdav . $file_ref_id);
        curl_setopt($r, CURLOPT_HTTPHEADER, ($header));
        curl_setopt($r, CURLOPT_RETURNTRANSFER, 1);

        curl_exec($r);
        $status = curl_getinfo($r, CURLINFO_HTTP_CODE);
        curl_close($r);
        return ($status >= 200) && ($status < 300);
    }

    public function createFile($filedata)
    {       
        $webdav = $this->getWebDavURL();

        if ($this->fileExists($filedata['name'])) {
            if (strpos($filedata['name'], ".")) {
                $end = substr($filedata['name'], strpos($filedata['name'], "."));
                $name_raw = substr($filedata['name'], 0, strpos($filedata['name'], "."));
            } else {
                $name_raw = $filedata['name'];
            }
            $i = 0;
            do {
                $i++;
                $new_name = $name_raw."(".$i.").".$end;
            } while ($this->fileExists($new_name));
            $filedata['name'] = $new_name;
        }
        $file_ref_id = $this->id . (mb_strlen($this->id) ? '/' : '') . rawurlencode($filedata['name']);

        $header = array();
        $header[] = "Authorization: Bearer ".\Owncloud\OAuth::getAccessToken();

        $url_template = "[InternetShortcut]\nURL=%s";
        if (is_a($filedata, "File")) {
            if ($filedata->getURL()) {
                $data = $GLOBALS['TMP_PATH']."/file_".md5(uniqid());
                file_put_contents($data, sprintf($url_template, $filedata->getURL()));
                $file_ref_id .= ".url";
            } else {
                $data = $filedata->getPath();
            }
        } else {
            if ($filedata['url']) {
                $data = $GLOBALS['TMP_PATH']."/file_".md5(uniqid());
                file_put_contents($data, sprintf($url_template, $filedata['url']));
                $file_ref_id .= ".url";
            } else {
                $data = $filedata['tmp_name'];
            }
        }
        $fh_res = fopen($data, 'r');

        $r = curl_init();
        curl_setopt($r, CURLOPT_PUT, 1);
        curl_setopt($r, CURLOPT_URL, $webdav . $file_ref_id);
        curl_setopt($r, CURLOPT_HTTPHEADER, ($header));
        curl_setopt($r, CURLOPT_INFILE, $fh_res);
        curl_setopt($r, CURLOPT_INFILESIZE, filesize($data));        
        curl_setopt($r, CURLOPT_RETURNTRANSFER, 1);
        curl_exec($r);
        $status = curl_getinfo($r, CURLINFO_HTTP_CODE);
        curl_close($r);
        fclose($fh_res);

        $plugin = PluginManager::getInstance()->getPlugin("OwnCloudPlugin");
        return $plugin->getPreparedFile($file_ref_id);
    }

    public function copyFile($file_ref_id)
    {
        $webdav = $this->getWebDavURL();
        
        $tmp_parts = explode('/', $file_ref_id);

        $name = end($tmp_parts);
        if ($this->fileExists($name)) {
            if (strpos($name, ".")) {
                $end = substr($name, strpos($name, "."));
                $name_raw = substr($name, 0, strpos($name, "."));
            } else {
                $name_raw = $name;
            }
            $i = 0;
            do {
                $i++;
                $new_name = $name_raw."(".$i.").".$end;
            } while ($this->fileExists($new_name));
            $name = $new_name;
        }

        $destination = $this->id . (mb_strlen($this->id) ? '/' : '') . rawurlencode($name);

        $header = array();
        $header[] = "Authorization: Bearer ".\Owncloud\OAuth::getAccessToken();
        $header[] = "Destination: ". $webdav . $destination;

        $r = curl_init();
        curl_setopt($r, CURLOPT_CUSTOMREQUEST, "COPY");
        curl_setopt($r, CURLOPT_URL, $webdav . $file_ref_id);
        curl_setopt($r, CURLOPT_HTTPHEADER, ($header));
        curl_setopt($r, CURLOPT_RETURNTRANSFER, 1);  

        curl_exec($r);
        $status = curl_getinfo($r, CURLINFO_HTTP_CODE);
        curl_close($r);

        $plugin = PluginManager::getInstance()->getPlugin("OwnCloudPlugin");
        return $plugin->getPreparedFile($destination);
    }

    public function moveFile($file_ref_id)
    {
        $webdav = $this->getWebDavURL();

        $tmp_parts = explode('/', $file_ref_id);

        $name = end($tmp_parts);
        if ($this->fileExists($name)) {
            if (strpos($name, ".")) {
                $end = substr($name, strpos($name, "."));
                $name_raw = substr($name, 0, strpos($name, "."));
            } else {
                $name_raw = $name;
            }
            $i = 0;
            do {
                $i++;
                $new_name = $name_raw."(".$i.").".$end;
            } while ($this->fileExists($new_name));
            $name = $new_name;
        }
        $destination = $this->id . (mb_strlen($this->id)?'/':'') . rawurlencode($name);

        $header = array();
        $header[] = "Authorization: Bearer ".\Owncloud\OAuth::getAccessToken();
        $header[] = "Destination: ". $webdav . $destination;

        $r = curl_init();
        curl_setopt($r, CURLOPT_CUSTOMREQUEST, "MOVE");
        curl_setopt($r, CURLOPT_URL, $webdav . $file_ref_id);
        curl_setopt($r, CURLOPT_HTTPHEADER, ($header));
        curl_setopt($r, CURLOPT_RETURNTRANSFER, 1);

        curl_exec($r);
        $status = curl_getinfo($r, CURLINFO_HTTP_CODE);
        curl_close($r);

        $plugin = PluginManager::getInstance()->getPlugin("OwnCloudPlugin");
        return $plugin->getPreparedFile($destination);
    }

    public function editFile($file_ref_id, $name = null, $description = null,  $content_terms_of_use_id = null)
    {
        if (!$name) {
            return false;
        }
        
        $webdav = $this->getWebDavURL();
        if ($this->fileExists(rawurlencode($name))) {
            if (strpos($name, ".")) {
                $end = substr($name, strpos($name, "."));
                $name_raw = substr($name, 0, strpos($name, "."));
            } else {
                $name_raw = $name;
            }
            $i = 0;
            do {
                $i++;
                $new_name = $name_raw."(".$i.").".$end;
            } while ($this->fileExists(rawurlencode($new_name)));
            $name = $new_name;
        }
        $destination = $this->id . (mb_strlen($this->id)?'/':'') . rawurlencode($name);

        $header = array();
        $header[] = "Authorization: Bearer ".\Owncloud\OAuth::getAccessToken();
        $header[] = "Destination: ". $webdav . $destination;

        $r = curl_init();
        curl_setopt($r, CURLOPT_CUSTOMREQUEST, "MOVE");
        curl_setopt($r, CURLOPT_URL, $webdav . $file_ref_id);
        curl_setopt($r, CURLOPT_HTTPHEADER, ($header));
        curl_setopt($r, CURLOPT_RETURNTRANSFER, 1);

        curl_exec($r);
        $status = curl_getinfo($r, CURLINFO_HTTP_CODE);
        curl_close($r);
        
        $plugin = PluginManager::getInstance()->getPlugin("OwnCloudPlugin");
        return $plugin->getPreparedFile($destination);
    }

    public function createSubfolder(FolderType $foldertype)
    {
        $webdav = $this->getWebDavURL();

        if ($foldertype->getId()) {
            $name = explode('/', $foldertype->getId());
            $name = end($name);
        } else {
            $name = rawurlencode($foldertype->name);
        }
        if ($this->folderExists($name)) {
            $name_raw = $name;
            $i = 0;
            do {
                $i++;
                $new_name = $name_raw."(".$i.")";
            } while ($this->folderExists($new_name));
            $name = $new_name;
        }
        $destination = $this->id . (mb_strlen($this->id)?'/':'') . $name;

        $header = array();
        $header[] = "Authorization: Bearer ".\Owncloud\OAuth::getAccessToken();

        $r = curl_init();

        curl_setopt($r, CURLOPT_CUSTOMREQUEST, "MKCOL");
        curl_setopt($r, CURLOPT_URL, $webdav . $destination);
        curl_setopt($r, CURLOPT_HTTPHEADER, ($header));
        curl_setopt($r, CURLOPT_RETURNTRANSFER, 1);

        curl_exec($r);
        $status = curl_getinfo($r, CURLINFO_HTTP_CODE);
        curl_close($r);

        $plugin = PluginManager::getInstance()->getPlugin("OwnCloudPlugin");
        return (($status >= 200) && ($status < 300)) ? $plugin->getFolder($destination) : false;
    }

    protected function getWebDavURL()
    {
        $url = Config::get()->OWNCLOUD_ENDPOINT ?: UserConfig::get($GLOBALS['user']->id)->OWNCLOUD_ENDPOINT;
        if ($url[strlen($url) - 1] !== "/") {
            $url .= "/";
        }
        $webdav = $url . "remote.php/webdav/";
        return $webdav;
    }

    protected function fetchObjects()
    {
        if ($this->did_propfind === true) {
            return;
        }
        $webdav = $this->getWebDavURL();
        $root = "remote.php/webdav/".$this->id;


        $header = array();
        $header[] = "Authorization: Bearer ".\Owncloud\OAuth::getAccessToken();
        $header[] = "Depth: 1";

        $r = curl_init();
        curl_setopt($r, CURLOPT_CUSTOMREQUEST, "PROPFIND");
        curl_setopt($r, CURLOPT_URL, $webdav . $this->id);
        curl_setopt($r, CURLOPT_HTTPHEADER, ($header));
        curl_setopt($r, CURLOPT_RETURNTRANSFER, 1);

        $xml = curl_exec($r);
        curl_close($r);

        if (!$xml) {
            PageLayout::postError(_("Konnte keine Daten von OwnCloud bekommen."));
            $this->subfolders = array();
            $this->files = array();
            $this->did_propfind = true;
            return;
        }

        $doc = new DOMDocument();
        $doc->loadXML($xml);

        foreach ($doc->getElementsByTagNameNS("DAV:","response") as $file) {
            //response
            //  -> href
            //  -> propstat
            //    -> prop
            //      -> resourcetype
            //      -> getcontentlength
            //      -> getcontenttype
            //      -> getlastmodified
            //    -> status
            $file_attributes = array();

            foreach ($file->childNodes as $node) {
                if (strtolower($node->tagName) === "d:href") {
                    $nodeValue = $node->nodeValue;
                    if ($nodeValue[strlen($nodeValue) - 1] === "/") {
                        $nodeValue = substr($nodeValue, 0, -1);
                    }
                    if ($nodeValue[0] === "/") {
                        $nodeValue = substr($nodeValue, 1);
                    }
                    $nodeValue = str_replace(array("(", ")", "'", "$", "+", "!", "*", ","), array("%28", "%29", "%27", "%24", "%2B", "%21", "%2A", "%2C"), $nodeValue); //for Owncloud only
                    if (strpos(rawurldecode($nodeValue), rawurldecode($root)) !== false) {
                        $path = substr($nodeValue, strpos(rawurldecode($nodeValue), rawurldecode($root)) + strlen($root));
                    } else {
                        $path = null;
                    }
                    $path_array = preg_split("/\//", $path, 0, PREG_SPLIT_NO_EMPTY);
                    $file_attributes['name'] = rawurldecode(array_pop($path_array));
                    if (!trim($file_attributes['name']) || ($path === $this->id) || !$path) {
                        continue 2;
                    }
                }
                if (strtolower($node->tagName) === "d:propstat") {
                    foreach ($node->childNodes as $prop) {
                        if ($prop->childNodes) {
                            foreach ($prop->childNodes as $attr) {
                                if (strtolower($attr->tagName) === "d:resourcetype") {
                                    $file_attributes['type'] = $attr->childNodes[0] && strtolower($attr->childNodes[0]->tagName) === "d:collection" ? "folder" : "file";
                                }
                                if (strtolower($attr->tagName) === "d:getcontentlength") {
                                    $file_attributes['size'] = $attr->nodeValue;
                                }
                                if (strtolower($attr->tagName) === "d:getcontenttype") {
                                    $file_attributes['contenttype'] = $attr->nodeValue;
                                }
                                if (strtolower($attr->tagName) === "d:creationdate") {
                                    $file_attributes['chdate'] = strtotime($attr->nodeValue);
                                }
                                if (strtolower($attr->tagName) === "d:displayname") {
                                    $file_attributes['name'] = $attr->nodeValue;
                                }
                                if (strtolower($attr->tagName) === "d:getlastmodified") {
                                    $file_attributes['chdate'] = strtotime($attr->nodeValue);
                                }
                            }
                        }
                    }
                }
            }
            if (trim($file_attributes['name'])) {
                if ($file_attributes['type'] === "folder") {
                    $this->subfolders[] = new OwncloudFolder(array(
                        'id' => ($this->id ? $this->id . "/" : "") . rawurlencode($file_attributes['name']),
                        'name' => $file_attributes['name'],
                        'parent_id' => $this->id,
                        'range_type' => $this->plugin_id,
                        'range_id' => 'OwnCloudPlugin'
                    ), $this->plugin_id);
                } else {
                    $content_type = $file_attributes['contenttype'] ?: get_mime_type($file_attributes['name']);
                    $this->files[] = (object) array(
                        'id' => ($this->id ? $this->id . "/" : "") . rawurlencode($file_attributes['name']),
                        'name' => $file_attributes['name'],
                        'size' => $file_attributes['size'],
                        'mime_type' => $content_type,
                        'description' => "",
                        'chdate' => $file_attributes['chdate'],
                        'download_url' => URLHelper::getURL("plugins.php/owncloudplugin/download/" . ($this->id ? $this->id . "/" : "") . $file_attributes['name'])
                    );
                }
            }
        }
        $this->did_propfind = true;
    }

    public function getFiles()
    {
        $this->fetchObjects();
        return $this->files;
    }

    public function getSubfolders()
    {
        $this->fetchObjects();
        return $this->subfolders;
    }

    public function setDataFromEditTemplate($request)
    {

        if (!$request['name']) {
            return MessageBox::error(_('Die Bezeichnung des Ordners fehlt.'));
        }

        $plugin = PluginEngine::getPlugin($request["from_plugin"]);
    
        if (empty($request['parent_id'])) {
            $this->folderdata['id'] = $request['name'];
        } else {
            $this->folderdata['id'] = $request['parent_id'] . '/' . $request['name'];
        }        
        $this->folderdata['parent_id'] = $request['parent_id'];
        $this->folderdata['range_type'] = $plugin->getPluginId();
        $this->folderdata['range_id'] = $plugin->getPluginName();
        $this->folderdata['plugin_id'] = $plugin->getPluginId();
        return $this;
    }

    public function getParent()
    {
        if ($this->id == $this->parent_id) {
            return null;
        }
        $plugin = PluginEngine::getPlugin('OwnCloudPlugin');
        return $plugin->getFolder($this->parent_id);
    }

    public function fileExists($name)
    {
        foreach ($this->getFiles() as $file) {
            if ($file->name === $name) {
                return true;
            }
        }
        return false;
    }

    public function folderExists($name)
    {
        foreach ($this->getSubfolders() as $folder) {
            if ($folder->name === $name) {
                return true;
            }
        }
        return false;
    }

}