work on public interface implementation

1 files changed, 90 insertions, 2 deletions

diff --git a/brandt.c b/brandt.c
index b175c3e..d71e7c9 100644
--- a/brandt.c
+++ b/brandt.c
@@ -50,6 +50,94 @@ BRANDT_init (struct GNUNET_CRYPTO_EccDlogContext *dlogctx)
 
 
 static void
+start_auction (void *arg)
+{
+        struct BRANDT_Auction *ad = (struct BRANDT_Auction *)arg;
+
+        /* \todo: broadcast start message to all participants */
+}
+
+
+struct BRANDT_Auction *
+BRANDT_new (BRANDT_CbBroadcast broadcast,
+            BRANDT_CbResult    result,
+            void               *auction_closure,
+            void               **auction_data,
+            size_t             *auction_data_len,
+            struct GNUNET_TIME_Absolute time_start,
+            struct GNUNET_TIME_Relative time_round,
+            uint16_t           num_prices,
+            uint16_t           m,
+            int                outcome_public)
+{
+        struct BRANDT_Auction *ret;
+
+        ret = GNUNET_new (struct BRANDT_Auction);
+
+        ret->time_start = time_start;
+        ret->time_round = time_round;
+
+        ret->k = num_prices;
+        ret->m = m;
+        ret->outcome_public = outcome_public;
+
+        /* we are the seller */
+        ret->seller_mode = 1;
+
+        /* interface with application */
+        ret->closure = auction_closure;
+        ret->bcast = broadcast;
+        ret->result = result;
+
+        ret->cur_round = msg_join;
+        ret->round_progress = gcry_mpi_new (256);
+
+        /* \todo: store returned task somewhere to cancel it on shutdown */
+        GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_absolute_get_remaining (time_start),
+                                      &start_auction,
+                                      ret);
+
+        return ret;
+}
+
+
+struct BRANDT_Auction *
+BRANDT_join (BRANDT_CbBroadcast broadcast,
+             BRANDT_CbUnicast   unicast,
+             BRANDT_CbResult    result,
+             void               *auction_closure,
+             const void         *auction_data,
+             size_t             auction_data_len)
+{
+        struct BRANDT_Auction *ret;
+        struct BRANDT_DescrP *desc = (struct BRANDT_DescrP *)auction_data;
+
+        ret = GNUNET_new (struct BRANDT_Auction);
+
+        ret->time_start = GNUNET_TIME_absolute_ntoh(desc->time_start);
+        ret->time_round = GNUNET_TIME_relative_ntoh(desc->time_round);
+
+        ret->k = ntohs(desc->k);
+        ret->m = ntohs(desc->m);
+        ret->outcome_public = ntohs(desc->outcome_public);
+
+        /* we are the seller */
+        ret->seller_mode = 0;
+
+        /* interface with application */
+        ret->closure = auction_closure;
+        ret->bcast = broadcast;
+        ret->ucast = unicast;
+        ret->result = result;
+
+        ret->cur_round = msg_join;
+        ret->round_progress = gcry_mpi_new (256);
+
+        return ret;
+}
+
+
+static void
 advance_round (struct BRANDT_Auction *auction, enum auction_type atype, enum outcome_type outcome)
 {
         unsigned char *buf;
@@ -95,8 +183,8 @@ BRANDT_got_message (struct BRANDT_Auction *auction,
         enum outcome_type         outcome;
         enum rounds round = auction->cur_round;
 
-        atype = auction->desc->m > 0 ? auction_mPlusFirstPrice : auction_firstPrice;
-        outcome = auction->desc->outcome_public ? outcome_public : outcome_private;
+        atype = auction->m > 0 ? auction_mPlusFirstPrice : auction_firstPrice;
+        outcome = auction->outcome_public ? outcome_public : outcome_private;
 
         /** \todo: cache out of order messages */