Redis-cachningstrategier som faktiskt fungerar i produktion

import Redis from "ioredis";
 
const redis = new Redis({
  host: process.env.REDIS_HOST || "127.0.0.1",
  port: Number(process.env.REDIS_PORT) || 6379,
  password: process.env.REDIS_PASSWORD || undefined,
  db: Number(process.env.REDIS_DB) || 0,
  maxRetriesPerRequest: 3,
  retryStrategy(times) {
    const delay = Math.min(times * 200, 5000);
    return delay;
  },
  lazyConnect: true,
  enableReadyCheck: true,
  connectTimeout: 10000,
});
 
redis.on("error", (err) => {
  console.error("[Redis] Connection error:", err.message);
});
 
redis.on("connect", () => {
  console.log("[Redis] Connected");
});
 
export default redis;

import redis from "./redis";
 
interface CacheOptions {
  ttl?: number; // sekunder
  prefix?: string;
}
 
async function cacheAside<T>(key: string, fetcher: () => Promise<T>, options: CacheOptions = {}): Promise<T> {
  const { ttl = 3600, prefix = "cache" } = options;
  const cacheKey = `${prefix}:${key}`;
 
  // Steg 1: Försök läsa från cache
  const cached = await redis.get(cacheKey);
 
  if (cached !== null) {
    try {
      return JSON.parse(cached) as T;
    } catch {
      // Korrupt cache-post, radera den och fortsätt
      await redis.del(cacheKey);
    }
  }
 
  // Steg 2: Cache miss — hämta från källa
  const result = await fetcher();
 
  // Steg 3: Lagra i cache (vänta inte — fire and forget)
  redis.set(cacheKey, JSON.stringify(result), "EX", ttl).catch((err) => {
    console.error(`[Cache] Failed to set ${cacheKey}:`, err.message);
  });
 
  return result;
}

interface User {
  id: string;
  name: string;
  email: string;
  plan: "free" | "pro" | "enterprise";
}
 
async function getUser(userId: string): Promise<User | null> {
  return cacheAside<User | null>(
    `user:${userId}`,
    async () => {
      const row = await db.query("SELECT * FROM users WHERE id = $1", [userId]);
      return row[0] ?? null;
    },
    { ttl: 1800 }, // 30 minuter
  );
}

async function getUserSafe(userId: string): Promise<User | null> {
  return cacheAside<User | null>(
    `user:${userId}`,
    async () => {
      const row = await db.query("SELECT * FROM users WHERE id = $1", [userId]);
      return row[0] ?? null;
    },
    {
      // Kortare TTL för null-resultat för att begränsa minnesanvändning
      // men tillräckligt lång för att absorbera upprepade missar
      ttl: row ? 1800 : 300,
    },
  );
}

async function getUserWithDynamicTTL(userId: string): Promise<User | null> {
  const cacheKey = `cache:user:${userId}`;
 
  const cached = await redis.get(cacheKey);
  if (cached !== null) {
    return JSON.parse(cached) as User | null;
  }
 
  const row = await db.query("SELECT * FROM users WHERE id = $1", [userId]);
  const user: User | null = row[0] ?? null;
 
  // Cacha existerande resultat i 30 min, null-resultat i 5 min
  const ttl = user ? 1800 : 300;
  await redis.set(cacheKey, JSON.stringify(user), "EX", ttl);
 
  return user;
}

async function updateUser(userId: string, updates: Partial<User>): Promise<User> {
  // Steg 1: Uppdatera databasen
  const updated = await db.query(
    "UPDATE users SET name = COALESCE($2, name), email = COALESCE($3, email) WHERE id = $1 RETURNING *",
    [userId, updates.name, updates.email],
  );
  const user: User = updated[0];
 
  // Steg 2: Uppdatera cachen omedelbart
  const cacheKey = `cache:user:${userId}`;
  await redis.set(cacheKey, JSON.stringify(user), "EX", 1800);
 
  return user;
}

async function updateUserWriteBehind(userId: string, updates: Partial<User>): Promise<User> {
  const cacheKey = `cache:user:${userId}`;
 
  // Läs aktuellt tillstånd
  const current = await redis.get(cacheKey);
  const user = current ? (JSON.parse(current) as User) : null;
  if (!user) throw new Error("User not in cache");
 
  // Uppdatera cache omedelbart
  const updated = { ...user, ...updates };
  await redis.set(cacheKey, JSON.stringify(updated), "EX", 1800);
 
  // Köa databasskrivning för asynkron bearbetning
  await redis.rpush("write_behind:users", JSON.stringify({ userId, updates, timestamp: Date.now() }));
 
  return updated;
}

