json_api.php 50 KB

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