summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/wire/plugin_wire_test.c41
1 files changed, 36 insertions, 5 deletions
diff --git a/src/wire/plugin_wire_test.c b/src/wire/plugin_wire_test.c
index 7940b4775..8a6f98ea2 100644
--- a/src/wire/plugin_wire_test.c
+++ b/src/wire/plugin_wire_test.c
@@ -226,7 +226,9 @@ test_amount_round (void *cls,
/**
- * Check if the given wire format JSON object is correctly formatted
+ * Check if the given wire format JSON object is correctly formatted.
+ * Right now, the only thing we require is a field
+ * "account_number" which must contain a positive 53-bit integer.
*
* @param wire the JSON wire format object
* @return #GNUNET_YES if correctly formatted; #GNUNET_NO if not
@@ -234,8 +236,25 @@ test_amount_round (void *cls,
static int
test_wire_validate (const json_t *wire)
{
- GNUNET_break (0); /* FIXME: we still need to define the
- proper wire format for 'test' */
+ json_error_t error;
+ json_int_t account_no;
+
+ if (0 !=
+ json_unpack_ex ((json_t *) wire,
+ &error,
+ 0,
+ "{s:I}",
+ "account_number", &account_no))
+ {
+ GNUNET_break (0);
+ return GNUNET_SYSERR;
+ }
+ if ( (account_no < 0) ||
+ (account_no > (1LL << 53)) )
+ {
+ GNUNET_break (0);
+ return GNUNET_SYSERR;
+ }
return GNUNET_YES;
}
@@ -427,7 +446,9 @@ test_execute_wire_transfer (void *cls,
struct TestClosure *tc = cls;
struct TALER_WIRE_ExecuteHandle *eh;
json_t *wire;
+ json_error_t error;
struct TALER_Amount amount;
+ json_int_t account_no;
struct BufFormatP bf;
if ( (buf_size <= sizeof (struct BufFormatP)) ||
@@ -449,16 +470,26 @@ test_execute_wire_transfer (void *cls,
GNUNET_break (0);
return NULL;
}
-
GNUNET_assert (GNUNET_YES ==
test_wire_validate (wire));
+ if (0 !=
+ json_unpack_ex (wire,
+ &error,
+ 0,
+ "{s:I}",
+ "account_number", &account_no))
+ {
+ GNUNET_break (0);
+ return NULL;
+ }
+
eh = GNUNET_new (struct TALER_WIRE_ExecuteHandle);
eh->cc = cc;
eh->cc_cls = cc_cls;
eh->aaih = TALER_BANK_admin_add_incoming (tc->bank,
&bf.wtid,
&amount,
- wire,
+ (uint64_t) account_no,
&execute_cb,
eh);
json_decref (wire);