Persist data with KV cache

import { BrowserContext, Page } from "playwright";
import { persistentStore } from "@intuned/runtime";

interface Params {}

export default async function handler(
  params: Params,
  page: Page,
  context: BrowserContext
) {
  const CACHE_KEY = "consultations";

  // 1. Check cache first
  const cached = await persistentStore.get(CACHE_KEY);
  if (cached) {
    return cached;
  }

  // 2. Cache miss — navigate and scrape the page
  await page.goto("https://sandbox.intuned.dev/consultations/list");
  await page.waitForSelector(".consultation-item");

  const consultations = await page.locator(".consultation-item").evaluateAll(
    (items) =>
      items.map((item) => ({
        id: item.getAttribute("data-consultation-id"),
        status: item.querySelector(".consultation-status")?.textContent?.trim(),
        name: item.querySelector(".client-name .data-value")?.textContent?.trim(),
        date: item.querySelector(".consultation-date .data-value")?.textContent?.trim(),
        topic: item.querySelector(".consultation-topic .data-value")?.textContent?.trim(),
      }))
  );

  // 3. Store for future runs
  await persistentStore.set(CACHE_KEY, consultations);

  return consultations;
}

from playwright.async_api import Page
from intuned_runtime import persistent_store
from typing import Any, Dict


async def automation(page: Page, params: Dict[str, Any] | None = None, **_kwargs):
    CACHE_KEY = "consultations"

    # 1. Check cache first
    cached = await persistent_store.get(CACHE_KEY)
    if cached:
        return cached

    # 2. Cache miss — navigate and scrape the page
    await page.goto("https://sandbox.intuned.dev/consultations/list")
    await page.wait_for_selector(".consultation-item")

    items = await page.locator(".consultation-item").all()
    consultations = []
    for item in items:
        consultations.append({
            "id": await item.get_attribute("data-consultation-id"),
            "status": await item.locator(".consultation-status").inner_text(),
            "name": await item.locator(".client-name .data-value").inner_text(),
            "date": await item.locator(".consultation-date .data-value").inner_text(),
            "topic": await item.locator(".consultation-topic .data-value").inner_text(),
        })

    # 3. Store for future runs
    await persistent_store.set(CACHE_KEY, consultations)

    return consultations