json_api.php 50 KB

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