Kept tracks of current active DB items.

8 files changed, 206 insertions, 25 deletions

diff --git a/src/analysis/db/cdb.c b/src/analysis/db/cdb.c
index 597242f..a787a19 100644
--- a/src/analysis/db/cdb.c
+++ b/src/analysis/db/cdb.c
@@ -146,7 +146,7 @@ static bool g_cdb_archive_create_db(const GCdbArchive *);
 static bool g_cdb_archive_load_collections(GCdbArchive *);
 
 /* Réagit à une modification au sein d'une collection donnée. */
-static void on_collection_changed(GDbCollection *, DBAction, GDbItem *, GCdbArchive *);
+static void on_collection_extended(GDbCollection *, GDbItem *, GCdbArchive *);
 
 /* Assure le traitement des requêtes de clients. */
 static void *g_cdb_archive_process(GCdbArchive *);
@@ -742,7 +742,7 @@ static bool g_cdb_archive_load_collections(GCdbArchive *archive)
          iter = g_list_next(iter))
     {
         collec = G_DB_COLLECTION(iter->data);
-        g_signal_connect(collec, "content-changed", G_CALLBACK(on_collection_changed), archive);
+        g_signal_connect(collec, "content-extended", G_CALLBACK(on_collection_extended), archive);
 
         if (!g_db_collection_load_all_items(collec, archive->db))
             return false;
@@ -757,7 +757,6 @@ static bool g_cdb_archive_load_collections(GCdbArchive *archive)
 /******************************************************************************
 *                                                                             *
 *  Paramètres  : collec  = collection dont le contenu a évolué.               *
-*                action  = type d'évolution rencontrée.                       *
 *                item    = élément ajouté, modifié ou supprimé.               *
 *                archive = centralisation de tous les savoirs.                *
 *                                                                             *
@@ -769,7 +768,7 @@ static bool g_cdb_archive_load_collections(GCdbArchive *archive)
 *                                                                             *
 ******************************************************************************/
 
-static void on_collection_changed(GDbCollection *collec, DBAction action, GDbItem *item, GCdbArchive *archive)
+static void on_collection_extended(GDbCollection *collec, GDbItem *item, GCdbArchive *archive)
 {
     packed_buffer pbuf;                     /* Tampon d'émission           */
     size_t i;                               /* Boucle de parcours          */
@@ -777,7 +776,7 @@ static void on_collection_changed(GDbCollection *collec, DBAction action, GDbIte
 
     init_packed_buffer(&pbuf);
 
-    status = g_db_collection_pack(collec, &pbuf, action, item);
+    status = g_db_collection_pack(collec, &pbuf, DBA_ADD_ITEM, item);
 
     g_mutex_lock(&archive->clients_access);
 
diff --git a/src/analysis/db/client.c b/src/analysis/db/client.c
index 3197a8c..744fa57 100644
--- a/src/analysis/db/client.c
+++ b/src/analysis/db/client.c
@@ -789,7 +789,7 @@ static void *g_hub_client_update(GHubClient *client)
                     status = extract_packed_buffer(&in_pbuf, &tmp8, sizeof(uint8_t), true);
                     if (!status) goto gdcu_bad_exchange;
 
-                    client->can_get_updates = (tmp8 == 0x1);
+                    client->can_get_updates = (tmp8 == 0x0);
                     break;
 
             }
diff --git a/src/analysis/db/collection-int.h b/src/analysis/db/collection-int.h
index c2d1282..b3b83bb 100644
--- a/src/analysis/db/collection-int.h
+++ b/src/analysis/db/collection-int.h
@@ -60,6 +60,7 @@ struct _GDbCollection
 
     GList *items;                           /* Eléments rassemblés         */
     GList *sorted;                          /* Eléments triés              */
+    GHashTable *last_items;                 /* Statuts courants d'éléments */
     GRWLock params_access;                  /* Verrou de protection        */
 
 };
@@ -76,7 +77,7 @@ struct _GDbCollectionClass
 
     /* Signaux */
 
-    void (* content_changed) (GDbCollection *, DBAction, GDbItem *);
+    void (* content_extended) (GDbCollection *, GDbItem *);
 
 };
 
diff --git a/src/analysis/db/collection.c b/src/analysis/db/collection.c
index 33145a6..f728718 100644
--- a/src/analysis/db/collection.c
+++ b/src/analysis/db/collection.c
@@ -106,13 +106,13 @@ static void g_db_collection_class_init(GDbCollectionClass *klass)
 
     klass->setup_load = (collec_setup_load_fc)_g_db_collection_setup_load;
 
