* This file is part of Pydio.
*
* Pydio is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* Pydio is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with Pydio. If not, see .
*
* The latest code can be found at .
*/
namespace Pydio\Core\Serializer;
use Pydio\Access\Core\IAjxpWrapperProvider;
use Pydio\Access\Core\Model\AJXP_Node;
use Pydio\Core\Utils\Vars\XMLFilter;
use Pydio\Core\Model\ContextInterface;
use Pydio\Core\PluginFramework\PluginsService;
use Pydio\Core\Services\ConfService;
use Pydio\Core\Services\UsersService;
use Pydio\Core\Services\ApplicationState;
use Pydio\Core\Utils\Vars\StringHelper;
use Pydio\Core\Utils\XMLHelper;
defined('AJXP_EXEC') or die('Access not allowed');
/**
* Class UserXML
* @package Pydio\Core\Serializer
*/
class UserXML
{
/**
* List all bookmmarks as XML
* @static
* @param $allBookmarks
* @param ContextInterface $context
* @param bool $print
* @param string $format legacy|node_list
* @return string
*/
public static function writeBookmarks($allBookmarks, $context, $print = true, $format = "legacy")
{
$driver = false;
$repository = $context->getRepository();
if ($format == "node_list") {
$driver = $repository->getDriverInstance($context);
if (!($driver instanceof IAjxpWrapperProvider)) {
$driver = false;
}
}
$buffer = "";
foreach ($allBookmarks as $bookmark) {
$path = "";
$title = "";
if (is_array($bookmark)) {
$path = $bookmark["PATH"];
$title = $bookmark["TITLE"];
} else if (is_string($bookmark)) {
$path = $bookmark;
$title = basename($bookmark);
}
if ($format == "node_list") {
if ($driver) {
$node = new AJXP_Node($context->getUrlBase() . $path);
$buffer .= NodeXML::toXML($node, true);
} else {
$buffer .= NodeXML::toNode($path, $title, false, array('icon' => "mime_empty.png"), true);
}
} else {
$buffer .= "";
}
}
if ($print) {
print $buffer;
return null;
} else {
return $buffer;
}
}
/**
* Extract all the user data and put it in XML
* @param ContextInterface $ctx
* @return string
*/
public function serialize(ContextInterface $ctx)
{
$buffer = "";
$loggedUser = $ctx->getUser();
$currentRepoId = $ctx->getRepositoryId();
$confDriver = ConfService::getConfStorageImpl();
if (!UsersService::usersEnabled()) {
$buffer.="";
$buffer.="";
$buffer.= $this->writeRepositoriesData($ctx);
$buffer.="";
} else if ($loggedUser !== null) {
$lock = $loggedUser->getLock();
$buffer.="getId())."\">";
$buffer.="canWrite($currentRepoId)?"1":"0")."\" read=\"".($loggedUser->canRead($currentRepoId)?"1":"0")."\"/>";
$buffer.= $this->writeRepositoriesData($ctx);
$buffer.="";
$preferences = $confDriver->getExposedPreferences($loggedUser);
foreach ($preferences as $prefName => $prefData) {
$atts = "";
if (isSet($prefData["exposed"]) && $prefData["exposed"] == true) {
foreach ($prefData as $k => $v) {
if($k=="name") continue;
if($k == "value") $k = "default";
$atts .= "$k='$v' ";
}
}
if (isset($prefData["pluginId"])) {
$atts .= "pluginId='".$prefData["pluginId"]."' ";
}
if ($prefData["type"] == "string") {
$buffer.="";
} else if ($prefData["type"] == "json") {
$buffer.="";
}
}
$buffer.="";
$buffer.="isAdmin()?"1":"0")."\" ".($lock!==false?"lock=\"$lock\"":"")."/>";
$buffer.="";
}
return $buffer;
}
/**
* Write the repositories access rights in XML format
* @static
* @param ContextInterface $ctx
* @return string
*/
protected function writeRepositoriesData(ContextInterface $ctx)
{
$loggedUser = $ctx->getUser();
$accessible = UsersService::getRepositoriesForUser($loggedUser);
$streams = PluginsService::detectRepositoriesStreams($accessible);
$exposed = PluginsService::searchManifestsWithCache("//server_settings/param[contains(@scope,'repository') and @expose='true']", function($nodes){
$exposedNodes = [];
/** @var \DOMElement $exposed_prop */
foreach($nodes as $exposed_prop){
$pluginId = $exposed_prop->parentNode->parentNode->getAttribute("id");
$paramName = $exposed_prop->getAttribute("name");
$paramDefault = $exposed_prop->getAttribute("default");
$exposedNodes[] = array("PLUGIN_ID" => $pluginId, "NAME" => $paramName, "DEFAULT" => $paramDefault);
}
return $exposedNodes;
});
$repoSerializer = new RepositoryXML($exposed, $streams, $loggedUser);
$st = "";
$inboxStatus = 0;
foreach($accessible as $repoId => $repoObject){
if(!$repoObject->hasContentFilter()) {
continue;
}
$accessStatus = $repoObject->getAccessStatus();
if(empty($accessStatus) && $loggedUser != null){
$lastConnected = $loggedUser->getArrayPref("repository_last_connected", $repoId);
if(empty($lastConnected)){
$accessStatus = 1;
}
}
if(!empty($accessStatus)){
$inboxStatus ++;
}
}
foreach ($accessible as $repoId => $repoObject) {
if(!ApplicationState::hasMinisiteHash() && $repoObject->hasContentFilter()){
continue;
}
$accessStatus = '';
if($repoObject->getAccessType() == "inbox"){
$accessStatus = $inboxStatus;
}
$xmlString = $repoSerializer->serialize($repoObject, $repoId === $ctx->getRepositoryId(), $accessStatus);
$st .= $xmlString;
}
$st .= "";
return $st;
}
}