json_api.php 45 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230
  1. <?php
  2. /*
  3. edit/alias => POST data:
  4. {
  5. address: {a, b, c}, (where a, b, c represent alias addresses)
  6. active: 1 (0 or 1)
  7. }
  8. delete/alias => POST data:
  9. {
  10. address: {a, b, c}, (where a, b, c represent alias addresses)
  11. }
  12. */
  13. header('Content-Type: application/json');
  14. require_once $_SERVER['DOCUMENT_ROOT'] . '/inc/prerequisites.inc.php';
  15. error_reporting(0);
  16. function api_log($_data) {
  17. global $redis;
  18. $data_var = array();
  19. foreach ($_data as $data => &$value) {
  20. if ($data == 'csrf_token') {
  21. continue;
  22. }
  23. if ($value = json_decode($value, true)) {
  24. unset($value["csrf_token"]);
  25. foreach ($value as $key => &$val) {
  26. if(preg_match("/pass/i", $key)) {
  27. $val = '*';
  28. }
  29. }
  30. $value = json_encode($value);
  31. }
  32. $data_var[] = $data . "='" . $value . "'";
  33. }
  34. try {
  35. $log_line = array(
  36. 'time' => time(),
  37. 'uri' => $_SERVER['REQUEST_URI'],
  38. 'method' => $_SERVER['REQUEST_METHOD'],
  39. 'remote' => get_remote_ip(),
  40. 'data' => implode(', ', $data_var)
  41. );
  42. $redis->lPush('API_LOG', json_encode($log_line));
  43. }
  44. catch (RedisException $e) {
  45. $_SESSION['return'][] = array(
  46. 'type' => 'danger',
  47. 'msg' => 'Redis: '.$e
  48. );
  49. return false;
  50. }
  51. }
  52. api_log($_POST);
  53. if (isset($_SESSION['mailcow_cc_role']) || isset($_SESSION['pending_mailcow_cc_username'])) {
  54. if (isset($_GET['query'])) {
  55. $query = explode('/', $_GET['query']);
  56. $action = (isset($query[0])) ? $query[0] : null;
  57. $category = (isset($query[1])) ? $query[1] : null;
  58. $object = (isset($query[2])) ? $query[2] : null;
  59. $extra = (isset($query[3])) ? $query[3] : null;
  60. $request_incomplete = json_encode(array(
  61. 'type' => 'error',
  62. 'msg' => 'Cannot find attributes in post data'
  63. ));
  64. switch ($action) {
  65. case "add":
  66. function process_add_return($return) {
  67. $generic_failure = json_encode(array(
  68. 'type' => 'error',
  69. 'msg' => 'Cannot add item'
  70. ));
  71. $generic_success = json_encode(array(
  72. 'type' => 'success',
  73. 'msg' => 'Task completed'
  74. ));
  75. if ($return === false) {
  76. echo isset($_SESSION['return']) ? json_encode($_SESSION['return']) : $generic_failure;
  77. }
  78. else {
  79. echo isset($_SESSION['return']) ? json_encode($_SESSION['return']) : $generic_success;
  80. }
  81. }
  82. if (!isset($_POST['attr'])) {
  83. echo $request_incomplete;
  84. exit;
  85. }
  86. else {
  87. $attr = (array)json_decode($_POST['attr'], true);
  88. unset($attr['csrf_token']);
  89. }
  90. switch ($category) {
  91. case "time_limited_alias":
  92. process_add_return(mailbox('add', 'time_limited_alias', $attr));
  93. break;
  94. case "relayhost":
  95. process_add_return(relayhost('add', $attr));
  96. break;
  97. case "transport":
  98. process_add_return(transport('add', $attr));
  99. break;
  100. case "rsetting":
  101. process_add_return(rsettings('add', $attr));
  102. break;
  103. case "mailbox":
  104. process_add_return(mailbox('add', 'mailbox', $attr));
  105. break;
  106. case "domain":
  107. process_add_return(mailbox('add', 'domain', $attr));
  108. break;
  109. case "resource":
  110. process_add_return(mailbox('add', 'resource', $attr));
  111. break;
  112. case "alias":
  113. process_add_return(mailbox('add', 'alias', $attr));
  114. break;
  115. case "filter":
  116. process_add_return(mailbox('add', 'filter', $attr));
  117. break;
  118. case "domain-policy":
  119. process_add_return(policy('add', 'domain', $attr));
  120. break;
  121. case "mailbox-policy":
  122. process_add_return(policy('add', 'mailbox', $attr));
  123. break;
  124. case "alias-domain":
  125. process_add_return(mailbox('add', 'alias_domain', $attr));
  126. break;
  127. case "fwdhost":
  128. process_add_return(fwdhost('add', $attr));
  129. break;
  130. case "dkim":
  131. process_add_return(dkim('add', $attr));
  132. break;
  133. case "dkim_duplicate":
  134. process_add_return(dkim('duplicate', $attr));
  135. break;
  136. case "dkim_import":
  137. process_add_return(dkim('import', $attr));
  138. break;
  139. case "domain-admin":
  140. process_add_return(domain_admin('add', $attr));
  141. break;
  142. case "admin":
  143. process_add_return(admin('add', $attr));
  144. break;
  145. case "syncjob":
  146. process_add_return(mailbox('add', 'syncjob', $attr));
  147. break;
  148. case "bcc":
  149. process_add_return(bcc('add', $attr));
  150. break;
  151. case "recipient_map":
  152. process_add_return(recipient_map('add', $attr));
  153. break;
  154. case "tls-policy-map":
  155. process_add_return(tls_policy_maps('add', $attr));
  156. break;
  157. }
  158. break;
  159. case "get":
  160. function process_get_return($data) {
  161. echo (!isset($data) || empty($data)) ? '{}' : json_encode($data, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT);
  162. }
  163. switch ($category) {
  164. case "rspamd":
  165. switch ($object) {
  166. case "actions":
  167. $curl = curl_init();
  168. curl_setopt($curl, CURLOPT_UNIX_SOCKET_PATH, '/var/lib/rspamd/rspamd.sock');
  169. curl_setopt($curl, CURLOPT_URL,"http://rspamd/stat");
  170. curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
  171. $data = curl_exec($curl);
  172. if ($data) {
  173. $return = array();
  174. $stats_array = json_decode($data, true)['actions'];
  175. $stats_array['soft reject'] = $stats_array['soft reject'] + $stats_array['greylist'];
  176. unset($stats_array['greylist']);
  177. foreach ($stats_array as $action => $count) {
  178. $return[] = array($action, $count);
  179. }
  180. echo json_encode($return, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT);
  181. }
  182. elseif (!isset($data) || empty($data)) {
  183. echo '{}';
  184. }
  185. break;
  186. }
  187. break;
  188. case "domain":
  189. switch ($object) {
  190. case "all":
  191. $domains = mailbox('get', 'domains');
  192. if (!empty($domains)) {
  193. foreach ($domains as $domain) {
  194. if ($details = mailbox('get', 'domain_details', $domain)) {
  195. $data[] = $details;
  196. }
  197. else {
  198. continue;
  199. }
  200. }
  201. process_get_return($data);
  202. }
  203. else {
  204. echo '{}';
  205. }
  206. break;
  207. default:
  208. $data = mailbox('get', 'domain_details', $object);
  209. process_get_return($data);
  210. break;
  211. }
  212. break;
  213. case "mailq":
  214. switch ($object) {
  215. case "all":
  216. $mailq = mailq('get');
  217. if (!empty($mailq)) {
  218. echo $mailq;
  219. }
  220. else {
  221. echo '{}';
  222. }
  223. break;
  224. }
  225. break;
  226. case "rl-domain":
  227. switch ($object) {
  228. case "all":
  229. $domains = array_merge(mailbox('get', 'domains'), mailbox('get', 'alias_domains'));
  230. if (!empty($domains)) {
  231. foreach ($domains as $domain) {
  232. if ($details = ratelimit('get', 'domain', $domain)) {
  233. $details['domain'] = $domain;
  234. $data[] = $details;
  235. }
  236. else {
  237. continue;
  238. }
  239. }
  240. process_get_return($data);
  241. }
  242. else {
  243. echo '{}';
  244. }
  245. break;
  246. default:
  247. $data = ratelimit('get', 'domain', $object);
  248. process_get_return($data);
  249. break;
  250. }
  251. break;
  252. case "rl-mbox":
  253. switch ($object) {
  254. case "all":
  255. $domains = mailbox('get', 'domains');
  256. if (!empty($domains)) {
  257. foreach ($domains as $domain) {
  258. $mailboxes = mailbox('get', 'mailboxes', $domain);
  259. if (!empty($mailboxes)) {
  260. foreach ($mailboxes as $mailbox) {
  261. if ($details = ratelimit('get', 'mailbox', $mailbox)) {
  262. $details['mailbox'] = $mailbox;
  263. $data[] = $details;
  264. }
  265. else {
  266. continue;
  267. }
  268. }
  269. }
  270. }
  271. process_get_return($data);
  272. }
  273. else {
  274. echo '{}';
  275. }
  276. break;
  277. default:
  278. $data = ratelimit('get', 'mailbox', $object);
  279. process_get_return($data);
  280. break;
  281. }
  282. break;
  283. case "relayhost":
  284. switch ($object) {
  285. case "all":
  286. $relayhosts = relayhost('get');
  287. if (!empty($relayhosts)) {
  288. foreach ($relayhosts as $relayhost) {
  289. if ($details = relayhost('details', $relayhost['id'])) {
  290. $data[] = $details;
  291. }
  292. else {
  293. continue;
  294. }
  295. }
  296. process_get_return($data);
  297. }
  298. else {
  299. echo '{}';
  300. }
  301. break;
  302. default:
  303. $data = relayhost('details', $object);
  304. process_get_return($data);
  305. break;
  306. }
  307. break;
  308. case "transport":
  309. switch ($object) {
  310. case "all":
  311. $transports = transport('get');
  312. if (!empty($transports)) {
  313. foreach ($transports as $transport) {
  314. if ($details = transport('details', $transport['id'])) {
  315. $data[] = $details;
  316. }
  317. else {
  318. continue;
  319. }
  320. }
  321. process_get_return($data);
  322. }
  323. else {
  324. echo '{}';
  325. }
  326. break;
  327. default:
  328. $data = transport('details', $object);
  329. process_get_return($data);
  330. break;
  331. }
  332. break;
  333. case "rsetting":
  334. switch ($object) {
  335. case "all":
  336. $rsettings = rsettings('get');
  337. if (!empty($rsettings)) {
  338. foreach ($rsettings as $rsetting) {
  339. if ($details = rsettings('details', $rsetting['id'])) {
  340. $data[] = $details;
  341. }
  342. else {
  343. continue;
  344. }
  345. }
  346. process_get_return($data);
  347. }
  348. else {
  349. echo '{}';
  350. }
  351. break;
  352. default:
  353. $data = rsetting('details', $object);
  354. process_get_return($data);
  355. break;
  356. }
  357. break;
  358. case "oauth2-client":
  359. switch ($object) {
  360. case "all":
  361. $clients = oauth2('get', 'clients');
  362. if (!empty($clients)) {
  363. foreach ($clients as $client) {
  364. if ($details = oauth2('details', 'client', $client)) {
  365. $data[] = $details;
  366. }
  367. else {
  368. continue;
  369. }
  370. }
  371. process_get_return($data);
  372. }
  373. else {
  374. echo '{}';
  375. }
  376. break;
  377. default:
  378. $data = oauth2('details', 'client', $object);
  379. process_get_return($data);
  380. break;
  381. }
  382. break;
  383. case "logs":
  384. switch ($object) {
  385. case "dovecot":
  386. // 0 is first record, so empty is fine
  387. if (isset($extra)) {
  388. $extra = preg_replace('/[^\d\-]/i', '', $extra);
  389. $logs = get_logs('dovecot-mailcow', $extra);
  390. }
  391. else {
  392. $logs = get_logs('dovecot-mailcow');
  393. }
  394. echo (isset($logs) && !empty($logs)) ? json_encode($logs, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT) : '{}';
  395. break;
  396. case "ratelimited":
  397. // 0 is first record, so empty is fine
  398. if (isset($extra)) {
  399. $extra = preg_replace('/[^\d\-]/i', '', $extra);
  400. $logs = get_logs('ratelimited', $extra);
  401. }
  402. else {
  403. $logs = get_logs('ratelimited');
  404. }
  405. echo (isset($logs) && !empty($logs)) ? json_encode($logs, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT) : '{}';
  406. break;
  407. case "netfilter":
  408. // 0 is first record, so empty is fine
  409. if (isset($extra)) {
  410. $extra = preg_replace('/[^\d\-]/i', '', $extra);
  411. $logs = get_logs('netfilter-mailcow', $extra);
  412. }
  413. else {
  414. $logs = get_logs('netfilter-mailcow');
  415. }
  416. echo (isset($logs) && !empty($logs)) ? json_encode($logs, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT) : '{}';
  417. break;
  418. case "postfix":
  419. // 0 is first record, so empty is fine
  420. if (isset($extra)) {
  421. $extra = preg_replace('/[^\d\-]/i', '', $extra);
  422. $logs = get_logs('postfix-mailcow', $extra);
  423. }
  424. else {
  425. $logs = get_logs('postfix-mailcow');
  426. }
  427. echo (isset($logs) && !empty($logs)) ? json_encode($logs, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT) : '{}';
  428. break;
  429. case "autodiscover":
  430. // 0 is first record, so empty is fine
  431. if (isset($extra)) {
  432. $extra = preg_replace('/[^\d\-]/i', '', $extra);
  433. $logs = get_logs('autodiscover-mailcow', $extra);
  434. }
  435. else {
  436. $logs = get_logs('autodiscover-mailcow');
  437. }
  438. echo (isset($logs) && !empty($logs)) ? json_encode($logs, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT) : '{}';
  439. break;
  440. case "sogo":
  441. // 0 is first record, so empty is fine
  442. if (isset($extra)) {
  443. $extra = preg_replace('/[^\d\-]/i', '', $extra);
  444. $logs = get_logs('sogo-mailcow', $extra);
  445. }
  446. else {
  447. $logs = get_logs('sogo-mailcow');
  448. }
  449. echo (isset($logs) && !empty($logs)) ? json_encode($logs, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT) : '{}';
  450. break;
  451. case "ui":
  452. // 0 is first record, so empty is fine
  453. if (isset($extra)) {
  454. $extra = preg_replace('/[^\d\-]/i', '', $extra);
  455. $logs = get_logs('mailcow-ui', $extra);
  456. }
  457. else {
  458. $logs = get_logs('mailcow-ui');
  459. }
  460. echo (isset($logs) && !empty($logs)) ? json_encode($logs, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT) : '{}';
  461. break;
  462. case "watchdog":
  463. // 0 is first record, so empty is fine
  464. if (isset($extra)) {
  465. $extra = preg_replace('/[^\d\-]/i', '', $extra);
  466. $logs = get_logs('watchdog-mailcow', $extra);
  467. }
  468. else {
  469. $logs = get_logs('watchdog-mailcow');
  470. }
  471. echo (isset($logs) && !empty($logs)) ? json_encode($logs, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT) : '{}';
  472. break;
  473. case "acme":
  474. // 0 is first record, so empty is fine
  475. if (isset($extra)) {
  476. $extra = preg_replace('/[^\d\-]/i', '', $extra);
  477. $logs = get_logs('acme-mailcow', $extra);
  478. }
  479. else {
  480. $logs = get_logs('acme-mailcow');
  481. }
  482. echo (isset($logs) && !empty($logs)) ? json_encode($logs, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT) : '{}';
  483. break;
  484. case "api":
  485. // 0 is first record, so empty is fine
  486. if (isset($extra)) {
  487. $extra = preg_replace('/[^\d\-]/i', '', $extra);
  488. $logs = get_logs('api-mailcow', $extra);
  489. }
  490. else {
  491. $logs = get_logs('api-mailcow');
  492. }
  493. echo (isset($logs) && !empty($logs)) ? json_encode($logs, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT) : '{}';
  494. break;
  495. case "rspamd-history":
  496. // 0 is first record, so empty is fine
  497. if (isset($extra)) {
  498. $extra = preg_replace('/[^\d\-]/i', '', $extra);
  499. $logs = get_logs('rspamd-history', $extra);
  500. }
  501. else {
  502. $logs = get_logs('rspamd-history');
  503. }
  504. echo (isset($logs) && !empty($logs)) ? json_encode($logs, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT) : '{}';
  505. break;
  506. }
  507. break;
  508. case "mailbox":
  509. switch ($object) {
  510. case "all":
  511. $domains = mailbox('get', 'domains');
  512. if (!empty($domains)) {
  513. foreach ($domains as $domain) {
  514. $mailboxes = mailbox('get', 'mailboxes', $domain);
  515. if (!empty($mailboxes)) {
  516. foreach ($mailboxes as $mailbox) {
  517. if ($details = mailbox('get', 'mailbox_details', $mailbox)) {
  518. $data[] = $details;
  519. }
  520. else {
  521. continue;
  522. }
  523. }
  524. }
  525. }
  526. process_get_return($data);
  527. }
  528. else {
  529. echo '{}';
  530. }
  531. break;
  532. default:
  533. $data = mailbox('get', 'mailbox_details', $object);
  534. process_get_return($data);
  535. break;
  536. }
  537. break;
  538. case "syncjobs":
  539. switch ($object) {
  540. case "all":
  541. $domains = mailbox('get', 'domains');
  542. if (!empty($domains)) {
  543. foreach ($domains as $domain) {
  544. $mailboxes = mailbox('get', 'mailboxes', $domain);
  545. if (!empty($mailboxes)) {
  546. foreach ($mailboxes as $mailbox) {
  547. $syncjobs = mailbox('get', 'syncjobs', $mailbox);
  548. if (!empty($syncjobs)) {
  549. foreach ($syncjobs as $syncjob) {
  550. if (isset($extra)) {
  551. $details = mailbox('get', 'syncjob_details', $syncjob, explode(',', $extra));
  552. }
  553. else {
  554. $details = mailbox('get', 'syncjob_details', $syncjob);
  555. }
  556. if ($details) {
  557. $data[] = $details;
  558. }
  559. else {
  560. continue;
  561. }
  562. }
  563. }
  564. }
  565. }
  566. }
  567. process_get_return($data);
  568. }
  569. else {
  570. echo '{}';
  571. }
  572. break;
  573. default:
  574. $syncjobs = mailbox('get', 'syncjobs', $object);
  575. if (!empty($syncjobs)) {
  576. foreach ($syncjobs as $syncjob) {
  577. if (isset($extra)) {
  578. $details = mailbox('get', 'syncjob_details', $syncjob, explode(',', $extra));
  579. }
  580. else {
  581. $details = mailbox('get', 'syncjob_details', $syncjob);
  582. }
  583. if ($details) {
  584. $data[] = $details;
  585. }
  586. else {
  587. continue;
  588. }
  589. }
  590. }
  591. process_get_return($data);
  592. break;
  593. }
  594. break;
  595. case "active-user-sieve":
  596. if (isset($object)) {
  597. $sieve_filter = mailbox('get', 'active_user_sieve', $object);
  598. if (!empty($sieve_filter)) {
  599. $data[] = $sieve_filter;
  600. }
  601. }
  602. process_get_return($data);
  603. break;
  604. case "filters":
  605. switch ($object) {
  606. case "all":
  607. $domains = mailbox('get', 'domains');
  608. if (!empty($domains)) {
  609. foreach ($domains as $domain) {
  610. $mailboxes = mailbox('get', 'mailboxes', $domain);
  611. if (!empty($mailboxes)) {
  612. foreach ($mailboxes as $mailbox) {
  613. $filters = mailbox('get', 'filters', $mailbox);
  614. if (!empty($filters)) {
  615. foreach ($filters as $filter) {
  616. if ($details = mailbox('get', 'filter_details', $filter)) {
  617. $data[] = $details;
  618. }
  619. else {
  620. continue;
  621. }
  622. }
  623. }
  624. }
  625. }
  626. }
  627. process_get_return($data);
  628. }
  629. else {
  630. echo '{}';
  631. }
  632. break;
  633. default:
  634. $filters = mailbox('get', 'filters', $object);
  635. if (!empty($filters)) {
  636. foreach ($filters as $filter) {
  637. if ($details = mailbox('get', 'filter_details', $filter)) {
  638. $data[] = $details;
  639. }
  640. else {
  641. continue;
  642. }
  643. }
  644. }
  645. process_get_return($data);
  646. break;
  647. }
  648. break;
  649. case "bcc":
  650. switch ($object) {
  651. case "all":
  652. $bcc_items = bcc('get');
  653. if (!empty($bcc_items)) {
  654. foreach ($bcc_items as $bcc_item) {
  655. if ($details = bcc('details', $bcc_item)) {
  656. $data[] = $details;
  657. }
  658. else {
  659. continue;
  660. }
  661. }
  662. }
  663. process_get_return($data);
  664. break;
  665. default:
  666. $data = bcc('details', $object);
  667. if (!empty($data)) {
  668. $data[] = $details;
  669. }
  670. process_get_return($data);
  671. break;
  672. }
  673. break;
  674. case "recipient_map":
  675. switch ($object) {
  676. case "all":
  677. $recipient_map_items = recipient_map('get');
  678. if (!empty($recipient_map_items)) {
  679. foreach ($recipient_map_items as $recipient_map_item) {
  680. if ($details = recipient_map('details', $recipient_map_item)) {
  681. $data[] = $details;
  682. }
  683. else {
  684. continue;
  685. }
  686. }
  687. }
  688. process_get_return($data);
  689. break;
  690. default:
  691. $data = recipient_map('details', $object);
  692. if (!empty($data)) {
  693. $data[] = $details;
  694. }
  695. process_get_return($data);
  696. break;
  697. }
  698. break;
  699. case "tls-policy-map":
  700. switch ($object) {
  701. case "all":
  702. $tls_policy_maps_items = tls_policy_maps('get');
  703. if (!empty($tls_policy_maps_items)) {
  704. foreach ($tls_policy_maps_items as $tls_policy_maps_item) {
  705. if ($details = tls_policy_maps('details', $tls_policy_maps_item)) {
  706. $data[] = $details;
  707. }
  708. else {
  709. continue;
  710. }
  711. }
  712. }
  713. process_get_return($data);
  714. break;
  715. default:
  716. $data = tls_policy_maps('details', $object);
  717. if (!empty($data)) {
  718. $data[] = $details;
  719. }
  720. process_get_return($data);
  721. break;
  722. }
  723. break;
  724. case "policy_wl_mailbox":
  725. switch ($object) {
  726. default:
  727. $data = policy('get', 'mailbox', $object)['whitelist'];
  728. process_get_return($data);
  729. break;
  730. }
  731. break;
  732. case "policy_bl_mailbox":
  733. switch ($object) {
  734. default:
  735. $data = policy('get', 'mailbox', $object)['blacklist'];
  736. process_get_return($data);
  737. break;
  738. }
  739. break;
  740. case "policy_wl_domain":
  741. switch ($object) {
  742. default:
  743. $data = policy('get', 'domain', $object)['whitelist'];
  744. process_get_return($data);
  745. break;
  746. }
  747. break;
  748. case "policy_bl_domain":
  749. switch ($object) {
  750. default:
  751. $data = policy('get', 'domain', $object)['blacklist'];
  752. process_get_return($data);
  753. break;
  754. }
  755. break;
  756. case "time_limited_aliases":
  757. switch ($object) {
  758. default:
  759. $data = mailbox('get', 'time_limited_aliases', $object);
  760. process_get_return($data);
  761. break;
  762. }
  763. break;
  764. case "resource":
  765. switch ($object) {
  766. case "all":
  767. $domains = mailbox('get', 'domains');
  768. if (!empty($domains)) {
  769. foreach ($domains as $domain) {
  770. $resources = mailbox('get', 'resources', $domain);
  771. if (!empty($resources)) {
  772. foreach ($resources as $resource) {
  773. if ($details = mailbox('get', 'resource_details', $resource)) {
  774. $data[] = $details;
  775. }
  776. else {
  777. continue;
  778. }
  779. }
  780. }
  781. }
  782. process_get_return($data);
  783. }
  784. else {
  785. echo '{}';
  786. }
  787. break;
  788. default:
  789. $data = mailbox('get', 'resource_details', $object);
  790. process_get_return($data);
  791. break;
  792. }
  793. break;
  794. case "fwdhost":
  795. switch ($object) {
  796. case "all":
  797. process_get_return(fwdhost('get'));
  798. break;
  799. default:
  800. process_get_return(fwdhost('details', $object));
  801. break;
  802. }
  803. break;
  804. case "quarantine":
  805. // "all" will not print details
  806. switch ($object) {
  807. case "all":
  808. process_get_return(quarantine('get'));
  809. break;
  810. default:
  811. process_get_return(quarantine('details', $object));
  812. break;
  813. }
  814. break;
  815. case "alias-domain":
  816. switch ($object) {
  817. case "all":
  818. $alias_domains = mailbox('get', 'alias_domains');
  819. if (!empty($alias_domains)) {
  820. foreach ($alias_domains as $alias_domain) {
  821. if ($details = mailbox('get', 'alias_domain_details', $alias_domain)) {
  822. $data[] = $details;
  823. }
  824. else {
  825. continue;
  826. }
  827. }
  828. }
  829. process_get_return($data);
  830. break;
  831. default:
  832. process_get_return(mailbox('get', 'alias_domain_details', $object));
  833. break;
  834. }
  835. break;
  836. case "alias":
  837. switch ($object) {
  838. case "all":
  839. $domains = array_merge(mailbox('get', 'domains'), mailbox('get', 'alias_domains'));
  840. if (!empty($domains)) {
  841. foreach ($domains as $domain) {
  842. $aliases = mailbox('get', 'aliases', $domain);
  843. if (!empty($aliases)) {
  844. foreach ($aliases as $alias) {
  845. if ($details = mailbox('get', 'alias_details', $alias)) {
  846. $data[] = $details;
  847. }
  848. else {
  849. continue;
  850. }
  851. }
  852. }
  853. }
  854. process_get_return($data);
  855. }
  856. else {
  857. echo '{}';
  858. }
  859. break;
  860. default:
  861. process_get_return(mailbox('get', 'alias_details', $object));
  862. break;
  863. }
  864. break;
  865. case "domain-admin":
  866. switch ($object) {
  867. case "all":
  868. $domain_admins = domain_admin('get');
  869. if (!empty($domain_admins)) {
  870. foreach ($domain_admins as $domain_admin) {
  871. if ($details = domain_admin('details', $domain_admin)) {
  872. $data[] = $details;
  873. }
  874. else {
  875. continue;
  876. }
  877. }
  878. process_get_return($data);
  879. }
  880. else {
  881. echo '{}';
  882. }
  883. break;
  884. default:
  885. process_get_return(domain_admin('details', $object));
  886. break;
  887. }
  888. break;
  889. case "admin":
  890. switch ($object) {
  891. case "all":
  892. $admins = admin('get');
  893. if (!empty($admins)) {
  894. foreach ($admins as $admin) {
  895. if ($details = admin('details', $admin)) {
  896. $data[] = $details;
  897. }
  898. else {
  899. continue;
  900. }
  901. }
  902. process_get_return($data);
  903. }
  904. else {
  905. echo '{}';
  906. }
  907. break;
  908. default:
  909. process_get_return(admin('details', $object));
  910. break;
  911. }
  912. break;
  913. case "u2f-registration":
  914. header('Content-Type: application/javascript');
  915. if (($_SESSION["mailcow_cc_role"] == "admin" || $_SESSION["mailcow_cc_role"] == "domainadmin") && $_SESSION["mailcow_cc_username"] == $object) {
  916. list($req, $sigs) = $u2f->getRegisterData(get_u2f_registrations($object));
  917. $_SESSION['regReq'] = json_encode($req);
  918. $_SESSION['regSigs'] = json_encode($sigs);
  919. echo 'var req = ' . json_encode($req) . ';';
  920. echo 'var registeredKeys = ' . json_encode($sigs) . ';';
  921. echo 'var appId = req.appId;';
  922. echo 'var registerRequests = [{version: req.version, challenge: req.challenge}];';
  923. }
  924. else {
  925. return;
  926. }
  927. break;
  928. case "u2f-authentication":
  929. header('Content-Type: application/javascript');
  930. if (isset($_SESSION['pending_mailcow_cc_username']) && $_SESSION['pending_mailcow_cc_username'] == $object) {
  931. $auth_data = $u2f->getAuthenticateData(get_u2f_registrations($object));
  932. $challenge = $auth_data[0]->challenge;
  933. $appId = $auth_data[0]->appId;
  934. foreach ($auth_data as $each) {
  935. $key = array(); // Empty array
  936. $key['version'] = $each->version;
  937. $key['keyHandle'] = $each->keyHandle;
  938. $registeredKey[] = $key;
  939. }
  940. $_SESSION['authReq'] = json_encode($auth_data);
  941. echo 'var appId = "' . $appId . '";';
  942. echo 'var challenge = ' . json_encode($challenge) . ';';
  943. echo 'var registeredKeys = ' . json_encode($registeredKey) . ';';
  944. }
  945. else {
  946. return;
  947. }
  948. break;
  949. case "dkim":
  950. switch ($object) {
  951. default:
  952. $data = dkim('details', $object);
  953. process_get_return($data);
  954. break;
  955. }
  956. break;
  957. default:
  958. echo '{}';
  959. break;
  960. }
  961. break;
  962. case "delete":
  963. function process_delete_return($return) {
  964. $generic_failure = json_encode(array(
  965. 'type' => 'error',
  966. 'msg' => 'Cannot delete item'
  967. ));
  968. $generic_success = json_encode(array(
  969. 'type' => 'success',
  970. 'msg' => 'Task completed'
  971. ));
  972. if ($return === false) {
  973. echo isset($_SESSION['return']) ? json_encode($_SESSION['return']) : $generic_failure;
  974. }
  975. else {
  976. echo isset($_SESSION['return']) ? json_encode($_SESSION['return']) : $generic_success;
  977. }
  978. }
  979. if (!isset($_POST['items'])) {
  980. echo $request_incomplete;
  981. exit;
  982. }
  983. else {
  984. $items = (array)json_decode($_POST['items'], true);
  985. }
  986. switch ($category) {
  987. case "alias":
  988. process_delete_return(mailbox('delete', 'alias', array('id' => $items)));
  989. break;
  990. case "relayhost":
  991. process_delete_return(relayhost('delete', array('id' => $items)));
  992. break;
  993. case "transport":
  994. process_delete_return(transport('delete', array('id' => $items)));
  995. break;
  996. case "rsetting":
  997. process_delete_return(rsettings('delete', array('id' => $items)));
  998. break;
  999. case "syncjob":
  1000. process_delete_return(mailbox('delete', 'syncjob', array('id' => $items)));
  1001. break;
  1002. case "filter":
  1003. process_delete_return(mailbox('delete', 'filter', array('id' => $items)));
  1004. break;
  1005. case "mailq":
  1006. process_delete_return(mailq('delete', array('qid' => $items)));
  1007. break;
  1008. case "qitem":
  1009. process_delete_return(quarantine('delete', array('id' => $items)));
  1010. break;
  1011. case "bcc":
  1012. process_delete_return(bcc('delete', array('id' => $items)));
  1013. break;
  1014. case "recipient_map":
  1015. process_delete_return(recipient_map('delete', array('id' => $items)));
  1016. break;
  1017. case "tls-policy-map":
  1018. process_delete_return(tls_policy_maps('delete', array('id' => $items)));
  1019. break;
  1020. case "fwdhost":
  1021. process_delete_return(fwdhost('delete', array('forwardinghost' => $items)));
  1022. break;
  1023. case "dkim":
  1024. process_delete_return(dkim('delete', array('domains' => $items)));
  1025. break;
  1026. case "domain":
  1027. file_put_contents('/tmp/dssaa', $items);
  1028. process_delete_return(mailbox('delete', 'domain', array('domain' => $items)));
  1029. break;
  1030. case "alias-domain":
  1031. process_delete_return(mailbox('delete', 'alias_domain', array('alias_domain' => $items)));
  1032. break;
  1033. case "mailbox":
  1034. process_delete_return(mailbox('delete', 'mailbox', array('username' => $items)));
  1035. break;
  1036. case "resource":
  1037. process_delete_return(mailbox('delete', 'resource', array('name' => $items)));
  1038. break;
  1039. case "mailbox-policy":
  1040. process_delete_return(policy('delete', 'mailbox', array('prefid' => $items)));
  1041. break;
  1042. case "domain-policy":
  1043. process_delete_return(policy('delete', 'domain', array('prefid' => $items)));
  1044. break;
  1045. case "time_limited_alias":
  1046. process_delete_return(mailbox('delete', 'time_limited_alias', array('address' => $items)));
  1047. break;
  1048. case "eas_cache":
  1049. process_delete_return(mailbox('delete', 'eas_cache', array('username' => $items)));
  1050. break;
  1051. case "sogo_profile":
  1052. process_delete_return(mailbox('delete', 'sogo_profile', array('username' => $items)));
  1053. break;
  1054. case "domain-admin":
  1055. process_delete_return(domain_admin('delete', array('username' => $items)));
  1056. break;
  1057. case "admin":
  1058. process_delete_return(admin('delete', array('username' => $items)));
  1059. break;
  1060. case "rlhash":
  1061. echo ratelimit('delete', null, implode($items));
  1062. break;
  1063. }
  1064. break;
  1065. case "edit":
  1066. function process_edit_return($return) {
  1067. $generic_failure = json_encode(array(
  1068. 'type' => 'error',
  1069. 'msg' => 'Cannot edit item'
  1070. ));
  1071. $generic_success = json_encode(array(
  1072. 'type' => 'success',
  1073. 'msg' => 'Task completed'
  1074. ));
  1075. if ($return === false) {
  1076. echo isset($_SESSION['return']) ? json_encode($_SESSION['return']) : $generic_failure;
  1077. }
  1078. else {
  1079. echo isset($_SESSION['return']) ? json_encode($_SESSION['return']) : $generic_success;
  1080. }
  1081. }
  1082. if (!isset($_POST['attr'])) {
  1083. echo $request_incomplete;
  1084. exit;
  1085. }
  1086. else {
  1087. $attr = (array)json_decode($_POST['attr'], true);
  1088. unset($attr['csrf_token']);
  1089. $items = isset($_POST['items']) ? (array)json_decode($_POST['items'], true) : null;
  1090. }
  1091. switch ($category) {
  1092. case "bcc":
  1093. process_edit_return(bcc('edit', array_merge(array('id' => $items), $attr)));
  1094. break;
  1095. case "oauth2-client":
  1096. process_edit_return(oauth2('edit', 'client', array_merge(array('id' => $items), $attr)));
  1097. break;
  1098. case "recipient_map":
  1099. process_edit_return(recipient_map('edit', array_merge(array('id' => $items), $attr)));
  1100. break;
  1101. case "tls-policy-map":
  1102. process_edit_return(tls_policy_maps('edit', array_merge(array('id' => $items), $attr)));
  1103. break;
  1104. case "alias":
  1105. process_edit_return(mailbox('edit', 'alias', array_merge(array('id' => $items), $attr)));
  1106. break;
  1107. case "app_links":
  1108. process_edit_return(customize('edit', 'app_links', $attr));
  1109. break;
  1110. case "relayhost":
  1111. process_edit_return(relayhost('edit', array_merge(array('id' => $items), $attr)));
  1112. break;
  1113. case "transport":
  1114. process_edit_return(transport('edit', array_merge(array('id' => $items), $attr)));
  1115. break;
  1116. case "rsetting":
  1117. process_edit_return(rsettings('edit', array_merge(array('id' => $items), $attr)));
  1118. break;
  1119. case "delimiter_action":
  1120. process_edit_return(mailbox('edit', 'delimiter_action', array_merge(array('username' => $items), $attr)));
  1121. break;
  1122. case "tls_policy":
  1123. process_edit_return(mailbox('edit', 'tls_policy', array_merge(array('username' => $items), $attr)));
  1124. break;
  1125. case "quarantine_notification":
  1126. process_edit_return(mailbox('edit', 'quarantine_notification', array_merge(array('username' => $items), $attr)));
  1127. break;
  1128. case "qitem":
  1129. process_edit_return(quarantine('edit', array_merge(array('id' => $items), $attr)));
  1130. break;
  1131. case "quarantine":
  1132. process_edit_return(quarantine('edit', $attr));
  1133. break;
  1134. case "mailq":
  1135. process_edit_return(mailq('edit', array_merge(array('qid' => $items), $attr)));
  1136. break;
  1137. case "time_limited_alias":
  1138. process_edit_return(mailbox('edit', 'time_limited_alias', array_merge(array('address' => $items), $attr)));
  1139. break;
  1140. case "mailbox":
  1141. process_edit_return(mailbox('edit', 'mailbox', array_merge(array('username' => $items), $attr)));
  1142. break;
  1143. case "syncjob":
  1144. process_edit_return(mailbox('edit', 'syncjob', array_merge(array('id' => $items), $attr)));
  1145. break;
  1146. case "filter":
  1147. process_edit_return(mailbox('edit', 'filter', array_merge(array('id' => $items), $attr)));
  1148. break;
  1149. case "resource":
  1150. process_edit_return(mailbox('edit', 'resource', array_merge(array('name' => $items), $attr)));
  1151. break;
  1152. case "domain":
  1153. process_edit_return(mailbox('edit', 'domain', array_merge(array('domain' => $items), $attr)));
  1154. break;
  1155. case "rl-domain":
  1156. process_edit_return(ratelimit('edit', 'domain', array_merge(array('object' => $items), $attr)));
  1157. break;
  1158. case "rl-mbox":
  1159. process_edit_return(ratelimit('edit', 'mailbox', array_merge(array('object' => $items), $attr)));
  1160. break;
  1161. case "user-acl":
  1162. process_edit_return(acl('edit', 'user', array_merge(array('username' => $items), $attr)));
  1163. break;
  1164. case "da-acl":
  1165. process_edit_return(acl('edit', 'domainadmin', array_merge(array('username' => $items), $attr)));
  1166. break;
  1167. case "alias-domain":
  1168. process_edit_return(mailbox('edit', 'alias_domain', array_merge(array('alias_domain' => $items), $attr)));
  1169. break;
  1170. case "spam-score":
  1171. process_edit_return(mailbox('edit', 'spam_score', array_merge(array('username' => $items), $attr)));
  1172. break;
  1173. case "domain-admin":
  1174. process_edit_return(domain_admin('edit', array_merge(array('username' => $items), $attr)));
  1175. break;
  1176. case "admin":
  1177. process_edit_return(admin('edit', array_merge(array('username' => $items), $attr)));
  1178. break;
  1179. case "fwdhost":
  1180. process_edit_return(fwdhost('edit', array_merge(array('fwdhost' => $items), $attr)));
  1181. break;
  1182. case "fail2ban":
  1183. process_edit_return(fail2ban('edit', array_merge(array('network' => $items), $attr)));
  1184. break;
  1185. case "ui_texts":
  1186. process_edit_return(customize('edit', 'ui_texts', $attr));
  1187. break;
  1188. case "self":
  1189. if ($_SESSION['mailcow_cc_role'] == "domainadmin") {
  1190. process_edit_return(domain_admin('edit', $attr));
  1191. }
  1192. elseif ($_SESSION['mailcow_cc_role'] == "user") {
  1193. process_edit_return(edit_user_account($attr));
  1194. }
  1195. break;
  1196. }
  1197. break;
  1198. }
  1199. }
  1200. }