b4c76386d0472b094eb8bcb0ec74f95f073aec02
3 /***************************************************************************\
4 * SPIP, Systeme de publication pour l'internet *
6 * Copyright (c) 2001-2016 *
7 * Arnaud Martin, Antoine Pitrou, Philippe Riviere, Emmanuel Saint-James *
9 * Ce programme est un logiciel libre distribue sous licence GNU/GPL. *
10 * Pour plus de details voir le fichier COPYING.txt ou l'aide en ligne. *
11 \***************************************************************************/
14 * Installation du plugin révisions
16 * @package SPIP\Revisions\Installation
19 if (!defined('_ECRIRE_INC_VERSION')) {
24 * Installation/maj des tables révisions
26 * @param string $nom_meta_base_version
27 * @param string $version_cible
29 function revisions_upgrade($nom_meta_base_version, $version_cible) {
31 // si plugin pas installe mais que la table existe
32 // considerer que c'est un upgrade depuis v 1.0.0
33 // pour gerer l'historique des installations SPIP <=2.1
34 if (!isset($GLOBALS['meta'][$nom_meta_base_version])) {
35 $trouver_table = charger_fonction('trouver_table', 'base');
36 if ($desc = $trouver_table('spip_versions')
37 and isset($desc['exist']) and $desc['exist']
38 and isset($desc['field']['id_article'])
40 ecrire_meta($nom_meta_base_version, '1.0.0');
42 // si pas de table en base, on fera une simple creation de base
46 $maj['create'] = array(
47 array('maj_tables', array('spip_versions', 'spip_versions_fragments')),
48 array('revisions_upate_meta'),
51 $maj['1.1.0'] = array(
52 // Ajout du champs objet et modification du champs id_article en id_objet
53 // sur les 2 tables spip_versions et spip_versions_fragments
54 array('sql_alter', 'TABLE spip_versions CHANGE id_article id_objet bigint(21) DEFAULT 0 NOT NULL'),
55 array('sql_alter', "TABLE spip_versions ADD objet VARCHAR (25) DEFAULT '' NOT NULL AFTER id_objet"),
56 // Les id_objet restent les id_articles puisque les révisions n'étaient possibles que sur les articles
57 array('sql_updateq', 'spip_versions', array('objet' => 'article'), "objet=''"),
58 // Changement des clefs primaires également
59 array('sql_alter', 'TABLE spip_versions DROP PRIMARY KEY'),
60 array('sql_alter', 'TABLE spip_versions ADD PRIMARY KEY (id_version, id_objet, objet)'),
62 array('sql_alter', 'TABLE spip_versions_fragments CHANGE id_article id_objet bigint(21) DEFAULT 0 NOT NULL'),
63 array('sql_alter', "TABLE spip_versions_fragments ADD objet VARCHAR (25) DEFAULT '' NOT NULL AFTER id_objet"),
64 // Les id_objet restent les id_articles puisque les révisions n'étaient possibles que sur les articles
65 array('sql_updateq', 'spip_versions_fragments', array('objet' => 'article'), "objet=''"),
66 // Changement des clefs primaires également
67 array('sql_alter', 'TABLE spip_versions_fragments DROP PRIMARY KEY'),
68 array('sql_alter', 'TABLE spip_versions_fragments ADD PRIMARY KEY (id_objet, objet, id_fragment, version_min)'),
69 array('revisions_upate_meta')
71 $maj['1.1.2'] = array(
72 array('revisions_upate_meta'),
73 array('sql_updateq', 'spip_versions', array('objet' => 'article'), "objet=''"),
74 array('sql_updateq', 'spip_versions_fragments', array('objet' => 'article'), "objet=''"),
76 $maj['1.1.3'] = array(
77 array('sql_alter', 'TABLE spip_versions DROP KEY id_objet'),
78 array('sql_alter', 'TABLE spip_versions ADD INDEX id_version (id_version)'),
79 array('sql_alter', 'TABLE spip_versions ADD INDEX id_objet (id_objet)'),
80 array('sql_alter', 'TABLE spip_versions ADD INDEX objet (objet)')
82 $maj['1.1.4'] = array(
83 array('sql_alter', "TABLE spip_versions CHANGE permanent permanent char(3) DEFAULT '' NOT NULL"),
84 array('sql_alter', "TABLE spip_versions CHANGE champs champs text DEFAULT '' NOT NULL"),
86 $maj['1.2.0'] = array(
87 array('revisions_uncompress_fragments'),
88 array('revisions_repair_unserialized_fragments'),
91 include_spip('base/upgrade');
92 maj_plugin($nom_meta_base_version, $version_cible, $maj);
95 function revisions_uncompress_fragments() {
96 $count = sql_countsel('spip_versions_fragments', 'compress=' . intval(1));
104 $res = sql_allfetsel(
106 'spip_versions_fragments',
107 'compress=' . intval(1),
113 foreach ($res as $row) {
114 $fragment = @gzuncompress
($row['fragment']);
116 // si la decompression echoue, on met en base le flag 'corrompu-gz'
117 // et au dump le framgment compresse dans un fichier
118 if (strlen($row['fragment']) and $fragment === false) {
119 $dir_tmp = sous_repertoire(_DIR_TMP
, 'versions_fragments_corrompus');
120 $f = $row['id_fragment'] . '-' . $row['objet'] . '-' . $row['id_objet'];
122 ecrire_fichier($dir_tmp . $f, $row['fragment']);
123 $fragment = 'corrompu-gz';
128 'fragment' => $fragment,
132 'spip_versions_fragments',
134 'id_fragment=' . intval($row['id_fragment']) . '
135 AND id_objet=' . intval($row['id_objet']) . '
136 AND objet=' . sql_quote($row['objet']) . '
137 AND version_min=' . intval($row['version_min'])
139 if (time() > _TIME_OUT
) {
143 if (sql_countsel('spip_versions_fragments', 'compress=' . intval(1)) > 0) {
144 revisions_uncompress_fragments();
146 sql_updateq('spip_versions_fragments', array('compress' => -1));
149 function revisions_repair_unserialized_fragments() {
150 $n = sql_countsel('spip_versions_fragments', 'compress=' . intval(-1));
151 spip_log("$n fragments a verifier", 'maj.'._LOG_ERREUR
);
158 $res = sql_allfetsel(
160 'spip_versions_fragments',
161 'compress=' . intval(-1),
167 foreach ($res as $row) {
168 $fragment = $row['fragment'];
173 // verifier que le fragment est bien serializable
174 if (unserialize($fragment) === false and strncmp($fragment, 'corrompu', 8) !== 0) {
175 $dir_tmp = sous_repertoire(_DIR_TMP
, 'versions_fragments_corrompus');
176 $set['fragment'] = revisions_repair_serialise($fragment);
177 if (strncmp($set['fragment'], 'corrompu', 8) == 0) {
178 $f = $row['id_fragment'] . '-' . $row['objet'] . '-' . $row['id_objet'];
179 spip_log("Fragment serialize corrompu $f", 'maj');
180 $f = $f . '-serialize.txt';
181 ecrire_fichier($dir_tmp . $f, $fragment);
185 'spip_versions_fragments',
187 'id_fragment=' . intval($row['id_fragment']) . '
188 AND id_objet=' . intval($row['id_objet']) . '
189 AND objet=' . sql_quote($row['objet']) . '
190 AND version_min=' . intval($row['version_min'])
193 if (time() > _TIME_OUT
) {
197 if (sql_countsel('spip_versions_fragments', 'compress=' . intval(-1)) > 0) {
198 revisions_repair_unserialized_fragments();
202 function revisions_repair_serialise($serialize) {
203 if (unserialize($serialize)) {
207 // verifier les strings
208 preg_match_all(',s:(\d+):\"(.*)\";(?=}|\w:\d+),Uims', $serialize, $matches, PREG_SET_ORDER
);
209 $serialize_repair = $serialize;
210 foreach ($matches as $match) {
213 if (strlen($s) !== $l) {
214 if (strlen($s) < $l) {
215 $s = str_replace("\r\n", "\n", $s);
216 $s = str_replace("\r", "\n", $s);
217 $s = str_replace("\n", "\r\n", $s);
219 if (strlen($s) > $l) {
220 $s = str_replace("\r\n", "\n", $s);
221 $s = str_replace("\r", "\n", $s);
223 if (strlen($s) < $l) {
224 $s .= str_pad('', $l - strlen($s), ' ');
226 if (strlen($s) == $l) {
227 $s = str_replace($match[2], $s, $match[0]);
228 $serialize_repair = str_replace($match[0], $s, $serialize_repair);
232 if (unserialize($serialize_repair)) {
233 return $serialize_repair;
236 // on essaye brutalement
237 $serialize_repair = $serialize;
238 $serialize_repair = str_replace("\r\n", "\n", $serialize_repair);
239 $serialize_repair = str_replace("\r", "\n", $serialize_repair);
240 if (unserialize($serialize_repair)) {
241 return $serialize_repair;
243 $serialize_repair = str_replace("\n", "\r\n", $serialize_repair);
244 if (unserialize($serialize_repair)) {
245 return $serialize_repair;
248 #echo "Impossible de reparer la chaine :";
249 #var_dump($serialize);
251 #die("corrompu-serialize");
252 return 'corrompu-serialize';
257 * Desinstallation/suppression des tables revisions
259 * @param string $nom_meta_base_version
261 function revisions_vider_tables($nom_meta_base_version) {
262 sql_drop_table('spip_versions');
263 sql_drop_table('spip_versions_fragments');
265 effacer_meta($nom_meta_base_version);
269 * Mettre a jour la meta des versions
273 function revisions_upate_meta() {
274 // Si dans une installation antérieure ou un upgrade, les articles étaient versionnés
275 // On crée la meta correspondante
276 // mettre les metas par defaut
277 $config = charger_fonction('config', 'inc');
279 if (isset($GLOBALS['meta']['articles_versions']) and $GLOBALS['meta']['articles_versions'] == 'oui') {
280 ecrire_meta('objets_versions', serialize(array('articles')));
282 effacer_meta('articles_versions');
283 if (!$versions = unserialize($GLOBALS['meta']['objets_versions'])) {
286 $versions = array_map('table_objet_sql', $versions);
287 ecrire_meta('objets_versions', serialize($versions));