functions.auth.inc.php 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715
  1. <?php
  2. function check_login($user, $pass, $extra = null) {
  3. global $pdo;
  4. global $redis;
  5. $is_internal = $extra['is_internal'];
  6. $role = $extra['role'];
  7. $extra['service'] = !isset($extra['service']) ? 'NONE' : $extra['service'];
  8. // Try validate admin
  9. if (!isset($role) || $role == "admin") {
  10. $result = admin_login($user, $pass);
  11. if ($result !== false){
  12. return $result;
  13. }
  14. }
  15. // Try validate domain admin
  16. if (!isset($role) || $role == "domain_admin") {
  17. $result = domainadmin_login($user, $pass);
  18. if ($result !== false) {
  19. return $result;
  20. }
  21. }
  22. // Try validate app password
  23. if (!isset($role) || $role == "app") {
  24. $result = apppass_login($user, $pass, $extra);
  25. if ($result !== false) {
  26. $real_rip = ($_SERVER['HTTP_X_REAL_IP'] ?? $_SERVER['REMOTE_ADDR']);
  27. set_sasl_log($user, $real_rip, $extra['service'], $pass);
  28. return $result;
  29. }
  30. }
  31. // Try validate user
  32. if (!isset($role) || $role == "user") {
  33. $result = user_login($user, $pass, $extra);
  34. if ($result !== false) {
  35. $real_rip = ($_SERVER['HTTP_X_REAL_IP'] ?? $_SERVER['REMOTE_ADDR']);
  36. set_sasl_log($user, $real_rip, $extra['service']);
  37. return $result;
  38. }
  39. }
  40. // skip log and only return false if it's an internal request
  41. if ($is_internal == true) return false;
  42. if (!isset($_SESSION['ldelay'])) {
  43. $_SESSION['ldelay'] = "0";
  44. $redis->publish("F2B_CHANNEL", "mailcow UI: Invalid password for " . $user . " by " . $_SERVER['REMOTE_ADDR']);
  45. error_log("mailcow UI: Invalid password for " . $user . " by " . $_SERVER['REMOTE_ADDR']);
  46. }
  47. elseif (!isset($_SESSION['mailcow_cc_username'])) {
  48. $_SESSION['ldelay'] = $_SESSION['ldelay']+0.5;
  49. $redis->publish("F2B_CHANNEL", "mailcow UI: Invalid password for " . $user . " by " . $_SERVER['REMOTE_ADDR']);
  50. error_log("mailcow UI: Invalid password for " . $user . " by " . $_SERVER['REMOTE_ADDR']);
  51. }
  52. $_SESSION['return'][] = array(
  53. 'type' => 'danger',
  54. 'log' => array(__FUNCTION__, $user, '*'),
  55. 'msg' => 'login_failed'
  56. );
  57. sleep($_SESSION['ldelay']);
  58. return false;
  59. }
  60. function admin_login($user, $pass){
  61. global $pdo;
  62. if (!filter_var($user, FILTER_VALIDATE_EMAIL) && !ctype_alnum(str_replace(array('_', '.', '-'), '', $user))) {
  63. if (!$is_internal){
  64. $_SESSION['return'][] = array(
  65. 'type' => 'danger',
  66. 'log' => array(__FUNCTION__, $user, '*'),
  67. 'msg' => 'malformed_username'
  68. );
  69. }
  70. return false;
  71. }
  72. $user = strtolower(trim($user));
  73. $stmt = $pdo->prepare("SELECT `password` FROM `admin`
  74. WHERE `superadmin` = '1'
  75. AND `active` = '1'
  76. AND `username` = :user");
  77. $stmt->execute(array(':user' => $user));
  78. $row = $stmt->fetch(PDO::FETCH_ASSOC);
  79. // verify password
  80. if (verify_hash($row['password'], $pass)) {
  81. // check for tfa authenticators
  82. $authenticators = get_tfa($user);
  83. if (isset($authenticators['additional']) && is_array($authenticators['additional']) && count($authenticators['additional']) > 0) {
  84. // active tfa authenticators found, set pending user login
  85. $_SESSION['pending_mailcow_cc_username'] = $user;
  86. $_SESSION['pending_mailcow_cc_role'] = "admin";
  87. $_SESSION['pending_tfa_methods'] = $authenticators['additional'];
  88. unset($_SESSION['ldelay']);
  89. $_SESSION['return'][] = array(
  90. 'type' => 'info',
  91. 'log' => array(__FUNCTION__, $user, '*'),
  92. 'msg' => 'awaiting_tfa_confirmation'
  93. );
  94. return "pending";
  95. } else {
  96. unset($_SESSION['ldelay']);
  97. // Reactivate TFA if it was set to "deactivate TFA for next login"
  98. $stmt = $pdo->prepare("UPDATE `tfa` SET `active`='1' WHERE `username` = :user");
  99. $stmt->execute(array(':user' => $user));
  100. $_SESSION['return'][] = array(
  101. 'type' => 'success',
  102. 'log' => array(__FUNCTION__, $user, '*'),
  103. 'msg' => array('logged_in_as', $user)
  104. );
  105. return "admin";
  106. }
  107. }
  108. return false;
  109. }
  110. function domainadmin_login($user, $pass){
  111. global $pdo;
  112. if (!filter_var($user, FILTER_VALIDATE_EMAIL) && !ctype_alnum(str_replace(array('_', '.', '-'), '', $user))) {
  113. if (!$is_internal){
  114. $_SESSION['return'][] = array(
  115. 'type' => 'danger',
  116. 'log' => array(__FUNCTION__, $user, '*'),
  117. 'msg' => 'malformed_username'
  118. );
  119. }
  120. return false;
  121. }
  122. $stmt = $pdo->prepare("SELECT `password` FROM `admin`
  123. WHERE `superadmin` = '0'
  124. AND `active`='1'
  125. AND `username` = :user");
  126. $stmt->execute(array(':user' => $user));
  127. $row = $stmt->fetch(PDO::FETCH_ASSOC);
  128. // verify password
  129. if (verify_hash($row['password'], $pass) !== false) {
  130. // check for tfa authenticators
  131. $authenticators = get_tfa($user);
  132. if (isset($authenticators['additional']) && is_array($authenticators['additional']) && count($authenticators['additional']) > 0) {
  133. $_SESSION['pending_mailcow_cc_username'] = $user;
  134. $_SESSION['pending_mailcow_cc_role'] = "domainadmin";
  135. $_SESSION['pending_tfa_methods'] = $authenticators['additional'];
  136. unset($_SESSION['ldelay']);
  137. $_SESSION['return'][] = array(
  138. 'type' => 'info',
  139. 'log' => array(__FUNCTION__, $user, '*'),
  140. 'msg' => 'awaiting_tfa_confirmation'
  141. );
  142. return "pending";
  143. }
  144. else {
  145. unset($_SESSION['ldelay']);
  146. // Reactivate TFA if it was set to "deactivate TFA for next login"
  147. $stmt = $pdo->prepare("UPDATE `tfa` SET `active`='1' WHERE `username` = :user");
  148. $stmt->execute(array(':user' => $user));
  149. $_SESSION['return'][] = array(
  150. 'type' => 'success',
  151. 'log' => array(__FUNCTION__, $user, '*'),
  152. 'msg' => array('logged_in_as', $user)
  153. );
  154. return "domainadmin";
  155. }
  156. }
  157. return false;
  158. }
  159. function user_login($user, $pass, $extra = null){
  160. global $pdo;
  161. global $iam_provider;
  162. global $iam_settings;
  163. $is_internal = $extra['is_internal'];
  164. $extra['service'] = !isset($extra['service']) ? 'NONE' : $extra['service'];
  165. if (!filter_var($user, FILTER_VALIDATE_EMAIL) && !ctype_alnum(str_replace(array('_', '.', '-'), '', $user))) {
  166. if (!$is_internal){
  167. $_SESSION['return'][] = array(
  168. 'type' => 'danger',
  169. 'log' => array(__FUNCTION__, $user, '*'),
  170. 'msg' => 'malformed_username'
  171. );
  172. }
  173. return false;
  174. }
  175. $stmt = $pdo->prepare("SELECT
  176. mailbox.*,
  177. domain.active AS d_active
  178. FROM `mailbox`
  179. INNER JOIN domain on mailbox.domain = domain.domain
  180. WHERE `kind` NOT REGEXP 'location|thing|group'
  181. AND `username` = :user");
  182. $stmt->execute(array(':user' => $user));
  183. $row = $stmt->fetch(PDO::FETCH_ASSOC);
  184. // user does not exist, try call idp login and create user if possible via rest flow
  185. if (!$row){
  186. $result = false;
  187. if ($iam_settings['authsource'] == 'keycloak' && intval($iam_settings['mailpassword_flow']) == 1){
  188. $result = keycloak_mbox_login_rest($user, $pass, array('is_internal' => $is_internal, 'create' => true));
  189. } else if ($iam_settings['authsource'] == 'ldap') {
  190. $result = ldap_mbox_login($user, $pass, array('is_internal' => $is_internal, 'create' => true));
  191. }
  192. if ($result !== false){
  193. // double check if mailbox is active
  194. $stmt = $pdo->prepare("SELECT * FROM `mailbox`
  195. INNER JOIN domain on mailbox.domain = domain.domain
  196. WHERE `kind` NOT REGEXP 'location|thing|group'
  197. AND `mailbox`.`active`='1'
  198. AND `domain`.`active`='1'
  199. AND `username` = :user");
  200. $stmt->execute(array(':user' => $user));
  201. $row = $stmt->fetch(PDO::FETCH_ASSOC);
  202. if (!empty($row)) {
  203. // check if user has access to service (imap, smtp, pop3, sieve, dav, eas) if service is set
  204. $row['attributes'] = json_decode($row['attributes'], true);
  205. if ($extra['service'] != 'NONE') {
  206. $key = strtolower($extra['service']) . "_access";
  207. if (isset($row['attributes'][$key]) && $row['attributes'][$key] != '1') {
  208. return false;
  209. }
  210. }
  211. return true;
  212. }
  213. }
  214. clear_session();
  215. return false;
  216. }
  217. // check if user has access to service (imap, smtp, pop3, sieve) if service is set
  218. $row['attributes'] = json_decode($row['attributes'], true);
  219. if ($extra['service'] != 'NONE') {
  220. $key = strtolower($extra['service']) . "_access";
  221. if (isset($row['attributes'][$key]) && $row['attributes'][$key] != '1') {
  222. return false;
  223. }
  224. }
  225. switch ($row['authsource']) {
  226. case 'keycloak':
  227. // user authsource is keycloak, try using via rest flow
  228. if (intval($iam_settings['mailpassword_flow']) == 1){
  229. $result = keycloak_mbox_login_rest($user, $pass, array('is_internal' => $is_internal));
  230. if ($result !== false) {
  231. // double check if mailbox and domain is active
  232. $stmt = $pdo->prepare("SELECT * FROM `mailbox`
  233. INNER JOIN domain on mailbox.domain = domain.domain
  234. WHERE `kind` NOT REGEXP 'location|thing|group'
  235. AND `mailbox`.`active`='1'
  236. AND `domain`.`active`='1'
  237. AND `username` = :user");
  238. $stmt->execute(array(':user' => $user));
  239. $row = $stmt->fetch(PDO::FETCH_ASSOC);
  240. if (empty($row)) {
  241. return false;
  242. }
  243. // check for tfa authenticators
  244. $authenticators = get_tfa($user);
  245. if (isset($authenticators['additional']) && is_array($authenticators['additional']) && count($authenticators['additional']) > 0 && !$is_internal) {
  246. // authenticators found, init TFA flow
  247. $_SESSION['pending_mailcow_cc_username'] = $user;
  248. $_SESSION['pending_mailcow_cc_role'] = "user";
  249. $_SESSION['pending_tfa_methods'] = $authenticators['additional'];
  250. unset($_SESSION['ldelay']);
  251. $_SESSION['return'][] = array(
  252. 'type' => 'success',
  253. 'log' => array(__FUNCTION__, $user, '*', 'Provider: Keycloak'),
  254. 'msg' => array('logged_in_as', $user)
  255. );
  256. return "pending";
  257. } else if (!isset($authenticators['additional']) || !is_array($authenticators['additional']) || count($authenticators['additional']) == 0) {
  258. // no authenticators found, login successfull
  259. if (!$is_internal){
  260. unset($_SESSION['ldelay']);
  261. // Reactivate TFA if it was set to "deactivate TFA for next login"
  262. $stmt = $pdo->prepare("UPDATE `tfa` SET `active`='1' WHERE `username` = :user");
  263. $stmt->execute(array(':user' => $user));
  264. $_SESSION['return'][] = array(
  265. 'type' => 'success',
  266. 'log' => array(__FUNCTION__, $user, '*', 'Provider: Keycloak'),
  267. 'msg' => array('logged_in_as', $user)
  268. );
  269. }
  270. return "user";
  271. }
  272. }
  273. return $result;
  274. } else {
  275. return false;
  276. }
  277. break;
  278. case 'ldap':
  279. // user authsource is ldap
  280. $result = ldap_mbox_login($user, $pass, array('is_internal' => $is_internal));
  281. if ($result !== false) {
  282. // double check if mailbox and domain is active
  283. $stmt = $pdo->prepare("SELECT * FROM `mailbox`
  284. INNER JOIN domain on mailbox.domain = domain.domain
  285. WHERE `kind` NOT REGEXP 'location|thing|group'
  286. AND `mailbox`.`active`='1'
  287. AND `domain`.`active`='1'
  288. AND `username` = :user");
  289. $stmt->execute(array(':user' => $user));
  290. $row = $stmt->fetch(PDO::FETCH_ASSOC);
  291. if (empty($row)) {
  292. return false;
  293. }
  294. // check for tfa authenticators
  295. $authenticators = get_tfa($user);
  296. if (isset($authenticators['additional']) && is_array($authenticators['additional']) && count($authenticators['additional']) > 0 && !$is_internal) {
  297. // authenticators found, init TFA flow
  298. $_SESSION['pending_mailcow_cc_username'] = $user;
  299. $_SESSION['pending_mailcow_cc_role'] = "user";
  300. $_SESSION['pending_tfa_methods'] = $authenticators['additional'];
  301. unset($_SESSION['ldelay']);
  302. $_SESSION['return'][] = array(
  303. 'type' => 'success',
  304. 'log' => array(__FUNCTION__, $user, '*', 'Provider: LDAP'),
  305. 'msg' => array('logged_in_as', $user)
  306. );
  307. return "pending";
  308. } else if (!isset($authenticators['additional']) || !is_array($authenticators['additional']) || count($authenticators['additional']) == 0) {
  309. // no authenticators found, login successfull
  310. if (!$is_internal){
  311. unset($_SESSION['ldelay']);
  312. // Reactivate TFA if it was set to "deactivate TFA for next login"
  313. $stmt = $pdo->prepare("UPDATE `tfa` SET `active`='1' WHERE `username` = :user");
  314. $stmt->execute(array(':user' => $user));
  315. $_SESSION['return'][] = array(
  316. 'type' => 'success',
  317. 'log' => array(__FUNCTION__, $user, '*', 'Provider: LDAP'),
  318. 'msg' => array('logged_in_as', $user)
  319. );
  320. }
  321. return "user";
  322. }
  323. }
  324. return $result;
  325. break;
  326. case 'mailcow':
  327. if ($row['active'] != 1 || $row['d_active'] != 1) {
  328. return false;
  329. }
  330. // verify password
  331. if (verify_hash($row['password'], $pass) !== false) {
  332. if (intval($row['attributes']['force_pw_update']) == 1) {
  333. $_SESSION['pending_pw_update'] = true;
  334. }
  335. // check for tfa authenticators
  336. $authenticators = get_tfa($user);
  337. if (isset($authenticators['additional']) && is_array($authenticators['additional']) && count($authenticators['additional']) > 0 && !$is_internal) {
  338. // authenticators found, init TFA flow
  339. $_SESSION['pending_mailcow_cc_username'] = $user;
  340. $_SESSION['pending_mailcow_cc_role'] = "user";
  341. $_SESSION['pending_tfa_methods'] = $authenticators['additional'];
  342. unset($_SESSION['ldelay']);
  343. $_SESSION['return'][] = array(
  344. 'type' => 'success',
  345. 'log' => array(__FUNCTION__, $user, '*', 'Provider: mailcow'),
  346. 'msg' => array('logged_in_as', $user)
  347. );
  348. return "pending";
  349. } else if (!isset($authenticators['additional']) || !is_array($authenticators['additional']) || count($authenticators['additional']) == 0) {
  350. // no authenticators found, login successfull
  351. if (!$is_internal){
  352. unset($_SESSION['ldelay']);
  353. // Reactivate TFA if it was set to "deactivate TFA for next login"
  354. $stmt = $pdo->prepare("UPDATE `tfa` SET `active`='1' WHERE `username` = :user");
  355. $stmt->execute(array(':user' => $user));
  356. $_SESSION['return'][] = array(
  357. 'type' => 'success',
  358. 'log' => array(__FUNCTION__, $user, '*', 'Provider: mailcow'),
  359. 'msg' => array('logged_in_as', $user)
  360. );
  361. }
  362. return "user";
  363. }
  364. }
  365. break;
  366. }
  367. return false;
  368. }
  369. function apppass_login($user, $pass, $extra = null){
  370. global $pdo;
  371. $is_internal = $extra['is_internal'];
  372. if (!filter_var($user, FILTER_VALIDATE_EMAIL) && !ctype_alnum(str_replace(array('_', '.', '-'), '', $user))) {
  373. if (!$is_internal){
  374. $_SESSION['return'][] = array(
  375. 'type' => 'danger',
  376. 'log' => array(__FUNCTION__, $user, '*'),
  377. 'msg' => 'malformed_username'
  378. );
  379. }
  380. return false;
  381. }
  382. $extra['service'] = !isset($extra['service']) ? 'NONE' : $extra['service'];
  383. if (!$is_internal && $extra['service'] == 'NONE') {
  384. return false;
  385. }
  386. // fetch app password data
  387. $stmt = $pdo->prepare("SELECT `app_passwd`.*, `app_passwd`.`password` as `password`, `app_passwd`.`id` as `app_passwd_id` FROM `app_passwd`
  388. INNER JOIN `mailbox` ON `mailbox`.`username` = `app_passwd`.`mailbox`
  389. INNER JOIN `domain` ON `mailbox`.`domain` = `domain`.`domain`
  390. WHERE `mailbox`.`kind` NOT REGEXP 'location|thing|group'
  391. AND `mailbox`.`active` = '1'
  392. AND `domain`.`active` = '1'
  393. AND `app_passwd`.`active` = '1'
  394. AND `app_passwd`.`mailbox` = :user"
  395. );
  396. // fetch password data
  397. $stmt->execute(array(
  398. ':user' => $user,
  399. ));
  400. $rows = $stmt->fetchAll(PDO::FETCH_ASSOC);
  401. foreach ($rows as $row) {
  402. if ($extra['service'] != 'NONE' && $row[strtolower($extra['service']) . '_access'] != '1'){
  403. continue;
  404. }
  405. // verify password
  406. if (verify_hash($row['password'], $pass) !== false) {
  407. $_SESSION['app_passwd_id'] = $row['app_passwd_id'];
  408. unset($_SESSION['ldelay']);
  409. return "user";
  410. }
  411. }
  412. return false;
  413. }
  414. // Keycloak REST Api Flow - auth user by mailcow_password attribute
  415. // This password will be used for direct UI, IMAP and SMTP Auth
  416. // To use direct user credentials, only Authorization Code Flow is valid
  417. function keycloak_mbox_login_rest($user, $pass, $extra = null){
  418. global $pdo;
  419. global $iam_provider;
  420. global $iam_settings;
  421. $is_internal = $extra['is_internal'];
  422. $create = $extra['create'];
  423. if (!filter_var($user, FILTER_VALIDATE_EMAIL) && !ctype_alnum(str_replace(array('_', '.', '-'), '', $user))) {
  424. if (!$is_internal){
  425. $_SESSION['return'][] = array(
  426. 'type' => 'danger',
  427. 'log' => array(__FUNCTION__, $user, '*'),
  428. 'msg' => 'malformed_username'
  429. );
  430. }
  431. return false;
  432. }
  433. if (!$iam_provider) {
  434. return false;
  435. }
  436. // get access_token for service account of mailcow client
  437. $admin_token = identity_provider("get-keycloak-admin-token");
  438. // get the mailcow_password attribute from keycloak user
  439. $url = "{$iam_settings['server_url']}/admin/realms/{$iam_settings['realm']}/users";
  440. $queryParams = array('email' => $user, 'exact' => true);
  441. $queryString = http_build_query($queryParams);
  442. $curl = curl_init();
  443. curl_setopt($curl, CURLOPT_TIMEOUT, 7);
  444. curl_setopt($curl, CURLOPT_URL, $url . '?' . $queryString);
  445. curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
  446. curl_setopt($curl, CURLOPT_HTTPHEADER, array(
  447. 'Authorization: Bearer ' . $admin_token,
  448. 'Content-Type: application/json'
  449. ));
  450. $user_res = json_decode(curl_exec($curl), true)[0];
  451. $code = curl_getinfo($curl, CURLINFO_HTTP_CODE);
  452. curl_close($curl);
  453. if ($code != 200) {
  454. $_SESSION['return'][] = array(
  455. 'type' => 'danger',
  456. 'log' => array(__FUNCTION__, $user, '*', 'Identity Provider returned HTTP ' . $code),
  457. 'msg' => 'generic_server_error'
  458. );
  459. return false;
  460. }
  461. if (!isset($user_res['attributes']['mailcow_password']) || !is_array($user_res['attributes']['mailcow_password'])){
  462. $_SESSION['return'][] = array(
  463. 'type' => 'danger',
  464. 'log' => array(__FUNCTION__, $user, '*', 'User has no mailcow_password attribute'),
  465. 'msg' => 'generic_server_error'
  466. );
  467. return false;
  468. }
  469. if (empty($user_res['attributes']['mailcow_password'][0])){
  470. $_SESSION['return'][] = array(
  471. 'type' => 'danger',
  472. 'log' => array(__FUNCTION__, $user, '*', "User's mailcow_password attribute is empty"),
  473. 'msg' => 'generic_server_error'
  474. );
  475. return false;
  476. }
  477. // validate mailcow_password
  478. $mailcow_password = $user_res['attributes']['mailcow_password'][0];
  479. if (!verify_hash($mailcow_password, $pass)) {
  480. return false;
  481. }
  482. // get mapped template
  483. $user_template = $user_res['attributes']['mailcow_template'][0];
  484. $mapper_key = array_search($user_template, $iam_settings['mappers']);
  485. if (!$create) {
  486. // login success
  487. if ($mapper_key !== false) {
  488. // update user
  489. $_SESSION['access_all_exception'] = '1';
  490. mailbox('edit', 'mailbox_from_template', array(
  491. 'username' => $user,
  492. 'name' => $user_res['name'],
  493. 'template' => $iam_settings['templates'][$mapper_key]
  494. ));
  495. $_SESSION['access_all_exception'] = '0';
  496. }
  497. return 'user';
  498. }
  499. // check if login provisioning is enabled before creating user
  500. if (!$iam_settings['login_provisioning']){
  501. if (!$is_internal){
  502. $_SESSION['return'][] = array(
  503. 'type' => 'danger',
  504. 'log' => array(__FUNCTION__, "Auto-create users on login is deactivated"),
  505. 'msg' => 'login_failed'
  506. );
  507. }
  508. return false;
  509. }
  510. // check if matching attribute exist
  511. if (empty($iam_settings['mappers']) || !$user_template || $mapper_key === false) {
  512. if (!empty($iam_settings['default_template'])) {
  513. $mbox_template = $iam_settings['default_template'];
  514. } else {
  515. $_SESSION['return'][] = array(
  516. 'type' => 'danger',
  517. 'log' => array(__FUNCTION__, $user, '*', 'No matching attribute mapping was found'),
  518. 'msg' => 'generic_server_error'
  519. );
  520. return false;
  521. }
  522. } else {
  523. $mbox_template = $iam_settings['templates'][$mapper_key];
  524. }
  525. // create mailbox
  526. $_SESSION['access_all_exception'] = '1';
  527. $create_res = mailbox('add', 'mailbox_from_template', array(
  528. 'domain' => explode('@', $user)[1],
  529. 'local_part' => explode('@', $user)[0],
  530. 'name' => $user_res['name'],
  531. 'authsource' => 'keycloak',
  532. 'template' => $mbox_template
  533. ));
  534. $_SESSION['access_all_exception'] = '0';
  535. if (!$create_res){
  536. clear_session();
  537. $_SESSION['return'][] = array(
  538. 'type' => 'danger',
  539. 'log' => array(__FUNCTION__, $user, '*', 'Could not create mailbox on login'),
  540. 'msg' => 'generic_server_error'
  541. );
  542. return false;
  543. }
  544. return 'user';
  545. }
  546. function ldap_mbox_login($user, $pass, $extra = null){
  547. global $pdo;
  548. global $iam_provider;
  549. global $iam_settings;
  550. $is_internal = $extra['is_internal'];
  551. $create = $extra['create'];
  552. if (!filter_var($user, FILTER_VALIDATE_EMAIL) && !ctype_alnum(str_replace(array('_', '.', '-'), '', $user))) {
  553. if (!$is_internal){
  554. $_SESSION['return'][] = array(
  555. 'type' => 'danger',
  556. 'log' => array(__FUNCTION__, $user, '*'),
  557. 'msg' => 'malformed_username'
  558. );
  559. }
  560. return false;
  561. }
  562. if (!$iam_provider) {
  563. return false;
  564. }
  565. try {
  566. $ldap_query = $iam_provider->query();
  567. if (!empty($iam_settings['filter'])) {
  568. $ldap_query = $ldap_query->rawFilter($iam_settings['filter']);
  569. }
  570. $ldap_query = $ldap_query->where($iam_settings['username_field'], '=', $user)
  571. ->select([$iam_settings['username_field'], $iam_settings['attribute_field'], 'displayname', 'distinguishedname', 'dn']);
  572. $user_res = $ldap_query->firstOrFail();
  573. } catch (Exception $e) {
  574. // clear $_SESSION['return'] to not leak data
  575. $_SESSION['return'] = array();
  576. $_SESSION['return'][] = array(
  577. 'type' => 'danger',
  578. 'log' => array(__FUNCTION__, $user, '*', $e->getMessage()),
  579. 'msg' => 'generic_server_error'
  580. );
  581. return false;
  582. }
  583. try {
  584. if (!$iam_provider->auth()->attempt($user_res['dn'], $pass)) {
  585. return false;
  586. }
  587. } catch (Exception $e) {
  588. // clear $_SESSION['return'] to not leak data
  589. $_SESSION['return'] = array();
  590. $_SESSION['return'][] = array(
  591. 'type' => 'danger',
  592. 'log' => array(__FUNCTION__, $user, '*', $e->getMessage()),
  593. 'msg' => 'generic_server_error'
  594. );
  595. return false;
  596. }
  597. // get mapped template
  598. $user_template = $user_res[$iam_settings['attribute_field']][0];
  599. $mapper_key = array_search($user_template, $iam_settings['mappers']);
  600. if (!$create) {
  601. // login success
  602. if ($mapper_key !== false) {
  603. // update user
  604. $_SESSION['access_all_exception'] = '1';
  605. mailbox('edit', 'mailbox_from_template', array(
  606. 'username' => $user,
  607. 'name' => $user_res['displayname'][0],
  608. 'template' => $iam_settings['templates'][$mapper_key]
  609. ));
  610. $_SESSION['access_all_exception'] = '0';
  611. }
  612. return 'user';
  613. }
  614. // check if login provisioning is enabled before creating user
  615. if (!$iam_settings['login_provisioning']){
  616. if (!$is_internal){
  617. $_SESSION['return'][] = array(
  618. 'type' => 'danger',
  619. 'log' => array(__FUNCTION__, "Auto-create users on login is deactivated"),
  620. 'msg' => 'login_failed'
  621. );
  622. }
  623. return false;
  624. }
  625. // check if matching attribute exist
  626. if (empty($iam_settings['mappers']) || !$user_template || $mapper_key === false) {
  627. if (!empty($iam_settings['default_template'])) {
  628. $mbox_template = $iam_settings['default_template'];
  629. } else {
  630. $_SESSION['return'][] = array(
  631. 'type' => 'danger',
  632. 'log' => array(__FUNCTION__, $user, '*', 'No matching attribute mapping was found'),
  633. 'msg' => 'generic_server_error'
  634. );
  635. return false;
  636. }
  637. } else {
  638. $mbox_template = $iam_settings['templates'][$mapper_key];
  639. }
  640. // create mailbox
  641. $_SESSION['access_all_exception'] = '1';
  642. $create_res = mailbox('add', 'mailbox_from_template', array(
  643. 'domain' => explode('@', $user)[1],
  644. 'local_part' => explode('@', $user)[0],
  645. 'name' => $user_res['displayname'][0],
  646. 'authsource' => 'ldap',
  647. 'template' => $mbox_template
  648. ));
  649. $_SESSION['access_all_exception'] = '0';
  650. if (!$create_res){
  651. clear_session();
  652. $_SESSION['return'][] = array(
  653. 'type' => 'danger',
  654. 'log' => array(__FUNCTION__, $user, '*', 'Could not create mailbox on login'),
  655. 'msg' => 'generic_server_error'
  656. );
  657. return false;
  658. }
  659. return 'user';
  660. }