import { createClient } from "@sanity/client";

// Sanity client configured with an OAuth token scoped to the agent identity
const client = createClient({
  projectId: process.env.SANITY_PROJECT_ID!,
  dataset: process.env.SANITY_DATASET!,
  apiVersion: "2025-10-01",
  token: process.env.SANITY_AGENT_TOKEN!,
  useCdn: false,
});

// 1. Agent reads structured product data via GROQ (MCP exposes this as a tool)
async function getProductsNeedingUpdate() {
  const query = `*[_type == "product" && language == "en" && needsDescriptionUpdate == true]{
    _id,
    name,
    price,
    category->{name},
    description
  }`;
  return client.fetch(query);
}

// 2. Agent generates a new description with an LLM (pseudo-code)
async function generateDescription(product: any): Promise<string> {
  // call your LLM here with structured context
  return `Updated description for ${product.name} in category ${product.category?.name}.`;
}

// 3. Agent writes back via governed mutations (Agent API semantics)
async function updateProductDescription(productId: string, description: string) {
  return client
    .patch(productId)
    .set({ description, needsDescriptionUpdate: false })
    .commit();
}

// 4. Orchestrate the workflow (can be triggered by Sanity Functions on price change)
export async function runAgentCycle() {
  const products = await getProductsNeedingUpdate();

  for (const product of products) {
    const newDescription = await generateDescription(product);

    // Optional: send to a review workflow instead of direct publish
    await updateProductDescription(product._id, newDescription);
  }
}

runAgentCycle().catch(console.error);