{
  "path": "https://kqznk1deju1f3qri.public.blob.vercel-storage.com/another_Bugs_Bunny_No.jpg",
  "metadata": {
    "title": "Bugs Bunny 'No' Meme with Defiant Expression",
    "description": "Meme này thể hiện Bugs Bunny với biểu cảm phản kháng, đôi mắt nửa nhắm và miệng hé mở thể hiện thái độ không quan tâm, từ 'no' nổi bật bằng chữ trắng đậm nhấn mạnh sự từ chối hài hước.",
    "tags": [ "Bugs Bunny", "Looney Tunes", "meme", "refusal", "humor" ],
    "memeContext": "Một khung hình từ Looney Tunes được dùng để biểu đạt sự từ chối hài hước trên mạng.",
    "humor": "Sử dụng phản ứng thái quá của nhân vật hoạt hình nổi tiếng để tạo hiệu ứng cười.",
    "format": "Bugs Bunny 'No' Meme",
    "textContent": "no",
    "person": "Bugs Bunny, animated character",
    "objects": "Bugs Bunny, text 'no'"
  }
}

export const generateEmbedding = async (value: string): Promise<number[]> => {
  const input = value.replaceAll("\n", " ");
  const { embedding } = await embed({ model: embeddingModel, value: input });
  return embedding;
};

export const memesIndex = new Index({
  url: process.env.UPSTASH_VECTOR_URL!,
  token: process.env.UPSTASH_VECTOR_TOKEN!,
});

const directMatches = await findMemesByQuery(query);
const semanticMatches = await findSimilarMemes(query);
const allMatches = uniqueItemsByTitle([...directMatches, ...semanticMatches]);

export const findSimilarMemes = async (description: string): Promise<Meme[]> => {
  const embedding = await generateEmbedding(description);
  const results = await memesIndex.query({
    vector: embedding,
    includeMetadata: true,
    topK: 60,
    includeVectors: false,
  });

  return results.map((result: any) => ({
    id: String(result.id),
    title: result.metadata?.title || '',
    description: result.metadata?.description || '',
    path: result.metadata?.path || '',
    embedding: [],
    similarity: result.score,
  }));
};

const cacheKey = query ? `q:${query.toLowerCase().replaceAll(" ", "_")}` : "all_memes";
const cached = await redis.get(cacheKey);

if (cached) {
  return { memes: JSON.parse(cached as string) };
}

// Thực hiện tìm kiếm

await redis.set(cacheKey, JSON.stringify(allMatches), { ex: REDIS_CACHE_TTL });

const RATE_LIMIT = {
  window: 60, // 60 giây
  requests: 10 // tối đa 10 yêu cầu
};

async function checkRateLimit(ip: string): Promise<boolean> {
  const now = Math.floor(Date.now() / 1000);
  const windowStart = now - RATE_LIMIT.window;

  await redis.zremrangebyscore(`ratelimit:${ip}`, 0, windowStart);

  const requestCount = await redis.zcount(`ratelimit:${ip}`, windowStart, '+inf');

  if (requestCount < RATE_LIMIT.requests) {
    await redis.zadd(`ratelimit:${ip}`, { score: now, member: now.toString() });
    return true;
  }
  return false;
}