diff options
Diffstat (limited to 'src')
-rw-r--r-- | src/exchangedb/test_exchangedb.c | 68 |
1 files changed, 63 insertions, 5 deletions
diff --git a/src/exchangedb/test_exchangedb.c b/src/exchangedb/test_exchangedb.c index fc92ab3d0..974290ee3 100644 --- a/src/exchangedb/test_exchangedb.c +++ b/src/exchangedb/test_exchangedb.c @@ -65,6 +65,46 @@ static struct TALER_EXCHANGEDB_Plugin *plugin; /** + * Callback that should never be called. + */ +static void +dead_prepare_cb (void *cls, + unsigned long long rowid, + const char *wire_method, + const char *buf, + size_t buf_size) +{ + GNUNET_assert (0); +} + + +/** + * Callback that is called with wire prepare data + * and then marks it as finished. + */ +static void +mark_prepare_cb (void *cls, + unsigned long long rowid, + const char *wire_method, + const char *buf, + size_t buf_size) +{ + struct TALER_EXCHANGEDB_Session *session = cls; + + GNUNET_assert (11 == buf_size); + GNUNET_assert (0 == strcasecmp (wire_method, + "testcase")); + GNUNET_assert (0 == memcmp (buf, + "hello world", + buf_size)); + GNUNET_break (GNUNET_OK == + plugin->wire_prepare_data_mark_finished (plugin->cls, + session, + rowid)); +} + + +/** * Test API relating to persisting the wire plugins preparation data. * * @param session database session to use for the test @@ -73,12 +113,30 @@ static struct TALER_EXCHANGEDB_Plugin *plugin; static int test_wire_prepare (struct TALER_EXCHANGEDB_Session *session) { - /* - FIXME #4401: test: wire_prepare_data_insert - FIXME #4401: test: wire_prepare_data_mark_finished - FIXME #4401: test: wire_prepare_data_get - */ + FAILIF (GNUNET_NO != + plugin->wire_prepare_data_get (plugin->cls, + session, + &dead_prepare_cb, + NULL)); + FAILIF (GNUNET_OK != + plugin->wire_prepare_data_insert (plugin->cls, + session, + "testcase", + "hello world", + 11)); + FAILIF (GNUNET_OK != + plugin->wire_prepare_data_get (plugin->cls, + session, + &mark_prepare_cb, + session)); + FAILIF (GNUNET_NO != + plugin->wire_prepare_data_get (plugin->cls, + session, + &dead_prepare_cb, + NULL)); return GNUNET_OK; + drop: + return GNUNET_SYSERR; } |