FASE 1 — schema:
- Cliente.email opcional; nuevo telefonoNorm (E.164, único) para matchear por WhatsApp
- TipoServicio.jefeMecanicoId opcional (trabajos per-jefe; globales legacy quedan null)
- Turno.autoId/kilometros opcionales (reservas por WhatsApp sin auto/km)
- Nuevo modelo ConversacionWhatsapp (estado del bot por teléfono)
- admin/turnos/[id]: no permite COMPLETADO sin auto+km; Sheets tolera email nulo

FASE 3 — panel de trabajos del jefe:
- API jefe/servicios (GET/POST) y jefe/servicios/[id] (PATCH/DELETE), scoped al jefe
- DELETE desactiva si el trabajo ya tiene turnos asociados
- Página /jefe/servicios (alta/listado/activar/editar/eliminar) + nav Turnos|Trabajos
- Dashboard del jefe resiliente a turnos sin auto/km ("a completar")

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>

@@ -14,2 +10,2 @@
-  telefono  String
-  createdAt DateTime @default(now())
+  id           String   @id @default(cuid())
+  email        String?  @unique

@@ -16,0 +12,4 @@
+  nombre       String
+  apellido     String
+  telefono     String
+  telefonoNorm String?  @unique // teléfono en formato E.164, usado para matchear al que escribe por WhatsApp

@@ -48,3 +52,3 @@
   id             String      @id @default(cuid())
   clienteId      String
-  autoId         String
+  autoId         String?

@@ -42,0 +41,4 @@
+  nombre         String
+  duracionHoras  Float
+  activo         Boolean @default(true)
+  jefeMecanicoId String? // trabajo cargado por un jefe mecánico puntual; null = servicio global (legacy)

@@ -53,3 +57,3 @@
   fechaInicio    DateTime
   fechaFin       DateTime
-  kilometros     Int
+  kilometros     Int?

