<?php
/*
 * Copyright 2007-2017 Charles du Jeu - Abstrium SAS <team (at) pyd.io>
 * 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 <http://www.gnu.org/licenses/>.
 *
 * The latest code can be found at <https://pydio.com>.
 */
namespace Pydio\Notification\Core;

use Pydio\Access\Core\Model\AJXP_Node;
use Pydio\Core\Model\ContextProviderInterface;

use Pydio\Core\Services\LocaleService;
use Pydio\Core\Services\RepositoryService;
use Pydio\Core\Services\UsersService;
use Pydio\Core\Services\ApplicationState;
use Pydio\Core\Utils\Vars\StatHelper;

use Pydio\Log\Core\Logger;

defined('AJXP_EXEC') or die( 'Access not allowed');

define('AJXP_NOTIF_NODE_ADD', "add");
define('AJXP_NOTIF_NODE_DEL', "delete");
define('AJXP_NOTIF_NODE_CHANGE', "change");
define('AJXP_NOTIF_NODE_RENAME', "rename");
define('AJXP_NOTIF_NODE_VIEW', "view");
define('AJXP_NOTIF_NODE_COPY', "copy");
define('AJXP_NOTIF_NODE_MOVE', "move");
define('AJXP_NOTIF_NODE_COPY_TO', "copy_to");
define('AJXP_NOTIF_NODE_MOVE_TO', "move_to");
define('AJXP_NOTIF_NODE_COPY_FROM', "copy_from");
define('AJXP_NOTIF_NODE_MOVE_FROM', "move_from");
/**
 * Simple properties container
 * @package AjaXplorer_Plugins
 * @subpackage Core
 */
class Notification implements ContextProviderInterface
{

    /**
     * @var AJXP_Node
     */
    public $node;
    /**
     * @var String
     */
    public $action;
    /**
     * @var String
     */
    public $author;
    /**
     * @var String
     */
    public $authorTemporaryLabel;
    /**
     * @var int
     */
    public $date;
    /**
     * @var string;
     */
    public $target;

    /**
     * @var \Pydio\Access\Core\Model\AJXP_Node
     */
    public $secondaryNode;

    /**
     * @var Notification[]
     */
    public $relatedNotifications;

    public static $usersCaches = array();

    /**
     * @var string A hint about the current context (workspace, shared minisite, etc..)
     */
    private $locationType;

    public static function autoload()
    {
    }

    /**
     * @param $string
     * @return string
     */
    protected function getRoot($string)
    {
        if(empty($string)) return "/";
        return $string;
    }

    /**
     * @param $tplString
     * @param $mess
     * @param bool $rich
     * @return mixed
     */
    protected function replaceVars($tplString, $mess, $rich = true)
    {
        $repoId = $this->getNode()->getRepositoryId();
        $repoObject = RepositoryService::getRepositoryById($repoId);
        if ($repoObject != null) {
            $repoLabel = $repoObject->getDisplay();
        } else {
            $repoLabel = "Repository";
        }
        $uLabel = "";
        if (strstr($tplString, "AJXP_USER") !== false){
            $uLabel = $this->getAuthorLabel();
        }

        $em = ($rich ? "<em>" : "");
        $me = ($rich ? "</em>" : "");

        $replaces = array(
            "AJXP_NODE_PATH"        => $em.$this->getRoot($this->getNode()->getPath()).$me,
            "AJXP_NODE_LABEL"       => $em.$this->getNode()->getLabel().$me,
            "AJXP_PARENT_PATH"      => $em.$this->getRoot(dirname($this->getNode()->getPath())).$me,
            "AJXP_PARENT_LABEL"     => $em.$this->getRoot(basename(dirname($this->getNode()->getPath()))).$me,
            "AJXP_REPOSITORY_ID"    => $em.$repoId.$me,
            "AJXP_REPOSITORY_LABEL" => $em.$repoLabel.$me,
            "AJXP_LINK"             => $this->getMainLink(),
            "AJXP_USER"             => $uLabel,
            "AJXP_DATE"             => StatHelper::relativeDate($this->getDate(), $mess),
        );

        if($replaces["AJXP_NODE_LABEL"]==$em.$me || $replaces["AJXP_NODE_LABEL"] == $em."/".$me ){
            $replaces["AJXP_NODE_LABEL"] = $replaces["AJXP_REPOSITORY_LABEL"];
        }
        if($replaces["AJXP_PARENT_LABEL"] == $em.$me || $replaces["AJXP_PARENT_LABEL"] == $em."/".$me ){
            $replaces["AJXP_PARENT_LABEL"] = $replaces["AJXP_REPOSITORY_LABEL"];
        }
        if((strstr($tplString, "AJXP_TARGET_FOLDER") !== false || strstr($tplString, "AJXP_SOURCE_FOLDER")) &&
            isSet($this->secondaryNode)
        ){
            $p = $this->secondaryNode->getPath();
            if($this->secondaryNode->isLeaf()) $p = $this->getRoot(dirname($p));
            $replaces["AJXP_TARGET_FOLDER"] = $replaces["AJXP_SOURCE_FOLDER"] =  $em.$p.$me;
        }

        if ((strstr($tplString, "AJXP_TARGET_LABEL") !== false || strstr($tplString, "AJXP_SOURCE_LABEL") !== false ) && isSet($this->secondaryNode) ) {
            $replaces["AJXP_TARGET_LABEL"] = $replaces["AJXP_SOURCE_LABEL"] = $em.$this->secondaryNode->getLabel().$me;
        }

        return str_replace(array_keys($replaces), array_values($replaces), $tplString);
    }

