/***************************************************************************\
* SPIP, Systeme de publication pour l'internet *
* *
- * Copyright (c) 2001-2014 *
+ * Copyright (c) 2001-2019 *
* Arnaud Martin, Antoine Pitrou, Philippe Riviere, Emmanuel Saint-James *
* *
* Ce programme est un logiciel libre distribue sous licence GNU/GPL. *
/**
* Installation du plugin révisions
*
- * @package Revisions\Installation
-**/
+ * @package SPIP\Revisions\Installation
+ **/
-if (!defined('_ECRIRE_INC_VERSION')) return;
+if (!defined('_ECRIRE_INC_VERSION')) {
+ return;
+}
/**
* Installation/maj des tables révisions
* @param string $nom_meta_base_version
* @param string $version_cible
*/
-function revisions_upgrade($nom_meta_base_version,$version_cible){
+function revisions_upgrade($nom_meta_base_version, $version_cible) {
// cas particulier :
// si plugin pas installe mais que la table existe
// considerer que c'est un upgrade depuis v 1.0.0
// pour gerer l'historique des installations SPIP <=2.1
- if (!isset($GLOBALS['meta'][$nom_meta_base_version])){
- $trouver_table = charger_fonction('trouver_table','base');
+ if (!isset($GLOBALS['meta'][$nom_meta_base_version])) {
+ $trouver_table = charger_fonction('trouver_table', 'base');
if ($desc = $trouver_table('spip_versions')
- AND isset($desc['exist'])){
- ecrire_meta($nom_meta_base_version,'1.0.0');
+ and isset($desc['exist']) and $desc['exist']
+ and isset($desc['field']['id_article'])
+ ) {
+ ecrire_meta($nom_meta_base_version, '1.0.0');
}
// si pas de table en base, on fera une simple creation de base
}
$maj = array();
$maj['create'] = array(
- array('maj_tables',array('spip_versions','spip_versions_fragments')),
+ array('maj_tables', array('spip_versions', 'spip_versions_fragments')),
array('revisions_upate_meta'),
);
$maj['1.1.0'] = array(
// Ajout du champs objet et modification du champs id_article en id_objet
// sur les 2 tables spip_versions et spip_versions_fragments
- array('sql_alter',"TABLE spip_versions CHANGE id_article id_objet bigint(21) DEFAULT 0 NOT NULL"),
- array('sql_alter',"TABLE spip_versions ADD objet VARCHAR (25) DEFAULT '' NOT NULL AFTER id_objet"),
+ array('sql_alter', 'TABLE spip_versions CHANGE id_article id_objet bigint(21) DEFAULT 0 NOT NULL'),
+ array('sql_alter', "TABLE spip_versions ADD objet VARCHAR (25) DEFAULT '' NOT NULL AFTER id_objet"),
// Les id_objet restent les id_articles puisque les révisions n'étaient possibles que sur les articles
- array('sql_updateq',"spip_versions",array('objet'=>'article'),"objet=''"),
+ array('sql_updateq', 'spip_versions', array('objet' => 'article'), "objet=''"),
// Changement des clefs primaires également
- array('sql_alter',"TABLE spip_versions DROP PRIMARY KEY"),
- array('sql_alter',"TABLE spip_versions ADD PRIMARY KEY (id_version, id_objet, objet)"),
+ array('sql_alter', 'TABLE spip_versions DROP PRIMARY KEY'),
+ array('sql_alter', 'TABLE spip_versions ADD PRIMARY KEY (id_version, id_objet, objet)'),
- array('sql_alter',"TABLE spip_versions_fragments CHANGE id_article id_objet bigint(21) DEFAULT 0 NOT NULL"),
- array('sql_alter',"TABLE spip_versions_fragments ADD objet VARCHAR (25) DEFAULT '' NOT NULL AFTER id_objet"),
+ array('sql_alter', 'TABLE spip_versions_fragments CHANGE id_article id_objet bigint(21) DEFAULT 0 NOT NULL'),
+ array('sql_alter', "TABLE spip_versions_fragments ADD objet VARCHAR (25) DEFAULT '' NOT NULL AFTER id_objet"),
// Les id_objet restent les id_articles puisque les révisions n'étaient possibles que sur les articles
- array('sql_updateq',"spip_versions_fragments",array('objet'=>'article'),"objet=''"),
+ array('sql_updateq', 'spip_versions_fragments', array('objet' => 'article'), "objet=''"),
// Changement des clefs primaires également
- array('sql_alter',"TABLE spip_versions_fragments DROP PRIMARY KEY"),
- array('sql_alter',"TABLE spip_versions_fragments ADD PRIMARY KEY (id_objet, objet, id_fragment, version_min)"),
- array('revisions_upate_meta'),
+ array('sql_alter', 'TABLE spip_versions_fragments DROP PRIMARY KEY'),
+ array('sql_alter', 'TABLE spip_versions_fragments ADD PRIMARY KEY (id_objet, objet, id_fragment, version_min)'),
+ array('revisions_upate_meta')
);
$maj['1.1.2'] = array(
array('revisions_upate_meta'),
- array('sql_updateq',"spip_versions",array('objet'=>'article'),"objet=''"),
- array('sql_updateq',"spip_versions_fragments",array('objet'=>'article'),"objet=''"),
+ array('sql_updateq', 'spip_versions', array('objet' => 'article'), "objet=''"),
+ array('sql_updateq', 'spip_versions_fragments', array('objet' => 'article'), "objet=''"),
);
$maj['1.1.3'] = array(
- array('sql_alter',"TABLE spip_versions DROP KEY id_objet"),
- array('sql_alter',"TABLE spip_versions ADD INDEX id_version (id_version)"),
- array('sql_alter',"TABLE spip_versions ADD INDEX id_objet (id_objet)"),
- array('sql_alter',"TABLE spip_versions ADD INDEX objet (objet)")
+ array('sql_alter', 'TABLE spip_versions DROP KEY id_objet'),
+ array('sql_alter', 'TABLE spip_versions ADD INDEX id_version (id_version)'),
+ array('sql_alter', 'TABLE spip_versions ADD INDEX id_objet (id_objet)'),
+ array('sql_alter', 'TABLE spip_versions ADD INDEX objet (objet)')
);
$maj['1.1.4'] = array(
- array('sql_alter',"TABLE spip_versions CHANGE permanent permanent char(3) DEFAULT '' NOT NULL"),
- array('sql_alter',"TABLE spip_versions CHANGE champs champs text DEFAULT '' NOT NULL"),
+ array('sql_alter', "TABLE spip_versions CHANGE permanent permanent char(3) DEFAULT '' NOT NULL"),
+ array('sql_alter', "TABLE spip_versions CHANGE champs champs text DEFAULT '' NOT NULL"),
+ );
+ $maj['1.2.0'] = array(
+ array('revisions_uncompress_fragments'),
+ array('revisions_repair_unserialized_fragments'),
);
-
include_spip('base/upgrade');
maj_plugin($nom_meta_base_version, $version_cible, $maj);
+}
+
+function revisions_uncompress_fragments() {
+ $count = sql_countsel('spip_versions_fragments', 'compress=' . intval(1));
+ if ($count > 20000) {
+ $limit = '0,20000';
+ } else {
+ $limit = "0,$count";
+ }
+
+ $res = sql_allfetsel(
+ '*',
+ 'spip_versions_fragments',
+ 'compress=' . intval(1),
+ '',
+ '',
+ $limit
+ );
+
+ foreach ($res as $row) {
+ $fragment = @gzuncompress($row['fragment']);
+
+ // si la decompression echoue, on met en base le flag 'corrompu-gz'
+ // et au dump le framgment compresse dans un fichier
+ if (strlen($row['fragment']) and $fragment === false) {
+ $dir_tmp = sous_repertoire(_DIR_TMP, 'versions_fragments_corrompus');
+ $f = $row['id_fragment'] . '-' . $row['objet'] . '-' . $row['id_objet'];
+ $f = $f . '-gz.txt';
+ ecrire_fichier($dir_tmp . $f, $row['fragment']);
+ $fragment = 'corrompu-gz';
+ }
+
+ $set = array(
+ 'compress' => 0,
+ 'fragment' => $fragment,
+ );
+
+ sql_updateq(
+ 'spip_versions_fragments',
+ $set,
+ 'id_fragment=' . intval($row['id_fragment']) . '
+ AND id_objet=' . intval($row['id_objet']) . '
+ AND objet=' . sql_quote($row['objet']) . '
+ AND version_min=' . intval($row['version_min'])
+ );
+ if (time() > _TIME_OUT) {
+ return;
+ }
+ }
+ if (sql_countsel('spip_versions_fragments', 'compress=' . intval(1)) > 0) {
+ revisions_uncompress_fragments();
+ }
+ sql_updateq('spip_versions_fragments', array('compress' => -1));
}
+function revisions_repair_unserialized_fragments() {
+ $n = sql_countsel('spip_versions_fragments', 'compress=' . intval(-1));
+ spip_log("$n fragments a verifier", 'maj.'._LOG_ERREUR);
+ if ($n > 20000) {
+ $limit = '0,20000';
+ } else {
+ $limit = "0,$n";
+ }
+
+ $res = sql_allfetsel(
+ '*',
+ 'spip_versions_fragments',
+ 'compress=' . intval(-1),
+ '',
+ '',
+ $limit
+ );
+
+ foreach ($res as $row) {
+ $fragment = $row['fragment'];
+ $set = array(
+ 'compress' => 0,
+ );
+
+ // verifier que le fragment est bien serializable
+ if (unserialize($fragment) === false and strncmp($fragment, 'corrompu', 8) !== 0) {
+ $dir_tmp = sous_repertoire(_DIR_TMP, 'versions_fragments_corrompus');
+ $set['fragment'] = revisions_repair_serialise($fragment);
+ if (strncmp($set['fragment'], 'corrompu', 8) == 0) {
+ $f = $row['id_fragment'] . '-' . $row['objet'] . '-' . $row['id_objet'];
+ spip_log("Fragment serialize corrompu $f", 'maj');
+ $f = $f . '-serialize.txt';
+ ecrire_fichier($dir_tmp . $f, $fragment);
+ }
+ }
+ sql_updateq(
+ 'spip_versions_fragments',
+ $set,
+ 'id_fragment=' . intval($row['id_fragment']) . '
+ AND id_objet=' . intval($row['id_objet']) . '
+ AND objet=' . sql_quote($row['objet']) . '
+ AND version_min=' . intval($row['version_min'])
+ );
+
+ if (time() > _TIME_OUT) {
+ return;
+ }
+ }
+ if (sql_countsel('spip_versions_fragments', 'compress=' . intval(-1)) > 0) {
+ revisions_repair_unserialized_fragments();
+ }
+}
+
+function revisions_repair_serialise($serialize) {
+ if (unserialize($serialize)) {
+ return $serialize;
+ }
+
+ // verifier les strings
+ preg_match_all(',s:(\d+):\"(.*)\";(?=}|\w:\d+),Uims', $serialize, $matches, PREG_SET_ORDER);
+ $serialize_repair = $serialize;
+ foreach ($matches as $match) {
+ $s = $match[2];
+ $l = $match[1];
+ if (strlen($s) !== $l) {
+ if (strlen($s) < $l) {
+ $s = str_replace("\r\n", "\n", $s);
+ $s = str_replace("\r", "\n", $s);
+ $s = str_replace("\n", "\r\n", $s);
+ }
+ if (strlen($s) > $l) {
+ $s = str_replace("\r\n", "\n", $s);
+ $s = str_replace("\r", "\n", $s);
+ }
+ if (strlen($s) < $l) {
+ $s .= str_pad('', $l - strlen($s), ' ');
+ }
+ if (strlen($s) == $l) {
+ $s = str_replace($match[2], $s, $match[0]);
+ $serialize_repair = str_replace($match[0], $s, $serialize_repair);
+ }
+ }
+ }
+ if (unserialize($serialize_repair)) {
+ return $serialize_repair;
+ }
+
+ // on essaye brutalement
+ $serialize_repair = $serialize;
+ $serialize_repair = str_replace("\r\n", "\n", $serialize_repair);
+ $serialize_repair = str_replace("\r", "\n", $serialize_repair);
+ if (unserialize($serialize_repair)) {
+ return $serialize_repair;
+ }
+ $serialize_repair = str_replace("\n", "\r\n", $serialize_repair);
+ if (unserialize($serialize_repair)) {
+ return $serialize_repair;
+ }
+
+ #echo "Impossible de reparer la chaine :";
+ #var_dump($serialize);
+ #var_dump($matches);
+ #die("corrompu-serialize");
+ return 'corrompu-serialize';
+}
+
+
/**
* Desinstallation/suppression des tables revisions
*
* @param string $nom_meta_base_version
*/
function revisions_vider_tables($nom_meta_base_version) {
- sql_drop_table("spip_versions");
- sql_drop_table("spip_versions_fragments");
+ sql_drop_table('spip_versions');
+ sql_drop_table('spip_versions_fragments');
effacer_meta($nom_meta_base_version);
}
/**
* Mettre a jour la meta des versions
+ *
* @return void
*/
-function revisions_upate_meta(){
+function revisions_upate_meta() {
// Si dans une installation antérieure ou un upgrade, les articles étaient versionnés
// On crée la meta correspondante
// mettre les metas par defaut
- $config = charger_fonction('config','inc');
+ $config = charger_fonction('config', 'inc');
$config();
- if($GLOBALS['meta']['articles_versions'] == 'oui'){
- ecrire_meta('objets_versions',serialize(array('articles')));
+ if (isset($GLOBALS['meta']['articles_versions']) and $GLOBALS['meta']['articles_versions'] == 'oui') {
+ ecrire_meta('objets_versions', serialize(array('articles')));
}
effacer_meta('articles_versions');
- if (!$versions = unserialize($GLOBALS['meta']['objets_versions']))
+ if (!$versions = unserialize($GLOBALS['meta']['objets_versions'])) {
$versions = array();
- $versions = array_map('table_objet_sql',$versions);
- ecrire_meta('objets_versions',serialize($versions));
+ }
+ $versions = array_map('table_objet_sql', $versions);
+ ecrire_meta('objets_versions', serialize($versions));
}
-
-
-?>
dépôts / lhc / web / www.git / blobdiff