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'; 'use strict';
const winston = require('winston'); const winston = require('winston');
const async = require('async');
const nconf = require('nconf'); const nconf = require('nconf');
const session = require('express-session'); const session = require('express-session');
const semver = require('semver'); const semver = require('semver');
@@ -344,26 +343,20 @@ ALTER TABLE "session"
return done(db); return done(db);
}; };
postgresModule.createIndices = function (callback) { postgresModule.createIndices = async function () {
if (!postgresModule.pool) { if (!postgresModule.pool) {
winston.warn('[database/createIndices] database not initialized'); winston.warn('[database/createIndices] database not initialized');
return callback(); return;
} }
const query = postgresModule.pool.query.bind(postgresModule.pool);
winston.info('[database] Checking database indices.'); winston.info('[database] Checking database indices.');
async.series([ try {
async.apply(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_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)`), await postgresModule.pool.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);
}
winston.info('[database] Checking database indices done!'); winston.info('[database] Checking database indices done!');
callback(); } catch (err) {
}); winston.error(`Error creating index ${err.message}`);
throw err;
}
}; };
postgresModule.checkCompatibility = function (callback) { postgresModule.checkCompatibility = function (callback) {