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 */