www/plugins-dist/revisions/revisions_administrations.php

   1 <?php
   2
   3 /***************************************************************************\
   4  *  SPIP, Systeme de publication pour l'internet                           *
   5  *                                                                         *
   6  *  Copyright (c) 2001-2016                                                *
   7  *  Arnaud Martin, Antoine Pitrou, Philippe Riviere, Emmanuel Saint-James  *
   8  *                                                                         *
   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 \***************************************************************************/
  12
  13 /**
  14  * Installation du plugin révisions
  15  *
  16  * @package SPIP\Revisions\Installation
  17  **/
  18
  19 if (!defined('_ECRIRE_INC_VERSION')) {
  20         return;
  21 }
  22
  23 /**
  24  * Installation/maj des tables révisions
  25  *
  26  * @param string $nom_meta_base_version
  27  * @param string $version_cible
  28  */
  29 function revisions_upgrade($nom_meta_base_version, $version_cible) {
  30         // cas particulier :
  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'])
  39                 ) {
  40                         ecrire_meta($nom_meta_base_version, '1.0.0');
  41                 }
  42                 // si pas de table en base, on fera une simple creation de base
  43         }
  44
  45         $maj = array();
  46         $maj['create'] = array(
  47                 array('maj_tables', array('spip_versions', 'spip_versions_fragments')),
  48                 array('revisions_upate_meta'),
  49         );
  50
  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)'),
  61
  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')
  70         );
  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=''"),
  75         );
  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)')
  81         );
  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"),
  85         );
  86         $maj['1.2.0'] = array(
  87                 array('revisions_uncompress_fragments'),
  88                 array('revisions_repair_unserialized_fragments'),
  89         );
  90
  91         include_spip('base/upgrade');
  92         maj_plugin($nom_meta_base_version, $version_cible, $maj);
  93 }
  94
  95 function revisions_uncompress_fragments() {
  96         $count = sql_countsel('spip_versions_fragments', 'compress=' . intval(1));
  97
  98         if ($count > 20000) {
  99                 $limit = '0,20000';
 100         } else {
 101                 $limit = "0,$count";
 102         }
 103
 104         $res = sql_allfetsel(
 105                 '*',
 106                 'spip_versions_fragments',
 107                 'compress=' . intval(1),
 108                 '',
 109                 '',
 110                 $limit
 111         );
 112
 113         foreach ($res as $row) {
 114                 $fragment = @gzuncompress($row['fragment']);
 115
 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'];
 121                         $f = $f . '-gz.txt';
 122                         ecrire_fichier($dir_tmp . $f, $row['fragment']);
 123                         $fragment = 'corrompu-gz';
 124                 }
 125
 126                 $set = array(
 127                         'compress' => 0,
 128                         'fragment' => $fragment,
 129                 );
 130
 131                 sql_updateq(
 132                         'spip_versions_fragments',
 133                         $set,
 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'])
 138                 );
 139                 if (time() > _TIME_OUT) {
 140                         return;
 141                 }
 142         }
 143         if (sql_countsel('spip_versions_fragments', 'compress=' . intval(1)) > 0) {
 144                 revisions_uncompress_fragments();
 145         }
 146         sql_updateq('spip_versions_fragments', array('compress' => -1));
 147 }
 148
 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);
 152         if ($n > 20000) {
 153                 $limit = '0,20000';
 154         } else {
 155                 $limit = "0,$n";
 156         }
 157
 158         $res = sql_allfetsel(
 159                 '*',
 160                 'spip_versions_fragments',
 161                 'compress=' . intval(-1),
 162                 '',
 163                 '',
 164                 $limit
 165         );
 166
 167         foreach ($res as $row) {
 168                 $fragment = $row['fragment'];
 169                 $set = array(
 170                         'compress' => 0,
 171                 );
 172
 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);
 182                         }
 183                 }
 184                 sql_updateq(
 185                         'spip_versions_fragments',
 186                         $set,
 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'])
 191                 );
 192
 193                 if (time() > _TIME_OUT) {
 194                         return;
 195                 }
 196         }
 197         if (sql_countsel('spip_versions_fragments', 'compress=' . intval(-1)) > 0) {
 198                 revisions_repair_unserialized_fragments();
 199         }
 200 }
 201
 202 function revisions_repair_serialise($serialize) {
 203         if (unserialize($serialize)) {
 204                 return $serialize;
 205         }
 206
 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) {
 211                 $s = $match[2];
 212                 $l = $match[1];
 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);
 218                         }
 219                         if (strlen($s) > $l) {
 220                                 $s = str_replace("\r\n", "\n", $s);
 221                                 $s = str_replace("\r", "\n", $s);
 222                         }
 223                         if (strlen($s) < $l) {
 224                                 $s .= str_pad('', $l - strlen($s), ' ');
 225                         }
 226                         if (strlen($s) == $l) {
 227                                 $s = str_replace($match[2], $s, $match[0]);
 228                                 $serialize_repair = str_replace($match[0], $s, $serialize_repair);
 229                         }
 230                 }
 231         }
 232         if (unserialize($serialize_repair)) {
 233                 return $serialize_repair;
 234         }
 235
 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;
 242         }
 243         $serialize_repair = str_replace("\n", "\r\n", $serialize_repair);
 244         if (unserialize($serialize_repair)) {
 245                 return $serialize_repair;
 246         }
 247
 248         #echo "Impossible de reparer la chaine :";
 249         #var_dump($serialize);
 250         #var_dump($matches);
 251         #die("corrompu-serialize");
 252         return 'corrompu-serialize';
 253 }
 254
 255
 256 /**
 257  * Desinstallation/suppression des tables revisions
 258  *
 259  * @param string $nom_meta_base_version
 260  */
 261 function revisions_vider_tables($nom_meta_base_version) {
 262         sql_drop_table('spip_versions');
 263         sql_drop_table('spip_versions_fragments');
 264
 265         effacer_meta($nom_meta_base_version);
 266 }
 267
 268 /**
 269  * Mettre a jour la meta des versions
 270  *
 271  * @return void
 272  */
 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');
 278         $config();
 279         if (isset($GLOBALS['meta']['articles_versions']) and $GLOBALS['meta']['articles_versions'] == 'oui') {
 280                 ecrire_meta('objets_versions', serialize(array('articles')));
 281         }
 282         effacer_meta('articles_versions');
 283         if (!$versions = unserialize($GLOBALS['meta']['objets_versions'])) {
 284                 $versions = array();
 285         }
 286         $versions = array_map('table_objet_sql', $versions);
 287         ecrire_meta('objets_versions', serialize($versions));
 288 }