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
|
import * as chai from 'chai';
import * as _ from 'lodash';
import Web3 = require('web3');
import Web3ProviderEngine = require('web3-provider-engine');
import FixtureSubprovider = require('web3-provider-engine/subproviders/fixture');
import promisify = require('es6-promisify');
import EthereumTx = require('ethereumjs-tx');
import { NonceTrackerSubprovider } from '../../src';
import { DoneCallback } from '../../src/types';
import { chaiSetup } from '../chai_setup';
import { reportCallbackErrors } from '../utils/report_callback_errors';
import { Subprovider } from '../../src/subproviders/subprovider';
const expect = chai.expect;
chaiSetup.configure();
describe('NonceTrackerSubprovider', () => {
let provider: Web3ProviderEngine;
it('successfully caches the transaction count', async () => {
provider = new Web3ProviderEngine();
let called = false;
const nonceTrackerSubprovider = new NonceTrackerSubprovider();
provider.addProvider(nonceTrackerSubprovider);
provider.addProvider(new FixtureSubprovider({
'eth_getBlockByNumber': '0x01',
'eth_getTransactionCount': (data: any, next: any, end: any) => {
if (called) {
return end(null, '0x99');
} else {
called = true;
end(null, '0x01');
}
},
}));
provider.start();
const payload = {
jsonrpc: '2.0',
method: 'eth_getTransactionCount',
params: ['0x0', 'pending'],
id: 1,
};
const response = await promisify(provider.sendAsync, provider)(payload);
expect(response.result).to.be.eq('0x01');
const secondResponse = await promisify(provider.sendAsync, provider)(payload);
expect(secondResponse.result).to.be.eq('0x01');
});
it('does not cache the result for latest transaction count', async () => {
provider = new Web3ProviderEngine();
let called = false;
const nonceTrackerSubprovider = new NonceTrackerSubprovider();
provider.addProvider(nonceTrackerSubprovider);
provider.addProvider(new FixtureSubprovider({
'eth_getBlockByNumber': '0x01',
'eth_getTransactionCount': (data: any, next: any, end: any) => {
if (called) {
return end(null, '0x99');
} else {
called = true;
end(null, '0x01');
}
},
}));
provider.start();
const payload = {
jsonrpc: '2.0',
method: 'eth_getTransactionCount',
params: ['0x0', 'latest'],
id: 1,
};
const response = await promisify(provider.sendAsync, provider)(payload);
expect(response.result).to.be.eq('0x01');
const secondResponse = await promisify(provider.sendAsync, provider)(payload);
expect(secondResponse.result).to.be.eq('0x99');
});
it('clears the cache on a Nonce Too Low Error', async () => {
provider = new Web3ProviderEngine();
let called = false;
const nonceTrackerSubprovider = new NonceTrackerSubprovider();
provider.addProvider(nonceTrackerSubprovider);
provider.addProvider(new FixtureSubprovider({
'eth_getBlockByNumber': '0x01',
'eth_getTransactionCount': (data: any, next: any, end: any) => {
if (called) {
return end(null, '0x99');
} else {
called = true;
end(null, '0x01');
}
},
'eth_sendRawTransaction': (data: any, next: any, end: any) => {
end(new Error('Transaction nonce is too low'));
},
}));
provider.start();
const noncePayload = {
jsonrpc: '2.0',
method: 'eth_getTransactionCount',
params: ['0x1f36f546477cda21bf2296c50976f2740247906f', 'pending'],
id: 1,
};
const txParams = [
'0x',
'0x09184e72a000',
'0x2710',
'0x0000000000000000000000000000000000000000',
'0x',
'0x7f7465737432000000000000000000000000000000000000000000000000000000600057',
'0x1c',
'0x5e1d3a76fbf824220eafc8c79ad578ad2b67d01b0c2425eb1f1347e8f50882ab',
'0x5bd428537f05f9830e93792f90ea6a3e2d1ee84952dd96edbae9f658f831ab13'
];
const transaction = new EthereumTx(txParams);
const txPayload = {
jsonrpc: '2.0',
method: 'eth_sendRawTransaction',
params: [transaction.serialize()],
id: 1,
};
const response = await promisify(provider.sendAsync, provider)(noncePayload);
expect(response.result).to.be.eq('0x01');
const secondResponse = await promisify(provider.sendAsync, provider)(noncePayload);
expect(secondResponse.result).to.be.eq('0x01');
try {
const txResponse = await promisify(provider.sendAsync, provider)(txPayload);
} catch (err) {
const thirdResponse = await promisify(provider.sendAsync, provider)(noncePayload);
expect(thirdResponse.result).to.be.eq('0x99');
}
});
it('increments the used nonce', async () => {
provider = new Web3ProviderEngine();
let called = false;
const nonceTrackerSubprovider = new NonceTrackerSubprovider();
provider.addProvider(nonceTrackerSubprovider);
provider.addProvider(new FixtureSubprovider({
'eth_getBlockByNumber': '0x01',
'eth_getTransactionCount': (data: any, next: any, end: any) => {
if (called) {
return end(null, '0x99');
} else {
called = true;
end(null, '0x00');
}
},
'eth_sendRawTransaction': (data: any, next: any, end: any) => {
end(null);
},
}));
provider.start();
const noncePayload = {
jsonrpc: '2.0',
method: 'eth_getTransactionCount',
params: ['0x1f36f546477cda21bf2296c50976f2740247906f', 'pending'],
id: 1,
};
const txParams = [
'0x',
'0x09184e72a000',
'0x2710',
'0x0000000000000000000000000000000000000000',
'0x',
'0x7f7465737432000000000000000000000000000000000000000000000000000000600057',
'0x1c',
'0x5e1d3a76fbf824220eafc8c79ad578ad2b67d01b0c2425eb1f1347e8f50882ab',
'0x5bd428537f05f9830e93792f90ea6a3e2d1ee84952dd96edbae9f658f831ab13'
];
const transaction = new EthereumTx(txParams);
const txPayload = {
jsonrpc: '2.0',
method: 'eth_sendRawTransaction',
params: [transaction.serialize()],
id: 1,
};
const response = await promisify(provider.sendAsync, provider)(noncePayload);
expect(response.result).to.be.eq('0x00');
const secondResponse = await promisify(provider.sendAsync, provider)(noncePayload);
expect(secondResponse.result).to.be.eq('0x00');
const txResponse = await promisify(provider.sendAsync, provider)(txPayload);
const thirdResponse = await promisify(provider.sendAsync, provider)(noncePayload);
expect(thirdResponse.result).to.be.eq('0x01');
});
});
|
