taler/exchange
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Compare commits

base: taler:6dedca0fa36bd30bbeb26be012ce3ac9d967065a
Branches Tags
taler:master
taler:new-amount
taler:fail-amount
taler:age-withdraw
taler:master-broken
taler:auction_brandt
..
compare: taler:94e5193bffd5b2107710ba4fab0405ba22ea6dcf
Branches Tags
taler:new-amount
taler:fail-amount
taler:age-withdraw
taler:master
taler:master-broken
taler:auction_brandt

No commits in common. "6dedca0fa36bd30bbeb26be012ce3ac9d967065a" and "94e5193bffd5b2107710ba4fab0405ba22ea6dcf" have entirely different histories.
6dedca0fa3 ... 94e5193bff

29 changed files with 492 additions and 410 deletions
Show Stats Expand all files Collapse all files

2
src/auditor/.gitignore vendored
View File

@ -24,5 +24,3 @@ taler-auditor-test.sqlite3
libeufin-nexus.pid
libeufin-sandbox.pid
taler-helper-auditor-purses
generate-kyc-basedb.conf.edited
generate-auditor-basedb.conf.edited

8
src/exchangedb/0002-reserves.sql
View File

@ -27,7 +27,8 @@ BEGIN
'CREATE TABLE %I'
'(reserve_uuid BIGINT GENERATED BY DEFAULT AS IDENTITY'
',reserve_pub BYTEA PRIMARY KEY CHECK(LENGTH(reserve_pub)=32)'
',current_balance taler_amount NOT NULL DEFAULT (0, 0)'
',current_balance_val INT8 NOT NULL DEFAULT(0)'
',current_balance_frac INT4 NOT NULL DEFAULT(0)'
',purses_active INT8 NOT NULL DEFAULT(0)'
',purses_allowed INT8 NOT NULL DEFAULT(0)'
',birthday INT4 NOT NULL DEFAULT(0)'
@ -51,7 +52,7 @@ BEGIN
);
PERFORM comment_partitioned_column(
'Current balance remaining with the reserve.'
,'current_balance'
,'current_balance_val'
,table_name
,partition_suffix
);
@ -108,7 +109,8 @@ BEGIN
'CREATE INDEX ' || table_name || '_by_expiration_index '
'ON ' || table_name || ' '
'(expiration_date'
',current_balance'
',current_balance_val'
',current_balance_frac'
');'
);
EXECUTE FORMAT (

38
src/exchangedb/exchange_do_age_withdraw.sql
View File

@ -36,9 +36,10 @@ CREATE OR REPLACE FUNCTION exchange_do_age_withdraw(
LANGUAGE plpgsql
AS $$
DECLARE
reserve RECORD;
reserve_gc INT8;
difference RECORD;
balance taler_amount;
new_balance taler_amount;
not_before date;
earliest_date date;
BEGIN
@ -48,8 +49,16 @@ BEGIN
-- reserves_in by reserve_pub (SELECT)
-- wire_targets by wire_target_h_payto
SELECT *
INTO reserve
SELECT
current_balance_val
,current_balance_frac
,gc_date
,birthday
INTO
balance.val
,balance.frac
,reserve_gc
,reserve_birthday
FROM exchange.reserves
WHERE reserves.reserve_pub=rpub;
@ -66,13 +75,10 @@ END IF;
reserve_found = TRUE;
conflict=FALSE; -- not really yet determined
balance = reserve.current_balance;
reserve_birthday = reserve.birthday;
-- Check age requirements
IF (reserve.birthday <> 0)
IF (reserve_birthday <> 0)
THEN
not_before=date '1970-01-01' + reserve.birthday;
not_before=date '1970-01-01' + reserve_birthday;
earliest_date = current_date - make_interval(maximum_age_committed);
--
-- 1970-01-01 + birthday == not_before now
@ -98,9 +104,12 @@ required_age=0;
-- Check reserve balance is sufficient.
SELECT *
INTO difference
FROM amount_left_minus_right(balance
,amount_with_fee);
INTO
difference
FROM
amount_left_minus_right(
balance
,amount_with_fee);
balance_ok = difference.ok;
@ -109,15 +118,16 @@ THEN
RETURN;
END IF;
balance = difference.diff;
new_balance = difference.diff;
-- Calculate new expiration dates.
min_reserve_gc=GREATEST(min_reserve_gc,reserve.gc_date);
min_reserve_gc=GREATEST(min_reserve_gc,reserve_gc);
-- Update reserve balance.
UPDATE reserves SET
gc_date=min_reserve_gc
,current_balance=balance
,current_balance_val=new_balance.val
,current_balance_frac=new_balance.frac
WHERE
reserves.reserve_pub=rpub;

15
src/exchangedb/exchange_do_batch_reserves_update.sql
View File

@ -18,7 +18,8 @@ CREATE OR REPLACE FUNCTION exchange_do_batch_reserves_update(
IN in_reserve_pub BYTEA,
IN in_expiration_date INT8,
IN in_wire_ref INT8,
IN in_credit taler_amount,
IN in_credit_val INT8,
IN in_credit_frac INT4,
IN in_exchange_account_name VARCHAR,
IN in_wire_source_h_payto BYTEA,
IN in_notify text,
@ -37,8 +38,8 @@ BEGIN
VALUES
(in_reserve_pub
,in_wire_ref
,in_credit.val
,in_credit.frac
,in_credit_val
,in_credit_frac
,in_exchange_account_name
,in_wire_source_h_payto
,in_expiration_date)
@ -49,15 +50,15 @@ BEGIN
out_duplicate = FALSE;
UPDATE reserves
SET
current_balance.frac = current_balance.frac+in_credit.frac
current_balance_frac = current_balance_frac+in_credit_frac
- CASE
WHEN current_balance.frac + in_credit.frac >= 100000000
WHEN current_balance_frac + in_credit_frac >= 100000000
THEN 100000000
ELSE 1
END
,current_balance.val = current_balance.val+in_credit.val
,current_balance_val = current_balance_val+in_credit_val
+ CASE
WHEN current_balance.frac + in_credit.frac >= 100000000
WHEN current_balance_frac + in_credit_frac >= 100000000
THEN 1
ELSE 0
END

55
src/exchangedb/exchange_do_batch_withdraw.sql
View File

@ -17,7 +17,8 @@
-- @author Özgür Kesim
CREATE OR REPLACE FUNCTION exchange_do_batch_withdraw(
IN amount taler_amount,
IN amount_val INT8,
IN amount_frac INT4,
IN rpub BYTEA,
IN now INT8,
IN min_reserve_gc INT8,
@ -30,8 +31,10 @@ CREATE OR REPLACE FUNCTION exchange_do_batch_withdraw(
LANGUAGE plpgsql
AS $$
DECLARE
reserve RECORD;
balance taler_amount;
reserve_gc INT8;
reserve_val INT8;
reserve_frac INT4;
reserve_birthday INT4;
not_before date;
BEGIN
-- Shards: reserves by reserve_pub (SELECT)
@ -41,8 +44,18 @@ BEGIN
-- wire_targets by wire_target_h_payto
SELECT *
INTO reserve
SELECT
current_balance_val
,current_balance_frac
,gc_date
,birthday
,reserve_uuid
INTO
reserve_val
,reserve_frac
,reserve_gc
,reserve_birthday
,ruuid
FROM exchange.reserves
WHERE reserves.reserve_pub=rpub;
@ -57,10 +70,9 @@ THEN
RETURN;
END IF;
ruuid = reserve.reserve_uuid;
-- Check if age requirements are present
IF ((NOT do_age_check) OR (reserve.birthday = 0))
IF ((NOT do_age_check) OR (reserve_birthday = 0))
THEN
age_ok = TRUE;
allowed_maximum_age = -1;
@ -70,7 +82,7 @@ ELSE
-- birthday set (reserve_birthday != 0), but the client called the
-- batch-withdraw endpoint instead of the age-withdraw endpoint, which it
-- should have.
not_before=date '1970-01-01' + reserve.birthday;
not_before=date '1970-01-01' + reserve_birthday;
allowed_maximum_age = extract(year from age(current_date, not_before));
reserve_found=TRUE;
@ -79,24 +91,22 @@ ELSE
RETURN;
END IF;
balance = reserve.current_balance;
-- Check reserve balance is sufficient.
IF (balance.val > amount.val)
IF (reserve_val > amount_val)
THEN
IF (balance.frac >= amount.frac)
IF (reserve_frac >= amount_frac)
THEN
balance.val=balance.val - amount.val;
balance.frac=balance.frac - amount.frac;
reserve_val=reserve_val - amount_val;
reserve_frac=reserve_frac - amount_frac;
ELSE
balance.val=balance.val - amount.val - 1;
balance.frac=balance.frac + 100000000 - amount.frac;
reserve_val=reserve_val - amount_val - 1;
reserve_frac=reserve_frac + 100000000 - amount_frac;
END IF;
ELSE
IF (balance.val = amount.val) AND (balance.frac >= amount.frac)
IF (reserve_val = amount_val) AND (reserve_frac >= amount_frac)
THEN
balance.val=0;
balance.frac=balance.frac - amount.frac;
reserve_val=0;
reserve_frac=reserve_frac - amount_frac;
ELSE
balance_ok=FALSE;
RETURN;
@ -104,12 +114,13 @@ ELSE
END IF;
-- Calculate new expiration dates.
min_reserve_gc=GREATEST(min_reserve_gc,reserve.gc_date);
min_reserve_gc=GREATEST(min_reserve_gc,reserve_gc);
-- Update reserve balance.
UPDATE reserves SET
gc_date=min_reserve_gc
,current_balance=balance
,current_balance_val=reserve_val
,current_balance_frac=reserve_frac
WHERE
reserves.reserve_pub=rpub;
@ -118,6 +129,6 @@ balance_ok=TRUE;
END $$;
COMMENT ON FUNCTION exchange_do_batch_withdraw(taler_amount, BYTEA, INT8, INT8, BOOLEAN)
COMMENT ON FUNCTION exchange_do_batch_withdraw(INT8, INT4, BYTEA, INT8, INT8, BOOLEAN)
IS 'Checks whether the reserve has sufficient balance for a withdraw operation (or the request is repeated and was previously approved) and that age requirements are formally met. If so updates the database with the result. Excludes storing the planchets.';

9
src/exchangedb/exchange_do_batch_withdraw_insert.sql
View File

@ -16,7 +16,8 @@
CREATE OR REPLACE FUNCTION exchange_do_batch_withdraw_insert(
IN cs_nonce BYTEA,
IN amount taler_amount,
IN amount_val INT8,
IN amount_frac INT4,
IN h_denom_pub BYTEA, -- FIXME: denom_serials should really be a parameter to this FUNCTION.
IN ruuid INT8,
IN reserve_sig BYTEA,
@ -73,8 +74,8 @@ VALUES
,ruuid
,reserve_sig
,now
,amount.val
,amount.frac)
,amount_val
,amount_frac)
ON CONFLICT DO NOTHING;
IF NOT FOUND
@ -118,6 +119,6 @@ END IF;
END $$;
COMMENT ON FUNCTION exchange_do_batch_withdraw_insert(BYTEA, taler_amount, BYTEA, INT8, BYTEA, BYTEA, BYTEA, INT8)
COMMENT ON FUNCTION exchange_do_batch_withdraw_insert(BYTEA, INT8, INT4, BYTEA, INT8, BYTEA, BYTEA, BYTEA, INT8)
IS 'Stores information about a planchet for a batch withdraw operation. Checks if the planchet already exists, and in that case indicates a conflict';

8
src/exchangedb/exchange_do_gc.sql
View File

@ -21,10 +21,15 @@ LANGUAGE plpgsql
AS $$
DECLARE
reserve_uuid_min INT8; -- minimum reserve UUID still alive
DECLARE
melt_min INT8; -- minimum melt still alive
DECLARE
coin_min INT8; -- minimum known_coin still alive
DECLARE
deposit_min INT8; -- minimum deposit still alive
DECLARE
reserve_out_min INT8; -- minimum reserve_out still alive
DECLARE
denom_min INT8; -- minimum denomination still alive
BEGIN
@ -37,7 +42,8 @@ DELETE FROM exchange.wire_fee
-- TODO: use closing fee as threshold?
DELETE FROM exchange.reserves
WHERE gc_date < in_now
AND current_balance = (0, 0);
AND current_balance_val = 0
AND current_balance_frac = 0;
SELECT
reserve_out_serial_id

71
src/exchangedb/exchange_do_history_request.sql
View File

@ -19,15 +19,12 @@ CREATE OR REPLACE FUNCTION exchange_do_history_request(
IN in_reserve_pub BYTEA,
IN in_reserve_sig BYTEA,
IN in_request_timestamp INT8,
IN in_history_fee taler_amount,
IN in_history_fee_val INT8,
IN in_history_fee_frac INT4,
OUT out_balance_ok BOOLEAN,
OUT out_idempotent BOOLEAN)
LANGUAGE plpgsql
AS $$
DECLARE
reserve RECORD;
balance taler_amount;
new_balance taler_amount;
BEGIN
-- Insert and check for idempotency.
@ -41,8 +38,8 @@ BEGIN
(in_reserve_pub
,in_request_timestamp
,in_reserve_sig
,in_history_fee.val
,in_history_fee.frac)
,in_history_fee_val
,in_history_fee_frac)
ON CONFLICT DO NOTHING;
IF NOT FOUND
@ -54,51 +51,35 @@ BEGIN
out_idempotent=FALSE;
SELECT *
INTO reserve
FROM exchange.reserves
WHERE reserve_pub=in_reserve_pub;
-- Update reserve balance.
UPDATE exchange.reserves
SET
current_balance_frac=current_balance_frac-in_history_fee_frac
+ CASE
WHEN current_balance_frac < in_history_fee_frac
THEN 100000000
ELSE 0
END,
current_balance_val=current_balance_val-in_history_fee_val
- CASE
WHEN current_balance_frac < in_history_fee_frac
THEN 1
ELSE 0
END
WHERE
reserve_pub=in_reserve_pub
AND ( (current_balance_val > in_history_fee_val) OR
( (current_balance_frac >= in_history_fee_frac) AND
(current_balance_val >= in_history_fee_val) ) );
IF NOT FOUND
THEN
-- Reserve does not exist, we treat it the same here
-- as balance insufficient.
-- Either reserve does not exist, or balance insufficient.
-- Both we treat the same here as balance insufficient.
out_balance_ok=FALSE;
RETURN;
END IF;
balance = reserve.current_balance;
-- check balance
IF ( (balance.val <= in_history_fee.val) AND
( (balance.frac < in_history_fee.frac) OR
(balance.val < in_history_fee.val) ) )
THEN
out_balance_ok=FALSE;
RETURN;
END IF;
new_balance.frac=balance.frac-in_history_fee.frac
+ CASE
WHEN balance.frac < in_history_fee.frac
THEN 100000000
ELSE 0
END;
new_balance.val=balance.val-in_history_fee.val
- CASE
WHEN balance.frac < in_history_fee.frac
THEN 1
ELSE 0
END;
-- Update reserve balance.
UPDATE exchange.reserves
SET current_balance=new_balance
WHERE reserve_pub=in_reserve_pub;
ASSERT FOUND, 'reserve suddenly disappeared';
out_balance_ok=TRUE;
END $$;

59
src/exchangedb/exchange_do_purse_deposit.sql
View File

@ -17,10 +17,12 @@
CREATE OR REPLACE FUNCTION exchange_do_purse_deposit(
IN in_partner_id INT8,
IN in_purse_pub BYTEA,
IN in_amount_with_fee taler_amount,
IN in_amount_with_fee_val INT8,
IN in_amount_with_fee_frac INT4,
IN in_coin_pub BYTEA,
IN in_coin_sig BYTEA,
IN in_amount_without_fee taler_amount,
IN in_amount_without_fee_val INT8,
IN in_amount_without_fee_frac INT4,
IN in_reserve_expiration INT8,
IN in_now INT8,
OUT out_balance_ok BOOLEAN,
@ -30,10 +32,17 @@ LANGUAGE plpgsql
AS $$
DECLARE
was_merged BOOLEAN;
DECLARE
psi INT8; -- partner's serial ID (set if merged)
my_amount taler_amount; -- total in purse
DECLARE
my_amount_val INT8; -- total in purse
DECLARE
my_amount_frac INT4; -- total in purse
DECLARE
was_paid BOOLEAN;
DECLARE
my_in_reserve_quota BOOLEAN;
DECLARE
my_reserve_pub BYTEA;
BEGIN
@ -49,8 +58,8 @@ INSERT INTO exchange.purse_deposits
(in_partner_id
,in_purse_pub
,in_coin_pub
,in_amount_with_fee.val
,in_amount_with_fee.frac
,in_amount_with_fee_val
,in_amount_with_fee_frac
,in_coin_sig)
ON CONFLICT DO NOTHING;
@ -98,22 +107,22 @@ END IF;
-- Check and update balance of the coin.
UPDATE known_coins
SET
remaining_frac=remaining_frac-in_amount_with_fee.frac
remaining_frac=remaining_frac-in_amount_with_fee_frac
+ CASE
WHEN remaining_frac < in_amount_with_fee.frac
WHEN remaining_frac < in_amount_with_fee_frac
THEN 100000000
ELSE 0
END,
remaining_val=remaining_val-in_amount_with_fee.val
remaining_val=remaining_val-in_amount_with_fee_val
- CASE
WHEN remaining_frac < in_amount_with_fee.frac
WHEN remaining_frac < in_amount_with_fee_frac
THEN 1
ELSE 0
END
WHERE coin_pub=in_coin_pub
AND ( (remaining_val > in_amount_with_fee.val) OR
( (remaining_frac >= in_amount_with_fee.frac) AND
(remaining_val >= in_amount_with_fee.val) ) );
AND ( (remaining_val > in_amount_with_fee_val) OR
( (remaining_frac >= in_amount_with_fee_frac) AND
(remaining_val >= in_amount_with_fee_val) ) );
IF NOT FOUND
THEN
@ -128,15 +137,15 @@ END IF;
-- Credit the purse.
UPDATE purse_requests
SET
balance_frac=balance_frac+in_amount_without_fee.frac
balance_frac=balance_frac+in_amount_without_fee_frac
- CASE
WHEN balance_frac+in_amount_without_fee.frac >= 100000000
WHEN balance_frac+in_amount_without_fee_frac >= 100000000
THEN 100000000
ELSE 0
END,
balance_val=balance_val+in_amount_without_fee.val
balance_val=balance_val+in_amount_without_fee_val
+ CASE
WHEN balance_frac+in_amount_without_fee.frac >= 100000000
WHEN balance_frac+in_amount_without_fee_frac >= 100000000
THEN 1
ELSE 0
END
@ -165,8 +174,8 @@ SELECT
,amount_with_fee_frac
,in_reserve_quota
INTO
my_amount.val
,my_amount.frac
my_amount_val
,my_amount_frac
,my_in_reserve_quota
FROM exchange.purse_requests
WHERE (purse_pub=in_purse_pub)
@ -222,12 +231,14 @@ ELSE
-- This is a local reserve, update balance immediately.
INSERT INTO reserves
(reserve_pub
,current_balance
,current_balance_frac
,current_balance_val
,expiration_date
,gc_date)
VALUES
(my_reserve_pub
,my_amount
,my_amount_frac
,my_amount_val
,in_reserve_expiration
,in_reserve_expiration)
ON CONFLICT DO NOTHING;
@ -237,15 +248,15 @@ ELSE
-- Reserve existed, thus UPDATE instead of INSERT.
UPDATE reserves
SET
current_balance.frac=(current_balance).frac+my_amount.frac
current_balance_frac=current_balance_frac+my_amount_frac
- CASE
WHEN (current_balance).frac + my_amount.frac >= 100000000
WHEN current_balance_frac + my_amount_frac >= 100000000
THEN 100000000
ELSE 0
END
,current_balance.val=(current_balance).val+my_amount.val
,current_balance_val=current_balance_val+my_amount_val
+ CASE
WHEN (current_balance).frac + my_amount.frac >= 100000000
WHEN current_balance_frac + my_amount_frac >= 100000000
THEN 1
ELSE 0
END

62
src/exchangedb/exchange_do_purse_merge.sql
View File

@ -29,12 +29,17 @@ CREATE OR REPLACE FUNCTION exchange_do_purse_merge(
LANGUAGE plpgsql
AS $$
DECLARE
my_amount taler_amount;
my_purse_fee taler_amount;
my_amount_val INT8;
DECLARE
my_amount_frac INT4;
DECLARE
my_purse_fee_val INT8;
DECLARE
my_purse_fee_frac INT4;
DECLARE
my_partner_serial_id INT8;
DECLARE
my_in_reserve_quota BOOLEAN;
reserve RECORD;
balance taler_amount;
BEGIN
@ -67,10 +72,10 @@ SELECT amount_with_fee_val
,purse_fee_val
,purse_fee_frac
,in_reserve_quota
INTO my_amount.val
,my_amount.frac
,my_purse_fee.val
,my_purse_fee.frac
INTO my_amount_val
,my_amount_frac
,my_purse_fee_val
,my_purse_fee_frac
,my_in_reserve_quota
FROM exchange.purse_requests
WHERE purse_pub=in_purse_pub
@ -191,33 +196,26 @@ ELSE
-- This is a local reserve, update reserve balance immediately.
-- Refund the purse fee, by adding it to the purse value:
my_amount.val = my_amount.val + my_purse_fee.val;
my_amount.frac = my_amount.frac + my_purse_fee.frac;
my_amount_val = my_amount_val + my_purse_fee_val;
my_amount_frac = my_amount_frac + my_purse_fee_frac;
-- normalize result
my_amount.val = my_amount.val + my_amount.frac / 100000000;
my_amount.frac = my_amount.frac % 100000000;
SELECT *
INTO reserve
FROM exchange.reserves
WHERE reserve_pub=in_reserve_pub;
balance = reserve.current_balance;
balance.frac=balance.frac+my_amount.frac
- CASE
WHEN balance.frac + my_amount.frac >= 100000000
THEN 100000000
ELSE 0
END;
balance.val=balance.val+my_amount.val
+ CASE
WHEN balance.frac + my_amount.frac >= 100000000
THEN 1
ELSE 0
END;
my_amount_val = my_amount_val + my_amount_frac / 100000000;
my_amount_frac = my_amount_frac % 100000000;
UPDATE exchange.reserves
SET current_balance=balance
SET
current_balance_frac=current_balance_frac+my_amount_frac
- CASE
WHEN current_balance_frac + my_amount_frac >= 100000000
THEN 100000000
ELSE 0
END,
current_balance_val=current_balance_val+my_amount_val
+ CASE
WHEN current_balance_frac + my_amount_frac >= 100000000
THEN 1
ELSE 0
END
WHERE reserve_pub=in_reserve_pub;
END IF;

50
src/exchangedb/exchange_do_recoup_to_reserve.sql
View File

@ -31,10 +31,9 @@ CREATE OR REPLACE FUNCTION exchange_do_recoup_to_reserve(
LANGUAGE plpgsql
AS $$
DECLARE
tmp taler_amount; -- amount recouped
balance taler_amount; -- current balance of the reserve
new_balance taler_amount; -- new balance of the reserve
reserve RECORD;
tmp_val INT8; -- amount recouped
DECLARE
tmp_frac INT8; -- amount recouped
BEGIN
-- Shards: SELECT known_coins (by coin_pub)
-- SELECT recoup (by coin_pub)
@ -50,8 +49,8 @@ SELECT
remaining_frac
,remaining_val
INTO
tmp.frac
,tmp.val
tmp_frac
,tmp_val
FROM exchange.known_coins
WHERE coin_pub=in_coin_pub;
@ -62,7 +61,7 @@ THEN
RETURN;
END IF;
IF tmp.val + tmp.frac = 0
IF tmp_val + tmp_frac = 0
THEN
-- Check for idempotency
SELECT
@ -84,31 +83,22 @@ UPDATE known_coins
,remaining_val=0
WHERE coin_pub=in_coin_pub;
-- Get current balance
SELECT *
INTO reserve
FROM reserves
WHERE reserve_pub=in_reserve_pub;
balance = reserve.current_balance;
new_balance.frac=balance.frac+tmp.frac
- CASE
WHEN balance.frac+tmp.frac >= 100000000
THEN 100000000
ELSE 0
END;
new_balance.val=balance.val+tmp.val
+ CASE
WHEN balance.frac+tmp.frac >= 100000000
THEN 1
ELSE 0
END;
-- Credit the reserve and update reserve timers.
UPDATE reserves
SET
current_balance = new_balance,
current_balance_frac=current_balance_frac+tmp_frac
- CASE
WHEN current_balance_frac+tmp_frac >= 100000000
THEN 100000000
ELSE 0
END,
current_balance_val=current_balance_val+tmp_val
+ CASE
WHEN current_balance_frac+tmp_frac >= 100000000
THEN 1
ELSE 0
END,
gc_date=GREATEST(gc_date, in_reserve_gc),
expiration_date=GREATEST(expiration_date, in_reserve_expiration)
WHERE reserve_pub=in_reserve_pub;
@ -136,8 +126,8 @@ VALUES
(in_coin_pub
,in_coin_sig
,in_coin_blind
,tmp.val
,tmp.frac
,tmp_val
,tmp_frac
,in_recoup_timestamp
,in_reserve_out_serial_id);

134
src/exchangedb/exchange_do_reserve_open.sql
View File

@ -16,36 +16,62 @@
CREATE OR REPLACE FUNCTION exchange_do_reserve_open(
IN in_reserve_pub BYTEA,
IN in_total_paid taler_amount,
IN in_reserve_payment taler_amount,
IN in_total_paid_val INT8,
IN in_total_paid_frac INT4,
IN in_reserve_payment_val INT8,
IN in_reserve_payment_frac INT4,
IN in_min_purse_limit INT4,
IN in_default_purse_limit INT4,
IN in_reserve_sig BYTEA,
IN in_desired_expiration INT8,
IN in_reserve_gc_delay INT8,
IN in_now INT8,
IN in_open_fee taler_amount,
OUT out_open_cost taler_amount,
IN in_open_fee_val INT8,
IN in_open_fee_frac INT4,
OUT out_open_cost_val INT8,
OUT out_open_cost_frac INT4,
OUT out_final_expiration INT8,
OUT out_no_funds BOOLEAN)
LANGUAGE plpgsql
AS $$
DECLARE
my_balance taler_amount;
my_cost taler_amount;
my_balance_val INT8;
DECLARE
my_balance_frac INT4;
DECLARE
my_cost_val INT8;
DECLARE
my_cost_tmp INT8;
DECLARE
my_cost_frac INT4;
DECLARE
my_years_tmp INT4;
DECLARE
my_years INT4;
DECLARE
my_needs_update BOOL;
DECLARE
my_purses_allowed INT8;
DECLARE
my_expiration_date INT8;
reserve RECORD;
DECLARE
my_reserve_expiration INT8;
BEGIN
-- FIXME: use SELECT FOR UPDATE?
SELECT *
INTO reserve
FROM reserves
WHERE reserve_pub=in_reserve_pub;
SELECT
purses_allowed
,expiration_date
,current_balance_val
,current_balance_frac
INTO
my_purses_allowed
,my_reserve_expiration
,my_balance_val
,my_balance_frac
FROM reserves
WHERE
reserve_pub=in_reserve_pub;
IF NOT FOUND
THEN
@ -54,18 +80,16 @@ THEN
RETURN;
END IF;
my_balance = reserve.current_balance;
-- Do not allow expiration time to start in the past already
IF (reserve.expiration_date < in_now)
IF (my_reserve_expiration < in_now)
THEN
my_expiration_date = in_now;
ELSE
my_expiration_date = reserve.expiration_date;
my_expiration_date = my_reserve_expiration;
END IF;
my_cost.val = 0;
my_cost.frac = 0;
my_cost_val = 0;
my_cost_frac = 0;
my_needs_update = FALSE;
my_years = 0;
@ -73,62 +97,62 @@ my_years = 0;
IF (my_expiration_date < in_desired_expiration)
THEN
my_years = (31535999999999 + in_desired_expiration - my_expiration_date) / 31536000000000;
reserve.purses_allowed = in_default_purse_limit;
my_purses_allowed = in_default_purse_limit;
my_expiration_date = my_expiration_date + 31536000000000 * my_years;
END IF;
-- Increase years based on purses requested
IF (reserve.purses_allowed < in_min_purse_limit)
IF (my_purses_allowed < in_min_purse_limit)
THEN
my_years = (31535999999999 + in_desired_expiration - in_now) / 31536000000000;
my_expiration_date = in_now + 31536000000000 * my_years;
my_years_tmp = (in_min_purse_limit + in_default_purse_limit - reserve.purses_allowed - 1) / in_default_purse_limit;
my_years_tmp = (in_min_purse_limit + in_default_purse_limit - my_purses_allowed - 1) / in_default_purse_limit;
my_years = my_years + my_years_tmp;
reserve.purses_allowed = reserve.purses_allowed + (in_default_purse_limit * my_years_tmp);
my_purses_allowed = my_purses_allowed + (in_default_purse_limit * my_years_tmp);
END IF;
-- Compute cost based on annual fees
IF (my_years > 0)
THEN
my_cost.val = my_years * in_open_fee.val;
my_cost_tmp = my_years * in_open_fee.frac / 100000000;
IF (CAST (my_cost.val + my_cost_tmp AS INT8) < my_cost.val)
my_cost_val = my_years * in_open_fee_val;
my_cost_tmp = my_years * in_open_fee_frac / 100000000;
IF (CAST (my_cost_val + my_cost_tmp AS INT8) < my_cost_val)
THEN
out_open_cost.val=9223372036854775807;
out_open_cost.frac=2147483647;
out_open_cost_val=9223372036854775807;
out_open_cost_frac=2147483647;
out_final_expiration=my_expiration_date;
out_no_funds=FALSE;
RAISE NOTICE 'arithmetic issue computing amount';
RETURN;
END IF;
my_cost.val = CAST (my_cost.val + my_cost_tmp AS INT8);
my_cost.frac = my_years * in_open_fee.frac % 100000000;
my_cost_val = CAST (my_cost_val + my_cost_tmp AS INT8);
my_cost_frac = my_years * in_open_fee_frac % 100000000;
my_needs_update = TRUE;
END IF;
-- check if we actually have something to do
IF NOT my_needs_update
THEN
out_final_expiration = reserve.expiration_date;
out_open_cost.val = 0;
out_open_cost.frac = 0;
out_final_expiration = my_reserve_expiration;
out_open_cost_val = 0;
out_open_cost_frac = 0;
out_no_funds=FALSE;
RAISE NOTICE 'no change required';
RETURN;
END IF;
-- Check payment (coins and reserve) would be sufficient.
IF ( (in_total_paid.val < my_cost.val) OR
( (in_total_paid.val = my_cost.val) AND
(in_total_paid.frac < my_cost.frac) ) )
IF ( (in_total_paid_val < my_cost_val) OR
( (in_total_paid_val = my_cost_val) AND
(in_total_paid_frac < my_cost_frac) ) )
THEN
out_open_cost.val = my_cost.val;
out_open_cost.frac = my_cost.frac;
out_open_cost_val = my_cost_val;
out_open_cost_frac = my_cost_frac;
out_no_funds=FALSE;
-- We must return a failure, which is indicated by
-- the expiration being below the desired expiration.
IF (reserve.expiration_date >= in_desired_expiration)
IF (my_reserve_expiration >= in_desired_expiration)
THEN
-- This case is relevant especially if the purse
-- count was to be increased and the payment was
@ -136,32 +160,32 @@ THEN
RAISE NOTICE 'forcing low expiration time';
out_final_expiration = 0;
ELSE
out_final_expiration = reserve.expiration_date;
out_final_expiration = my_reserve_expiration;
END IF;
RAISE NOTICE 'amount paid too low';
RETURN;
END IF;
-- Check reserve balance is sufficient.
IF (my_balance.val > in_reserve_payment.val)
IF (my_balance_val > in_reserve_payment_val)
THEN
IF (my_balance.frac >= in_reserve_payment.frac)
IF (my_balance_frac >= in_reserve_payment_frac)
THEN
my_balance.val=my_balance.val - in_reserve_payment.val;
my_balance.frac=my_balance.frac - in_reserve_payment.frac;
my_balance_val=my_balance_val - in_reserve_payment_val;
my_balance_frac=my_balance_frac - in_reserve_payment_frac;
ELSE
my_balance.val=my_balance.val - in_reserve_payment.val - 1;
my_balance.frac=my_balance.frac + 100000000 - in_reserve_payment.frac;
my_balance_val=my_balance_val - in_reserve_payment_val - 1;
my_balance_frac=my_balance_frac + 100000000 - in_reserve_payment_frac;
END IF;
ELSE
IF (my_balance.val = in_reserve_payment.val) AND (my_balance.frac >= in_reserve_payment.frac)
IF (my_balance_val = in_reserve_payment_val) AND (my_balance_frac >= in_reserve_payment_frac)
THEN
my_balance.val=0;
my_balance.frac=my_balance.frac - in_reserve_payment.frac;
my_balance_val=0;
my_balance_frac=my_balance_frac - in_reserve_payment_frac;
ELSE
out_final_expiration = reserve.expiration_date;
out_open_cost.val = my_cost.val;
out_open_cost.frac = my_cost.frac;
out_final_expiration = my_reserve_expiration;
out_open_cost_val = my_cost_val;
out_open_cost_frac = my_cost_frac;
out_no_funds=TRUE;
RAISE NOTICE 'reserve balance too low';
RETURN;
@ -169,15 +193,17 @@ ELSE
END IF;
UPDATE reserves SET
current_balance=my_balance
,gc_date=reserve.expiration_date + in_reserve_gc_delay
current_balance_val=my_balance_val
,current_balance_frac=my_balance_frac
,gc_date=my_reserve_expiration + in_reserve_gc_delay
,expiration_date=my_expiration_date
,purses_allowed=reserve.purses_allowed
,purses_allowed=my_purses_allowed
WHERE
reserve_pub=in_reserve_pub;
out_final_expiration=my_expiration_date;
out_open_cost = my_cost;
out_open_cost_val = my_cost_val;
out_open_cost_frac = my_cost_frac;
out_no_funds=FALSE;
RETURN;

23
src/exchangedb/exchange_do_reserve_purse.sql
View File

@ -22,7 +22,8 @@ CREATE OR REPLACE FUNCTION exchange_do_reserve_purse(
IN in_reserve_gc INT8,
IN in_reserve_sig BYTEA,
IN in_reserve_quota BOOLEAN,
IN in_purse_fee taler_amount,
IN in_purse_fee_val INT8,
IN in_purse_fee_frac INT4,
IN in_reserve_pub BYTEA,
IN in_wallet_h_payto BYTEA,
OUT out_no_funds BOOLEAN,
@ -100,8 +101,8 @@ ELSE
-- UPDATE reserves balance (and check if balance is enough to pay the fee)
IF (out_no_reserve)
THEN
IF ( (0 != in_purse_fee.val) OR
(0 != in_purse_fee.frac) )
IF ( (0 != in_purse_fee_val) OR
(0 != in_purse_fee_frac) )
THEN
out_no_funds=TRUE;
RETURN;
@ -117,22 +118,22 @@ ELSE
ELSE
UPDATE exchange.reserves
SET
current_balance.frac=(current_balance).frac-in_purse_fee.frac
current_balance_frac=current_balance_frac-in_purse_fee_frac
+ CASE
WHEN (current_balance).frac < in_purse_fee.frac
WHEN current_balance_frac < in_purse_fee_frac
THEN 100000000
ELSE 0
END,
current_balance.val=(current_balance).val-in_purse_fee.val
current_balance_val=current_balance_val-in_purse_fee_val
- CASE
WHEN (current_balance).frac < in_purse_fee.frac
WHEN current_balance_frac < in_purse_fee_frac
THEN 1
ELSE 0
END
WHERE reserve_pub=in_reserve_pub
AND ( ((current_balance).val > in_purse_fee.val) OR
( ((current_balance).frac >= in_purse_fee.frac) AND
((current_balance).val >= in_purse_fee.val) ) );
AND ( (current_balance_val > in_purse_fee_val) OR
( (current_balance_frac >= in_purse_fee_frac) AND
(current_balance_val >= in_purse_fee_val) ) );
IF NOT FOUND
THEN
out_no_funds=TRUE;
@ -158,5 +159,5 @@ INSERT INTO exchange.account_merges
END $$;
COMMENT ON FUNCTION exchange_do_reserve_purse(BYTEA, BYTEA, INT8, INT8, INT8, BYTEA, BOOLEAN, taler_amount, BYTEA, BYTEA)
COMMENT ON FUNCTION exchange_do_reserve_purse(BYTEA, BYTEA, INT8, INT8, INT8, BYTEA, BOOLEAN, INT8, INT4, BYTEA, BYTEA)
IS 'Create a purse for a reserve.';

176
src/exchangedb/exchange_do_reserves_in_insert.sql
View File

@ -19,7 +19,8 @@ CREATE OR REPLACE FUNCTION exchange_do_batch_reserves_in_insert(
IN in_reserve_expiration INT8,
IN in_reserve_pub BYTEA,
IN in_wire_ref INT8,
IN in_credit taler_amount,
IN in_credit_val INT8,
IN in_credit_frac INT4,
IN in_exchange_account_name VARCHAR,
IN in_execution_date INT8,
IN in_wire_source_h_payto BYTEA,
@ -41,12 +42,14 @@ BEGIN
INSERT INTO reserves
(reserve_pub
,current_balance
,current_balance_val
,current_balance_frac
,expiration_date
,gc_date)
VALUES
(in_reserve_pub
,in_credit
,in_credit_val
,in_credit_frac
,in_reserve_expiration
,in_gc_date)
ON CONFLICT DO NOTHING
@ -64,8 +67,8 @@ BEGIN
VALUES
(in_reserve_pub
,in_wire_ref
,in_credit.val
,in_credit.frac
,in_credit_val
,in_credit_frac
,in_exchange_account_name
,in_wire_source_h_payto
,in_execution_date)
@ -87,7 +90,8 @@ CREATE OR REPLACE FUNCTION exchange_do_batch2_reserves_insert(
IN in_reserve_expiration INT8,
IN in0_reserve_pub BYTEA,
IN in0_wire_ref INT8,
IN in0_credit taler_amount,
IN in0_credit_val INT8,
IN in0_credit_frac INT4,
IN in0_exchange_account_name VARCHAR,
IN in0_execution_date INT8,
IN in0_wire_source_h_payto BYTEA,
@ -95,7 +99,8 @@ CREATE OR REPLACE FUNCTION exchange_do_batch2_reserves_insert(
IN in0_notify TEXT,
IN in1_reserve_pub BYTEA,
IN in1_wire_ref INT8,
IN in1_credit taler_amount,
IN in1_credit_val INT8,
IN in1_credit_frac INT4,
IN in1_exchange_account_name VARCHAR,
IN in1_execution_date INT8,
IN in1_wire_source_h_payto BYTEA,
@ -109,8 +114,11 @@ LANGUAGE plpgsql
AS $$
DECLARE
curs_reserve_exist REFCURSOR;
DECLARE
k INT8;
DECLARE
curs_transaction_exist REFCURSOR;
DECLARE
i RECORD;
BEGIN
transaction_duplicate0 = TRUE;
@ -130,16 +138,19 @@ BEGIN
WITH reserve_changes AS (
INSERT INTO reserves
(reserve_pub
,current_balance
,current_balance_val
,current_balance_frac
,expiration_date
,gc_date)
VALUES
(in0_reserve_pub
,in0_credit
,in0_credit_val
,in0_credit_frac
,in_reserve_expiration
,in_gc_date),
(in1_reserve_pub
,in1_credit
,in1_credit_val
,in1_credit_frac
,in_reserve_expiration
,in_gc_date)
ON CONFLICT DO NOTHING
@ -189,15 +200,15 @@ BEGIN
VALUES
(in0_reserve_pub
,in0_wire_ref
,in0_credit.val
,in0_credit.frac
,in0_credit_val
,in0_credit_frac
,in0_exchange_account_name
,in0_wire_source_h_payto
,in0_execution_date),
(in1_reserve_pub
,in1_wire_ref
,in1_credit.val
,in1_credit.frac
,in1_credit_val
,in1_credit_frac
,in1_exchange_account_name
,in1_wire_source_h_payto
,in1_execution_date)
@ -250,7 +261,8 @@ CREATE OR REPLACE FUNCTION exchange_do_batch4_reserves_insert(
IN in_reserve_expiration INT8,
IN in0_reserve_pub BYTEA,
IN in0_wire_ref INT8,
IN in0_credit taler_amount,
IN in0_credit_val INT8,
IN in0_credit_frac INT4,
IN in0_exchange_account_name VARCHAR,
IN in0_execution_date INT8,
IN in0_wire_source_h_payto BYTEA,
@ -258,7 +270,8 @@ CREATE OR REPLACE FUNCTION exchange_do_batch4_reserves_insert(
IN in0_notify TEXT,
IN in1_reserve_pub BYTEA,
IN in1_wire_ref INT8,
IN in1_credit taler_amount,
IN in1_credit_val INT8,
IN in1_credit_frac INT4,
IN in1_exchange_account_name VARCHAR,
IN in1_execution_date INT8,
IN in1_wire_source_h_payto BYTEA,
@ -266,7 +279,8 @@ CREATE OR REPLACE FUNCTION exchange_do_batch4_reserves_insert(
IN in1_notify TEXT,
IN in2_reserve_pub BYTEA,
IN in2_wire_ref INT8,
IN in2_credit taler_amount,
IN in2_credit_val INT8,
IN in2_credit_frac INT4,
IN in2_exchange_account_name VARCHAR,
IN in2_execution_date INT8,
IN in2_wire_source_h_payto BYTEA,
@ -274,7 +288,8 @@ CREATE OR REPLACE FUNCTION exchange_do_batch4_reserves_insert(
IN in2_notify TEXT,
IN in3_reserve_pub BYTEA,
IN in3_wire_ref INT8,
IN in3_credit taler_amount,
IN in3_credit_val INT8,
IN in3_credit_frac INT4,
IN in3_exchange_account_name VARCHAR,
IN in3_execution_date INT8,
IN in3_wire_source_h_payto BYTEA,
@ -292,8 +307,11 @@ LANGUAGE plpgsql
AS $$
DECLARE
curs_reserve_exist REFCURSOR;
DECLARE
k INT8;
DECLARE
curs_transaction_exist REFCURSOR;
DECLARE
i RECORD;
BEGIN
transaction_duplicate0=TRUE;
@ -319,24 +337,29 @@ BEGIN
WITH reserve_changes AS (
INSERT INTO reserves
(reserve_pub
,current_balance
,current_balance_val
,current_balance_frac
,expiration_date
,gc_date)
VALUES
(in0_reserve_pub
,in0_credit
,in0_credit_val
,in0_credit_frac
,in_reserve_expiration
,in_gc_date),
(in1_reserve_pub
,in1_credit
,in1_credit_val
,in1_credit_frac
,in_reserve_expiration
,in_gc_date),
(in2_reserve_pub
,in2_credit
,in2_credit_val
,in2_credit_frac
,in_reserve_expiration
,in_gc_date),
(in3_reserve_pub
,in3_credit
,in3_credit_val
,in3_credit_frac
,in_reserve_expiration
,in_gc_date)
ON CONFLICT DO NOTHING
@ -402,29 +425,29 @@ BEGIN
VALUES
(in0_reserve_pub
,in0_wire_ref
,in0_credit.val
,in0_credit.frac
,in0_credit_val
,in0_credit_frac
,in0_exchange_account_name
,in0_wire_source_h_payto
,in0_execution_date),
(in1_reserve_pub
,in1_wire_ref
,in1_credit.val
,in1_credit.frac
,in1_credit_val
,in1_credit_frac
,in1_exchange_account_name
,in1_wire_source_h_payto
,in1_execution_date),
(in2_reserve_pub
,in2_wire_ref
,in2_credit.val
,in2_credit.frac
,in2_credit_val
,in2_credit_frac
,in2_exchange_account_name
,in2_wire_source_h_payto
,in2_execution_date),
(in3_reserve_pub
,in3_wire_ref
,in3_credit.val
,in3_credit.frac
,in3_credit_val
,in3_credit_frac
,in3_exchange_account_name
,in3_wire_source_h_payto
,in3_execution_date)
@ -499,7 +522,8 @@ CREATE OR REPLACE FUNCTION exchange_do_batch8_reserves_insert(
IN in_reserve_expiration INT8,
IN in0_reserve_pub BYTEA,
IN in0_wire_ref INT8,
IN in0_credit taler_amount,
IN in0_credit_val INT8,
IN in0_credit_frac INT4,
IN in0_exchange_account_name VARCHAR,
IN in0_execution_date INT8,
IN in0_wire_source_h_payto BYTEA,
@ -507,7 +531,8 @@ CREATE OR REPLACE FUNCTION exchange_do_batch8_reserves_insert(
IN in0_notify TEXT,
IN in1_reserve_pub BYTEA,
IN in1_wire_ref INT8,
IN in1_credit taler_amount,
IN in1_credit_val INT8,
IN in1_credit_frac INT4,
IN in1_exchange_account_name VARCHAR,
IN in1_execution_date INT8,
IN in1_wire_source_h_payto BYTEA,
@ -515,7 +540,8 @@ CREATE OR REPLACE FUNCTION exchange_do_batch8_reserves_insert(
IN in1_notify TEXT,
IN in2_reserve_pub BYTEA,
IN in2_wire_ref INT8,
IN in2_credit taler_amount,
IN in2_credit_val INT8,
IN in2_credit_frac INT4,
IN in2_exchange_account_name VARCHAR,
IN in2_execution_date INT8,
IN in2_wire_source_h_payto BYTEA,
@ -523,7 +549,8 @@ CREATE OR REPLACE FUNCTION exchange_do_batch8_reserves_insert(
IN in2_notify TEXT,
IN in3_reserve_pub BYTEA,
IN in3_wire_ref INT8,
IN in3_credit taler_amount,
IN in3_credit_val INT8,
IN in3_credit_frac INT4,
IN in3_exchange_account_name VARCHAR,
IN in3_execution_date INT8,
IN in3_wire_source_h_payto BYTEA,
@ -531,7 +558,8 @@ CREATE OR REPLACE FUNCTION exchange_do_batch8_reserves_insert(
IN in3_notify TEXT,
IN in4_reserve_pub BYTEA,
IN in4_wire_ref INT8,
IN in4_credit taler_amount,
IN in4_credit_val INT8,
IN in4_credit_frac INT4,
IN in4_exchange_account_name VARCHAR,
IN in4_execution_date INT8,
IN in4_wire_source_h_payto BYTEA,
@ -539,7 +567,8 @@ CREATE OR REPLACE FUNCTION exchange_do_batch8_reserves_insert(
IN in4_notify TEXT,
IN in5_reserve_pub BYTEA,
IN in5_wire_ref INT8,
IN in5_credit taler_amount,
IN in5_credit_val INT8,
IN in5_credit_frac INT4,
IN in5_exchange_account_name VARCHAR,
IN in5_execution_date INT8,
IN in5_wire_source_h_payto BYTEA,
@ -547,7 +576,8 @@ CREATE OR REPLACE FUNCTION exchange_do_batch8_reserves_insert(
IN in5_notify TEXT,
IN in6_reserve_pub BYTEA,
IN in6_wire_ref INT8,
IN in6_credit taler_amount,
IN in6_credit_val INT8,
IN in6_credit_frac INT4,
IN in6_exchange_account_name VARCHAR,
IN in6_execution_date INT8,
IN in6_wire_source_h_payto BYTEA,
@ -555,7 +585,8 @@ CREATE OR REPLACE FUNCTION exchange_do_batch8_reserves_insert(
IN in6_notify TEXT,
IN in7_reserve_pub BYTEA,
IN in7_wire_ref INT8,
IN in7_credit taler_amount,
IN in7_credit_val INT8,
IN in7_credit_frac INT4,
IN in7_exchange_account_name VARCHAR,
IN in7_execution_date INT8,
IN in7_wire_source_h_payto BYTEA,
@ -581,9 +612,13 @@ LANGUAGE plpgsql
AS $$
DECLARE
curs_reserve_exist REFCURSOR;
DECLARE
k INT8;
DECLARE
curs_transaction_exist REFCURSOR;
DECLARE
i RECORD;
DECLARE
r RECORD;
BEGIN
@ -622,40 +657,49 @@ BEGIN
WITH reserve_changes AS (
INSERT INTO reserves
(reserve_pub
,current_balance
,current_balance_val
,current_balance_frac
,expiration_date
,gc_date)
VALUES
(in0_reserve_pub
,in0_credit
,in0_credit_val
,in0_credit_frac
,in_reserve_expiration
,in_gc_date),
(in1_reserve_pub
,in1_credit
,in1_credit_val
,in1_credit_frac
,in_reserve_expiration
,in_gc_date),
(in2_reserve_pub
,in2_credit
,in2_credit_val
,in2_credit_frac
,in_reserve_expiration
,in_gc_date),
(in3_reserve_pub
,in3_credit
,in3_credit_val
,in3_credit_frac
,in_reserve_expiration
,in_gc_date),
(in4_reserve_pub
,in4_credit
,in4_credit_val
,in4_credit_frac
,in_reserve_expiration
,in_gc_date),
(in5_reserve_pub
,in5_credit
,in5_credit_val
,in5_credit_frac
,in_reserve_expiration
,in_gc_date),
(in6_reserve_pub
,in6_credit
,in6_credit_val
,in6_credit_frac
,in_reserve_expiration
,in_gc_date),
(in7_reserve_pub
,in7_credit
,in7_credit_val
,in7_credit_frac
,in_reserve_expiration
,in_gc_date)
ON CONFLICT DO NOTHING
@ -758,57 +802,57 @@ BEGIN
VALUES
(in0_reserve_pub
,in0_wire_ref
,in0_credit.val
,in0_credit.frac
,in0_credit_val
,in0_credit_frac
,in0_exchange_account_name
,in0_wire_source_h_payto
,in0_execution_date),
(in1_reserve_pub
,in1_wire_ref
,in1_credit.val
,in1_credit.frac
,in1_credit_val
,in1_credit_frac
,in1_exchange_account_name
,in1_wire_source_h_payto
,in1_execution_date),
(in2_reserve_pub
,in2_wire_ref
,in2_credit.val
,in2_credit.frac
,in2_credit_val
,in2_credit_frac
,in2_exchange_account_name
,in2_wire_source_h_payto
,in2_execution_date),
(in3_reserve_pub
,in3_wire_ref
,in3_credit.val
,in3_credit.frac
,in3_credit_val
,in3_credit_frac
,in3_exchange_account_name
,in3_wire_source_h_payto
,in3_execution_date),
(in4_reserve_pub
,in4_wire_ref
,in4_credit.val
,in4_credit.frac
,in4_credit_val
,in4_credit_frac
,in4_exchange_account_name
,in4_wire_source_h_payto
,in4_execution_date),
(in5_reserve_pub
,in5_wire_ref
,in5_credit.val
,in5_credit.frac
,in5_credit_val
,in5_credit_frac
,in5_exchange_account_name
,in5_wire_source_h_payto
,in5_execution_date),
(in6_reserve_pub
,in6_wire_ref
,in6_credit.val
,in6_credit.frac
,in6_credit_val
,in6_credit_frac
,in6_exchange_account_name
,in6_wire_source_h_payto
,in6_execution_date),
(in7_reserve_pub
,in7_wire_ref
,in7_credit.val
,in7_credit.frac
,in7_credit_val
,in7_credit_frac
,in7_exchange_account_name
,in7_wire_source_h_payto
,in7_execution_date)
@ -939,9 +983,13 @@ LANGUAGE plpgsql
AS $$
DECLARE
curs REFCURSOR;
DECLARE
conflict BOOL;
DECLARE
dup BOOL;
DECLARE
uuid INT8;
DECLARE
i RECORD;
BEGIN

60
src/exchangedb/exchange_do_withdraw.sql
View File

@ -17,7 +17,8 @@
CREATE OR REPLACE FUNCTION exchange_do_withdraw(
IN cs_nonce BYTEA,
IN amount taler_amount,
IN amount_val INT8,
IN amount_frac INT4,
IN h_denom_pub BYTEA,
IN rpub BYTEA,
IN reserve_sig BYTEA,
@ -35,9 +36,11 @@ CREATE OR REPLACE FUNCTION exchange_do_withdraw(
LANGUAGE plpgsql
AS $$
DECLARE
reserve RECORD;
reserve_gc INT8;
denom_serial INT8;
balance taler_amount;
reserve_val INT8;
reserve_frac INT4;
reserve_birthday INT4;
not_before date;
BEGIN
-- Shards: reserves by reserve_pub (SELECT)
@ -64,8 +67,18 @@ THEN
END IF;
SELECT *
INTO reserve
SELECT
current_balance_val
,current_balance_frac
,gc_date
,birthday
,reserve_uuid
INTO
reserve_val
,reserve_frac
,reserve_gc
,reserve_birthday
,ruuid
FROM exchange.reserves
WHERE reserves.reserve_pub=rpub;
@ -81,11 +94,8 @@ THEN
RETURN;
END IF;
balance = reserve.current_balance;
ruuid = reserve.reserve_uuid;
-- Check if age requirements are present
IF ((NOT do_age_check) OR (reserve.birthday = 0))
IF ((NOT do_age_check) OR (reserve_birthday = 0))
THEN
age_ok = TRUE;
allowed_maximum_age = -1;
@ -95,7 +105,7 @@ ELSE
-- birthday set (reserve_birthday != 0), but the client called the
-- batch-withdraw endpoint instead of the age-withdraw endpoint, which it
-- should have.
not_before=date '1970-01-01' + reserve.birthday;
not_before=date '1970-01-01' + reserve_birthday;
allowed_maximum_age = extract(year from age(current_date, not_before));
reserve_found=TRUE;
@ -123,8 +133,8 @@ VALUES
,ruuid
,reserve_sig
,now
,amount.val
,amount.frac)
,amount_val
,amount_frac)
ON CONFLICT DO NOTHING;
IF NOT FOUND
@ -137,21 +147,21 @@ THEN
END IF;
-- Check reserve balance is sufficient.
IF (balance.val > amount.val)
IF (reserve_val > amount_val)
THEN
IF (balance.frac >= amount.frac)
IF (reserve_frac >= amount_frac)
THEN
balance.val=balance.val - amount.val;
balance.frac=balance.frac - amount.frac;
reserve_val=reserve_val - amount_val;
reserve_frac=reserve_frac - amount_frac;
ELSE
balance.val=balance.val - amount.val - 1;
balance.frac=balance.frac + 100000000 - amount.frac;
reserve_val=reserve_val - amount_val - 1;
reserve_frac=reserve_frac + 100000000 - amount_frac;
END IF;
ELSE
IF (balance.val = amount.val) AND (balance.frac >= amount.frac)
IF (reserve_val = amount_val) AND (reserve_frac >= amount_frac)
THEN
balance.val=0;
balance.frac=balance.frac - amount.frac;
reserve_val=0;
reserve_frac=reserve_frac - amount_frac;
ELSE
reserve_found=TRUE;
nonce_ok=TRUE; -- we do not really know
@ -161,12 +171,13 @@ ELSE
END IF;
-- Calculate new expiration dates.
min_reserve_gc=GREATEST(min_reserve_gc,reserve.gc_date);
min_reserve_gc=GREATEST(min_reserve_gc,reserve_gc);
-- Update reserve balance.
UPDATE reserves SET
gc_date=min_reserve_gc
,current_balance=balance
,current_balance_val=reserve_val
,current_balance_frac=reserve_frac
WHERE
reserves.reserve_pub=rpub;
@ -211,6 +222,7 @@ END IF;
END $$;
COMMENT ON FUNCTION exchange_do_withdraw(BYTEA, taler_amount, BYTEA, BYTEA, BYTEA, BYTEA, BYTEA, INT8, INT8, BOOLEAN)
COMMENT ON FUNCTION exchange_do_withdraw(BYTEA, INT8, INT4, BYTEA, BYTEA, BYTEA, BYTEA, BYTEA, INT8, INT8, BOOLEAN)
IS 'Checks whether the reserve has sufficient balance for a withdraw operation (or the request is repeated and was previously approved) and if the age requirements are formally met. If so updates the database with the result';

5
src/exchangedb/pg_do_batch_withdraw.c
View File

@ -43,8 +43,7 @@ TEH_PG_do_batch_withdraw (
struct PostgresClosure *pg = cls;
struct GNUNET_TIME_Timestamp gc;
struct GNUNET_PQ_QueryParam params[] = {
TALER_PQ_query_param_amount_tuple (pg->conn,
amount),
TALER_PQ_query_param_amount (amount),
GNUNET_PQ_query_param_auto_from_type (reserve_pub),
GNUNET_PQ_query_param_timestamp (&now),
GNUNET_PQ_query_param_timestamp (&gc),
@ -81,7 +80,7 @@ TEH_PG_do_batch_withdraw (
",allowed_maximum_age"
",ruuid"
" FROM exchange_do_batch_withdraw"
" ($1,$2,$3,$4,$5);");
" ($1,$2,$3,$4,$5,$6);");
return GNUNET_PQ_eval_prepared_singleton_select (pg->conn,
"call_batch_withdraw",
params,

5
src/exchangedb/pg_do_batch_withdraw_insert.c
View File

@ -41,8 +41,7 @@ TEH_PG_do_batch_withdraw_insert (
NULL == nonce
? GNUNET_PQ_query_param_null ()
: GNUNET_PQ_query_param_auto_from_type (nonce),
TALER_PQ_query_param_amount_tuple (pg->conn,
&collectable->amount_with_fee),
TALER_PQ_query_param_amount (&collectable->amount_with_fee),
GNUNET_PQ_query_param_auto_from_type (&collectable->denom_pub_hash),
GNUNET_PQ_query_param_uint64 (&ruuid),
GNUNET_PQ_query_param_auto_from_type (&collectable->reserve_sig),
@ -70,7 +69,7 @@ TEH_PG_do_batch_withdraw_insert (
",out_conflict AS conflict"
",out_nonce_reuse AS nonce_reuse"
" FROM exchange_do_batch_withdraw_insert"
" ($1,$2,$3,$4,$5,$6,$7,$8);");
" ($1,$2,$3,$4,$5,$6,$7,$8,$9);");
return GNUNET_PQ_eval_prepared_singleton_select (pg->conn,
"call_batch_withdraw_insert",
params,

10
src/exchangedb/pg_do_purse_deposit.c
View File

@ -47,14 +47,10 @@ TEH_PG_do_purse_deposit (
? GNUNET_PQ_query_param_null ()
: GNUNET_PQ_query_param_uint64 (&partner_id),
GNUNET_PQ_query_param_auto_from_type (purse_pub),
TALER_PQ_query_param_amount_tuple (
pg->conn,
amount),
TALER_PQ_query_param_amount (amount),
GNUNET_PQ_query_param_auto_from_type (coin_pub),
GNUNET_PQ_query_param_auto_from_type (coin_sig),
TALER_PQ_query_param_amount_tuple (
pg->conn,
amount_minus_fee),
TALER_PQ_query_param_amount (amount_minus_fee),
GNUNET_PQ_query_param_timestamp (&reserve_expiration),
GNUNET_PQ_query_param_timestamp (&now),
GNUNET_PQ_query_param_end
@ -81,7 +77,7 @@ TEH_PG_do_purse_deposit (
",out_conflict AS conflict"
",out_late AS too_late"
" FROM exchange_do_purse_deposit"
" ($1,$2,$3,$4,$5,$6,$7,$8);");
" ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10);");
return GNUNET_PQ_eval_prepared_singleton_select (pg->conn,
"call_purse_deposit",

21
src/exchangedb/pg_do_reserve_open.c
View File

@ -44,26 +44,20 @@ TEH_PG_do_reserve_open (
struct PostgresClosure *pg = cls;
struct GNUNET_PQ_QueryParam params[] = {
GNUNET_PQ_query_param_auto_from_type (reserve_pub),
TALER_PQ_query_param_amount_tuple (
pg->conn,
total_paid),
TALER_PQ_query_param_amount_tuple (
pg->conn,
reserve_payment),
TALER_PQ_query_param_amount (total_paid),
TALER_PQ_query_param_amount (reserve_payment),
GNUNET_PQ_query_param_uint32 (&min_purse_limit),
GNUNET_PQ_query_param_uint32 (&pg->def_purse_limit),
GNUNET_PQ_query_param_auto_from_type (reserve_sig),
GNUNET_PQ_query_param_timestamp (&desired_expiration),
GNUNET_PQ_query_param_relative_time (&pg->legal_reserve_expiration_time),
GNUNET_PQ_query_param_timestamp (&now),
TALER_PQ_query_param_amount_tuple (pg->conn,
open_fee),
TALER_PQ_query_param_amount (open_fee),
GNUNET_PQ_query_param_end
};
struct GNUNET_PQ_ResultSpec rs[] = {
TALER_PQ_result_spec_amount_tuple ("out_open_cost",
pg->currency,
open_cost),
TALER_PQ_RESULT_SPEC_AMOUNT ("out_open_cost",
open_cost),
GNUNET_PQ_result_spec_timestamp ("out_final_expiration",
final_expiration),
GNUNET_PQ_result_spec_bool ("out_no_funds",
@ -74,11 +68,12 @@ TEH_PG_do_reserve_open (
PREPARE (pg,
"do_reserve_open",
"SELECT "
" out_open_cost"
" out_open_cost_val"
",out_open_cost_frac"
",out_final_expiration"
",out_no_funds"
" FROM exchange_do_reserve_open"
" ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10);");
" ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10,$11,$12,$13);");
return GNUNET_PQ_eval_prepared_singleton_select (pg->conn,
"do_reserve_open",
params,

9
src/exchangedb/pg_do_reserve_purse.c
View File

@ -74,10 +74,9 @@ TEH_PG_do_reserve_purse (
GNUNET_PQ_query_param_timestamp (&reserve_gc),
GNUNET_PQ_query_param_auto_from_type (reserve_sig),
GNUNET_PQ_query_param_bool (NULL == purse_fee),
TALER_PQ_query_param_amount_tuple (pg->conn,
NULL == purse_fee
? &zero_fee
: purse_fee),
TALER_PQ_query_param_amount (NULL == purse_fee
? &zero_fee
: purse_fee),
GNUNET_PQ_query_param_auto_from_type (reserve_pub),
GNUNET_PQ_query_param_auto_from_type (&h_payto),
GNUNET_PQ_query_param_end
@ -112,7 +111,7 @@ TEH_PG_do_reserve_purse (
",out_no_reserve AS no_reserve"
",out_conflict AS conflict"
" FROM exchange_do_reserve_purse"
" ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10);");
" ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11);");
return GNUNET_PQ_eval_prepared_singleton_select (pg->conn,
"call_reserve_purse",

5
src/exchangedb/pg_do_withdraw.c
View File

@ -46,8 +46,7 @@ TEH_PG_do_withdraw (
NULL == nonce
? GNUNET_PQ_query_param_null ()
: GNUNET_PQ_query_param_auto_from_type (nonce),
TALER_PQ_query_param_amount_tuple (pg->conn,
&collectable->amount_with_fee),
TALER_PQ_query_param_amount (&collectable->amount_with_fee),
GNUNET_PQ_query_param_auto_from_type (&collectable->denom_pub_hash),
GNUNET_PQ_query_param_auto_from_type (&collectable->reserve_pub),
GNUNET_PQ_query_param_auto_from_type (&collectable->reserve_sig),
@ -84,7 +83,7 @@ TEH_PG_do_withdraw (
",allowed_maximum_age"
",ruuid"
" FROM exchange_do_withdraw"
" ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10);");
" ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10,$11);");
gc = GNUNET_TIME_absolute_to_timestamp (
GNUNET_TIME_absolute_add (now.abs_time,
pg->legal_reserve_expiration_time));

10
src/exchangedb/pg_get_expired_reserves.c
View File

@ -84,9 +84,8 @@ reserve_expired_cb (void *cls,
&account_details),
GNUNET_PQ_result_spec_auto_from_type ("reserve_pub",
&reserve_pub),
TALER_PQ_result_spec_amount_tuple ("current_balance",
pg->currency,
&remaining_balance),
TALER_PQ_RESULT_SPEC_AMOUNT ("current_balance",
&remaining_balance),
GNUNET_PQ_result_spec_end
};
@ -138,7 +137,7 @@ TEH_PG_get_expired_reserves (void *cls,
" SELECT * "
" FROM reserves "
" WHERE expiration_date <= $1 "
" AND ((current_balance).val != 0 OR (current_balance).frac != 0) "
" AND (current_balance_val != 0 OR current_balance_frac != 0) "
" ORDER BY expiration_date ASC "
" LIMIT 1 "
") "
@ -146,7 +145,8 @@ TEH_PG_get_expired_reserves (void *cls,
" ed.expiration_date "
" ,payto_uri AS account_details "
" ,ed.reserve_pub "
" ,current_balance "
" ,current_balance_val "
" ,current_balance_frac "
"FROM ( "
" SELECT "
" * "

8
src/exchangedb/pg_get_reserve_balance.c
View File

@ -36,16 +36,16 @@ TEH_PG_get_reserve_balance (void *cls,
GNUNET_PQ_query_param_end
};
struct GNUNET_PQ_ResultSpec rs[] = {
TALER_PQ_result_spec_amount_tuple ("current_balance",
pg->currency,
balance),
TALER_PQ_RESULT_SPEC_AMOUNT ("current_balance",
balance),
GNUNET_PQ_result_spec_end
};
PREPARE (pg,
"get_reserve_balance",
"SELECT"
" current_balance"
" current_balance_val"
",current_balance_frac"
" FROM reserves"
" WHERE reserve_pub=$1;");
return GNUNET_PQ_eval_prepared_singleton_select (pg->conn,

5
src/exchangedb/pg_insert_history_request.c
View File

@ -41,8 +41,7 @@ TEH_PG_insert_history_request (
GNUNET_PQ_query_param_auto_from_type (reserve_pub),
GNUNET_PQ_query_param_auto_from_type (reserve_sig),
GNUNET_PQ_query_param_timestamp (&request_timestamp),
TALER_PQ_query_param_amount_tuple (pg->conn,
history_fee),
TALER_PQ_query_param_amount (history_fee),
GNUNET_PQ_query_param_end
};
struct GNUNET_PQ_ResultSpec rs[] = {
@ -59,7 +58,7 @@ TEH_PG_insert_history_request (
" out_balance_ok AS balance_ok"
" ,out_idempotent AS idempotent"
" FROM exchange_do_history_request"
" ($1, $2, $3, $4)");
" ($1, $2, $3, $4, $5)");
return GNUNET_PQ_eval_prepared_singleton_select (pg->conn,
"call_history_request",
params,

8
src/exchangedb/pg_reserves_get.c
View File

@ -35,9 +35,8 @@ TEH_PG_reserves_get (void *cls,
GNUNET_PQ_query_param_end
};
struct GNUNET_PQ_ResultSpec rs[] = {
TALER_PQ_result_spec_amount_tuple ("current_balance",
pg->currency,
&reserve->balance),
TALER_PQ_RESULT_SPEC_AMOUNT ("current_balance",
&reserve->balance),
GNUNET_PQ_result_spec_timestamp ("expiration_date",
&reserve->expiry),
GNUNET_PQ_result_spec_timestamp ("gc_date",
@ -48,7 +47,8 @@ TEH_PG_reserves_get (void *cls,
PREPARE (pg,
"reserves_get",
"SELECT"
" current_balance"
" current_balance_val"
",current_balance_frac"
",expiration_date"
",gc_date"
" FROM reserves"

16
src/exchangedb/pg_reserves_in_insert.c
View File

@ -100,7 +100,7 @@ struct ReserveRecord
#define RR_QUERY_PARAM(rr,index) \
GNUNET_PQ_query_param_auto_from_type (rr[index].reserve->reserve_pub), \
GNUNET_PQ_query_param_uint64 (&rr[index].reserve->wire_reference), \
TALER_PQ_query_param_amount_tuple (pg->conn, rr[index].reserve->balance), \
TALER_PQ_query_param_amount (rr[index].reserve->balance), \
GNUNET_PQ_query_param_string (rr[index].reserve->exchange_account_name), \
GNUNET_PQ_query_param_timestamp (&rr[index].reserve->execution_time), \
GNUNET_PQ_query_param_auto_from_type (&rr[index].h_payto), \
@ -154,7 +154,7 @@ insert1 (struct PostgresClosure *pg,
" transaction_duplicate0 AS transaction_duplicate0"
",ruuid0 AS reserve_uuid0"
" FROM exchange_do_batch_reserves_in_insert"
" ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10);");
" ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10,$11);");
qs = GNUNET_PQ_eval_prepared_singleton_select (pg->conn,
"batch1_reserve_create",
params,
@ -214,7 +214,7 @@ insert2 (struct PostgresClosure *pg,
",ruuid0 AS reserve_uuid0"
",ruuid1 AS reserve_uuid1"
" FROM exchange_do_batch2_reserves_insert"
" ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10,$11,$12,$13,$14,$15,$16,$17,$18);");
" ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10,$11,$12,$13,$14,$15,$16,$17,$18,$19,$20);");
qs = GNUNET_PQ_eval_prepared_singleton_select (pg->conn,
"batch2_reserve_create",
params,
@ -285,7 +285,7 @@ insert4 (struct PostgresClosure *pg,
",ruuid2 AS reserve_uuid2"
",ruuid3 AS reserve_uuid3"
" FROM exchange_do_batch4_reserves_insert"
" ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10,$11,$12,$13,$14,$15,$16,$17,$18,$19,$20,$21,$22,$23,$24,$25,$26,$27,$28,$29,$30,$31,$32,$33,$34);");
" ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10,$11,$12,$13,$14,$15,$16,$17,$18,$19,$20,$21,$22,$23,$24,$25,$26,$27,$28,$29,$30,$31,$32,$33,$34,$35,$36,$37,$38);");
qs = GNUNET_PQ_eval_prepared_singleton_select (pg->conn,
"batch4_reserve_create",
params,
@ -373,7 +373,7 @@ insert8 (struct PostgresClosure *pg,
",ruuid6 AS reserve_uuid6"
",ruuid7 AS reserve_uuid7"
" FROM exchange_do_batch8_reserves_insert"
" ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10,$11,$12,$13,$14,$15,$16,$17,$18,$19,$20,$21,$22,$23,$24,$25,$26,$27,$28,$29,$30,$31,$32,$33,$34,$35,$36,$37,$38,$39, $40, $41,$42,$43,$44,$45,$46,$47,$48,$49,$50,$51,$52,$53,$54,$55,$56,$57,$58,$59,$60,$61,$62,$63,$64,$65,$66);");
" ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10,$11,$12,$13,$14,$15,$16,$17,$18,$19,$20,$21,$22,$23,$24,$25,$26,$27,$28,$29,$30,$31,$32,$33,$34,$35,$36,$37,$38,$39, $40, $41,$42,$43,$44,$45,$46,$47,$48,$49,$50,$51,$52,$53,$54,$55,$56,$57,$58,$59,$60,$61,$62,$63,$64,$65,$66,$67,$68,$69,$70,$71,$72,$73,$74);");
qs = GNUNET_PQ_eval_prepared_singleton_select (pg->conn,
"batch8_reserve_create",
@ -537,8 +537,7 @@ transact (
GNUNET_PQ_query_param_auto_from_type (rr[i].reserve->reserve_pub),
GNUNET_PQ_query_param_timestamp (&reserve_expiration),
GNUNET_PQ_query_param_uint64 (&rr[i].reserve->wire_reference),
TALER_PQ_query_param_amount_tuple (pg->conn,
rr[i].reserve->balance),
TALER_PQ_query_param_amount (rr[i].reserve->balance),
GNUNET_PQ_query_param_string (rr[i].reserve->exchange_account_name),
GNUNET_PQ_query_param_auto_from_type (&rr[i].h_payto),
GNUNET_PQ_query_param_string (rr[i].notify_s),
@ -860,8 +859,7 @@ TEH_PG_reserves_in_insertN (
GNUNET_PQ_query_param_auto_from_type (reserve_pubs[i]),
GNUNET_PQ_query_param_timestamp (&reserve_expiration),
GNUNET_PQ_query_param_uint64 (&wire_reference[i]),
TALER_PQ_query_param_amount_tuple (pg->conn,
balances[i]),
TALER_PQ_query_param_amount (balances[i]),
GNUNET_PQ_query_param_string (exchange_account_names[i]),
GNUNET_PQ_query_param_auto_from_type (h_paytos[i]),
GNUNET_PQ_query_param_string (notify_s[i]),

8
src/exchangedb/pg_reserves_update.c
View File

@ -33,8 +33,7 @@ TEH_PG_reserves_update (void *cls,
struct GNUNET_PQ_QueryParam params[] = {
GNUNET_PQ_query_param_timestamp (&reserve->expiry),
GNUNET_PQ_query_param_timestamp (&reserve->gc),
TALER_PQ_query_param_amount_tuple (pg->conn,
&reserve->balance),
TALER_PQ_query_param_amount (&reserve->balance),
GNUNET_PQ_query_param_auto_from_type (&reserve->pub),
GNUNET_PQ_query_param_end
};
@ -45,8 +44,9 @@ TEH_PG_reserves_update (void *cls,
" SET"
" expiration_date=$1"
",gc_date=$2"
",current_balance=$3"
" WHERE reserve_pub=$4;");
",current_balance_val=$3"
",current_balance_frac=$4"
" WHERE reserve_pub=$5;");
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
"reserve_update",
params);

8
src/exchangedb/pg_select_reserve_close_info.c
View File

@ -39,9 +39,8 @@ TEH_PG_select_reserve_close_info (
GNUNET_PQ_query_param_end
};
struct GNUNET_PQ_ResultSpec rs[] = {
TALER_PQ_result_spec_amount_tuple ("current_balance",
pg->currency,
balance),
TALER_PQ_RESULT_SPEC_AMOUNT ("current_balance",
balance),
GNUNET_PQ_result_spec_string ("payto_uri",
payto_uri),
GNUNET_PQ_result_spec_end
@ -50,7 +49,8 @@ TEH_PG_select_reserve_close_info (
PREPARE (pg,
"select_reserve_close_info",
"SELECT "
" r.current_balance"
" r.current_balance_val"
",r.current_balance_frac"
",wt.payto_uri"
" FROM reserves r"
" LEFT JOIN reserves_in ri USING (reserve_pub)"

14
src/exchangedb/plugin_exchangedb_postgres.c
View File

@ -294,6 +294,14 @@ TEH_PG_internal_setup (struct PostgresClosure *pg)
if (NULL == db_conn)
return GNUNET_SYSERR;
if (GNUNET_OK != TALER_PQ_load_oids_for_composite_types (db_conn))
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"Failed to load OIDs for composite types\n");
GNUNET_PQ_disconnect (db_conn);
return GNUNET_SYSERR;
}
pg->prep_gen++;
pg->conn = db_conn;
}
@ -779,12 +787,6 @@ libtaler_plugin_exchangedb_postgres_init (void *cls)
plugin->batch_ensure_coin_known
= &TEH_PG_batch_ensure_coin_known;
if (GNUNET_OK != TALER_PQ_load_oids_for_composite_types (pg->conn))
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"Failed to load OIDs for composite types\n");
}
return plugin;
}