async function processWriteBehindQueue(): Promise<void> {
  while (true) {
    const item = await redis.blpop("write_behind:users", 5);
 
    if (item) {
      const { userId, updates } = JSON.parse(item[1]);
      try {
        await db.query("UPDATE users SET name = COALESCE($2, name), email = COALESCE($3, email) WHERE id = $1", [
          userId,
          updates.name,
          updates.email,
        ]);
      } catch (err) {
        // Lägg tillbaka i kön vid misslyckande med antal omförsök
        console.error("[WriteBehind] Failed:", err);
        await redis.rpush("write_behind:users:dlq", item[1]);
      }
    }
  }
}

const TTL = {
  // Nivå 1: Ändras sällan, dyrt att beräkna
  // Exempel: produktkatalog, webbplatskonfiguration, feature flags
  STATIC: 86400, // 24 timmar
 
  // Nivå 2: Ändras ibland, måttlig kostnad
  // Exempel: användarprofiler, teaminställningar, behörigheter
  MODERATE: 1800, // 30 minuter
 
  // Nivå 3: Ändras ofta, billigt att beräkna men anropas ofta
  // Exempel: flödesdata, notifieringsräknare, sessionsinformation
  VOLATILE: 300, // 5 minuter
 
  // Nivå 4: Efemärt, används för hastighetsbegränsning och lås
  EPHEMERAL: 60, // 1 minut
 
  // Null-resultat: alltid kortlivade
  NOT_FOUND: 120, // 2 minuter
} as const;

function ttlWithJitter(baseTtl: number, jitterPercent = 0.1): number {
  const jitter = baseTtl * jitterPercent;
  const offset = Math.random() * jitter * 2 - jitter;
  return Math.max(1, Math.round(baseTtl + offset));
}
 
// Istället för: redis.set(key, value, "EX", 3600)
// Använd:      redis.set(key, value, "EX", ttlWithJitter(3600))
 
// 3600 ± 10% = slumpmässigt värde mellan 3240 och 3960

const ttl = ttlWithJitter(3600, 0.2); // 2880–4320 sekunder

async function getWithSlidingExpiry<T>(key: string, ttl: number): Promise<T | null> {
  // GETEX hämtar atomärt värdet OCH återställer TTL:en
  const value = await redis.getex(key, "EX", ttl);
  if (value === null) return null;
  return JSON.parse(value) as T;
}

async function getWithSlidingExpiryCompat<T>(key: string, ttl: number): Promise<T | null> {
  const pipeline = redis.pipeline();
  pipeline.get(key);
  pipeline.expire(key, ttl);
  const results = await pipeline.exec();
 
  if (!results || !results[0] || results[0][1] === null) return null;
  return JSON.parse(results[0][1] as string) as T;
}

async function cacheAsideWithMutex<T>(key: string, fetcher: () => Promise<T>, ttl: number = 3600): Promise<T | null> {
  const cacheKey = `cache:${key}`;
  const lockKey = `lock:${key}`;
 
  // Försök cache först
  const cached = await redis.get(cacheKey);
  if (cached !== null) {
    return JSON.parse(cached) as T;
  }
 
  // Försök skaffa lås (NX = bara om det inte finns, EX = auto-utgång)
  const acquired = await redis.set(lockKey, "1", "EX", 10, "NX");
 
  if (acquired) {
    try {
      // Vi fick låset — hämta och cacha
      const result = await fetcher();
      await redis.set(cacheKey, JSON.stringify(result), "EX", ttlWithJitter(ttl));
      return result;
    } finally {
      // Släpp lås
      await redis.del(lockKey);
    }
  }
 
  // En annan förfrågan håller låset — vänta och försök igen
  await sleep(100);
 
  const retried = await redis.get(cacheKey);
  if (retried !== null) {
    return JSON.parse(retried) as T;
  }
 
  // Fortfarande ingen cache — faller igenom till databasen
  // (detta hanterar fallet där låshållaren misslyckades)
  return fetcher();
}
 
function sleep(ms: number): Promise<void> {
  return new Promise((resolve) => setTimeout(resolve, ms));
}

import { randomUUID } from "crypto";
 
async function acquireLock(lockKey: string, ttl: number): Promise<string | null> {
  const token = randomUUID();
  const acquired = await redis.set(lockKey, token, "EX", ttl, "NX");
  return acquired ? token : null;
}
 
async function releaseLock(lockKey: string, token: string): Promise<boolean> {
  // Lua-skript säkerställer atomär kontrollera-och-radera
  const script = `
    if redis.call("get", KEYS[1]) == ARGV[1] then
      return redis.call("del", KEYS[1])
    else
      return 0
    end
  `;
  const result = await redis.eval(script, 1, lockKey, token);
  return result === 1;
}

