mirror of
				https://github.com/getgrav/grav-plugin-admin.git
				synced 2025-10-31 18:35:57 +01:00 
			
		
		
		
	
		
			
				
	
	
		
			1841 lines
		
	
	
		
			49 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
			
		
		
	
	
			1841 lines
		
	
	
		
			49 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
| <?php
 | |
| namespace Grav\Plugin\Admin;
 | |
| 
 | |
| use DateTime;
 | |
| use Grav\Common\Data;
 | |
| use Grav\Common\File\CompiledYamlFile;
 | |
| use Grav\Common\GPM\GPM;
 | |
| use Grav\Common\GPM\Licenses;
 | |
| use Grav\Common\GPM\Response;
 | |
| use Grav\Common\Grav;
 | |
| use Grav\Common\Language\LanguageCodes;
 | |
| use Grav\Common\Page\Collection;
 | |
| use Grav\Common\Page\Page;
 | |
| use Grav\Common\Page\Pages;
 | |
| use Grav\Common\Plugins;
 | |
| use Grav\Common\Security;
 | |
| use Grav\Common\Themes;
 | |
| use Grav\Common\Uri;
 | |
| use Grav\Common\User\User;
 | |
| use Grav\Common\Utils;
 | |
| use Grav\Framework\Collection\ArrayCollection;
 | |
| use Grav\Plugin\Admin\Twig\AdminTwigExtension;
 | |
| use Grav\Plugin\Login\Login;
 | |
| use Grav\Plugin\Login\TwoFactorAuth\TwoFactorAuth;
 | |
| use RocketTheme\Toolbox\Event\Event;
 | |
| use RocketTheme\Toolbox\File\File;
 | |
| use RocketTheme\Toolbox\File\JsonFile;
 | |
| use RocketTheme\Toolbox\ResourceLocator\UniformResourceIterator;
 | |
| use RocketTheme\Toolbox\ResourceLocator\UniformResourceLocator;
 | |
| use RocketTheme\Toolbox\Session\Message;
 | |
| use RocketTheme\Toolbox\Session\Session;
 | |
| use Grav\Common\Yaml;
 | |
| use Composer\Semver\Semver;
 | |
| use PicoFeed\Reader\Reader;
 | |
| 
 | |
| define('LOGIN_REDIRECT_COOKIE', 'grav-login-redirect');
 | |
| 
 | |
| class Admin
 | |