-    g_signal_new("content-changed",
+    g_signal_new("content-extended",
                  G_TYPE_DB_COLLECTION,
                  G_SIGNAL_RUN_LAST,
-                 G_STRUCT_OFFSET(GDbCollectionClass, content_changed),
+                 G_STRUCT_OFFSET(GDbCollectionClass, content_extended),
                  NULL, NULL,
-                 g_cclosure_user_marshal_VOID__ENUM_OBJECT,
-                 G_TYPE_NONE, 2, G_TYPE_UINT, G_TYPE_OBJECT);
+                 g_cclosure_marshal_VOID__OBJECT,
+                 G_TYPE_NONE, 1, G_TYPE_OBJECT);
 
 }
 
@@ -133,6 +133,11 @@ static void g_db_collection_init(GDbCollection *collec)
 {
     collec->binary = NULL;
 
+    collec->last_items = g_hash_table_new_full((GHashFunc)g_db_item_hash_key,
+                                               (GEqualFunc)g_db_item_cmp_key,
+                                               (GDestroyNotify)g_object_unref,
+                                               (GDestroyNotify)g_object_unref);
+
     g_rw_lock_init(&collec->params_access);
 
 }
@@ -654,6 +659,7 @@ bool g_db_collection_has_item(GDbCollection *collec, GDbItem *item)
 bool _g_db_collection_add_item(GDbCollection *collec, GDbItem *item, bool lock)
 {
     bool result;                            /* Bilan à faire remonter      */
+    GDbItem *prev;                          /* Elément similaire précédent */
 
     result = true;
 
@@ -666,7 +672,40 @@ bool _g_db_collection_add_item(GDbCollection *collec, GDbItem *item, bool lock)
     g_object_ref(G_OBJECT(item));
     collec->sorted = g_list_insert_sorted(collec->sorted, item, (GCompareFunc)g_db_item_compare_with_timestamp);
 
-    g_signal_emit_by_name(collec, "content-changed", DBA_ADD_ITEM, item);
+    prev = g_hash_table_lookup(collec->last_items, item);
+
+    if (prev != NULL)
+    {
+        g_object_ref(G_OBJECT(prev));
+
+        if (g_db_item_get_flags(item) & DIF_ERASER)
+            g_hash_table_remove(collec->last_items, prev);
+
+        else
+        {
+            g_db_item_add_flag(item, DIF_UPDATED);
+
+            g_object_ref(G_OBJECT(item));
+            g_object_ref(G_OBJECT(item));
+
+            g_hash_table_replace(collec->last_items, item, item);
+
+        }
+
+        g_object_unref(G_OBJECT(prev));
+
+    }
+
+    else
+    {
+        g_object_ref(G_OBJECT(item));
+        g_object_ref(G_OBJECT(item));
+
+        g_hash_table_add(collec->last_items, item);
+
+    }
+
+    g_signal_emit_by_name(collec, "content-extended", item);
 
     if (lock)
         g_db_collection_wunlock(collec);
@@ -718,7 +757,7 @@ bool _g_db_collection_remove_item(GDbCollection *collec, GDbItem *item, bool loc
         collec->items = g_list_delete_link(collec->items, found);
 
         if (signal)
-            g_signal_emit_by_name(collec, "content-changed", DBA_REM_ITEM, internal);
+            ;//g_signal_emit_by_name(collec, "content-changed", DBA_REM_ITEM, internal);
 
         g_object_unref(G_OBJECT(internal));
         g_object_unref(G_OBJECT(internal));
@@ -816,7 +855,7 @@ bool _g_db_collection_update_item_activity(GDbCollection *collec, GDbItem *item,
 
         result = g_db_item_set_activity(internal, collec->binary, timestamp);
 
-        g_signal_emit_by_name(collec, "content-changed", DBA_CHANGE_STATE, internal);
+        //g_signal_emit_by_name(collec, "content-changed", DBA_CHANGE_STATE, internal);
 
     }
 
@@ -863,7 +902,7 @@ GList *g_db_collection_set_last_active(GDbCollection *collec, timestamp_t timest
             {
                 /* ... */g_db_item_set_activity(item, collec->binary, NULL);
                 /* ... */g_db_collection_store_updated_item(collec, item, db);
-                g_signal_emit_by_name(collec, "content-changed", DBA_CHANGE_STATE, item);
+                //g_signal_emit_by_name(collec, "content-changed", DBA_CHANGE_STATE, item);
             }
 
         }
@@ -911,7 +950,7 @@ bool g_db_collection_set_inactive(GDbCollection *collec, GDbItem *item, timestam
 
     result = g_db_item_set_activity(item, collec->binary, timestamp);
 
-    g_signal_emit_by_name(collec, "content-changed", DBA_CHANGE_STATE, item);
+    //g_signal_emit_by_name(collec, "content-changed", DBA_CHANGE_STATE, item);
 
     return result;
 
diff --git a/src/analysis/db/item-int.h b/src/analysis/db/item-int.h
index a6398f9..8bba8a3 100644
--- a/src/analysis/db/item-int.h
+++ b/src/analysis/db/item-int.h
@@ -36,6 +36,12 @@
 
 
 
+/* Calcule le condensat associé à l'élément vu comme clef. */
+typedef guint (* hash_db_item_key_fc) (const GDbItem *);
+
+/* Compare deux éléments en tant que clefs. */
+typedef gboolean (* cmp_db_item_key_fc) (const GDbItem *, const GDbItem *);
+
 /* Effectue la comparaison entre deux éléments de collection. */
 typedef gint (* cmp_db_item_fc) (GDbItem *, GDbItem *, bool);
 
@@ -84,6 +90,9 @@ struct _GDbItemClass
 
     DBFeatures feature;                     /* Fonctionnalité représentée  */
 
+    hash_db_item_key_fc hash_key;           /* Condensat de l'élément      */
+    cmp_db_item_key_fc cmp_key;             /* Comparaison en tant que clef*/
+
     cmp_db_item_fc cmp;                     /* Comparaison entre éléments  */
 
     unpack_db_item_fc unpack;               /* Réception depuis le réseau  */
diff --git a/src/analysis/db/item.c b/src/analysis/db/item.c
index 2eb31b1..efa2cdf 100644
--- a/src/analysis/db/item.c
+++ b/src/analysis/db/item.c
@@ -205,6 +205,59 @@ void g_db_item_set_server_side(GDbItem *item)
 
 /******************************************************************************
 *                                                                             *
+*  Paramètres  : item = élément de collection à consulter.                    *
+*                                                                             *
+*  Description : Calcule le condensat associé à l'élément vu comme clef.      *
+*                                                                             *
+*  Retour      : Condensat associé à l'élément.                               *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+guint g_db_item_hash_key(const GDbItem *item)
+{
+    guint result;                           /* Valeur "unique" à renvoyer  */
+    GDbItemClass *class;                    /* Classe liée à l'instance    */
+
+    class = G_DB_ITEM_GET_CLASS(item);
+
+    result = class->hash_key(item);
+
+    return result;
+
+}
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : a = premier élément de collection à consulter.               *
+*                b = second élément de collection à consulter.                *
+*                                                                             *
+*  Description : Compare deux éléments en tant que clefs.                     *
+*                                                                             *
+*  Retour      : Bilan de la comparaison.                                     *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+gboolean g_db_item_cmp_key(const GDbItem *a, const GDbItem *b)
+{
+    gboolean result;                        /* Bilan à retourner           */
+    GDbItemClass *class;                    /* Classe liée à l'instance    */
+
+    class = G_DB_ITEM_GET_CLASS(a);
+
+    result = class->cmp_key(a, b);
+
+    return result;
+
+}
+
+
+/******************************************************************************
+*                                                                             *
 *  Paramètres  : a    = premier élément à analyser.                           *
 *                b    = second élément à analyser.                            *
 *                with = précise les horodatages à prendre en compte.          *
diff --git a/src/analysis/db/item.h b/src/analysis/db/item.h
index dfc97fd..395a56f 100644
--- a/src/analysis/db/item.h
+++ b/src/analysis/db/item.h
@@ -45,8 +45,9 @@ typedef enum _DbItemFlags
 {
     DIF_NONE     = (0 << 0),                /* Propriétés par défaut       */
     DIF_ERASER   = (1 << 0),                /* Suppression de l'effet      */
-    DIF_VOLATILE = (1 << 1),                /* Abscence de sauvegarde      */
-    DIF_BROKEN   = (1 << 2),                /* Application impossible      */
+    DIF_UPDATED  = (1 << 1),                /* Mise à jour de l'élément    */
+    DIF_VOLATILE = (1 << 2),                /* Abscence de sauvegarde      */
+    DIF_BROKEN   = (1 << 3),                /* Application impossible      */
 
 } DbItemFlags;
 
@@ -75,6 +76,12 @@ DBFeatures g_db_item_get_feature(const GDbItem *);
 /* Indique à l'élément qu'il se trouve du côté serveur. */
 void g_db_item_set_server_side(GDbItem *);
 
+/* Calcule le condensat associé à l'élément vu comme clef. */
+guint g_db_item_hash_key(const GDbItem *);
+
+/* Compare deux éléments en tant que clefs. */
+gboolean g_db_item_cmp_key(const GDbItem *, const GDbItem *);
+
 /* Effectue la comparaison entre deux éléments de collection. */
 gint g_db_item_cmp(GDbItem *, GDbItem *, bool);
 
diff --git a/src/analysis/db/items/bookmark.c b/src/analysis/db/items/bookmark.c
index 20f98ea..3d66f6b 100644
--- a/src/analysis/db/items/bookmark.c
+++ b/src/analysis/db/items/bookmark.c
@@ -73,6 +73,12 @@ static void g_db_bookmark_dispose(GDbBookmark *);
 /* Procède à la libération totale de la mémoire. */
 static void g_db_bookmark_finalize(GDbBookmark *);
 
+/* Calcule le condensat associé à l'élément vu comme clef. */
+static guint g_db_bookmark_hash_key(const GDbBookmark *);
+
+/* Compare deux éléments en tant que clefs. */
+static gboolean g_db_bookmark_cmp_key(const GDbBookmark *, const GDbBookmark *);
+
 /* Effectue la comparaison entre deux signets de collection. */
 static gint g_db_bookmark_cmp(GDbBookmark *, GDbBookmark *, bool);
 
@@ -178,6 +184,9 @@ static void g_db_bookmark_class_init(GDbBookmarkClass *klass)
 
     item->feature = DBF_BOOKMARKS;
 
+    item->hash_key = (hash_db_item_key_fc)g_db_bookmark_hash_key;
+    item->cmp_key = (cmp_db_item_key_fc)g_db_bookmark_cmp_key;
+
     item->cmp = (cmp_db_item_fc)g_db_bookmark_cmp;
 
     item->unpack = (unpack_db_item_fc)g_db_bookmark_unpack;
@@ -319,6 +328,56 @@ bool g_db_bookmark_fill(GDbBookmark *bookmark, const vmpa2t *addr, const char *c
 
 /******************************************************************************
 *                                                                             *
+*  Paramètres  : bookmark = élément de collection à consulter.                *
+*                                                                             *
+*  Description : Calcule le condensat associé à l'élément vu comme clef.      *
+*                                                                             *
+*  Retour      : Condensat associé à l'élément.                               *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+static guint g_db_bookmark_hash_key(const GDbBookmark *bookmark)
+{
+    guint result;                           /* Valeur "unique" à renvoyer  */
+
+    result = hash_vmpa(&bookmark->addr);
+
+    return result;
+
+}
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : a = premier élément de collection à consulter.               *
+*                b = second élément de collection à consulter.                *
+*                                                                             *
+*  Description : Compare deux éléments en tant que clefs.                     *
+*                                                                             *
+*  Retour      : Bilan de la comparaison.                                     *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+static gboolean g_db_bookmark_cmp_key(const GDbBookmark *a, const GDbBookmark *b)
+{
+    gboolean result;                        /* Bilan à retourner           */
+    int ret;                                /* Bilan intermédiaire         */
+
+    ret = cmp_vmpa(&a->addr, &b->addr);
+
+    result = (ret == 0);
+
+    return result;
+
+}
+
+
+/******************************************************************************
+*                                                                             *
 *  Paramètres  : a    = premier élément à analyser.                           *
 *                b    = second élément à analyser.                            *
 *                with = précise les horodatages à prendre en compte.          *
@@ -424,22 +483,36 @@ static char *g_db_bookmark_build_label(GDbBookmark *bookmark)
 {
     char *result;                           /* Description à retourner     */
     DbItemFlags flags;                      /* Propriétés de l'élément     */
-    const char *prefix;                     /* Préfixe à ajouter           */
     const char *text;                       /* Commentaire associé         */
+    const char *prefix;                     /* Préfixe à ajouter           */
 
     flags = g_db_item_get_flags(G_DB_ITEM(bookmark));
 
     if (flags & DIF_ERASER)
-        prefix = _("Removed");
+        asprintf(&result, _("Removed bookmark"));
+
+    else if (flags & DIF_UPDATED)
+    {
+        text = get_rle_string(&bookmark->comment);
+
+        if (text != NULL)
+            asprintf(&result, _("Updated bookmark: \"%s\""), text);
+        else
+            asprintf(&result, _("Reset bookmark"));
+    }
+
     else
+    {
         prefix = _("Created");
 
-    text = get_rle_string(&bookmark->comment);
+        text = get_rle_string(&bookmark->comment);
 
-    if (text != NULL)
-        asprintf(&result, _("%s bookmark \"%s\""), prefix, text);
-    else
-        asprintf(&result, _("%s empty bookmark"), prefix);
+        if (text != NULL)
+            asprintf(&result, _("%s bookmark \"%s\""), prefix, text);
+        else
+            asprintf(&result, _("%s empty bookmark"), prefix);
+
+    }
 
     return result;