ioredis-mock
ioredis-mock copied to clipboard
Published
20 hours ago •
stipsan
stipsan
redis.scanStream not working correctly
created a repo duplicating the problem: https://github.com/khawkinson/ioredis-mock-test
Basically this fails:
import RedisMock from 'ioredis-mock';
import { describe, it } from 'mocha';
import { expect } from 'chai';
describe('ioredis-mock test', () => {
let redis;
beforeEach(() => {
redis = new RedisMock({
data: {
'user:1': 'bill',
'user:2': 'steve',
'user:3': 'john',
'user:4': 'billy',
'user:5': 'erin',
'user:6': 'paul',
'user:7': 'jim',
'user:8': 'dave',
'user:9': 'peter',
'user:10': 'james',
'user:11': 'don',
'user:13': 'aaron',
'user:14': 'bill',
'user:15': 'steve',
'user:16': 'john',
'user:17': 'billy',
'user:18': 'erin',
'user:19': 'paul',
'user:20': 'jim',
'user:21': 'dave',
'user:22': 'peter',
'user:23': 'james',
'user:24': 'don',
'user:25': 'aaron',
'user:25:balls': new Set(['balls'])
}
});
});
describe('', () => {
it('should properly do a scan', () => {
const finalTally = [];
// ADD count to options object, { match: 'user:*', count: 100 }
// Test will pass.
// if you use a count value less than what should be returned, it also fails.
// like count: 10
const stream = redis.scanStream({ match: 'user:*' });
stream.on('data', keys => {
if (keys.length) {
console.log(keys);
const pipeline = redis.pipeline();
keys.forEach((key) => {
finalTally.push(key);
pipeline.del(key);
});
pipeline.exec();
}
});
stream.on('end', () => {
expect(finalTally.length).to.equal(25);
})
});
});
});
