json_api.php 50 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368
  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. $domains = mailbox('get', 'domains');
  576. if (!empty($domains)) {
  577. foreach ($domains as $domain) {
  578. $mailboxes = mailbox('get', 'mailboxes', $domain);
  579. if (!empty($mailboxes)) {
  580. foreach ($mailboxes as $mailbox) {
  581. if ($details = mailbox('get', 'mailbox_details', $mailbox)) {
  582. $data[] = $details;
  583. }
  584. else {
  585. continue;
  586. }
  587. }
  588. }
  589. }
  590. process_get_return($data);
  591. }
  592. else {
  593. echo '{}';
  594. }
  595. break;
  596. default:
  597. $data = mailbox('get', 'mailbox_details', $object);
  598. process_get_return($data);
  599. break;
  600. }
  601. break;
  602. case "syncjobs":
  603. switch ($object) {
  604. case "all":
  605. $domains = mailbox('get', 'domains');
  606. if (!empty($domains)) {
  607. foreach ($domains as $domain) {
  608. $mailboxes = mailbox('get', 'mailboxes', $domain);
  609. if (!empty($mailboxes)) {
  610. foreach ($mailboxes as $mailbox) {
  611. $syncjobs = mailbox('get', 'syncjobs', $mailbox);
  612. if (!empty($syncjobs)) {
  613. foreach ($syncjobs as $syncjob) {
  614. if (isset($extra)) {
  615. $details = mailbox('get', 'syncjob_details', $syncjob, explode(',', $extra));
  616. }
  617. else {
  618. $details = mailbox('get', 'syncjob_details', $syncjob);
  619. }
  620. if ($details) {
  621. $data[] = $details;
  622. }
  623. else {
  624. continue;
  625. }
  626. }
  627. }
  628. }
  629. }
  630. }
  631. process_get_return($data);
  632. }
  633. else {
  634. echo '{}';
  635. }
  636. break;
  637. default:
  638. $syncjobs = mailbox('get', 'syncjobs', $object);
  639. if (!empty($syncjobs)) {
  640. foreach ($syncjobs as $syncjob) {
  641. if (isset($extra)) {
  642. $details = mailbox('get', 'syncjob_details', $syncjob, explode(',', $extra));
  643. }
  644. else {
  645. $details = mailbox('get', 'syncjob_details', $syncjob);
  646. }
  647. if ($details) {
  648. $data[] = $details;
  649. }
  650. else {
  651. continue;
  652. }
  653. }
  654. }
  655. process_get_return($data);
  656. break;
  657. }
  658. break;
  659. case "active-user-sieve":
  660. if (isset($object)) {
  661. $sieve_filter = mailbox('get', 'active_user_sieve', $object);
  662. if (!empty($sieve_filter)) {
  663. $data[] = $sieve_filter;
  664. }
  665. }
  666. process_get_return($data);
  667. break;
  668. case "filters":
  669. switch ($object) {
  670. case "all":
  671. $domains = mailbox('get', 'domains');
  672. if (!empty($domains)) {
  673. foreach ($domains as $domain) {
  674. $mailboxes = mailbox('get', 'mailboxes', $domain);
  675. if (!empty($mailboxes)) {
  676. foreach ($mailboxes as $mailbox) {
  677. $filters = mailbox('get', 'filters', $mailbox);
  678. if (!empty($filters)) {
  679. foreach ($filters as $filter) {
  680. if ($details = mailbox('get', 'filter_details', $filter)) {
  681. $data[] = $details;
  682. }
  683. else {
  684. continue;
  685. }
  686. }
  687. }
  688. }
  689. }
  690. }
  691. process_get_return($data);
  692. }
  693. else {
  694. echo '{}';
  695. }
  696. break;
  697. default:
  698. $filters = mailbox('get', 'filters', $object);
  699. if (!empty($filters)) {
  700. foreach ($filters as $filter) {
  701. if ($details = mailbox('get', 'filter_details', $filter)) {
  702. $data[] = $details;
  703. }
  704. else {
  705. continue;
  706. }
  707. }
  708. }
  709. process_get_return($data);
  710. break;
  711. }
  712. break;
  713. case "bcc":
  714. switch ($object) {
  715. case "all":
  716. $bcc_items = bcc('get');
  717. if (!empty($bcc_items)) {
  718. foreach ($bcc_items as $bcc_item) {
  719. if ($details = bcc('details', $bcc_item)) {
  720. $data[] = $details;
  721. }
  722. else {
  723. continue;
  724. }
  725. }
  726. }
  727. process_get_return($data);
  728. break;
  729. default:
  730. $data = bcc('details', $object);
  731. if (!empty($data)) {
  732. $data[] = $details;
  733. }
  734. process_get_return($data);
  735. break;
  736. }
  737. break;
  738. case "recipient_map":
  739. switch ($object) {
  740. case "all":
  741. $recipient_map_items = recipient_map('get');
  742. if (!empty($recipient_map_items)) {
  743. foreach ($recipient_map_items as $recipient_map_item) {
  744. if ($details = recipient_map('details', $recipient_map_item)) {
  745. $data[] = $details;
  746. }
  747. else {
  748. continue;
  749. }
  750. }
  751. }
  752. process_get_return($data);
  753. break;
  754. default:
  755. $data = recipient_map('details', $object);
  756. if (!empty($data)) {
  757. $data[] = $details;
  758. }
  759. process_get_return($data);
  760. break;
  761. }
  762. break;
  763. case "tls-policy-map":
  764. switch ($object) {
  765. case "all":
  766. $tls_policy_maps_items = tls_policy_maps('get');
  767. if (!empty($tls_policy_maps_items)) {
  768. foreach ($tls_policy_maps_items as $tls_policy_maps_item) {
  769. if ($details = tls_policy_maps('details', $tls_policy_maps_item)) {
  770. $data[] = $details;
  771. }
  772. else {
  773. continue;
  774. }
  775. }
  776. }
  777. process_get_return($data);
  778. break;
  779. default:
  780. $data = tls_policy_maps('details', $object);
  781. if (!empty($data)) {
  782. $data[] = $details;
  783. }
  784. process_get_return($data);
  785. break;
  786. }
  787. break;
  788. case "policy_wl_mailbox":
  789. switch ($object) {
  790. default:
  791. $data = policy('get', 'mailbox', $object)['whitelist'];
  792. process_get_return($data);
  793. break;
  794. }
  795. break;
  796. case "policy_bl_mailbox":
  797. switch ($object) {
  798. default:
  799. $data = policy('get', 'mailbox', $object)['blacklist'];
  800. process_get_return($data);
  801. break;
  802. }
  803. break;
  804. case "policy_wl_domain":
  805. switch ($object) {
  806. default:
  807. $data = policy('get', 'domain', $object)['whitelist'];
  808. process_get_return($data);
  809. break;
  810. }
  811. break;
  812. case "policy_bl_domain":
  813. switch ($object) {
  814. default:
  815. $data = policy('get', 'domain', $object)['blacklist'];
  816. process_get_return($data);
  817. break;
  818. }
  819. break;
  820. case "time_limited_aliases":
  821. switch ($object) {
  822. default:
  823. $data = mailbox('get', 'time_limited_aliases', $object);
  824. process_get_return($data);
  825. break;
  826. }
  827. break;
  828. case "fail2ban":
  829. switch ($object) {
  830. default:
  831. $data = fail2ban('get');
  832. process_get_return($data);
  833. break;
  834. }
  835. break;
  836. case "resource":
  837. switch ($object) {
  838. case "all":
  839. $domains = mailbox('get', 'domains');
  840. if (!empty($domains)) {
  841. foreach ($domains as $domain) {
  842. $resources = mailbox('get', 'resources', $domain);
  843. if (!empty($resources)) {
  844. foreach ($resources as $resource) {
  845. if ($details = mailbox('get', 'resource_details', $resource)) {
  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. $data = mailbox('get', 'resource_details', $object);
  862. process_get_return($data);
  863. break;
  864. }
  865. break;
  866. case "fwdhost":
  867. switch ($object) {
  868. case "all":
  869. process_get_return(fwdhost('get'));
  870. break;
  871. default:
  872. process_get_return(fwdhost('details', $object));
  873. break;
  874. }
  875. break;
  876. case "quarantine":
  877. // "all" will not print details
  878. switch ($object) {
  879. case "all":
  880. process_get_return(quarantine('get'));
  881. break;
  882. default:
  883. process_get_return(quarantine('details', $object));
  884. break;
  885. }
  886. break;
  887. case "alias-domain":
  888. switch ($object) {
  889. case "all":
  890. $alias_domains = mailbox('get', 'alias_domains');
  891. if (!empty($alias_domains)) {
  892. foreach ($alias_domains as $alias_domain) {
  893. if ($details = mailbox('get', 'alias_domain_details', $alias_domain)) {
  894. $data[] = $details;
  895. }
  896. else {
  897. continue;
  898. }
  899. }
  900. }
  901. process_get_return($data);
  902. break;
  903. default:
  904. process_get_return(mailbox('get', 'alias_domain_details', $object));
  905. break;
  906. }
  907. break;
  908. case "alias":
  909. switch ($object) {
  910. case "all":
  911. $domains = array_merge(mailbox('get', 'domains'), mailbox('get', 'alias_domains'));
  912. if (!empty($domains)) {
  913. foreach ($domains as $domain) {
  914. $aliases = mailbox('get', 'aliases', $domain);
  915. if (!empty($aliases)) {
  916. foreach ($aliases as $alias) {
  917. if ($details = mailbox('get', 'alias_details', $alias)) {
  918. $data[] = $details;
  919. }
  920. else {
  921. continue;
  922. }
  923. }
  924. }
  925. }
  926. process_get_return($data);
  927. }
  928. else {
  929. echo '{}';
  930. }
  931. break;
  932. default:
  933. process_get_return(mailbox('get', 'alias_details', $object));
  934. break;
  935. }
  936. break;
  937. case "domain-admin":
  938. switch ($object) {
  939. case "all":
  940. $domain_admins = domain_admin('get');
  941. if (!empty($domain_admins)) {
  942. foreach ($domain_admins as $domain_admin) {
  943. if ($details = domain_admin('details', $domain_admin)) {
  944. $data[] = $details;
  945. }
  946. else {
  947. continue;
  948. }
  949. }
  950. process_get_return($data);
  951. }
  952. else {
  953. echo '{}';
  954. }
  955. break;
  956. default:
  957. process_get_return(domain_admin('details', $object));
  958. break;
  959. }
  960. break;
  961. case "admin":
  962. switch ($object) {
  963. case "all":
  964. $admins = admin('get');
  965. if (!empty($admins)) {
  966. foreach ($admins as $admin) {
  967. if ($details = admin('details', $admin)) {
  968. $data[] = $details;
  969. }
  970. else {
  971. continue;
  972. }
  973. }
  974. process_get_return($data);
  975. }
  976. else {
  977. echo '{}';
  978. }
  979. break;
  980. default:
  981. process_get_return(admin('details', $object));
  982. break;
  983. }
  984. break;
  985. case "u2f-registration":
  986. header('Content-Type: application/javascript');
  987. if (($_SESSION["mailcow_cc_role"] == "admin" || $_SESSION["mailcow_cc_role"] == "domainadmin") && $_SESSION["mailcow_cc_username"] == $object) {
  988. list($req, $sigs) = $u2f->getRegisterData(get_u2f_registrations($object));
  989. $_SESSION['regReq'] = json_encode($req);
  990. $_SESSION['regSigs'] = json_encode($sigs);
  991. echo 'var req = ' . json_encode($req) . ';';
  992. echo 'var registeredKeys = ' . json_encode($sigs) . ';';
  993. echo 'var appId = req.appId;';
  994. echo 'var registerRequests = [{version: req.version, challenge: req.challenge}];';
  995. }
  996. else {
  997. return;
  998. }
  999. break;
  1000. case "u2f-authentication":
  1001. header('Content-Type: application/javascript');
  1002. if (isset($_SESSION['pending_mailcow_cc_username']) && $_SESSION['pending_mailcow_cc_username'] == $object) {
  1003. $auth_data = $u2f->getAuthenticateData(get_u2f_registrations($object));
  1004. $challenge = $auth_data[0]->challenge;
  1005. $appId = $auth_data[0]->appId;
  1006. foreach ($auth_data as $each) {
  1007. $key = array(); // Empty array
  1008. $key['version'] = $each->version;
  1009. $key['keyHandle'] = $each->keyHandle;
  1010. $registeredKey[] = $key;
  1011. }
  1012. $_SESSION['authReq'] = json_encode($auth_data);
  1013. echo 'var appId = "' . $appId . '";';
  1014. echo 'var challenge = ' . json_encode($challenge) . ';';
  1015. echo 'var registeredKeys = ' . json_encode($registeredKey) . ';';
  1016. }
  1017. else {
  1018. return;
  1019. }
  1020. break;
  1021. case "dkim":
  1022. switch ($object) {
  1023. default:
  1024. $data = dkim('details', $object);
  1025. process_get_return($data);
  1026. break;
  1027. }
  1028. break;
  1029. // return no route found if no case is matched
  1030. default:
  1031. http_response_code(404);
  1032. echo json_encode(array(
  1033. 'type' => 'error',
  1034. 'msg' => 'route not found'
  1035. ));
  1036. exit();
  1037. }
  1038. break;
  1039. case "delete":
  1040. function process_delete_return($return) {
  1041. $generic_failure = json_encode(array(
  1042. 'type' => 'error',
  1043. 'msg' => 'Cannot delete item'
  1044. ));
  1045. $generic_success = json_encode(array(
  1046. 'type' => 'success',
  1047. 'msg' => 'Task completed'
  1048. ));
  1049. if ($return === false) {
  1050. echo isset($_SESSION['return']) ? json_encode($_SESSION['return']) : $generic_failure;
  1051. }
  1052. else {
  1053. echo isset($_SESSION['return']) ? json_encode($_SESSION['return']) : $generic_success;
  1054. }
  1055. }
  1056. if (!isset($_POST['items'])) {
  1057. echo $request_incomplete;
  1058. exit;
  1059. }
  1060. else {
  1061. $items = (array)json_decode($_POST['items'], true);
  1062. }
  1063. // only allow POST requests to POST API endpoints
  1064. if ($_SERVER['REQUEST_METHOD'] != 'POST') {
  1065. http_response_code(405);
  1066. echo json_encode(array(
  1067. 'type' => 'error',
  1068. 'msg' => 'only POST method is allowed'
  1069. ));
  1070. exit();
  1071. }
  1072. switch ($category) {
  1073. case "alias":
  1074. process_delete_return(mailbox('delete', 'alias', array('id' => $items)));
  1075. break;
  1076. case "oauth2-client":
  1077. process_delete_return(oauth2('delete', 'client', array('id' => $items)));
  1078. break;
  1079. case "relayhost":
  1080. process_delete_return(relayhost('delete', array('id' => $items)));
  1081. break;
  1082. case "transport":
  1083. process_delete_return(transport('delete', array('id' => $items)));
  1084. break;
  1085. case "rsetting":
  1086. process_delete_return(rsettings('delete', array('id' => $items)));
  1087. break;
  1088. case "syncjob":
  1089. process_delete_return(mailbox('delete', 'syncjob', array('id' => $items)));
  1090. break;
  1091. case "filter":
  1092. process_delete_return(mailbox('delete', 'filter', array('id' => $items)));
  1093. break;
  1094. case "mailq":
  1095. process_delete_return(mailq('delete', array('qid' => $items)));
  1096. break;
  1097. case "qitem":
  1098. process_delete_return(quarantine('delete', array('id' => $items)));
  1099. break;
  1100. case "bcc":
  1101. process_delete_return(bcc('delete', array('id' => $items)));
  1102. break;
  1103. case "recipient_map":
  1104. process_delete_return(recipient_map('delete', array('id' => $items)));
  1105. break;
  1106. case "tls-policy-map":
  1107. process_delete_return(tls_policy_maps('delete', array('id' => $items)));
  1108. break;
  1109. case "fwdhost":
  1110. process_delete_return(fwdhost('delete', array('forwardinghost' => $items)));
  1111. break;
  1112. case "dkim":
  1113. process_delete_return(dkim('delete', array('domains' => $items)));
  1114. break;
  1115. case "domain":
  1116. file_put_contents('/tmp/dssaa', $items);
  1117. process_delete_return(mailbox('delete', 'domain', array('domain' => $items)));
  1118. break;
  1119. case "alias-domain":
  1120. process_delete_return(mailbox('delete', 'alias_domain', array('alias_domain' => $items)));
  1121. break;
  1122. case "mailbox":
  1123. process_delete_return(mailbox('delete', 'mailbox', array('username' => $items)));
  1124. break;
  1125. case "resource":
  1126. process_delete_return(mailbox('delete', 'resource', array('name' => $items)));
  1127. break;
  1128. case "mailbox-policy":
  1129. process_delete_return(policy('delete', 'mailbox', array('prefid' => $items)));
  1130. break;
  1131. case "domain-policy":
  1132. process_delete_return(policy('delete', 'domain', array('prefid' => $items)));
  1133. break;
  1134. case "time_limited_alias":
  1135. process_delete_return(mailbox('delete', 'time_limited_alias', array('address' => $items)));
  1136. break;
  1137. case "eas_cache":
  1138. process_delete_return(mailbox('delete', 'eas_cache', array('username' => $items)));
  1139. break;
  1140. case "sogo_profile":
  1141. process_delete_return(mailbox('delete', 'sogo_profile', array('username' => $items)));
  1142. break;
  1143. case "domain-admin":
  1144. process_delete_return(domain_admin('delete', array('username' => $items)));
  1145. break;
  1146. case "admin":
  1147. process_delete_return(admin('delete', array('username' => $items)));
  1148. break;
  1149. case "rlhash":
  1150. echo ratelimit('delete', null, implode($items));
  1151. break;
  1152. // return no route found if no case is matched
  1153. default:
  1154. http_response_code(404);
  1155. echo json_encode(array(
  1156. 'type' => 'error',
  1157. 'msg' => 'route not found'
  1158. ));
  1159. exit();
  1160. }
  1161. break;
  1162. case "edit":
  1163. function process_edit_return($return) {
  1164. $generic_failure = json_encode(array(
  1165. 'type' => 'error',
  1166. 'msg' => 'Cannot edit item'
  1167. ));
  1168. $generic_success = json_encode(array(
  1169. 'type' => 'success',
  1170. 'msg' => 'Task completed'
  1171. ));
  1172. if ($return === false) {
  1173. echo isset($_SESSION['return']) ? json_encode($_SESSION['return']) : $generic_failure;
  1174. }
  1175. else {
  1176. echo isset($_SESSION['return']) ? json_encode($_SESSION['return']) : $generic_success;
  1177. }
  1178. }
  1179. if (!isset($_POST['attr'])) {
  1180. echo $request_incomplete;
  1181. exit;
  1182. }
  1183. else {
  1184. $attr = (array)json_decode($_POST['attr'], true);
  1185. unset($attr['csrf_token']);
  1186. $items = isset($_POST['items']) ? (array)json_decode($_POST['items'], true) : null;
  1187. }
  1188. // only allow POST requests to POST API endpoints
  1189. if ($_SERVER['REQUEST_METHOD'] != 'POST') {
  1190. http_response_code(405);
  1191. echo json_encode(array(
  1192. 'type' => 'error',
  1193. 'msg' => 'only POST method is allowed'
  1194. ));
  1195. exit();
  1196. }
  1197. switch ($category) {
  1198. case "bcc":
  1199. process_edit_return(bcc('edit', array_merge(array('id' => $items), $attr)));
  1200. break;
  1201. case "oauth2-client":
  1202. process_edit_return(oauth2('edit', 'client', array_merge(array('id' => $items), $attr)));
  1203. break;
  1204. case "recipient_map":
  1205. process_edit_return(recipient_map('edit', array_merge(array('id' => $items), $attr)));
  1206. break;
  1207. case "tls-policy-map":
  1208. process_edit_return(tls_policy_maps('edit', array_merge(array('id' => $items), $attr)));
  1209. break;
  1210. case "alias":
  1211. process_edit_return(mailbox('edit', 'alias', array_merge(array('id' => $items), $attr)));
  1212. break;
  1213. case "rspamd-map":
  1214. process_edit_return(rspamd('edit', array_merge(array('map' => $items), $attr)));
  1215. break;
  1216. case "app_links":
  1217. process_edit_return(customize('edit', 'app_links', $attr));
  1218. break;
  1219. case "relayhost":
  1220. process_edit_return(relayhost('edit', array_merge(array('id' => $items), $attr)));
  1221. break;
  1222. case "transport":
  1223. process_edit_return(transport('edit', array_merge(array('id' => $items), $attr)));
  1224. break;
  1225. case "rsetting":
  1226. process_edit_return(rsettings('edit', array_merge(array('id' => $items), $attr)));
  1227. break;
  1228. case "delimiter_action":
  1229. process_edit_return(mailbox('edit', 'delimiter_action', array_merge(array('username' => $items), $attr)));
  1230. break;
  1231. case "tls_policy":
  1232. process_edit_return(mailbox('edit', 'tls_policy', array_merge(array('username' => $items), $attr)));
  1233. break;
  1234. case "quarantine_notification":
  1235. process_edit_return(mailbox('edit', 'quarantine_notification', array_merge(array('username' => $items), $attr)));
  1236. break;
  1237. case "qitem":
  1238. process_edit_return(quarantine('edit', array_merge(array('id' => $items), $attr)));
  1239. break;
  1240. case "quarantine":
  1241. process_edit_return(quarantine('edit', $attr));
  1242. break;
  1243. case "quota_notification":
  1244. process_edit_return(quota_notification('edit', $attr));
  1245. break;
  1246. case "mailq":
  1247. process_edit_return(mailq('edit', array_merge(array('qid' => $items), $attr)));
  1248. break;
  1249. case "time_limited_alias":
  1250. process_edit_return(mailbox('edit', 'time_limited_alias', array_merge(array('address' => $items), $attr)));
  1251. break;
  1252. case "mailbox":
  1253. process_edit_return(mailbox('edit', 'mailbox', array_merge(array('username' => $items), $attr)));
  1254. break;
  1255. case "syncjob":
  1256. process_edit_return(mailbox('edit', 'syncjob', array_merge(array('id' => $items), $attr)));
  1257. break;
  1258. case "filter":
  1259. process_edit_return(mailbox('edit', 'filter', array_merge(array('id' => $items), $attr)));
  1260. break;
  1261. case "resource":
  1262. process_edit_return(mailbox('edit', 'resource', array_merge(array('name' => $items), $attr)));
  1263. break;
  1264. case "domain":
  1265. process_edit_return(mailbox('edit', 'domain', array_merge(array('domain' => $items), $attr)));
  1266. break;
  1267. case "rl-domain":
  1268. process_edit_return(ratelimit('edit', 'domain', array_merge(array('object' => $items), $attr)));
  1269. break;
  1270. case "rl-mbox":
  1271. process_edit_return(ratelimit('edit', 'mailbox', array_merge(array('object' => $items), $attr)));
  1272. break;
  1273. case "user-acl":
  1274. process_edit_return(acl('edit', 'user', array_merge(array('username' => $items), $attr)));
  1275. break;
  1276. case "da-acl":
  1277. process_edit_return(acl('edit', 'domainadmin', array_merge(array('username' => $items), $attr)));
  1278. break;
  1279. case "alias-domain":
  1280. process_edit_return(mailbox('edit', 'alias_domain', array_merge(array('alias_domain' => $items), $attr)));
  1281. break;
  1282. case "spam-score":
  1283. process_edit_return(mailbox('edit', 'spam_score', array_merge(array('username' => $items), $attr)));
  1284. break;
  1285. case "domain-admin":
  1286. process_edit_return(domain_admin('edit', array_merge(array('username' => $items), $attr)));
  1287. break;
  1288. case "admin":
  1289. process_edit_return(admin('edit', array_merge(array('username' => $items), $attr)));
  1290. break;
  1291. case "fwdhost":
  1292. process_edit_return(fwdhost('edit', array_merge(array('fwdhost' => $items), $attr)));
  1293. break;
  1294. case "fail2ban":
  1295. process_edit_return(fail2ban('edit', array_merge(array('network' => $items), $attr)));
  1296. break;
  1297. case "ui_texts":
  1298. process_edit_return(customize('edit', 'ui_texts', $attr));
  1299. break;
  1300. case "self":
  1301. if ($_SESSION['mailcow_cc_role'] == "domainadmin") {
  1302. process_edit_return(domain_admin('edit', $attr));
  1303. }
  1304. elseif ($_SESSION['mailcow_cc_role'] == "user") {
  1305. process_edit_return(edit_user_account($attr));
  1306. }
  1307. break;
  1308. // return no route found if no case is matched
  1309. default:
  1310. http_response_code(404);
  1311. echo json_encode(array(
  1312. 'type' => 'error',
  1313. 'msg' => 'route not found'
  1314. ));
  1315. exit();
  1316. }
  1317. break;
  1318. // return no route found if no case is matched
  1319. default:
  1320. http_response_code(404);
  1321. echo json_encode(array(
  1322. 'type' => 'error',
  1323. 'msg' => 'route not found'
  1324. ));
  1325. exit();
  1326. }
  1327. }
  1328. if ($_SESSION['mailcow_cc_api'] === true) {
  1329. if (isset($_SESSION['mailcow_cc_api']) && $_SESSION['mailcow_cc_api'] === true) {
  1330. unset($_SESSION['return']);
  1331. }
  1332. }
  1333. }