Controller.php 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603
  1. <?php
  2. /**
  3. * @package Grav\Plugin\Login
  4. *
  5. * @copyright Copyright (C) 2014 - 2017 RocketTheme, LLC. All rights reserved.
  6. * @license MIT License; see LICENSE file for details.
  7. */
  8. namespace Grav\Plugin\Login;
  9. use Grav\Common\Grav;
  10. use Grav\Common\Language\Language;
  11. use Grav\Common\Uri;
  12. use Grav\Common\User\Interfaces\UserCollectionInterface;
  13. use Grav\Common\User\Interfaces\UserInterface;
  14. use Grav\Common\Utils;
  15. use Grav\Plugin\Email\Utils as EmailUtils;
  16. use Grav\Plugin\Login\TwoFactorAuth\TwoFactorAuth;
  17. use Grav\Plugin\LoginPlugin;
  18. use RocketTheme\Toolbox\Session\Message;
  19. /**
  20. * Class Controller
  21. * @package Grav\Plugin\Login
  22. */
  23. class Controller
  24. {
  25. /**
  26. * @var Grav
  27. */
  28. public $grav;
  29. /**
  30. * @var string
  31. */
  32. public $action;
  33. /**
  34. * @var array
  35. */
  36. public $post;
  37. /**
  38. * @var string
  39. */
  40. protected $redirect;
  41. /**
  42. * @var int
  43. */
  44. protected $redirectCode;
  45. /**
  46. * @var string
  47. */
  48. protected $prefix = 'task';
  49. /**
  50. * @var RememberMe\RememberMe
  51. * @deprecated 2.0 Use $grav['login']->rememberMe() instead
  52. */
  53. protected $rememberMe;
  54. /**
  55. * @var Login
  56. */
  57. protected $login;
  58. /**
  59. * @param Grav $grav
  60. * @param string $action
  61. * @param array $post
  62. */
  63. public function __construct(Grav $grav, $action, $post = null)
  64. {
  65. $this->grav = $grav;
  66. $this->action = $action;
  67. $this->login = $this->grav['login'];
  68. $this->post = $post ? $this->getPost($post) : [];
  69. $this->rememberMe();
  70. }
  71. /**
  72. * Performs an action.
  73. * @throws \RuntimeException
  74. */
  75. public function execute()
  76. {
  77. $messages = $this->grav['messages'];
  78. // Set redirect if available.
  79. $redirect = $this->post['_redirect'] ?? null;
  80. unset($this->post['_redirect']);
  81. $success = false;
  82. $method = $this->prefix . ucfirst($this->action);
  83. if (!method_exists($this, $method)) {
  84. throw new \RuntimeException('Page Not Found', 404);
  85. }
  86. try {
  87. $success = $this->{$method}();
  88. } catch (\RuntimeException $e) {
  89. $messages->add($e->getMessage(), 'error');
  90. $this->grav['log']->error('plugin.login: '. $e->getMessage());
  91. }
  92. if (!$this->redirect && $redirect) {
  93. $this->setRedirect($redirect, 303);
  94. }
  95. return $success;
  96. }
  97. /**
  98. * Handle login.
  99. *
  100. * @return bool True if the action was performed.
  101. */
  102. public function taskLogin()
  103. {
  104. /** @var Language $t */
  105. $t = $this->grav['language'];
  106. /** @var Message $messages */
  107. $messages = $this->grav['messages'];
  108. $userKey = (string)($this->post['username'] ?? '');
  109. $ip = Uri::ip();
  110. $isIPv4 = filter_var($ip, FILTER_VALIDATE_IP, FILTER_FLAG_IPV4);
  111. $ipKey = $isIPv4 ? $ip : Utils::getSubnet($ip, $this->grav['config']->get('plugins.login.ipv6_subnet_size'));
  112. // Is twofa enabled?
  113. $twofa = $this->grav['config']->get('plugins.login.twofa_enabled', false);
  114. // Pseudonymization of the IP
  115. $ipKey = sha1($ipKey . $this->grav['config']->get('security.salt'));
  116. $rateLimiter = $this->login->getRateLimiter('login_attempts');
  117. // Check if the current IP has been used in failed login attempts.
  118. $attempts = \count($rateLimiter->getAttempts($ipKey, 'ip'));
  119. $rateLimiter->registerRateLimitedAction($ipKey, 'ip')->registerRateLimitedAction($userKey);
  120. // Check rate limit for both IP and user, but allow each IP a single try even if user is already rate limited.
  121. if ($rateLimiter->isRateLimited($ipKey, 'ip') || ($attempts && $rateLimiter->isRateLimited($userKey))) {
  122. $messages->add($t->translate(['PLUGIN_LOGIN.TOO_MANY_LOGIN_ATTEMPTS', $rateLimiter->getInterval()]), 'error');
  123. $this->setRedirect($this->grav['config']->get('plugins.login.route', '/'));
  124. return true;
  125. }
  126. // Remove login nonce from the form.
  127. $form = array_diff_key($this->post, ['login-form-nonce' => true]);
  128. // Fire Login process.
  129. $event = $this->login->login($form, ['remember_me' => true, 'twofa' => $twofa], ['return_event' => true]);
  130. $user = $event->getUser();
  131. if ($user->authenticated) {
  132. $rateLimiter->resetRateLimit($ipKey, 'ip')->resetRateLimit($userKey);
  133. if ($user->authorized) {
  134. $event->defMessage('PLUGIN_LOGIN.LOGIN_SUCCESSFUL', 'info');
  135. $event->defRedirect(
  136. $this->grav['session']->redirect_after_login ?: $this->grav['uri']->referrer('/')
  137. );
  138. } else {
  139. $login_route = $this->grav['config']->get('plugins.login.route');
  140. $event->defRedirect($login_route ?: $this->grav['uri']->referrer('/'));
  141. }
  142. } else {
  143. if ($user->authorized) {
  144. $event->defMessage('PLUGIN_LOGIN.ACCESS_DENIED', 'error');
  145. $event->defRedirect($this->grav['config']->get('plugins.login.route_unauthorized', '/'));
  146. } else {
  147. $event->defMessage('PLUGIN_LOGIN.LOGIN_FAILED', 'error');
  148. }
  149. }
  150. $message = $event->getMessage();
  151. if ($message) {
  152. $messages->add($t->translate($message), $event->getMessageType());
  153. }
  154. $redirect = $event->getRedirect();
  155. if ($redirect) {
  156. $this->setRedirect($redirect, $event->getRedirectCode());
  157. }
  158. return true;
  159. }
  160. public function taskTwoFa()
  161. {
  162. /** @var Language $t */
  163. $t = $this->grav['language'];
  164. /** @var Message $messages */
  165. $messages = $this->grav['messages'];
  166. /** @var TwoFactorAuth $twoFa */
  167. $twoFa = $this->grav['login']->twoFactorAuth();
  168. $user = $this->grav['user'];
  169. $code = $this->post['2fa_code'] ?? null;
  170. $secret = $user->twofa_secret ?? null;
  171. if (!$code || !$secret || !$twoFa->verifyCode($secret, $code)) {
  172. $messages->add($t->translate('PLUGIN_LOGIN.2FA_FAILED'), 'error');
  173. $user->authenticated = false;
  174. $login_route = $this->grav['config']->get('plugins.login.route');
  175. if ($login_route) {
  176. $this->setRedirect($login_route, 303);
  177. }
  178. return true;
  179. }
  180. $messages->add($t->translate('PLUGIN_LOGIN.LOGIN_SUCCESSFUL'), 'info');
  181. $user->authorized = true;
  182. $this->setRedirect(
  183. $this->grav['session']->redirect_after_login
  184. ?: $this->grav['config']->get('plugins.login.redirect_after_login')
  185. ?: $this->grav['uri']->referrer('/')
  186. );
  187. return true;
  188. }
  189. /**
  190. * Handle logout.
  191. *
  192. * @return bool True if the action was performed.
  193. */
  194. public function taskLogout()
  195. {
  196. $event = $this->login->logout(['remember_me' => true], ['return_event' => true]);
  197. $message = $event->getMessage();
  198. if ($message) {
  199. /** @var Language $t */
  200. $t = $this->grav['language'];
  201. $messages = $this->grav['messages'];
  202. $messages->add($t->translate($message), $event->getMessageType());
  203. }
  204. $redirect = $event->getRedirect() ?: $this->grav['config']->get('plugins.login.redirect_after_logout');
  205. if ($redirect) {
  206. $this->setRedirect($redirect, $event->getRedirectCode());
  207. }
  208. $this->grav['session']->setFlashCookieObject(LoginPlugin::TMP_COOKIE_NAME, ['message' => $this->grav['language']->translate('PLUGIN_LOGIN.LOGGED_OUT'),
  209. 'status' => 'info']);
  210. return true;
  211. }
  212. /**
  213. * Handle the email password recovery procedure.
  214. *
  215. * @return bool True if the action was performed.
  216. */
  217. protected function taskForgot()
  218. {
  219. $param_sep = $this->grav['config']->get('system.param_sep', ':');
  220. $data = $this->post;
  221. /** @var UserCollectionInterface $users */
  222. $users = $this->grav['accounts'];
  223. $email = $data['email'] ?? '';
  224. $user = !empty($email) ? $users->find($email, ['email']) : null;
  225. /** @var Language $language */
  226. $language = $this->grav['language'];
  227. $messages = $this->grav['messages'];
  228. if (!isset($this->grav['Email'])) {
  229. $messages->add($language->translate('PLUGIN_LOGIN.FORGOT_EMAIL_NOT_CONFIGURED'), 'error');
  230. $this->setRedirect($this->grav['config']->get('plugins.login.route_forgot', '/'));
  231. return true;
  232. }
  233. if (!$user || !$user->exists()) {
  234. $messages->add($language->translate('PLUGIN_LOGIN.FORGOT_INSTRUCTIONS_SENT_VIA_EMAIL'), 'info');
  235. $this->setRedirect($this->grav['config']->get('plugins.login.route_forgot', '/'));
  236. return true;
  237. }
  238. if (empty($user->email)) {
  239. $messages->add($language->translate(['PLUGIN_LOGIN.FORGOT_CANNOT_RESET_EMAIL_NO_EMAIL', $email]),
  240. 'error');
  241. $this->setRedirect($this->grav['config']->get('plugins.login.route_forgot', '/'));
  242. return true;
  243. }
  244. if (empty($user->password) && empty($user->hashed_password)) {
  245. $messages->add($language->translate(['PLUGIN_LOGIN.FORGOT_CANNOT_RESET_EMAIL_NO_PASSWORD', $email]),
  246. 'error');
  247. $this->setRedirect($this->grav['config']->get('plugins.login.route_forgot', '/'));
  248. return true;
  249. }
  250. $from = $this->grav['config']->get('plugins.email.from');
  251. if (empty($from)) {
  252. $messages->add($language->translate('PLUGIN_LOGIN.FORGOT_EMAIL_NOT_CONFIGURED'), 'error');
  253. $this->setRedirect($this->grav['config']->get('plugins.login.route_forgot', '/'));
  254. return true;
  255. }
  256. $userKey = $user->username;
  257. $rateLimiter = $this->login->getRateLimiter('pw_resets');
  258. $rateLimiter->registerRateLimitedAction($userKey);
  259. if ($rateLimiter->isRateLimited($userKey)) {
  260. $messages->add($language->translate(['PLUGIN_LOGIN.FORGOT_CANNOT_RESET_IT_IS_BLOCKED', $email, $rateLimiter->getInterval()]), 'error');
  261. $this->setRedirect($this->grav['config']->get('plugins.login.route', '/'));
  262. return true;
  263. }
  264. $token = md5(uniqid(mt_rand(), true));
  265. $expire = time() + 604800; // next week
  266. $user->reset = $token . '::' . $expire;
  267. $user->save();
  268. $author = $this->grav['config']->get('site.author.name', '');
  269. $fullname = $user->fullname ?: $user->username;
  270. if ($this->grav['language']->getDefault() != $this->grav['language']->getLanguage()) {
  271. $lang = '/'.$this->grav['language']->getLanguage();
  272. } else {
  273. $lang = '';
  274. }
  275. $reset_link = $this->grav['base_url_absolute'] . $lang . $this->grav['config']->get('plugins.login.route_reset') . '/task:login.reset/token' . $param_sep . $token . '/user' . $param_sep . $user->username . '/nonce' . $param_sep . Utils::getNonce('reset-form');
  276. $sitename = $this->grav['config']->get('site.title', 'Website');
  277. $to = $user->email;
  278. $subject = $language->translate(['PLUGIN_LOGIN.FORGOT_EMAIL_SUBJECT', $sitename]);
  279. $content = $language->translate(['PLUGIN_LOGIN.FORGOT_EMAIL_BODY', $fullname, $reset_link, $author, $sitename]);
  280. $sent = EmailUtils::sendEmail($subject, $content, $to);
  281. if ($sent < 1) {
  282. $messages->add($language->translate('PLUGIN_LOGIN.FORGOT_FAILED_TO_EMAIL'), 'error');
  283. } else {
  284. $messages->add($language->translate('PLUGIN_LOGIN.FORGOT_INSTRUCTIONS_SENT_VIA_EMAIL'), 'info');
  285. }
  286. $this->setRedirect($this->grav['config']->get('plugins.login.route', '/'));
  287. return true;
  288. }
  289. /**
  290. * Handle the reset password action.
  291. *
  292. * @return bool True if the action was performed.
  293. * @throws \Exception
  294. */
  295. public function taskReset()
  296. {
  297. $data = $this->post;
  298. $language = $this->grav['language'];
  299. $messages = $this->grav['messages'];
  300. if (isset($data['password'])) {
  301. /** @var UserCollectionInterface $users */
  302. $users = $this->grav['accounts'];
  303. $username = $data['username'] ?? null;
  304. $user = !empty($username) ? $users->find($username) : null;
  305. $password = $data['password'] ?? null;
  306. $token = $data['token'] ?? null;
  307. if ($user && !empty($user->reset) && $user->exists()) {
  308. [$good_token, $expire] = explode('::', $user->reset);
  309. if ($good_token === $token) {
  310. if (time() > $expire) {
  311. $messages->add($language->translate('PLUGIN_LOGIN.RESET_LINK_EXPIRED'), 'error');
  312. $this->grav->redirectLangSafe($this->grav['config']->get('plugins.login.route_forgot', '/'));
  313. return true;
  314. }
  315. unset($user->hashed_password, $user->reset);
  316. $user->password = $password;
  317. $user->save();
  318. $messages->add($language->translate('PLUGIN_LOGIN.RESET_PASSWORD_RESET'), 'info');
  319. $this->setRedirect($this->grav['config']->get('plugins.login.route', '/'));
  320. return true;
  321. }
  322. }
  323. $messages->add($language->translate('PLUGIN_LOGIN.RESET_INVALID_LINK'), 'error');
  324. $this->grav->redirectLangSafe($this->grav['config']->get('plugins.login.route_forgot'));
  325. return true;
  326. }
  327. $user = $this->grav['uri']->param('user');
  328. $token = $this->grav['uri']->param('token');
  329. if (!$user || !$token) {
  330. $messages->add($language->translate('PLUGIN_LOGIN.RESET_INVALID_LINK'), 'error');
  331. $this->grav->redirectLangSafe($this->grav['config']->get('plugins.login.route_forgot'));
  332. return true;
  333. }
  334. return true;
  335. }
  336. /**
  337. * @param null $secret
  338. * @return bool
  339. */
  340. public function taskRegenerate2FASecret()
  341. {
  342. try {
  343. /** @var UserInterface $user */
  344. $user = $this->grav['user'];
  345. if ($user->exists()) {
  346. /** @var TwoFactorAuth $twoFa */
  347. $twoFa = $this->grav['login']->twoFactorAuth();
  348. $secret = $twoFa->createSecret();
  349. $image = $twoFa->getQrImageData($user->username, $secret);
  350. // Change secret in the session.
  351. $user->twofa_secret = $secret;
  352. // Save secret into the user file.
  353. $user->save();
  354. $json_response = ['status' => 'success', 'image' => $image, 'secret' => trim(preg_replace('|(\w{4})|', '\\1 ', $secret))];
  355. } else {
  356. $json_response = ['status' => 'error', 'message' => 'user does not exist'];
  357. }
  358. } catch (\Exception $e) {
  359. $json_response = ['status' => 'error', 'message' => $e->getMessage()];
  360. }
  361. // Return JSON
  362. header('Content-Type: application/json');
  363. echo json_encode($json_response);
  364. exit;
  365. }
  366. /**
  367. * Redirects an action
  368. */
  369. public function redirect()
  370. {
  371. if ($this->redirect) {
  372. $this->grav->redirectLangSafe($this->redirect, $this->redirectCode);
  373. }
  374. }
  375. /**
  376. * Set redirect.
  377. *
  378. * @param $path
  379. * @param int $code
  380. */
  381. public function setRedirect($path, $code = 303)
  382. {
  383. $this->redirect = $path;
  384. $this->redirectCode = $code;
  385. }
  386. /**
  387. * @return array Array containing [redirect, code].
  388. */
  389. public function getRedirect()
  390. {
  391. return [$this->redirect, $this->redirectCode];
  392. }
  393. /**
  394. * Prepare and return POST data.
  395. *
  396. * @param array $post
  397. *
  398. * @return array
  399. */
  400. protected function &getPost(array $post)
  401. {
  402. unset($post[$this->prefix]);
  403. // Decode JSON encoded fields and merge them to data.
  404. if (isset($post['_json'])) {
  405. $post = array_merge_recursive($post, $this->jsonDecode($post['_json']));
  406. unset($post['_json']);
  407. }
  408. return $post;
  409. }
  410. /**
  411. * Recursively JSON decode data.
  412. *
  413. * @param array $data
  414. *
  415. * @return array
  416. */
  417. protected function jsonDecode(array $data)
  418. {
  419. foreach ($data as &$value) {
  420. if (\is_array($value)) {
  421. $value = $this->jsonDecode($value);
  422. } else {
  423. $value = json_decode($value, true);
  424. }
  425. }
  426. return $data;
  427. }
  428. /**
  429. * Gets and sets the RememberMe class
  430. *
  431. * @param mixed $var A rememberMe instance to set
  432. *
  433. * @return RememberMe\RememberMe Returns the current rememberMe instance
  434. * @deprecated 2.5.0 Use $grav['login']->rememberMe() instead
  435. */
  436. public function rememberMe($var = null)
  437. {
  438. $this->rememberMe = $this->login->rememberMe($var);
  439. return $this->rememberMe;
  440. }
  441. /**
  442. * Check if user may use password reset functionality.
  443. *
  444. * @param UserInterface $user
  445. * @param $field
  446. * @param $count
  447. * @param $interval
  448. * @return bool
  449. * @deprecated 2.5.0 Use $grav['login']->getRateLimiter($context) instead. See Grav\Plugin\Login\RateLimiter class.
  450. */
  451. protected function isUserRateLimited(UserInterface $user, $field, $count, $interval)
  452. {
  453. return $this->login->isUserRateLimited($user, $field, $count, $interval);
  454. }
  455. /**
  456. * Reset the rate limit counter
  457. *
  458. * @param UserInterface $user
  459. * @param $field
  460. * @deprecated 2.5.0 Use $grav['login']->getRateLimiter($context) instead. See Grav\Plugin\Login\RateLimiter class.
  461. */
  462. protected function resetRateLimit(UserInterface $user, $field)
  463. {
  464. $this->login->resetRateLimit($user, $field);
  465. }
  466. /**
  467. * Authenticate user.
  468. *
  469. * @param array $form Form fields.
  470. *
  471. * @return bool
  472. * @deprecated 2.6.2 Will be removed without replacement.
  473. */
  474. protected function authenticate($form)
  475. {
  476. // Remove login nonce.
  477. $form = array_diff_key($form, ['login-form-nonce' => true]);
  478. return $this->login->login($form, ['remember_me' => true])->authenticated;
  479. }
  480. }