import { NextResponse } from 'next/server';
import type { NextRequest } from 'next/server';

const RATE_LIMIT_WINDOW = 60 * 1000; // 1 minute
const MAX_REQUESTS = 100; // 100 requests per window

const ipMap = new Map<string, { count: number; expires: number }>();

export function middleware(request: NextRequest) {
    // Simple in-memory rate limiting implementation
    // Note: specific to a single instance container. For distributed, use Redis.
    const ip = request.headers.get('x-forwarded-for') || 'unknown';
    const now = Date.now();

    // Logging Stub: In future, this will push to a DB service
    console.log(`[${new Date().toISOString()}] Request to ${request.nextUrl.pathname} from ${ip}`);

    const record = ipMap.get(ip);

    if (!record || now > record.expires) {
        ipMap.set(ip, { count: 1, expires: now + RATE_LIMIT_WINDOW });
    } else {
        record.count++;
        if (record.count > MAX_REQUESTS) {
            return new NextResponse('Too Many Requests', { status: 429 });
        }
    }

    // Cleanup old entries occasionally (naive approach for this scale)
    if (ipMap.size > 1000) {
        for (const [key, val] of ipMap.entries()) {
            if (now > val.expires) {
                ipMap.delete(key);
            }
        }
    }

    return NextResponse.next();
}

export const config = {
    matcher: '/:path*',
};