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
198
199
200
|
/*
This file is part of TALER
(C) 2014, 2015 Christian Grothoff (and other contributing authors)
TALER is free software; you can redistribute it and/or modify it under the
terms of the GNU General Public License as published by the Free Software
Foundation; either version 3, or (at your option) any later version.
TALER is distributed in the hope that it will be useful, but WITHOUT ANY
WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
A PARTICULAR PURPOSE. See the GNU General Public License for more details.
You should have received a copy of the GNU General Public License along with
TALER; see the file COPYING. If not, If not, see <http://www.gnu.org/licenses/>
*/
/**
* @file include/taler_merchantdb_lib.h
* @brief database helper functions used by the merchant backend
* @author Sree Harsha Totakura <sreeharsha@totakura.in>
*/
#ifndef MERCHANT_DB_H
#define MERCHANT_DB_H
#include <gnunet/gnunet_postgres_lib.h>
#include <taler/taler_util.h>
/* Set of values that represent a contract. To be expanded on an
as-needed basis */
struct MERCHANT_contract_handle
{
/* The nounce used when hashing the wire details
for this contract */
uint64_t nounce;
/* The maximum time when the merchant expects the money tranfer
to his bank account to happen */
struct GNUNET_TIME_Absolute edate;
/* The time when this contract was generated */
struct GNUNET_TIME_Absolute timestamp;
/* The maximum time until which the merchant could issue a
refund to the customer */
struct GNUNET_TIME_Absolute refund_deadline;
/* The identification number for this contract */
uint64_t contract_id;
};
/**
* Connect to postgresql database
*
* @param cfg the configuration handle
* @return connection to the postgresql database; NULL upon error
*/
PGconn *
MERCHANT_DB_connect (const struct GNUNET_CONFIGURATION_Handle *cfg);
/**
* Disconnect from the database
*
* @param conn database handle to close
*/
void
MERCHANT_DB_disconnect (PGconn *conn);
/**
* Initialize merchant tables
*
* @param conn the connection handle to postgres db.
* @param tmp GNUNET_YES if the tables are to be made temporary i.e. their
* contents are dropped when the @a conn is closed
* @return GNUNET_OK upon success; GNUNET_SYSERR upon failure
*/
int
MERCHANT_DB_initialize (PGconn *conn, int tmp);
/**
* Inserts a contract record into the database and if successfull returns the
* serial number of the inserted row.
*
* @param conn the database connection
* @param timestamp the timestamp of this contract
* @param expiry the time when the contract will expire
* @param edate when the merchant wants to receive the wire transfer corresponding
* to this deal (this value is also a field inside the 'wire' JSON format)
* @param refund deadline until which the merchant can return the paid amount
* @param amount the taler amount corresponding to the contract
* @param hash of the stringified JSON corresponding to this contract
* @param c_id contract's id
* @param desc descripition of the contract
* @param nounce a random 64-bit nounce
* @param product description to identify a product
* @return #GNUNET_OK on success, #GNUNET_SYSERR upon error
*/
uint32_t
MERCHANT_DB_contract_create (PGconn *conn,
const struct GNUNET_TIME_Absolute timestamp,
const struct GNUNET_TIME_Absolute expiry,
struct GNUNET_TIME_Absolute edate,
struct GNUNET_TIME_Absolute refund,
const struct TALER_Amount *amount,
const struct GNUNET_HashCode *h_contract,
uint64_t c_id,
const char *desc,
uint64_t nounce,
uint64_t product);
long long
MERCHANT_DB_get_contract_product (PGconn *conn,
uint64_t contract_id);
/**
* Update the pending column of a deposit permission
*
* @param conn handle to DB
* @param transaction_id identification number of the deposit to
* update
* @param pending true if still pending, false otherwise (i.e. the
* mint did respond something)
* @return #GNUNET_OK if successful, #GNUNET_SYSERR upon errors
*/
uint32_t
MERCHANT_DB_update_deposit_permission (PGconn *conn,
uint64_t transaction_id,
unsigned int pending);
unsigned int
MERCHANT_DB_checkout_create (PGconn *conn,
struct GNUNET_CRYPTO_rsa_PublicKey *coin_pub,
uint64_t transaction_id,
struct TALER_Amount *amount,
struct GNUNET_CRYPTO_rsa_Signature *coin_sig);
long long
MERCHANT_DB_get_checkout_product (PGconn *conn,
struct GNUNET_CRYPTO_rsa_PublicKey *coin_pub);
/**
* The query gets a contract's nounce and edate used to reproduce
* a 'wire' JSON object. This function is also useful to check whether
* a claimed contract existed or not.
*
* @param conn handle to the DB
* @param h_contract the parameter for the row to match against
* @param nounce where to store the found nounce
* @param edate where to store the found expiration date
* @return #GNUNET_OK on success, #GNUNET_SYSERR upon errors
*/
uint32_t
MERCHANT_DB_get_contract_values (PGconn *conn,
const struct GNUNET_HashCode *h_contract,
uint64_t *nounce,
struct GNUNET_TIME_Absolute *edate);
#endif /* MERCHANT_DB_H */
/**
* Get a set of values representing a contract. This function is meant
* to obsolete the '_get_contract_values' version.
*
* @param h_contract the hashcode of this contract
* @param contract_handle where to store the results
* @raturn #GNUNET_OK in case of success, #GNUNET_SYSERR
* upon errors
*/
uint32_t
MERCHANT_DB_get_contract_handle (PGconn *conn,
const struct GNUNET_HashCode *h_contract,
struct MERCHANT_contract_handle *contract_handle);
/**
* Store a deposit permission in DB. To be mainly used if /deposit should
* be retried; also, the merchant can benefit from this information in case
* he needs to later investigate about some transaction_id.
* @param conn DB handle
* @param transaction_id identification number of this payment (which is the
* same id of the related contract)
* @param pending if true, this payment got to a persistent state
* @param which mint is to get this deposit permission
* @return #GNUNET_OK if successful, #GNUNET_SYSERR upon errors
*/
uint32_t
MERCHANT_DB_store_deposit_permission (PGconn *conn,
const char *deposit_permission,
uint64_t transaction_id,
unsigned int pending,
const char *mint_url);
/* end of merchant-db.h */
|
