4 files changed, 694 insertions, 19 deletions

diff --git a/include/gnunet/gnunet_chat_lib.h b/include/gnunet/gnunet_chat_lib.h
index 574f661..3958dba 100644
--- a/include/gnunet/gnunet_chat_lib.h
+++ b/include/gnunet/gnunet_chat_lib.h
@@ -195,7 +195,7 @@ typedef enum GNUNET_GenericReturnValue
  * Iterator over attributes of a specific chat handle.
  *
  * @param[in,out] cls Closure from #GNUNET_CHAT_get_attributes
- * @param[in] handle Chat handle
+ * @param[in,out] handle Chat handle
  * @param[in] name Attribute name
  * @param[in] value Attribute value
  * @return #GNUNET_YES if we should continue to iterate, #GNUNET_NO otherwise.
@@ -516,11 +516,11 @@ void
 GNUNET_CHAT_set_attribute (struct GNUNET_CHAT_Handle *handle,
                            const char *name,
                            const char *value,
-                           const struct GNUNET_TIME_Relative *expires);
+                           struct GNUNET_TIME_Relative expires);
 
 /**
- * Deletes an attribute of a chat handle for related communication under a given
- * <i>name</i>.
+ * Deletes an attribute of a chat <i>handle</i> for related communication 
+ * under a given <i>name</i>.
  *
  * @param[in,out] handle Chat handle
  * @param[in] name Attribute name
@@ -543,6 +543,47 @@ GNUNET_CHAT_get_attributes (struct GNUNET_CHAT_Handle *handle,
                             void *cls);
 
 /**
+ * Share an attribute of a chat <i>handle</i> under a given <i>name</i>
+ * with a specific chat <i>contact</i>.
+ *
+ * @param[in,out] handle Chat handle
+ * @param[in,out] contact Chat contact
+ * @param[in] name Attribute name
+ */
+void
+GNUNET_CHAT_share_attribute_with (struct GNUNET_CHAT_Handle *handle,
+                                  struct GNUNET_CHAT_Contact *contact,
+                                  const char *name);
+
+/**
+ * Unshare an attribute of a chat <i>handle</i> under a given <i>name</i>
+ * from a specific chat <i>contact</i>.
+ *
+ * @param[in,out] handle Chat handle
+ * @param[in,out] contact Chat contact
+ * @param[in] name Attribute name
+ */
+void
+GNUNET_CHAT_unshare_attribute_from (struct GNUNET_CHAT_Handle *handle,
+                                    struct GNUNET_CHAT_Contact *contact,
+                                    const char *name);
+
+/**
+ * Calls an optional <i>callback</i> for each attribute of a given chat 
+ * <i>handle</i> shared with a specific chat <i>contact</i>.
+ *
+ * @param[in,out] handle Chat handle
+ * @param[in] contact Chat contact
+ * @param[in] callback Callback for attribute iteration (optional)
+ * @param[in,out] cls Closure for attribute iteration (optional)
+ */
+void
+GNUNET_CHAT_get_shared_attributes (struct GNUNET_CHAT_Handle *handle,
+                                   const struct GNUNET_CHAT_Contact *contact,
+                                   GNUNET_CHAT_ContactAttributeCallback callback,
+                                   void *cls);
+
+/**
  * Convert an UTF-8 String to a chat URI which will be newly allocated.
  *
  * @param[in] uri UTF-8 string to parse
diff --git a/src/gnunet_chat_handle.h b/src/gnunet_chat_handle.h
index 677c153..30c14ad 100644
--- a/src/gnunet_chat_handle.h
+++ b/src/gnunet_chat_handle.h
@@ -94,8 +94,10 @@ struct GNUNET_CHAT_UriLookups
 struct GNUNET_CHAT_AttributeProcess
 {
   struct GNUNET_CHAT_Handle *handle;
+  const struct GNUNET_CHAT_Contact *contact;
 
   struct GNUNET_RECLAIM_Attribute *attribute;
+  char *name;
 
   GNUNET_CHAT_AttributeCallback callback;
   void *closure;
@@ -110,6 +112,13 @@ struct GNUNET_CHAT_AttributeProcess
 struct GNUNET_CHAT_TicketProcess
 {
   struct GNUNET_CHAT_Handle *handle;
+  const struct GNUNET_CHAT_Contact *contact;
+
+  struct GNUNET_RECLAIM_Ticket *ticket;
+  char *name;
+
+  GNUNET_CHAT_ContactAttributeCallback callback;
+  void *closure;
 
   struct GNUNET_CRYPTO_PrivateKey identity;
 
@@ -379,7 +388,7 @@ handle_process_records (struct GNUNET_CHAT_Handle *handle,
 
 /**
  * Updates the tickets of a given chat <i>handle</i>, revoking 
- * all tickets of a <i>identity</i>.
+ * all tickets of an <i>identity</i>.
  *
  * @param[in,out] handle Chat handle
  * @param[in] identity Identity private key
diff --git a/src/gnunet_chat_lib.c b/src/gnunet_chat_lib.c
index ca17b62..3c7bb14 100644
--- a/src/gnunet_chat_lib.c
+++ b/src/gnunet_chat_lib.c
@@ -275,7 +275,7 @@ void
 GNUNET_CHAT_set_attribute (struct GNUNET_CHAT_Handle *handle,
                            const char *name,
                            const char *value,
-                           const struct GNUNET_TIME_Relative *expires)
+                           struct GNUNET_TIME_Relative expires)
 {
   GNUNET_CHAT_VERSION_ASSERT();
 
@@ -336,7 +336,7 @@ GNUNET_CHAT_set_attribute (struct GNUNET_CHAT_Handle *handle,
     handle->reclaim,
     key,
     attributes->attribute,
-    expires,
+    &expires,
     cont_update_attribute_with_status,
     attributes
   );
@@ -375,25 +375,22 @@ GNUNET_CHAT_delete_attribute (struct GNUNET_CHAT_Handle *handle,
   memset(attributes, 0, sizeof(struct GNUNET_CHAT_AttributeProcess));
 
   attributes->handle = handle;
-  attributes->attribute = GNUNET_RECLAIM_attribute_new(
-    name,
-    NULL,
-    GNUNET_RECLAIM_ATTRIBUTE_TYPE_NONE,
-    NULL,
-    0
-  );
+  attributes->name = GNUNET_strdup(name);
 
-  if (!attributes->attribute)
+  if (!attributes->name)
   {
     GNUNET_free(attributes);
     return;
   }
 
-  attributes->op = GNUNET_RECLAIM_attribute_delete(
+  attributes->iter = GNUNET_RECLAIM_get_attributes_start(
     handle->reclaim,
     key,
-    attributes->attribute,
-    cont_update_attribute_with_status,
+    cb_task_error_iterate_attribute,
+    attributes,
+    cb_delete_attribute,
+    attributes,
+    cb_task_finish_iterate_attribute,
     attributes
   );
 
@@ -455,6 +452,160 @@ GNUNET_CHAT_get_attributes (struct GNUNET_CHAT_Handle *handle,
 }
 
 
+void
+GNUNET_CHAT_share_attribute_with (struct GNUNET_CHAT_Handle *handle,
+                                  struct GNUNET_CHAT_Contact *contact,
+                                  const char *name)
+{
+  GNUNET_CHAT_VERSION_ASSERT();
+
+  if ((!handle) || (handle->destruction) || (!contact))
+    return;
+
+  const struct GNUNET_CRYPTO_PrivateKey *key = handle_get_key(
+    handle
+  );
+
+  const struct GNUNET_CRYPTO_PublicKey *pubkey = contact_get_key(
+    contact
+  );
+
+  if ((!key) || (!pubkey) || (!name))
+    return;
+
+  struct GNUNET_CHAT_AttributeProcess *attributes = GNUNET_new(
+    struct GNUNET_CHAT_AttributeProcess
+  );
+
+  if (!attributes)
+    return;
+
+  memset(attributes, 0, sizeof(struct GNUNET_CHAT_AttributeProcess));
+
+  attributes->handle = handle;
+  attributes->contact = contact;
+  attributes->name = GNUNET_strdup(name);
+
+  attributes->iter = GNUNET_RECLAIM_get_attributes_start(
+    handle->reclaim,
+    key,
+    cb_task_error_iterate_attribute,
+    attributes,
+    cb_share_attribute,
+    attributes,
+    cb_task_finish_iterate_attribute,
+    attributes
+  );
+
+  GNUNET_CONTAINER_DLL_insert_tail(
+    handle->attributes_head,
+    handle->attributes_tail,
+    attributes
+  );
+}
+
+
+void
+GNUNET_CHAT_unshare_attribute_from (struct GNUNET_CHAT_Handle *handle,
+                                    struct GNUNET_CHAT_Contact *contact,
+                                    const char *name)
+{
+  GNUNET_CHAT_VERSION_ASSERT();
+
+  if ((!handle) || (handle->destruction) || (!contact))
+    return;
+
+  const struct GNUNET_CRYPTO_PrivateKey *key = handle_get_key(
+    handle
+  );
+
+  if ((!key) || (!name))
+    return;
+
+  struct GNUNET_CHAT_TicketProcess *tickets = GNUNET_new(
+    struct GNUNET_CHAT_TicketProcess
+  );
+
+  if (!tickets)
+    return;
+
+  memset(tickets, 0, sizeof(struct GNUNET_CHAT_TicketProcess));
+
+  tickets->handle = handle;
+  tickets->contact = contact;
+  tickets->name = GNUNET_strdup(name);
+
+  tickets->iter = GNUNET_RECLAIM_ticket_iteration_start(
+    handle->reclaim,
+    key,
+    cb_task_error_iterate_ticket,
+    tickets,
+    cb_iterate_ticket_check,
+    tickets,
+    cb_task_finish_iterate_ticket,
+    tickets
+  );
+
+  GNUNET_CONTAINER_DLL_insert_tail(
+    handle->tickets_head,
+    handle->tickets_tail,
+    tickets
+  );
+}
+
+
+void
+GNUNET_CHAT_get_shared_attributes (struct GNUNET_CHAT_Handle *handle,
+                                   const struct GNUNET_CHAT_Contact *contact,
+                                   GNUNET_CHAT_ContactAttributeCallback callback,
+                                   void *cls)
+{
+  GNUNET_CHAT_VERSION_ASSERT();
+
+  if ((!handle) || (handle->destruction) || (!contact))
+    return;
+
+  const struct GNUNET_CRYPTO_PrivateKey *key = handle_get_key(
+    handle
+  );
+
+  if (!key)
+    return;
+
+  struct GNUNET_CHAT_TicketProcess *tickets = GNUNET_new(
+    struct GNUNET_CHAT_TicketProcess
+  );
+
+  if (!tickets)
+    return;
+
+  memset(tickets, 0, sizeof(struct GNUNET_CHAT_TicketProcess));
+
+  tickets->handle = handle;
+  tickets->contact = contact;
+
+  tickets->callback = callback;
+  tickets->closure = cls;
+
+  tickets->iter = GNUNET_RECLAIM_ticket_iteration_start(
+    handle->reclaim,
+    key,
+    cb_task_error_iterate_ticket,
+    tickets,
+    cb_iterate_ticket,
+    tickets,
+    cb_task_finish_iterate_ticket,
+    tickets
+  );
+
+  GNUNET_CONTAINER_DLL_insert_tail(
+    handle->tickets_head,
+    handle->tickets_tail,
+    tickets
+  );
+}
+
+
 struct GNUNET_CHAT_Uri*
 GNUNET_CHAT_uri_parse (const char *uri,
                                    char **emsg)
diff --git a/src/gnunet_chat_lib_intern.c b/src/gnunet_chat_lib_intern.c
index 9bf5788..61c0e94 100644
--- a/src/gnunet_chat_lib_intern.c
+++ b/src/gnunet_chat_lib_intern.c
@@ -26,7 +26,11 @@
 #include "gnunet_chat_handle.h"
 
 #include <gnunet/gnunet_common.h>
+#include <gnunet/gnunet_messenger_service.h>
+#include <gnunet/gnunet_reclaim_lib.h>
+#include <gnunet/gnunet_reclaim_service.h>
 #include <stdlib.h>
+#include <string.h>
 
 #define GNUNET_UNUSED __attribute__ ((unused))
 
@@ -438,6 +442,11 @@ cb_task_finish_iterate_attribute (void *cls)
   if (attributes->iter)
     GNUNET_RECLAIM_get_attributes_stop(attributes->iter);
 
+  attributes->iter = NULL;
+
+  if (attributes->op)
+    return;
+
   GNUNET_CONTAINER_DLL_remove(
     handle->attributes_head,
     handle->attributes_tail,
@@ -467,6 +476,55 @@ cb_task_error_iterate_attribute (void *cls)
 }
 
 void
+cb_delete_attribute (void *cls,
+                     const struct GNUNET_CRYPTO_PublicKey *identity,
+                     const struct GNUNET_RECLAIM_Attribute *attribute)
+{
+  GNUNET_assert(cls);
+
+  struct GNUNET_CHAT_AttributeProcess *attributes = (
+    (struct GNUNET_CHAT_AttributeProcess*) cls
+  );
+
+  if (! attributes->name)
+  {
+    if (attributes->iter)
+      GNUNET_RECLAIM_get_attributes_stop(attributes->iter);
+
+    attributes->iter = NULL;
+    return;
+  }
+
+  struct GNUNET_CHAT_Handle *handle = attributes->handle;
+
+  const struct GNUNET_CRYPTO_PrivateKey *key = handle_get_key(
+    handle
+  );
+
+  if (0 == strcmp(attribute->name, attributes->name))
+  {
+    if (attributes->iter)
+      GNUNET_RECLAIM_get_attributes_stop(attributes->iter);
+
+    attributes->iter = NULL;
+    attributes->op = GNUNET_RECLAIM_attribute_delete(
+      handle->reclaim,
+      key,
+      attribute,
+      cont_update_attribute_with_status,
+      attributes
+    );
+
+    GNUNET_free(attributes->name);
+    attributes->name = NULL;
+    return;
+  }
+
+  if (attributes->iter)
+    GNUNET_RECLAIM_get_attributes_next(attributes->iter);
+}
+
+void
 cb_iterate_attribute (void *cls,
                       const struct GNUNET_CRYPTO_PublicKey *identity,
                       const struct GNUNET_RECLAIM_Attribute *attribute)
@@ -479,7 +537,7 @@ cb_iterate_attribute (void *cls,
 
   struct GNUNET_CHAT_Handle *handle = attributes->handle;
 
-  const char *value = GNUNET_RECLAIM_attribute_value_to_string(
+  char *value = GNUNET_RECLAIM_attribute_value_to_string(
     attribute->type,
     attribute->data,
     attribute->data_size
@@ -488,6 +546,422 @@ cb_iterate_attribute (void *cls,
   if (attributes->callback)
     attributes->callback(attributes->closure, handle, attribute->name, value);
 
+  if (value)
+    GNUNET_free (value);
+
+  if (attributes->iter)
+    GNUNET_RECLAIM_get_attributes_next(attributes->iter);
+}
+
+void
+cb_issue_ticket (void *cls,
+                 const struct GNUNET_RECLAIM_Ticket *ticket,
+                 const struct GNUNET_RECLAIM_PresentationList *presentations)
+{
+  GNUNET_assert(cls);
+
+  struct GNUNET_CHAT_AttributeProcess *attributes = (
+    (struct GNUNET_CHAT_AttributeProcess*) cls
+  );
+
+  struct GNUNET_CHAT_Handle *handle = attributes->handle;
+  struct GNUNET_CHAT_Context *context = contact_find_context(
+    attributes->contact
+  );
+
+  if ((context) && (context->room) && (ticket))
+    GNUNET_MESSENGER_send_ticket(context->room, ticket);
+
+  GNUNET_CONTAINER_DLL_remove(
+    handle->attributes_head,
+    handle->attributes_tail,
+    attributes
+  );
+
+  GNUNET_free(attributes);
+}
+
+void
+cb_share_attribute (void *cls,
+                    const struct GNUNET_CRYPTO_PublicKey *identity,
+                    const struct GNUNET_RECLAIM_Attribute *attribute)
+{
+  GNUNET_assert(cls);
+
+  struct GNUNET_CHAT_AttributeProcess *attributes = (
+    (struct GNUNET_CHAT_AttributeProcess*) cls
+  );
+
+  if (! attributes->name)
+  {
+    if (attributes->iter)
+      GNUNET_RECLAIM_get_attributes_stop(attributes->iter);
+
+    attributes->iter = NULL;
+    return;
+  }
+
+  struct GNUNET_CHAT_Handle *handle = attributes->handle;
+
+  if (0 == strcmp(attribute->name, attributes->name))
+  {
+    GNUNET_free(attributes->name);
+    attributes->name = NULL;
+
+    const struct GNUNET_CRYPTO_PrivateKey *key = handle_get_key(
+      handle
+    );
+
+    const struct GNUNET_CRYPTO_PublicKey *pubkey = contact_get_key(
+      attributes->contact
+    );
+
+    if (attributes->iter)
+      GNUNET_RECLAIM_get_attributes_stop(attributes->iter);
+
+    attributes->iter = NULL;
+
+    struct GNUNET_RECLAIM_AttributeList *attrs;
+    attrs = GNUNET_new (struct GNUNET_RECLAIM_AttributeList);
+
+    if (attrs)
+      GNUNET_RECLAIM_attribute_list_add(
+        attrs,
+        attribute->name,
+        &(attribute->credential),
+        attribute->type,
+        attribute->data,
+        attribute->data_size
+      );
+
+    if ((key) && (pubkey) && (attrs))
+      attributes->op = GNUNET_RECLAIM_ticket_issue(
+        handle->reclaim,
+        key,
+        pubkey,
+        attrs,
+        cb_issue_ticket,
+        attributes
+      );
+    
+    if (attrs)
+      GNUNET_RECLAIM_attribute_list_destroy(attrs);
+    
+    return;
+  }
+
   if (attributes->iter)
     GNUNET_RECLAIM_get_attributes_next(attributes->iter);
 }
+
+void
+cb_task_finish_iterate_ticket (void *cls)
+{
+  GNUNET_assert(cls);
+
+  struct GNUNET_CHAT_TicketProcess *tickets = (
+    (struct GNUNET_CHAT_TicketProcess*) cls
+  );
+
+  struct GNUNET_CHAT_Handle *handle = tickets->handle;
+
+  if (tickets->iter)
+    GNUNET_RECLAIM_ticket_iteration_stop (tickets->iter);
+
+  if (tickets->name)
+    GNUNET_free(tickets->name);
+
+  GNUNET_CONTAINER_DLL_remove(
+    handle->tickets_head,
+    handle->tickets_tail,
+    tickets
+  );
+
+  GNUNET_free(tickets);
+}
+
+void
+cb_task_error_iterate_ticket (void *cls)
+{
+  GNUNET_assert(cls);
+
+  struct GNUNET_CHAT_TicketProcess *tickets = (
+    (struct GNUNET_CHAT_TicketProcess*) cls
+  );
+
+  handle_send_internal_message(
+    tickets->handle,
+    NULL,
+    GNUNET_CHAT_FLAG_WARNING,
+    "Ticket iteration failed!"
+  );
+
+  cb_task_finish_iterate_ticket(cls);
+}
+
+void
+cont_revoke_ticket (void *cls,
+                    int32_t success,
+                    const char *emsg)
+{
+  GNUNET_assert(cls);
+
+  struct GNUNET_CHAT_TicketProcess *tickets = (
+    (struct GNUNET_CHAT_TicketProcess*) cls
+  );
+
+  struct GNUNET_CHAT_Handle *handle = tickets->handle;
+
+  if (success == GNUNET_SYSERR)
+    handle_send_internal_message(
+      handle,
+      NULL,
+      GNUNET_CHAT_FLAG_WARNING,
+      emsg
+    );
+  
+  GNUNET_CONTAINER_DLL_remove(
+    handle->tickets_head,
+    handle->tickets_tail,
+    tickets
+  );
+
+  GNUNET_free(tickets);
+}
+
+void
+cb_consume_ticket_check (void *cls,
+                         const struct GNUNET_CRYPTO_PublicKey *identity,
+                         const struct GNUNET_RECLAIM_Attribute *attribute,
+                         const struct GNUNET_RECLAIM_Presentation *presentation)
+{
+  GNUNET_assert(cls);
+
+  struct GNUNET_CHAT_TicketProcess *tickets = (
+    (struct GNUNET_CHAT_TicketProcess*) cls
+  );
+
+  if ((!identity) && (!attribute) && (!presentation))
+  {
+    tickets->op = NULL;
+
+    struct GNUNET_CHAT_Handle *handle = tickets->handle;
+
+    const struct GNUNET_CRYPTO_PrivateKey *key = handle_get_key(
+      handle
+    );
+
+    if (tickets->name)
+    {
+      GNUNET_free(tickets->name);
+      tickets->name = NULL;
+    }
+    else if (!key)
+      tickets->op = GNUNET_RECLAIM_ticket_revoke(
+        handle->reclaim,
+        key,
+        tickets->ticket,
+        cont_revoke_ticket,
+        tickets
+      );
+    
+    if (tickets->ticket)
+      GNUNET_free(tickets->ticket);
+
+    tickets->ticket = NULL;
+
+    if (tickets->op)
+      return;
+
+    GNUNET_CONTAINER_DLL_remove(
+      handle->tickets_head,
+      handle->tickets_tail,
+      tickets
+    );
+
+    GNUNET_free(tickets);
+  }
+
+  if ((!attribute) || (! tickets->name) || 
+      (0 != strcmp(tickets->name, attribute->name)))
+    return;
+
+  if (tickets->name)
+    GNUNET_free(tickets->name);
+
+  tickets->name = NULL;
+}
+
+void
+cb_iterate_ticket_check (void *cls,
+                         const struct GNUNET_RECLAIM_Ticket *ticket)
+{
+  GNUNET_assert(cls);
+
+  struct GNUNET_CHAT_TicketProcess *tickets = (
+    (struct GNUNET_CHAT_TicketProcess*) cls
+  );
+
+  struct GNUNET_CHAT_Handle *handle = tickets->handle;
+
+  const struct GNUNET_CRYPTO_PrivateKey *key = handle_get_key(
+    handle
+  );
+
+  const struct GNUNET_CRYPTO_PublicKey *pubkey = contact_get_key(
+    tickets->contact
+  );
+
+  if ((!key) || (!pubkey))
+    return;
+
+  if (0 != GNUNET_memcmp(pubkey, &(ticket->audience)))
+    goto skip_ticket;
+
+  struct GNUNET_CHAT_TicketProcess *tick = GNUNET_new(
+    struct GNUNET_CHAT_TicketProcess
+  );
+
+  if (!tick)
+    return;
+
+  memset(tick, 0, sizeof (struct GNUNET_CHAT_TicketProcess));
+
+  tick->handle = handle;
+  tick->contact = tickets->contact;
+
+  if (tickets->name)
+    tick->name = GNUNET_strdup (tickets->name);
+
+  tick->ticket = GNUNET_new (struct GNUNET_RECLAIM_Ticket);
+
+  if (tick->ticket)
+    GNUNET_memcpy (
+      tick->ticket,
+      ticket,
+      sizeof (struct GNUNET_RECLAIM_Ticket)
+    );
+
+  tick->callback = tickets->callback;
+  tick->closure = tickets->closure;
+
+  tick->op = GNUNET_RECLAIM_ticket_consume(
+    handle->reclaim,
+    key,
+    ticket,
+    cb_consume_ticket_check,
+    tick
+  );
+
+  GNUNET_CONTAINER_DLL_insert_tail(
+    handle->tickets_head,
+    handle->tickets_tail,
+    tick
+  );
+
+skip_ticket:
+  if (tickets->iter)
+    GNUNET_RECLAIM_ticket_iteration_next (tickets->iter);
+}
+
+void
+cb_consume_ticket (void *cls,
+                   const struct GNUNET_CRYPTO_PublicKey *identity,
+                   const struct GNUNET_RECLAIM_Attribute *attribute,
+                   const struct GNUNET_RECLAIM_Presentation *presentation)
+{
+  GNUNET_assert(cls);
+
+  struct GNUNET_CHAT_TicketProcess *tickets = (
+    (struct GNUNET_CHAT_TicketProcess*) cls
+  );
+
+  if ((!identity) && (!attribute) && (!presentation))
+  {
+    struct GNUNET_CHAT_Handle *handle = tickets->handle;
+
+    GNUNET_CONTAINER_DLL_remove(
+      handle->tickets_head,
+      handle->tickets_tail,
+      tickets
+    );
+
+    GNUNET_free(tickets);
+    return;
+  }
+
+  if (!attribute)
+    return;
+
+  char *value = GNUNET_RECLAIM_attribute_value_to_string(
+    attribute->type,
+    attribute->data,
+    attribute->data_size
+  );
+
+  if (tickets->callback)
+    tickets->callback(tickets->closure, tickets->contact, attribute->name, value);
+
+  if (value)
+    GNUNET_free (value);
+}
+
+void
+cb_iterate_ticket (void *cls,
+                   const struct GNUNET_RECLAIM_Ticket *ticket)
+{
+  GNUNET_assert(cls);
+
+  struct GNUNET_CHAT_TicketProcess *tickets = (
+    (struct GNUNET_CHAT_TicketProcess*) cls
+  );
+
+  struct GNUNET_CHAT_Handle *handle = tickets->handle;
+
+  const struct GNUNET_CRYPTO_PrivateKey *key = handle_get_key(
+    handle
+  );
+
+  const struct GNUNET_CRYPTO_PublicKey *pubkey = contact_get_key(
+    tickets->contact
+  );
+
+  if ((!key) || (!pubkey))
+    return;
+
+  if (0 != GNUNET_memcmp(pubkey, &(ticket->audience)))
+    goto skip_ticket;
+
+  struct GNUNET_CHAT_TicketProcess *tick = GNUNET_new(
+    struct GNUNET_CHAT_TicketProcess
+  );
+
+  if (!tick)
+    return;
+
+  memset(tick, 0, sizeof (struct GNUNET_CHAT_TicketProcess));
+
+  tick->handle = handle;
+  tick->contact = tickets->contact;
+
+  tick->callback = tickets->callback;
+  tick->closure = tickets->closure;
+
+  tick->op = GNUNET_RECLAIM_ticket_consume(
+    handle->reclaim,
+    key,
+    ticket,
+    cb_consume_ticket,
+    tick
+  );
+
+  GNUNET_CONTAINER_DLL_insert_tail(
+    handle->tickets_head,
+    handle->tickets_tail,
+    tick
+  );
+
+skip_ticket:
+  if (tickets->iter)
+    GNUNET_RECLAIM_ticket_iteration_next (tickets->iter);
+}