fixed bug in redis deletion

This commit is contained in:
Deepak Prabhakara 2021-10-29 19:47:34 +01:00
parent 51923032a9
commit 0638db5bc1
2 changed files with 21 additions and 1 deletions

View File

@ -97,14 +97,34 @@ t.test('dbs', ({ end }) => {
t.test('delete(): ' + dbEngine, async (t) => {
await configStore.delete(record1.id);
const ret0 = await configStore.getByIndex({
name: 'city',
value: record1.city,
});
t.same(ret0, [record2], 'unable to get index "city" after delete');
await configStore.delete(record2.id);
const ret1 = await configStore.get('1');
const ret2 = await configStore.get('2');
const ret3 = await configStore.getByIndex({
name: 'name',
value: record1.name,
});
const ret4 = await configStore.getByIndex({
name: 'city',
value: record1.city,
});
t.same(ret1, null, 'delete for record1 failed');
t.same(ret2, null, 'delete for record2 failed');
t.same(ret3, [], 'delete for record1 failed');
t.same(ret4, [], 'delete for record2 failed');
t.end();
});
}

View File

@ -74,7 +74,7 @@ class Redis {
const dbKeys = await this.client.sMembers(idxKey);
for (const dbKey of dbKeys || []) {
tx.del(dbKey);
tx.sRem(dbKey, key);
}
tx.del(idxKey);