RECLAIM: Towards -sql

1 files changed, 55 insertions, 2 deletions

diff --git a/src/reclaim/gnunet-reclaim.c b/src/reclaim/gnunet-reclaim.c
index df6ebc66f..c36955a04 100644
--- a/src/reclaim/gnunet-reclaim.c
+++ b/src/reclaim/gnunet-reclaim.c
@@ -77,6 +77,11 @@ static char* type_str;
 static char* revoke_ticket;
 
 /**
+ * Ticket listing
+ */
+static int list_tickets;
+
+/**
  * Ego name
  */
 static char* ego_name;
@@ -102,6 +107,11 @@ static struct GNUNET_RECLAIM_Operation *reclaim_op;
 static struct GNUNET_RECLAIM_AttributeIterator *attr_iterator;
 
 /**
+ * Ticket iterator
+ */
+static struct GNUNET_RECLAIM_TicketIterator *ticket_iterator;
+
+/**
  * Master ABE key
  */
 static struct GNUNET_CRYPTO_AbeMasterKey *abe_key;
@@ -156,6 +166,8 @@ do_cleanup(void *cls)
     GNUNET_RECLAIM_cancel (reclaim_op);
   if (NULL != attr_iterator)
     GNUNET_RECLAIM_get_attributes_stop (attr_iterator);
+  if (NULL != ticket_iterator)
+    GNUNET_RECLAIM_ticket_iteration_stop (ticket_iterator);
   if (NULL != reclaim_handle)
     GNUNET_RECLAIM_disconnect (reclaim_handle);
   if (NULL != identity_handle)
@@ -223,6 +235,30 @@ process_attrs (void *cls,
            attr->name, value_str, attr_type, attr->version, attr->id);
 }
 
+static void
+ticket_iter_err (void *cls)
+{
+  ticket_iterator = NULL;
+  fprintf (stderr,
+           "Failed to iterate over tickets\n");
+  cleanup_task = GNUNET_SCHEDULER_add_now (&do_cleanup, NULL);
+}
+
+static void
+ticket_iter_fin (void *cls)
+{
+  ticket_iterator = NULL;
+  cleanup_task = GNUNET_SCHEDULER_add_now (&do_cleanup, NULL);
+}
+
+static void
+ticket_iter (void *cls,
+             const struct GNUNET_RECLAIM_Ticket *ticket)
+{
+  fprintf (stdout,
+           "Found ticket\n");
+  GNUNET_RECLAIM_ticket_iteration_next (ticket_iterator);
+}
 
 static void
 iter_error (void *cls)
@@ -396,7 +432,7 @@ iter_cb (void *cls,
 }
 
 static void
-start_get_attributes ()
+start_process ()
 {
   if (NULL == pkey)
   {
@@ -406,6 +442,19 @@ start_get_attributes ()
     return;
   }
 
+  if (list_tickets)
+  {
+    ticket_iterator = GNUNET_RECLAIM_ticket_iteration_start (reclaim_handle,
+                                                             pkey,
+                                                             &ticket_iter_err,
+                                                             NULL,
+                                                             &ticket_iter,
+                                                             NULL,
+                                                             &ticket_iter_fin,
+                                                             NULL);
+    return;
+  }
+
   if (NULL != rp)
     GNUNET_CRYPTO_ecdsa_public_key_from_string (rp,
                                                 strlen (rp),
@@ -446,7 +495,7 @@ ego_cb (void *cls,
   if (NULL == name) {
     if (GNUNET_YES == init) {
       init = GNUNET_NO;
-      start_get_attributes();
+      start_process ();
     }
     return;
   }
@@ -548,6 +597,10 @@ main(int argc, char *const argv[])
                                  "TYPE",
                                  gettext_noop ("Type of attribute"),
                                  &type_str),
+    GNUNET_GETOPT_option_flag ('T',
+                               "tickets",
+                               gettext_noop ("List tickets of ego"),
+                               &list_tickets),
     GNUNET_GETOPT_option_relative_time ('E',
                                         "expiration",
                                         "INTERVAL",