summaryrefslogtreecommitdiff
path: root/src/exchangedb/lrbt_callbacks.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2022-06-01 23:03:40 +0200
committerChristian Grothoff <christian@grothoff.org>2022-06-01 23:03:49 +0200
commit00c68e0a04ae25f533e261547cf0847b4ae0de06 (patch)
tree34a968f43aebc27370b2744a474c6fe1abe6362e /src/exchangedb/lrbt_callbacks.c
parentf86eead6d6abe56b772b60c2f4a83a2a40bf3bd8 (diff)
downloadexchange-00c68e0a04ae25f533e261547cf0847b4ae0de06.tar.gz
exchange-00c68e0a04ae25f533e261547cf0847b4ae0de06.tar.bz2
exchange-00c68e0a04ae25f533e261547cf0847b4ae0de06.zip
-work on SQL for P2P table replication
Diffstat (limited to 'src/exchangedb/lrbt_callbacks.c')
-rw-r--r--src/exchangedb/lrbt_callbacks.c31
1 files changed, 20 insertions, 11 deletions
diff --git a/src/exchangedb/lrbt_callbacks.c b/src/exchangedb/lrbt_callbacks.c
index b621b7b00..7050199e5 100644
--- a/src/exchangedb/lrbt_callbacks.c
+++ b/src/exchangedb/lrbt_callbacks.c
@@ -1498,7 +1498,7 @@ lrbt_cb_table_purse_requests (void *cls,
{
struct GNUNET_PQ_ResultSpec rs[] = {
GNUNET_PQ_result_spec_uint64 (
- "extension_details_serial_id",
+ "purse_requests_serial_id",
&td.serial),
GNUNET_PQ_result_spec_auto_from_type (
"purse_pub",
@@ -1570,8 +1570,11 @@ lrbt_cb_table_purse_merges (void *cls,
{
struct GNUNET_PQ_ResultSpec rs[] = {
GNUNET_PQ_result_spec_uint64 (
- "extension_details_serial_id",
+ "purse_merge_request_serial_id",
&td.serial),
+ GNUNET_PQ_result_spec_uint64 (
+ "partner_serial_id",
+ &td.details.purse_merges.partner_serial_id),
GNUNET_PQ_result_spec_auto_from_type (
"reserve_pub",
&td.details.purse_merges.reserve_pub),
@@ -1582,7 +1585,7 @@ lrbt_cb_table_purse_merges (void *cls,
"merge_sig",
&td.details.purse_merges.merge_sig),
GNUNET_PQ_result_spec_timestamp (
- "purse_expiration",
+ "merge_timestamp",
&td.details.purse_merges.merge_timestamp),
GNUNET_PQ_result_spec_end
};
@@ -1625,8 +1628,11 @@ lrbt_cb_table_purse_deposits (void *cls,
{
struct GNUNET_PQ_ResultSpec rs[] = {
GNUNET_PQ_result_spec_uint64 (
- "extension_details_serial_id",
+ "purse_deposit_serial_id",
&td.serial),
+ GNUNET_PQ_result_spec_uint64 (
+ "partner_serial_id",
+ &td.details.purse_deposits.partner_serial_id),
GNUNET_PQ_result_spec_auto_from_type (
"purse_pub",
&td.details.purse_deposits.purse_pub),
@@ -1679,7 +1685,7 @@ lrbt_cb_table_account_merges (void *cls,
{
struct GNUNET_PQ_ResultSpec rs[] = {
GNUNET_PQ_result_spec_uint64 (
- "extension_details_serial_id",
+ "account_merge_request_serial_id",
&td.serial),
GNUNET_PQ_result_spec_auto_from_type (
"reserve_pub",
@@ -1731,7 +1737,7 @@ lrbt_cb_table_history_requests (void *cls,
{
struct GNUNET_PQ_ResultSpec rs[] = {
GNUNET_PQ_result_spec_uint64 (
- "extension_details_serial_id",
+ "history_request_serial_id",
&td.serial),
GNUNET_PQ_result_spec_auto_from_type (
"reserve_pub",
@@ -1783,7 +1789,7 @@ lrbt_cb_table_close_requests (void *cls,
{
struct GNUNET_PQ_ResultSpec rs[] = {
GNUNET_PQ_result_spec_uint64 (
- "extension_details_serial_id",
+ "close_request_serial_id",
&td.serial),
GNUNET_PQ_result_spec_auto_from_type (
"reserve_pub",
@@ -1835,7 +1841,7 @@ lrbt_cb_table_wads_out (void *cls,
{
struct GNUNET_PQ_ResultSpec rs[] = {
GNUNET_PQ_result_spec_uint64 (
- "extension_details_serial_id",
+ "wad_out_serial_id",
&td.serial),
GNUNET_PQ_result_spec_auto_from_type (
"wad_id",
@@ -1890,7 +1896,7 @@ lrbt_cb_table_wads_out_entries (void *cls,
{
struct GNUNET_PQ_ResultSpec rs[] = {
GNUNET_PQ_result_spec_uint64 (
- "extension_details_serial_id",
+ "wad_out_entry_serial_id",
&td.serial),
GNUNET_PQ_result_spec_auto_from_type (
"reserve_pub",
@@ -1911,6 +1917,9 @@ lrbt_cb_table_wads_out_entries (void *cls,
"amount_with_fee",
&td.details.wads_out_entries.amount_with_fee),
TALER_PQ_RESULT_SPEC_AMOUNT (
+ "wad_fee",
+ &td.details.wads_out_entries.wad_fee),
+ TALER_PQ_RESULT_SPEC_AMOUNT (
"deposit_fees",
&td.details.wads_out_entries.deposit_fees),
GNUNET_PQ_result_spec_auto_from_type (
@@ -1960,7 +1969,7 @@ lrbt_cb_table_wads_in (void *cls,
{
struct GNUNET_PQ_ResultSpec rs[] = {
GNUNET_PQ_result_spec_uint64 (
- "extension_details_serial_id",
+ "wad_in_serial_id",
&td.serial),
GNUNET_PQ_result_spec_auto_from_type (
"wad_id",
@@ -2015,7 +2024,7 @@ lrbt_cb_table_wads_in_entries (void *cls,
{
struct GNUNET_PQ_ResultSpec rs[] = {
GNUNET_PQ_result_spec_uint64 (
- "extension_details_serial_id",
+ "wad_in_entry_serial_id",
&td.serial),
GNUNET_PQ_result_spec_auto_from_type (
"reserve_pub",