Encadenar extractor de preferencias y aplicación de extras en el orquestador

mvp/b2c/src/lib/funnel/orchestrator.ts

@@ -3,8 +3,10 @@ import { db } from '@/db';
 import { leads, leadPipelineEventos } from '@/db/schema';
 import { getPricingConfigFor, getCatalogFor, getEnvioModeFor } from '@/db/pricing-queries';
 import { computeBudget } from '@/budget';
-import type { BudgetInputs } from '@/budget/types';
 import type { Lead } from '@/db/schema';
+import { deterministicExtractor } from '@/lib/voice/extractor';
+import { mergeIntoBudgetInputs, applyPreferences } from '@/lib/voice/apply';
+import type { RawCallData } from '@/lib/voice/preferences';
 
 // Render demo por tipo de reforma. No hay generación IA real en esta fase (keyless):
 // reusamos los renders de muestra del directorio público.
@@ -84,21 +86,29 @@ export async function procesarLead(leadId: string): Promise<void> {
     metadata: { simulado: true, renderUrl },
   });
 
-  // Paso 6b: presupuesto calculado (REAL) con el catálogo del reformista
+  // Paso 6b: presupuesto calculado (REAL) con catálogo + preferencias abstraídas
   const [config, catalog] = await Promise.all([
     getPricingConfigFor(lead.tenantId),
     getCatalogFor(lead.tenantId),
   ]);
-  const inputs: BudgetInputs = {
+
+  const raw: RawCallData = {
     tipoReforma: tipo,
     m2Suelo: lead.m2Suelo ?? null,
-    alturaTecho: lead.alturaTecho ?? null,
-    calidadGlobal: lead.calidadGlobal ?? 'media',
+    calidad: lead.calidadGlobal ?? null,
     estructural: lead.estructural,
-    provincia: lead.provincia ?? null,
-    materialSelections: (lead.materialSelections as Record<string, string>) ?? {},
+    urgencia: lead.urgencia ?? null,
+    presupuestoTarget: lead.presupuestoTarget ?? null,
+    tasteText: lead.tasteText ?? '',
   };
-  const result = computeBudget(inputs, config, catalog);
+  const prefs = deterministicExtractor.extract(raw, catalog);
+  const inputs = mergeIntoBudgetInputs(prefs, {
+    tipoReforma: lead.tipoReforma,
+    m2Suelo: lead.m2Suelo ?? null,
+    alturaTecho: lead.alturaTecho ?? null,
+    provincia: lead.provincia ?? null,
+  });
+  const result = applyPreferences(computeBudget(inputs, config, catalog), prefs);
 
   await db
     .update(leads)
@@ -108,6 +118,7 @@ export async function procesarLead(leadId: string): Promise<void> {
       renderUrl,
       presupuestoEstimado: result.total,
       desgloseSnapshot: { stage: 'presupuesto_generado', result },
+      preferencesSnapshot: prefs,
       pipelineStage: 'presupuesto_generado',
       updatedAt: new Date(),
     })