json_api.php 50 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385
  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-admin-rspamd":
  1040. process_get_return(presets('get', 'admin-rspamd', $object));
  1041. break;
  1042. case "presets-mailbox-sieve":
  1043. process_get_return(presets('get', 'mailbox-sieve', $object));
  1044. break;
  1045. break;
  1046. // return no route found if no case is matched
  1047. default:
  1048. http_response_code(404);
  1049. echo json_encode(array(
  1050. 'type' => 'error',
  1051. 'msg' => 'route not found'
  1052. ));
  1053. exit();
  1054. }
  1055. break;
  1056. case "delete":
  1057. function process_delete_return($return) {
  1058. $generic_failure = json_encode(array(
  1059. 'type' => 'error',
  1060. 'msg' => 'Cannot delete item'
  1061. ));
  1062. $generic_success = json_encode(array(
  1063. 'type' => 'success',
  1064. 'msg' => 'Task completed'
  1065. ));
  1066. if ($return === false) {
  1067. echo isset($_SESSION['return']) ? json_encode($_SESSION['return']) : $generic_failure;
  1068. }
  1069. else {
  1070. echo isset($_SESSION['return']) ? json_encode($_SESSION['return']) : $generic_success;
  1071. }
  1072. }
  1073. if (!isset($_POST['items'])) {
  1074. echo $request_incomplete;
  1075. exit;
  1076. }
  1077. else {
  1078. $items = (array)json_decode($_POST['items'], true);
  1079. }
  1080. // only allow POST requests to POST API endpoints
  1081. if ($_SERVER['REQUEST_METHOD'] != 'POST') {
  1082. http_response_code(405);
  1083. echo json_encode(array(
  1084. 'type' => 'error',
  1085. 'msg' => 'only POST method is allowed'
  1086. ));
  1087. exit();
  1088. }
  1089. switch ($category) {
  1090. case "alias":
  1091. process_delete_return(mailbox('delete', 'alias', array('id' => $items)));
  1092. break;
  1093. case "oauth2-client":
  1094. process_delete_return(oauth2('delete', 'client', array('id' => $items)));
  1095. break;
  1096. case "relayhost":
  1097. process_delete_return(relayhost('delete', array('id' => $items)));
  1098. break;
  1099. case "transport":
  1100. process_delete_return(transport('delete', array('id' => $items)));
  1101. break;
  1102. case "rsetting":
  1103. process_delete_return(rsettings('delete', array('id' => $items)));
  1104. break;
  1105. case "syncjob":
  1106. process_delete_return(mailbox('delete', 'syncjob', array('id' => $items)));
  1107. break;
  1108. case "filter":
  1109. process_delete_return(mailbox('delete', 'filter', array('id' => $items)));
  1110. break;
  1111. case "mailq":
  1112. process_delete_return(mailq('delete', array('qid' => $items)));
  1113. break;
  1114. case "qitem":
  1115. process_delete_return(quarantine('delete', array('id' => $items)));
  1116. break;
  1117. case "bcc":
  1118. process_delete_return(bcc('delete', array('id' => $items)));
  1119. break;
  1120. case "recipient_map":
  1121. process_delete_return(recipient_map('delete', array('id' => $items)));
  1122. break;
  1123. case "tls-policy-map":
  1124. process_delete_return(tls_policy_maps('delete', array('id' => $items)));
  1125. break;
  1126. case "fwdhost":
  1127. process_delete_return(fwdhost('delete', array('forwardinghost' => $items)));
  1128. break;
  1129. case "dkim":
  1130. process_delete_return(dkim('delete', array('domains' => $items)));
  1131. break;
  1132. case "domain":
  1133. file_put_contents('/tmp/dssaa', $items);
  1134. process_delete_return(mailbox('delete', 'domain', array('domain' => $items)));
  1135. break;
  1136. case "alias-domain":
  1137. process_delete_return(mailbox('delete', 'alias_domain', array('alias_domain' => $items)));
  1138. break;
  1139. case "mailbox":
  1140. process_delete_return(mailbox('delete', 'mailbox', array('username' => $items)));
  1141. break;
  1142. case "resource":
  1143. process_delete_return(mailbox('delete', 'resource', array('name' => $items)));
  1144. break;
  1145. case "mailbox-policy":
  1146. process_delete_return(policy('delete', 'mailbox', array('prefid' => $items)));
  1147. break;
  1148. case "domain-policy":
  1149. process_delete_return(policy('delete', 'domain', array('prefid' => $items)));
  1150. break;
  1151. case "time_limited_alias":
  1152. process_delete_return(mailbox('delete', 'time_limited_alias', array('address' => $items)));
  1153. break;
  1154. case "eas_cache":
  1155. process_delete_return(mailbox('delete', 'eas_cache', array('username' => $items)));
  1156. break;
  1157. case "sogo_profile":
  1158. process_delete_return(mailbox('delete', 'sogo_profile', array('username' => $items)));
  1159. break;
  1160. case "domain-admin":
  1161. process_delete_return(domain_admin('delete', array('username' => $items)));
  1162. break;
  1163. case "admin":
  1164. process_delete_return(admin('delete', array('username' => $items)));
  1165. break;
  1166. case "rlhash":
  1167. echo ratelimit('delete', null, implode($items));
  1168. break;
  1169. // return no route found if no case is matched
  1170. default:
  1171. http_response_code(404);
  1172. echo json_encode(array(
  1173. 'type' => 'error',
  1174. 'msg' => 'route not found'
  1175. ));
  1176. exit();
  1177. }
  1178. break;
  1179. case "edit":
  1180. function process_edit_return($return) {
  1181. $generic_failure = json_encode(array(
  1182. 'type' => 'error',
  1183. 'msg' => 'Cannot edit item'
  1184. ));
  1185. $generic_success = json_encode(array(
  1186. 'type' => 'success',
  1187. 'msg' => 'Task completed'
  1188. ));
  1189. if ($return === false) {
  1190. echo isset($_SESSION['return']) ? json_encode($_SESSION['return']) : $generic_failure;
  1191. }
  1192. else {
  1193. echo isset($_SESSION['return']) ? json_encode($_SESSION['return']) : $generic_success;
  1194. }
  1195. }
  1196. if (!isset($_POST['attr'])) {
  1197. echo $request_incomplete;
  1198. exit;
  1199. }
  1200. else {
  1201. $attr = (array)json_decode($_POST['attr'], true);
  1202. unset($attr['csrf_token']);
  1203. $items = isset($_POST['items']) ? (array)json_decode($_POST['items'], true) : null;
  1204. }
  1205. // only allow POST requests to POST API endpoints
  1206. if ($_SERVER['REQUEST_METHOD'] != 'POST') {
  1207. http_response_code(405);
  1208. echo json_encode(array(
  1209. 'type' => 'error',
  1210. 'msg' => 'only POST method is allowed'
  1211. ));
  1212. exit();
  1213. }
  1214. switch ($category) {
  1215. case "bcc":
  1216. process_edit_return(bcc('edit', array_merge(array('id' => $items), $attr)));
  1217. break;
  1218. case "oauth2-client":
  1219. process_edit_return(oauth2('edit', 'client', array_merge(array('id' => $items), $attr)));
  1220. break;
  1221. case "recipient_map":
  1222. process_edit_return(recipient_map('edit', array_merge(array('id' => $items), $attr)));
  1223. break;
  1224. case "tls-policy-map":
  1225. process_edit_return(tls_policy_maps('edit', array_merge(array('id' => $items), $attr)));
  1226. break;
  1227. case "alias":
  1228. process_edit_return(mailbox('edit', 'alias', array_merge(array('id' => $items), $attr)));
  1229. break;
  1230. case "rspamd-map":
  1231. process_edit_return(rspamd('edit', array_merge(array('map' => $items), $attr)));
  1232. break;
  1233. case "app_links":
  1234. process_edit_return(customize('edit', 'app_links', $attr));
  1235. break;
  1236. case "relayhost":
  1237. process_edit_return(relayhost('edit', array_merge(array('id' => $items), $attr)));
  1238. break;
  1239. case "transport":
  1240. process_edit_return(transport('edit', array_merge(array('id' => $items), $attr)));
  1241. break;
  1242. case "rsetting":
  1243. process_edit_return(rsettings('edit', array_merge(array('id' => $items), $attr)));
  1244. break;
  1245. case "delimiter_action":
  1246. process_edit_return(mailbox('edit', 'delimiter_action', array_merge(array('username' => $items), $attr)));
  1247. break;
  1248. case "tls_policy":
  1249. process_edit_return(mailbox('edit', 'tls_policy', array_merge(array('username' => $items), $attr)));
  1250. break;
  1251. case "quarantine_notification":
  1252. process_edit_return(mailbox('edit', 'quarantine_notification', array_merge(array('username' => $items), $attr)));
  1253. break;
  1254. case "qitem":
  1255. process_edit_return(quarantine('edit', array_merge(array('id' => $items), $attr)));
  1256. break;
  1257. case "quarantine":
  1258. process_edit_return(quarantine('edit', $attr));
  1259. break;
  1260. case "quota_notification":
  1261. process_edit_return(quota_notification('edit', $attr));
  1262. break;
  1263. case "mailq":
  1264. process_edit_return(mailq('edit', array_merge(array('qid' => $items), $attr)));
  1265. break;
  1266. case "time_limited_alias":
  1267. process_edit_return(mailbox('edit', 'time_limited_alias', array_merge(array('address' => $items), $attr)));
  1268. break;
  1269. case "mailbox":
  1270. process_edit_return(mailbox('edit', 'mailbox', array_merge(array('username' => $items), $attr)));
  1271. break;
  1272. case "syncjob":
  1273. process_edit_return(mailbox('edit', 'syncjob', array_merge(array('id' => $items), $attr)));
  1274. break;
  1275. case "filter":
  1276. process_edit_return(mailbox('edit', 'filter', array_merge(array('id' => $items), $attr)));
  1277. break;
  1278. case "resource":
  1279. process_edit_return(mailbox('edit', 'resource', array_merge(array('name' => $items), $attr)));
  1280. break;
  1281. case "domain":
  1282. process_edit_return(mailbox('edit', 'domain', array_merge(array('domain' => $items), $attr)));
  1283. break;
  1284. case "rl-domain":
  1285. process_edit_return(ratelimit('edit', 'domain', array_merge(array('object' => $items), $attr)));
  1286. break;
  1287. case "rl-mbox":
  1288. process_edit_return(ratelimit('edit', 'mailbox', array_merge(array('object' => $items), $attr)));
  1289. break;
  1290. case "user-acl":
  1291. process_edit_return(acl('edit', 'user', array_merge(array('username' => $items), $attr)));
  1292. break;
  1293. case "da-acl":
  1294. process_edit_return(acl('edit', 'domainadmin', array_merge(array('username' => $items), $attr)));
  1295. break;
  1296. case "alias-domain":
  1297. process_edit_return(mailbox('edit', 'alias_domain', array_merge(array('alias_domain' => $items), $attr)));
  1298. break;
  1299. case "spam-score":
  1300. process_edit_return(mailbox('edit', 'spam_score', array_merge(array('username' => $items), $attr)));
  1301. break;
  1302. case "domain-admin":
  1303. process_edit_return(domain_admin('edit', array_merge(array('username' => $items), $attr)));
  1304. break;
  1305. case "admin":
  1306. process_edit_return(admin('edit', array_merge(array('username' => $items), $attr)));
  1307. break;
  1308. case "fwdhost":
  1309. process_edit_return(fwdhost('edit', array_merge(array('fwdhost' => $items), $attr)));
  1310. break;
  1311. case "fail2ban":
  1312. process_edit_return(fail2ban('edit', array_merge(array('network' => $items), $attr)));
  1313. break;
  1314. case "ui_texts":
  1315. process_edit_return(customize('edit', 'ui_texts', $attr));
  1316. break;
  1317. case "self":
  1318. if ($_SESSION['mailcow_cc_role'] == "domainadmin") {
  1319. process_edit_return(domain_admin('edit', $attr));
  1320. }
  1321. elseif ($_SESSION['mailcow_cc_role'] == "user") {
  1322. process_edit_return(edit_user_account($attr));
  1323. }
  1324. break;
  1325. // return no route found if no case is matched
  1326. default:
  1327. http_response_code(404);
  1328. echo json_encode(array(
  1329. 'type' => 'error',
  1330. 'msg' => 'route not found'
  1331. ));
  1332. exit();
  1333. }
  1334. break;
  1335. // return no route found if no case is matched
  1336. default:
  1337. http_response_code(404);
  1338. echo json_encode(array(
  1339. 'type' => 'error',
  1340. 'msg' => 'route not found'
  1341. ));
  1342. exit();
  1343. }
  1344. }
  1345. if ($_SESSION['mailcow_cc_api'] === true) {
  1346. if (isset($_SESSION['mailcow_cc_api']) && $_SESSION['mailcow_cc_api'] === true) {
  1347. unset($_SESSION['return']);
  1348. }
  1349. }
  1350. }