interface CachedValue<T> {
  data: T;
  cachedAt: number;
  ttl: number;
}
 
async function cacheWithEarlyExpiration<T>(key: string, fetcher: () => Promise<T>, ttl: number = 3600): Promise<T> {
  const cacheKey = `cache:${key}`;
  const cached = await redis.get(cacheKey);
 
  if (cached !== null) {
    const entry = JSON.parse(cached) as CachedValue<T>;
    const age = (Date.now() - entry.cachedAt) / 1000;
    const remaining = entry.ttl - age;
 
    // XFetch-algoritm: regenerera probabilistiskt när utgången närmar sig
    // beta * Math.log(Math.random()) producerar ett negativt tal
    // som växer sig större (mer negativt) när utgången närmar sig
    const beta = 1; // justeringsparameter, 1 fungerar bra
    const shouldRegenerate = remaining - beta * Math.log(Math.random()) * -1 <= 0;
 
    if (!shouldRegenerate) {
      return entry.data;
    }
 
    // Faller igenom för att regenerera
    console.log(`[Cache] Early regeneration triggered for ${key}`);
  }
 
  const data = await fetcher();
  const entry: CachedValue<T> = {
    data,
    cachedAt: Date.now(),
    ttl,
  };
 
  // Sätt med extra buffert så Redis inte löper ut innan vi kan regenerera
  await redis.set(cacheKey, JSON.stringify(entry), "EX", Math.round(ttl * 1.1));
 
  return data;
}

async function staleWhileRevalidate<T>(
  key: string,
  fetcher: () => Promise<T>,
  options: {
    freshTtl: number; // hur länge datan är "färsk"
    staleTtl: number; // hur länge inaktuell data kan serveras
  },
): Promise<T | null> {
  const cacheKey = `cache:${key}`;
  const metaKey = `meta:${key}`;
 
  const [cached, meta] = await redis.mget(cacheKey, metaKey);
 
  if (cached !== null) {
    const parsedMeta = meta ? JSON.parse(meta) : null;
    const isFresh = parsedMeta && Date.now() - parsedMeta.cachedAt < options.freshTtl * 1000;
 
    if (!isFresh) {
      // Datan är inaktuell — servera den men utlös bakgrundsuppdatering
      revalidateInBackground(key, cacheKey, metaKey, fetcher, options);
    }
 
    return JSON.parse(cached) as T;
  }
 
  // Komplett cache-miss — måste hämta synkront
  return fetchAndCache(key, cacheKey, metaKey, fetcher, options);
}
 
async function fetchAndCache<T>(
  key: string,
  cacheKey: string,
  metaKey: string,
  fetcher: () => Promise<T>,
  options: { freshTtl: number; staleTtl: number },
): Promise<T> {
  const data = await fetcher();
  const totalTtl = options.freshTtl + options.staleTtl;
 
  const pipeline = redis.pipeline();
  pipeline.set(cacheKey, JSON.stringify(data), "EX", totalTtl);
  pipeline.set(metaKey, JSON.stringify({ cachedAt: Date.now() }), "EX", totalTtl);
  await pipeline.exec();
 
  return data;
}
 
function revalidateInBackground<T>(
  key: string,
  cacheKey: string,
  metaKey: string,
  fetcher: () => Promise<T>,
  options: { freshTtl: number; staleTtl: number },
): void {
  // Använd ett lås för att förhindra flera bakgrundsuppdateringar
  const lockKey = `revalidate_lock:${key}`;
 
  redis
    .set(lockKey, "1", "EX", 30, "NX")
    .then((acquired) => {
      if (!acquired) return;
 
      return fetchAndCache(key, cacheKey, metaKey, fetcher, options).finally(() => redis.del(lockKey));
    })
    .catch((err) => {
      console.error(`[SWR] Background revalidation failed for ${key}:`, err);
    });
}

const user = await staleWhileRevalidate<User>("user:123", fetchUserFromDB, {
  freshTtl: 300, // 5 minuter färsk
  staleTtl: 3600, // servera inaktuellt i upp till 1 timme medan revalidering pågår
});

async function updateUserAndInvalidate(userId: string, updates: Partial<User>): Promise<User> {
  const user = await db.query("UPDATE users SET name = $2 WHERE id = $1 RETURNING *", [userId, updates.name]);
 
  // Invalidera cachen
  await redis.del(`cache:user:${userId}`);
 
  return user[0];
}

