From 5c0dd23304187b158d293fc6cbc017ec7fc4ba56 Mon Sep 17 00:00:00 2001
From: Andrea Zagli <a.zagli@comune.scandicci.fi.it>
Date: Mon, 1 Sep 2014 09:54:31 +0200
Subject: [PATCH] SolipaLog: aggiunta la compressione dei file ruotati.

---
 src/log.c | 89 +++++++++++++++++++++++++++++++++++++++++++++++++++++--
 1 file changed, 87 insertions(+), 2 deletions(-)

diff --git a/src/log.c b/src/log.c
index e0da3ef..24edb00 100644
--- a/src/log.c
+++ b/src/log.c
@@ -288,6 +288,9 @@ solipa_log_handler (const gchar *log_domain,
 	gchar *buf;
 
 	GFileInfo *finfo;
+	gssize size;
+
+	GError *error;
 
 	SolipaLog *solipa_log = (SolipaLog *)user_data;
 
@@ -319,7 +322,8 @@ solipa_log_handler (const gchar *log_domain,
 	                           NULL);
 	if (finfo != NULL)
 		{
-			if (g_file_info_get_size (finfo) > priv->rotation_size)
+			size = g_file_info_get_size (finfo);
+			if (size > priv->rotation_size)
 				{
 					GFile *fold;
 
@@ -328,14 +332,95 @@ solipa_log_handler (const gchar *log_domain,
 					g_object_unref (fold);
 
 					g_output_stream_close (G_OUTPUT_STREAM (priv->stream), NULL, NULL);
-					g_file_set_display_name (priv->file, "log.log.0", NULL, NULL);
+
+					fold = g_file_set_display_name (priv->file, "log.log.0", NULL, NULL);
+					g_object_unref (priv->file);
+					priv->file = g_object_ref (fold);
+					g_object_unref (fold);
 
 					if (priv->compress)
 						{
 							GZlibCompressor *compress;
+							GOutputStream *ostreamcomp;
+							GFile *fout;
+							GFileInputStream *istream;
+							GFileOutputStream *ostream;
+
+							error = NULL;
+							istream = g_file_read (priv->file, NULL, &error);
+							if (istream == NULL || error != NULL)
+								{
+									g_warning ("Impossibile leggere dal file %s: %s.",
+									         "log.log.0",
+									         error != NULL && error->message != NULL ? error->message : "nessun dettaglio");
+								}
+
+							buf = g_malloc0 (size);
+
+							error = NULL;
+							if (!g_input_stream_read_all (G_INPUT_STREAM (istream),
+							                              buf,
+							                              size,
+							                              NULL,
+							                              NULL,
+							                              &error))
+								{
+									g_warning ("Impossibile leggere dallo stream: %s.",
+									         error != NULL && error->message != NULL ? error->message : "nessun dettaglio");
+								}
+
+							fout = g_file_new_for_path (g_build_filename (g_file_get_path (g_file_get_parent (priv->file)), "log.log.0.gz", NULL));
+							error = NULL;
+							ostream = g_file_replace (fout,
+							                          NULL,
+							                          FALSE,
+							                          G_FILE_CREATE_PRIVATE,
+							                          NULL,
+							                          &error);
+							if (ostream == NULL || error != NULL)
+								{
+									g_warning ("Impossibile creare il file: %s.",
+									         error != NULL && error->message != NULL ? error->message : "nessun dettaglio");
+								}
 
 							compress = g_zlib_compressor_new (G_ZLIB_COMPRESSOR_FORMAT_GZIP,
 							                                  -1);
+							ostreamcomp = g_converter_output_stream_new (G_OUTPUT_STREAM (ostream),
+							                                             G_CONVERTER (compress));
+
+							error = NULL;
+							if (!g_output_stream_write_all (ostreamcomp,
+							                           buf,
+							                           size,
+							                           NULL,
+							                           NULL,
+							                           &error))
+								{
+									g_warning ("Impossibile creare il file: %s.",
+									         error != NULL && error->message != NULL ? error->message : "nessun dettaglio");
+								}
+
+							if (istream != NULL)
+								{
+									g_input_stream_close (G_INPUT_STREAM (istream), NULL, NULL);
+									g_object_unref (istream);
+								}
+							if (ostreamcomp != NULL)
+								{
+									g_output_stream_close (ostreamcomp, NULL, NULL);
+									g_object_unref (ostreamcomp);
+								}
+							if (ostream != NULL)
+								{
+									g_output_stream_close (G_OUTPUT_STREAM (ostream), NULL, NULL);
+									g_object_unref (ostream);
+								}
+
+							g_free (buf);
+
+							g_object_unref (fout);
+
+							g_file_delete (priv->file, NULL, NULL);
 						}
 
 					g_object_unref (priv->file);
-- 
2.49.0