    /**
     * @return string
     */
    public function getMainLink()
    {
        if(ApplicationState::hasMinisiteHash() && class_exists("\\Pydio\\Share\\ShareCenter")){
            $hash = ApplicationState::getMinisiteHash();
            $shareCenter = \Pydio\Share\ShareCenter::getShareCenter($this->getContext());
            if(!empty($shareCenter)){
                return $shareCenter->getPublicAccessManager()->buildPublicLink($hash);
            }
        }
        return ApplicationState::getWorkspaceShortcutURL($this->getNode()->getRepository()) .$this->getNode()->getPath();
    }

    /**
     * @return string
     */
    public function getDescriptionShort()
    {
        $mess = LocaleService::getMessages();
        $tpl = $mess["notification.tpl.short.".($this->getNode()->isLeaf()?"file":"folder").".".$this->action];
        return $this->replaceVars($tpl, $mess, false);
    }

    /**
     * @return string
     */
    public function getDescriptionBlock()
    {
        $mess = LocaleService::getMessages();
        $tpl = $mess["notification.tpl.block.".($this->getNode()->isLeaf()?"file":"folder").".".$this->action];
        return $this->replaceVars($tpl, $mess, false);
    }

    /**
     * @param bool $skipLink
     * @return string
     */
    public function getDescriptionLong($skipLink = false)
    {
        $mess = LocaleService::getMessages();
        $tpl = "";
        if(!$skipLink){
            $tpl = "[".$this->getDescriptionLocation()."] ";
        }

        if (is_array($this->relatedNotifications) && count($this->relatedNotifications) == 1 && $this->relatedNotifications[0]->getNode()->getUrl() != $this->getNode()->getUrl()){

            $key = "notification.tpl.group.".($this->getNode()->isLeaf()?"file":"folder").".".$this->action;
            $tpl .= $this->replaceVars($mess[$key], $mess).": ";
            $tpl .= "".lcfirst($this->relatedNotifications[0]->getDescriptionLong(true)).".";

        }else if (is_array($this->relatedNotifications) && count($this->relatedNotifications) > 1) {

            $key = "notification.tpl.group.".($this->getNode()->isLeaf()?"file":"folder").".".$this->action;
            $tpl .= $this->replaceVars($mess[$key], $mess).": ";
            $tpl .= "<ul>";
            foreach ($this->relatedNotifications as $relatedNotification) {
                $tpl .= "<li>".$relatedNotification->getDescriptionLong(true)."</li>";
            }
            $tpl .= "</ul>";

        } else {
            $tpl .= $this->replaceVars($mess["notification.tpl.long.".($this->getNode()->isLeaf()?"file":"folder").".".$this->action], $mess);

        }
        if (!$skipLink) {
            $tpl .= "<br><br>".$this->replaceVars($mess["notification.tpl.long.ajxp_link"], $mess);
        }
        return $tpl;
    }

    /**
     * @return mixed
     */
    public function getDescriptionLocation(){
        $mess = LocaleService::getMessages();
        if(!isSet($this->locationType)){
            $this->computeLocationType();
        }
        return $this->replaceVars($mess["notification.tpl.location.".$this->locationType], $mess);
    }

