LibreChat/config/ban-user.js
Theo N. Truong 01b012a8fa
🏦 refactor: Centralize Caching & Redis Key Prefixing (#8457)
* 🔧 Overhauled caching feature:
- Refactored caching logic.
- Fixed redis prefix, namespace, tls, ttl, and cluster.
- Added REDIS_KEY_PREFIX_VAR

* # refactor: Rename redisCache to standardCache

* # Add Redis pinging mechanism to maintain connection.

* # docs: Add warning about Keyv Redis client prefix support
2025-07-15 18:24:31 -04:00

92 lines
2.4 KiB
JavaScript

const path = require('path');
const mongoose = require(path.resolve(__dirname, '..', 'api', 'node_modules', 'mongoose'));
const { User } = require('@librechat/data-schemas').createModels(mongoose);
const { ViolationTypes } = require('librechat-data-provider');
require('module-alias')({ base: path.resolve(__dirname, '..', 'api') });
const { askQuestion, silentExit } = require('./helpers');
const banViolation = require('~/cache/banViolation');
const connect = require('./connect');
(async () => {
await connect();
console.purple('---------------------');
console.purple('Ban a user account!');
console.purple('---------------------');
let email = '';
let duration = '';
if (process.argv.length >= 4) {
// Check if there are enough command-line arguments.
email = process.argv[2];
duration = parseInt(process.argv[3]); // Parse the duration as an integer.
} else {
console.orange('Usage: npm run ban-user <email> <duration>');
console.orange('Note: if you do not pass in the arguments, you will be prompted for them.');
console.purple('--------------------------');
}
if (!email) {
email = await askQuestion('Email:');
}
if (!duration) {
const durationInMinutes = await askQuestion('Duration (in minutes):');
duration = parseInt(durationInMinutes) * 60000;
}
if (isNaN(duration) || duration <= 0) {
console.red('Error: Invalid duration!');
silentExit(1);
}
if (!email.includes('@')) {
console.red('Error: Invalid email address!');
silentExit(1);
}
const user = await User.findOne({ email }).lean();
if (!user) {
console.red('Error: No user with that email was found!');
silentExit(1);
} else {
console.purple(`Found user: ${user.email}`);
}
const req = {};
const res = {
clearCookie: () => {},
status: function () {
return this;
},
json: function () {
return this;
},
};
const errorMessage = {
type: ViolationTypes.CONCURRENT,
violation_count: 20,
user_id: user._id,
prev_count: 0,
duration: duration,
};
await banViolation(req, res, errorMessage);
silentExit(0);
})();
process.on('uncaughtException', (err) => {
if (!err.message.includes('fetch failed')) {
console.error('There was an uncaught error:');
console.error(err);
}
if (err.message.includes('fetch failed')) {
return;
} else {
process.exit(1);
}
});