@@ -120,0 +127,4 @@
+// El webhook es stateless: acá se guarda en qué paso está y las selecciones parciales.
+model ConversacionWhatsapp {
+  id        String   @id @default(cuid())
+  telefono  String   @unique // wa_id del cliente (E.164, sin '+')

@@ -11,3 +11,3 @@
     "db:push": "prisma db push",
     "db:seed": "npx tsx prisma/seed.ts",
-    "db:studio": "prisma studio"
+    "db:studio": "prisma studio",

@@ -13,1 +13,3 @@
-    "db:studio": "prisma studio"
+    "db:studio": "prisma studio",
+    "test:bot": "tsx scripts/test-whatsapp-bot.ts",
+    "test:envio": "tsx scripts/test-whatsapp-envio.ts"

@@ -120,0 +129,4 @@
+  id        String   @id @default(cuid())
+  telefono  String   @unique // wa_id del cliente (E.164, sin '+')
+  paso      String   @default("INICIO") // paso de la máquina de estados
+  datos     Json     @default("{}") // selecciones parciales (mecánico, trabajo, slot, alta en curso, etc.)

@@ -12,2 +12,3 @@
     "db:seed": "npx tsx prisma/seed.ts",
-    "db:studio": "prisma studio"
+    "db:studio": "prisma studio",
+    "test:bot": "tsx scripts/test-whatsapp-bot.ts",

@@ -120,0 +141,4 @@
+// webhook tarda o falla, y sin esto un reintento crea el turno dos veces. Va en la
+// base (y no en memoria) para que siga valiendo con más de una instancia.
+model MensajeWhatsappProcesado {
+  id        String   @id // wamid que manda Meta

@@ -120,0 +144,4 @@
+  id        String   @id // wamid que manda Meta
+  createdAt DateTime @default(now())
+
+  @@index([createdAt])

@@ -13,0 +13,4 @@
+  // Regla: no se puede cerrar (COMPLETADO) un turno sin auto y kilometraje cargados.
+  // Las reservas por WhatsApp los dejan vacíos; el jefe mecánico debe completarlos antes de cerrar.
+  if (estado === "COMPLETADO") {
+    const actual = await prisma.turno.findUnique({

@@ -17,3 +32,3 @@
   });
 
-  if (estado === "COMPLETADO") {
+  if (estado === "COMPLETADO" && turno.auto && turno.kilometros != null) {

@@ -27,3 +42,3 @@
         nombre: turno.cliente.nombre,
         apellido: turno.cliente.apellido,
-        email: turno.cliente.email,
+        email: turno.cliente.email ?? "",

@@ -7,2 +10,4 @@
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
+  const jefeMecanicoId = req.nextUrl.searchParams.get("jefeMecanicoId");
+  if (!jefeMecanicoId)

@@ -9,0 +18,4 @@
+    where: { id: jefeMecanicoId },
+    select: { activo: true },
+  });
+  if (!jefe || !jefe.activo)

@@ -9,2 +23,3 @@
+
   const servicios = await prisma.tipoServicio.findMany({
-    where: { activo: true },
+    where: whereTrabajosDeJefe(jefeMecanicoId),

@@ -18,6 +19,8 @@ export async function GET(req: NextRequest) {
   const servicio = await prisma.tipoServicio.findUnique({ where: { id: tipoServicioId } });
   if (!servicio || !servicio.activo)
     return NextResponse.json({ error: "Servicio no encontrado" }, { status: 404 });
+  if (!trabajoEsDeJefe(servicio, jefeMecanicoId))

@@ -0,0 +8,4 @@
+ * Correr con:  npx tsx scripts/test-whatsapp-bot.ts
+ */
+
+/* eslint-disable @typescript-eslint/no-explicit-any */

@@ -0,0 +68,4 @@
+    async findMany({ where, orderBy, select }: any = {}) {
+      let rs = rows.filter((x) => match(x, where || {}));
+      if (orderBy) {
+        const [f, dir] = Object.entries(orderBy)[0] as [string, string];

@@ -0,0 +85,4 @@
+      const r = rows.find((x) => match(x, where || {}));
+      if (!r) throw new Error("update: fila no encontrada");
+      Object.assign(r, data);
+      r.updatedAt = new Date();

@@ -0,0 +94,4 @@
+        Object.assign(r, update);
+        return { ...r };
+      }
+      const nuevo = { ...defaults(), ...where, ...create };

@@ -0,0 +140,4 @@
+  },
+  // `crearTurno` verifica y crea dentro de una transacción con un lock por jefe.
+  // Acá corre todo sobre el mismo cliente falso, que ya es secuencial.
+  async $transaction(fn: any) {

@@ -0,0 +181,4 @@
+const paso = (tel: string) => convs.find((c) => c.telefono === tel)?.paso;
+
+async function main() {
+  const { procesarMensaje } = await import("../src/lib/whatsapp-bot");

@@ -0,0 +251,4 @@
+  ok(/Revision general/i.test(flat(r)), "un jefe sin trabajos propios igual ofrece los globales");
+  ok(!/Cambio de aceite/i.test(flat(r)), "NO ofrece los trabajos propios de otro jefe");
+
+  const { crearTurno } = await import("../src/lib/turnos");

@@ -0,0 +52,4 @@
+  });
+  if (!propio) return NextResponse.json({ error: "Trabajo no encontrado" }, { status: 404 });
+
+  const enUso = await prisma.turno.count({ where: { tipoServicioId: id } });

@@ -0,0 +18,4 @@
+
+  if (data.duracionHoras !== undefined) {
+    const dur = Number(data.duracionHoras);
+    if (!Number.isFinite(dur) || dur <= 0 || dur > 24)

@@ -0,0 +20,4 @@
+    const dur = Number(data.duracionHoras);
+    if (!Number.isFinite(dur) || dur <= 0 || dur > 24)
+      return NextResponse.json(
+        { error: "La duración debe ser un número de horas entre 0 y 24" },

@@ -0,0 +58,4 @@
+      where: { id },
+      data: { activo: false },
+    });
+    return NextResponse.json({ ...servicio, desactivado: true });

@@ -2,3 +2,3 @@
 import { prisma } from "@/lib/prisma";
 import { verificarSesion } from "@/lib/auth-admin";
-import { slotEstaDisponible } from "@/lib/scheduling";
+import { crearTurno } from "@/lib/turnos";

@@ -63,0 +40,4 @@
+    tipoServicioId,
+    fechaInicio: new Date(fechaInicio),
+    autoId,
+    kilometros: km,

@@ -63,3 +44,3 @@
   });
 
-  return NextResponse.json(turno, { status: 201 });
+  if (!resultado.ok)

@@ -66,0 +46,4 @@
+  if (!resultado.ok)
+    return NextResponse.json({ error: resultado.error }, { status: resultado.status });
+
+  return NextResponse.json(resultado.turno, { status: 201 });

@@ -82,3 +82,3 @@
                   <span>{t.cliente.telefono}</span>
                   <span className="text-gray-400">Auto</span>
-                  <span>{t.auto.marca} {t.auto.modelo}</span>
+                  <span>{t.auto ? `${t.auto.marca} ${t.auto.modelo}` : <em className="text-amber-600">a completar</em>}</span>

@@ -87,2 +86,3 @@
+                  <span className="font-mono">{t.auto?.patente ?? "—"}</span>
                   <span className="text-gray-400">Kilometraje</span>
-                  <span>{t.kilometros.toLocaleString("es-AR")} km</span>
+                  <span>{t.kilometros != null ? `${t.kilometros.toLocaleString("es-AR")} km` : <em className="text-amber-600">a completar</em>}</span>

@@ -0,0 +22,4 @@
+  if (!sesion || sesion.role !== "jefe")
+    return NextResponse.json({ error: "No autorizado" }, { status: 401 });
+
+  const { nombre, duracionHoras } = await req.json();

@@ -0,0 +26,4 @@
+  const dur = Number(duracionHoras);
+  if (!nombre || typeof nombre !== "string" || !nombre.trim())
+    return NextResponse.json({ error: "El nombre del trabajo es obligatorio" }, { status: 400 });
+  if (!Number.isFinite(dur) || dur <= 0 || dur > 24)

@@ -0,0 +32,4 @@
+      { status: 400 }
+    );
+
+  const servicio = await prisma.tipoServicio.create({

@@ -0,0 +8,4 @@
+  if (!sesion || sesion.role !== "jefe")
+    return NextResponse.json({ error: "No autorizado" }, { status: 401 });
+
+  const servicios = await prisma.tipoServicio.findMany({

@@ -0,0 +26,4 @@
+  const dur = Number(duracionHoras);
+  if (!nombre || typeof nombre !== "string" || !nombre.trim())
+    return NextResponse.json({ error: "El nombre del trabajo es obligatorio" }, { status: 400 });
+  if (!Number.isFinite(dur) || dur <= 0 || dur > 24)

@@ -12,6 +12,11 @@ export default function JefeLayout({ children }: { children: React.ReactNode })
 
   if (pathname === "/jefe") return <>{children}</>;
 
+  const tabs = [

@@ -26,1 +31,4 @@
         </div>
+        <nav className="flex gap-1">
+          {tabs.map((t) => {
+            const activo = pathname === t.href;

@@ -27,0 +35,4 @@
+            return (
+              <button
+                key={t.href}
+                onClick={() => router.push(t.href)}

@@ -27,0 +36,4 @@
+              <button
+                key={t.href}
+                onClick={() => router.push(t.href)}
+                className={`text-sm px-4 py-2 rounded-lg transition ${

@@ -0,0 +23,4 @@
+// crea el turno dos veces. Se resuelve insertando el id en la base: el índice único
+// hace la operación atómica, así que sirve incluso con varias instancias corriendo.
+const DIAS_RETENCION = 7;
+let ultimaLimpieza = 0;

@@ -0,0 +36,4 @@
+}
+
+/** Borra los ids viejos como mucho una vez por día. Best-effort: si falla, no importa. */
+async function limpiarProcesadosViejos(): Promise<void> {

@@ -0,0 +73,4 @@
+
+  let body: PayloadWebhook;
+  try {
+    body = JSON.parse(cuerpoCrudo) as PayloadWebhook;

@@ -0,0 +66,4 @@
+  // La firma se calcula sobre el cuerpo CRUDO: leerlo como texto y recién ahí parsear.
+  const cuerpoCrudo = await req.text();
+
+  if (!firmaValida(cuerpoCrudo, req.headers.get("x-hub-signature-256"))) {

@@ -0,0 +86,4 @@
+      const messageId = mensaje.id;
+      if (!telefono || !messageId || (await yaProcesado(messageId))) continue;
+
+      void marcarLeido(messageId).catch(() => {});

@@ -0,0 +102,4 @@
+      const respuestas = await procesarMensaje(telefono, texto);
+      await enviarRespuestas(telefono, respuestas);
+    }
+  } catch (e) {

@@ -0,0 +25,4 @@
+const DIAS_RETENCION = 7;
+let ultimaLimpieza = 0;
+
+async function yaProcesado(id: string): Promise<boolean> {

@@ -3,0 +6,4 @@
+ * verificación de disponibilidad corra dentro de la misma transacción que crea
+ * el turno (ver `crearTurno`), que es lo que evita reservas superpuestas.
+ */
+type ClienteDb = Prisma.TransactionClient;

@@ -55,2 +63,3 @@
   fin: Date,
-  jefeMecanicoId: string
+  jefeMecanicoId: string,
+  db: ClienteDb = prisma

@@ -0,0 +8,4 @@
+ * cualquiera. El cliente elige primero el mecánico y después el trabajo, así que la lista
+ * siempre es: los del jefe + los globales.
+ */
+export function whereTrabajosDeJefe(jefeMecanicoId: string): Prisma.TipoServicioWhereInput {

@@ -0,0 +11,4 @@
+export function whereTrabajosDeJefe(jefeMecanicoId: string): Prisma.TipoServicioWhereInput {
+  return {
+    activo: true,
+    OR: [{ jefeMecanicoId }, { jefeMecanicoId: null }],

@@ -0,0 +35,4 @@
+  if (!trabajoEsDeJefe(servicio, jefeMecanicoId))
+    return { ok: false, error: "Ese trabajo no lo hace este mecánico", status: 400 };
+
+  const fin = new Date(fechaInicio.getTime() + servicio.duracionHoras * 60 * 60 * 1000);

@@ -0,0 +41,4 @@
+  // de Postgres: si no, dos clientes pueden pasar la verificación al mismo tiempo
+  // y quedar los dos reservados sobre la misma capacidad.
+  const turno = await prisma.$transaction(async (tx) => {
+    await tx.$executeRaw`SELECT pg_advisory_xact_lock(hashtext(${jefeMecanicoId}))`;

@@ -0,0 +44,4 @@
+    await tx.$executeRaw`SELECT pg_advisory_xact_lock(hashtext(${jefeMecanicoId}))`;
+
+    const disponible = await slotEstaDisponible(fechaInicio, fin, jefeMecanicoId, tx);
+    if (!disponible) return null;

@@ -0,0 +64,4 @@
+    });
+  });
+
+  if (!turno) return { ok: false, error: "El horario ya no está disponible", status: 409 };

@@ -0,0 +21,4 @@
+
+  useEffect(() => { cargar(); }, []);
+
+  async function cargar() {

@@ -0,0 +36,4 @@
+    const res = await fetch("/api/jefe/servicios", {
+      method: "POST",
+      headers: { "Content-Type": "application/json" },
+      body: JSON.stringify({ nombre, duracionHoras: duracion }),

@@ -0,0 +64,4 @@
+    const res = await fetch(`/api/jefe/servicios/${s.id}`, {
+      method: "PATCH",
+      headers: { "Content-Type": "application/json" },
+      body: JSON.stringify({ duracionHoras: valor }),

@@ -0,0 +49,4 @@
+    cargar();
+  }
+
+  async function toggleActivo(s: Servicio) {

@@ -0,0 +19,4 @@
+  const [error, setError] = useState<string | null>(null);
+  const [guardando, setGuardando] = useState(false);
+
+  useEffect(() => { cargar(); }, []);

@@ -0,0 +74,4 @@
+    cargar();
+  }
+
+  async function eliminar(s: Servicio) {

@@ -0,0 +102,4 @@
+            />
+            <Input
+              label="Duración (horas)"
+              type="text"

@@ -0,0 +139,4 @@
+                  </p>
+                </div>
+                <div className="flex gap-2">
+                  <Button variant="secondary" className="text-sm" onClick={() => editarDuracion(s)}>

@@ -0,0 +86,4 @@
+    };
+
+  const opciones: OpcionMenu[] = jefes.map((j, i) => ({ letra: String(i + 1), id: j.id, label: j.nombre }));
+  const botones: BotonBot[] = jefes.slice(0, 3).map((j) => ({ id: j.id, titulo: j.nombre.slice(0, 20) }));

@@ -0,0 +114,4 @@
+    servicios.map((s) => ({ label: `${s.nombre} (${s.duracionHoras}h)` }))
+  );
+  // Guardar el id real de cada trabajo en las opciones
+  servicios.forEach((s, i) => (opciones[i].id = s.id));

@@ -0,0 +132,4 @@
+  datos: DatosConv,
+  offset: number
+): Promise<{ resp: RespuestaBot[]; datos: DatosConv; paso: string }> {
+  const slots = await obtenerSlotsDisponibles(datos.jefeMecanicoId!, datos.duracionHoras ?? 1, 30, 200);

@@ -0,0 +148,4 @@
+
+  const opciones: OpcionMenu[] = pagina.map((s, i) => ({
+    letra: LETRAS[i] ?? String(i + 1),
+    id: s.fechaInicio.toISOString(),

@@ -0,0 +208,4 @@
+  }
+
+  // Comando global: cancelar
+  if (NO.includes(lower) && paso !== "CONFIRMAR" && paso !== "INICIO") {

@@ -0,0 +166,4 @@
+
+// ── Persistencia ──
+async function guardar(
+  convId: string,

@@ -0,0 +216,4 @@
+
+  switch (paso) {
+    case "INICIO": {
+      const cliente = await prisma.cliente.findFirst({ where: { telefonoNorm: telefono } });

@@ -0,0 +239,4 @@
+      const cliente = conv.clienteId
+        ? await prisma.cliente.findUnique({ where: { id: conv.clienteId } })
+        : await prisma.cliente.findFirst({ where: { telefonoNorm: telefono } });
+      if (cliente?.email && lower === cliente.email.toLowerCase()) {

@@ -0,0 +276,4 @@
+          { tipo: "texto", texto: "Ese email ya está registrado con otro número. Escribí otro o comunicate con el taller." },
+        ]);
+
+      const cliente = await prisma.cliente.create({

@@ -0,0 +341,4 @@
+      if (!SI.includes(lower))
+        return guardar(conv.id, "CONFIRMAR", datos, [{ tipo: "texto", texto: "Respondé *sí* para confirmar o *no* para cancelar." }]);
+
+      const res = await crearTurno({

@@ -0,0 +52,4 @@
+  return new Promise((r) => setTimeout(r, ms));
+}
+
+async function postMensaje(payload: Record<string, unknown>): Promise<void> {

@@ -0,0 +73,4 @@
+    let status: number;
+    let detalle = "";
+    try {
+      const res = await fetch(url, init);

@@ -0,0 +66,4 @@
+      Authorization: `Bearer ${cred.token}`,
+      "Content-Type": "application/json",
+    },
+    body: JSON.stringify({ messaging_product: "whatsapp", ...payload }),

@@ -0,0 +133,4 @@
+}
+
+/** Envía en orden las respuestas del bot (secuencial: WhatsApp respeta el orden de llegada). */
+export async function enviarRespuestas(telefono: string, respuestas: RespuestaBot[]): Promise<void> {

@@ -0,0 +141,4 @@
+}
+
+/** Marca el mensaje como leído (los tildes azules). Best-effort: si falla, no importa. */
+export async function marcarLeido(messageId: string): Promise<void> {

@@ -0,0 +169,4 @@
+}
+
+/** Saca el texto de un mensaje según su tipo. `null` = tipo que el bot no maneja. */
+export function textoDeMensaje(mensaje: MensajeMeta): string | null {

@@ -0,0 +27,4 @@
+}
+
+/** Valida la firma X-Hub-Signature-256 del webhook contra el cuerpo crudo. */
+export function firmaValida(cuerpoCrudo: string, firmaHeader: string | null): boolean {

@@ -0,0 +100,4 @@
+  await postMensaje({
+    to: telefono,
+    type: "text",
+    text: { body: texto.slice(0, MAX_TEXTO), preview_url: false },