json_api.php 48 KB

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