Pipeline 3-Stage
Shopify Product Optimizer

// Pipeline multiagente — 3 etapas — 47 productos Shopify

export const meta = {
  name: 'terroir-product-optimizer',
  description: 'Audita, reescribe y valida fichas de producto Shopify
               para Terroir Specialty Coffee — SEO y CRO',
  phases: [
    { title: 'Audit SEO/CRO' },
    { title: 'Rewrite Copy' },
    { title: 'QA Validation' }
  ]
}

// Schemas de output estructurado
const AUDIT_SCHEMA = {
  type: 'object', required: ['product_id', 'seo_score_before', 'seo_issues', 'cro_issues'],
  properties: {
    product_id:       { type: 'string' },
    seo_score_before: { type: 'number', minimum: 0, maximum: 100 },
    seo_issues:       { type: 'array', items: { type: 'string' } },
    cro_issues:       { type: 'array', items: { type: 'string' } }
  }
}

const QA_SCHEMA = {
  type: 'object', required: ['product_id', 'quality_score', 'passed', 'flags'],
  properties: {
    product_id:    { type: 'string' },
    quality_score: { type: 'number', minimum: 0, maximum: 100 },
    passed:        { type: 'boolean' },
    flags:         { type: 'array', items: { type: 'string' } }
  }
}

// Lista de productos (en producción: args?.products desde CSV)
const PRODUCTS = args?.products ?? [
  { id: 'gid://shopify/Product/7301', title: 'Ethiopia Yirgacheffe', ... },
  { id: 'gid://shopify/Product/7302', title: 'Colombia Huila Washed', ... },
  // ... 44 más
]

// Pipeline: 3 etapas, cada producto fluye de forma independiente
const results = await pipeline(
  PRODUCTS,

  // Stage 1 — Audit SEO/CRO (haiku — barato, 47 auditorías en paralelo)
  (product, _orig, i) => agent(
    `Audita la ficha: "${product.title}" contra checklist SEO y CRO...`,
    { label: `audit:${product.id}`, phase: 'Audit SEO/CRO',
      model: 'haiku', schema: AUDIT_SCHEMA }
  ),

  // Stage 2 — Rewrite copy (sonnet — creatividad y storytelling de origen)
  (audit) => agent(
    `Reescribe el copy usando los datos de origen y los problemas detectados...`,
    { label: `rewrite:${audit?.product_id}`, phase: 'Rewrite Copy',
      model: 'sonnet' }
  ),

  // Stage 3 — QA validation (sonnet — checklist 10 criterios, schema)
  (rewrite) => agent(
    `Valida el copy generado contra 10 criterios de calidad...`,
    { label: `qa:${parsed?.product_id}`, phase: 'QA Validation',
      model: 'sonnet', schema: QA_SCHEMA }
  )
)

log(`Procesados: ${results.filter(Boolean).length}/47 productos`)
return results.filter(Boolean)