init_db.inc.php 46 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090
  1. <?php
  2. function init_db_schema() {
  3. try {
  4. global $pdo;
  5. $db_version = "01092019_1240";
  6. $stmt = $pdo->query("SHOW TABLES LIKE 'versions'");
  7. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  8. if ($num_results != 0) {
  9. $stmt = $pdo->query("SELECT `version` FROM `versions` WHERE `application` = 'db_schema'");
  10. if ($stmt->fetch(PDO::FETCH_ASSOC)['version'] == $db_version) {
  11. return true;
  12. }
  13. }
  14. $views = array(
  15. "grouped_mail_aliases" => "CREATE VIEW grouped_mail_aliases (username, aliases) AS
  16. SELECT goto, IFNULL(GROUP_CONCAT(address SEPARATOR ' '), '') AS address FROM alias
  17. WHERE address!=goto
  18. AND active = '1'
  19. AND address NOT LIKE '@%'
  20. GROUP BY goto;",
  21. // Unused at the moment - we cannot allow to show a foreign mailbox as sender address in SOGo, as SOGo does not like this
  22. // We need to create delegation in SOGo AND set a sender_acl in mailcow to allow to send as user X
  23. "grouped_sender_acl" => "CREATE VIEW grouped_sender_acl (username, send_as_acl) AS
  24. SELECT logged_in_as, IFNULL(GROUP_CONCAT(send_as SEPARATOR ' '), '') AS send_as_acl FROM sender_acl
  25. WHERE send_as NOT LIKE '@%'
  26. GROUP BY logged_in_as;",
  27. "grouped_sender_acl_external" => "CREATE VIEW grouped_sender_acl_external (username, send_as_acl) AS
  28. SELECT logged_in_as, IFNULL(GROUP_CONCAT(send_as SEPARATOR ' '), '') AS send_as_acl FROM sender_acl
  29. WHERE send_as NOT LIKE '@%' AND external = '1'
  30. GROUP BY logged_in_as;",
  31. "grouped_domain_alias_address" => "CREATE VIEW grouped_domain_alias_address (username, ad_alias) AS
  32. SELECT username, IFNULL(GROUP_CONCAT(local_part, '@', alias_domain SEPARATOR ' '), '') AS ad_alias FROM mailbox
  33. LEFT OUTER JOIN alias_domain ON target_domain=domain
  34. GROUP BY username;",
  35. "sieve_before" => "CREATE VIEW sieve_before (id, username, script_name, script_data) AS
  36. SELECT md5(script_data), username, script_name, script_data FROM sieve_filters
  37. WHERE filter_type = 'prefilter';",
  38. "sieve_after" => "CREATE VIEW sieve_after (id, username, script_name, script_data) AS
  39. SELECT md5(script_data), username, script_name, script_data FROM sieve_filters
  40. WHERE filter_type = 'postfilter';"
  41. );
  42. $tables = array(
  43. "versions" => array(
  44. "cols" => array(
  45. "application" => "VARCHAR(255) NOT NULL",
  46. "version" => "VARCHAR(100) NOT NULL",
  47. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  48. ),
  49. "keys" => array(
  50. "primary" => array(
  51. "" => array("application")
  52. )
  53. ),
  54. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  55. ),
  56. "admin" => array(
  57. "cols" => array(
  58. "username" => "VARCHAR(255) NOT NULL",
  59. "password" => "VARCHAR(255) NOT NULL",
  60. "superadmin" => "TINYINT(1) NOT NULL DEFAULT '0'",
  61. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  62. "modified" => "DATETIME ON UPDATE NOW(0)",
  63. "active" => "TINYINT(1) NOT NULL DEFAULT '1'"
  64. ),
  65. "keys" => array(
  66. "primary" => array(
  67. "" => array("username")
  68. )
  69. ),
  70. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  71. ),
  72. "_sogo_static_view" => array(
  73. "cols" => array(
  74. "c_uid" => "VARCHAR(255) NOT NULL",
  75. "domain" => "VARCHAR(255) NOT NULL",
  76. "c_name" => "VARCHAR(255) NOT NULL",
  77. "c_password" => "VARCHAR(255) NOT NULL DEFAULT ''",
  78. "c_cn" => "VARCHAR(255)",
  79. "mail" => "VARCHAR(255) NOT NULL",
  80. // TODO -> use TEXT and check if SOGo login breaks on empty aliases
  81. "aliases" => "TEXT NOT NULL",
  82. "ad_aliases" => "VARCHAR(6144) NOT NULL DEFAULT ''",
  83. "ext_acl" => "VARCHAR(6144) NOT NULL DEFAULT ''",
  84. "kind" => "VARCHAR(100) NOT NULL DEFAULT ''",
  85. "multiple_bookings" => "INT NOT NULL DEFAULT -1"
  86. ),
  87. "keys" => array(
  88. "primary" => array(
  89. "" => array("c_uid")
  90. ),
  91. "key" => array(
  92. "domain" => array("domain")
  93. )
  94. ),
  95. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  96. ),
  97. "relayhosts" => array(
  98. "cols" => array(
  99. "id" => "INT NOT NULL AUTO_INCREMENT",
  100. "hostname" => "VARCHAR(255) NOT NULL",
  101. "username" => "VARCHAR(255) NOT NULL",
  102. "password" => "VARCHAR(255) NOT NULL",
  103. "active" => "TINYINT(1) NOT NULL DEFAULT '1'"
  104. ),
  105. "keys" => array(
  106. "primary" => array(
  107. "" => array("id")
  108. ),
  109. "key" => array(
  110. "hostname" => array("hostname")
  111. )
  112. ),
  113. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  114. ),
  115. "transports" => array(
  116. "cols" => array(
  117. "id" => "INT NOT NULL AUTO_INCREMENT",
  118. "destination" => "VARCHAR(255) NOT NULL",
  119. "nexthop" => "VARCHAR(255) NOT NULL",
  120. "username" => "VARCHAR(255) NOT NULL",
  121. "password" => "VARCHAR(255) NOT NULL",
  122. "lookup_mx" => "TINYINT(1) NOT NULL DEFAULT '1'",
  123. "active" => "TINYINT(1) NOT NULL DEFAULT '1'"
  124. ),
  125. "keys" => array(
  126. "primary" => array(
  127. "" => array("id")
  128. ),
  129. "key" => array(
  130. "destination" => array("destination"),
  131. "nexthop" => array("nexthop"),
  132. )
  133. ),
  134. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  135. ),
  136. "alias" => array(
  137. "cols" => array(
  138. "id" => "INT NOT NULL AUTO_INCREMENT",
  139. "address" => "VARCHAR(255) NOT NULL",
  140. "goto" => "TEXT NOT NULL",
  141. "domain" => "VARCHAR(255) NOT NULL",
  142. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  143. "modified" => "DATETIME ON UPDATE CURRENT_TIMESTAMP",
  144. "private_comment" => "TEXT",
  145. "public_comment" => "TEXT",
  146. "active" => "TINYINT(1) NOT NULL DEFAULT '1'"
  147. ),
  148. "keys" => array(
  149. "primary" => array(
  150. "" => array("id")
  151. ),
  152. "unique" => array(
  153. "address" => array("address")
  154. ),
  155. "key" => array(
  156. "domain" => array("domain")
  157. )
  158. ),
  159. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  160. ),
  161. "api" => array(
  162. "cols" => array(
  163. "api_key" => "VARCHAR(255) NOT NULL",
  164. "allow_from" => "VARCHAR(512) NOT NULL",
  165. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  166. "modified" => "DATETIME ON UPDATE NOW(0)",
  167. "active" => "TINYINT(1) NOT NULL DEFAULT '1'"
  168. ),
  169. "keys" => array(
  170. "primary" => array(
  171. "" => array("api_key")
  172. ),
  173. ),
  174. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  175. ),
  176. "sender_acl" => array(
  177. "cols" => array(
  178. "id" => "INT NOT NULL AUTO_INCREMENT",
  179. "logged_in_as" => "VARCHAR(255) NOT NULL",
  180. "send_as" => "VARCHAR(255) NOT NULL",
  181. "external" => "TINYINT(1) NOT NULL DEFAULT '0'"
  182. ),
  183. "keys" => array(
  184. "primary" => array(
  185. "" => array("id")
  186. )
  187. ),
  188. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  189. ),
  190. "domain" => array(
  191. // Todo: Move some attributes to json
  192. "cols" => array(
  193. "domain" => "VARCHAR(255) NOT NULL",
  194. "description" => "VARCHAR(255)",
  195. "aliases" => "INT(10) NOT NULL DEFAULT '0'",
  196. "mailboxes" => "INT(10) NOT NULL DEFAULT '0'",
  197. "defquota" => "BIGINT(20) NOT NULL DEFAULT '3072'",
  198. "maxquota" => "BIGINT(20) NOT NULL DEFAULT '102400'",
  199. "quota" => "BIGINT(20) NOT NULL DEFAULT '102400'",
  200. "relayhost" => "VARCHAR(255) NOT NULL DEFAULT '0'",
  201. "backupmx" => "TINYINT(1) NOT NULL DEFAULT '0'",
  202. "gal" => "TINYINT(1) NOT NULL DEFAULT '1'",
  203. "relay_all_recipients" => "TINYINT(1) NOT NULL DEFAULT '0'",
  204. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  205. "modified" => "DATETIME ON UPDATE CURRENT_TIMESTAMP",
  206. "active" => "TINYINT(1) NOT NULL DEFAULT '1'"
  207. ),
  208. "keys" => array(
  209. "primary" => array(
  210. "" => array("domain")
  211. )
  212. ),
  213. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  214. ),
  215. "tls_policy_override" => array(
  216. "cols" => array(
  217. "id" => "INT NOT NULL AUTO_INCREMENT",
  218. "dest" => "VARCHAR(255) NOT NULL",
  219. "policy" => "ENUM('none', 'may', 'encrypt', 'dane', 'dane-only', 'fingerprint', 'verify', 'secure') NOT NULL",
  220. "parameters" => "VARCHAR(255) DEFAULT ''",
  221. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  222. "modified" => "DATETIME ON UPDATE CURRENT_TIMESTAMP",
  223. "active" => "TINYINT(1) NOT NULL DEFAULT '1'"
  224. ),
  225. "keys" => array(
  226. "primary" => array(
  227. "" => array("id")
  228. ),
  229. "unique" => array(
  230. "dest" => array("dest")
  231. ),
  232. ),
  233. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  234. ),
  235. "quarantine" => array(
  236. "cols" => array(
  237. "id" => "INT NOT NULL AUTO_INCREMENT",
  238. "qid" => "VARCHAR(30) NOT NULL",
  239. "subject" => "VARCHAR(500)",
  240. "score" => "FLOAT(8,2)",
  241. "ip" => "VARCHAR(50)",
  242. "action" => "CHAR(20) NOT NULL DEFAULT 'unknown'",
  243. "symbols" => "JSON",
  244. "sender" => "VARCHAR(255) NOT NULL DEFAULT 'unknown'",
  245. "rcpt" => "VARCHAR(255)",
  246. "msg" => "LONGTEXT",
  247. "domain" => "VARCHAR(255)",
  248. "notified" => "TINYINT(1) NOT NULL DEFAULT '0'",
  249. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  250. "user" => "VARCHAR(255) NOT NULL DEFAULT 'unknown'",
  251. ),
  252. "keys" => array(
  253. "primary" => array(
  254. "" => array("id")
  255. )
  256. ),
  257. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  258. ),
  259. "mailbox" => array(
  260. "cols" => array(
  261. "username" => "VARCHAR(255) NOT NULL",
  262. "password" => "VARCHAR(255) NOT NULL",
  263. "name" => "VARCHAR(255)",
  264. // mailbox_path_prefix is followed by domain/local_part/
  265. "mailbox_path_prefix" => "VARCHAR(150) DEFAULT '/var/vmail/'",
  266. "quota" => "BIGINT(20) NOT NULL DEFAULT '102400'",
  267. "local_part" => "VARCHAR(255) NOT NULL",
  268. "domain" => "VARCHAR(255) NOT NULL",
  269. "attributes" => "JSON",
  270. "kind" => "VARCHAR(100) NOT NULL DEFAULT ''",
  271. "multiple_bookings" => "INT NOT NULL DEFAULT -1",
  272. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  273. "modified" => "DATETIME ON UPDATE CURRENT_TIMESTAMP",
  274. "active" => "TINYINT(1) NOT NULL DEFAULT '1'"
  275. ),
  276. "keys" => array(
  277. "primary" => array(
  278. "" => array("username")
  279. ),
  280. "key" => array(
  281. "domain" => array("domain")
  282. )
  283. ),
  284. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  285. ),
  286. "sieve_filters" => array(
  287. "cols" => array(
  288. "id" => "INT NOT NULL AUTO_INCREMENT",
  289. "username" => "VARCHAR(255) NOT NULL",
  290. "script_desc" => "VARCHAR(255) NOT NULL",
  291. "script_name" => "ENUM('active','inactive')",
  292. "script_data" => "TEXT NOT NULL",
  293. "filter_type" => "ENUM('postfilter','prefilter')",
  294. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  295. "modified" => "DATETIME ON UPDATE CURRENT_TIMESTAMP"
  296. ),
  297. "keys" => array(
  298. "primary" => array(
  299. "" => array("id")
  300. ),
  301. "key" => array(
  302. "username" => array("username"),
  303. "script_desc" => array("script_desc")
  304. ),
  305. "fkey" => array(
  306. "fk_username_sieve_global_before" => array(
  307. "col" => "username",
  308. "ref" => "mailbox.username",
  309. "delete" => "CASCADE",
  310. "update" => "NO ACTION"
  311. )
  312. )
  313. ),
  314. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  315. ),
  316. "user_acl" => array(
  317. "cols" => array(
  318. "username" => "VARCHAR(255) NOT NULL",
  319. "spam_alias" => "TINYINT(1) NOT NULL DEFAULT '1'",
  320. "tls_policy" => "TINYINT(1) NOT NULL DEFAULT '1'",
  321. "spam_score" => "TINYINT(1) NOT NULL DEFAULT '1'",
  322. "spam_policy" => "TINYINT(1) NOT NULL DEFAULT '1'",
  323. "delimiter_action" => "TINYINT(1) NOT NULL DEFAULT '1'",
  324. "syncjobs" => "TINYINT(1) NOT NULL DEFAULT '1'",
  325. "eas_reset" => "TINYINT(1) NOT NULL DEFAULT '1'",
  326. "sogo_profile_reset" => "TINYINT(1) NOT NULL DEFAULT '1'",
  327. "quarantine" => "TINYINT(1) NOT NULL DEFAULT '1'",
  328. "quarantine_attachments" => "TINYINT(1) NOT NULL DEFAULT '1'",
  329. "quarantine_notification" => "TINYINT(1) NOT NULL DEFAULT '1'",
  330. ),
  331. "keys" => array(
  332. "primary" => array(
  333. "" => array("username")
  334. ),
  335. "fkey" => array(
  336. "fk_username" => array(
  337. "col" => "username",
  338. "ref" => "mailbox.username",
  339. "delete" => "CASCADE",
  340. "update" => "NO ACTION"
  341. )
  342. )
  343. ),
  344. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  345. ),
  346. "alias_domain" => array(
  347. "cols" => array(
  348. "alias_domain" => "VARCHAR(255) NOT NULL",
  349. "target_domain" => "VARCHAR(255) NOT NULL",
  350. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  351. "modified" => "DATETIME ON UPDATE CURRENT_TIMESTAMP",
  352. "active" => "TINYINT(1) NOT NULL DEFAULT '1'"
  353. ),
  354. "keys" => array(
  355. "primary" => array(
  356. "" => array("alias_domain")
  357. ),
  358. "key" => array(
  359. "active" => array("active"),
  360. "target_domain" => array("target_domain")
  361. )
  362. ),
  363. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  364. ),
  365. "spamalias" => array(
  366. "cols" => array(
  367. "address" => "VARCHAR(255) NOT NULL",
  368. "goto" => "TEXT NOT NULL",
  369. "validity" => "INT(11) NOT NULL"
  370. ),
  371. "keys" => array(
  372. "primary" => array(
  373. "" => array("address")
  374. ),
  375. ),
  376. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  377. ),
  378. "filterconf" => array(
  379. "cols" => array(
  380. "object" => "VARCHAR(255) NOT NULL DEFAULT ''",
  381. "option" => "VARCHAR(50) NOT NULL DEFAULT ''",
  382. "value" => "VARCHAR(100) NOT NULL DEFAULT ''",
  383. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  384. "modified" => "DATETIME ON UPDATE CURRENT_TIMESTAMP",
  385. "prefid" => "INT(11) NOT NULL AUTO_INCREMENT"
  386. ),
  387. "keys" => array(
  388. "primary" => array(
  389. "" => array("prefid")
  390. ),
  391. "key" => array(
  392. "object" => array("object")
  393. )
  394. ),
  395. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  396. ),
  397. "settingsmap" => array(
  398. "cols" => array(
  399. "id" => "INT NOT NULL AUTO_INCREMENT",
  400. "desc" => "VARCHAR(255) NOT NULL",
  401. "content" => "LONGTEXT NOT NULL",
  402. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  403. "modified" => "DATETIME ON UPDATE CURRENT_TIMESTAMP",
  404. "active" => "TINYINT(1) NOT NULL DEFAULT '0'"
  405. ),
  406. "keys" => array(
  407. "primary" => array(
  408. "" => array("id")
  409. )
  410. ),
  411. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  412. ),
  413. "logs" => array(
  414. "cols" => array(
  415. "id" => "INT NOT NULL AUTO_INCREMENT",
  416. "task" => "CHAR(32) NOT NULL DEFAULT '000000'",
  417. "type" => "VARCHAR(32) DEFAULT ''",
  418. "msg" => "TEXT",
  419. "call" => "TEXT",
  420. "user" => "VARCHAR(64) NOT NULL",
  421. "role" => "VARCHAR(32) NOT NULL",
  422. "remote" => "VARCHAR(39) NOT NULL",
  423. "time" => "INT(11) NOT NULL"
  424. ),
  425. "keys" => array(
  426. "primary" => array(
  427. "" => array("id")
  428. )
  429. ),
  430. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  431. ),
  432. "quota2" => array(
  433. "cols" => array(
  434. "username" => "VARCHAR(255) NOT NULL",
  435. "bytes" => "BIGINT(20) NOT NULL DEFAULT '0'",
  436. "messages" => "BIGINT(20) NOT NULL DEFAULT '0'"
  437. ),
  438. "keys" => array(
  439. "primary" => array(
  440. "" => array("username")
  441. )
  442. ),
  443. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  444. ),
  445. "domain_admins" => array(
  446. "cols" => array(
  447. "id" => "INT NOT NULL AUTO_INCREMENT",
  448. "username" => "VARCHAR(255) NOT NULL",
  449. "domain" => "VARCHAR(255) NOT NULL",
  450. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  451. "active" => "TINYINT(1) NOT NULL DEFAULT '1'"
  452. ),
  453. "keys" => array(
  454. "primary" => array(
  455. "" => array("id")
  456. ),
  457. "key" => array(
  458. "username" => array("username")
  459. )
  460. ),
  461. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  462. ),
  463. "da_acl" => array(
  464. "cols" => array(
  465. "username" => "VARCHAR(255) NOT NULL",
  466. "syncjobs" => "TINYINT(1) NOT NULL DEFAULT '1'",
  467. "quarantine" => "TINYINT(1) NOT NULL DEFAULT '1'",
  468. "login_as" => "TINYINT(1) NOT NULL DEFAULT '1'",
  469. "bcc_maps" => "TINYINT(1) NOT NULL DEFAULT '1'",
  470. "filters" => "TINYINT(1) NOT NULL DEFAULT '1'",
  471. "ratelimit" => "TINYINT(1) NOT NULL DEFAULT '1'",
  472. "spam_policy" => "TINYINT(1) NOT NULL DEFAULT '1'",
  473. "extend_sender_acl" => "TINYINT(1) NOT NULL DEFAULT '0'",
  474. "unlimited_quota" => "TINYINT(1) NOT NULL DEFAULT '0'",
  475. "alias_domains" => "TINYINT(1) NOT NULL DEFAULT '0'",
  476. ),
  477. "keys" => array(
  478. "primary" => array(
  479. "" => array("username")
  480. )
  481. ),
  482. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  483. ),
  484. "imapsync" => array(
  485. "cols" => array(
  486. "id" => "INT NOT NULL AUTO_INCREMENT",
  487. "user2" => "VARCHAR(255) NOT NULL",
  488. "host1" => "VARCHAR(255) NOT NULL",
  489. "authmech1" => "ENUM('PLAIN','LOGIN','CRAM-MD5') DEFAULT 'PLAIN'",
  490. "regextrans2" => "VARCHAR(255) DEFAULT ''",
  491. "authmd51" => "TINYINT(1) NOT NULL DEFAULT 0",
  492. "domain2" => "VARCHAR(255) NOT NULL DEFAULT ''",
  493. "subfolder2" => "VARCHAR(255) NOT NULL DEFAULT ''",
  494. "user1" => "VARCHAR(255) NOT NULL",
  495. "password1" => "VARCHAR(255) NOT NULL",
  496. "exclude" => "VARCHAR(500) NOT NULL DEFAULT ''",
  497. "maxage" => "SMALLINT NOT NULL DEFAULT '0'",
  498. "mins_interval" => "VARCHAR(50) NOT NULL DEFAULT '0'",
  499. "maxbytespersecond" => "VARCHAR(50) NOT NULL DEFAULT '0'",
  500. "port1" => "SMALLINT NOT NULL",
  501. "enc1" => "ENUM('TLS','SSL','PLAIN') DEFAULT 'TLS'",
  502. "delete2duplicates" => "TINYINT(1) NOT NULL DEFAULT '1'",
  503. "delete1" => "TINYINT(1) NOT NULL DEFAULT '0'",
  504. "delete2" => "TINYINT(1) NOT NULL DEFAULT '0'",
  505. "automap" => "TINYINT(1) NOT NULL DEFAULT '0'",
  506. "skipcrossduplicates" => "TINYINT(1) NOT NULL DEFAULT '0'",
  507. "custom_params" => "VARCHAR(512) NOT NULL DEFAULT ''",
  508. "timeout1" => "SMALLINT NOT NULL DEFAULT '600'",
  509. "timeout2" => "SMALLINT NOT NULL DEFAULT '600'",
  510. "subscribeall" => "TINYINT(1) NOT NULL DEFAULT '1'",
  511. "is_running" => "TINYINT(1) NOT NULL DEFAULT '0'",
  512. "returned_text" => "LONGTEXT",
  513. "last_run" => "TIMESTAMP NULL DEFAULT NULL",
  514. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  515. "modified" => "DATETIME ON UPDATE CURRENT_TIMESTAMP",
  516. "active" => "TINYINT(1) NOT NULL DEFAULT '0'"
  517. ),
  518. "keys" => array(
  519. "primary" => array(
  520. "" => array("id")
  521. )
  522. ),
  523. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  524. ),
  525. "bcc_maps" => array(
  526. "cols" => array(
  527. "id" => "INT NOT NULL AUTO_INCREMENT",
  528. "local_dest" => "VARCHAR(255) NOT NULL",
  529. "bcc_dest" => "VARCHAR(255) NOT NULL",
  530. "domain" => "VARCHAR(255) NOT NULL",
  531. "type" => "ENUM('sender','rcpt')",
  532. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  533. "modified" => "DATETIME ON UPDATE CURRENT_TIMESTAMP",
  534. "active" => "TINYINT(1) NOT NULL DEFAULT '0'"
  535. ),
  536. "keys" => array(
  537. "primary" => array(
  538. "" => array("id")
  539. ),
  540. "key" => array(
  541. "local_dest" => array("local_dest"),
  542. )
  543. ),
  544. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  545. ),
  546. "recipient_maps" => array(
  547. "cols" => array(
  548. "id" => "INT NOT NULL AUTO_INCREMENT",
  549. "old_dest" => "VARCHAR(255) NOT NULL",
  550. "new_dest" => "VARCHAR(255) NOT NULL",
  551. "created" => "DATETIME(0) NOT NULL DEFAULT NOW(0)",
  552. "modified" => "DATETIME ON UPDATE CURRENT_TIMESTAMP",
  553. "active" => "TINYINT(1) NOT NULL DEFAULT '0'"
  554. ),
  555. "keys" => array(
  556. "primary" => array(
  557. "" => array("id")
  558. ),
  559. "key" => array(
  560. "local_dest" => array("old_dest"),
  561. )
  562. ),
  563. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  564. ),
  565. "tfa" => array(
  566. "cols" => array(
  567. "id" => "INT NOT NULL AUTO_INCREMENT",
  568. "key_id" => "VARCHAR(255) NOT NULL",
  569. "username" => "VARCHAR(255) NOT NULL",
  570. "authmech" => "ENUM('yubi_otp', 'u2f', 'hotp', 'totp')",
  571. "secret" => "VARCHAR(255) DEFAULT NULL",
  572. "keyHandle" => "VARCHAR(255) DEFAULT NULL",
  573. "publicKey" => "VARCHAR(255) DEFAULT NULL",
  574. "counter" => "INT NOT NULL DEFAULT '0'",
  575. "certificate" => "TEXT",
  576. "active" => "TINYINT(1) NOT NULL DEFAULT '0'"
  577. ),
  578. "keys" => array(
  579. "primary" => array(
  580. "" => array("id")
  581. )
  582. ),
  583. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  584. ),
  585. "forwarding_hosts" => array(
  586. "cols" => array(
  587. "host" => "VARCHAR(255) NOT NULL",
  588. "source" => "VARCHAR(255) NOT NULL",
  589. "filter_spam" => "TINYINT(1) NOT NULL DEFAULT '0'"
  590. ),
  591. "keys" => array(
  592. "primary" => array(
  593. "" => array("host")
  594. ),
  595. ),
  596. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  597. ),
  598. "sogo_acl" => array(
  599. "cols" => array(
  600. "id" => "INT NOT NULL AUTO_INCREMENT",
  601. "c_folder_id" => "INT NOT NULL",
  602. "c_object" => "VARCHAR(255) NOT NULL",
  603. "c_uid" => "VARCHAR(255) NOT NULL",
  604. "c_role" => "VARCHAR(80) NOT NULL"
  605. ),
  606. "keys" => array(
  607. "primary" => array(
  608. "" => array("id")
  609. ),
  610. "key" => array(
  611. "sogo_acl_c_folder_id_idx" => array("c_folder_id"),
  612. "sogo_acl_c_uid_idx" => array("c_uid")
  613. )
  614. ),
  615. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  616. ),
  617. "sogo_alarms_folder" => array(
  618. "cols" => array(
  619. "id" => "INT NOT NULL AUTO_INCREMENT",
  620. "c_path" => "VARCHAR(255) NOT NULL",
  621. "c_name" => "VARCHAR(255) NOT NULL",
  622. "c_uid" => "VARCHAR(255) NOT NULL",
  623. "c_recurrence_id" => "INT(11) DEFAULT NULL",
  624. "c_alarm_number" => "INT(11) NOT NULL",
  625. "c_alarm_date" => "INT(11) NOT NULL"
  626. ),
  627. "keys" => array(
  628. "primary" => array(
  629. "" => array("id")
  630. )
  631. ),
  632. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  633. ),
  634. "sogo_cache_folder" => array(
  635. "cols" => array(
  636. "c_uid" => "VARCHAR(255) NOT NULL",
  637. "c_path" => "VARCHAR(255) NOT NULL",
  638. "c_parent_path" => "VARCHAR(255) DEFAULT NULL",
  639. "c_type" => "TINYINT(3) unsigned NOT NULL",
  640. "c_creationdate" => "INT(11) NOT NULL",
  641. "c_lastmodified" => "INT(11) NOT NULL",
  642. "c_version" => "INT(11) NOT NULL DEFAULT '0'",
  643. "c_deleted" => "TINYINT(4) NOT NULL DEFAULT '0'",
  644. "c_content" => "LONGTEXT"
  645. ),
  646. "keys" => array(
  647. "primary" => array(
  648. "" => array("c_uid", "c_path")
  649. ),
  650. ),
  651. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  652. ),
  653. "sogo_folder_info" => array(
  654. "cols" => array(
  655. "c_folder_id" => "BIGINT(20) unsigned NOT NULL AUTO_INCREMENT",
  656. "c_path" => "VARCHAR(255) NOT NULL",
  657. "c_path1" => "VARCHAR(255) NOT NULL",
  658. "c_path2" => "VARCHAR(255) DEFAULT NULL",
  659. "c_path3" => "VARCHAR(255) DEFAULT NULL",
  660. "c_path4" => "VARCHAR(255) DEFAULT NULL",
  661. "c_foldername" => "VARCHAR(255) NOT NULL",
  662. "c_location" => "VARCHAR(2048) DEFAULT NULL",
  663. "c_quick_location" => "VARCHAR(2048) DEFAULT NULL",
  664. "c_acl_location" => "VARCHAR(2048) DEFAULT NULL",
  665. "c_folder_type" => "VARCHAR(255) NOT NULL"
  666. ),
  667. "keys" => array(
  668. "primary" => array(
  669. "" => array("c_path")
  670. ),
  671. "unique" => array(
  672. "c_folder_id" => array("c_folder_id")
  673. )
  674. ),
  675. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  676. ),
  677. "sogo_quick_appointment" => array(
  678. "cols" => array(
  679. "c_folder_id" => "INT NOT NULL",
  680. "c_name" => "VARCHAR(255) NOT NULL",
  681. "c_uid" => "VARCHAR(255) NOT NULL",
  682. "c_startdate" => "INT",
  683. "c_enddate" => "INT",
  684. "c_cycleenddate" => "INT",
  685. "c_title" => "VARCHAR(1000) NOT NULL",
  686. "c_participants" => "TEXT",
  687. "c_isallday" => "INT",
  688. "c_iscycle" => "INT",
  689. "c_cycleinfo" => "TEXT",
  690. "c_classification" => "INT NOT NULL",
  691. "c_isopaque" => "INT NOT NULL",
  692. "c_status" => "INT NOT NULL",
  693. "c_priority" => "INT",
  694. "c_location" => "VARCHAR(255)",
  695. "c_orgmail" => "VARCHAR(255)",
  696. "c_partmails" => "TEXT",
  697. "c_partstates" => "TEXT",
  698. "c_category" => "VARCHAR(255)",
  699. "c_sequence" => "INT",
  700. "c_component" => "VARCHAR(10) NOT NULL",
  701. "c_nextalarm" => "INT",
  702. "c_description" => "TEXT"
  703. ),
  704. "keys" => array(
  705. "primary" => array(
  706. "" => array("c_folder_id", "c_name")
  707. )
  708. ),
  709. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  710. ),
  711. "sogo_quick_contact" => array(
  712. "cols" => array(
  713. "c_folder_id" => "INT NOT NULL",
  714. "c_name" => "VARCHAR(255) NOT NULL",
  715. "c_givenname" => "VARCHAR(255)",
  716. "c_cn" => "VARCHAR(255)",
  717. "c_sn" => "VARCHAR(255)",
  718. "c_screenname" => "VARCHAR(255)",
  719. "c_l" => "VARCHAR(255)",
  720. "c_mail" => "TEXT",
  721. "c_o" => "VARCHAR(255)",
  722. "c_ou" => "VARCHAR(255)",
  723. "c_telephonenumber" => "VARCHAR(255)",
  724. "c_categories" => "VARCHAR(255)",
  725. "c_component" => "VARCHAR(10) NOT NULL",
  726. "c_hascertificate" => "INT4 DEFAULT 0"
  727. ),
  728. "keys" => array(
  729. "primary" => array(
  730. "" => array("c_folder_id", "c_name")
  731. )
  732. ),
  733. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  734. ),
  735. "sogo_sessions_folder" => array(
  736. "cols" => array(
  737. "c_id" => "VARCHAR(255) NOT NULL",
  738. "c_value" => "VARCHAR(255) NOT NULL",
  739. "c_creationdate" => "INT(11) NOT NULL",
  740. "c_lastseen" => "INT(11) NOT NULL"
  741. ),
  742. "keys" => array(
  743. "primary" => array(
  744. "" => array("c_id")
  745. )
  746. ),
  747. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  748. ),
  749. "sogo_store" => array(
  750. "cols" => array(
  751. "c_folder_id" => "INT NOT NULL",
  752. "c_name" => "VARCHAR(255) NOT NULL",
  753. "c_content" => "MEDIUMTEXT NOT NULL",
  754. "c_creationdate" => "INT NOT NULL",
  755. "c_lastmodified" => "INT NOT NULL",
  756. "c_version" => "INT NOT NULL",
  757. "c_deleted" => "INT"
  758. ),
  759. "keys" => array(
  760. "primary" => array(
  761. "" => array("c_folder_id", "c_name")
  762. )
  763. ),
  764. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  765. ),
  766. "sogo_user_profile" => array(
  767. "cols" => array(
  768. "c_uid" => "VARCHAR(255) NOT NULL",
  769. "c_defaults" => "LONGTEXT",
  770. "c_settings" => "LONGTEXT"
  771. ),
  772. "keys" => array(
  773. "primary" => array(
  774. "" => array("c_uid")
  775. )
  776. ),
  777. "attr" => "ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC"
  778. )
  779. );
  780. foreach ($tables as $table => $properties) {
  781. // Migrate to quarantine
  782. if ($table == 'quarantine') {
  783. $stmt = $pdo->query("SHOW TABLES LIKE 'quarantaine'");
  784. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  785. if ($num_results != 0) {
  786. $stmt = $pdo->query("SHOW TABLES LIKE 'quarantine'");
  787. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  788. if ($num_results == 0) {
  789. $pdo->query("RENAME TABLE `quarantaine` TO `quarantine`");
  790. }
  791. }
  792. }
  793. // Migrate tls_enforce_* options
  794. if ($table == 'mailbox') {
  795. $stmt = $pdo->query("SHOW TABLES LIKE 'mailbox'");
  796. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  797. if ($num_results != 0) {
  798. $stmt = $pdo->query("SHOW COLUMNS FROM `mailbox` LIKE '%tls_enforce%'");
  799. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  800. if ($num_results != 0) {
  801. $stmt = $pdo->query("SELECT `username`, `tls_enforce_in`, `tls_enforce_out` FROM `mailbox`");
  802. $tls_options_rows = $stmt->fetchAll(PDO::FETCH_ASSOC);
  803. while ($row = array_shift($tls_options_rows)) {
  804. $tls_options[$row['username']] = array('tls_enforce_in' => $row['tls_enforce_in'], 'tls_enforce_out' => $row['tls_enforce_out']);
  805. }
  806. }
  807. }
  808. }
  809. $stmt = $pdo->query("SHOW TABLES LIKE '" . $table . "'");
  810. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  811. if ($num_results != 0) {
  812. $stmt = $pdo->prepare("SELECT CONCAT('ALTER TABLE ', `table_schema`, '.', `table_name`, ' DROP FOREIGN KEY ', `constraint_name`, ';') AS `FKEY_DROP` FROM `information_schema`.`table_constraints`
  813. WHERE `constraint_type` = 'FOREIGN KEY' AND `table_name` = :table;");
  814. $stmt->execute(array(':table' => $table));
  815. $rows = $stmt->fetchAll(PDO::FETCH_ASSOC);
  816. while ($row = array_shift($rows)) {
  817. $pdo->query($row['FKEY_DROP']);
  818. }
  819. foreach($properties['cols'] as $column => $type) {
  820. $stmt = $pdo->query("SHOW COLUMNS FROM `" . $table . "` LIKE '" . $column . "'");
  821. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  822. if ($num_results == 0) {
  823. if (strpos($type, 'AUTO_INCREMENT') !== false) {
  824. $type = $type . ' PRIMARY KEY ';
  825. // Adding an AUTO_INCREMENT key, need to drop primary keys first, if exists
  826. $stmt = $pdo->query("SHOW KEYS FROM `" . $table . "` WHERE Key_name = 'PRIMARY'");
  827. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  828. if ($num_results != 0) {
  829. $pdo->query("ALTER TABLE `" . $table . "` DROP PRIMARY KEY");
  830. }
  831. }
  832. $pdo->query("ALTER TABLE `" . $table . "` ADD `" . $column . "` " . $type);
  833. }
  834. else {
  835. $pdo->query("ALTER TABLE `" . $table . "` MODIFY COLUMN `" . $column . "` " . $type);
  836. }
  837. }
  838. foreach($properties['keys'] as $key_type => $key_content) {
  839. if (strtolower($key_type) == 'primary') {
  840. foreach ($key_content as $key_values) {
  841. $fields = "`" . implode("`, `", $key_values) . "`";
  842. $stmt = $pdo->query("SHOW KEYS FROM `" . $table . "` WHERE Key_name = 'PRIMARY'");
  843. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  844. $is_drop = ($num_results != 0) ? "DROP PRIMARY KEY, " : "";
  845. $pdo->query("ALTER TABLE `" . $table . "` " . $is_drop . "ADD PRIMARY KEY (" . $fields . ")");
  846. }
  847. }
  848. if (strtolower($key_type) == 'key') {
  849. foreach ($key_content as $key_name => $key_values) {
  850. $fields = "`" . implode("`, `", $key_values) . "`";
  851. $stmt = $pdo->query("SHOW KEYS FROM `" . $table . "` WHERE Key_name = '" . $key_name . "'");
  852. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  853. $is_drop = ($num_results != 0) ? "DROP INDEX `" . $key_name . "`, " : "";
  854. $pdo->query("ALTER TABLE `" . $table . "` " . $is_drop . "ADD KEY `" . $key_name . "` (" . $fields . ")");
  855. }
  856. }
  857. if (strtolower($key_type) == 'unique') {
  858. foreach ($key_content as $key_name => $key_values) {
  859. $fields = "`" . implode("`, `", $key_values) . "`";
  860. $stmt = $pdo->query("SHOW KEYS FROM `" . $table . "` WHERE Key_name = '" . $key_name . "'");
  861. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  862. $is_drop = ($num_results != 0) ? "DROP INDEX `" . $key_name . "`, " : "";
  863. $pdo->query("ALTER TABLE `" . $table . "` " . $is_drop . "ADD UNIQUE KEY `" . $key_name . "` (" . $fields . ")");
  864. }
  865. }
  866. if (strtolower($key_type) == 'fkey') {
  867. foreach ($key_content as $key_name => $key_values) {
  868. $fields = "`" . implode("`, `", $key_values) . "`";
  869. $stmt = $pdo->query("SHOW KEYS FROM `" . $table . "` WHERE Key_name = '" . $key_name . "'");
  870. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  871. if ($num_results != 0) {
  872. $pdo->query("ALTER TABLE `" . $table . "` DROP INDEX `" . $key_name . "`");
  873. }
  874. @list($table_ref, $field_ref) = explode('.', $key_values['ref']);
  875. $pdo->query("ALTER TABLE `" . $table . "` ADD FOREIGN KEY `" . $key_name . "` (" . $key_values['col'] . ") REFERENCES `" . $table_ref . "` (`" . $field_ref . "`)
  876. ON DELETE " . $key_values['delete'] . " ON UPDATE " . $key_values['update']);
  877. }
  878. }
  879. }
  880. // Drop all vanished columns
  881. $stmt = $pdo->query("SHOW COLUMNS FROM `" . $table . "`");
  882. $cols_in_table = $stmt->fetchAll(PDO::FETCH_ASSOC);
  883. while ($row = array_shift($cols_in_table)) {
  884. if (!array_key_exists($row['Field'], $properties['cols'])) {
  885. $pdo->query("ALTER TABLE `" . $table . "` DROP COLUMN `" . $row['Field'] . "`;");
  886. }
  887. }
  888. // Step 1: Get all non-primary keys, that currently exist and those that should exist
  889. $stmt = $pdo->query("SHOW KEYS FROM `" . $table . "` WHERE `Key_name` != 'PRIMARY'");
  890. $keys_in_table = $stmt->fetchAll(PDO::FETCH_ASSOC);
  891. $keys_to_exist = array();
  892. if (isset($properties['keys']['unique']) && is_array($properties['keys']['unique'])) {
  893. foreach ($properties['keys']['unique'] as $key_name => $key_values) {
  894. $keys_to_exist[] = $key_name;
  895. }
  896. }
  897. if (isset($properties['keys']['key']) && is_array($properties['keys']['key'])) {
  898. foreach ($properties['keys']['key'] as $key_name => $key_values) {
  899. $keys_to_exist[] = $key_name;
  900. }
  901. }
  902. // Index for foreign key must exist
  903. if (isset($properties['keys']['fkey']) && is_array($properties['keys']['fkey'])) {
  904. foreach ($properties['keys']['fkey'] as $key_name => $key_values) {
  905. $keys_to_exist[] = $key_name;
  906. }
  907. }
  908. // Step 2: Drop all vanished indexes
  909. while ($row = array_shift($keys_in_table)) {
  910. if (!in_array($row['Key_name'], $keys_to_exist)) {
  911. $pdo->query("ALTER TABLE `" . $table . "` DROP INDEX `" . $row['Key_name'] . "`");
  912. }
  913. }
  914. // Step 3: Drop all vanished primary keys
  915. if (!isset($properties['keys']['primary'])) {
  916. $stmt = $pdo->query("SHOW KEYS FROM `" . $table . "` WHERE Key_name = 'PRIMARY'");
  917. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  918. if ($num_results != 0) {
  919. $pdo->query("ALTER TABLE `" . $table . "` DROP PRIMARY KEY");
  920. }
  921. }
  922. }
  923. else {
  924. // Create table if it is missing
  925. $sql = "CREATE TABLE IF NOT EXISTS `" . $table . "` (";
  926. foreach($properties['cols'] as $column => $type) {
  927. $sql .= "`" . $column . "` " . $type . ",";
  928. }
  929. foreach($properties['keys'] as $key_type => $key_content) {
  930. if (strtolower($key_type) == 'primary') {
  931. foreach ($key_content as $key_values) {
  932. $fields = "`" . implode("`, `", $key_values) . "`";
  933. $sql .= "PRIMARY KEY (" . $fields . ")" . ",";
  934. }
  935. }
  936. elseif (strtolower($key_type) == 'key') {
  937. foreach ($key_content as $key_name => $key_values) {
  938. $fields = "`" . implode("`, `", $key_values) . "`";
  939. $sql .= "KEY `" . $key_name . "` (" . $fields . ")" . ",";
  940. }
  941. }
  942. elseif (strtolower($key_type) == 'unique') {
  943. foreach ($key_content as $key_name => $key_values) {
  944. $fields = "`" . implode("`, `", $key_values) . "`";
  945. $sql .= "UNIQUE KEY `" . $key_name . "` (" . $fields . ")" . ",";
  946. }
  947. }
  948. elseif (strtolower($key_type) == 'fkey') {
  949. foreach ($key_content as $key_name => $key_values) {
  950. @list($table_ref, $field_ref) = explode('.', $key_values['ref']);
  951. $fields = "`" . implode("`, `", $key_values) . "`";
  952. $sql .= "FOREIGN KEY `" . $key_name . "` (" . $key_values['col'] . ") REFERENCES `" . $table_ref . "` (`" . $field_ref . "`)
  953. ON DELETE " . $key_values['delete'] . " ON UPDATE " . $key_values['update'] . ",";
  954. }
  955. }
  956. }
  957. $sql = rtrim($sql, ",");
  958. $sql .= ") " . $properties['attr'];
  959. $pdo->query($sql);
  960. }
  961. // Reset table attributes
  962. $pdo->query("ALTER TABLE `" . $table . "` " . $properties['attr'] . ";");
  963. }
  964. // Recreate SQL views
  965. foreach ($views as $view => $create) {
  966. $pdo->query("DROP VIEW IF EXISTS `" . $view . "`;");
  967. $pdo->query($create);
  968. }
  969. // Create events to clean database
  970. $events[] = 'DROP EVENT IF EXISTS clean_spamalias;
  971. DELIMITER //
  972. CREATE EVENT clean_spamalias
  973. ON SCHEDULE EVERY 1 DAY DO
  974. BEGIN
  975. DELETE FROM spamalias WHERE validity < UNIX_TIMESTAMP();
  976. END;
  977. //
  978. DELIMITER ;';
  979. foreach ($events as $event) {
  980. $pdo->exec($event);
  981. }
  982. // Inject admin if not exists
  983. $stmt = $pdo->query("SELECT NULL FROM `admin`");
  984. $num_results = count($stmt->fetchAll(PDO::FETCH_ASSOC));
  985. if ($num_results == 0) {
  986. $stmt = $pdo->query("INSERT INTO `admin` (`username`, `password`, `superadmin`, `created`, `modified`, `active`)
  987. VALUES ('admin', '{SSHA256}K8eVJ6YsZbQCfuJvSUbaQRLr0HPLz5rC9IAp0PAFl0tmNDBkMDc0NDAyOTAxN2Rk', 1, NOW(), NOW(), 1)");
  988. $stmt = $pdo->query("INSERT INTO `domain_admins` (`username`, `domain`, `created`, `active`)
  989. SELECT `username`, 'ALL', NOW(), 1 FROM `admin`
  990. WHERE superadmin='1' AND `username` NOT IN (SELECT `username` FROM `domain_admins`);");
  991. $stmt = $pdo->query("DELETE FROM `admin` WHERE `username` NOT IN (SELECT `username` FROM `domain_admins`);");
  992. }
  993. // Insert new DB schema version
  994. $stmt = $pdo->query("REPLACE INTO `versions` (`application`, `version`) VALUES ('db_schema', '" . $db_version . "');");
  995. // Migrate attributes
  996. $stmt = $pdo->query("UPDATE `mailbox` SET `attributes` = '{}' WHERE `attributes` = '' OR `attributes` IS NULL;");
  997. $stmt = $pdo->query("UPDATE `mailbox` SET `attributes` = JSON_SET(`attributes`, '$.force_pw_update', \"0\") WHERE JSON_EXTRACT(`attributes`, '$.force_pw_update') IS NULL;");
  998. $stmt = $pdo->query("UPDATE `mailbox` SET `attributes` = JSON_SET(`attributes`, '$.sogo_access', \"1\") WHERE JSON_EXTRACT(`attributes`, '$.sogo_access') IS NULL;");
  999. $stmt = $pdo->query("UPDATE `mailbox` SET `attributes` = JSON_SET(`attributes`, '$.mailbox_format', \"maildir:\") WHERE JSON_EXTRACT(`attributes`, '$.mailbox_format') IS NULL;");
  1000. $stmt = $pdo->query("UPDATE `mailbox` SET `attributes` = JSON_SET(`attributes`, '$.quarantine_notification', \"never\") WHERE JSON_EXTRACT(`attributes`, '$.quarantine_notification') IS NULL;");
  1001. foreach($tls_options as $tls_user => $tls_options) {
  1002. $stmt = $pdo->prepare("UPDATE `mailbox` SET `attributes` = JSON_SET(`attributes`, '$.tls_enforce_in', :tls_enforce_in),
  1003. `attributes` = JSON_SET(`attributes`, '$.tls_enforce_out', :tls_enforce_out)
  1004. WHERE `username` = :username");
  1005. $stmt->execute(array(':tls_enforce_in' => $tls_options['tls_enforce_in'], ':tls_enforce_out' => $tls_options['tls_enforce_out'], ':username' => $tls_user));
  1006. }
  1007. // Set tls_enforce_* if still missing (due to deleted attrs for example)
  1008. $stmt = $pdo->query("UPDATE `mailbox` SET `attributes` = JSON_SET(`attributes`, '$.tls_enforce_out', \"1\") WHERE JSON_EXTRACT(`attributes`, '$.tls_enforce_out') IS NULL;");
  1009. $stmt = $pdo->query("UPDATE `mailbox` SET `attributes` = JSON_SET(`attributes`, '$.tls_enforce_in', \"1\") WHERE JSON_EXTRACT(`attributes`, '$.tls_enforce_in') IS NULL;");
  1010. // Fix ACL
  1011. $stmt = $pdo->query("INSERT INTO `user_acl` (`username`) SELECT `username` FROM `mailbox` WHERE `kind` = '' AND NOT EXISTS (SELECT `username` FROM `user_acl`);");
  1012. $stmt = $pdo->query("INSERT INTO `da_acl` (`username`) SELECT DISTINCT `username` FROM `domain_admins` WHERE `username` != 'admin' AND NOT EXISTS (SELECT `username` FROM `da_acl`);");
  1013. // Fix domain_admins
  1014. $stmt = $pdo->query("DELETE FROM `domain_admins` WHERE `domain` = 'ALL';");
  1015. if (php_sapi_name() == "cli") {
  1016. echo "DB initialization completed" . PHP_EOL;
  1017. } else {
  1018. $_SESSION['return'][] = array(
  1019. 'type' => 'success',
  1020. 'log' => array(__FUNCTION__),
  1021. 'msg' => 'db_init_complete'
  1022. );
  1023. }
  1024. }
  1025. catch (PDOException $e) {
  1026. if (php_sapi_name() == "cli") {
  1027. echo "DB initialization failed: " . print_r($e, true) . PHP_EOL;
  1028. } else {
  1029. $_SESSION['return'][] = array(
  1030. 'type' => 'danger',
  1031. 'log' => array(__FUNCTION__),
  1032. 'msg' => array('mysql_error', $e)
  1033. );
  1034. }
  1035. }
  1036. }
  1037. if (php_sapi_name() == "cli") {
  1038. include '/web/inc/vars.inc.php';
  1039. // $now = new DateTime();
  1040. // $mins = $now->getOffset() / 60;
  1041. // $sgn = ($mins < 0 ? -1 : 1);
  1042. // $mins = abs($mins);
  1043. // $hrs = floor($mins / 60);
  1044. // $mins -= $hrs * 60;
  1045. // $offset = sprintf('%+d:%02d', $hrs*$sgn, $mins);
  1046. $dsn = $database_type . ":unix_socket=" . $database_sock . ";dbname=" . $database_name;
  1047. $opt = [
  1048. PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
  1049. PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
  1050. PDO::ATTR_EMULATE_PREPARES => false,
  1051. //PDO::MYSQL_ATTR_INIT_COMMAND => "SET time_zone = '" . $offset . "', group_concat_max_len = 3423543543;",
  1052. ];
  1053. $pdo = new PDO($dsn, $database_user, $database_pass, $opt);
  1054. $stmt = $pdo->query("SELECT COUNT('OK') AS OK_C FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = 'sogo_view' OR TABLE_NAME = '_sogo_static_view';");
  1055. $res = $stmt->fetch(PDO::FETCH_ASSOC);
  1056. if (intval($res['OK_C']) === 2) {
  1057. // Be more precise when replacing into _sogo_static_view, col orders may change
  1058. try {
  1059. $stmt = $pdo->query("REPLACE INTO _sogo_static_view (`c_uid`, `domain`, `c_name`, `c_password`, `c_cn`, `mail`, `aliases`, `ad_aliases`, `kind`, `multiple_bookings`)
  1060. SELECT `c_uid`, `domain`, `c_name`, `c_password`, `c_cn`, `mail`, `aliases`, `ad_aliases`, `kind`, `multiple_bookings` from sogo_view");
  1061. $stmt = $pdo->query("DELETE FROM _sogo_static_view WHERE `c_uid` NOT IN (SELECT `username` FROM `mailbox` WHERE `active` = '1');");
  1062. echo "Fixed _sogo_static_view" . PHP_EOL;
  1063. }
  1064. catch ( Exception $e ) {
  1065. // Dunno
  1066. }
  1067. }
  1068. try {
  1069. $m = new Memcached();
  1070. $m->addServer('memcached', 11211);
  1071. $m->flush();
  1072. echo "Cleaned up memcached". PHP_EOL;
  1073. }
  1074. catch ( Exception $e ) {
  1075. // Dunno
  1076. }
  1077. init_db_schema();
  1078. }