-
Notifications
You must be signed in to change notification settings - Fork 3
/
PaymentProcessor.groovy
240 lines (189 loc) · 8.97 KB
/
PaymentProcessor.groovy
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
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
/**
* Created by jeremy on 1/04/14.
*/
@Grab(group='log4j', module='log4j', version='1.2.17')
@Grab(group='org.xerial', module='sqlite-jdbc', version='3.7.2')
import org.apache.log4j.*
import groovy.sql.Sql
class PaymentProcessor {
static counterpartyAPI
static bitcoinAPI
static boolean testMode
// static String listenerBitcoinAddress
static String walletPassphrase
static int sleepIntervalms
static String databaseName
static String counterpartyTransactionEncoding
static int walletUnlockSeconds
static logger
static log4j
// static groovyx.net.http.AsyncHTTPBuilder HttpAsync
static db
class Payment {
//blockIdSource integer, txid string, sourceAddress string, inAsset string, inAmount integer, outAsset string, outAmount integer, status string, lastUpdatedBlockId integer
def blockIdSource
def txid
def sourceAddress
def destinationAddress
def outAsset
def outAmount
def status
def lastUpdatedBlockId
public Payment(blockIsSourceValue, txidValue, sourceAddressValue, destinationAddressValue, outAssetValue, outAmountValue, statusValue, lastUpdatedBlockIdValue) {
blockIdSource = blockIsSourceValue
txid = txidValue
sourceAddress = sourceAddressValue
destinationAddress = destinationAddressValue
outAsset = outAssetValue
outAmount = outAmountValue
status = statusValue
lastUpdatedBlockId = lastUpdatedBlockIdValue
}
}
public init() {
counterpartyAPI = new CounterpartyAPI()
bitcoinAPI = new BitcoinAPI()
// Set up some log4j stuff
logger = new Logger()
PropertyConfigurator.configure("PaymentProcessor_log4j.properties")
log4j = logger.getRootLogger()
log4j.setLevel(Level.INFO)
// Read in ini file
def iniConfig = new ConfigSlurper().parse(new File("PaymentProcessor.ini").toURL())
testMode = iniConfig.testMode
// listenerBitcoinAddress = iniConfig.listenerBitcoinAddress
walletPassphrase = iniConfig.bitcoin.walletPassphrase
sleepIntervalms = iniConfig.sleepIntervalms
databaseName = iniConfig.database.name
counterpartyTransactionEncoding = iniConfig.counterpartyTransactionEncoding
walletUnlockSeconds = iniConfig.walletUnlockSeconds
// Init database
def row
db = Sql.newInstance("jdbc:sqlite:${databaseName}", "org.sqlite.JDBC")
db.execute("PRAGMA busy_timeout = 2000")
// Check vital tables exist
row = db.firstRow("select name from sqlite_master where type='table' and name='blocks'")
assert row != null
row = db.firstRow("select name from sqlite_master where type='table' and name='transactions'")
assert row != null
row = db.firstRow("select name from sqlite_master where type='table' and name='inputAddresses'")
assert row != null
row = db.firstRow("select name from sqlite_master where type='table' and name='outputAddresses'")
assert row != null
row = db.firstRow("select name from sqlite_master where type='table' and name='fees'")
assert row != null
row = db.firstRow("select name from sqlite_master where type='table' and name='audit'")
assert row != null
row = db.firstRow("select name from sqlite_master where type='table' and name='credits'")
assert row != null
row = db.firstRow("select name from sqlite_master where type='table' and name='debits'")
assert row != null
row = db.firstRow("select name from sqlite_master where type='table' and name='payments'")
assert row != null
row = db.firstRow("select name from sqlite_master where type='table' and name='issuances'")
assert row != null
}
public audit() {
}
public getLastPaymentBlock() {
def Long result
def row
row = db.firstRow("select max(lastUpdatedBlockId) from payments where status in ('complete')")
if (row == null) {
result = 0
}
else {
if (row[0] == null) result = 0
else result = row[0]
}
return result
}
public getNextPayment() {
def Payment result
def row
row = db.firstRow("select * from payments where status='authorized' order by blockId")
if (row == null) result = null
else {
if (row[0] == null) result = null
else {
def blockIdSource = row.blockId
def txid = row.SourceTxid
def sourceAddress = row.sourceAddress
def destinationAddress = row.destinationAddress
def outAsset = row.outAsset
def outAmount = row.outAmount
def status = row.status
def lastUpdated = row.lastUpdatedBlockId
result = new Payment(blockIdSource, txid, sourceAddress, destinationAddress, outAsset, outAmount, status, lastUpdated)
}
}
return result
}
public pay(Long currentBlock, Payment payment) {
def sourceAddress = payment.sourceAddress
def blockIdSource = payment.blockIdSource
def destinationAddress = payment.destinationAddress
def asset = payment.outAsset
def amount = payment.outAmount
log4j.info("Processing payment ${payment.blockIdSource} ${payment.txid}. Sending ${payment.outAmount / 100000000} ${payment.outAsset} from ${payment.sourceAddress} to ${payment.destinationAddress}")
bitcoinAPI.lockBitcoinWallet() // Lock first to ensure the unlock doesn't fail
bitcoinAPI.unlockBitcoinWallet(walletPassphrase, 30)
// Create the (unsigned) counterparty send transaction
def unsignedTransaction = counterpartyAPI.createSend(sourceAddress, destinationAddress, asset, amount, testMode, log4j)
assert unsignedTransaction instanceof java.lang.String
assert unsignedTransaction != null
if (!(unsignedTransaction instanceof java.lang.String)) { // catch non technical error in RPC call
assert unsignedTransaction.code == null
}
// sign transaction
def signedTransaction = counterpartyAPI.signTransaction(unsignedTransaction, log4j)
assert signedTransaction instanceof java.lang.String
assert signedTransaction != null
// send transaction
try {
counterpartyAPI.broadcastSignedTransaction(signedTransaction, log4j)
log4j.info("update payments set status='complete', lastUpdatedBlockId = ${currentBlock} where blockId = ${blockIdSource} and sourceTxid = ${payment.txid}")
db.execute("update payments set status='complete', lastUpdatedBlockId = ${currentBlock} where blockId = ${blockIdSource} and sourceTxid = ${payment.txid}")
}
catch (Throwable e) {
log4j.info("update payments set status='error', lastUpdatedBlockId = ${currentBlock} where blockId = ${blockIdSource} and sourceTxid = ${payment.txid}")
db.execute("update payments set status='error', lastUpdatedBlockId = ${currentBlock} where blockId = ${blockIdSource} and sourceTxid = ${payment.txid}")
assert e == null
}
// Lock bitcoin wallet
bitcoinAPI.lockBitcoinWallet()
log4j.info("Payment ${sourceAddress} -> ${destinationAddress} ${amount/100000000} ${asset} complete")
if (testMode == true) log4j.info("Test mode: Payment 12nY87y6qf4Efw5WZaTwgGeceXApRYAwC7 -> 142UYTzD1PLBcSsww7JxKLck871zRYG5D3 " + 20000/100000000 + "${asset} complete")
// return unsignedTransaction
}
public static int main(String[] args) {
def paymentProcessor = new PaymentProcessor()
paymentProcessor.init()
paymentProcessor.audit()
log4j.info("Payment processor started")
log4j.info("Last processed payment: " + paymentProcessor.getLastPaymentBlock())
// Begin following blocks
while (true) {
def blockHeight = bitcoinAPI.getBlockHeight()
def lastPaymentBlock = paymentProcessor.getLastPaymentBlock()
def Payment payment = paymentProcessor.getNextPayment()
assert lastPaymentBlock <= blockHeight
log4j.info("Block ${blockHeight}")
// // If a payment wasn't performed this block and there is a payment to make
// if (lastPaymentBlock < blockHeight && payment != null) {
// paymentProcessor.pay(blockHeight, payment)
// }
// if (lastPaymentBlock >= blockHeight && payment != null) {
// log4j.info("Payment to make but already paid already this block. Sleeping...")
// }
if (payment != null) {
paymentProcessor.pay(blockHeight, payment)
log4j.info("Sleeping...")
}
else {
log4j.info("No payments to make. Sleeping...")
}
sleep(sleepIntervalms)
}
}
}