Hire Expert
Redis Developers

import { createClient } from 'redis';

const client = createClient({ url: process.env.REDIS_URL });
await client.connect();

// Sliding window rate limiter
async function rateLimit(userId: string, limit = 100, windowSec = 60) {
  const key = `rate:${userId}:${Math.floor(Date.now() / 1000 / windowSec)}`;
  const count = await client.incr(key);
  if (count === 1) await client.expire(key, windowSec);
  return count <= limit;
}

// Cache-aside pattern
async function getUser(id: string) {
  const cached = await client.get(`user:${id}`);
  if (cached) return JSON.parse(cached);
  const user = await db.users.findById(id);
  await client.setEx(`user:${id}`, 300, JSON.stringify(user));
  return user;
}