refactor: move als requires, move autoLocale to api/page routes

This commit is contained in:
Barış Soner Uşaklı
2024-06-10 20:43:22 -04:00
parent 8eccdb481f
commit 3356022a85
4 changed files with 7 additions and 5 deletions

View File

@@ -3,6 +3,7 @@
const winston = require('winston'); const winston = require('winston');
const plugins = require('.'); const plugins = require('.');
const utils = require('../utils'); const utils = require('../utils');
const als = require('../als');
const Hooks = module.exports; const Hooks = module.exports;
@@ -185,7 +186,6 @@ Hooks.fire = async function (hook, params) {
} }
let deleteCaller = false; let deleteCaller = false;
if (params && typeof params === 'object' && !Array.isArray(params) && !params.hasOwnProperty('caller')) { if (params && typeof params === 'object' && !Array.isArray(params) && !params.hasOwnProperty('caller')) {
const als = require('../als');
params.caller = als.getStore(); params.caller = als.getStore();
deleteCaller = true; deleteCaller = true;
} }

View File

@@ -16,6 +16,7 @@ helpers.setupPageRoute = function (...args) {
} }
middlewares = [ middlewares = [
middleware.autoLocale,
middleware.applyBlacklist, middleware.applyBlacklist,
middleware.authenticateRequest, middleware.authenticateRequest,
middleware.redirectToHomeIfBanned, middleware.redirectToHomeIfBanned,
@@ -44,7 +45,7 @@ helpers.setupAdminPageRoute = function (...args) {
if (args.length === 5) { if (args.length === 5) {
winston.warn(`[helpers.setupAdminPageRoute(${name})] passing \`middleware\` as the third param is deprecated, it can now be safely removed`); winston.warn(`[helpers.setupAdminPageRoute(${name})] passing \`middleware\` as the third param is deprecated, it can now be safely removed`);
} }
router.get(name, middleware.admin.buildHeader, middlewares, helpers.tryRoute(controller)); router.get(name, middleware.autoLocale, middleware.admin.buildHeader, middlewares, helpers.tryRoute(controller));
router.get(`/api${name}`, middlewares, helpers.tryRoute(controller)); router.get(`/api${name}`, middlewares, helpers.tryRoute(controller));
}; };
@@ -55,6 +56,7 @@ helpers.setupApiRoute = function (...args) {
const controller = args[args.length - 1]; const controller = args[args.length - 1];
middlewares = [ middlewares = [
middleware.autoLocale,
middleware.applyBlacklist, middleware.applyBlacklist,
middleware.authenticateRequest, middleware.authenticateRequest,
middleware.maintenanceMode, middleware.maintenanceMode,

View File

@@ -14,6 +14,8 @@ const logger = require('../logger');
const plugins = require('../plugins'); const plugins = require('../plugins');
const ratelimit = require('../middleware/ratelimit'); const ratelimit = require('../middleware/ratelimit');
const blacklist = require('../meta/blacklist'); const blacklist = require('../meta/blacklist');
const als = require('../als');
const apiHelpers = require('../api/helpers');
const Namespaces = Object.create(null); const Namespaces = Object.create(null);
@@ -88,8 +90,7 @@ function onConnection(socket) {
onConnect(socket); onConnect(socket);
socket.onAny((event, ...args) => { socket.onAny((event, ...args) => {
const payload = { event: event, ...deserializePayload(args) }; const payload = { event: event, ...deserializePayload(args) };
const als = require('../als');
const apiHelpers = require('../api/helpers');
als.run({ als.run({
uid: socket.uid, uid: socket.uid,
req: apiHelpers.buildReqObject(socket, payload), req: apiHelpers.buildReqObject(socket, payload),

View File

@@ -182,7 +182,6 @@ function setupExpressApp(app) {
req: apiHelpers.buildReqObject(req), req: apiHelpers.buildReqObject(req),
}, next); }, next);
}); });
app.use(middleware.autoLocale); // must be added after auth middlewares are added
const toobusy = require('toobusy-js'); const toobusy = require('toobusy-js');
toobusy.maxLag(meta.config.eventLoopLagThreshold); toobusy.maxLag(meta.config.eventLoopLagThreshold);