Defined a new way to launch updates share servers.

11 files changed, 957 insertions, 12 deletions

diff --git a/plugins/pychrysalide/analysis/db/Makefile.am b/plugins/pychrysalide/analysis/db/Makefile.am
index 709f153..4bd8353 100644
--- a/plugins/pychrysalide/analysis/db/Makefile.am
+++ b/plugins/pychrysalide/analysis/db/Makefile.am
@@ -3,9 +3,12 @@ noinst_LTLIBRARIES = libpychrysaanalysisdb.la
 
 libpychrysaanalysisdb_la_SOURCES =		\
 	certs.h certs.c						\
+	client.h client.c					\
 	collection.h collection.c			\
+	constants.h constants.c				\
 	item.h item.c						\
-	module.h module.c
+	module.h module.c					\
+	server.h server.c
 
 libpychrysaanalysisdb_la_LIBADD = 		\
 	items/libpychrysaanalysisdbitems.la
diff --git a/plugins/pychrysalide/analysis/db/certs.c b/plugins/pychrysalide/analysis/db/certs.c
index 3da3849..3d9fcc6 100644
--- a/plugins/pychrysalide/analysis/db/certs.c
+++ b/plugins/pychrysalide/analysis/db/certs.c
@@ -42,10 +42,10 @@
 static bool py_certs_fill_x509_entries(PyObject *, x509_entries *);
 
 /* Crée un certificat de signature racine. */
-static PyObject *py_certs_make_ca(PyObject *, PyObject *);
+static PyObject *py_certs_build_keys_and_ca(PyObject *, PyObject *);
 
 /* Crée un certificat pour application. */
-static PyObject *py_certs_make_request(PyObject *, PyObject *);
+static PyObject *py_certs_build_keys_and_request(PyObject *, PyObject *);
 
 /* Signe un certificat pour application. */
 static PyObject *py_certs_sign_cert(PyObject *, PyObject *);
@@ -127,7 +127,7 @@ static bool py_certs_fill_x509_entries(PyObject *dict, x509_entries *out)
 *                                                                             *
 ******************************************************************************/
 
