json_api.php 48 KB

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