-first implementation of execute function for ego advertisement

1 files changed, 195 insertions, 3 deletions

diff --git a/src/identity/gnunet-identity-gtk_advertise.c b/src/identity/gnunet-identity-gtk_advertise.c
index 07ab09fd..63bba35e 100644
--- a/src/identity/gnunet-identity-gtk_advertise.c
+++ b/src/identity/gnunet-identity-gtk_advertise.c
@@ -24,6 +24,7 @@
  * @author Christian Grothoff
  */
 #include "gnunet-identity-gtk_advertise.h"
+#include "gnunet-identity-gtk.h"
 #include <gnunet/gnunet_fs_service.h>
 
 
@@ -148,6 +149,120 @@ struct AdvertiseContext
 };
 
 
+/**
+ * Context for the publishing operation.
+ */
+struct PublishContext
+{
+
+  /**
+   * Kept in a DLL.
+   */
+  struct PublishContext *next;
+
+  /**
+   * Kept in a DLL.
+   */
+  struct PublishContext *prev;
+
+  /**
+   * Handle to FS subsystem.
+   */
+  struct GNUNET_FS_Handle *fs;
+
+  /**
+   * Handle to the publish operation.
+   */
+  struct GNUNET_FS_PublishKskContext *pub;
+
+};
+
+
+/**
+ * Kept in a DLL.
+ */
+static struct PublishContext *pc_head;
+
+/**
+ * Kept in a DLL.
+ */
+static struct PublishContext *pc_tail;
+
+
+/**
+ * Shutdown advertisement subsystem, this process is terminating.
+ */
+void
+GIG_advertise_shutdown_ ()
+{
+  struct PublishContext *pc;
+
+  while (NULL != (pc = pc_head))
+  {
+    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+                _("Aborting advertising operation due to shutdown.\n"));
+    GNUNET_CONTAINER_DLL_remove (pc_head,
+                                 pc_tail,
+                                 pc);
+    GNUNET_FS_publish_ksk_cancel (pc->pub);
+    GNUNET_FS_stop (pc->fs);
+    GNUNET_free (pc);
+  }
+}
+
+
+/**
+ * Function called once we published the advertisement.
+ *
+ * @param cls closure with the `struct PublishContext`
+ * @param uri URI under which the block is now available, NULL on error
+ * @param emsg error message, NULL on success
+ */
+static void
+publish_continuation (void *cls,
+                      const struct GNUNET_FS_Uri *uri,
+                      const char *emsg)
+{
+  struct PublishContext *pc = cls;
+  
+  pc->pub = NULL;
+  if (NULL == uri)
+  {
+    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+                _("Failed to advertise ego: %s\n"),
+                emsg);
+    /* FIXME: might want to output to GUI... */
+  }
+  GNUNET_FS_stop (pc->fs);
+  GNUNET_CONTAINER_DLL_remove (pc_head,
+                               pc_tail,
+                               pc);
+  GNUNET_free (pc);
+}
+
+
+/**
+ * Notification of FS to a client about the progress of an
+ * operation.  Callbacks of this type will be used for uploads,
+ * downloads and searches.  Some of the arguments depend a bit
+ * in their meaning on the context in which the callback is used.
+ *
+ * @param cls closure
+ * @param info details about the event, specifying the event type
+ *        and various bits about the event
+ * @return client-context (for the next progress call
+ *         for this operation; should be set to NULL for
+ *         SUSPEND and STOPPED events).  The value returned
+ *         will be passed to future callbacks in the respective
+ *         field in the `struct GNUNET_FS_ProgressInfo`.
+ */
+static void *
+progress_cb (void *cls,
+             const struct GNUNET_FS_ProgressInfo *info)
+{
+  return NULL;
+}
+
 
 /**
  * The user terminated the dialog.  Perform the appropriate action.
@@ -162,12 +277,89 @@ GNUNET_GTK_identity_advertise_dialog_response_cb (GtkDialog *dialog,
                                                   gpointer user_data)
 {
   struct AdvertiseContext *ac = user_data;
-
-  if (GTK_RESPONSE_OK == response_id)
+  struct GNUNET_FS_Uri *ksk_uri;
+  struct GNUNET_FS_Uri *uri;
+  gchar *keyword;
+  struct GNUNET_CONTAINER_MetaData *meta;
+  guint ntype;
+  gchar *value;
+  GtkTreeIter iter;
+  struct GNUNET_FS_BlockOptions bo;
+  struct GNUNET_CRYPTO_EccPublicKey pk;
+  struct PublishContext *pc;
+
+  if (GTK_RESPONSE_OK != response_id)
+    goto cleanup;  
+  ksk_uri = NULL;
+  if (! gtk_tree_model_get_iter_first (GTK_TREE_MODEL (ac->keywords), &iter))
+  {
+    GNUNET_break (0);
+    goto cleanup;
+  }  
+  do
+  {    
+    gtk_tree_model_get (GTK_TREE_MODEL (ac->keywords), &iter,
+                        KEYWORDS_MC_KEYWORD, &keyword,
+                        -1);
+    if (NULL == ksk_uri)
+      ksk_uri = GNUNET_FS_uri_ksk_create_from_args (1, (const char **) &keyword);
+    else
+      GNUNET_FS_uri_ksk_add_keyword (ksk_uri, keyword, GNUNET_NO);
+    g_free (keyword);
+  }
+  while (gtk_tree_model_iter_next (GTK_TREE_MODEL (ac->keywords), &iter));
+  
+  meta = GNUNET_CONTAINER_meta_data_create ();
+  if (gtk_tree_model_get_iter_first (GTK_TREE_MODEL (ac->metadata),
+                                     &iter))
+  {
+    do
     {
-      GNUNET_break (0); // FIXME: not implemented
+      gtk_tree_model_get (GTK_TREE_MODEL (ac->metadata), &iter,
+                          METADATA_MC_TYPE_AS_ENUM, &ntype,
+                          METADATA_MC_VALUE, &value,
+                          -1);
+      if (ntype > 0)
+      {
+        GNUNET_CONTAINER_meta_data_insert (meta, "<user>", 
+                                           ntype,
+                                           EXTRACTOR_METAFORMAT_UTF8,
+                                           "text/plain", value,
+                                           strlen (value) + 1);
+      }
+      g_free (value);
     }
+    while (gtk_tree_model_iter_next (GTK_TREE_MODEL (ac->metadata), &iter));
+  }
 
+  bo.expiration_time = GNUNET_TIME_UNIT_FOREVER_ABS; /* FIXME: allow user to specify */
+  bo.anonymity_level = 1; /* FIXME: allow user to specify */
+  bo.content_priority = 1000; /* FIXME: allow user to specify */
+  bo.replication_level = 5;
+  GNUNET_CRYPTO_ecc_key_get_public (&ac->priv,
+                                    &pk);
+  uri = GNUNET_FS_uri_sks_create (&pk,
+                                  "root"); /* FIXME: allow user to specify! */
+
+  pc = GNUNET_new (struct PublishContext);
+  pc->fs = GNUNET_FS_start (GIG_get_configuration (),
+                            "gnunet-identity-gtk",
+                            &progress_cb, pc,
+                            GNUNET_FS_FLAGS_NONE,
+                            GNUNET_FS_OPTIONS_END);
+  pc->pub = GNUNET_FS_publish_ksk (pc->fs,
+                                   ksk_uri,
+                                   meta,
+                                   uri,
+                                   &bo,
+                                   GNUNET_FS_PUBLISH_OPTION_NONE,
+                                   &publish_continuation, pc);
+  GNUNET_CONTAINER_DLL_insert (pc_head,
+                               pc_tail,
+                               pc);
+  GNUNET_FS_uri_destroy (uri);
+  GNUNET_CONTAINER_meta_data_destroy (meta);
+ cleanup:
   gtk_widget_destroy (ac->dialog);
   g_object_unref (G_OBJECT (ac->builder));
   GNUNET_free (ac);