json_api.php 49 KB

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