-more db logic refactoring
This commit is contained in:
Christian Grothoff
parent
7e5c6a7e46
commit
b8dada3403
@ -23,6 +23,7 @@
|
|||||||
* inlined into the plugin
|
* inlined into the plugin
|
||||||
* @author Christian Grothoff
|
* @author Christian Grothoff
|
||||||
*/
|
*/
|
||||||
|
#include "pg_helper.h"
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -67,6 +68,33 @@ irbt_cb_table_denominations (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_denominations",
|
||||||
|
"INSERT INTO denominations"
|
||||||
|
"(denominations_serial"
|
||||||
|
",denom_pub_hash"
|
||||||
|
",denom_type"
|
||||||
|
",age_mask"
|
||||||
|
",denom_pub"
|
||||||
|
",master_sig"
|
||||||
|
",valid_from"
|
||||||
|
",expire_withdraw"
|
||||||
|
",expire_deposit"
|
||||||
|
",expire_legal"
|
||||||
|
",coin_val"
|
||||||
|
",coin_frac"
|
||||||
|
",fee_withdraw_val"
|
||||||
|
",fee_withdraw_frac"
|
||||||
|
",fee_deposit_val"
|
||||||
|
",fee_deposit_frac"
|
||||||
|
",fee_refresh_val"
|
||||||
|
",fee_refresh_frac"
|
||||||
|
",fee_refund_val"
|
||||||
|
",fee_refund_frac"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6, $7, $8, $9, $10,"
|
||||||
|
" $11, $12, $13, $14, $15, $16, $17, $18, $19, $20);");
|
||||||
|
|
||||||
TALER_denom_pub_hash (
|
TALER_denom_pub_hash (
|
||||||
&td->details.denominations.denom_pub,
|
&td->details.denominations.denom_pub,
|
||||||
&denom_hash);
|
&denom_hash);
|
||||||
@ -97,6 +125,14 @@ irbt_cb_table_denomination_revocations (
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_denomination_revocations",
|
||||||
|
"INSERT INTO denomination_revocations"
|
||||||
|
"(denom_revocations_serial_id"
|
||||||
|
",master_sig"
|
||||||
|
",denominations_serial"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_denomination_revocations",
|
"insert_into_table_denomination_revocations",
|
||||||
params);
|
params);
|
||||||
@ -122,6 +158,14 @@ irbt_cb_table_wire_targets (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_wire_targets",
|
||||||
|
"INSERT INTO wire_targets"
|
||||||
|
"(wire_target_serial_id"
|
||||||
|
",wire_target_h_payto"
|
||||||
|
",payto_uri"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3);");
|
||||||
TALER_payto_hash (
|
TALER_payto_hash (
|
||||||
td->details.wire_targets.payto_uri,
|
td->details.wire_targets.payto_uri,
|
||||||
&payto_hash);
|
&payto_hash);
|
||||||
@ -207,6 +251,15 @@ irbt_cb_table_reserves (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_reserves",
|
||||||
|
"INSERT INTO reserves"
|
||||||
|
"(reserve_uuid"
|
||||||
|
",reserve_pub"
|
||||||
|
",expiration_date"
|
||||||
|
",gc_date"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_reserves",
|
"insert_into_table_reserves",
|
||||||
params);
|
params);
|
||||||
@ -237,6 +290,19 @@ irbt_cb_table_reserves_in (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_reserves_in",
|
||||||
|
"INSERT INTO reserves_in"
|
||||||
|
"(reserve_in_serial_id"
|
||||||
|
",wire_reference"
|
||||||
|
",credit_val"
|
||||||
|
",credit_frac"
|
||||||
|
",wire_source_h_payto"
|
||||||
|
",exchange_account_section"
|
||||||
|
",execution_date"
|
||||||
|
",reserve_pub"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6, $7, $8);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_reserves_in",
|
"insert_into_table_reserves_in",
|
||||||
params);
|
params);
|
||||||
@ -362,6 +428,20 @@ irbt_cb_table_reserves_close (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_reserves_close",
|
||||||
|
"INSERT INTO reserves_close"
|
||||||
|
"(close_uuid"
|
||||||
|
",execution_date"
|
||||||
|
",wtid"
|
||||||
|
",wire_target_h_payto"
|
||||||
|
",amount_val"
|
||||||
|
",amount_frac"
|
||||||
|
",closing_fee_val"
|
||||||
|
",closing_fee_frac"
|
||||||
|
",reserve_pub"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6, $7, $8, $9);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_reserves_close",
|
"insert_into_table_reserves_close",
|
||||||
params);
|
params);
|
||||||
@ -397,6 +477,20 @@ irbt_cb_table_reserves_out (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_reserves_out",
|
||||||
|
"INSERT INTO reserves_out"
|
||||||
|
"(reserve_out_serial_id"
|
||||||
|
",h_blind_ev"
|
||||||
|
",denominations_serial"
|
||||||
|
",denom_sig"
|
||||||
|
",reserve_uuid"
|
||||||
|
",reserve_sig"
|
||||||
|
",execution_date"
|
||||||
|
",amount_with_fee_val"
|
||||||
|
",amount_with_fee_frac"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6, $7, $8, $9);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_reserves_out",
|
"insert_into_table_reserves_out",
|
||||||
params);
|
params);
|
||||||
@ -423,6 +517,17 @@ irbt_cb_table_auditors (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_auditors",
|
||||||
|
"INSERT INTO auditors"
|
||||||
|
"(auditor_uuid"
|
||||||
|
",auditor_pub"
|
||||||
|
",auditor_name"
|
||||||
|
",auditor_url"
|
||||||
|
",is_active"
|
||||||
|
",last_change"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_auditors",
|
"insert_into_table_auditors",
|
||||||
params);
|
params);
|
||||||
@ -449,6 +554,15 @@ irbt_cb_table_auditor_denom_sigs (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_auditor_denom_sigs",
|
||||||
|
"INSERT INTO auditor_denom_sigs"
|
||||||
|
"(auditor_denom_serial"
|
||||||
|
",auditor_uuid"
|
||||||
|
",denominations_serial"
|
||||||
|
",auditor_sig"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_auditor_denom_sigs",
|
"insert_into_table_auditor_denom_sigs",
|
||||||
params);
|
params);
|
||||||
@ -480,6 +594,17 @@ irbt_cb_table_exchange_sign_keys (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_exchange_sign_keys",
|
||||||
|
"INSERT INTO exchange_sign_keys"
|
||||||
|
"(esk_serial"
|
||||||
|
",exchange_pub"
|
||||||
|
",master_sig"
|
||||||
|
",valid_from"
|
||||||
|
",expire_sign"
|
||||||
|
",expire_legal"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_exchange_sign_keys",
|
"insert_into_table_exchange_sign_keys",
|
||||||
params);
|
params);
|
||||||
@ -504,6 +629,14 @@ irbt_cb_table_signkey_revocations (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_signkey_revocations",
|
||||||
|
"INSERT INTO signkey_revocations"
|
||||||
|
"(signkey_revocations_serial_id"
|
||||||
|
",esk_serial"
|
||||||
|
",master_sig"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_signkey_revocations",
|
"insert_into_table_signkey_revocations",
|
||||||
params);
|
params);
|
||||||
@ -531,6 +664,15 @@ irbt_cb_table_known_coins (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_known_coins",
|
||||||
|
"INSERT INTO known_coins"
|
||||||
|
"(known_coin_id"
|
||||||
|
",coin_pub"
|
||||||
|
",denom_sig"
|
||||||
|
",denominations_serial"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_known_coins",
|
"insert_into_table_known_coins",
|
||||||
params);
|
params);
|
||||||
@ -561,6 +703,18 @@ irbt_cb_table_refresh_commitments (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_refresh_commitments",
|
||||||
|
"INSERT INTO refresh_commitments"
|
||||||
|
"(melt_serial_id"
|
||||||
|
",rc"
|
||||||
|
",old_coin_sig"
|
||||||
|
",amount_with_fee_val"
|
||||||
|
",amount_with_fee_frac"
|
||||||
|
",noreveal_index"
|
||||||
|
",old_coin_pub"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6, $7);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_refresh_commitments",
|
"insert_into_table_refresh_commitments",
|
||||||
params);
|
params);
|
||||||
@ -601,6 +755,20 @@ irbt_cb_table_refresh_revealed_coins (
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_refresh_revealed_coins",
|
||||||
|
"INSERT INTO refresh_revealed_coins"
|
||||||
|
"(rrc_serial"
|
||||||
|
",freshcoin_index"
|
||||||
|
",link_sig"
|
||||||
|
",coin_ev"
|
||||||
|
",h_coin_ev"
|
||||||
|
",ev_sig"
|
||||||
|
",ewv"
|
||||||
|
",denominations_serial"
|
||||||
|
",melt_serial_id"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6, $7, $8, $9);");
|
||||||
GNUNET_CRYPTO_hash (td->details.refresh_revealed_coins.coin_ev,
|
GNUNET_CRYPTO_hash (td->details.refresh_revealed_coins.coin_ev,
|
||||||
td->details.refresh_revealed_coins.coin_ev_size,
|
td->details.refresh_revealed_coins.coin_ev_size,
|
||||||
&h_coin_ev);
|
&h_coin_ev);
|
||||||
@ -634,6 +802,15 @@ irbt_cb_table_refresh_transfer_keys (
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_refresh_transfer_keys",
|
||||||
|
"INSERT INTO refresh_transfer_keys"
|
||||||
|
"(rtc_serial"
|
||||||
|
",transfer_pub"
|
||||||
|
",transfer_privs"
|
||||||
|
",melt_serial_id"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_refresh_transfer_keys",
|
"insert_into_table_refresh_transfer_keys",
|
||||||
params);
|
params);
|
||||||
@ -677,6 +854,29 @@ irbt_cb_table_deposits (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_deposits",
|
||||||
|
"INSERT INTO deposits"
|
||||||
|
"(deposit_serial_id"
|
||||||
|
",shard"
|
||||||
|
",known_coin_id"
|
||||||
|
",coin_pub"
|
||||||
|
",amount_with_fee_val"
|
||||||
|
",amount_with_fee_frac"
|
||||||
|
",wallet_timestamp"
|
||||||
|
",exchange_timestamp"
|
||||||
|
",refund_deadline"
|
||||||
|
",wire_deadline"
|
||||||
|
",merchant_pub"
|
||||||
|
",h_contract_terms"
|
||||||
|
",coin_sig"
|
||||||
|
",wire_salt"
|
||||||
|
",wire_target_h_payto"
|
||||||
|
",extension_blocked"
|
||||||
|
",extension_details_serial_id"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6, $7, $8, $9, $10,"
|
||||||
|
" $11, $12, $13, $14, $15, $16, $17);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_deposits",
|
"insert_into_table_deposits",
|
||||||
params);
|
params);
|
||||||
@ -703,6 +903,18 @@ irbt_cb_table_refunds (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_refunds",
|
||||||
|
"INSERT INTO refunds"
|
||||||
|
"(refund_serial_id"
|
||||||
|
",coin_pub"
|
||||||
|
",merchant_sig"
|
||||||
|
",rtransaction_id"
|
||||||
|
",amount_with_fee_val"
|
||||||
|
",amount_with_fee_frac"
|
||||||
|
",deposit_serial_id"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6, $7);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_refunds",
|
"insert_into_table_refunds",
|
||||||
params);
|
params);
|
||||||
@ -731,6 +943,7 @@ irbt_cb_table_wire_out (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_wire_out",
|
"insert_into_table_wire_out",
|
||||||
params);
|
params);
|
||||||
@ -756,6 +969,14 @@ irbt_cb_table_aggregation_tracking (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_aggregation_tracking",
|
||||||
|
"INSERT INTO aggregation_tracking"
|
||||||
|
"(aggregation_serial_id"
|
||||||
|
",deposit_serial_id"
|
||||||
|
",wtid_raw"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_aggregation_tracking",
|
"insert_into_table_aggregation_tracking",
|
||||||
params);
|
params);
|
||||||
@ -784,6 +1005,22 @@ irbt_cb_table_wire_fee (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_wire_fee",
|
||||||
|
"INSERT INTO wire_fee"
|
||||||
|
"(wire_fee_serial"
|
||||||
|
",wire_method"
|
||||||
|
",start_date"
|
||||||
|
",end_date"
|
||||||
|
",wire_fee_val"
|
||||||
|
",wire_fee_frac"
|
||||||
|
",closing_fee_val"
|
||||||
|
",closing_fee_frac"
|
||||||
|
",wad_fee_val"
|
||||||
|
",wad_fee_frac"
|
||||||
|
",master_sig"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_wire_fee",
|
"insert_into_table_wire_fee",
|
||||||
params);
|
params);
|
||||||
@ -828,6 +1065,27 @@ irbt_cb_table_global_fee (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_global_fee",
|
||||||
|
"INSERT INTO global_fee"
|
||||||
|
"(global_fee_serial"
|
||||||
|
",start_date"
|
||||||
|
",end_date"
|
||||||
|
",history_fee_val"
|
||||||
|
",history_fee_frac"
|
||||||
|
",kyc_fee_val"
|
||||||
|
",kyc_fee_frac"
|
||||||
|
",account_fee_val"
|
||||||
|
",account_fee_frac"
|
||||||
|
",purse_fee_val"
|
||||||
|
",purse_fee_frac"
|
||||||
|
",purse_timeout"
|
||||||
|
",kyc_timeout"
|
||||||
|
",history_expiration"
|
||||||
|
",purse_account_limit"
|
||||||
|
",master_sig"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15, $16);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_global_fee",
|
"insert_into_table_global_fee",
|
||||||
params);
|
params);
|
||||||
@ -856,6 +1114,19 @@ irbt_cb_table_recoup (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_recoup",
|
||||||
|
"INSERT INTO recoup"
|
||||||
|
"(recoup_uuid"
|
||||||
|
",coin_sig"
|
||||||
|
",coin_blind"
|
||||||
|
",amount_val"
|
||||||
|
",amount_frac"
|
||||||
|
",recoup_timestamp"
|
||||||
|
",coin_pub"
|
||||||
|
",reserve_out_serial_id"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6, $7, $8);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_recoup",
|
"insert_into_table_recoup",
|
||||||
params);
|
params);
|
||||||
@ -886,6 +1157,20 @@ irbt_cb_table_recoup_refresh (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_recoup_refresh",
|
||||||
|
"INSERT INTO recoup_refresh"
|
||||||
|
"(recoup_refresh_uuid"
|
||||||
|
",coin_sig"
|
||||||
|
",coin_blind"
|
||||||
|
",amount_val"
|
||||||
|
",amount_frac"
|
||||||
|
",recoup_timestamp"
|
||||||
|
",known_coin_id"
|
||||||
|
",coin_pub"
|
||||||
|
",rrc_serial"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6, $7, $8, $9);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_recoup_refresh",
|
"insert_into_table_recoup_refresh",
|
||||||
params);
|
params);
|
||||||
@ -911,6 +1196,14 @@ irbt_cb_table_extensions (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_extensions",
|
||||||
|
"INSERT INTO extensions"
|
||||||
|
"(extension_id"
|
||||||
|
",name"
|
||||||
|
",config"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_extensions",
|
"insert_into_table_extensions",
|
||||||
params);
|
params);
|
||||||
@ -937,6 +1230,13 @@ irbt_cb_table_extension_details (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_extension_details",
|
||||||
|
"INSERT INTO extension_details"
|
||||||
|
"(extension_details_serial_id"
|
||||||
|
",extension_options"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_extension_details",
|
"insert_into_table_extension_details",
|
||||||
params);
|
params);
|
||||||
@ -974,6 +1274,24 @@ irbt_cb_table_purse_requests (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_purse_requests",
|
||||||
|
"INSERT INTO purse_requests"
|
||||||
|
"(purse_requests_serial_id"
|
||||||
|
",purse_pub"
|
||||||
|
",merge_pub"
|
||||||
|
",purse_creation"
|
||||||
|
",purse_expiration"
|
||||||
|
",h_contract_terms"
|
||||||
|
",age_limit"
|
||||||
|
",flags"
|
||||||
|
",amount_with_fee_val"
|
||||||
|
",amount_with_fee_frac"
|
||||||
|
",purse_fee_val"
|
||||||
|
",purse_fee_frac"
|
||||||
|
",purse_sig"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_purse_requests",
|
"insert_into_table_purse_requests",
|
||||||
params);
|
params);
|
||||||
@ -997,6 +1315,13 @@ irbt_cb_table_purse_refunds (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_purse_refunds",
|
||||||
|
"INSERT INTO purse_refunds"
|
||||||
|
"(purse_refunds_serial_id"
|
||||||
|
",purse_pub"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_purse_refunds",
|
"insert_into_table_purse_refunds",
|
||||||
params);
|
params);
|
||||||
@ -1024,6 +1349,17 @@ irbt_cb_table_purse_merges (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_purse_merges",
|
||||||
|
"INSERT INTO purse_merges"
|
||||||
|
"(purse_merge_request_serial_id"
|
||||||
|
",partner_serial_id"
|
||||||
|
",reserve_pub"
|
||||||
|
",purse_pub"
|
||||||
|
",merge_sig"
|
||||||
|
",merge_timestamp"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_purse_merges",
|
"insert_into_table_purse_merges",
|
||||||
params);
|
params);
|
||||||
@ -1052,6 +1388,18 @@ irbt_cb_table_purse_deposits (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_purse_deposits",
|
||||||
|
"INSERT INTO purse_deposits"
|
||||||
|
"(purse_deposit_serial_id"
|
||||||
|
",partner_serial_id"
|
||||||
|
",purse_pub"
|
||||||
|
",coin_pub"
|
||||||
|
",amount_with_fee_val"
|
||||||
|
",amount_with_fee_frac"
|
||||||
|
",coin_sig"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6, $7);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_purse_deposits",
|
"insert_into_table_purse_deposits",
|
||||||
params);
|
params);
|
||||||
@ -1059,7 +1407,7 @@ irbt_cb_table_purse_deposits (struct PostgresClosure *pg,
|
|||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Function called with account_mergers records to insert into table.
|
x * Function called with account_mergers records to insert into table.
|
||||||
*
|
*
|
||||||
* @param pg plugin context
|
* @param pg plugin context
|
||||||
* @param td record to insert
|
* @param td record to insert
|
||||||
@ -1108,6 +1456,17 @@ irbt_cb_table_history_requests (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_history_requests",
|
||||||
|
"INSERT INTO history_requests"
|
||||||
|
"(history_request_serial_id"
|
||||||
|
",reserve_pub"
|
||||||
|
",request_timestamp"
|
||||||
|
",reserve_sig"
|
||||||
|
",history_fee_val"
|
||||||
|
",history_fee_frac"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_history_requests",
|
"insert_into_table_history_requests",
|
||||||
params);
|
params);
|
||||||
@ -1137,6 +1496,17 @@ irbt_cb_table_close_requests (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_close_requests",
|
||||||
|
"INSERT INTO close_requests"
|
||||||
|
"(close_request_serial_id"
|
||||||
|
",reserve_pub"
|
||||||
|
",close_timestamp"
|
||||||
|
",reserve_sig"
|
||||||
|
",close_val"
|
||||||
|
",close_frac"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_close_requests",
|
"insert_into_table_close_requests",
|
||||||
params);
|
params);
|
||||||
@ -1162,6 +1532,17 @@ irbt_cb_table_wads_out (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_wads_out",
|
||||||
|
"INSERT INTO wads_out"
|
||||||
|
"(wad_out_serial_id"
|
||||||
|
",wad_id"
|
||||||
|
",partner_serial_id"
|
||||||
|
",amount_val"
|
||||||
|
",amount_frac"
|
||||||
|
",execution_time"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_wads_out",
|
"insert_into_table_wads_out",
|
||||||
params);
|
params);
|
||||||
@ -1205,6 +1586,26 @@ irbt_cb_table_wads_out_entries (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_wad_out_entries",
|
||||||
|
"INSERT INTO wad_out_entries"
|
||||||
|
"(wad_out_entry_serial_id"
|
||||||
|
",wad_out_serial_id"
|
||||||
|
",reserve_pub"
|
||||||
|
",purse_pub"
|
||||||
|
",h_contract"
|
||||||
|
",purse_expiration"
|
||||||
|
",merge_timestamp"
|
||||||
|
",amount_with_fee_val"
|
||||||
|
",amount_with_fee_frac"
|
||||||
|
",wad_fee_val"
|
||||||
|
",wad_fee_frac"
|
||||||
|
",deposit_fees_val"
|
||||||
|
",deposit_fees_frac"
|
||||||
|
",reserve_sig"
|
||||||
|
",purse_sig"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_wads_out_entries",
|
"insert_into_table_wads_out_entries",
|
||||||
params);
|
params);
|
||||||
@ -1230,6 +1631,17 @@ irbt_cb_table_wads_in (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_wads_in",
|
||||||
|
"INSERT INTO wads_in"
|
||||||
|
"(wad_in_serial_id"
|
||||||
|
",wad_id"
|
||||||
|
",origin_exchange_url"
|
||||||
|
",amount_val"
|
||||||
|
",amount_frac"
|
||||||
|
",arrival_time"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_wads_in",
|
"insert_into_table_wads_in",
|
||||||
params);
|
params);
|
||||||
@ -1271,6 +1683,26 @@ irbt_cb_table_wads_in_entries (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_wad_in_entries",
|
||||||
|
"INSERT INTO wad_in_entries"
|
||||||
|
"(wad_in_entry_serial_id"
|
||||||
|
",wad_in_serial_id"
|
||||||
|
",reserve_pub"
|
||||||
|
",purse_pub"
|
||||||
|
",h_contract"
|
||||||
|
",purse_expiration"
|
||||||
|
",merge_timestamp"
|
||||||
|
",amount_with_fee_val"
|
||||||
|
",amount_with_fee_frac"
|
||||||
|
",wad_fee_val"
|
||||||
|
",wad_fee_frac"
|
||||||
|
",deposit_fees_val"
|
||||||
|
",deposit_fees_frac"
|
||||||
|
",reserve_sig"
|
||||||
|
",purse_sig"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_wads_in_entries",
|
"insert_into_table_wads_in_entries",
|
||||||
params);
|
params);
|
||||||
@ -1304,6 +1736,19 @@ irbt_cb_table_profit_drains (struct PostgresClosure *pg,
|
|||||||
GNUNET_PQ_query_param_end
|
GNUNET_PQ_query_param_end
|
||||||
};
|
};
|
||||||
|
|
||||||
|
PREPARE (pg,
|
||||||
|
"insert_into_table_profit_drains",
|
||||||
|
"INSERT INTO profit_drains"
|
||||||
|
"(profit_drain_serial_id"
|
||||||
|
",wtid"
|
||||||
|
",account_section"
|
||||||
|
",payto_uri"
|
||||||
|
",trigger_date"
|
||||||
|
",amount_val"
|
||||||
|
",amount_frac"
|
||||||
|
",master_sig"
|
||||||
|
") VALUES "
|
||||||
|
"($1, $2, $3, $4, $5, $6, $7, $8);");
|
||||||
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
|
||||||
"insert_into_table_profit_drains",
|
"insert_into_table_profit_drains",
|
||||||
params);
|
params);
|
||||||
|
|||||||
@ -3612,486 +3612,6 @@ prepare_statements (struct PostgresClosure *pg)
|
|||||||
" WHERE profit_drain_serial_id > $1"
|
" WHERE profit_drain_serial_id > $1"
|
||||||
" ORDER BY profit_drain_serial_id ASC;",
|
" ORDER BY profit_drain_serial_id ASC;",
|
||||||
1),
|
1),
|
||||||
/* For postgres_insert_records_by_table */
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_denominations",
|
|
||||||
"INSERT INTO denominations"
|
|
||||||
"(denominations_serial"
|
|
||||||
",denom_pub_hash"
|
|
||||||
",denom_type"
|
|
||||||
",age_mask"
|
|
||||||
",denom_pub"
|
|
||||||
",master_sig"
|
|
||||||
",valid_from"
|
|
||||||
",expire_withdraw"
|
|
||||||
",expire_deposit"
|
|
||||||
",expire_legal"
|
|
||||||
",coin_val"
|
|
||||||
",coin_frac"
|
|
||||||
",fee_withdraw_val"
|
|
||||||
",fee_withdraw_frac"
|
|
||||||
",fee_deposit_val"
|
|
||||||
",fee_deposit_frac"
|
|
||||||
",fee_refresh_val"
|
|
||||||
",fee_refresh_frac"
|
|
||||||
",fee_refund_val"
|
|
||||||
",fee_refund_frac"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6, $7, $8, $9, $10,"
|
|
||||||
" $11, $12, $13, $14, $15, $16, $17, $18, $19, $20);",
|
|
||||||
20),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_denomination_revocations",
|
|
||||||
"INSERT INTO denomination_revocations"
|
|
||||||
"(denom_revocations_serial_id"
|
|
||||||
",master_sig"
|
|
||||||
",denominations_serial"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3);",
|
|
||||||
3),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_wire_targets",
|
|
||||||
"INSERT INTO wire_targets"
|
|
||||||
"(wire_target_serial_id"
|
|
||||||
",wire_target_h_payto"
|
|
||||||
",payto_uri"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3);",
|
|
||||||
3),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_reserves",
|
|
||||||
"INSERT INTO reserves"
|
|
||||||
"(reserve_uuid"
|
|
||||||
",reserve_pub"
|
|
||||||
",expiration_date"
|
|
||||||
",gc_date"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4);",
|
|
||||||
4),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_reserves_in",
|
|
||||||
"INSERT INTO reserves_in"
|
|
||||||
"(reserve_in_serial_id"
|
|
||||||
",wire_reference"
|
|
||||||
",credit_val"
|
|
||||||
",credit_frac"
|
|
||||||
",wire_source_h_payto"
|
|
||||||
",exchange_account_section"
|
|
||||||
",execution_date"
|
|
||||||
",reserve_pub"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6, $7, $8);",
|
|
||||||
8),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_reserves_close",
|
|
||||||
"INSERT INTO reserves_close"
|
|
||||||
"(close_uuid"
|
|
||||||
",execution_date"
|
|
||||||
",wtid"
|
|
||||||
",wire_target_h_payto"
|
|
||||||
",amount_val"
|
|
||||||
",amount_frac"
|
|
||||||
",closing_fee_val"
|
|
||||||
",closing_fee_frac"
|
|
||||||
",reserve_pub"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6, $7, $8, $9);",
|
|
||||||
9),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_reserves_out",
|
|
||||||
"INSERT INTO reserves_out"
|
|
||||||
"(reserve_out_serial_id"
|
|
||||||
",h_blind_ev"
|
|
||||||
",denominations_serial"
|
|
||||||
",denom_sig"
|
|
||||||
",reserve_uuid"
|
|
||||||
",reserve_sig"
|
|
||||||
",execution_date"
|
|
||||||
",amount_with_fee_val"
|
|
||||||
",amount_with_fee_frac"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6, $7, $8, $9);",
|
|
||||||
9),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_auditors",
|
|
||||||
"INSERT INTO auditors"
|
|
||||||
"(auditor_uuid"
|
|
||||||
",auditor_pub"
|
|
||||||
",auditor_name"
|
|
||||||
",auditor_url"
|
|
||||||
",is_active"
|
|
||||||
",last_change"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6);",
|
|
||||||
6),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_auditor_denom_sigs",
|
|
||||||
"INSERT INTO auditor_denom_sigs"
|
|
||||||
"(auditor_denom_serial"
|
|
||||||
",auditor_uuid"
|
|
||||||
",denominations_serial"
|
|
||||||
",auditor_sig"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4);",
|
|
||||||
4),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_exchange_sign_keys",
|
|
||||||
"INSERT INTO exchange_sign_keys"
|
|
||||||
"(esk_serial"
|
|
||||||
",exchange_pub"
|
|
||||||
",master_sig"
|
|
||||||
",valid_from"
|
|
||||||
",expire_sign"
|
|
||||||
",expire_legal"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6);",
|
|
||||||
6),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_signkey_revocations",
|
|
||||||
"INSERT INTO signkey_revocations"
|
|
||||||
"(signkey_revocations_serial_id"
|
|
||||||
",esk_serial"
|
|
||||||
",master_sig"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3);",
|
|
||||||
3),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_known_coins",
|
|
||||||
"INSERT INTO known_coins"
|
|
||||||
"(known_coin_id"
|
|
||||||
",coin_pub"
|
|
||||||
",denom_sig"
|
|
||||||
",denominations_serial"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4);",
|
|
||||||
4),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_refresh_commitments",
|
|
||||||
"INSERT INTO refresh_commitments"
|
|
||||||
"(melt_serial_id"
|
|
||||||
",rc"
|
|
||||||
",old_coin_sig"
|
|
||||||
",amount_with_fee_val"
|
|
||||||
",amount_with_fee_frac"
|
|
||||||
",noreveal_index"
|
|
||||||
",old_coin_pub"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6, $7);",
|
|
||||||
7),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_refresh_revealed_coins",
|
|
||||||
"INSERT INTO refresh_revealed_coins"
|
|
||||||
"(rrc_serial"
|
|
||||||
",freshcoin_index"
|
|
||||||
",link_sig"
|
|
||||||
",coin_ev"
|
|
||||||
",h_coin_ev"
|
|
||||||
",ev_sig"
|
|
||||||
",ewv"
|
|
||||||
",denominations_serial"
|
|
||||||
",melt_serial_id"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6, $7, $8, $9);",
|
|
||||||
9),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_refresh_transfer_keys",
|
|
||||||
"INSERT INTO refresh_transfer_keys"
|
|
||||||
"(rtc_serial"
|
|
||||||
",transfer_pub"
|
|
||||||
",transfer_privs"
|
|
||||||
",melt_serial_id"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4);",
|
|
||||||
4),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_deposits",
|
|
||||||
"INSERT INTO deposits"
|
|
||||||
"(deposit_serial_id"
|
|
||||||
",shard"
|
|
||||||
",known_coin_id"
|
|
||||||
",coin_pub"
|
|
||||||
",amount_with_fee_val"
|
|
||||||
",amount_with_fee_frac"
|
|
||||||
",wallet_timestamp"
|
|
||||||
",exchange_timestamp"
|
|
||||||
",refund_deadline"
|
|
||||||
",wire_deadline"
|
|
||||||
",merchant_pub"
|
|
||||||
",h_contract_terms"
|
|
||||||
",coin_sig"
|
|
||||||
",wire_salt"
|
|
||||||
",wire_target_h_payto"
|
|
||||||
",extension_blocked"
|
|
||||||
",extension_details_serial_id"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6, $7, $8, $9, $10,"
|
|
||||||
" $11, $12, $13, $14, $15, $16, $17);",
|
|
||||||
17),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_refunds",
|
|
||||||
"INSERT INTO refunds"
|
|
||||||
"(refund_serial_id"
|
|
||||||
",coin_pub"
|
|
||||||
",merchant_sig"
|
|
||||||
",rtransaction_id"
|
|
||||||
",amount_with_fee_val"
|
|
||||||
",amount_with_fee_frac"
|
|
||||||
",deposit_serial_id"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6, $7);",
|
|
||||||
7),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_aggregation_tracking",
|
|
||||||
"INSERT INTO aggregation_tracking"
|
|
||||||
"(aggregation_serial_id"
|
|
||||||
",deposit_serial_id"
|
|
||||||
",wtid_raw"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3);",
|
|
||||||
3),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_wire_fee",
|
|
||||||
"INSERT INTO wire_fee"
|
|
||||||
"(wire_fee_serial"
|
|
||||||
",wire_method"
|
|
||||||
",start_date"
|
|
||||||
",end_date"
|
|
||||||
",wire_fee_val"
|
|
||||||
",wire_fee_frac"
|
|
||||||
",closing_fee_val"
|
|
||||||
",closing_fee_frac"
|
|
||||||
",wad_fee_val"
|
|
||||||
",wad_fee_frac"
|
|
||||||
",master_sig"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11);",
|
|
||||||
11),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_global_fee",
|
|
||||||
"INSERT INTO global_fee"
|
|
||||||
"(global_fee_serial"
|
|
||||||
",start_date"
|
|
||||||
",end_date"
|
|
||||||
",history_fee_val"
|
|
||||||
",history_fee_frac"
|
|
||||||
",kyc_fee_val"
|
|
||||||
",kyc_fee_frac"
|
|
||||||
",account_fee_val"
|
|
||||||
",account_fee_frac"
|
|
||||||
",purse_fee_val"
|
|
||||||
",purse_fee_frac"
|
|
||||||
",purse_timeout"
|
|
||||||
",kyc_timeout"
|
|
||||||
",history_expiration"
|
|
||||||
",purse_account_limit"
|
|
||||||
",master_sig"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15, $16);",
|
|
||||||
16),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_recoup",
|
|
||||||
"INSERT INTO recoup"
|
|
||||||
"(recoup_uuid"
|
|
||||||
",coin_sig"
|
|
||||||
",coin_blind"
|
|
||||||
",amount_val"
|
|
||||||
",amount_frac"
|
|
||||||
",recoup_timestamp"
|
|
||||||
",coin_pub"
|
|
||||||
",reserve_out_serial_id"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6, $7, $8);",
|
|
||||||
8),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_recoup_refresh",
|
|
||||||
"INSERT INTO recoup_refresh"
|
|
||||||
"(recoup_refresh_uuid"
|
|
||||||
",coin_sig"
|
|
||||||
",coin_blind"
|
|
||||||
",amount_val"
|
|
||||||
",amount_frac"
|
|
||||||
",recoup_timestamp"
|
|
||||||
",known_coin_id"
|
|
||||||
",coin_pub"
|
|
||||||
",rrc_serial"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6, $7, $8, $9);",
|
|
||||||
9),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_extensions",
|
|
||||||
"INSERT INTO extensions"
|
|
||||||
"(extension_id"
|
|
||||||
",name"
|
|
||||||
",config"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3);",
|
|
||||||
3),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_extension_details",
|
|
||||||
"INSERT INTO extension_details"
|
|
||||||
"(extension_details_serial_id"
|
|
||||||
",extension_options"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2);",
|
|
||||||
2),
|
|
||||||
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_purse_requests",
|
|
||||||
"INSERT INTO purse_requests"
|
|
||||||
"(purse_requests_serial_id"
|
|
||||||
",purse_pub"
|
|
||||||
",merge_pub"
|
|
||||||
",purse_creation"
|
|
||||||
",purse_expiration"
|
|
||||||
",h_contract_terms"
|
|
||||||
",age_limit"
|
|
||||||
",flags"
|
|
||||||
",amount_with_fee_val"
|
|
||||||
",amount_with_fee_frac"
|
|
||||||
",purse_fee_val"
|
|
||||||
",purse_fee_frac"
|
|
||||||
",purse_sig"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13);",
|
|
||||||
13),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_purse_refunds",
|
|
||||||
"INSERT INTO purse_refunds"
|
|
||||||
"(purse_refunds_serial_id"
|
|
||||||
",purse_pub"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2);",
|
|
||||||
2),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_purse_merges",
|
|
||||||
"INSERT INTO purse_merges"
|
|
||||||
"(purse_merge_request_serial_id"
|
|
||||||
",partner_serial_id"
|
|
||||||
",reserve_pub"
|
|
||||||
",purse_pub"
|
|
||||||
",merge_sig"
|
|
||||||
",merge_timestamp"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6);",
|
|
||||||
6),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_purse_deposits",
|
|
||||||
"INSERT INTO purse_deposits"
|
|
||||||
"(purse_deposit_serial_id"
|
|
||||||
",partner_serial_id"
|
|
||||||
",purse_pub"
|
|
||||||
",coin_pub"
|
|
||||||
",amount_with_fee_val"
|
|
||||||
",amount_with_fee_frac"
|
|
||||||
",coin_sig"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6, $7);",
|
|
||||||
7),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_history_requests",
|
|
||||||
"INSERT INTO history_requests"
|
|
||||||
"(history_request_serial_id"
|
|
||||||
",reserve_pub"
|
|
||||||
",request_timestamp"
|
|
||||||
",reserve_sig"
|
|
||||||
",history_fee_val"
|
|
||||||
",history_fee_frac"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6);",
|
|
||||||
6),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_close_requests",
|
|
||||||
"INSERT INTO close_requests"
|
|
||||||
"(close_request_serial_id"
|
|
||||||
",reserve_pub"
|
|
||||||
",close_timestamp"
|
|
||||||
",reserve_sig"
|
|
||||||
",close_val"
|
|
||||||
",close_frac"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6);",
|
|
||||||
6),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_wads_out",
|
|
||||||
"INSERT INTO wads_out"
|
|
||||||
"(wad_out_serial_id"
|
|
||||||
",wad_id"
|
|
||||||
",partner_serial_id"
|
|
||||||
",amount_val"
|
|
||||||
",amount_frac"
|
|
||||||
",execution_time"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6);",
|
|
||||||
6),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_wad_out_entries",
|
|
||||||
"INSERT INTO wad_out_entries"
|
|
||||||
"(wad_out_entry_serial_id"
|
|
||||||
",wad_out_serial_id"
|
|
||||||
",reserve_pub"
|
|
||||||
",purse_pub"
|
|
||||||
",h_contract"
|
|
||||||
",purse_expiration"
|
|
||||||
",merge_timestamp"
|
|
||||||
",amount_with_fee_val"
|
|
||||||
",amount_with_fee_frac"
|
|
||||||
",wad_fee_val"
|
|
||||||
",wad_fee_frac"
|
|
||||||
",deposit_fees_val"
|
|
||||||
",deposit_fees_frac"
|
|
||||||
",reserve_sig"
|
|
||||||
",purse_sig"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15);",
|
|
||||||
15),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_wads_in",
|
|
||||||
"INSERT INTO wads_in"
|
|
||||||
"(wad_in_serial_id"
|
|
||||||
",wad_id"
|
|
||||||
",origin_exchange_url"
|
|
||||||
",amount_val"
|
|
||||||
",amount_frac"
|
|
||||||
",arrival_time"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6);",
|
|
||||||
6),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_wad_in_entries",
|
|
||||||
"INSERT INTO wad_in_entries"
|
|
||||||
"(wad_in_entry_serial_id"
|
|
||||||
",wad_in_serial_id"
|
|
||||||
",reserve_pub"
|
|
||||||
",purse_pub"
|
|
||||||
",h_contract"
|
|
||||||
",purse_expiration"
|
|
||||||
",merge_timestamp"
|
|
||||||
",amount_with_fee_val"
|
|
||||||
",amount_with_fee_frac"
|
|
||||||
",wad_fee_val"
|
|
||||||
",wad_fee_frac"
|
|
||||||
",deposit_fees_val"
|
|
||||||
",deposit_fees_frac"
|
|
||||||
",reserve_sig"
|
|
||||||
",purse_sig"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15);",
|
|
||||||
15),
|
|
||||||
GNUNET_PQ_make_prepare (
|
|
||||||
"insert_into_table_profit_drains",
|
|
||||||
"INSERT INTO profit_drains"
|
|
||||||
"(profit_drain_serial_id"
|
|
||||||
",wtid"
|
|
||||||
",account_section"
|
|
||||||
",payto_uri"
|
|
||||||
",trigger_date"
|
|
||||||
",amount_val"
|
|
||||||
",amount_frac"
|
|
||||||
",master_sig"
|
|
||||||
") VALUES "
|
|
||||||
"($1, $2, $3, $4, $5, $6, $7, $8);",
|
|
||||||
8),
|
|
||||||
|
|
||||||
/* Used in #postgres_begin_shard() */
|
/* Used in #postgres_begin_shard() */
|
||||||
GNUNET_PQ_make_prepare (
|
GNUNET_PQ_make_prepare (
|
||||||
"get_open_shard",
|
"get_open_shard",
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user