async function setWithTags<T>(key: string, value: T, ttl: number, tags: string[]): Promise<void> {
  const pipeline = redis.pipeline();
 
  // Lagra värdet
  pipeline.set(`cache:${key}`, JSON.stringify(value), "EX", ttl);
 
  // Lägg till nyckeln i varje taggs uppsättning
  for (const tag of tags) {
    pipeline.sadd(`tag:${tag}`, `cache:${key}`);
    pipeline.expire(`tag:${tag}`, ttl + 3600); // Tagguppsättningar lever längre än värden
  }
 
  await pipeline.exec();
}
 
async function invalidateByTag(tag: string): Promise<number> {
  const keys = await redis.smembers(`tag:${tag}`);
 
  if (keys.length === 0) return 0;
 
  const pipeline = redis.pipeline();
  for (const key of keys) {
    pipeline.del(key);
  }
  pipeline.del(`tag:${tag}`);
 
  await pipeline.exec();
  return keys.length;
}

// När du cachar teamdata, tagga den med alla medlems-ID:n
const team = await fetchTeam(teamId);
await setWithTags(`team:${teamId}`, team, 1800, [
  `entity:team:${teamId}`,
  ...team.members.map((m) => `entity:user:${m.id}`),
]);
 
// När användare 42 uppdaterar sin profil, invalidera allt som innehåller dem
await invalidateByTag("entity:user:42");

// Publicerare (i din API-tjänst)
async function publishInvalidation(entityType: string, entityId: string): Promise<void> {
  await redis.publish("cache:invalidate", JSON.stringify({ entityType, entityId, timestamp: Date.now() }));
}
 
// Prenumerant (i varje appinstans)
const subscriber = new Redis(/* samma konfiguration */);
 
subscriber.subscribe("cache:invalidate", (err) => {
  if (err) console.error("[PubSub] Subscribe error:", err);
});
 
subscriber.on("message", async (_channel, message) => {
  const { entityType, entityId } = JSON.parse(message);
  await invalidateByTag(`entity:${entityType}:${entityId}`);
  console.log(`[Cache] Invalidated ${entityType}:${entityId}`);
});

async function invalidateByPattern(pattern: string): Promise<number> {
  let cursor = "0";
  let deletedCount = 0;
 
  do {
    const [nextCursor, keys] = await redis.scan(cursor, "MATCH", pattern, "COUNT", 100);
    cursor = nextCursor;
 
    if (keys.length > 0) {
      await redis.del(...keys);
      deletedCount += keys.length;
    }
  } while (cursor !== "0");
 
  return deletedCount;
}
 
// Invalidera all cachad data för ett specifikt team
await invalidateByPattern("cache:team:42:*");

// Lagra användare som en hash
async function setUserHash(user: User): Promise<void> {
  const key = `user:${user.id}`;
  await redis.hset(key, {
    name: user.name,
    email: user.email,
    plan: user.plan,
    updatedAt: Date.now().toString(),
  });
  await redis.expire(key, 1800);
}
 
// Läs specifika fält
async function getUserPlan(userId: string): Promise<string | null> {
  return redis.hget(`user:${userId}`, "plan");
}
 
// Uppdatera ett enskilt fält
async function upgradeUserPlan(userId: string, plan: string): Promise<void> {
  await redis.hset(`user:${userId}`, "plan", plan);
}
 
// Läs hela hashen som objekt
async function getUserHash(userId: string): Promise<User | null> {
  const data = await redis.hgetall(`user:${userId}`);
  if (!data || Object.keys(data).length === 0) return null;
 
  return {
    id: userId,
    name: data.name,
    email: data.email,
    plan: data.plan as User["plan"],
  };
}

// Topplista
async function addScore(leaderboard: string, userId: string, score: number): Promise<void> {
  await redis.zadd(leaderboard, score, userId);
}
 
async function getTopPlayers(
  leaderboard: string,
  count: number = 10,
): Promise<Array<{ userId: string; score: number }>> {
  const results = await redis.zrevrange(leaderboard, 0, count - 1, "WITHSCORES");
 
  const players: Array<{ userId: string; score: number }> = [];
  for (let i = 0; i < results.length; i += 2) {
    players.push({
      userId: results[i],
      score: parseFloat(results[i + 1]),
    });
  }
  return players;
}
 
async function getUserRank(leaderboard: string, userId: string): Promise<number | null> {
  const rank = await redis.zrevrank(leaderboard, userId);
  return rank !== null ? rank + 1 : null; // 0-indexerat till 1-indexerat
}

