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.series

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2023-10-13 12:11:41 -04:00
parent f96b0b7a4a
commit c7c6e8ffb4
1 changed files with 9 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/database/postgres.js
View File

@@ -1,7 +1,6 @@
'use strict';
const winston = require('winston');
const async = require('async');
const nconf = require('nconf');
const session = require('express-session');
const semver = require('semver');
@@ -344,26 +343,20 @@ ALTER TABLE "session"
return done(db);
};
postgresModule.createIndices = function (callback) {
postgresModule.createIndices = async function () {
if (!postgresModule.pool) {
winston.warn('[database/createIndices] database not initialized');
return callback();
return;
}
const query = postgresModule.pool.query.bind(postgresModule.pool);
winston.info('[database] Checking database indices.');
async.series([
async.apply(query, `CREATE INDEX IF NOT EXISTS "idx__legacy_zset__key__score" ON "legacy_zset"("_key" ASC, "score" DESC)`),
async.apply(query, `CREATE INDEX IF NOT EXISTS "idx__legacy_object__expireAt" ON "legacy_object"("expireAt" ASC)`),
], (err) => {
if (err) {
winston.error(`Error creating index ${err.message}`);
return callback(err);
}
try {
await postgresModule.pool.query(`CREATE INDEX IF NOT EXISTS "idx__legacy_zset__key__score" ON "legacy_zset"("_key" ASC, "score" DESC)`);
await postgresModule.pool.query(`CREATE INDEX IF NOT EXISTS "idx__legacy_object__expireAt" ON "legacy_object"("expireAt" ASC)`);
winston.info('[database] Checking database indices done!');
callback();
});
} catch (err) {
winston.error(`Error creating index ${err.message}`);
throw err;
}
};
postgresModule.checkCompatibility = function (callback) {