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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
|
BEGIN;
SET search_path TO libeufin_nexus;
CREATE OR REPLACE FUNCTION create_incoming_and_bounce(
IN in_amount taler_amount
,IN in_wire_transfer_subject TEXT
,IN in_execution_time BIGINT
,IN in_debit_payto_uri TEXT
,IN in_bank_transfer_id TEXT
,IN in_timestamp BIGINT
,IN in_request_uid TEXT
,IN in_refund_amount taler_amount
,OUT out_ok BOOLEAN
) RETURNS BOOLEAN
LANGUAGE plpgsql AS $$
DECLARE
new_tx_id INT8;
new_init_id INT8;
BEGIN
-- creating the bounced incoming transaction.
INSERT INTO incoming_transactions (
amount
,wire_transfer_subject
,execution_time
,debit_payto_uri
,bank_transfer_id
) VALUES (
in_amount
,in_wire_transfer_subject
,in_execution_time
,in_debit_payto_uri
,in_bank_transfer_id
) RETURNING incoming_transaction_id INTO new_tx_id;
-- creating its reimbursement.
INSERT INTO initiated_outgoing_transactions (
amount
,wire_transfer_subject
,credit_payto_uri
,initiation_time
,request_uid
) VALUES (
in_refund_amount
,'refund: ' || in_wire_transfer_subject
,in_debit_payto_uri
,in_timestamp
,in_request_uid
) RETURNING initiated_outgoing_transaction_id INTO new_init_id;
INSERT INTO bounced_transactions (
incoming_transaction_id
,initiated_outgoing_transaction_id
) VALUES (
new_tx_id
,new_init_id
);
out_ok = TRUE;
END $$;
COMMENT ON FUNCTION create_incoming_and_bounce(taler_amount, TEXT, BIGINT, TEXT, TEXT, BIGINT, TEXT, taler_amount)
IS 'creates one incoming transaction with a bounced state and initiates its related refund.';
CREATE OR REPLACE FUNCTION create_outgoing_payment(
IN in_amount taler_amount
,IN in_wire_transfer_subject TEXT
,IN in_execution_time BIGINT
,IN in_credit_payto_uri TEXT
,IN in_bank_transfer_id TEXT
,IN in_initiated_id BIGINT
,OUT out_nx_initiated BOOLEAN
)
LANGUAGE plpgsql AS $$
DECLARE
new_outgoing_transaction_id BIGINT;
BEGIN
IF in_initiated_id IS NULL THEN
out_nx_initiated = FALSE;
ELSE
PERFORM 1
FROM initiated_outgoing_transactions
WHERE initiated_outgoing_transaction_id = in_initiated_id;
IF NOT FOUND THEN
out_nx_initiated = TRUE;
RETURN;
END IF;
END IF;
INSERT INTO outgoing_transactions (
amount
,wire_transfer_subject
,execution_time
,credit_payto_uri
,bank_transfer_id
) VALUES (
in_amount
,in_wire_transfer_subject
,in_execution_time
,in_credit_payto_uri
,in_bank_transfer_id
)
RETURNING outgoing_transaction_id
INTO new_outgoing_transaction_id;
IF in_initiated_id IS NOT NULL
THEN
UPDATE initiated_outgoing_transactions
SET outgoing_transaction_id = new_outgoing_transaction_id
WHERE initiated_outgoing_transaction_id = in_initiated_id;
END IF;
END $$;
COMMENT ON FUNCTION create_outgoing_payment(taler_amount, TEXT, BIGINT, TEXT, TEXT, BIGINT)
IS 'Creates a new outgoing payment and optionally reconciles the related initiated payment with it. If the initiated payment to reconcile is not found, it inserts NOTHING.';
CREATE OR REPLACE FUNCTION bounce_payment(
IN in_incoming_transaction_id BIGINT
,IN in_initiation_time BIGINT
,IN in_request_uid TEXT
,OUT out_nx_incoming_payment BOOLEAN
)
LANGUAGE plpgsql AS $$
BEGIN
INSERT INTO initiated_outgoing_transactions (
amount
,wire_transfer_subject
,credit_payto_uri
,initiation_time
,request_uid
)
SELECT
amount
,'refund: ' || wire_transfer_subject
,debit_payto_uri
,in_initiation_time
,in_request_uid
FROM incoming_transactions
WHERE incoming_transaction_id = in_incoming_transaction_id;
IF NOT FOUND THEN
out_nx_incoming_payment=TRUE;
RETURN;
END IF;
out_nx_incoming_payment=FALSE;
-- finally setting the payment as bounced. Not checking
-- the update outcome since the row existence was checked
-- just above.
UPDATE incoming_transactions
SET bounced = true
WHERE incoming_transaction_id = in_incoming_transaction_id;
END $$;
COMMENT ON FUNCTION bounce_payment(BIGINT, BIGINT, TEXT) IS 'Marks an incoming payment as bounced and initiates its refunding payment';
CREATE OR REPLACE FUNCTION create_incoming_talerable(
IN in_amount taler_amount
,IN in_wire_transfer_subject TEXT
,IN in_execution_time BIGINT
,IN in_debit_payto_uri TEXT
,IN in_bank_transfer_id TEXT
,IN in_reserve_public_key BYTEA
,OUT out_ok BOOLEAN
) RETURNS BOOLEAN
LANGUAGE plpgsql AS $$
DECLARE
new_tx_id INT8;
BEGIN
INSERT INTO incoming_transactions (
amount
,wire_transfer_subject
,execution_time
,debit_payto_uri
,bank_transfer_id
) VALUES (
in_amount
,in_wire_transfer_subject
,in_execution_time
,in_debit_payto_uri
,in_bank_transfer_id
) RETURNING incoming_transaction_id INTO new_tx_id;
INSERT INTO talerable_incoming_transactions (
incoming_transaction_id
,reserve_public_key
) VALUES (
new_tx_id
,in_reserve_public_key
);
out_ok = TRUE;
END $$;
COMMENT ON FUNCTION create_incoming_talerable(taler_amount, TEXT, BIGINT, TEXT, TEXT, BYTEA) IS '
Creates one row in the incoming transactions table and one row
in the talerable transactions table. The talerable row links the
incoming one.';
|