-static PyObject *py_certs_make_ca(PyObject *self, PyObject *args)
+static PyObject *py_certs_build_keys_and_ca(PyObject *self, PyObject *args)
 {
     PyObject *result;                       /* Désignation à retourner     */
     const char *dir;                        /* Répertoire de sortie        */
@@ -144,7 +144,7 @@ static PyObject *py_certs_make_ca(PyObject *self, PyObject *args)
     status = py_certs_fill_x509_entries(dict, &entries);
     if (!status) return NULL;
 
-    status = make_ca(dir, label, valid, &entries);
+    status = build_keys_and_ca(dir, label, valid, &entries);
 
     free_x509_entries(&entries);
 
@@ -170,7 +170,7 @@ static PyObject *py_certs_make_ca(PyObject *self, PyObject *args)
 *                                                                             *
 ******************************************************************************/
 
-static PyObject *py_certs_make_request(PyObject *self, PyObject *args)
+static PyObject *py_certs_build_keys_and_request(PyObject *self, PyObject *args)
 {
     PyObject *result;                       /* Désignation à retourner     */
     const char *dir;                        /* Répertoire de sortie        */
@@ -186,7 +186,7 @@ static PyObject *py_certs_make_request(PyObject *self, PyObject *args)
     status = py_certs_fill_x509_entries(dict, &entries);
     if (!status) return NULL;
 
-    status = make_request(dir, label, &entries);
+    status = build_keys_and_request(dir, label, &entries);
 
     free_x509_entries(&entries);
 
@@ -253,13 +253,13 @@ PyTypeObject *get_python_certs_type(void)
 {
     static PyMethodDef py_certs_methods[] = {
 
-        { "make_ca", py_certs_make_ca,
+        { "build_keys_and_ca", py_certs_build_keys_and_ca,
           METH_VARARGS | METH_STATIC,
-          "make_ca(dir, label, valid, entries, /)\n--\n\nCreate a certificate authority."
+          "build_keys_and_ca(dir, label, valid, entries, /)\n--\n\nCreate a certificate authority."
         },
-        { "make_request", py_certs_make_request,
+        { "build_keys_and_request", py_certs_build_keys_and_request,
           METH_VARARGS | METH_STATIC,
-          "make_request(dir, label, entries, /)\n--\n\nCreate a certificate sign request."
+          "build_keys_and_request(dir, label, entries, /)\n--\n\nCreate a certificate sign request."
         },
         { "sign_cert", py_certs_sign_cert,
           METH_VARARGS | METH_STATIC,
diff --git a/plugins/pychrysalide/analysis/db/client.c b/plugins/pychrysalide/analysis/db/client.c
new file mode 100644
index 0000000..a9ad930
--- /dev/null
+++ b/plugins/pychrysalide/analysis/db/client.c
@@ -0,0 +1,360 @@
+
+/* Chrysalide - Outil d'analyse de fichiers binaires
+ * client.c - équivalent Python du fichier "analysis/db/client.c"
+ *
+ * Copyright (C) 2019 Cyrille Bagard
+ *
+ *  This file is part of Chrysalide.
+ *
+ *  Chrysalide is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  Chrysalide is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+ */
+
+
+#include "client.h"
+
+
+#include <pygobject.h>
+
+
+#include <i18n.h>
+#include <analysis/db/client.h>
+#include <core/collections.h>
+
+
+#include "collection.h"
+#include "../../access.h"
+#include "../../helpers.h"
+
+
+
+/* Crée un nouvel objet Python de type 'HubClient'. */
+static PyObject *py_hub_client_new(PyTypeObject *, PyObject *, PyObject *);
+
+/* Démarre la connexion à la base de données. */
+static PyObject *py_hub_client_start(PyObject *, PyObject *);
+
+/* Arrête la connexion à la base de données. */
+static PyObject *py_hub_client_stop(PyObject *, PyObject *);
+
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : type = type de l'objet à instancier.                         *
+*                args = arguments fournis à l'appel.                          *
+*                kwds = arguments de type key=val fournis.                    *
+*                                                                             *
+*  Description : Crée un nouvel objet Python de type 'HubClient'.             *
+*                                                                             *
+*  Retour      : Instance Python mise en place.                               *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+static PyObject *py_hub_client_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
+{
+    PyObject *result;                       /* Instance à retourner        */
+    const char *hash;                       /* Empreinte du binaire visé   */
+    PyObject *list;                         /* Liste Python de collections */
+    int ret;                                /* Bilan de lecture des args.  */
+    Py_ssize_t length;                      /* Nombre d'éléments collectés */
+    GList *collections;                     /* Liste native de collections */
+    Py_ssize_t i;                           /* Boucle de parcours          */
+    PyObject *item;                         /* Elément de la liste Python  */
+    GDbCollection *collec;                  /* Version équivalente native  */
+    GHubClient *client;                     /* Serveur mis en place        */
+
+#define HUB_CLIENT_DOC                                                                  \
+    "HubClient provides binary updates to a given server.\n"                            \
+    "\n"                                                                                \
+    "Such clients must be authenticated and communications are encrypted using TLS.\n"  \
+    "\n"                                                                                \
+    "Instances can be created using the following constructor:\n"                       \
+    "\n"                                                                                \
+    "    HubClient(hash, list)"                                                         \
+    "\n"                                                                                \
+    "Where hash is a SHA256 fingerprint of the studied binary and list is a list of"    \
+    " pychrysalide.analysis.db.DbCollection instances.\n"                               \
+    "\n"                                                                                \
+    "This kind of list can be retrived with the"                                        \
+    " pychrysalide.analysis.LoadedBinary.collections attribute."
+
+    ret = PyArg_ParseTuple(args, "sO", &hash, &list);
+    if (!ret) return NULL;
+
+    if (!PySequence_Check(list))
+    {
+        PyErr_SetString(PyExc_TypeError, _("The second argument must be a collection list"));
+        return NULL;
+    }
+
+    length = PySequence_Length(list);
+
+    collections = NULL;
+
+    for (i = 0; i < length; i++)
+    {
+        item = PySequence_GetItem(list, i);
+
+        ret = convert_to_db_collection(item, &collec);
+
+        Py_DECREF(item);
+
+        if (ret != 1)
+        {
+            delete_collections_list(&collections);
+            result = NULL;
+            goto exit;
+        }
+
+        g_object_ref(G_OBJECT(collec));
+        collections = g_list_append(collections, collec);
+
+    }
+
+    client = g_hub_client_new(hash, collections);
+
+    if (client != NULL)
+    {
+        result = pygobject_new(G_OBJECT(client));
+        g_object_unref(client);
+    }
+    else result = NULL;
+
+ exit:
+
+    return result;
+
+}
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : self = serveur à manipuler.                                  *
+*                args = paramètres à transmettre à l'appel natif.             *
+*                                                                             *
+*  Description : Démarre la connexion à la base de données.                   *
+*                                                                             *
+*  Retour      : Bilan de l'opération.                                        *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+static PyObject *py_hub_client_start(PyObject *self, PyObject *args)
+{
+    PyObject *result;                       /* Bilan à retourner           */
+    const char *host;                       /* Désignation de serveur      */
+    const char *port;                       /* Port d'écoute associé       */
+    bool ipv6;                              /* Préférence pour IPv6 ?      */
+    int ret;                                /* Bilan de lecture des args.  */
+    GHubClient *client;                     /* Version native du serveur   */
+    bool status;                            /* Bilan de l'opération        */
+
+#define HUB_CLIENT_START_METHOD PYTHON_METHOD_DEF                   \
+(                                                                   \
+    start, "$self, /, host=None, port='1337', ipv6=True",           \
+    METH_VARARGS, py_hub_client,                                    \
+    "Connect to a server for binary updates.\n"                     \
+    "\n"                                                            \
+    "host and port define the properties of the server, and ipv6"   \
+    " tries to establish IPv6 connections first."                   \
+)
+
+    host = NULL;
+    port = "1337";
+    ipv6 = true;
+
+    ret = PyArg_ParseTuple(args, "|ssp", &host, &port, &ipv6);
+    if (!ret) return NULL;
+
+    client = G_HUB_CLIENT(pygobject_get(self));
+
+    if (host == NULL)
+        status = g_hub_client_start_internal(client);
+    else
+        status = g_hub_client_start_remote(client, host, port, ipv6);
+
+    result = status ? Py_True : Py_False;
+    Py_INCREF(result);
+
+    return result;
+
+}
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : self = serveur à manipuler.                                  *
+*                args = arguments d'appel non utilisés ici.                   *
+*                                                                             *
+*  Description : Arrête la connexion à la base de données.                    *
+*                                                                             *
+*  Retour      : -                                                            *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+static PyObject *py_hub_client_stop(PyObject *self, PyObject *args)
+{
+    PyObject *result;                       /* Bilan à retourner           */
+    GHubClient *client;                     /* Version native du serveur   */
+
+#define HUB_CLIENT_STOP_METHOD PYTHON_METHOD_DEF    \
+(                                                   \
+    stop, "$self, /",                               \
+    METH_NOARGS, py_hub_client,                     \
+    "Stop the client."                              \
+)
+
+    client = G_HUB_CLIENT(pygobject_get(self));
+
+    g_hub_client_stop(client);
+
+    result = Py_None;
+    Py_INCREF(result);
+
+    return result;
+
+}
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : -                                                            *
+*                                                                             *
+*  Description : Fournit un accès à une définition de type à diffuser.        *
+*                                                                             *
+*  Retour      : Définition d'objet pour Python.                              *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+PyTypeObject *get_python_hub_client_type(void)
+{
+    static PyMethodDef py_hub_client_methods[] = {
+        HUB_CLIENT_START_METHOD,
+        HUB_CLIENT_STOP_METHOD,
+        { NULL }
+    };
+
+    static PyGetSetDef py_hub_client_getseters[] = {
+        { NULL }
+    };
+
+    static PyTypeObject py_hub_client_type = {
+
+        PyVarObject_HEAD_INIT(NULL, 0)
+
+        .tp_name        = "pychrysalide.analysis.db.HubClient",
+        .tp_basicsize   = sizeof(PyGObject),
+
+        .tp_flags       = Py_TPFLAGS_DEFAULT | Py_TPFLAGS_BASETYPE,
+
+        .tp_doc         = HUB_CLIENT_DOC,
+
+        .tp_methods     = py_hub_client_methods,
+        .tp_getset      = py_hub_client_getseters,
+        .tp_new         = py_hub_client_new,
+
+    };
+
+    return &py_hub_client_type;
+
+}
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : module = module dont la définition est à compléter.          *
+*                                                                             *
+*  Description : Prend en charge l'objet 'pychrysalide....db.HubClient'.      *
+*                                                                             *
+*  Retour      : Bilan de l'opération.                                        *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+bool ensure_python_hub_client_is_registered(void)
+{
+    PyTypeObject *type;                     /* Type Python 'HubClient'     */
+    PyObject *module;                       /* Module à recompléter        */
+    PyObject *dict;                         /* Dictionnaire du module      */
+
+    type = get_python_hub_client_type();
+
+    if (!PyType_HasFeature(type, Py_TPFLAGS_READY))
+    {
+        module = get_access_to_python_module("pychrysalide.analysis.db");
+
+        dict = PyModule_GetDict(module);
+
+        if (!register_class_for_pygobject(dict, G_TYPE_HUB_CLIENT, type, &PyGObject_Type))
+            return false;
+
+    }
+
+    return true;
+
+}
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : arg = argument quelconque à tenter de convertir.             *
+*                dst = destination des valeurs récupérées en cas de succès.   *
+*                                                                             *
+*  Description : Tente de convertir en client de base de données.             *
+*                                                                             *
+*  Retour      : Bilan de l'opération, voire indications supplémentaires.     *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+int convert_to_hub_client(PyObject *arg, void *dst)
+{
+    int result;                             /* Bilan à retourner           */
+
+    result = PyObject_IsInstance(arg, (PyObject *)get_python_hub_client_type());
+
+    switch (result)
+    {
+        case -1:
+            /* L'exception est déjà fixée par Python */
+            result = 0;
+            break;
+
+        case 0:
+            PyErr_SetString(PyExc_TypeError, "unable to convert the provided argument to hub client");
+            break;
+
+        case 1:
+            *((GHubClient **)dst) = G_HUB_CLIENT(pygobject_get(arg));
+            break;
+
+        default:
+            assert(false);
+            break;
+
+    }
+
+    return result;
+
+}
diff --git a/plugins/pychrysalide/analysis/db/client.h b/plugins/pychrysalide/analysis/db/client.h
new file mode 100644
index 0000000..dbeb91f
--- /dev/null
+++ b/plugins/pychrysalide/analysis/db/client.h
@@ -0,0 +1,45 @@
+
+/* Chrysalide - Outil d'analyse de fichiers binaires
+ * client.h - prototypes pour l'équivalent Python du fichier "analysis/db/client.h"
+ *
+ * Copyright (C) 2019 Cyrille Bagard
+ *
+ *  This file is part of Chrysalide.
+ *
+ *  Chrysalide is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  Chrysalide is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+ */
+
+
+#ifndef _PLUGINS_PYCHRYSALIDE_ANALYSIS_DB_CLIENT_H
+#define _PLUGINS_PYCHRYSALIDE_ANALYSIS_DB_CLIENT_H
+
+
+#include <Python.h>
+#include <stdbool.h>
+
+
+
+/* Fournit un accès à une définition de type à diffuser. */
+PyTypeObject *get_python_hub_client_type(void);
+
+/* Prend en charge l'objet 'pychrysalide.analysis.db.HubClient'. */
+bool ensure_python_hub_client_is_registered(void);
+
+/* Tente de convertir en client de base de données. */
+int convert_to_hub_client(PyObject *, void *);
+
+
+
+#endif  /* _PLUGINS_PYCHRYSALIDE_ANALYSIS_DB_CLIENT_H */
diff --git a/plugins/pychrysalide/analysis/db/collection.c b/plugins/pychrysalide/analysis/db/collection.c
index 699c272..b7e3e0b 100644
--- a/plugins/pychrysalide/analysis/db/collection.c
+++ b/plugins/pychrysalide/analysis/db/collection.c
@@ -116,3 +116,48 @@ bool ensure_python_db_collection_is_registered(void)
     return true;
 
 }
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : arg = argument quelconque à tenter de convertir.             *
+*                dst = destination des valeurs récupérées en cas de succès.   *
+*                                                                             *
+*  Description : Tente de convertir en collection de traitements sur binaire. *
+*                                                                             *
+*  Retour      : Bilan de l'opération, voire indications supplémentaires.     *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+int convert_to_db_collection(PyObject *arg, void *dst)
+{
+    int result;                             /* Bilan à retourner           */
+
+    result = PyObject_IsInstance(arg, (PyObject *)get_python_db_collection_type());
+
+    switch (result)
+    {
+        case -1:
+            /* L'exception est déjà fixée par Python */
+            result = 0;
+            break;
+
+        case 0:
+            PyErr_SetString(PyExc_TypeError, "unable to convert the provided argument to DB collection");
+            break;
+
+        case 1:
+            *((GDbCollection **)dst) = G_DB_COLLECTION(pygobject_get(arg));
+            break;
+
+        default:
+            assert(false);
+            break;
+
+    }
+
+    return result;
+
+}
diff --git a/plugins/pychrysalide/analysis/db/collection.h b/plugins/pychrysalide/analysis/db/collection.h
index 9fa3c8a..13ca273 100644
--- a/plugins/pychrysalide/analysis/db/collection.h
+++ b/plugins/pychrysalide/analysis/db/collection.h
@@ -37,6 +37,9 @@ PyTypeObject *get_python_db_collection_type(void);
 /* Prend en charge l'objet 'pychrysalide.analysis.db.DbCollection'. */
 bool ensure_python_db_collection_is_registered(void);
 
+/* Tente de convertir en collection de traitements sur binaire. */
+int convert_to_db_collection(PyObject *, void *);
 
 
-#endif  /* _PLUGINS_PYCHRYSALIDE_ANALYSIS_DB_COLLECTIONS_H */
+
+#endif  /* _PLUGINS_PYCHRYSALIDE_ANALYSIS_DB_COLLECTION_H */
diff --git a/plugins/pychrysalide/analysis/db/constants.c b/plugins/pychrysalide/analysis/db/constants.c
new file mode 100644
index 0000000..9685ba6
--- /dev/null
+++ b/plugins/pychrysalide/analysis/db/constants.c
@@ -0,0 +1,70 @@
+
+/* Chrysalide - Outil d'analyse de fichiers binaires
+ * constants.c - équivalent Python partiel du fichier "plugins/dex/dex_def.h"
+ *
+ * Copyright (C) 2018 Cyrille Bagard
+ *
+ *  This file is part of Chrysalide.
+ *
+ *  Chrysalide is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  Chrysalide is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+ */
+
+
+#include "constants.h"
+
+
+#include <analysis/db/server.h>
+
+
+#include "../../helpers.h"
+
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : type = type dont le dictionnaire est à compléter.            *
+*                                                                             *
+*  Description : Définit les constantes pour les serveurs de données.         *
+*                                                                             *
+*  Retour      : true en cas de succès de l'opération, false sinon.           *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+bool define_hub_server_constants(PyTypeObject *type)
+{
+    bool result;                            /* Bilan à retourner           */
+    PyObject *values;                       /* Groupe de valeurs à établir */
+
+    values = PyDict_New();
+
+    result = add_const_to_group(values, "FAILURE", SSS_FAILURE);
+    if (result) result = add_const_to_group(values, "SUCCESS", SSS_SUCCESS);
+    if (result) result = add_const_to_group(values, "ALREADY_RUNNING", SSS_ALREADY_RUNNING);
+
+    if (!result)
+    {
+        Py_DECREF(values);
+        goto exit;
+    }
+
+    result = attach_constants_group(type, false, "ServerStartStatus", values, "Status of a server start.");
+
+ exit:
+
+    return result;
+
+}
diff --git a/plugins/pychrysalide/analysis/db/constants.h b/plugins/pychrysalide/analysis/db/constants.h
new file mode 100644
index 0000000..a2fc49e
--- /dev/null
+++ b/plugins/pychrysalide/analysis/db/constants.h
@@ -0,0 +1,39 @@
+
+/* Chrysalide - Outil d'analyse de fichiers binaires
+ * constants.h - prototypes pour l'ajout des constantes liées aux bases de données
+ *
+ * Copyright (C) 2019 Cyrille Bagard
+ *
+ *  This file is part of Chrysalide.
+ *
+ *  Chrysalide is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  Chrysalide is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+ */
+
+
+#ifndef _PLUGINS_PYCHRYSALIDE_ANALYSIS_DB_CONSTANTS_H
+#define _PLUGINS_PYCHRYSALIDE_ANALYSIS_DB_CONSTANTS_H
+
+
+#include <Python.h>
+#include <stdbool.h>
+
+
+
+/* Définit les constantes pour les serveurs de données. */
+bool define_hub_server_constants(PyTypeObject *);
+
+
+
+#endif  /* _PLUGINS_PYCHRYSALIDE_ANALYSIS_DB_CONSTANTS_H */
diff --git a/plugins/pychrysalide/analysis/db/module.c b/plugins/pychrysalide/analysis/db/module.c
index 33af35f..efe780f 100644
--- a/plugins/pychrysalide/analysis/db/module.c
+++ b/plugins/pychrysalide/analysis/db/module.c
@@ -29,8 +29,10 @@
 
 
 #include "certs.h"
+#include "client.h"
 #include "collection.h"
 #include "item.h"
+#include "server.h"
 #include "items/module.h"
 #include "../../helpers.h"
 
@@ -97,8 +99,10 @@ bool populate_analysis_db_module(void)
     result = true;
 
     if (result) result = ensure_python_certs_is_registered();
+    if (result) result = ensure_python_hub_client_is_registered();
     if (result) result = ensure_python_db_collection_is_registered();
     if (result) result = ensure_python_db_item_is_registered();
+    if (result) result = ensure_python_hub_server_is_registered();
 
     if (result) result = populate_analysis_db_items_module();
 
diff --git a/plugins/pychrysalide/analysis/db/server.c b/plugins/pychrysalide/analysis/db/server.c
new file mode 100644
index 0000000..cee6bf6
--- /dev/null
+++ b/plugins/pychrysalide/analysis/db/server.c
@@ -0,0 +1,331 @@
+
+/* Chrysalide - Outil d'analyse de fichiers binaires
+ * server.c - équivalent Python du fichier "analysis/db/server.c"
+ *
+ * Copyright (C) 2019 Cyrille Bagard
+ *
+ *  This file is part of Chrysalide.
+ *
+ *  Chrysalide is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  Chrysalide is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+ */
+
+
+#include "server.h"
+
+
+#include <pygobject.h>
+
+
+#include <i18n.h>
+#include <analysis/db/server.h>
+
+
+#include "constants.h"
+#include "../../access.h"
+#include "../../helpers.h"
+
+
+
+/* Crée un nouvel objet Python de type 'HubServer'. */
+static PyObject *py_hub_server_new(PyTypeObject *, PyObject *, PyObject *);
+
+/* Démarre le serveur de base de données. */
+static PyObject *py_hub_server_start(PyObject *, PyObject *);
+
+/* Arrête le serveur de base de données. */
+static PyObject *py_hub_server_stop(PyObject *, PyObject *);
+
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : type = type de l'objet à instancier.                         *
+*                args = arguments fournis à l'appel.                          *
+*                kwds = arguments de type key=val fournis.                    *
+*                                                                             *
+*  Description : Crée un nouvel objet Python de type 'HubServer'.             *
+*                                                                             *
+*  Retour      : Instance Python mise en place.                               *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+static PyObject *py_hub_server_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
+{
+    PyObject *result;                       /* Instance à retourner        */
+    const char *host;                       /* Désignation de serveur      */
+    const char *port;                       /* Port d'écoute associé       */
+    bool ipv6;                              /* Préférence pour IPv6 ?      */
+    int ret;                                /* Bilan de lecture des args.  */
+    GHubServer *server;                     /* Serveur mis en place        */
+
+#define HUB_SERVER_DOC                                                                  \
+    "HubServer creates a server listening for binary updates from clients.\n"           \
+    "\n"                                                                                \
+    "Such clients are authenticated and communications are encrypted using TLS.\n"      \
+    "\n"                                                                                \
+    "There are two kinds of servers:\n"                                                 \
+    "* one \"local\", which aims to server one given local user account;\n"             \
+    "* one \"remote\", which may target several different users at the same time.\n"    \
+    "\n"                                                                                \
+    "Instances can be created using the following constructor:\n"                       \
+    "\n"                                                                                \
+    "    HubServer(host=None, port='1337', ipv6=True)"                                  \
+    "\n"                                                                                \
+    "Where host and port define the listening properties of the server, and ipv6"       \
+    " tries to establish IPv6 connections first."                                       \
+    "\n"                                                                                \
+    "Without any parameters, a local server is created."
+
+    host = NULL;
+    port = "1337";
+    ipv6 = true;
+
+    ret = PyArg_ParseTuple(args, "|ssp", &host, &port, &ipv6);
+    if (!ret) return NULL;
+
+    if (host == NULL)
+        server = g_hub_server_new_internal();
+    else
+        server = g_hub_server_new_remote(host, port, ipv6);
+
+    if (server != NULL)
+    {
+        result = pygobject_new(G_OBJECT(server));
+        g_object_unref(server);
+    }
+    else result = NULL;
+
+    return result;
+
+}
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : self = serveur à manipuler.                                  *
+*                args = arguments d'appel non utilisés ici.                   *
+*                                                                             *
+*  Description : Démarre le serveur de base de données.                       *
+*                                                                             *
+*  Retour      : Bilan de l'opération.                                        *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+static PyObject *py_hub_server_start(PyObject *self, PyObject *args)
+{
+    PyObject *result;                       /* Bilan à retourner           */
+    int backlog;                            /* Nombre de connexions        */
+    int ret;                                /* Bilan de lecture des args.  */
+    GHubServer *server;                     /* Version native du serveur   */
+    bool status;                            /* Bilan de l'opération        */
+
+#define HUB_SERVER_START_METHOD PYTHON_METHOD_DEF               \
+(                                                               \
+    start, "$self, /, backlog=10",                              \
+    METH_VARARGS, py_hub_server,                                \
+    "Run a listening server waiting for client connections."    \
+    "\n"                                                        \
+    "The backlog argument defines the maximum length to which"  \
+    " the queue of pending connections may grow."               \
+    "\n"                                                        \
+    "The returned value is a status of type"                    \
+    " pychrysalide.analysis.db.HubServer.ServerStartStatus."    \
+)
+
+    backlog = 10;
+
+    ret = PyArg_ParseTuple(args, "|i", &backlog);
+    if (!ret) return NULL;
+
+    server = G_HUB_SERVER(pygobject_get(self));
+
+    status = g_hub_server_start(server, backlog, true);
+
+    result = cast_with_constants_group(get_python_hub_server_type(), "ServerStartStatus", status);
+
+    return result;
+
+}
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : self = serveur à manipuler.                                  *
+*                args = arguments d'appel non utilisés ici.                   *
+*                                                                             *
+*  Description : Arrête le serveur de base de données.                        *
+*                                                                             *
+*  Retour      : -                                                            *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+static PyObject *py_hub_server_stop(PyObject *self, PyObject *args)
+{
+    PyObject *result;                       /* Bilan à retourner           */
+    GHubServer *server;                     /* Version native du serveur   */
+
+#define HUB_SERVER_STOP_METHOD PYTHON_METHOD_DEF    \
+(                                                   \
+    stop, "$self, /",                               \
+    METH_NOARGS, py_hub_server,                     \
+    "Stop the listening server."                    \
+)
+
+    server = G_HUB_SERVER(pygobject_get(self));
+
+    g_hub_server_stop(server);
+
+    result = Py_None;
+    Py_INCREF(result);
+
+    return result;
+
+}
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : -                                                            *
+*                                                                             *
+*  Description : Fournit un accès à une définition de type à diffuser.        *
+*                                                                             *
+*  Retour      : Définition d'objet pour Python.                              *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+PyTypeObject *get_python_hub_server_type(void)
+{
+    static PyMethodDef py_hub_server_methods[] = {
+        HUB_SERVER_START_METHOD,
+        HUB_SERVER_STOP_METHOD,
+        { NULL }
+    };
+
+    static PyGetSetDef py_hub_server_getseters[] = {
+        { NULL }
+    };
+
+    static PyTypeObject py_hub_server_type = {
+
+        PyVarObject_HEAD_INIT(NULL, 0)
+
+        .tp_name        = "pychrysalide.analysis.db.HubServer",
+        .tp_basicsize   = sizeof(PyGObject),
+
+        .tp_flags       = Py_TPFLAGS_DEFAULT | Py_TPFLAGS_BASETYPE,
+
+        .tp_doc         = HUB_SERVER_DOC,
+
+        .tp_methods     = py_hub_server_methods,
+        .tp_getset      = py_hub_server_getseters,
+        .tp_new         = py_hub_server_new,
+
+    };
+
+    return &py_hub_server_type;
+
+}
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : module = module dont la définition est à compléter.          *
+*                                                                             *
+*  Description : Prend en charge l'objet 'pychrysalide....db.HubServer'.      *
+*                                                                             *
+*  Retour      : Bilan de l'opération.                                        *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+bool ensure_python_hub_server_is_registered(void)
+{
+    PyTypeObject *type;                     /* Type Python 'HubServer'     */
+    PyObject *module;                       /* Module à recompléter        */
+    PyObject *dict;                         /* Dictionnaire du module      */
+
+    type = get_python_hub_server_type();
+
+    if (!PyType_HasFeature(type, Py_TPFLAGS_READY))
+    {
+        module = get_access_to_python_module("pychrysalide.analysis.db");
+
+        dict = PyModule_GetDict(module);
+
+        if (!register_class_for_pygobject(dict, G_TYPE_HUB_SERVER, type, &PyGObject_Type))
+            return false;
+
+        if (!define_hub_server_constants(type))
+            return false;
+
+    }
+
+    return true;
+
+}
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : arg = argument quelconque à tenter de convertir.             *
+*                dst = destination des valeurs récupérées en cas de succès.   *
+*                                                                             *
+*  Description : Tente de convertir en serveur de base de données.            *
+*                                                                             *
+*  Retour      : Bilan de l'opération, voire indications supplémentaires.     *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+int convert_to_hub_server(PyObject *arg, void *dst)
+{
+    int result;                             /* Bilan à retourner           */
+
+    result = PyObject_IsInstance(arg, (PyObject *)get_python_hub_server_type());
+
+    switch (result)
+    {
+        case -1:
+            /* L'exception est déjà fixée par Python */
+            result = 0;
+            break;
+
+        case 0:
+            PyErr_SetString(PyExc_TypeError, "unable to convert the provided argument to hub server");
+            break;
+
+        case 1:
+            *((GHubServer **)dst) = G_HUB_SERVER(pygobject_get(arg));
+            break;
+
+        default:
+            assert(false);
+            break;
+
+    }
+
+    return result;
+
+}
diff --git a/plugins/pychrysalide/analysis/db/server.h b/plugins/pychrysalide/analysis/db/server.h
new file mode 100644
index 0000000..a5dbcde
--- /dev/null
+++ b/plugins/pychrysalide/analysis/db/server.h
@@ -0,0 +1,45 @@
+
+/* Chrysalide - Outil d'analyse de fichiers binaires
+ * server.h - prototypes pour l'équivalent Python du fichier "analysis/db/server.h"
+ *
+ * Copyright (C) 2019 Cyrille Bagard
+ *
+ *  This file is part of Chrysalide.
+ *
+ *  Chrysalide is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  Chrysalide is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+ */
+
+
+#ifndef _PLUGINS_PYCHRYSALIDE_ANALYSIS_DB_SERVER_H
+#define _PLUGINS_PYCHRYSALIDE_ANALYSIS_DB_SERVER_H
+
+
+#include <Python.h>
+#include <stdbool.h>
+
+
+
+/* Fournit un accès à une définition de type à diffuser. */
+PyTypeObject *get_python_hub_server_type(void);
+
+/* Prend en charge l'objet 'pychrysalide.analysis.db.HubServer'. */
+bool ensure_python_hub_server_is_registered(void);
+
+/* Tente de convertir en serveur de base de données. */
+int convert_to_hub_server(PyObject *, void *);
+
+
+
+#endif  /* _PLUGINS_PYCHRYSALIDE_ANALYSIS_DB_SERVER_H */