70 lines
2.2 KiB
JavaScript
70 lines
2.2 KiB
JavaScript
var chai = require('chai');
|
|
var assert = chai.assert;
|
|
var web3 = require('../index');
|
|
var FakeHttpProvider = require('./helpers/FakeHttpProvider');
|
|
var utils = require('../lib/utils/utils');
|
|
|
|
var tests = [{
|
|
protocol: 'eth',
|
|
args: ['pending'],
|
|
firstResult: 1,
|
|
firstPayload: {
|
|
method: "eth_newBlockFilter",
|
|
params: [
|
|
"pending"
|
|
]
|
|
},
|
|
secondResult: [null],
|
|
secondPayload: {
|
|
method: "eth_getFilterChanges"
|
|
}
|
|
}];
|
|
|
|
|
|
var testPolling = function (tests) {
|
|
|
|
describe('web3.eth.filter.polling', function () {
|
|
tests.forEach(function (test, index) {
|
|
it('should create && successfully poll filter', function (done) {
|
|
|
|
// given
|
|
var provider = new FakeHttpProvider();
|
|
web3.setProvider(provider);
|
|
web3.reset();
|
|
provider.injectResult(test.firstResult);
|
|
var step = 0;
|
|
provider.injectValidation(function (payload) {
|
|
if (step === 0) {
|
|
step = 1;
|
|
assert.equal(payload.jsonrpc, '2.0');
|
|
assert.equal(payload.method, test.firstPayload.method);
|
|
assert.deepEqual(payload.params, test.firstPayload.params);
|
|
} else if (step === 1 && utils.isArray(payload)) {
|
|
var r = payload.filter(function (p) {
|
|
return p.jsonrpc === '2.0' && p.method === test.secondPayload.method && p.params[0] === test.firstResult;
|
|
});
|
|
assert.equal(r.length > 0, true);
|
|
}
|
|
|
|
});
|
|
|
|
// when
|
|
var filter = web3[test.protocol].filter.apply(null, test.args);
|
|
provider.injectBatchResults([test.secondResult]);
|
|
filter.watch(function (err, result) {
|
|
if (test.err) {
|
|
// todo
|
|
} else {
|
|
assert.equal(result, test.secondResult[0]);
|
|
}
|
|
done();
|
|
|
|
});
|
|
});
|
|
});
|
|
});
|
|
};
|
|
|
|
testPolling(tests);
|
|
|