json_api.php 49 KB

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