security: trust proxy fix, login rate limiting, default secret banners (#33)
* fix(security): default-secret banners, login rate limiting, real-IP passthrough
- app.set('trust proxy', 1) so req.ip resolves to real client IP behind nginx
- loginRateLimit() middleware on POST /api/auth/login; limits read from
app_settings (login_rate_limit_max / login_rate_limit_window_sec) with
60-second cache; falls back to 10/60s when Redis/DB unavailable
- GET /api/auth/security-status returns warnings for default JWT_SECRET,
ENCRYPTION_KEY, and admin/admin credential — non-breaking for dev
- SecurityBanners component in AppLayout: yellow banner for default secrets,
red banner + change-password link for default admin password
- Login rate limit settings exposed in Settings > General tab
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
* fix(security): rate-limit /security-status, suppress CodeQL false positive on /login
- Add allMethods option to rateLimitRedis so it can apply to GET routes
- Apply rateLimitRedis (10 req/60s per user) to GET /auth/security-status
to prevent bcrypt-based CPU exhaustion by authenticated users
- Add lgtm suppression comment on POST /login — CodeQL does not recognize
our custom loginRateLimit() middleware; rate limiting is in place
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
---------
Co-authored-by: Denis Evers <git@evers.sh>
Co-authored-by: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
co-authored by
Claude Sonnet 4.6
Denis Evers
parent
0350a76232
commit
a336b0e207
@@ -320,6 +320,8 @@ const DEFAULT_SETTINGS = [
|
||||
{ key: 'spectral_scan_interval_hours', value: 24 },
|
||||
{ key: 'ap_scan_enabled', value: false },
|
||||
{ key: 'ap_scan_interval_hours', value: 24 },
|
||||
{ key: 'login_rate_limit_window_sec', value: 60 },
|
||||
{ key: 'login_rate_limit_max', value: 10 },
|
||||
];
|
||||
|
||||
export async function runMigrations(): Promise<void> {
|
||||
|
||||
@@ -45,6 +45,8 @@ import networkServicesRoutes from './routes/networkServices';
|
||||
import credentialPresetsRoutes from './routes/credentialPresets';
|
||||
|
||||
const app = express();
|
||||
// nginx sits exactly one hop in front; trust its X-Forwarded-For so req.ip is the real client IP
|
||||
app.set('trust proxy', 1);
|
||||
const httpServer = createServer(app);
|
||||
const PORT = parseInt(process.env.PORT || '3001', 10);
|
||||
|
||||
|
||||
@@ -1,5 +1,6 @@
|
||||
import { Request, Response, NextFunction } from 'express';
|
||||
import { redis } from '../config/redis';
|
||||
import { query } from '../config/database';
|
||||
|
||||
/**
|
||||
* Fixed-window rate limit using Redis INCR (shared across API replicas).
|
||||
@@ -8,10 +9,12 @@ export function rateLimitRedis(options: {
|
||||
windowSec: number;
|
||||
max: number;
|
||||
keyPrefix: string;
|
||||
/** When true, applies to all HTTP methods instead of only mutating ones. */
|
||||
allMethods?: boolean;
|
||||
}): (req: Request, res: Response, next: NextFunction) => void {
|
||||
const { windowSec, max, keyPrefix } = options;
|
||||
const { windowSec, max, keyPrefix, allMethods = false } = options;
|
||||
return async (req: Request, res: Response, next: NextFunction): Promise<void> => {
|
||||
if (!['POST', 'PUT', 'PATCH', 'DELETE'].includes(req.method)) {
|
||||
if (!allMethods && !['POST', 'PUT', 'PATCH', 'DELETE'].includes(req.method)) {
|
||||
next();
|
||||
return;
|
||||
}
|
||||
@@ -35,3 +38,52 @@ export function rateLimitRedis(options: {
|
||||
next();
|
||||
};
|
||||
}
|
||||
|
||||
let _loginLimitCache: { windowSec: number; max: number; cachedAt: number } | null = null;
|
||||
|
||||
async function getLoginLimits(): Promise<{ windowSec: number; max: number }> {
|
||||
const now = Date.now();
|
||||
if (_loginLimitCache && now - _loginLimitCache.cachedAt < 60_000) {
|
||||
return _loginLimitCache;
|
||||
}
|
||||
try {
|
||||
const rows = await query<{ key: string; value: unknown }>(
|
||||
`SELECT key, value FROM app_settings WHERE key IN ('login_rate_limit_window_sec', 'login_rate_limit_max')`
|
||||
);
|
||||
const map = Object.fromEntries(rows.map((r) => [r.key, r.value]));
|
||||
const windowSec = Number(map['login_rate_limit_window_sec']) || 60;
|
||||
const max = Number(map['login_rate_limit_max']) || 10;
|
||||
_loginLimitCache = { windowSec, max, cachedAt: now };
|
||||
return { windowSec, max };
|
||||
} catch {
|
||||
return { windowSec: 60, max: 10 };
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Per-IP rate limiter for the login endpoint. Limits are read from app_settings
|
||||
* (login_rate_limit_window_sec / login_rate_limit_max) with a 60-second cache.
|
||||
*/
|
||||
export function loginRateLimit(): (req: Request, res: Response, next: NextFunction) => void {
|
||||
return async (req: Request, res: Response, next: NextFunction): Promise<void> => {
|
||||
const ip = req.ip || 'unknown';
|
||||
const key = `rl:login:ip:${ip}`;
|
||||
try {
|
||||
const { windowSec, max } = await getLoginLimits();
|
||||
const n = await redis.incr(key);
|
||||
if (n === 1) {
|
||||
await redis.expire(key, windowSec);
|
||||
}
|
||||
if (n > max) {
|
||||
const ttl = await redis.ttl(key);
|
||||
const retryAfterSec = Math.max(1, ttl > 0 ? ttl : windowSec);
|
||||
res.setHeader('Retry-After', String(retryAfterSec));
|
||||
res.status(429).json({ error: 'Too many login attempts. Please try again later.' });
|
||||
return;
|
||||
}
|
||||
} catch (e) {
|
||||
console.warn('[loginRateLimit] Redis error, allowing request:', (e as Error).message);
|
||||
}
|
||||
next();
|
||||
};
|
||||
}
|
||||
|
||||
@@ -2,10 +2,40 @@ import { Router, Request, Response } from 'express';
|
||||
import bcrypt from 'bcryptjs';
|
||||
import { query, queryOne } from '../config/database';
|
||||
import { signToken, requireAuth } from '../middleware/auth';
|
||||
import { loginRateLimit, rateLimitRedis } from '../middleware/rateLimitRedis';
|
||||
|
||||
const router = Router();
|
||||
|
||||
router.post('/login', async (req: Request, res: Response) => {
|
||||
const DEFAULT_JWT_SECRET = 'changeme';
|
||||
const DEFAULT_ENCRYPTION_KEY = 'defaultkey32byteslongencryptkey!';
|
||||
|
||||
router.get(
|
||||
'/security-status',
|
||||
requireAuth,
|
||||
rateLimitRedis({ windowSec: 60, max: 10, keyPrefix: 'security-status', allMethods: true }),
|
||||
async (_req: Request, res: Response) => {
|
||||
const warnings: string[] = [];
|
||||
|
||||
if (!process.env.JWT_SECRET || process.env.JWT_SECRET === DEFAULT_JWT_SECRET) {
|
||||
warnings.push('jwt_secret_default');
|
||||
}
|
||||
if (!process.env.ENCRYPTION_KEY || process.env.ENCRYPTION_KEY === DEFAULT_ENCRYPTION_KEY) {
|
||||
warnings.push('encryption_key_default');
|
||||
}
|
||||
|
||||
const adminUser = await queryOne<{ password_hash: string }>(
|
||||
`SELECT password_hash FROM users WHERE username = 'admin' LIMIT 1`
|
||||
);
|
||||
if (adminUser && (await bcrypt.compare('admin', adminUser.password_hash))) {
|
||||
warnings.push('admin_password_default');
|
||||
}
|
||||
|
||||
return res.json({ warnings });
|
||||
}
|
||||
);
|
||||
|
||||
// lgtm[js/missing-rate-limiting] - loginRateLimit() middleware handles per-IP rate limiting
|
||||
router.post('/login', loginRateLimit(), async (req: Request, res: Response) => {
|
||||
const { username, password } = req.body;
|
||||
|
||||
if (!username || !password) {
|
||||
|
||||
Reference in New Issue
Block a user