| {
 | |
|     const MEDIA_PAGINATION_INTERVAL = 20;
 | |
|     const TMP_COOKIE_NAME = 'tmp-admin-message';
 | |
| 
 | |
|     /**
 | |
|      * @var Grav
 | |
|      */
 | |
|     public $grav;
 | |
|     /**
 | |
|      * @var string
 | |
|      */
 | |
|     public $base;
 | |
|     /**
 | |
|      * @var string
 | |
|      */
 | |
|     public $location;
 | |
|     /**
 | |
|      * @var string
 | |
|      */
 | |
|     public $route;
 | |
|     /**
 | |
|      * @var User
 | |
|      */
 | |
|     public $user;
 | |
|     /**
 | |
|      * @var array
 | |
|      */
 | |
|     public $forgot;
 | |
|     /**
 | |
|      * @var string
 | |
|      */
 | |
|     public $task;
 | |
|     /**
 | |
|      * @var array
 | |
|      */
 | |
|     public $json_response;
 | |
|     /**
 | |
|      * @var Uri $uri
 | |
|      */
 | |
|     protected $uri;
 | |
|     /**
 | |
|      * @var array
 | |
|      */
 | |
|     protected $pages = [];
 | |
|     /**
 | |
|      * @var Session
 | |
|      */
 | |
|     protected $session;
 | |
|     /**
 | |
|      * @var Data\Blueprints
 | |
|      */
 | |
|     protected $blueprints;
 | |
|     /**
 | |
|      * @var GPM
 | |
|      */
 | |
|     protected $gpm;
 | |
| 
 | |
|     /**
 | |
|      * @var int
 | |
|      */
 | |
|     protected $pages_count;
 | |
| 
 | |
|     /**
 | |
|      * @var array
 | |
|      */
 | |
|     protected $permissions;
 | |
| 
 | |
|     /**
 | |
|      * @var bool
 | |
|      */
 | |
|     protected $load_additional_files_in_background = false;
 | |
| 
 | |
|     /**
 | |
|      * @var bool
 | |
|      */
 | |
|     protected $loading_additional_files_in_background = false;
 | |
| 
 | |
|     /**
 | |
|      * @var array
 | |
|      */
 | |
|     protected $temp_messages = [];
 | |
| 
 | |
|     /**
 | |
|      * Constructor.
 | |
|      *
 | |
|      * @param Grav   $grav
 | |
|      * @param string $base
 | |
|      * @param string $location
 | |
|      * @param string $route
 | |
|      */
 | |
|     public function __construct(Grav $grav, $base, $location, $route)
 | |
|     {
 | |
|         // Register admin to grav because of calling $grav['user'] requires it.
 | |
|         $grav['admin']     = $this;
 | |
| 
 | |
|         $this->grav        = $grav;
 | |
|         $this->base        = $base;
 | |
|         $this->location    = $location;
 | |
|         $this->route       = $route;
 | |
|         $this->uri         = $grav['uri'];
 | |
|         $this->session     = $grav['session'];
 | |
|         $this->user        = $grav['user'];
 | |
|         $this->permissions = [];
 | |
|         $language          = $grav['language'];
 | |
| 
 | |
|         // Load utility class
 | |
|         if ($language->enabled()) {
 | |
|             $this->multilang         = true;
 | |
|             $this->languages_enabled = $this->grav['config']->get('system.languages.supported', []);
 | |
| 
 | |
|             //Set the currently active language for the admin
 | |
|             $language = $this->grav['uri']->param('lang');
 | |
|             if (!$language) {
 | |
|                 if (!$this->session->admin_lang) {
 | |
|                     $this->session->admin_lang = $this->grav['language']->getLanguage();
 | |
|                 }
 | |
|                 $language = $this->session->admin_lang;
 | |
|             }
 | |
|             $this->grav['language']->setActive($language ?: 'en');
 | |
|         } else {
 | |
|             $this->grav['language']->setActive('en');
 | |
|             $this->multilang = false;
 | |
|         }
 | |
| 
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Return the languages available in the admin
 | |
|      *
 | |
|      * @return array
 | |
|      */
 | |
|     public static function adminLanguages()
 | |
|     {
 | |
|         $languages = [];
 | |
| 
 | |
|         $path = Grav::instance()['locator']->findResource('plugins://admin/languages');
 | |
| 
 | |
|         /** @var \DirectoryIterator $directory */
 | |
|         foreach (new \DirectoryIterator($path) as $file) {
 | |
|             if ($file->isDir() || $file->isDot() || Utils::startsWith($file->getFilename(), '.')) {
 | |
|                 continue;
 | |
|             }
 | |
| 
 | |
|             $lang = $file->getBasename('.yaml');
 | |
| 
 | |
|             $languages[$lang] = LanguageCodes::getNativeName($lang);
 | |
| 
 | |
|         }
 | |
| 
 | |
|         // sort languages
 | |
|         asort($languages);
 | |
| 
 | |
|         return $languages;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Return the found configuration blueprints
 | |
|      *
 | |
|      * @return array
 | |
|      */
 | |
|     public static function configurations()
 | |
|     {
 | |
|         $configurations = [];
 | |
| 
 | |
|         /** @var UniformResourceIterator $iterator */
 | |
|         $iterator = Grav::instance()['locator']->getIterator('blueprints://config');
 | |
| 
 | |
|         foreach ($iterator as $file) {
 | |
|             if ($file->isDir() || !preg_match('/^[^.].*.yaml$/', $file->getFilename())) {
 | |
|                 continue;
 | |
|             }
 | |
|             $configurations[] = $file->getBasename('.yaml');
 | |
|         }
 | |
| 
 | |
|         return $configurations;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Return the tools found
 | |
|      *
 | |
|      * @return array
 | |
|      */
 | |
|     public static function tools()
 | |
|     {
 | |
|         $tools = [];
 | |
|         Grav::instance()->fireEvent('onAdminTools', new Event(['tools' => &$tools]));
 | |
| 
 | |
|         return $tools;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Return the languages available in the site
 | |
|      *
 | |
|      * @return array
 | |
|      */
 | |
|     public static function siteLanguages()
 | |
|     {
 | |
|         $languages = [];
 | |
|         $lang_data = (array) Grav::instance()['config']->get('system.languages.supported', []);
 | |
| 
 | |
|         foreach ($lang_data as $index => $lang) {
 | |
|             $languages[$lang] = LanguageCodes::getNativeName($lang);
 | |
|         }
 | |
| 
 | |
|         return $languages;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Static helper method to return the admin form nonce
 | |
|      *
 | |
|      * @return string
 | |
|      */
 | |
|     public static function getNonce()
 | |
|     {
 | |
|         $action = 'admin-form';
 | |
| 
 | |
|         return Utils::getNonce($action);
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Static helper method to return the last used page name
 | |
|      *
 | |
|      * @return string
 | |
|      */
 | |
|     public static function getLastPageName()
 | |
|     {
 | |
|         return Grav::instance()['session']->lastPageName ?: 'default';
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Static helper method to return the last used page route
 | |
|      *
 | |
|      * @return string
 | |
|      */
 | |
|     public static function getLastPageRoute()
 | |
|     {
 | |
|         return Grav::instance()['session']->lastPageRoute ?: self::route();
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Static helper method to return current route.
 | |
|      *
 | |
|      * @return string
 | |
|      */
 | |
|     public static function route()
 | |
|     {
 | |
|         $pages = Grav::instance()['pages'];
 | |
|         $route = '/' . ltrim(Grav::instance()['admin']->route, '/');
 | |
| 
 | |
|         /** @var Page $page */
 | |
|         $page         = $pages->dispatch($route);
 | |
|         $parent_route = null;
 | |
|         if ($page) {
 | |
|             /** @var Page $parent */
 | |
|             $parent       = $page->parent();
 | |
|             $parent_route = $parent->rawRoute();
 | |
|         }
 | |
| 
 | |
|         return $parent_route;
 | |
|     }
 | |
| 
 | |
|     public static function getTempDir()
 | |
|     {
 | |
|         try {
 | |
|             $tmp_dir = Grav::instance()['locator']->findResource('tmp://', true, true);
 | |
|         } catch (\Exception $e) {
 | |
|             $tmp_dir = Grav::instance()['locator']->findResource('cache://', true, true) . '/tmp';
 | |
|         }
 | |
| 
 | |
|         return $tmp_dir;
 | |
|     }
 | |
| 
 | |
|     public static function getPageMedia()
 | |
|     {
 | |
|         $files = [];
 | |
|         $grav = Grav::instance();
 | |
| 
 | |
|         $pages = $grav['pages'];
 | |
|         $route = '/' . ltrim($grav['admin']->route, '/');
 | |
| 
 | |
|         /** @var Page $page */
 | |
|         $page         = $pages->dispatch($route);
 | |
|         $parent_route = null;
 | |
|         if ($page) {
 | |
|             $media = $page->media()->all();
 | |
|             $files = array_keys($media);
 | |
|         }
 | |
|         return $files;
 | |
| 
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Get current session.
 | |
|      *
 | |
|      * @return Session
 | |
|      */
 | |
|     public function session()
 | |
|     {
 | |
|         return $this->session;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Fetch and delete messages from the session queue.
 | |
|      *
 | |
|      * @param string $type
 | |
|      *
 | |
|      * @return array
 | |
|      */
 | |
|     public function messages($type = null)
 | |
|     {
 | |
|         /** @var Message $messages */
 | |
|         $messages = $this->grav['messages'];
 | |
| 
 | |
|         return $messages->fetch($type);
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Authenticate user.
 | |
|      *
 | |
|      * @param  array $credentials User credentials.
 | |
|      */
 | |
|     public function authenticate($credentials, $post)
 | |
|     {
 | |
|         /** @var Login $login */
 | |
|         $login = $this->grav['login'];
 | |
| 
 | |
|         // Remove login nonce from the form.
 | |
|         $credentials = array_diff_key($credentials, ['admin-nonce' => true]);
 | |
|         $twofa = $this->grav['config']->get('plugins.admin.twofa_enabled', false);
 | |
| 
 | |
|         $rateLimiter = $login->getRateLimiter('login_attempts');
 | |
|         
 | |
|         $userKey = (string)($credentials['username'] ?? '');
 | |
|         $ipKey = Uri::ip();
 | |
|         $redirect = $post['redirect'] ?? $this->base . $this->route;
 | |
| 
 | |
|         // Check if the current IP has been used in failed login attempts.
 | |
|         $attempts = count($rateLimiter->getAttempts($ipKey, 'ip'));
 | |
| 
 | |
|         $rateLimiter->registerRateLimitedAction($ipKey, 'ip')->registerRateLimitedAction($userKey);
 | |
| 
 | |
|         // Check rate limit for both IP and user, but allow each IP a single try even if user is already rate limited.
 | |
|         if ($rateLimiter->isRateLimited($ipKey, 'ip') || ($attempts && $rateLimiter->isRateLimited($userKey))) {
 | |
|             $this->setMessage(static::translate(['PLUGIN_LOGIN.TOO_MANY_LOGIN_ATTEMPTS', $rateLimiter->getInterval()]), 'error');
 | |
| 
 | |
|             $this->grav->redirect('/');
 | |
|         }
 | |
|         
 | |
|         // Fire Login process.
 | |
|         $event = $login->login(
 | |
|             $credentials,
 | |
|             ['admin' => true, 'twofa' => $twofa],
 | |
|             ['authorize' => 'admin.login', 'return_event' => true]
 | |
|         );
 | |
|         $user = $event->getUser();
 | |
| 
 | |
|         if ($user->authenticated) {
 | |
|             $rateLimiter->resetRateLimit($ipKey, 'ip')->resetRateLimit($userKey);
 | |
|             if ($user->authorized) {
 | |
|                 $event->defMessage('PLUGIN_ADMIN.LOGIN_LOGGED_IN', 'info');
 | |
| 
 | |
|                 $event->defRedirect($post['redirect'] ?? $redirect);
 | |
|             } else {
 | |
|                 $this->session->redirect = $redirect;
 | |
|             }
 | |
|         } else {
 | |
|             if ($user->authorized) {
 | |
|                 $event->defMessage('PLUGIN_LOGIN.ACCESS_DENIED', 'error');
 | |
|             } else {
 | |
|                 $event->defMessage('PLUGIN_LOGIN.LOGIN_FAILED', 'error');
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         $event->defRedirect($redirect);
 | |
| 
 | |
|         $message = $event->getMessage();
 | |
|         if ($message) {
 | |
|             $this->setMessage(static::translate($message), $event->getMessageType());
 | |
|         }
 | |
| 
 | |
|         $redirect = $event->getRedirect();
 | |
| 
 | |
|         $this->grav->redirect($redirect, $event->getRedirectCode());
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Check Two-Factor Authentication.
 | |
|      */
 | |
|     public function twoFa($data, $post)
 | |
|     {
 | |
|         /** @var Login $login */
 | |
|         $login = $this->grav['login'];
 | |
| 
 | |
|         /** @var TwoFactorAuth $twoFa */
 | |
|         $twoFa = $login->twoFactorAuth();
 | |
|         $user = $this->grav['user'];
 | |
| 
 | |
|         $code = $data['2fa_code'] ?? null;
 | |
| 
 | |
|         $secret = $user->twofa_secret ?? null;
 | |
| 
 | |
|         if (!$code || !$secret || !$twoFa->verifyCode($secret, $code)) {
 | |
|             $login->logout(['admin' => true]);
 | |
| 
 | |
|             $this->grav['session']->setFlashCookieObject(Admin::TMP_COOKIE_NAME, ['message' => $this->translate('PLUGIN_ADMIN.2FA_FAILED'), 'status' => 'error']);
 | |
| 
 | |
|             $this->grav->redirect($this->uri->route(), 303);
 | |
|         }
 | |
| 
 | |
|         $this->setMessage($this->translate('PLUGIN_ADMIN.LOGIN_LOGGED_IN'), 'info');
 | |
| 
 | |
|         $user->authorized = true;
 | |
| 
 | |
|         $this->grav->redirect($post['redirect']);
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Logout from admin.
 | |
|      */
 | |
|     public function logout($data, $post)
 | |
|     {
 | |
|         /** @var Login $login */
 | |
|         $login = $this->grav['login'];
 | |
| 
 | |
|         $event = $login->logout(['admin' => true], ['return_event' => true]);
 | |
| 
 | |
|         $event->defMessage('PLUGIN_ADMIN.LOGGED_OUT', 'info');
 | |
|         $message = $event->getMessage();
 | |
|         if ($message) {
 | |
|             $this->grav['session']->setFlashCookieObject(Admin::TMP_COOKIE_NAME, ['message' => $this->translate($message), 'status' => $event->getMessageType()]);
 | |
|         }
 | |
| 
 | |
|         $this->grav->redirect($this->base);
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * @return bool
 | |
|      */
 | |
|     public static function doAnyUsersExist()
 | |
|     {
 | |
|         // check for existence of a user account
 | |
|         $account_dir = $file_path = Grav::instance()['locator']->findResource('account://');
 | |
|         $user_check = glob($account_dir . '/*.yaml');
 | |
| 
 | |
|         return $user_check ? true : false;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Add message into the session queue.
 | |
|      *
 | |
|      * @param string $msg
 | |
|      * @param string $type
 | |
|      */
 | |
|     public function setMessage($msg, $type = 'info')
 | |
|     {
 | |
|         /** @var Message $messages */
 | |
|         $messages = $this->grav['messages'];
 | |
|         $messages->add($msg, $type);
 | |
|     }
 | |
| 
 | |
|     public function addTempMessage($msg, $type)
 | |
|     {
 | |
|         $this->temp_messages[] = ['message' => $msg, 'scope' => $type];
 | |
|     }
 | |
| 
 | |
|     public function getTempMessages()
 | |
|     {
 | |
|         return $this->temp_messages;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Translate a string to the user-defined language
 | |
|      *
 | |
|      * @param array|mixed $args
 | |
|      *
 | |
|      * @param mixed       $languages
 | |
|      *
 | |
|      * @return string
 | |
|      */
 | |
|     public static function translate($args, $languages = null)
 | |
|     {
 | |
|         $grav = Grav::instance();
 | |
| 
 | |
|         if (is_array($args)) {
 | |
|             $lookup = array_shift($args);
 | |
|         } else {
 | |
|             $lookup = $args;
 | |
|             $args   = [];
 | |
|         }
 | |
| 
 | |
|         if (!$languages) {
 | |
|             if ($grav['config']->get('system.languages.translations_fallback', true)) {
 | |
|                 $languages = $grav['language']->getFallbackLanguages();
 | |
|             } else {
 | |
|                 $languages = (array)$grav['language']->getDefault();
 | |
|             }
 | |
|             $languages = $grav['user']->authenticated ? [ $grav['user']->language ] : $languages;
 | |
|         } else {
 | |
|             $languages = (array)$languages;
 | |
|         }
 | |
| 
 | |
|         foreach ((array)$languages as $lang) {
 | |
|             $translation = $grav['language']->getTranslation($lang, $lookup);
 | |
| 
 | |
|             if (!$translation) {
 | |
|                 $language    = $grav['language']->getDefault() ?: 'en';
 | |
|                 $translation = $grav['language']->getTranslation($language, $lookup);
 | |
|             }
 | |
| 
 | |
|             if (!$translation) {
 | |
|                 $language    = 'en';
 | |
|                 $translation = $grav['language']->getTranslation($language, $lookup);
 | |
|             }
 | |
| 
 | |
|             if ($translation) {
 | |
|                 if (count($args) >= 1) {
 | |
|                     return vsprintf($translation, $args);
 | |
|                 }
 | |
| 
 | |
|                 return $translation;
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         return $lookup;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Checks user authorisation to the action.
 | |
|      *
 | |
|      * @param  string|string[] $action
 | |
|      *
 | |
|      * @return bool
 | |
|      */
 | |
|     public function authorize($action = 'admin.login')
 | |
|     {
 | |
|         $action = (array)$action;
 | |
| 
 | |
|         foreach ($action as $a) {
 | |
|             if ($this->user->authorize($a)) {
 | |
|                 return true;
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         return false;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Gets configuration data.
 | |
|      *
 | |
|      * @param string $type
 | |
|      * @param array  $post
 | |
|      *
 | |
|      * @return mixed
 | |
|      * @throws \RuntimeException
 | |
|      */
 | |
|     public function data($type, array $post = [])
 | |
|     {
 | |
|         static $data = [];
 | |
| 
 | |
|         if (isset($data[$type])) {
 | |
|             return $data[$type];
 | |
|         }
 | |
| 
 | |
|         if (!$post) {
 | |
|             $post = $this->grav['uri']->post();
 | |
|             $post = $post['data'] ?? [];
 | |
|         }
 | |
| 
 | |
|         // Check to see if a data type is plugin-provided, before looking into core ones
 | |
|         $event = $this->grav->fireEvent('onAdminData', new Event(['type' => &$type]));
 | |
|         if ($event) {
 | |
|             if (isset($event['data_type'])) {
 | |
|                 return $event['data_type'];
 | |
|             }
 | |
| 
 | |
|             if (is_string($event['type'])) {
 | |
|                 $type = $event['type'];
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         /** @var UniformResourceLocator $locator */
 | |
|         $locator  = $this->grav['locator'];
 | |
|         $filename = $locator->findResource("config://{$type}.yaml", true, true);
 | |
|         $file     = CompiledYamlFile::instance($filename);
 | |
| 
 | |
|         if (preg_match('|plugins/|', $type)) {
 | |
|             /** @var Plugins $plugins */
 | |
|             $plugins = $this->grav['plugins'];
 | |
|             $obj     = $plugins->get(preg_replace('|plugins/|', '', $type));
 | |
| 
 | |
|             if (!$obj) {
 | |
|                 return [];
 | |
|             }
 | |
| 
 | |
|             $obj->merge($post);
 | |
|             $obj->file($file);
 | |
| 
 | |
|             $data[$type] = $obj;
 | |
|         } elseif (preg_match('|themes/|', $type)) {
 | |
|             /** @var Themes $themes */
 | |
|             $themes = $this->grav['themes'];
 | |
|             $obj    = $themes->get(preg_replace('|themes/|', '', $type));
 | |
| 
 | |
|             if (!$obj) {
 | |
|                 return [];
 | |
|             }
 | |
| 
 | |
|             $obj->merge($post);
 | |
|             $obj->file($file);
 | |
| 
 | |
|             $data[$type] = $obj;
 | |
|         } elseif (preg_match('|users/|', $type)) {
 | |
|             $obj = User::load(preg_replace('|users/|', '', $type));
 | |
|             $obj->merge($this->cleanUserPost($post));
 | |
| 
 | |
|             $data[$type] = $obj;
 | |
|         } elseif (preg_match('|user/|', $type)) {
 | |
|             $obj = User::load(preg_replace('|user/|', '', $type));
 | |
|             $obj->merge($this->cleanUserPost($post));
 | |
| 
 | |
|             $data[$type] = $obj;
 | |
|         } elseif (preg_match('|config/|', $type)) {
 | |
|             $type       = preg_replace('|config/|', '', $type);
 | |
|             $blueprints = $this->blueprints("config/{$type}");
 | |
|             $config     = $this->grav['config'];
 | |
|             $obj        = new Data\Data($config->get($type, []), $blueprints);
 | |
|             $obj->merge($post);
 | |
| 
 | |
|             // FIXME: We shouldn't allow user to change configuration files in system folder!
 | |
|             $filename = $this->grav['locator']->findResource("config://{$type}.yaml")
 | |
|                 ?: $this->grav['locator']->findResource("config://{$type}.yaml", true, true);
 | |
|             $file     = CompiledYamlFile::instance($filename);
 | |
|             $obj->file($file);
 | |
|             $data[$type] = $obj;
 | |
|         } elseif (preg_match('|media-manager/|', $type)) {
 | |
|             $filename = base64_decode(preg_replace('|media-manager/|', '', $type));
 | |
| 
 | |
|             $file = File::instance($filename);
 | |
| 
 | |
|             $obj = new \StdClass();
 | |
|             $obj->title = $file->basename();
 | |
|             $obj->path = $file->filename();
 | |
|             $obj->file = $file;
 | |
|             $obj->page = $this->grav['pages']->get(dirname($obj->path));
 | |
| 
 | |
|             $fileInfo = pathinfo($obj->title);
 | |
|             $filename = str_replace(['@3x', '@2x'], '', $fileInfo['filename']);
 | |
|             if (isset($fileInfo['extension'])) {
 | |
|                 $filename .= '.' . $fileInfo['extension'];
 | |
|             }
 | |
| 
 | |
|             if ($obj->page && isset($obj->page->media()[$filename])) {
 | |
|                 $obj->metadata = new Data\Data($obj->page->media()[$filename]->metadata());
 | |
|             }
 | |
| 
 | |
|             $data[$type] = $obj;
 | |
|         } else {
 | |
|             throw new \RuntimeException("Data type '{$type}' doesn't exist!");
 | |
|         }
 | |
| 
 | |
|         return $data[$type];
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Clean user form post and remove extra stuff that may be passed along
 | |
|      *
 | |
|      * @param $post
 | |
|      * @return array
 | |
|      */
 | |
|     protected function cleanUserPost($post)
 | |
|     {
 | |
|         // Clean fields for all users
 | |
|         unset($post['hashed_password']);
 | |
| 
 | |
|         // Clean field for users who shouldn't be able to modify these fields
 | |
|         if (!$this->authorize(['admin.user', 'admin.super'])) {
 | |
|             unset($post['access']);
 | |
|             unset($post['state']);
 | |
|         }
 | |
| 
 | |
|         return $post;
 | |
|     }
 | |
| 
 | |
|     protected function hasErrorMessage()
 | |
|     {
 | |
|         $msgs = $this->grav['messages']->all();
 | |
|         foreach ($msgs as $msg) {
 | |
|             if (isset($msg['scope']) && $msg['scope'] === 'error') {
 | |
|                 return true;
 | |
|             }
 | |
|         }
 | |
|         return false;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Returns blueprints for the given type.
 | |
|      *
 | |
|      * @param string $type
 | |
|      *
 | |
|      * @return Data\Blueprint
 | |
|      */
 | |
|     public function blueprints($type)
 | |
|     {
 | |
|         if ($this->blueprints === null) {
 | |
|             $this->blueprints = new Data\Blueprints('blueprints://');
 | |
|         }
 | |
| 
 | |
|         return $this->blueprints->get($type);
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Converts dot notation to array notation.
 | |
|      *
 | |
|      * @param  string $name
 | |
|      *
 | |
|      * @return string
 | |
|      */
 | |
|     public function field($name)
 | |
|     {
 | |
|         $path = explode('.', $name);
 | |
| 
 | |
|         return array_shift($path) . ($path ? '[' . implode('][', $path) . ']' : '');
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Get all routes.
 | |
|      *
 | |
|      * @param bool $unique
 | |
|      *
 | |
|      * @return array
 | |
|      */
 | |
|     public function routes($unique = false)
 | |
|     {
 | |
|         /** @var Pages $pages */
 | |
|         $pages = $this->grav['pages'];
 | |
| 
 | |
|         if ($unique) {
 | |
|             $routes = array_unique($pages->routes());
 | |
|         } else {
 | |
|             $routes = $pages->routes();
 | |
|         }
 | |
| 
 | |
|         return $routes;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Count the pages
 | |
|      *
 | |
|      * @return array
 | |
|      */
 | |
|     public function pagesCount()
 | |
|     {
 | |
|         if (!$this->pages_count) {
 | |
|             $this->pages_count = count($this->grav['pages']->all());
 | |
|         }
 | |
| 
 | |
|         return $this->pages_count;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Get all template types
 | |
|      *
 | |
|      * @return array
 | |
|      */
 | |
|     public function types()
 | |
|     {
 | |
|         return Pages::types();
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Get all modular template types
 | |
|      *
 | |
|      * @return array
 | |
|      */
 | |
|     public function modularTypes()
 | |
|     {
 | |
|         return Pages::modularTypes();
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Get all access levels
 | |
|      *
 | |
|      * @return array
 | |
|      */
 | |
|     public function accessLevels()
 | |
|     {
 | |
|         if (method_exists($this->grav['pages'], 'accessLevels')) {
 | |
|             return $this->grav['pages']->accessLevels();
 | |
|         }
 | |
| 
 | |
|         return [];
 | |
|     }
 | |
| 
 | |
|     public function license($package_slug)
 | |
|     {
 | |
|         return Licenses::get($package_slug);
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Generate an array of dependencies for a package, used to generate a list of
 | |
|      * packages that can be removed when removing a package.
 | |
|      *
 | |
|      * @param string $slug The package slug
 | |
|      *
 | |
|      * @return array|bool
 | |
|      */
 | |
|     public function dependenciesThatCanBeRemovedWhenRemoving($slug)
 | |
|     {
 | |
|         $gpm = $this->gpm();
 | |
|         if (!$gpm) {
 | |
|             return false;
 | |
|         }
 | |
| 
 | |
|         $dependencies = [];
 | |
| 
 | |
|         $package = $this->getPackageFromGPM($slug);
 | |
| 
 | |
|         if ($package) {
 | |
|             if ($package->dependencies) {
 | |
|                 foreach ($package->dependencies as $dependency) {
 | |
| //                    if (count($gpm->getPackagesThatDependOnPackage($dependency)) > 1) {
 | |
| //                        continue;
 | |
| //                    }
 | |
|                     if (isset($dependency['name'])) {
 | |
|                         $dependency = $dependency['name'];
 | |
|                     }
 | |
| 
 | |
|                     if (!in_array($dependency, $dependencies, true)) {
 | |
|                         if (!in_array($dependency, ['admin', 'form', 'login', 'email', 'php'])) {
 | |
|                             $dependencies[] = $dependency;
 | |
|                         }
 | |
|                     }
 | |
|                 }
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         return $dependencies;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Get the GPM instance
 | |
|      *
 | |
|      * @return GPM The GPM instance
 | |
|      */
 | |
|     public function gpm()
 | |
|     {
 | |
|         if (!$this->gpm) {
 | |
|             try {
 | |
|                 $this->gpm = new GPM();
 | |
|             } catch (\Exception $e) {
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         return $this->gpm;
 | |
|     }
 | |
| 
 | |
|     public function getPackageFromGPM($package_slug)
 | |
|     {
 | |
|         $package = $this->plugins(true)[$package_slug];
 | |
|         if (!$package) {
 | |
|             $package = $this->themes(true)[$package_slug];
 | |
|         }
 | |
| 
 | |
|         return $package;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Get all plugins.
 | |
|      *
 | |
|      * @param bool $local
 | |
|      *
 | |
|      * @return mixed
 | |
|      */
 | |
|     public function plugins($local = true)
 | |
|     {
 | |
|         $gpm = $this->gpm();
 | |
| 
 | |
|         if (!$gpm) {
 | |
|             return false;
 | |
|         }
 | |
| 
 | |
|         if ($local) {
 | |
|             return $gpm->getInstalledPlugins();
 | |
|         }
 | |
| 
 | |
|         $plugins = $gpm->getRepositoryPlugins();
 | |
|         if ($plugins) {
 | |
|             return $plugins->filter(function ($package, $slug) use ($gpm) {
 | |
|                 return !$gpm->isPluginInstalled($slug);
 | |
|             });
 | |
|         }
 | |
| 
 | |
|         return [];
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Get all themes.
 | |
|      *
 | |
|      * @param bool $local
 | |
|      *
 | |
|      * @return mixed
 | |
|      */
 | |
|     public function themes($local = true)
 | |
|     {
 | |
|         $gpm = $this->gpm();
 | |
| 
 | |
|         if (!$gpm) {
 | |
|             return false;
 | |
|         }
 | |
| 
 | |
|         if ($local) {
 | |
|             return $gpm->getInstalledThemes();
 | |
|         }
 | |
| 
 | |
|         $themes = $gpm->getRepositoryThemes();
 | |
|         if ($themes) {
 | |
|             return $themes->filter(function ($package, $slug) use ($gpm) {
 | |
|                 return !$gpm->isThemeInstalled($slug);
 | |
|             });
 | |
|         }
 | |
| 
 | |
|         return [];
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Get list of packages that depend on the passed package slug
 | |
|      *
 | |
|      * @param string $slug The package slug
 | |
|      *
 | |
|      * @return array|bool
 | |
|      */
 | |
|     public function getPackagesThatDependOnPackage($slug)
 | |
|     {
 | |
|         $gpm = $this->gpm();
 | |
|         if (!$gpm) {
 | |
|             return false;
 | |
|         }
 | |
| 
 | |
|         return $gpm->getPackagesThatDependOnPackage($slug);
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Check the passed packages list can be updated
 | |
|      *
 | |
|      * @param $packages
 | |
|      *
 | |
|      * @throws \Exception
 | |
|      * @return bool
 | |
|      */
 | |
|     public function checkPackagesCanBeInstalled($packages)
 | |
|     {
 | |
|         $gpm = $this->gpm();
 | |
|         if (!$gpm) {
 | |
|             return false;
 | |
|         }
 | |
| 
 | |
|         $this->gpm->checkPackagesCanBeInstalled($packages);
 | |
| 
 | |
|         return true;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Get an array of dependencies needed to be installed or updated for a list of packages
 | |
|      * to be installed.
 | |
|      *
 | |
|      * @param array $packages The packages slugs
 | |
|      *
 | |
|      * @return array|bool
 | |
|      */
 | |
|     public function getDependenciesNeededToInstall($packages)
 | |
|     {
 | |
|         $gpm = $this->gpm();
 | |
|         if (!$gpm) {
 | |
|             return false;
 | |
|         }
 | |
| 
 | |
|         return $this->gpm->getDependencies($packages);
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Used by the Dashboard in the admin to display the X latest pages
 | |
|      * that have been modified
 | |
|      *
 | |
|      * @param  integer $count number of pages to pull back
 | |
|      *
 | |
|      * @return array|null
 | |
|      */
 | |
|     public function latestPages($count = 10)
 | |
|     {
 | |
|         /** @var Pages $pages */
 | |
|         $pages = $this->grav['pages'];
 | |
| 
 | |
|         $latest = [];
 | |
| 
 | |
|         if (null === $pages->routes()) {
 | |
|             return null;
 | |
|         }
 | |
| 
 | |
|         foreach ($pages->routes() as $url => $path) {
 | |
|             $page = $pages->dispatch($url, true);
 | |
|             if ($page && $page->routable()) {
 | |
|                 $latest[$page->route()] = ['modified' => $page->modified(), 'page' => $page];
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         // sort based on modified
 | |
|         uasort($latest, function ($a, $b) {
 | |
|             if ($a['modified'] == $b['modified']) {
 | |
|                 return 0;
 | |
|             }
 | |
| 
 | |
|             return ($a['modified'] > $b['modified']) ? -1 : 1;
 | |
|         });
 | |
| 
 | |
|         // build new array with just pages in it
 | |
|         $list = [];
 | |
|         foreach ($latest as $item) {
 | |
|             $list[] = $item['page'];
 | |
|         }
 | |
| 
 | |
|         return array_slice($list, 0, $count);
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Get log file for fatal errors.
 | |
|      *
 | |
|      * @return string
 | |
|      */
 | |
|     public function logEntry()
 | |
|     {
 | |
|         $file    = File::instance($this->grav['locator']->findResource("log://{$this->route}.html"));
 | |
|         $content = $file->content();
 | |
|         $file->free();
 | |
| 
 | |
|         return $content;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Search in the logs when was the latest backup made
 | |
|      *
 | |
|      * @return array Array containing the latest backup information
 | |
|      */
 | |
|     public function lastBackup()
 | |
|     {
 | |
|         $file    = JsonFile::instance($this->grav['locator']->findResource('log://backup.log'));
 | |
|         $content = $file->content();
 | |
|         if (empty($content)) {
 | |
|             return [
 | |
|                 'days'        => '∞',
 | |
|                 'chart_fill'  => 100,
 | |
|                 'chart_empty' => 0
 | |
|             ];
 | |
|         }
 | |
| 
 | |
|         $backup = new \DateTime();
 | |
|         $backup->setTimestamp($content['time']);
 | |
|         $diff = $backup->diff(new \DateTime());
 | |
| 
 | |
|         $days       = $diff->days;
 | |
|         $chart_fill = $days > 30 ? 100 : round($days / 30 * 100);
 | |
| 
 | |
|         return [
 | |
|             'days'        => $days,
 | |
|             'chart_fill'  => $chart_fill,
 | |
|             'chart_empty' => 100 - $chart_fill
 | |
|         ];
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Determine if the plugin or theme info passed is from Team Grav
 | |
|      *
 | |
|      * @param object $info Plugin or Theme info object
 | |
|      *
 | |
|      * @return bool
 | |
|      */
 | |
|     public function isTeamGrav($info)
 | |
|     {
 | |
|         return isset($info['author']['name']) && ($info['author']['name'] === 'Team Grav' || Utils::contains($info['author']['name'], 'Trilby Media'));
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Determine if the plugin or theme info passed is premium
 | |
|      *
 | |
|      * @param object $info Plugin or Theme info object
 | |
|      *
 | |
|      * @return bool
 | |
|      */
 | |
|     public function isPremiumProduct($info)
 | |
|     {
 | |
|         return isset($info['premium']);
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Renders phpinfo
 | |
|      *
 | |
|      * @return string The phpinfo() output
 | |
|      */
 | |
|     function phpinfo()
 | |
|     {
 | |
|         if (function_exists('phpinfo')) {
 | |
|             ob_start();
 | |
|             phpinfo();
 | |
|             $pinfo = ob_get_contents();
 | |
|             ob_end_clean();
 | |
| 
 | |
|             $pinfo = preg_replace('%^.*<body>(.*)</body>.*$%ms', '$1', $pinfo);
 | |
| 
 | |
|             return $pinfo;
 | |
|         }
 | |
| 
 | |
|         return 'phpinfo() method is not available on this server.';
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Guest date format based on euro/US
 | |
|      *
 | |
|      * @param $date
 | |
|      *
 | |
|      * @return string
 | |
|      */
 | |
|     public function guessDateFormat($date)
 | |
|     {
 | |
|         static $guess;
 | |
| 
 | |
|         $date_formats = [
 | |
|             'm/d/y',
 | |
|             'm/d/Y',
 | |
|             'n/d/y',
 | |
|             'n/d/Y',
 | |
|             'd-m-Y',
 | |
|             'd-m-y',
 | |
|         ];
 | |
| 
 | |
|         $time_formats = [
 | |
|             'H:i',
 | |
|             'G:i',
 | |
|             'h:ia',
 | |
|             'g:ia'
 | |
|         ];
 | |
| 
 | |
|         if (!isset($guess[$date])) {
 | |
|             foreach ($date_formats as $date_format) {
 | |
|                 foreach ($time_formats as $time_format) {
 | |
|                     if ($this->validateDate($date, "$date_format $time_format")) {
 | |
|                         $guess[$date] = "$date_format $time_format";
 | |
|                         break 2;
 | |
|                     }
 | |
|                     if ($this->validateDate($date, "$time_format $date_format")) {
 | |
|                         $guess[$date] = "$time_format $date_format";
 | |
|                         break 2;
 | |
|                     }
 | |
|                 }
 | |
|             }
 | |
| 
 | |
|             if (!isset($guess[$date])) {
 | |
|                 $guess[$date] = 'd-m-Y H:i';
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         return $guess[$date];
 | |
|     }
 | |
| 
 | |
|     public function validateDate($date, $format)
 | |
|     {
 | |
|         $d = DateTime::createFromFormat($format, $date);
 | |
| 
 | |
|         return $d && $d->format($format) == $date;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * @param string $php_format
 | |
|      *
 | |
|      * @return string
 | |
|      */
 | |
|     public function dateformatToMomentJS($php_format)
 | |
|     {
 | |
|         $SYMBOLS_MATCHING = [
 | |
|             // Day
 | |
|             'd' => 'DD',
 | |
|             'D' => 'ddd',
 | |
|             'j' => 'D',
 | |
|             'l' => 'dddd',
 | |
|             'N' => 'E',
 | |
|             'S' => 'Do',
 | |
|             'w' => 'd',
 | |
|             'z' => 'DDD',
 | |
|             // Week
 | |
|             'W' => 'W',
 | |
|             // Month
 | |
|             'F' => 'MMMM',
 | |
|             'm' => 'MM',
 | |
|             'M' => 'MMM',
 | |
|             'n' => 'M',
 | |
|             't' => '',
 | |
|             // Year
 | |
|             'L' => '',
 | |
|             'o' => 'GGGG',
 | |
|             'Y' => 'YYYY',
 | |
|             'y' => 'yy',
 | |
|             // Time
 | |
|             'a' => 'a',
 | |
|             'A' => 'A',
 | |
|             'B' => 'SSS',
 | |
|             'g' => 'h',
 | |
|             'G' => 'H',
 | |
|             'h' => 'hh',
 | |
|             'H' => 'HH',
 | |
|             'i' => 'mm',
 | |
|             's' => 'ss',
 | |
|             'u' => '',
 | |
|             // Timezone
 | |
|             'e' => '',
 | |
|             'I' => '',
 | |
|             'O' => 'ZZ',
 | |
|             'P' => 'Z',
 | |
|             'T' => 'z',
 | |
|             'Z' => '',
 | |
|             // Full Date/Time
 | |
|             'c' => '',
 | |
|             'r' => 'llll ZZ',
 | |
|             'U' => 'X'
 | |
|         ];
 | |
|         $js_format        = '';
 | |
|         $escaping         = false;
 | |
|         $len = strlen($php_format);
 | |
|         for ($i = 0; $i < $len; $i++) {
 | |
|             $char = $php_format[$i];
 | |
|             if ($char === '\\') // PHP date format escaping character
 | |
|             {
 | |
|                 $i++;
 | |
|                 if ($escaping) {
 | |
|                     $js_format .= $php_format[$i];
 | |
|                 } else {
 | |
|                     $js_format .= '\'' . $php_format[$i];
 | |
|                 }
 | |
|                 $escaping = true;
 | |
|             } else {
 | |
|                 if ($escaping) {
 | |
|                     $js_format .= "'";
 | |
|                     $escaping = false;
 | |
|                 }
 | |
|                 if (isset($SYMBOLS_MATCHING[$char])) {
 | |
|                     $js_format .= $SYMBOLS_MATCHING[$char];
 | |
|                 } else {
 | |
|                     $js_format .= $char;
 | |
|                 }
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         return $js_format;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Gets the entire permissions array
 | |
|      *
 | |
|      * @return array
 | |
|      */
 | |
|     public function getPermissions()
 | |
|     {
 | |
|         return $this->permissions;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Sets the entire permissions array
 | |
|      *
 | |
|      * @param $permissions
 | |
|      */
 | |
|     public function setPermissions($permissions)
 | |
|     {
 | |
|         $this->permissions = $permissions;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Adds a permission to the permissions array
 | |
|      *
 | |
|      * @param $permissions
 | |
|      */
 | |
|     public function addPermissions($permissions)
 | |
|     {
 | |
|         $this->permissions = array_merge($this->permissions, $permissions);
 | |
|     }
 | |
| 
 | |
|     public function processNotifications($notifications)
 | |
|     {
 | |
|         // Sort by date
 | |
|         usort($notifications, function ($a, $b) {
 | |
|             return strcmp($a->date, $b->date);
 | |
|         });
 | |
| 
 | |
|         $notifications = array_reverse($notifications);
 | |
| 
 | |
|         // Make adminNicetimeFilter available
 | |
|         require_once __DIR__ . '/../classes/Twig/AdminTwigExtension.php';
 | |
|         $adminTwigExtension = new AdminTwigExtension;
 | |
| 
 | |
|         $filename           = $this->grav['locator']->findResource('user://data/notifications/' . $this->grav['user']->username . YAML_EXT,
 | |
|             true, true);
 | |
|         $read_notifications = (array)CompiledYamlFile::instance($filename)->content();
 | |
| 
 | |
|         $notifications_processed = [];
 | |
|         foreach ($notifications as $key => $notification) {
 | |
|             $is_valid = true;
 | |
| 
 | |
|             if (in_array($notification->id, $read_notifications, true)) {
 | |
|                 $notification->read = true;
 | |
|             }
 | |
| 
 | |
|             if ($is_valid && isset($notification->permissions) && !$this->authorize($notification->permissions)) {
 | |
|                 $is_valid = false;
 | |
|             }
 | |
| 
 | |
|             if ($is_valid && isset($notification->dependencies)) {
 | |
|                 foreach ($notification->dependencies as $dependency => $constraints) {
 | |
|                     if ($dependency === 'grav') {
 | |
|                         if (!Semver::satisfies(GRAV_VERSION, $constraints)) {
 | |
|                             $is_valid = false;
 | |
|                         }
 | |
|                     } else {
 | |
|                         $packages = array_merge($this->plugins()->toArray(), $this->themes()->toArray());
 | |
|                         if (!isset($packages[$dependency])) {
 | |
|                             $is_valid = false;
 | |
|                         } else {
 | |
|                             $version = $packages[$dependency]['version'];
 | |
|                             if (!Semver::satisfies($version, $constraints)) {
 | |
|                                 $is_valid = false;
 | |
|                             }
 | |
|                         }
 | |
|                     }
 | |
| 
 | |
|                     if (!$is_valid) {
 | |
|                         break;
 | |
|                     }
 | |
|                 }
 | |
|             }
 | |
| 
 | |
|             if ($is_valid) {
 | |
|                 $notifications_processed[] = $notification;
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         // Process notifications
 | |
|         $notifications_processed = array_map(function ($notification) use ($adminTwigExtension) {
 | |
|             $notification->date = $adminTwigExtension->adminNicetimeFilter($notification->date);
 | |
| 
 | |
|             return $notification;
 | |
|         }, $notifications_processed);
 | |
| 
 | |
|         return $notifications_processed;
 | |
|     }
 | |
| 
 | |
|     public function findFormFields($type, $fields, $found_fields = [])
 | |
|     {
 | |
|         foreach ($fields as $key => $field) {
 | |
| 
 | |
|             if (isset($field['type']) && $field['type'] == $type) {
 | |
|                 $found_fields[$key] = $field;
 | |
|             } elseif (isset($field['fields'])) {
 | |
|                 $result = $this->findFormFields($type, $field['fields'], $found_fields);
 | |
|                 if (!empty($result)) {
 | |
|                     $found_fields = array_merge($found_fields, $result);
 | |
|                 }
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         return $found_fields;
 | |
|     }
 | |
| 
 | |
|     public function getPagePathFromToken($path, $page = null)
 | |
|     {
 | |
|         return Utils::getPagePathFromToken($path, $page ?: $this->page(true));
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Returns edited page.
 | |
|      *
 | |
|      * @param bool $route
 | |
|      *
 | |
|      * @param null $path
 | |
|      *
 | |
|      * @return Page
 | |
|      */
 | |
|     public function page($route = false, $path = null)
 | |
|     {
 | |
|         if (!$path) {
 | |
|             $path = $this->route;
 | |
|         }
 | |
| 
 | |
|         if ($route && !$path) {
 | |
|             $path = '/';
 | |
|         }
 | |
| 
 | |
|         if (!isset($this->pages[$path])) {
 | |
|             $this->pages[$path] = $this->getPage($path);
 | |
|         }
 | |
| 
 | |
|         return $this->pages[$path];
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Returns the page creating it if it does not exist.
 | |
|      *
 | |
|      * @param $path
 | |
|      *
 | |
|      * @return Page
 | |
|      */
 | |
|     public function getPage($path)
 | |
|     {
 | |
|         /** @var Pages $pages */
 | |
|         $pages = $this->grav['pages'];
 | |
| 
 | |
|         if ($path && $path[0] !== '/') {
 | |
|             $path = "/{$path}";
 | |
|         }
 | |
| 
 | |
|         // Fix for entities in path causing looping...
 | |
|         $path = urldecode($path);
 | |
| 
 | |
|         $page = $path ? $pages->dispatch($path, true) : $pages->root();
 | |
| 
 | |
|         if (!$page) {
 | |
|             $slug = basename($path);
 | |
| 
 | |
|             if ($slug === '') {
 | |
|                 return null;
 | |
|             }
 | |
| 
 | |
|             $ppath = str_replace('\\', '/', dirname($path));
 | |
| 
 | |
|             // Find or create parent(s).
 | |
|             $parent = $this->getPage($ppath !== '/' ? $ppath : '');
 | |
| 
 | |
|             // Create page.
 | |
|             $page = new Page;
 | |
|             $page->parent($parent);
 | |
|             $page->filePath($parent->path() . '/' . $slug . '/' . $page->name());
 | |
| 
 | |
|             // Add routing information.
 | |
|             $pages->addPage($page, $path);
 | |
| 
 | |
|             // Set if Modular
 | |
|             $page->modularTwig($slug[0] === '_');
 | |
| 
 | |
|             // Determine page type.
 | |
|             if (isset($this->session->{$page->route()})) {
 | |
|                 // Found the type and header from the session.
 | |
|                 $data = $this->session->{$page->route()};
 | |
| 
 | |
|                 // Set the key header value
 | |
|                 $header = ['title' => $data['title']];
 | |
| 
 | |
|                 if (isset($data['visible'])) {
 | |
|                     if ($data['visible'] === '' || $data['visible']) {
 | |
|                         // if auto (ie '')
 | |
|                         $pageParent = $page->parent();
 | |
|                         $children = $pageParent ? $pageParent->children() : [];
 | |
|                         foreach ($children as $child) {
 | |
|                             if ($child->order()) {
 | |
|                                 // set page order
 | |
|                                 $page->order(AdminController::getNextOrderInFolder($pageParent->path()));
 | |
|                                 break;
 | |
|                             }
 | |
|                         }
 | |
|                     }
 | |
|                     if ((int)$data['visible'] === 1 && !$page->order()) {
 | |
|                         $header['visible'] = $data['visible'];
 | |
|                     }
 | |
| 
 | |
|                 }
 | |
| 
 | |
|                 if ($data['name'] === 'modular') {
 | |
|                     $header['body_classes'] = 'modular';
 | |
|                 }
 | |
| 
 | |
|                 $name = $page->modular() ? str_replace('modular/', '', $data['name']) : $data['name'];
 | |
|                 $page->name($name . '.md');
 | |
| 
 | |
|                 // Fire new event to allow plugins to manipulate page frontmatter
 | |
|                 $this->grav->fireEvent('onAdminCreatePageFrontmatter', new Event(['header' => &$header,
 | |
|                         'data' => $data]));
 | |
| 
 | |
|                 $page->header($header);
 | |
|                 $page->frontmatter(Yaml::dump((array)$page->header(), 20));
 | |
|             } else {
 | |
|                 // Find out the type by looking at the parent.
 | |
|                 $type = $parent->childType() ?: $parent->blueprints()->get('child_type', 'default');
 | |
|                 $page->name($type . CONTENT_EXT);
 | |
|                 $page->header();
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         return $page;
 | |
|     }
 | |
| 
 | |
|     public function generateReports()
 | |
|     {
 | |
|         $reports = new ArrayCollection();
 | |
| 
 | |
|         // Default to XSS Security Report
 | |
|         $result = Security::detectXssFromPages($this->grav['pages'], true);
 | |
| 
 | |
|         $reports['Grav Security Check'] = $this->grav['twig']->processTemplate('reports/security.html.twig', [
 | |
|             'result' => $result,
 | |
|         ]);
 | |
| 
 | |
|         // Fire new event to allow plugins to manipulate page frontmatter
 | |
|         $this->grav->fireEvent('onAdminGenerateReports', new Event(['reports' => $reports]));
 | |
| 
 | |
|         return $reports;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Get https://getgrav.org news feed
 | |
|      *
 | |
|      * @return mixed
 | |
|      */
 | |
|     public function getFeed()
 | |
|     {
 | |
|         $feed_url = 'https://getgrav.org/blog.atom';
 | |
| 
 | |
|         $body = Response::get($feed_url);
 | |
| 
 | |
|         $reader = new Reader();
 | |
|         $parser = $reader->getParser($feed_url, $body, 'utf-8');
 | |
| 
 | |
|         return $parser->execute();
 | |
| 
 | |
|     }
 | |
| 
 | |
|     public function getRouteDetails()
 | |
|     {
 | |
|         return [$this->base, $this->location, $this->route];
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Get the files list
 | |
|      *
 | |
|      * @param bool $filtered
 | |
|      * @param int $page_index
 | |
|      * @return array|null
 | |
|      * @todo allow pagination
 | |
|      */
 | |
|     public function files($filtered = true, $page_index = 0)
 | |
|     {
 | |
|         $param_type = $this->grav['uri']->param('type');
 | |
|         $param_date = $this->grav['uri']->param('date');
 | |
|         $param_page = $this->grav['uri']->param('page');
 | |
|         $param_page = str_replace('\\', '/', $param_page);
 | |
| 
 | |
|         $files_cache_key = 'media-manager-files';
 | |
| 
 | |
|         if ($param_type) {
 | |
|             $files_cache_key .= "-{$param_type}";
 | |
|         }
 | |
|         if ($param_date) {
 | |
|             $files_cache_key .= "-{$param_date}";
 | |
|         }
 | |
|         if ($param_page) {
 | |
|             $files_cache_key .= "-{$param_page}";
 | |
|         }
 | |
| 
 | |
|         $page_files = null;
 | |
| 
 | |
|         $cache_enabled = $this->grav['config']->get('plugins.admin.cache_enabled');
 | |
|         if (!$cache_enabled) {
 | |
|             $this->grav['cache']->setEnabled(true);
 | |
|         }
 | |
| 
 | |
|         $page_files = $this->grav['cache']->fetch(md5($files_cache_key));
 | |
| 
 | |
|         if (!$cache_enabled) {
 | |
|             $this->grav['cache']->setEnabled(false);
 | |
|         }
 | |
| 
 | |
|         if (!$page_files) {
 | |
|             $page_files = [];
 | |
|             $pages = $this->grav['pages'];
 | |
| 
 | |
|             if ($param_page) {
 | |
|                 $page = $pages->dispatch($param_page);
 | |
| 
 | |
|                 $page_files = $this->getFiles('images', $page, $page_files, $filtered);
 | |
|                 $page_files = $this->getFiles('videos', $page, $page_files, $filtered);
 | |
|                 $page_files = $this->getFiles('audios', $page, $page_files, $filtered);
 | |
|                 $page_files = $this->getFiles('files', $page, $page_files, $filtered);
 | |
|             } else {
 | |
|                 $allPages = $pages->all();
 | |
| 
 | |
|                 if ($allPages) foreach ($allPages as $page) {
 | |
|                     $page_files = $this->getFiles('images', $page, $page_files, $filtered);
 | |
|                     $page_files = $this->getFiles('videos', $page, $page_files, $filtered);
 | |
|                     $page_files = $this->getFiles('audios', $page, $page_files, $filtered);
 | |
|                     $page_files = $this->getFiles('files', $page, $page_files, $filtered);
 | |
|                 }
 | |
|             }
 | |
| 
 | |
|             if (count($page_files) >= self::MEDIA_PAGINATION_INTERVAL) {
 | |
|                 $this->shouldLoadAdditionalFilesInBackground(true);
 | |
|             }
 | |
| 
 | |
|             if (!$cache_enabled) {
 | |
|                 $this->grav['cache']->setEnabled(true);
 | |
|             }
 | |
|             $this->grav['cache']->save(md5($files_cache_key), $page_files, 600); //cache for 10 minutes
 | |
|             if (!$cache_enabled) {
 | |
|                 $this->grav['cache']->setEnabled(false);
 | |
|             }
 | |
| 
 | |
|         }
 | |
| 
 | |
|         if (count($page_files) >= self::MEDIA_PAGINATION_INTERVAL) {
 | |
|             $page_files = array_slice($page_files, $page_index * self::MEDIA_PAGINATION_INTERVAL, self::MEDIA_PAGINATION_INTERVAL);
 | |
|         }
 | |
| 
 | |
|         return $page_files;
 | |
|     }
 | |
| 
 | |
|     public function shouldLoadAdditionalFilesInBackground($status = null)
 | |
|     {
 | |
|         if ($status) {
 | |
|             $this->load_additional_files_in_background = true;
 | |
|         }
 | |
| 
 | |
|         return $this->load_additional_files_in_background;
 | |
|     }
 | |
| 
 | |
|     public function loadAdditionalFilesInBackground($status = null)
 | |
|     {
 | |
|         if (!$this->loading_additional_files_in_background) {
 | |
|             $this->loading_additional_files_in_background = true;
 | |
|             $this->files(false, false);
 | |
|             $this->shouldLoadAdditionalFilesInBackground(false);
 | |
|             $this->loading_additional_files_in_background = false;
 | |
|         }
 | |
|     }
 | |
| 
 | |
|     private function getFiles($type, $page, $page_files, $filtered)
 | |
|     {
 | |
|         $page_files = $this->getMediaOfType($type, $page, $page_files);
 | |
| 
 | |
|         if ($filtered) {
 | |
|             $page_files = $this->filterByType($page_files);
 | |
|             $page_files = $this->filterByDate($page_files);
 | |
|         }
 | |
| 
 | |
|         return $page_files;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Get all the media of a type ('images' | 'audios' | 'videos' | 'files')
 | |
|      *
 | |
|      * @param string $type
 | |
|      * @param Page|null $page
 | |
|      * @param array $files
 | |
|      *
 | |
|      * @return array
 | |
|      */
 | |
|     private function getMediaOfType($type, ?Page $page, array $files)
 | |
|     {
 | |
|         if ($page) {
 | |
|             $media = $page->media();
 | |
|             $mediaOfType = $media->$type();
 | |
| 
 | |
|             foreach($mediaOfType as $title => $file) {
 | |
|                 $files[] = [
 | |
|                     'title' => $title,
 | |
|                     'type' => $type,
 | |
|                     'page_route' => $page->route(),
 | |
|                     'file' => $file->higherQualityAlternative()
 | |
|                 ];
 | |
|             }
 | |
| 
 | |
|             return $files;
 | |
|         }
 | |
| 
 | |
|         return [];
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Filter media by type
 | |
|      *
 | |
|      * @param array $filesFiltered
 | |
|      *
 | |
|      * @return array
 | |
|      */
 | |
|     private function filterByType($filesFiltered)
 | |
|     {
 | |
|         $filter_type = $this->grav['uri']->param('type');
 | |
|         if (!$filter_type) {
 | |
|             return $filesFiltered;
 | |
|         }
 | |
| 
 | |
|         $filesFiltered = array_filter($filesFiltered, function ($file) use ($filter_type) {
 | |
|             return $file['type'] == $filter_type;
 | |
|         });
 | |
| 
 | |
|         return $filesFiltered;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Filter media by date
 | |
|      *
 | |
|      * @param array $filesFiltered
 | |
|      *
 | |
|      * @return array
 | |
|      */
 | |
|     private function filterByDate($filesFiltered)
 | |
|     {
 | |
|         $filter_date = $this->grav['uri']->param('date');
 | |
|         if (!$filter_date) {
 | |
|             return $filesFiltered;
 | |
|         }
 | |
| 
 | |
|         $year = substr($filter_date, 0, 4);
 | |
|         $month = substr($filter_date, 5, 2);
 | |
| 
 | |
|         $filesFilteredByDate = [];
 | |
| 
 | |
|         foreach($filesFiltered as $file) {
 | |
|             $filedate = $this->fileDate($file['file']);
 | |
|             $fileYear = $filedate->format('Y');
 | |
|             $fileMonth = $filedate->format('m');
 | |
| 
 | |
|             if ($fileYear == $year && $fileMonth == $month) {
 | |
|                 $filesFilteredByDate[] = $file;
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         return $filesFilteredByDate;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Return the DateTime object representation of a file modified date
 | |
|      *
 | |
|      * @param File $file
 | |
|      *
 | |
|      * @return DateTime
 | |
|      */
 | |
|     private function fileDate($file) {
 | |
|         $datetime = new \DateTime();
 | |
|         $datetime->setTimestamp($file->toArray()['modified']);
 | |
|         return $datetime;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Get the files dates list to be used in the Media Files filter
 | |
|      *
 | |
|      * @return array
 | |
|      */
 | |
|     public function filesDates()
 | |
|     {
 | |
|         $files = $this->files(false);
 | |
|         $dates = [];
 | |
| 
 | |
|         foreach ($files as $file) {
 | |
|             $datetime = $this->fileDate($file['file']);
 | |
|             $year = $datetime->format('Y');
 | |
|             $month = $datetime->format('m');
 | |
| 
 | |
|             if (!isset($dates[$year])) {
 | |
|                 $dates[$year] = [];
 | |
|             }
 | |
| 
 | |
|             if (!isset($dates[$year][$month])) {
 | |
|                 $dates[$year][$month] = 1;
 | |
|             } else {
 | |
|                 $dates[$year][$month]++;
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         return $dates;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Get the pages list to be used in the Media Files filter
 | |
|      *
 | |
|      * @return array
 | |
|      */
 | |
|     public function pages()
 | |
|     {
 | |
|         /** @var Collection $pages */
 | |
|         $pages = $this->grav['pages']->all();
 | |
| 
 | |
|         $pagesWithFiles = [];
 | |
|         foreach ($pages as $page) {
 | |
|             if (count($page->media()->all())) {
 | |
|                 $pagesWithFiles[] = $page;
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         return $pagesWithFiles;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Return HTTP_REFERRER if set
 | |
|      *
 | |
|      * @return null
 | |
|      */
 | |
|     public function getReferrer()
 | |
|     {
 | |
|         return $_SERVER['HTTP_REFERER'] ?? null;
 | |
|     }
 | |
| }
 |