    private function computeLocationType(){

        $type = "workspace.normal";
        $repo = $this->getNode()->getRepository();
        $crtUserId = "shared";
        $crtUser = $this->getNode()->hasUser() ? $this->getNode()->getUser() : null;
        if($crtUser != null) $crtUserId = $crtUser->getId();
        if(ApplicationState::hasMinisiteHash()){
            if($repo->hasContentFilter()){
                $type = "minisite.file";
            }else{
                $type = "minisite.folder";
            }
        }else if($repo->hasOwner() && $repo->getOwner() != $crtUserId){
            if($repo->hasContentFilter()){
                $type = "workspace.shared.file";
            }else{
                $type = "workspace.shared.folder";
            }
        }

        $this->locationType = $type;
    }

    /**
     * @param $action
     */
    public function setAction($action)
    {
        $this->action = $action;
    }

    /**
     * @return String
     */
    public function getAction()
    {
        return $this->action;
    }

    /**
     * @param $author
     */
    public function setAuthor($author)
    {
        $this->author = $author;
    }

    /**
     * @return String
     */
    public function getAuthor()
    {
        return $this->author;
    }

    /**
     * @return mixed|String
     * @throws \Pydio\Core\Exception\UserNotFoundException
     */
    public function getAuthorLabel(){
        if (array_key_exists($this->getAuthor(), self::$usersCaches)) {
            if(self::$usersCaches[$this->getAuthor()] != 'AJXP_USER_DONT_EXISTS'){
                $uLabel = self::$usersCaches[$this->getAuthor()];
            }
        } else if (UsersService::userExists($this->getAuthor())) {
            $obj = UsersService::getUserById($this->getAuthor(), false);
            if($obj->isHidden()){
                return $this->getPublicAuthorLabel();
            }
            $uLabel = $obj->getPersonalRole()->filterParameterValue("core.conf", "USER_DISPLAY_NAME", AJXP_REPO_SCOPE_ALL, "");
            self::$usersCaches[$this->getAuthor()] = $uLabel;
        } else{
            self::$usersCaches[$this->getAuthor()] = 'AJXP_USER_DONT_EXISTS';
        }
        if(!empty($uLabel)) return $uLabel;
        else return $this->getAuthor();
    }

    /**
     * @return mixed
     */
    protected function getPublicAuthorLabel(){
        $m = LocaleService::getMessages();
        if(!empty($this->authorTemporaryLabel)){
            return $this->authorTemporaryLabel . ' (' . Logger::getClientAdress().')';
        }else{
            return str_replace("%s", Logger::getClientAdress(), $m["notification.tpl.location.public_user"]);
        }
    }

    /**
     * @param $date
     */
    public function setDate($date)
    {
        $this->date = $date;
    }

    /**
     * @return int
     */
    public function getDate()
    {
        return $this->date;
    }

    /**
     * @param \Pydio\Access\Core\Model\AJXP_Node $node
     */
    public function setNode($node)
    {
        $this->node = $node;
        $this->computeLocationType();
    }

    /**
     * @return AJXP_Node
     */
    public function getNode()
    {
        if($this->node instanceof AJXP_Node && $this->node->getUserId() == null){
            $this->node->setUserId($this->getAuthor());
        }
        return $this->node;
    }

    /**
     * @param $secondaryNode
     */
    public function setSecondaryNode($secondaryNode)
    {
        $this->secondaryNode = $secondaryNode;
    }

    /**
     * @return AJXP_Node
     */
    public function getSecondaryNode()
    {
        return $this->secondaryNode;
    }

    /**
     * @param string $target
     */
    public function setTarget($target)
    {
        $this->target = $target;
    }

    /**
     * @return string
     */
    public function getTarget()
    {
        return $this->target;
    }

    /**
     * @param Notification $relatedNotification
     */
    public function addRelatedNotification($relatedNotification)
    {
        $this->relatedNotifications[] = $relatedNotification;
    }

    /**
     * @return Notification[]
     */
    public function getRelatedNotifications()
    {
        return $this->relatedNotifications;
    }

    /**
     * Returns a valid context
     * @return \Pydio\Core\Model\ContextInterface
     */
    public function getContext()
    {
        return $this->getNode()->getContext();
    }

    /**
     * @return String
     */
    public function getAuthorTemporaryLabel()
    {
        return $this->authorTemporaryLabel;
    }

    /**
     * @param String $authorTemporaryLabel
     */
    public function setAuthorTemporaryLabel($authorTemporaryLabel)
    {
        $this->authorTemporaryLabel = $authorTemporaryLabel;
    }
}