async function slidingWindowRateLimit(
  identifier: string,
  windowMs: number,
  maxRequests: number,
): Promise<{ allowed: boolean; remaining: number }> {
  const key = `ratelimit:${identifier}`;
  const now = Date.now();
  const windowStart = now - windowMs;
 
  const pipeline = redis.pipeline();
 
  // Ta bort poster utanför fönstret
  pipeline.zremrangebyscore(key, 0, windowStart);
 
  // Lägg till aktuell förfrågan
  pipeline.zadd(key, now, `${now}:${Math.random()}`);
 
  // Räkna förfrågningar i fönstret
  pipeline.zcard(key);
 
  // Sätt utgång på hela nyckeln
  pipeline.expire(key, Math.ceil(windowMs / 1000));
 
  const results = await pipeline.exec();
  const count = results?.[2]?.[1] as number;
 
  return {
    allowed: count <= maxRequests,
    remaining: Math.max(0, maxRequests - count),
  };
}

interface Job {
  id: string;
  type: string;
  payload: Record<string, unknown>;
  createdAt: number;
}
 
// Producent
async function enqueueJob(queue: string, type: string, payload: Record<string, unknown>): Promise<string> {
  const job: Job = {
    id: randomUUID(),
    type,
    payload,
    createdAt: Date.now(),
  };
 
  await redis.lpush(`queue:${queue}`, JSON.stringify(job));
  return job.id;
}
 
// Konsument (blockerar tills ett jobb är tillgängligt)
async function dequeueJob(queue: string, timeout: number = 5): Promise<Job | null> {
  const result = await redis.brpop(`queue:${queue}`, timeout);
  if (!result) return null;
 
  return JSON.parse(result[1]) as Job;
}

// Spåra unika besökare per dag
async function trackVisitor(page: string, visitorId: string): Promise<boolean> {
  const key = `visitors:${page}:${new Date().toISOString().split("T")[0]}`;
  const isNew = await redis.sadd(key, visitorId);
 
  // Auto-utgång efter 48 timmar
  await redis.expire(key, 172800);
 
  return isNew === 1; // 1 = ny medlem, 0 = fanns redan
}
 
// Hämta antal unika besökare
async function getUniqueVisitors(page: string, date: string): Promise<number> {
  return redis.scard(`visitors:${page}:${date}`);
}
 
// Kontrollera om användare redan har utfört en åtgärd
async function hasUserVoted(pollId: string, userId: string): Promise<boolean> {
  return (await redis.sismember(`votes:${pollId}`, userId)) === 1;
}

// HyperLogLog för ungefärliga unika räkningar
async function trackVisitorApprox(page: string, visitorId: string): Promise<void> {
  const key = `hll:visitors:${page}:${new Date().toISOString().split("T")[0]}`;
  await redis.pfadd(key, visitorId);
  await redis.expire(key, 172800);
}
 
async function getApproxUniqueVisitors(page: string, date: string): Promise<number> {
  return redis.pfcount(`hll:visitors:${page}:${date}`);
}

const user = {
  id: "usr_abc123",
  name: "Ahmet Kousa",
  email: "ahmet@example.com",
  plan: "pro",
  preferences: {
    theme: "dark",
    language: "tr",
    notifications: true,
  },
};
 
// JSON: 189 bytes
const jsonStr = JSON.stringify(user);
console.log(Buffer.byteLength(jsonStr)); // 189
 
// JSON.parse på en het väg: ~0.02ms per anrop
// Vid 10 000 förfrågningar/sek: 200ms total CPU-tid per sekund

npm install msgpackr

import { pack, unpack } from "msgpackr";
 
// MessagePack: ~140 bytes (25% mindre)
const packed = pack(user);
console.log(packed.length); // ~140
 
// Lagra som Buffer
await redis.set("user:123", packed);
 
// Läs som Buffer
const raw = await redis.getBuffer("user:123");
if (raw) {
  const data = unpack(raw);
}

import { promisify } from "util";
import { gzip, gunzip } from "zlib";
 
const gzipAsync = promisify(gzip);
const gunzipAsync = promisify(gunzip);
 
async function setCompressed<T>(key: string, value: T, ttl: number): Promise<void> {
  const json = JSON.stringify(value);
 
  // Komprimera bara om större än 1KB (komprimeringens overhead är inte värt det för små värden)
  if (Buffer.byteLength(json) > 1024) {
    const compressed = await gzipAsync(json);
    await redis.set(key, compressed, "EX", ttl);
  } else {
    await redis.set(key, json, "EX", ttl);
  }
}
 
async function getCompressed<T>(key: string): Promise<T | null> {
  const raw = await redis.getBuffer(key);
  if (!raw) return null;
 
  try {
    // Försök dekomprimera först
    const decompressed = await gunzipAsync(raw);
    return JSON.parse(decompressed.toString()) as T;
  } catch {
    // Inte komprimerad, parsa som vanlig JSON
    return JSON.parse(raw.toString()) as T;
  }
}

