# Produser: A1 Controller mengirim tugas scraping baru
XADD scrape-tasks * job_id "9b1deb4d-3b7d-4bad" domain "kompas.com" max_pages 15

# Konsumen: Scraper Worker membaca antrean tugas dalam consumer group
XREADGROUP GROUP b1-workers worker-01 BLOCK 5000 COUNT 5 STREAMS scrape-tasks >

# Konfirmasi: Scraper menyelesaikan scraping
XACK scrape-tasks b1-workers 1726056000000-0

// Implementasi Distributed Lock pada API Gateway / Worker
async function acquireArticleLock(articleId: string, instanceId: string): Promise<boolean> {
  const lockKey = `nexa:worker:lock:${articleId}`;
  // Set kunci jika belum ada (NX) dengan masa kedaluwarsa 600 detik (EX)
  const result = await redis.set(lockKey, instanceId, 'NX', 'EX', 600);
  return result === 'OK';
}

async function releaseArticleLock(articleId: string, instanceId: string): Promise<void> {
  const lockKey = `nexa:worker:lock:${articleId}`;
  const luaScript = `
    if redis.call("get", KEYS[1]) == ARGV[1] then
      return redis.call("del", KEYS[1])
    else
      return 0
    end
  `;
  await redis.eval(luaScript, 1, lockKey, instanceId);
}