Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-26 16:46:12 +01:00
Code Issues Packages Projects Releases Wiki Activity

refactor: get rid of async.parallel

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2025-03-24 10:22:27 -04:00
parent 75f1f6fbfe
commit e722e86956
1 changed files with 21 additions and 61 deletions
Download Patch File Download Diff File Expand all files Collapse all files

82
test/database/keys.js
View File

@@ -1,7 +1,5 @@
'use strict'; 'use strict';
const async = require('async');
const assert = require('assert'); const assert = require('assert');
const db = require('../mocks/databasemock'); const db = require('../mocks/databasemock');
@@ -115,67 +113,29 @@ describe('Key methods', () => {
}); });
}); });
it('should delete all keys passed in', (done) => { it('should delete all keys passed in', async () => {
async.parallel([ await Promise.all([
function (next) { db.set('key1', 'value1'),
db.set('key1', 'value1', next); db.set('key2', 'value2'),
}, ]);
function (next) {
db.set('key2', 'value2', next); await db.deleteAll(['key1', 'key2']);
}, const [key1Exists, key2Exists] = await db.exists(['key1', 'key2']);
], (err) => { assert.strictEqual(key1Exists, false);
if (err) { assert.strictEqual(key2Exists, false);
return done(err);
}
db.deleteAll(['key1', 'key2'], function (err) {
assert.ifError(err);
assert.equal(arguments.length, 1);
async.parallel({
key1exists: function (next) {
db.exists('key1', next);
},
key2exists: function (next) {
db.exists('key2', next);
},
}, (err, results) => {
assert.ifError(err);
assert.equal(results.key1exists, false);
assert.equal(results.key2exists, false);
done();
});
});
});
}); });
it('should delete all sorted set elements', (done) => { it('should delete all sorted set elements', async () => {
async.parallel([ await db.sortedSetAddBulk([
function (next) { ['deletezset', 1, 'value1'],
db.sortedSetAdd('deletezset', 1, 'value1', next); ['deletezset', 2, 'value2'],
}, ]);
function (next) {
db.sortedSetAdd('deletezset', 2, 'value2', next); await db.delete('deletezset');
}, const [key1Exists, key2Exists] = await db.isSortedSetMembers('deletezset', ['value1', 'value2']);
], (err) => {
if (err) { assert.strictEqual(key1Exists, false);
return done(err); assert.strictEqual(key2Exists, false);
}
db.delete('deletezset', (err) => {
assert.ifError(err);
async.parallel({
key1exists: function (next) {
db.isSortedSetMember('deletezset', 'value1', next);
},
key2exists: function (next) {
db.isSortedSetMember('deletezset', 'value2', next);
},
}, (err, results) => {
assert.ifError(err);
assert.equal(results.key1exists, false);
assert.equal(results.key2exists, false);
done();
});
});
});
}); });
describe('increment', () => { describe('increment', () => {