// app/api/products/route.ts
import { NextResponse } from "next/server";
import redis from "@/lib/redis";
 
export async function GET(request: Request) {
  const url = new URL(request.url);
  const category = url.searchParams.get("category") || "all";
  const cacheKey = `api:products:${category}`;
 
  // Kontrollera cache
  const cached = await redis.get(cacheKey);
  if (cached) {
    return NextResponse.json(JSON.parse(cached), {
      headers: {
        "X-Cache": "HIT",
        "Cache-Control": "public, s-maxage=60",
      },
    });
  }
 
  // Hämta från databas
  const products = await db.products.findMany({
    where: category !== "all" ? { category } : undefined,
    orderBy: { createdAt: "desc" },
    take: 50,
  });
 
  // Cacha i 5 minuter med jitter
  await redis.set(cacheKey, JSON.stringify(products), "EX", ttlWithJitter(300));
 
  return NextResponse.json(products, {
    headers: {
      "X-Cache": "MISS",
      "Cache-Control": "public, s-maxage=60",
    },
  });
}

// lib/session.ts
import { randomUUID } from "crypto";
import redis from "./redis";
 
interface Session {
  userId: string;
  role: string;
  createdAt: number;
  data: Record<string, unknown>;
}
 
const SESSION_TTL = 86400; // 24 timmar
const SESSION_PREFIX = "session:";
 
export async function createSession(userId: string, role: string): Promise<string> {
  const sessionId = randomUUID();
  const session: Session = {
    userId,
    role,
    createdAt: Date.now(),
    data: {},
  };
 
  await redis.set(`${SESSION_PREFIX}${sessionId}`, JSON.stringify(session), "EX", SESSION_TTL);
 
  return sessionId;
}
 
export async function getSession(sessionId: string): Promise<Session | null> {
  const key = `${SESSION_PREFIX}${sessionId}`;
 
  // Använd GETEX för att uppdatera TTL vid varje åtkomst (glidande utgång)
  const raw = await redis.getex(key, "EX", SESSION_TTL);
  if (!raw) return null;
 
  return JSON.parse(raw) as Session;
}
 
export async function destroySession(sessionId: string): Promise<void> {
  await redis.del(`${SESSION_PREFIX}${sessionId}`);
}
 
// Förstör alla sessioner för en användare (användbart för "logga ut överallt")
export async function destroyAllUserSessions(userId: string): Promise<void> {
  // Detta kräver att man underhåller ett användare->sessioner-index
  const sessionIds = await redis.smembers(`user_sessions:${userId}`);
 
  if (sessionIds.length > 0) {
    const pipeline = redis.pipeline();
    for (const sid of sessionIds) {
      pipeline.del(`${SESSION_PREFIX}${sid}`);
    }
    pipeline.del(`user_sessions:${userId}`);
    await pipeline.exec();
  }
}

// middleware.ts (eller en hjälpfunktion som används av middleware)
import redis from "@/lib/redis";
 
interface RateLimitResult {
  allowed: boolean;
  remaining: number;
  resetAt: number;
}
 
export async function rateLimit(
  identifier: string,
  limit: number = 60,
  windowSeconds: number = 60,
): Promise<RateLimitResult> {
  const key = `rate:${identifier}`;
  const now = Math.floor(Date.now() / 1000);
  const windowStart = now - windowSeconds;
 
  // Lua-skript för atomär hastighetsbegränsning
  const script = `
    redis.call('ZREMRANGEBYSCORE', KEYS[1], 0, ARGV[1])
    redis.call('ZADD', KEYS[1], ARGV[2], ARGV[3])
    local count = redis.call('ZCARD', KEYS[1])
    redis.call('EXPIRE', KEYS[1], ARGV[4])
    return count
  `;
 
  const count = (await redis.eval(
    script,
    1,
    key,
    windowStart,
    now,
    `${now}:${Math.random()}`,
    windowSeconds,
  )) as number;
 
  return {
    allowed: count <= limit,
    remaining: Math.max(0, limit - count),
    resetAt: now + windowSeconds,
  };
}

// lib/distributed-lock.ts
import { randomUUID } from "crypto";
import redis from "./redis";
 
export async function withLock<T>(
  lockName: string,
  fn: () => Promise<T>,
  options: { ttl?: number; retryDelay?: number; maxRetries?: number } = {},
): Promise<T | null> {
  const { ttl = 30, retryDelay = 200, maxRetries = 10 } = options;
  const token = randomUUID();
  const lockKey = `dlock:${lockName}`;
 
  // Försök skaffa lås
  for (let attempt = 0; attempt < maxRetries; attempt++) {
    const acquired = await redis.set(lockKey, token, "EX", ttl, "NX");
 
    if (acquired) {
      try {
        // Förläng lås automatiskt för långvariga uppgifter
        const extender = setInterval(
          async () => {
            const script = `
            if redis.call("get", KEYS[1]) == ARGV[1] then
              return redis.call("expire", KEYS[1], ARGV[2])
            else
              return 0
            end
          `;
            await redis.eval(script, 1, lockKey, token, ttl);
          },
          (ttl * 1000) / 3,
        );
 
        const result = await fn();
        clearInterval(extender);
        return result;
      } finally {
        // Släpp lås bara om vi fortfarande äger det
        const releaseScript = `
          if redis.call("get", KEYS[1]) == ARGV[1] then
            return redis.call("del", KEYS[1])
          else
            return 0
          end
        `;
        await redis.eval(releaseScript, 1, lockKey, token);
      }
    }
 
    // Vänta innan omförsök
    await new Promise((r) => setTimeout(r, retryDelay));
  }
 
  // Kunde inte skaffa lås efter alla omförsök
  return null;
}

// I en cron-utlöst API-rutt
export async function POST() {
  const result = await withLock("daily-report", async () => {
    // Bara en instans kör detta
    const report = await generateDailyReport();
    await sendReportEmail(report);
    return report;
  });
 
  if (result === null) {
    return NextResponse.json({ message: "Another instance is already processing" }, { status: 409 });
  }
 
  return NextResponse.json({ success: true });
}

// lib/cache-metrics.ts
import redis from "./redis";
 
const METRICS_KEY = "metrics:cache";
 
export async function recordCacheHit(): Promise<void> {
  await redis.hincrby(METRICS_KEY, "hits", 1);
}
 
export async function recordCacheMiss(): Promise<void> {
  await redis.hincrby(METRICS_KEY, "misses", 1);
}
 
export async function getCacheStats(): Promise<{
  hits: number;
  misses: number;
  hitRate: number;
}> {
  const stats = await redis.hgetall(METRICS_KEY);
  const hits = parseInt(stats.hits || "0", 10);
  const misses = parseInt(stats.misses || "0", 10);
  const total = hits + misses;
 
  return {
    hits,
    misses,
    hitRate: total > 0 ? hits / total : 0,
  };
}
 
// Återställ mätningar dagligen
export async function resetCacheStats(): Promise<void> {
  await redis.del(METRICS_KEY);
}

redis-cli INFO memory

redis-cli INFO stats

# Lämna ALDRIG detta igång i produktion
# Det lägger till betydande overhead och kan logga känslig data
redis-cli MONITOR

# Aktivera nyckelrymdnotifieringar för utgångna och evictade händelser
redis-cli CONFIG SET notify-keyspace-events Ex

const subscriber = new Redis(/* konfiguration */);
 
// Lyssna efter nyckelutgångshändelser
subscriber.subscribe("__keyevent@0__:expired", (err) => {
  if (err) console.error("Subscribe error:", err);
});
 
subscriber.on("message", (_channel, expiredKey) => {
  console.log(`Key expired: ${expiredKey}`);
 
  // Proaktivt regenerera viktiga nycklar
  if (expiredKey.startsWith("cache:homepage")) {
    regenerateHomepageCache().catch(console.error);
  }
});

# Sampla 10 största nycklar
redis-cli --bigkeys

# Minnesanvändning för en specifik nyckel (i bytes)
redis-cli MEMORY USAGE "cache:search:electronics"

// Programmatisk minnesanalys
async function analyzeMemory(pattern: string): Promise<void> {
  let cursor = "0";
  const stats: Array<{ key: string; bytes: number }> = [];
 
  do {
    const [nextCursor, keys] = await redis.scan(cursor, "MATCH", pattern, "COUNT", 100);
    cursor = nextCursor;
 
    for (const key of keys) {
      const bytes = await redis.memory("USAGE", key);
      if (bytes) {
        stats.push({ key, bytes: bytes as number });
      }
    }
  } while (cursor !== "0");
 
  // Sortera efter storlek fallande
  stats.sort((a, b) => b.bytes - a.bytes);
 
  console.log("Top 20 keys by memory usage:");
  for (const { key, bytes } of stats.slice(0, 20)) {
    const mb = (bytes / 1024 / 1024).toFixed(2);
    console.log(`  ${key}: ${mb} MB`);
  }
}

# I redis.conf eller via CONFIG SET
maxmemory 512mb
maxmemory-policy allkeys-lru

// lib/cache.ts
import Redis from "ioredis";
 
const redis = new Redis({
  host: process.env.REDIS_HOST || "127.0.0.1",
  port: Number(process.env.REDIS_PORT) || 6379,
  password: process.env.REDIS_PASSWORD || undefined,
  maxRetriesPerRequest: 3,
  retryStrategy(times) {
    return Math.min(times * 200, 5000);
  },
});
 
// TTL-nivåer
const TTL = {
  STATIC: 86400,
  MODERATE: 1800,
  VOLATILE: 300,
  EPHEMERAL: 60,
  NOT_FOUND: 120,
} as const;
 
type TTLTier = keyof typeof TTL;
 
function ttlWithJitter(base: number, jitter = 0.1): number {
  const offset = base * jitter * (Math.random() * 2 - 1);
  return Math.max(1, Math.round(base + offset));
}
 
// Kärnan: cache-aside med stampedeskydd
async function get<T>(
  key: string,
  fetcher: () => Promise<T>,
  options: {
    tier?: TTLTier;
    ttl?: number;
    tags?: string[];
    swr?: { freshTtl: number; staleTtl: number };
  } = {},
): Promise<T> {
  const { tier = "MODERATE", tags } = options;
  const baseTtl = options.ttl ?? TTL[tier];
  const cacheKey = `c:${key}`;
 
  // Kontrollera cache
  const cached = await redis.get(cacheKey);
 
  if (cached !== null) {
    try {
      const parsed = JSON.parse(cached);
      recordHit();
      return parsed as T;
    } catch {
      await redis.del(cacheKey);
    }
  }
 
  recordMiss();
 
  // Skaffa lås för att förhindra stampede
  const lockKey = `lock:${key}`;
  const acquired = await redis.set(lockKey, "1", "EX", 10, "NX");
 
  if (!acquired) {
    // En annan process hämtar — vänta kort och försök cache igen
    await new Promise((r) => setTimeout(r, 150));
    const retried = await redis.get(cacheKey);
    if (retried) return JSON.parse(retried) as T;
  }
 
  try {
    const result = await fetcher();
    const ttl = ttlWithJitter(baseTtl);
 
    const pipeline = redis.pipeline();
    pipeline.set(cacheKey, JSON.stringify(result), "EX", ttl);
 
    // Lagra taggassociationer
    if (tags) {
      for (const tag of tags) {
        pipeline.sadd(`tag:${tag}`, cacheKey);
        pipeline.expire(`tag:${tag}`, ttl + 3600);
      }
    }
 
    await pipeline.exec();
    return result;
  } finally {
    await redis.del(lockKey);
  }
}
 
// Invalidering
async function invalidate(...keys: string[]): Promise<void> {
  if (keys.length === 0) return;
  await redis.del(...keys.map((k) => `c:${k}`));
}
 
async function invalidateByTag(tag: string): Promise<number> {
  const keys = await redis.smembers(`tag:${tag}`);
  if (keys.length === 0) return 0;
 
  const pipeline = redis.pipeline();
  for (const key of keys) {
    pipeline.del(key);
  }
  pipeline.del(`tag:${tag}`);
  await pipeline.exec();
  return keys.length;
}
 
// Mätningar
function recordHit(): void {
  redis.hincrby("metrics:cache", "hits", 1).catch(() => {});
}
 
function recordMiss(): void {
  redis.hincrby("metrics:cache", "misses", 1).catch(() => {});
}
 
async function stats(): Promise<{
  hits: number;
  misses: number;
  hitRate: string;
}> {
  const raw = await redis.hgetall("metrics:cache");
  const hits = parseInt(raw.hits || "0", 10);
  const misses = parseInt(raw.misses || "0", 10);
  const total = hits + misses;
 
  return {
    hits,
    misses,
    hitRate: total > 0 ? ((hits / total) * 100).toFixed(1) + "%" : "N/A",
  };
}
 
export const cache = {
  get,
  invalidate,
  invalidateByTag,
  stats,
  redis,
  TTL,
};

import { cache } from "@/lib/cache";
 
// Enkel cache-aside
const products = await cache.get("products:featured", fetchFeaturedProducts, {
  tier: "VOLATILE",
  tags: ["entity:products"],
});
 
// Med anpassad TTL
const config = await cache.get("app:config", fetchAppConfig, {
  ttl: 43200, // 12 timmar
});
 
// Efter uppdatering av en produkt
await cache.invalidateByTag("entity:products");
 
// Kontrollera hälsa
const metrics = await cache.stats();
console.log(`Cache hit rate: ${metrics.hitRate}`);

async function resilientGet<T>(key: string, fetcher: () => Promise<T>): Promise<T> {
  try {
    return await cache.get(key, fetcher);
  } catch (err) {
    console.error(`[Cache] Degraded mode for ${key}:`, err);
    return fetcher(); // Kringgå cache helt
  }
}