fix(whatsapp): pasar las credenciales de Meta al contenedor

docker-compose.yml no interpolaba ninguna WHATSAPP_*, asi que las cuatro
variables cargadas en el .env de produccion no llegaban a la app: los
envios cortaban con "falta WHATSAPP_TOKEN" y el webhook devolvia 403 al
no tener APP_SECRET con que validar la firma.

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

.ai-review.yaml

@@ -0,0 +1,60 @@
+# Configuración de la revisión con IA (https://github.com/Nikita-Filonov/ai-review)
+#
+# Acá va sólo lo estático. Los tokens y el contexto del pull request llegan por
+# variables de entorno desde .gitea/workflows/ai-review.yml, con la convención
+# de doble guión bajo que usa la herramienta (VCS__PIPELINE__OWNER, etc.).
+# Ojo: la sintaxis ${VARIABLE} dentro de este archivo NO se resuelve.
+
+llm:
+  provider: OPENROUTER
+
+  meta:
+    # Modelo sin costo, 1M de contexto.
+    model: nvidia/nemotron-3-ultra-550b-a55b:free
+    max_tokens: 8000
+    temperature: 0.2
+    # Viaja como cabecera HTTP y se codifica en ASCII: sin acentos ni enies.
+    title: "Revision IA Taller"
+
+  http_client:
+    timeout: 180
+    api_url: https://openrouter.ai/api/v1
+
+  # --- Si este modelo deja de estar disponible ---
+  # El catalogo gratuito de OpenRouter rota. Si el job falla con 404 de modelo,
+  # listar los vigentes y reemplazar la clave model:
+  #   curl -s https://openrouter.ai/api/v1/models | grep -o '"id":"[^"]*:free"'
+  # Alternativas verificadas el 03/08/2026:
+  #   cohere/north-mini-code:free
+  #   nvidia/nemotron-3-super-120b-a12b:free
+
+core:
+  # El plan gratuito de OpenRouter admite 20 pedidos por minuto.
+  concurrency: 3
+
+review:
+  mode: FULL_FILE_DIFF
+  ignore_pure_renames: true
+  max_context_comments: 15
+  max_inline_comments: 10
+
+  ignore_changes:
+    - "package-lock.json"
+    - "*.lock"
+    - "*.min.js"
+    - "*.min.css"
+    - "*.svg"
+    - "*.png"
+    - "*.jpg"
+    - "*.jpeg"
+    - "*.ico"
+    - "*.woff*"
+    - "public/**"
+    - "tsconfig.tsbuildinfo"
+
+prompt:
+  context_prompt_files:
+    - ./.gitea/ai-review/context.md
+
+  summary_prompt_files:
+    - ./.gitea/ai-review/summary.md

.gitea/ai-review/context.md

@@ -0,0 +1,68 @@
+# Revisión de código — Taller Automotriz
+
+Escribí siempre en español rioplatense, directo y sin rodeos.
+
+Recibís **todos los archivos cambiados del pull request juntos**, no uno por
+vez. Aprovechalo: además de los errores dentro de cada archivo, buscá los que
+sólo se ven mirando el conjunto.
+
+## Contexto del proyecto
+
+Sistema de turnos para un taller mecánico. Next.js (App Router) con TypeScript,
+Prisma sobre PostgreSQL:
+
+- `src/app/api` — endpoints.
+- `src/app/{admin,jefe,cliente}` — las tres áreas, con permisos distintos.
+- `src/lib` — la lógica que importa: `scheduling.ts` y `turnos.ts` (slots y
+  reservas), `whatsapp-bot.ts` (bot de reservas), `magic-link.ts` y
+  `auth-admin.ts` (autenticación), `prisma.ts` (cliente).
+- `prisma/schema.prisma` — modelo de datos: `Cliente`, `Auto`, `Turno`,
+  `TipoServicio`, `JefeMecanico`, `HistorialServicio`, `Admin`, `MagicToken`,
+  `ConversacionWhatsapp`.
+
+## Qué mirar con prioridad
+
+1. **Turnos y disponibilidad**: es el corazón del sistema. Reservas que se
+   pisan, husos horarios, slots que se calculan distinto en dos lugares,
+   condiciones de carrera entre dos clientes reservando el mismo horario,
+   estados de `Turno` que cambian sin validar la transición.
+2. **Autorización por área**: `admin`, `jefe` y `cliente` ven cosas distintas.
+   Un endpoint que no verifica el rol en el backend, o que confía en lo que
+   manda el cliente, es un hallazgo grave. Los magic links son credenciales:
+   token que no expira, que se reutiliza o que se registra en un log.
+3. **Bugs reales**: promesas sin `await`, `null`/`undefined` sin contemplar,
+   errores tragados, casos borde sin cubrir.
+4. **Prisma**: migraciones que no acompañan al cambio de `schema.prisma`,
+   consultas dentro de un bucle (N+1), operaciones que deberían ir en una
+   transacción y no lo están.
+5. **Coherencia entre archivos**: un tipo que cambia en `src/lib` y deja
+   desactualizado a quien lo consume, lógica de negocio duplicada entre un
+   endpoint y el bot de WhatsApp en vez de vivir en `src/lib`.
+
+## Cuidados propios de este proyecto
+
+- Los datos de clientes (teléfono, email, patente) son personales: no deben
+  terminar en logs ni en respuestas de error.
+- El bot de WhatsApp responde a mensajes de afuera: todo lo que llega por ahí
+  es entrada no confiable y hay que validarlo.
+- Nunca claves ni tokens en el código, los documentos o los mensajes.
+
+## Antes de afirmar
+
+Si tu observación depende de cómo se comporta una función del lenguaje, de
+Next.js o de Prisma, verificá que estás seguro. Si no lo estás, plantealo como
+pregunta ("¿confirmaste que X hace Y?") en vez de afirmarlo. Un señalamiento
+correcto apoyado en una premisa falsa hace perder tiempo y resta credibilidad al
+resto de la revisión.
+
+## Qué no comentar
+
+- Formato, comillas, punto y coma o largo de línea: de eso se ocupa el linter.
+- Preferencias de estilo sin impacto en el comportamiento.
+- Renombres de variables porque te suenan mejor.
+- Reescrituras completas de un archivo que ya funciona.
+- Elogios o comentarios que sólo describen lo que hace el código.
+
+Como ves muchos archivos de una sola vez, resistí la tentación de comentar en
+todos para parecer completo. Si de veinte archivos sólo tres tienen algo que
+decir, comentá esos tres. Un comentario ruidoso cuesta más que uno faltante.

.gitea/ai-review/summary.md

@@ -0,0 +1,23 @@
+# Resumen del pull request — J2 ProDE
+
+Escribí en español rioplatense. Sé breve: quien lee quiere decidir si aprobar o
+no, no leer una redacción.
+
+Estructura:
+
+1. **Qué cambia** — dos o tres oraciones sobre la intención del cambio, no un
+   listado de archivos tocados.
+2. **Riesgos** — sólo si los hay de verdad. Priorizá: violaciones de las
+   invariantes del proyecto, cambios de contrato en `packages/contracts`,
+   migraciones de PostgreSQL, autorización, y todo lo que pueda romper un
+   despliegue en curso.
+3. **Antes de aprobar** — verificaciones concretas que convenga correr a mano si
+   el gate (`pnpm check`) no las cubre.
+
+Reglas:
+
+- Si no hay riesgos, decilo en una línea y terminá.
+- No repitas el diff ni parafrasees cada archivo.
+- No felicites al autor.
+- Ante la duda de si algo es un problema, decilo como duda y explicá qué
+  verificar, sin afirmar que está roto.

.gitea/workflows/ai-review.yml

@@ -0,0 +1,244 @@
+name: Revisión con IA
+
+on:
+  # Incluimos "synchronize" desde que la revision pasó al modo por contexto:
+  # antes costaba un pedido por archivo (unos veinte por revision) y revisar
+  # cada push era inviable contra el limite diario; ahora cuesta dos, asi que
+  # conviene que el pull request se revise de nuevo al corregirlo. Ademas el
+  # estado del check queda al dia: sin esto un pull request arreglado seguia
+  # figurando en rojo por la corrida vieja.
+  pull_request:
+    types: [opened, reopened, synchronize]
+  workflow_dispatch:
+    inputs:
+      pull-request-number:
+        description: "Número de PR a revisar"
+        required: true
+        type: string
+      review-command:
+        description: "Modo de revisión"
+        required: false
+        default: auto
+        type: choice
+        options:
+          # Lo mismo que hace el disparo automático: contexto + resumen,
+          # dos pedidos al modelo en total.
+          - auto
+          # Un pedido por archivo cambiado. Más minucioso y mucho más caro
+          # en cuota: con 20 archivos son 20 pedidos.
+          - run-inline
+          - run-context
+          - run-summary
+          - clear-inline
+          - clear-summary
+
+jobs:
+  ai-review:
+    runs-on: ai-review
+    timeout-minutes: 20
+
+    steps:
+      - name: Descargar el código
+        uses: actions/checkout@v4
+        with:
+          fetch-depth: 0
+
+      - name: Preparar Python
+        uses: actions/setup-python@v5
+        with:
+          python-version: "3.12"
+
+      - name: Instalar la herramienta de revisión
+        run: pip install xai-review==0.71.0
+
+      - name: Leer los secretos de Infisical
+        env:
+          INFISICAL_URL: ${{ vars.INFISICAL_URL }}
+          INFISICAL_CLIENT_ID: ${{ secrets.INFISICAL_CLIENT_ID }}
+          INFISICAL_CLIENT_SECRET: ${{ secrets.INFISICAL_CLIENT_SECRET }}
+          INFISICAL_PROJECT_ID: ${{ vars.INFISICAL_PROJECT_ID }}
+          INFISICAL_ENV: ${{ vars.INFISICAL_ENV }}
+          INFISICAL_PATH: ${{ vars.INFISICAL_PATH }}
+        run: |
+          set -eu
+          # Infisical vive en la misma red docker que este job, asi que le
+          # hablamos por DNS interno sin salir a Internet.
+          : "${INFISICAL_URL:=http://infisical:8080}"
+          : "${INFISICAL_PROJECT_ID:=4db7af6a-1f7a-445d-a5f3-fddb9e64b614}"
+          : "${INFISICAL_ENV:=prod}"
+          : "${INFISICAL_PATH:=/gitea-ai-review}"
+          export INFISICAL_URL INFISICAL_PROJECT_ID INFISICAL_ENV INFISICAL_PATH
+
+          python3 - <<'PY'
+          import json, os, sys, time, urllib.error, urllib.parse, urllib.request
+
+          base = os.environ["INFISICAL_URL"].rstrip("/")
+          INTENTOS = 3
+          ESPERA = 5
+
+          def diagnosticar(error):
+              """Devuelve (mensaje, si_conviene_reintentar)."""
+              if isinstance(error, urllib.error.HTTPError):
+                  motivos = {
+                      400: "el pedido fue rechazado; revisar el identificador del proyecto",
+                      401: "credenciales rechazadas; revisar INFISICAL_CLIENT_ID y INFISICAL_CLIENT_SECRET",
+                      403: "la identidad de maquina no tiene permiso sobre el proyecto",
+                      404: "no existe el proyecto, el entorno o la ruta indicada",
+                      429: "demasiados pedidos a Infisical",
+                  }
+                  motivo = motivos.get(error.code, "respuesta inesperada del servicio")
+                  # Reintentar solo lo transitorio: un 401 no se arregla esperando.
+                  return f"HTTP {error.code} — {motivo}", error.code >= 500 or error.code == 429
+              if isinstance(error, urllib.error.URLError):
+                  return f"no se pudo contactar a {base} ({error.reason})", True
+              return f"error inesperado: {error}", False
+
+          def call(path, data=None, token=None):
+              ultimo = None
+              for intento in range(1, INTENTOS + 1):
+                  req = urllib.request.Request(base + path)
+                  if token:
+                      req.add_header("Authorization", "Bearer " + token)
+                  if data is not None:
+                      req.add_header("Content-Type", "application/json")
+                      req.data = json.dumps(data).encode()
+                  try:
+                      with urllib.request.urlopen(req, timeout=30) as r:
+                          return json.load(r)
+                  except Exception as exc:  # noqa: BLE001 - se clasifica abajo
+                      mensaje, reintentable = diagnosticar(exc)
+                      ultimo = mensaje
+                      if not reintentable or intento == INTENTOS:
+                          break
+                      print(f"Infisical: {mensaje}. Reintento {intento}/{INTENTOS - 1} en {ESPERA}s.",
+                            file=sys.stderr)
+                      time.sleep(ESPERA)
+              print(f"No se pudieron leer los secretos de Infisical: {ultimo}", file=sys.stderr)
+              raise SystemExit(1)
+
+          auth = call("/api/v1/auth/universal-auth/login", {
+              "clientId": os.environ["INFISICAL_CLIENT_ID"],
+              "clientSecret": os.environ["INFISICAL_CLIENT_SECRET"],
+          })
+          query = urllib.parse.urlencode({
+              "workspaceId": os.environ["INFISICAL_PROJECT_ID"],
+              "environment": os.environ["INFISICAL_ENV"],
+              "secretPath": os.environ["INFISICAL_PATH"],
+          })
+          secrets = call("/api/v3/secrets/raw?" + query, token=auth["accessToken"])
+
+          wanted = {"OPENROUTER_API_KEY": "LLM__HTTP_CLIENT__API_TOKEN",
+                    "AI_REVIEW_GITEA_TOKEN": "VCS__HTTP_CLIENT__API_TOKEN"}
+          found = {s["secretKey"]: s["secretValue"] for s in secrets["secrets"]}
+
+          faltan = [k for k in wanted if not found.get(k)]
+          if faltan:
+              print("Faltan secretos en Infisical: " + ", ".join(faltan), file=sys.stderr)
+              raise SystemExit(1)
+
+          with open(os.environ["GITHUB_ENV"], "a") as env_file:
+              for clave, variable in wanted.items():
+                  valor = found[clave]
+                  # Que el runner lo tache si alguna vez se imprime.
+                  print(f"::add-mask::{valor}")
+                  env_file.write(f"{variable}={valor}\n")
+
+          print(f"Secretos leidos de Infisical: {', '.join(wanted)}")
+          PY
+
+      - name: Revisar el pull request
+        env:
+          VCS__PROVIDER: GITEA
+          VCS__PIPELINE__OWNER: ${{ gitea.repository_owner }}
+          VCS__PIPELINE__REPO: ${{ gitea.event.repository.name }}
+
+          # El job corre en la red "proxy" del runner, la misma del contenedor
+          # gitea: hablamos con la API por DNS interno en vez de salir a
+          # Internet para volver por el proxy. Se puede sobrescribir con la
+          # variable de repositorio GITEA_API_URL.
+          GITEA_API_URL: ${{ vars.GITEA_API_URL }}
+
+          PR_NUMBER: ${{ gitea.event.pull_request.number }}
+          PR_NUMBER_INPUT: ${{ inputs.pull-request-number }}
+          REVIEW_COMMAND: ${{ inputs.review-command }}
+        run: |
+          set -eu
+          : "${GITEA_API_URL:=http://gitea:3000/api/v1}"
+          : "${PR_NUMBER:=${PR_NUMBER_INPUT}}"
+          : "${REVIEW_COMMAND:=auto}"
+
+          if [ -z "${PR_NUMBER}" ]; then
+            echo "No hay número de pull request para revisar"
+            exit 1
+          fi
+
+          export VCS__HTTP_CLIENT__API_URL="${GITEA_API_URL}"
+          export VCS__PIPELINE__PULL_NUMBER="${PR_NUMBER}"
+
+          # xai-review termina con codigo 0 aunque falle la publicacion de los
+          # comentarios: imprime el traceback y saluda con
+          # "AI review completed successfully!". Sin esto el job quedaria en
+          # verde sin haber revisado nada, que es peor que fallar.
+          #
+          # Cuidado con QUE se busca: el log tambien trae el texto de los
+          # comentarios que escribe el modelo, y ese texto puede decir
+          # cualquier cosa. El patron 'Error: ' que habia antes se disparo con
+          # el comentario de la propia revision (inventario#3) y marco como
+          # fallida una revision que habia salido bien. Por eso ahora se miran
+          # las marcas de nivel que imprime la herramienta, que el modelo no
+          # escribe, y el traceback al principio de linea.
+          ERRORES='\| (ERROR|CRITICAL) \||^Traceback \(most recent call last\)'
+
+          # El plan gratuito de OpenRouter devuelve 502 cuando los proveedores
+          # del modelo estan saturados; pasó el 03/08/2026 y el pull request se
+          # mergeo sin revisar. Eso se reintenta, pero un 401 o un modelo que ya
+          # no existe no se arreglan esperando: por eso solo reintentamos con
+          # las marcas que deja una falla al pedirle la respuesta al modelo.
+          # Todas ocurren antes de publicar nada, asi que el reintento no puede
+          # dejar comentarios repetidos.
+          PASAJEROS='OpenRouterChatResponseSchema|LLM returned empty|Upstream|Too Many Requests|timed out'
+          INTENTOS=3
+          PRIMERA_ESPERA=30
+
+          revisar() {
+            modo="$1"
+            registro="/tmp/ai-review-${modo}.log"
+            intento=1
+            espera="${PRIMERA_ESPERA}"
+
+            while : ; do
+              echo "== ai-review ${modo} (intento ${intento} de ${INTENTOS})"
+
+              # Sin tuberia a proposito: con "| tee" el codigo que se evalua es
+              # el de tee, que siempre da 0, y la falla pasaba desapercibida.
+              salida=0
+              ai-review "${modo}" > "${registro}" 2>&1 || salida=$?
+              cat "${registro}"
+
+              if [ "${salida}" -eq 0 ] && ! grep -qE "${ERRORES}" "${registro}"; then
+                return 0
+              fi
+
+              if [ "${intento}" -ge "${INTENTOS}" ] || ! grep -qE "${PASAJEROS}" "${registro}"; then
+                echo "La revisión reportó errores en '${modo}' pese a terminar sin código de error." >&2
+                return 1
+              fi
+
+              echo "Falla pasajera del proveedor; reintento en ${espera}s." >&2
+              sleep "${espera}"
+              intento=$((intento + 1))
+              espera=$((espera * 2))
+            done
+          }
+
+          # Para depurar la configuración existe "ai-review show-config", pero
+          # imprime los tokens resueltos: no correrlo dentro del pipeline.
+          if [ "${REVIEW_COMMAND}" = "auto" ]; then
+            # La revisión por contexto manda todos los archivos en un único
+            # pedido y aun así deja los comentarios pegados a cada línea, así
+            # que el pull request completo cuesta dos pedidos al modelo.
+            revisar run-context
+            revisar run-summary
+          else
+            revisar "${REVIEW_COMMAND}"
+          fi

.gitea/workflows/deploy.yml

@@ -10,9 +10,33 @@ jobs:
     steps:
       - name: Pull y rebuild
         run: |
+          set -eu
           git config --global --add safe.directory /home/proyecto/taller_automotriz
           cd /home/proyecto/taller_automotriz
           git fetch origin
           git reset --hard origin/main
-          docker compose down
+
-          docker compose up -d --build
+          # Construir ANTES de tocar lo que esta corriendo. Antes este paso
+          # hacia "docker compose down" y recien despues "up --build": si la
+          # construccion fallaba (por ejemplo, npm sin poder bajar las
+          # dependencias), el taller quedaba caido hasta que alguien lo
+          # notara. Pasó el 03/08/2026.
+          docker compose build
+
+          # Con la imagen nueva ya lista, "up -d" recrea los contenedores que
+          # cambiaron. No hace falta bajar nada de antemano.
+          docker compose up -d --no-build --remove-orphans
+
+      - name: Verificar que quedo arriba
+        run: |
+          set -eu
+          cd /home/proyecto/taller_automotriz
+          docker compose ps
+
+          # Si el contenedor no esta corriendo, el despliegue fallo aunque los
+          # comandos anteriores hayan salido bien.
+          if [ -z "$(docker compose ps --quiet --status running)" ]; then
+            echo "El despliegue termino sin contenedores corriendo"
+            docker compose logs --tail 50
+            exit 1
+          fi

docker-compose.yml

@@ -33,6 +33,13 @@ services:
       GOOGLE_CLIENT_EMAIL: ${GOOGLE_CLIENT_EMAIL}
       GOOGLE_SHEET_ID: ${GOOGLE_SHEET_ID}
       GOOGLE_PRIVATE_KEY: ${GOOGLE_PRIVATE_KEY}
+      # Bot de WhatsApp. Sin estas cuatro el .env de produccion no llega al
+      # contenedor: los envios avisan que falta el token y el webhook contesta
+      # 403 porque no puede validar la firma. Ver docs/whatsapp.md.
+      WHATSAPP_PHONE_NUMBER_ID: ${WHATSAPP_PHONE_NUMBER_ID}
+      WHATSAPP_TOKEN: ${WHATSAPP_TOKEN}
+      WHATSAPP_VERIFY_TOKEN: ${WHATSAPP_VERIFY_TOKEN}
+      WHATSAPP_APP_SECRET: ${WHATSAPP_APP_SECRET}
     ports:
       - "3004:3000"
 

docs/whatsapp.md

@@ -35,7 +35,9 @@ puede confiar en el payload).
    Para el token definitivo: Business Settings → System Users → crear usuario → Generate Token
    con permisos `whatsapp_business_messaging` y `whatsapp_business_management`.
 4. **App → Settings → Basic → App Secret** → `WHATSAPP_APP_SECRET`.
-5. Cargar las 4 variables en el `.env` de producción y redeployar.
+5. Cargar las 4 variables en el `.env` de producción (`/home/proyecto/taller_automotriz/.env`,
+   al lado del `docker-compose.yml`, que es de donde compose las interpola) y levantar de nuevo
+   con `docker compose up -d`. Un `git push` no alcanza: el `.env` no está en el repo.
 6. **WhatsApp → Configuration → Webhook**:
    - Callback URL: `https://taller.beldo.duckdns.org/api/whatsapp/webhook`
    - Verify token: el mismo `WHATSAPP_VERIFY_TOKEN`

prisma/schema.prisma

@@ -136,3 +136,13 @@ model ConversacionWhatsapp {
 
   cliente Cliente? @relation(fields: [clienteId], references: [id])
 }
+
+// Ids de mensajes de WhatsApp ya procesados. Meta reintenta el mismo mensaje si el
+// 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
+  createdAt DateTime @default(now())
+
+  @@index([createdAt])
+}

scripts/chat-bot.ts

@@ -0,0 +1,54 @@
+/**
+ * Chatear con el bot de WhatsApp desde la consola, sin Meta.
+ *
+ * Habla directo con `procesarMensaje`, que es lo mismo que invoca el webhook, así
+ * que ejercita la conversación completa contra la base a la que apunte DATABASE_URL
+ * (turnos incluidos: lo que reserves acá queda guardado).
+ *
+ *   DATABASE_URL=... npx tsx scripts/chat-bot.ts [telefono]
+ *
+ * Acepta entrada interactiva o por tubería (una línea por mensaje).
+ * Comandos propios: /salir, /reset (borra la conversación de ese teléfono).
+ */
+
+import { createInterface } from "readline";
+import { prisma } from "../src/lib/prisma";
+import { procesarMensaje } from "../src/lib/whatsapp-bot";
+import { normalizarTelefono } from "../src/lib/telefono";
+
+// Normalizado igual que en el bot: si no, /reset no encuentra la conversación.
+const telefono = normalizarTelefono(process.argv[2] ?? "5493510000000");
+
+function mostrar(resp: { tipo: string; texto: string; botones?: { titulo: string }[] }[]) {
+  for (const r of resp) {
+    console.log("\n🤖 " + r.texto.replace(/\n/g, "\n   "));
+    if (r.tipo === "botones" && r.botones)
+      console.log("   [ " + r.botones.map((b) => b.titulo).join(" ] [ ") + " ]");
+  }
+}
+
+async function main() {
+  console.log(`Chateando como ${telefono}. /salir para terminar, /reset para empezar de cero.`);
+
+  const rl = createInterface({ input: process.stdin, terminal: false });
+
+  for await (const linea of rl) {
+    const texto = linea.trim();
+    if (texto === "/salir") break;
+    if (texto === "/reset") {
+      await prisma.conversacionWhatsapp.deleteMany({ where: { telefono } });
+      console.log("\n(conversación borrada)");
+      continue;
+    }
+    console.log(`\n👤 ${texto}`);
+    mostrar(await procesarMensaje(telefono, texto));
+  }
+
+  await prisma.$disconnect();
+}
+
+main().catch(async (e) => {
+  console.error(e);
+  await prisma.$disconnect();
+  process.exit(1);
+});

scripts/test-whatsapp-bot.ts

@@ -24,6 +24,10 @@ function match(row: Row, where: Row): boolean {
       if (!(v as Row[]).every((w) => match(row, w))) return false;
       continue;
     }
+    if (k === "OR") {
+      if (!(v as Row[]).some((w) => match(row, w))) return false;
+      continue;
+    }
     const rv = row[k];
     if (v !== null && typeof v === "object" && !(v instanceof Date)) {
       if ("in" in v && !(v.in as any[]).includes(rv)) return false;
@@ -134,6 +138,14 @@ const fakePrisma: any = {
       return out;
     },
   },
+  // `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) {
+    return fn(fakePrisma);
+  },
+  async $executeRaw() {
+    return 0;
+  },
 };
 
 (globalThis as any).prisma = fakePrisma;
@@ -143,6 +155,8 @@ jefes.push({ id: "j1", nombre: "Carlos", email: "j1@t.com", activo: true, slotsP
 jefes.push({ id: "j2", nombre: "Diego", email: "j2@t.com", activo: true, slotsParalelos: 1 });
 servicios.push({ id: "s1", nombre: "Cambio de aceite", duracionHoras: 1, activo: true, jefeMecanicoId: "j1" });
 servicios.push({ id: "s2", nombre: "Alineacion", duracionHoras: 2, activo: true, jefeMecanicoId: "j1" });
+// Trabajo global del taller (lo carga el admin): lo ofrece cualquier jefe.
+servicios.push({ id: "s3", nombre: "Revision general", duracionHoras: 1, activo: true, jefeMecanicoId: null });
 clientes.push({
   id: "c1",
   nombre: "Juan",
@@ -187,6 +201,7 @@ async function main() {
 
   r = await env(A, "j1");
   ok(/Cambio de aceite/i.test(flat(r)), "muestra trabajos del jefe elegido");
+  ok(/Revision general/i.test(flat(r)), "incluye los trabajos globales del taller");
   ok(paso(A) === "ELEGIR_TRABAJO", "paso=ELEGIR_TRABAJO");
 
   r = await env(A, "a");
@@ -225,6 +240,26 @@ async function main() {
   ok(/cancel/i.test(flat(r)), "cancelar resetea");
   ok(paso(B) === "INICIO", "paso=INICIO tras cancelar");
 
+  console.log("\n── Escenario D: trabajos por jefe ──");
+  const D = "5493518888888";
+  await env(D, "hola");
+  await env(D, "Ana");
+  await env(D, "Lopez");
+  r = await env(D, "ana@mail.com");
+  ok(hayBotones(r), "alta rápida hasta elegir mecánico");
+  r = await env(D, "j2");
+  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");
+  const cruzado = await crearTurno({
+    clienteId: "c1",
+    jefeMecanicoId: "j2",
+    tipoServicioId: "s1", // trabajo propio de j1
+    fechaInicio: new Date(Date.now() + 24 * 60 * 60 * 1000),
+  });
+  ok(!cruzado.ok && cruzado.status === 400, "crearTurno rechaza el trabajo de otro jefe (400)");
+
   console.log(`\n${fallos === 0 ? "✅ TODO OK" : `❌ ${fallos} assert(s) fallaron`}\n`);
   process.exit(fallos === 0 ? 0 : 1);
 }

scripts/test-whatsapp-envio.ts

@@ -32,6 +32,8 @@ function ok(cond: boolean, msg: string) {
 // ── Stub de fetch: guarda lo que se le manda a Meta en vez de salir a internet ──
 type Llamada = { url: string; auth: string; body: any };
 let llamadas: Llamada[] = [];
+// Códigos a devolver, en orden. Si se vacía, responde 200.
+let respuestas: number[] = [];
 globalThis.fetch = (async (url: string | URL, init?: RequestInit) => {
   const headers = (init?.headers ?? {}) as Record<string, string>;
   llamadas.push({
@@ -39,7 +41,8 @@ globalThis.fetch = (async (url: string | URL, init?: RequestInit) => {
     auth: headers["Authorization"] ?? "",
     body: JSON.parse(String(init?.body ?? "{}")),
   });
-  return { ok: true, status: 200, text: async () => "" } as Response;
+  const status = respuestas.shift() ?? 200;
+  return { ok: status < 400, status, text: async () => "detalle" } as Response;
 }) as typeof fetch;
 
 async function main() {
@@ -97,6 +100,33 @@ async function main() {
   ok(llamadas.length === 2, "manda las respuestas múltiples en orden");
   ok(llamadas[0].body.text.body === "uno" && llamadas[1].body.text.body === "dos", "respeta el orden");
 
+  console.log("\n── Salida: reintentos ──");
+  llamadas = [];
+  respuestas = [429];
+  await enviarRespuestas("549351", [{ tipo: "texto", texto: "con rate limit" }]);
+  ok(llamadas.length === 2, "reintenta ante un 429 y sale bien en el segundo intento");
+
+  llamadas = [];
+  respuestas = [500, 503];
+  await enviarRespuestas("549351", [{ tipo: "texto", texto: "con 5xx" }]);
+  ok(llamadas.length === 3, "reintenta ante 5xx hasta que uno sale bien");
+
+  llamadas = [];
+  respuestas = [500, 500, 500];
+  await enviarRespuestas("549351", [{ tipo: "texto", texto: "siempre 5xx" }]);
+  ok(llamadas.length === 3, "no reintenta más de 3 veces");
+
+  llamadas = [];
+  respuestas = [400];
+  await enviarRespuestas("549351", [{ tipo: "texto", texto: "payload malo" }]);
+  ok(llamadas.length === 1, "un 400 no se reintenta (es error nuestro)");
+
+  llamadas = [];
+  respuestas = [401];
+  await enviarRespuestas("549351", [{ tipo: "texto", texto: "token vencido" }]);
+  ok(llamadas.length === 1, "un 401 no se reintenta");
+  respuestas = [];
+
   console.log("\n── Firma del webhook ──");
   const cuerpo = JSON.stringify({ hola: "chau", acento: "ñandú" });
   const firma = "sha256=" + crypto.createHmac("sha256", "secreto-de-prueba").update(cuerpo, "utf8").digest("hex");

src/app/api/admin/clientes/route.ts

@@ -3,7 +3,7 @@ import { prisma } from "@/lib/prisma";
 import { verificarSesion } from "@/lib/auth-admin";
 
 export async function GET(req: NextRequest) {
-  const sesion = await verificarSesion("admin_session");
+  const sesion = await verificarSesion("admin_session", "admin");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const { searchParams } = new URL(req.url);

src/app/api/admin/historial/route.ts

@@ -3,7 +3,7 @@ import { prisma } from "@/lib/prisma";
 import { verificarSesion } from "@/lib/auth-admin";
 
 export async function GET(req: NextRequest) {
-  const sesion = await verificarSesion("admin_session");
+  const sesion = await verificarSesion("admin_session", "admin");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const { searchParams } = new URL(req.url);
@@ -20,7 +20,7 @@ export async function GET(req: NextRequest) {
 }
 
 export async function POST(req: NextRequest) {
-  const sesion = await verificarSesion("admin_session");
+  const sesion = await verificarSesion("admin_session", "admin");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const { autoId, tipoServicioId, descripcion, observaciones, fechaRealizado } = await req.json();

src/app/api/admin/jefes/[id]/route.ts

@@ -4,7 +4,7 @@ import { verificarSesion } from "@/lib/auth-admin";
 import bcrypt from "bcryptjs";
 
 export async function PATCH(req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
-  const sesion = await verificarSesion("admin_session");
+  const sesion = await verificarSesion("admin_session", "admin");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const { id } = await params;

src/app/api/admin/jefes/route.ts

@@ -4,7 +4,7 @@ import { verificarSesion } from "@/lib/auth-admin";
 import bcrypt from "bcryptjs";
 
 export async function GET() {
-  const sesion = await verificarSesion("admin_session");
+  const sesion = await verificarSesion("admin_session", "admin");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const jefes = await prisma.jefeMecanico.findMany({
@@ -15,7 +15,7 @@ export async function GET() {
 }
 
 export async function POST(req: NextRequest) {
-  const sesion = await verificarSesion("admin_session");
+  const sesion = await verificarSesion("admin_session", "admin");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const { nombre, email, password, slotsParalelos } = await req.json();

src/app/api/admin/servicios/[id]/route.ts

@@ -3,7 +3,7 @@ import { prisma } from "@/lib/prisma";
 import { verificarSesion } from "@/lib/auth-admin";
 
 export async function PATCH(req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
-  const sesion = await verificarSesion("admin_session");
+  const sesion = await verificarSesion("admin_session", "admin");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const { id } = await params;

src/app/api/admin/servicios/route.ts

@@ -3,7 +3,7 @@ import { prisma } from "@/lib/prisma";
 import { verificarSesion } from "@/lib/auth-admin";
 
 export async function GET() {
-  const sesion = await verificarSesion("admin_session");
+  const sesion = await verificarSesion("admin_session", "admin");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const servicios = await prisma.tipoServicio.findMany({ orderBy: { nombre: "asc" } });
@@ -11,7 +11,7 @@ export async function GET() {
 }
 
 export async function POST(req: NextRequest) {
-  const sesion = await verificarSesion("admin_session");
+  const sesion = await verificarSesion("admin_session", "admin");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const { nombre, duracionHoras } = await req.json();

src/app/api/admin/turnos/[id]/route.ts

@@ -4,7 +4,7 @@ import { verificarSesion } from "@/lib/auth-admin";
 import { agregarFilaSheet } from "@/lib/google-sheets";
 
 export async function PATCH(req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
-  const sesion = await verificarSesion("admin_session");
+  const sesion = await verificarSesion("admin_session", "admin");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const { id } = await params;

src/app/api/admin/turnos/route.ts

@@ -3,7 +3,7 @@ import { prisma } from "@/lib/prisma";
 import { verificarSesion } from "@/lib/auth-admin";
 
 export async function GET(req: NextRequest) {
-  const sesion = await verificarSesion("admin_session");
+  const sesion = await verificarSesion("admin_session", "admin");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const { searchParams } = new URL(req.url);

src/app/api/cliente/autos/route.ts

@@ -3,7 +3,7 @@ import { prisma } from "@/lib/prisma";
 import { verificarSesion } from "@/lib/auth-admin";
 
 export async function GET() {
-  const sesion = await verificarSesion("cliente_session");
+  const sesion = await verificarSesion("cliente_session", "cliente");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const autos = await prisma.auto.findMany({
@@ -15,7 +15,7 @@ export async function GET() {
 }
 
 export async function POST(req: NextRequest) {
-  const sesion = await verificarSesion("cliente_session");
+  const sesion = await verificarSesion("cliente_session", "cliente");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const { patente, marca, modelo, anio, nroChasis } = await req.json();

src/app/api/cliente/historial/route.ts

@@ -3,7 +3,7 @@ import { prisma } from "@/lib/prisma";
 import { verificarSesion } from "@/lib/auth-admin";
 
 export async function GET(req: NextRequest) {
-  const sesion = await verificarSesion("cliente_session");
+  const sesion = await verificarSesion("cliente_session", "cliente");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const { searchParams } = new URL(req.url);

src/app/api/cliente/jefes/route.ts

@@ -3,7 +3,7 @@ import { prisma } from "@/lib/prisma";
 import { verificarSesion } from "@/lib/auth-admin";
 
 export async function GET() {
-  const sesion = await verificarSesion("cliente_session");
+  const sesion = await verificarSesion("cliente_session", "cliente");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const jefes = await prisma.jefeMecanico.findMany({

src/app/api/cliente/perfil/route.ts

@@ -0,0 +1,97 @@
+import { NextRequest, NextResponse } from "next/server";
+import { Prisma } from "@prisma/client";
+import { prisma } from "@/lib/prisma";
+import { verificarSesion } from "@/lib/auth-admin";
+import { aFormatoWhatsapp, aLocalArgentino, esLocalArgentinoValido } from "@/lib/telefono";
+
+const EMAIL_RE = /^[^\s@]+@[^\s@]+\.[^\s@]+$/;
+
+// Datos de contacto del cliente logueado. El teléfono se devuelve en formato local
+// (sin el +54 9) porque el formulario lo muestra como prefijo fijo.
+export async function GET() {
+  const sesion = await verificarSesion("cliente_session", "cliente");
+  if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
+
+  const cliente = await prisma.cliente.findUnique({
+    where: { id: sesion.sub },
+    select: { nombre: true, apellido: true, email: true, telefono: true, telefonoNorm: true },
+  });
+  if (!cliente) return NextResponse.json({ error: "Cliente no encontrado" }, { status: 404 });
+
+  return NextResponse.json({
+    nombre: cliente.nombre,
+    apellido: cliente.apellido,
+    email: cliente.email ?? "",
+    telefono: aLocalArgentino(cliente.telefonoNorm ?? cliente.telefono ?? ""),
+  });
+}
+
+export async function PATCH(req: NextRequest) {
+  const sesion = await verificarSesion("cliente_session", "cliente");
+  if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
+
+  const { nombre, apellido, email, telefono } = await req.json();
+
+  if (!nombre?.trim() || !apellido?.trim())
+    return NextResponse.json({ error: "Nombre y apellido son obligatorios" }, { status: 400 });
+
+  if (!email?.trim() || !EMAIL_RE.test(email.trim()))
+    return NextResponse.json({ error: "El email no es válido" }, { status: 400 });
+
+  if (!esLocalArgentinoValido(telefono ?? ""))
+    return NextResponse.json(
+      { error: "El teléfono debe tener 10 dígitos, sin el 0 de la característica ni el 15" },
+      { status: 400 }
+    );
+
+  const emailNuevo = email.trim().toLowerCase();
+  const telefonoNorm = aFormatoWhatsapp(telefono);
+
+  // El email es con lo que se entra al sistema y el teléfono es con lo que el bot
+  // reconoce al cliente: los dos tienen que seguir siendo únicos.
+  const emailTomado = await prisma.cliente.findFirst({
+    where: { email: emailNuevo, id: { not: sesion.sub } },
+    select: { id: true },
+  });
+  if (emailTomado)
+    return NextResponse.json({ error: "Ese email ya está registrado" }, { status: 409 });
+
+  const telefonoTomado = await prisma.cliente.findFirst({
+    where: { telefonoNorm, id: { not: sesion.sub } },
+    select: { id: true },
+  });
+  if (telefonoTomado)
+    return NextResponse.json({ error: "Ese teléfono ya está registrado" }, { status: 409 });
+
+  // Entre la comprobación de arriba y este update otra request puede tomar el mismo
+  // email o teléfono; los índices únicos lo cortan y acá se traduce a un 409 legible.
+  let cliente;
+  try {
+    cliente = await prisma.cliente.update({
+      where: { id: sesion.sub },
+      data: {
+        nombre: nombre.trim(),
+        apellido: apellido.trim(),
+        email: emailNuevo,
+        telefono: aLocalArgentino(telefonoNorm),
+        telefonoNorm,
+      },
+      select: { nombre: true, apellido: true, email: true, telefonoNorm: true },
+    });
+  } catch (e) {
+    if (e instanceof Prisma.PrismaClientKnownRequestError && e.code === "P2002")
+      return NextResponse.json(
+        { error: "Ese email o teléfono ya está registrado" },
+        { status: 409 }
+      );
+    throw e;
+  }
+
+  return NextResponse.json({
+    ok: true,
+    nombre: cliente.nombre,
+    apellido: cliente.apellido,
+    email: cliente.email ?? "",
+    telefono: aLocalArgentino(cliente.telefonoNorm ?? ""),
+  });
+}

src/app/api/cliente/registro/route.ts

@@ -1,5 +1,6 @@
 import { NextRequest, NextResponse } from "next/server";
 import { prisma } from "@/lib/prisma";
+import { aFormatoWhatsapp, esLocalArgentinoValido, normalizarTelefono } from "@/lib/telefono";
 import nodemailer from "nodemailer";
 
 const transporter = nodemailer.createTransport({
@@ -18,11 +19,29 @@ export async function POST(req: NextRequest) {
   if (!email || !nombre || !apellido || !telefono)
     return NextResponse.json({ error: "Todos los campos son requeridos" }, { status: 400 });
 
+  if (!esLocalArgentinoValido(telefono))
+    return NextResponse.json(
+      { error: "El teléfono debe tener 10 dígitos, sin el 0 de la característica ni el 15" },
+      { status: 400 }
+    );
+
   const existe = await prisma.cliente.findUnique({ where: { email: email.toLowerCase() } });
   if (existe) return NextResponse.json({ error: "El email ya está registrado" }, { status: 409 });
 
+  // `telefonoNorm` queda igual al `wa_id` que manda Meta, que es como lo busca el bot.
+  const telefonoNorm = aFormatoWhatsapp(telefono);
+  const yaUsado = await prisma.cliente.findFirst({ where: { telefonoNorm } });
+  if (yaUsado)
+    return NextResponse.json({ error: "Ese teléfono ya está registrado" }, { status: 409 });
+
   const cliente = await prisma.cliente.create({
-    data: { email: email.toLowerCase().trim(), nombre, apellido, telefono },
+    data: {
+      email: email.toLowerCase().trim(),
+      nombre,
+      apellido,
+      telefono: normalizarTelefono(telefono),
+      telefonoNorm,
+    },
   });
 
   await transporter.sendMail({

src/app/api/cliente/servicios/route.ts

@@ -1,13 +1,28 @@
-import { NextResponse } from "next/server";
+import { NextRequest, NextResponse } from "next/server";
 import { prisma } from "@/lib/prisma";
 import { verificarSesion } from "@/lib/auth-admin";
+import { whereTrabajosDeJefe } from "@/lib/servicios";
 
-export async function GET() {
+// Trabajos que ofrece un jefe mecánico: los suyos + los globales del taller.
-  const sesion = await verificarSesion("cliente_session");
+// El flujo del cliente es jefe → trabajo, así que el jefe es obligatorio.
+export async function GET(req: NextRequest) {
+  const sesion = await verificarSesion("cliente_session", "cliente");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
+  const jefeMecanicoId = req.nextUrl.searchParams.get("jefeMecanicoId");
+  if (!jefeMecanicoId)
+    return NextResponse.json({ error: "jefeMecanicoId requerido" }, { status: 400 });
+
+  // Un jefe dado de baja no debe exponer sus trabajos (ni dejar arrancar una reserva).
+  const jefe = await prisma.jefeMecanico.findUnique({
+    where: { id: jefeMecanicoId },
+    select: { activo: true },
+  });
+  if (!jefe || !jefe.activo)
+    return NextResponse.json({ error: "Jefe mecánico no disponible" }, { status: 404 });
+
   const servicios = await prisma.tipoServicio.findMany({
-    where: { activo: true },
+    where: whereTrabajosDeJefe(jefeMecanicoId),
     orderBy: { nombre: "asc" },
   });
 

src/app/api/cliente/slots/route.ts

@@ -2,9 +2,10 @@ import { NextRequest, NextResponse } from "next/server";
 import { prisma } from "@/lib/prisma";
 import { verificarSesion } from "@/lib/auth-admin";
 import { obtenerSlotsDisponibles } from "@/lib/scheduling";
+import { trabajoEsDeJefe } from "@/lib/servicios";
 
 export async function GET(req: NextRequest) {
-  const sesion = await verificarSesion("cliente_session");
+  const sesion = await verificarSesion("cliente_session", "cliente");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const { searchParams } = new URL(req.url);
@@ -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))
+    return NextResponse.json({ error: "Ese trabajo no lo hace este mecánico" }, { status: 400 });
 
   const slots = await obtenerSlotsDisponibles(jefeMecanicoId, servicio.duracionHoras, 60, 500);
   return NextResponse.json(slots);

src/app/api/cliente/turnos/route.ts

@@ -4,7 +4,7 @@ import { verificarSesion } from "@/lib/auth-admin";
 import { crearTurno } from "@/lib/turnos";
 
 export async function GET() {
-  const sesion = await verificarSesion("cliente_session");
+  const sesion = await verificarSesion("cliente_session", "cliente");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const turnos = await prisma.turno.findMany({
@@ -17,7 +17,7 @@ export async function GET() {
 }
 
 export async function POST(req: NextRequest) {
-  const sesion = await verificarSesion("cliente_session");
+  const sesion = await verificarSesion("cliente_session", "cliente");
   if (!sesion) return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const { autoId, tipoServicioId, jefeMecanicoId, fechaInicio, kilometros } = await req.json();

src/app/api/jefe/servicios/[id]/route.ts

@@ -4,8 +4,8 @@ import { verificarSesion } from "@/lib/auth-admin";
 
 // Edita un trabajo propio del jefe (nombre, duración, activo). Solo si le pertenece.
 export async function PATCH(req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
-  const sesion = await verificarSesion("jefe_session");
+  const sesion = await verificarSesion("jefe_session", "jefe");
-  if (!sesion || sesion.role !== "jefe")
+  if (!sesion)
     return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const { id } = await params;
@@ -20,7 +20,7 @@ export async function PATCH(req: NextRequest, { params }: { params: Promise<{ id
     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" },
+        { error: "La duración debe ser mayor que 0 y hasta 24 horas" },
         { status: 400 }
       );
   }
@@ -42,8 +42,8 @@ export async function PATCH(req: NextRequest, { params }: { params: Promise<{ id
 // Elimina un trabajo propio. Si ya tiene turnos asociados, lo desactiva en vez de borrarlo
 // (para no romper la integridad referencial de los turnos históricos).
 export async function DELETE(_req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
-  const sesion = await verificarSesion("jefe_session");
+  const sesion = await verificarSesion("jefe_session", "jefe");
-  if (!sesion || sesion.role !== "jefe")
+  if (!sesion)
     return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const { id } = await params;

src/app/api/jefe/servicios/route.ts

@@ -4,8 +4,8 @@ import { verificarSesion } from "@/lib/auth-admin";
 
 // Lista los trabajos cargados por el jefe logueado (los suyos, no los globales).
 export async function GET() {
-  const sesion = await verificarSesion("jefe_session");
+  const sesion = await verificarSesion("jefe_session", "jefe");
-  if (!sesion || sesion.role !== "jefe")
+  if (!sesion)
     return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const servicios = await prisma.tipoServicio.findMany({
@@ -18,8 +18,8 @@ export async function GET() {
 
 // Crea un trabajo propio del jefe (nombre + duración en horas).
 export async function POST(req: NextRequest) {
-  const sesion = await verificarSesion("jefe_session");
+  const sesion = await verificarSesion("jefe_session", "jefe");
-  if (!sesion || sesion.role !== "jefe")
+  if (!sesion)
     return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const { nombre, duracionHoras } = await req.json();
@@ -28,7 +28,7 @@ export async function POST(req: NextRequest) {
     return NextResponse.json({ error: "El nombre del trabajo es obligatorio" }, { status: 400 });
   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" },
+      { error: "La duración debe ser mayor que 0 y hasta 24 horas" },
       { status: 400 }
     );
 

src/app/api/jefe/turnos/route.ts

@@ -3,8 +3,8 @@ import { prisma } from "@/lib/prisma";
 import { verificarSesion } from "@/lib/auth-admin";
 
 export async function GET(req: NextRequest) {
-  const sesion = await verificarSesion("jefe_session");
+  const sesion = await verificarSesion("jefe_session", "jefe");
-  if (!sesion || sesion.role !== "jefe")
+  if (!sesion)
     return NextResponse.json({ error: "No autorizado" }, { status: 401 });
 
   const { searchParams } = new URL(req.url);

src/app/api/whatsapp/webhook/route.ts

@@ -1,4 +1,6 @@
 import { NextRequest, NextResponse } from "next/server";
+import { Prisma } from "@prisma/client";
+import { prisma } from "@/lib/prisma";
 import { procesarMensaje } from "@/lib/whatsapp-bot";
 import {
   enviarRespuestas,
@@ -17,21 +19,34 @@ export const dynamic = "force-dynamic";
  * POST → mensajes entrantes: se los pasa a la máquina de conversación y se contesta.
  */
 
-// Meta reintenta el mismo mensaje si tardamos o si algo falla. Guardamos los ids ya
+// Meta reintenta el mismo mensaje si tardamos o si algo falla, y sin deduplicar eso
-// procesados en memoria (un solo container) para no duplicar turnos ni respuestas.
+// crea el turno dos veces. Se resuelve insertando el id en la base: el índice único
-const procesados = new Set<string>();
+// hace la operación atómica, así que sirve incluso con varias instancias corriendo.
-const MAX_PROCESADOS = 500;
+const DIAS_RETENCION = 7;
+let ultimaLimpieza = 0;
 
-function yaProcesado(id: string): boolean {
+async function yaProcesado(id: string): Promise<boolean> {
-  if (procesados.has(id)) return true;
+  try {
-  procesados.add(id);
+    await prisma.mensajeWhatsappProcesado.create({ data: { id } });
-  // Set mantiene orden de inserción: soltamos los más viejos.
+    return false;
-  while (procesados.size > MAX_PROCESADOS) {
+  } catch (e) {
-    const viejo: string | undefined = procesados.values().next().value;
+    if (e instanceof Prisma.PrismaClientKnownRequestError && e.code === "P2002") return true;
-    if (viejo === undefined) break;
+    throw e;
-    procesados.delete(viejo);
+  }
+}
+
+/** Borra los ids viejos como mucho una vez por día. Best-effort: si falla, no importa. */
+async function limpiarProcesadosViejos(): Promise<void> {
+  const unDia = 24 * 60 * 60 * 1000;
+  if (Date.now() - ultimaLimpieza < unDia) return;
+  ultimaLimpieza = Date.now();
+  try {
+    await prisma.mensajeWhatsappProcesado.deleteMany({
+      where: { createdAt: { lt: new Date(Date.now() - DIAS_RETENCION * unDia) } },
+    });
+  } catch (e) {
+    console.error("[whatsapp] no se pudieron limpiar los mensajes procesados:", e);
   }
-  return false;
 }
 
 export async function GET(req: NextRequest) {
@@ -64,10 +79,12 @@ export async function POST(req: NextRequest) {
   }
 
   try {
+    await limpiarProcesadosViejos();
+
     for (const mensaje of mensajesDelPayload(body)) {
       const telefono = mensaje.from;
       const messageId = mensaje.id;
-      if (!telefono || !messageId || yaProcesado(messageId)) continue;
+      if (!telefono || !messageId || (await yaProcesado(messageId))) continue;
 
       void marcarLeido(messageId).catch(() => {});
 

src/app/cliente/dashboard/page.tsx

@@ -68,9 +68,14 @@ export default function DashboardPage() {
     <div className="flex flex-col gap-6">
       <div className="flex items-center justify-between">
         <h1 className="text-2xl font-bold text-white">Mis autos</h1>
-        <button onClick={cerrarSesion} className="text-sm text-gray-200 hover:text-red-300 transition">
+        <div className="flex items-center gap-4">
-          Salir
+          <Link href="/cliente/perfil" className="text-sm text-gray-200 hover:text-white transition">
-        </button>
+            Mis datos
+          </Link>
+          <button onClick={cerrarSesion} className="text-sm text-gray-200 hover:text-red-300 transition">
+            Salir
+          </button>
+        </div>
       </div>
 
       {loading ? (

src/app/cliente/perfil/page.tsx

@@ -0,0 +1,166 @@
+"use client";
+import { useEffect, useState } from "react";
+import { useRouter } from "next/navigation";
+import Link from "next/link";
+import Button from "@/components/ui/Button";
+import Card from "@/components/ui/Card";
+import Input from "@/components/ui/Input";
+import { esLocalArgentinoValido } from "@/lib/telefono";
+
+interface Perfil {
+  nombre: string;
+  apellido: string;
+  email: string;
+  telefono: string;
+}
+
+const VACIO: Perfil = { nombre: "", apellido: "", email: "", telefono: "" };
+
+export default function PerfilPage() {
+  const router = useRouter();
+  const [perfil, setPerfil] = useState<Perfil>(VACIO);
+  const [form, setForm] = useState<Perfil>(VACIO);
+  const [loading, setLoading] = useState(true);
+  const [editando, setEditando] = useState(false);
+  const [guardando, setGuardando] = useState(false);
+  const [error, setError] = useState("");
+  const [telefonoError, setTelefonoError] = useState("");
+  const [guardado, setGuardado] = useState(false);
+
+  useEffect(() => {
+    fetch("/api/cliente/perfil")
+      .then((r) => {
+        if (r.status === 401) { router.push("/cliente"); return null; }
+        if (!r.ok) throw new Error("respuesta con error");
+        return r.json();
+      })
+      .then((data) => {
+        if (!data) return;
+        setPerfil(data);
+        setForm(data);
+        setLoading(false);
+      })
+      // Sin esto, si el pedido falla la pantalla se queda en "Cargando..." para siempre.
+      .catch(() => {
+        setError("No pudimos cargar tus datos. Probá recargar la página.");
+        setLoading(false);
+      });
+  }, [router]);
+
+  function set(campo: keyof Perfil) {
+    return (e: React.ChangeEvent<HTMLInputElement>) =>
+      setForm((f) => ({ ...f, [campo]: e.target.value }));
+  }
+
+  function handleTelefono(e: React.ChangeEvent<HTMLInputElement>) {
+    const soloDigitos = e.target.value.replace(/\D/g, "").slice(0, 10);
+    setForm((f) => ({ ...f, telefono: soloDigitos }));
+    if (soloDigitos.startsWith("0")) setTelefonoError("Sin el 0 de la característica");
+    else if (soloDigitos.startsWith("15")) setTelefonoError("Sin el 15, poné la característica");
+    else setTelefonoError("");
+  }
+
+  function cancelar() {
+    setForm(perfil);
+    setEditando(false);
+    setError("");
+    setTelefonoError("");
+  }
+
+  async function guardar(e: React.FormEvent) {
+    e.preventDefault();
+    if (!esLocalArgentinoValido(form.telefono)) {
+      setTelefonoError("Son 10 dígitos: característica sin el 0 y número sin el 15");
+      return;
+    }
+    setGuardando(true);
+    setError("");
+    const res = await fetch("/api/cliente/perfil", {
+      method: "PATCH",
+      headers: { "Content-Type": "application/json" },
+      body: JSON.stringify(form),
+    });
+    // Si la sesión venció mientras editaba, mandarlo a entrar de nuevo en vez de
+    // mostrarle un error suelto que no explica nada.
+    if (res.status === 401) { router.push("/cliente"); return; }
+    const data = await res.json();
+    setGuardando(false);
+    if (!res.ok) { setError(data.error || "No se pudieron guardar los cambios"); return; }
+    setPerfil(data);
+    setForm(data);
+    setEditando(false);
+    setGuardado(true);
+    setTimeout(() => setGuardado(false), 4000);
+  }
+
+  if (loading) return <div className="text-center py-10 text-gray-200">Cargando...</div>;
+
+  const emailCambio = editando && form.email.trim().toLowerCase() !== perfil.email.toLowerCase();
+
+  return (
+    <div className="flex flex-col gap-6">
+      <div className="flex items-center gap-3">
+        <Link href="/cliente/dashboard"><Button variant="ghost" className="px-2">←</Button></Link>
+        <h1 className="text-xl sm:text-2xl font-bold text-white">Mis datos</h1>
+      </div>
+
+      <Card>
+        {!editando ? (
+          <div className="flex flex-col gap-4">
+            <Dato etiqueta="Nombre" valor={`${perfil.nombre} ${perfil.apellido}`} />
+            <Dato etiqueta="Email" valor={perfil.email || "—"} />
+            <Dato etiqueta="Teléfono" valor={perfil.telefono ? `+54 9 ${perfil.telefono}` : "—"} />
+            {guardado && <p className="text-sm text-green-600">✅ Datos actualizados</p>}
+            <Button onClick={() => setEditando(true)} className="self-start">
+              Modificar datos
+            </Button>
+          </div>
+        ) : (
+          <form onSubmit={guardar} className="flex flex-col gap-4">
+            <div className="grid sm:grid-cols-2 gap-4">
+              <Input id="nombre" label="Nombre" value={form.nombre} onChange={set("nombre")} required />
+              <Input id="apellido" label="Apellido" value={form.apellido} onChange={set("apellido")} required />
+            </div>
+            <Input
+              id="email"
+              type="email"
+              label="Email"
+              value={form.email}
+              onChange={set("email")}
+              ayuda={emailCambio ? "Ojo: con este email vas a entrar de ahora en más." : undefined}
+              required
+            />
+            <Input
+              id="telefono"
+              type="tel"
+              inputMode="numeric"
+              label="Teléfono (celular)"
+              prefijo="+54 9"
+              placeholder="1141984844"
+              maxLength={10}
+              ayuda="Es el celular con el que sacás turnos por WhatsApp."
+              error={telefonoError}
+              value={form.telefono}
+              onChange={handleTelefono}
+              required
+            />
+            {error && <p className="text-sm text-red-500">{error}</p>}
+            <div className="flex gap-2 justify-end">
+              <Button variant="secondary" type="button" onClick={cancelar}>Cancelar</Button>
+              <Button type="submit" loading={guardando}>Guardar cambios</Button>
+            </div>
+          </form>
+        )}
+      </Card>
+    </div>
+  );
+}
+
+function Dato({ etiqueta, valor }: { etiqueta: string; valor: string }) {
+  return (
+    <div>
+      <p className="text-sm text-gray-500">{etiqueta}</p>
+      <p className="font-medium text-gray-800">{valor}</p>
+    </div>
+  );
+}

src/app/cliente/registro/page.tsx

@@ -5,19 +5,42 @@ import Link from "next/link";
 import Button from "@/components/ui/Button";
 import Input from "@/components/ui/Input";
 import Card from "@/components/ui/Card";
+import { esLocalArgentinoValido } from "@/lib/telefono";
 
 export default function RegistroPage() {
   const router = useRouter();
   const [form, setForm] = useState({ email: "", nombre: "", apellido: "", telefono: "" });
   const [loading, setLoading] = useState(false);
   const [error, setError] = useState("");
+  const [telefonoError, setTelefonoError] = useState("");
 
   function set(field: string) {
     return (e: React.ChangeEvent<HTMLInputElement>) => setForm((f) => ({ ...f, [field]: e.target.value }));
   }
 
+  // El teléfono se guarda como lo espera WhatsApp: solo característica + abonado,
+  // sin el 0 ni el 15 (el +54 9 lo pone el prefijo fijo del campo).
+  function handleTelefono(e: React.ChangeEvent<HTMLInputElement>) {
+    const soloDigitos = e.target.value.replace(/\D/g, "").slice(0, 10);
+    setForm((f) => ({ ...f, telefono: soloDigitos }));
+    // Mientras tipea sólo se avisa lo que ya es un error seguro; lo de "faltan
+    // dígitos" espera a que salga del campo, para no retarlo por la mitad.
+    if (soloDigitos.startsWith("0")) setTelefonoError("Sin el 0 de la característica");
+    else if (soloDigitos.startsWith("15")) setTelefonoError("Sin el 15, poné la característica");
+    else setTelefonoError("");
+  }
+
+  function handleTelefonoBlur() {
+    if (form.telefono && !esLocalArgentinoValido(form.telefono))
+      setTelefonoError("Son 10 dígitos: característica sin el 0 y número sin el 15");
+  }
+
   async function handleSubmit(e: React.FormEvent) {
     e.preventDefault();
+    if (!esLocalArgentinoValido(form.telefono)) {
+      setTelefonoError("Revisá el número: son 10 dígitos, sin el 0 y sin el 15");
+      return;
+    }
     setLoading(true);
     setError("");
     const res = await fetch("/api/cliente/registro", {
@@ -47,7 +70,21 @@ export default function RegistroPage() {
           <Input id="nombre" label="Nombre" placeholder="Juan" value={form.nombre} onChange={set("nombre")} required />
           <Input id="apellido" label="Apellido" placeholder="Pérez" value={form.apellido} onChange={set("apellido")} required />
           <Input id="email" type="email" label="Email" placeholder="juan@email.com" value={form.email} onChange={set("email")} required />
-          <Input id="telefono" type="tel" label="Teléfono" placeholder="11 1234-5678" value={form.telefono} onChange={set("telefono")} required />
+          <Input
+            id="telefono"
+            type="tel"
+            inputMode="numeric"
+            label="Teléfono (celular)"
+            prefijo="+54 9"
+            placeholder="1141984844"
+            maxLength={10}
+            ayuda="Característica sin el 0 y número sin el 15. Es el celular con el que vas a poder sacar turnos por WhatsApp."
+            error={telefonoError}
+            value={form.telefono}
+            onChange={handleTelefono}
+            onBlur={handleTelefonoBlur}
+            required
+          />
           {error && <p className="text-sm text-red-500 text-center">{error}</p>}
           <Button type="submit" loading={loading} className="w-full">
             Crear cuenta

src/app/cliente/turnos/page.tsx

@@ -20,7 +20,9 @@ interface Turno {
 const MESES = ["Enero","Febrero","Marzo","Abril","Mayo","Junio","Julio","Agosto","Septiembre","Octubre","Noviembre","Diciembre"];
 const DIAS_HEADER = ["Lun","Mar","Mié","Jue","Vie","Sáb","Dom"];
 
-type Step = "servicio" | "jefe" | "calendario" | "confirmado";
+// El cliente elige primero el mecánico y después el trabajo, porque cada jefe
+// carga sus propios trabajos (además de los globales del taller).
+type Step = "jefe" | "servicio" | "calendario" | "confirmado";
 
 function formatDuracion(h: number) {
   if (h < 1) return `${Math.round(h * 60)} min`;
@@ -66,12 +68,13 @@ function TurnosContent() {
   const params = useSearchParams();
   const autoId = params.get("autoId");
 
-  const [step, setStep] = useState<Step>("servicio");
+  const [step, setStep] = useState<Step>("jefe");
   const [servicios, setServicios] = useState<TipoServicio[]>([]);
   const [servicioSel, setServicioSel] = useState<TipoServicio | null>(null);
+  const [loadingServicios, setLoadingServicios] = useState(false);
   const [jefes, setJefes] = useState<Jefe[]>([]);
   const [jefeSel, setJefeSel] = useState<Jefe | null>(null);
-  const [loadingJefes, setLoadingJefes] = useState(false);
+  const [loadingJefes, setLoadingJefes] = useState(true);
   const [slots, setSlots] = useState<Slot[]>([]);
   const [loadingSlots, setLoadingSlots] = useState(false);
   const [misTurnos, setMisTurnos] = useState<Turno[]>([]);
@@ -90,7 +93,12 @@ function TurnosContent() {
 
   useEffect(() => {
     if (!autoId) { router.push("/cliente/dashboard"); return; }
-    fetch("/api/cliente/servicios").then(r => r.json()).then(setServicios);
+    fetch("/api/cliente/jefes")
+      .then(r => r.json())
+      .then((data) => {
+        setJefes(Array.isArray(data) ? data : []);
+        setLoadingJefes(false);
+      });
     fetch("/api/cliente/turnos")
       .then(r => r.json())
       .then((data) => {
@@ -110,29 +118,30 @@ function TurnosContent() {
     return m;
   }, [slots]);
 
-  async function seleccionarServicio(s: TipoServicio) {
+  async function seleccionarJefe(j: Jefe) {
-    setServicioSel(s);
+    setJefeSel(j);
-    setJefeSel(null);
+    setServicioSel(null);
+    setServicios([]);
     setSlots([]);
     setDiaSeleccionado(null);
     setSlotSel(null);
-    setLoadingJefes(true);
+    setLoadingServicios(true);
-    setStep("jefe");
+    setStep("servicio");
-    const res = await fetch("/api/cliente/jefes");
+    const res = await fetch(`/api/cliente/servicios?jefeMecanicoId=${j.id}`);
     const data = await res.json();
-    setJefes(Array.isArray(data) ? data : []);
+    setServicios(Array.isArray(data) ? data : []);
-    setLoadingJefes(false);
+    setLoadingServicios(false);
   }
 
-  async function seleccionarJefe(j: Jefe) {
+  async function seleccionarServicio(s: TipoServicio) {
-    if (!servicioSel) return;
+    if (!jefeSel) return;
-    setJefeSel(j);
+    setServicioSel(s);
     setLoadingSlots(true);
     setSlots([]);
     setDiaSeleccionado(null);
     setSlotSel(null);
     setStep("calendario");
-    const res = await fetch(`/api/cliente/slots?tipoServicioId=${servicioSel.id}&jefeMecanicoId=${j.id}`);
+    const res = await fetch(`/api/cliente/slots?tipoServicioId=${s.id}&jefeMecanicoId=${jefeSel.id}`);
     const data = await res.json();
     setSlots(Array.isArray(data) ? data : []);
     setLoadingSlots(false);
@@ -213,14 +222,14 @@ function TurnosContent() {
         <div className="text-5xl">✅</div>
         <h1 className="text-2xl font-bold text-white">¡Turno reservado!</h1>
         <Card className="text-left w-full max-w-sm">
-          <p className="text-sm text-gray-500 mb-1">Servicio</p>
-          <p className="font-semibold mb-3">{turnoCreado.tipoServicio.nombre}</p>
           {turnoCreado.jefeMecanico && (
             <>
               <p className="text-sm text-gray-500 mb-1">Jefe mecánico</p>
               <p className="font-semibold mb-3">{turnoCreado.jefeMecanico.nombre}</p>
             </>
           )}
+          <p className="text-sm text-gray-500 mb-1">Servicio</p>
+          <p className="font-semibold mb-3">{turnoCreado.tipoServicio.nombre}</p>
           <p className="text-sm text-gray-500 mb-1">Fecha</p>
           <p className="font-semibold">{new Date(turnoCreado.fechaInicio).toLocaleDateString("es-AR", {
             timeZone: "America/Argentina/Buenos_Aires", weekday: "long", day: "numeric", month: "long"
@@ -236,33 +245,46 @@ function TurnosContent() {
     <div className="flex flex-col gap-6">
       <div className="flex items-center gap-3">
         {step === "calendario" ? (
-          <Button variant="ghost" className="px-2" onClick={() => setStep("jefe")}>←</Button>
-        ) : step === "jefe" ? (
           <Button variant="ghost" className="px-2" onClick={() => setStep("servicio")}>←</Button>
+        ) : step === "servicio" ? (
+          <Button variant="ghost" className="px-2" onClick={() => setStep("jefe")}>←</Button>
         ) : (
           <Link href="/cliente/dashboard"><Button variant="ghost" className="px-2">←</Button></Link>
         )}
         <h1 className="text-xl sm:text-2xl font-bold text-white">
-          {step === "servicio" && "Elegí el servicio"}
           {step === "jefe" && "Elegí el jefe mecánico"}
-          {step === "calendario" && `${servicioSel?.nombre}${jefeSel ? ` · ${jefeSel.nombre}` : ""}`}
+          {step === "servicio" && `Trabajos de ${jefeSel?.nombre}`}
+          {step === "calendario" && `${jefeSel?.nombre}${servicioSel ? ` · ${servicioSel.nombre}` : ""}`}
         </h1>
       </div>
 
-      {/* STEP: servicio */}
+      {/* STEP: jefe */}
-      {step === "servicio" && (
+      {step === "jefe" && (
         <>
-          <div className="grid gap-3">
+          <div className="flex flex-col gap-3">
-            {servicios.map(s => (
+            {loadingJefes ? (
-              <button key={s.id} onClick={() => seleccionarServicio(s)}
+              <p className="text-center text-sm text-gray-200">Cargando jefes...</p>
-                className="text-left bg-white border border-gray-200 rounded-xl p-4 hover:border-blue-500 hover:shadow-sm transition flex items-center justify-between">
+            ) : jefes.length === 0 ? (
-                <div>
+              <Card>
-                  <p className="font-medium text-gray-800">{s.nombre}</p>
+                <p className="text-sm text-gray-600 text-center">
-                  <p className="text-sm text-gray-500 mt-0.5">Duración: {formatDuracion(s.duracionHoras)}</p>
+                  No hay jefes mecánicos disponibles en este momento. Intentá más tarde.
-                </div>
+                </p>
-                <span className="text-gray-400 text-lg">→</span>
+              </Card>
-              </button>
+            ) : (
-            ))}
+              jefes.map((j) => (
+                <button
+                  key={j.id}
+                  onClick={() => seleccionarJefe(j)}
+                  className="text-left bg-white border border-gray-200 rounded-xl p-4 hover:border-blue-500 hover:shadow-sm transition flex items-center justify-between"
+                >
+                  <div>
+                    <p className="font-medium text-gray-800">{j.nombre}</p>
+                    <p className="text-sm text-gray-500 mt-0.5">Ver sus trabajos</p>
+                  </div>
+                  <span className="text-gray-400 text-lg">→</span>
+                </button>
+              ))
+            )}
           </div>
 
           {!loadingTurnos && misTurnos.length > 0 && (
@@ -288,27 +310,24 @@ function TurnosContent() {
         </>
       )}
 
-      {/* STEP: jefe */}
+      {/* STEP: servicio */}
-      {step === "jefe" && (
+      {step === "servicio" && (
-        <div className="flex flex-col gap-3">
+        <div className="grid gap-3">
-          {loadingJefes ? (
+          {loadingServicios ? (
-            <p className="text-center text-sm text-gray-200">Cargando jefes...</p>
+            <p className="text-center text-sm text-gray-200">Cargando trabajos...</p>
-          ) : jefes.length === 0 ? (
+          ) : servicios.length === 0 ? (
             <Card>
               <p className="text-sm text-gray-600 text-center">
-                No hay jefes mecánicos disponibles en este momento. Intentá más tarde.
+                {jefeSel?.nombre} todavía no cargó trabajos. Elegí otro mecánico.
               </p>
             </Card>
           ) : (
-            jefes.map((j) => (
+            servicios.map(s => (
-              <button
+              <button key={s.id} onClick={() => seleccionarServicio(s)}
-                key={j.id}
+                className="text-left bg-white border border-gray-200 rounded-xl p-4 hover:border-blue-500 hover:shadow-sm transition flex items-center justify-between">
-                onClick={() => seleccionarJefe(j)}
-                className="text-left bg-white border border-gray-200 rounded-xl p-4 hover:border-blue-500 hover:shadow-sm transition flex items-center justify-between"
-              >
                 <div>
-                  <p className="font-medium text-gray-800">{j.nombre}</p>
+                  <p className="font-medium text-gray-800">{s.nombre}</p>
-                  <p className="text-sm text-gray-500 mt-0.5">Ver disponibilidad</p>
+                  <p className="text-sm text-gray-500 mt-0.5">Duración: {formatDuracion(s.duracionHoras)}</p>
                 </div>
                 <span className="text-gray-400 text-lg">→</span>
               </button>

src/components/ui/Input.tsx

@@ -3,9 +3,16 @@ import { InputHTMLAttributes } from "react";
 interface InputProps extends InputHTMLAttributes<HTMLInputElement> {
   label?: string;
   error?: string;
+  /** Texto fijo grisado antes del campo (ej: el prefijo de país del teléfono). */
+  prefijo?: string;
+  ayuda?: string;
 }
 
-export default function Input({ label, error, className = "", id, ...props }: InputProps) {
+export default function Input({ label, error, prefijo, ayuda, className = "", id, ...props }: InputProps) {
+  const estiloInput = `border rounded-lg px-3 py-2 text-sm outline-none focus:ring-2 focus:ring-blue-500 focus:border-transparent transition bg-gray-100 text-gray-900 placeholder-gray-500 ${
+    error ? "border-red-400" : "border-gray-400"
+  } ${className}`;
+
   return (
     <div className="flex flex-col gap-1">
       {label && (
@@ -13,13 +20,23 @@ export default function Input({ label, error, className = "", id, ...props }: In
           {label}
         </label>
       )}
-      <input
+      {prefijo ? (
-        id={id}
+        <div
-        className={`border rounded-lg px-3 py-2 text-sm outline-none focus:ring-2 focus:ring-blue-500 focus:border-transparent transition bg-gray-100 text-gray-900 placeholder-gray-500 ${
+          className={`flex items-center rounded-lg border bg-gray-100 focus-within:ring-2 focus-within:ring-blue-500 transition ${
-          error ? "border-red-400" : "border-gray-400"
+            error ? "border-red-400" : "border-gray-400"
-        } ${className}`}
+          }`}
-        {...props}
+        >
-      />
+          <span className="pl-3 pr-1 text-sm text-gray-500 select-none">{prefijo}</span>
+          <input
+            id={id}
+            className={`flex-1 bg-transparent px-1 py-2 text-sm outline-none text-gray-900 placeholder-gray-500 ${className}`}
+            {...props}
+          />
+        </div>
+      ) : (
+        <input id={id} className={estiloInput} {...props} />
+      )}
+      {ayuda && !error && <p className="text-xs text-gray-500">{ayuda}</p>}
       {error && <p className="text-xs text-red-500">{error}</p>}
     </div>
   );

src/lib/auth-admin.ts

@@ -28,14 +28,20 @@ export async function crearSesionJefe(jefeId: string): Promise<string> {
 }
 
 export async function verificarSesion(
-  cookieName: string
+  cookieName: string,
+  rolEsperado?: "admin" | "cliente" | "jefe"
 ): Promise<{ sub: string; role: string } | null> {
   const cookieStore = await cookies();
   const token = cookieStore.get(cookieName)?.value;
   if (!token) return null;
   try {
     const { payload } = await jwtVerify(token, SECRET);
-    return payload as { sub: string; role: string };
+    const sesion = payload as { sub: string; role: string };
+    // Los tres tipos de sesión se firman con el mismo secreto, así que un token de
+    // admin o de jefe puesto en la cookie del cliente pasa la verificación de firma.
+    // Cuando el rol importa, se comprueba acá.
+    if (rolEsperado && sesion.role !== rolEsperado) return null;
+    return sesion;
   } catch {
     return null;
   }

src/lib/scheduling.ts

@@ -1,5 +1,13 @@
+import type { Prisma } from "@prisma/client";
 import { prisma } from "./prisma";
 
+/**
+ * Cliente de Prisma o el cliente de una transacción en curso. Permite que la
+ * 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;
+
 const INICIO_H = 8;
 const INICIO_M = 30;
 const FIN_H = 17;
@@ -53,9 +61,10 @@ function horasDentroDeJornada(inicio: Date, fin: Date): boolean {
 async function turnosSolapados(
   inicio: Date,
   fin: Date,
-  jefeMecanicoId: string
+  jefeMecanicoId: string,
+  db: ClienteDb = prisma
 ): Promise<number> {
-  const count = await prisma.turno.count({
+  const count = await db.turno.count({
     where: {
       jefeMecanicoId,
       estado: { in: ["PENDIENTE", "CONFIRMADO"] },
@@ -65,8 +74,8 @@ async function turnosSolapados(
   return count;
 }
 
-async function obtenerJefeActivo(jefeMecanicoId: string) {
+async function obtenerJefeActivo(jefeMecanicoId: string, db: ClienteDb = prisma) {
-  return prisma.jefeMecanico.findUnique({
+  return db.jefeMecanico.findUnique({
     where: { id: jefeMecanicoId },
     select: { slotsParalelos: true, activo: true },
   });
@@ -133,11 +142,12 @@ export async function obtenerSlotsDisponibles(
 export async function slotEstaDisponible(
   inicio: Date,
   fin: Date,
-  jefeMecanicoId: string
+  jefeMecanicoId: string,
+  db: ClienteDb = prisma
 ): Promise<boolean> {
   if (!esDiaHabil(inicio) || !horasDentroDeJornada(inicio, fin)) return false;
-  const jefe = await obtenerJefeActivo(jefeMecanicoId);
+  const jefe = await obtenerJefeActivo(jefeMecanicoId, db);
   if (!jefe || !jefe.activo) return false;
-  const ocupados = await turnosSolapados(inicio, fin, jefeMecanicoId);
+  const ocupados = await turnosSolapados(inicio, fin, jefeMecanicoId, db);
   return ocupados < jefe.slotsParalelos;
 }

src/lib/servicios.ts

@@ -0,0 +1,24 @@
+import type { Prisma, TipoServicio } from "@prisma/client";
+
+/**
+ * Regla única de qué trabajos ofrece un jefe mecánico.
+ *
+ * Los jefes cargan sus propios trabajos desde `/jefe/servicios` (`jefeMecanicoId` = su id),
+ * y el admin puede cargar trabajos globales del taller (`jefeMecanicoId` = null) que ofrece
+ * 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 {
+  return {
+    activo: true,
+    OR: [{ jefeMecanicoId }, { jefeMecanicoId: null }],
+  };
+}
+
+/** Un trabajo propio de otro jefe no se puede reservar con este. Los globales sí. */
+export function trabajoEsDeJefe(
+  servicio: Pick<TipoServicio, "jefeMecanicoId">,
+  jefeMecanicoId: string
+): boolean {
+  return servicio.jefeMecanicoId === null || servicio.jefeMecanicoId === jefeMecanicoId;
+}

src/lib/telefono.ts

@@ -6,3 +6,36 @@
 export function normalizarTelefono(valor: string): string {
   return (valor ?? "").replace(/\D/g, "");
 }
+
+/**
+ * Prefijo con el que WhatsApp identifica a los celulares argentinos: 54 (país) + 9 (móvil).
+ * En el registro web se muestra fijo y el cliente completa el resto, así el número queda
+ * guardado igual que el `wa_id` que después manda Meta y el bot lo reconoce.
+ */
+export const PREFIJO_WHATSAPP_AR = "549";
+
+/**
+ * Parte local del número: característica sin el 0 y abonado sin el 15.
+ * En Argentina son siempre 10 dígitos (ej: 11 4198-4844, 351 555-4444).
+ */
+export function esLocalArgentinoValido(local: string): boolean {
+  const d = normalizarTelefono(local);
+  // Ninguna característica argentina empieza con 0 (es el prefijo de larga distancia)
+  // ni con 15 (el viejo prefijo de celular), así que esos casos son error de tipeo.
+  return d.length === 10 && !d.startsWith("0") && !d.startsWith("15");
+}
+
+/** Número local a formato WhatsApp: 1141984844 → 5491141984844. */
+export function aFormatoWhatsapp(local: string): string {
+  return PREFIJO_WHATSAPP_AR + normalizarTelefono(local);
+}
+
+/**
+ * Inverso del anterior: 5491141984844 → 1141984844. Sirve para mostrar el número
+ * en el formulario (donde el +54 9 es un prefijo fijo), venga de un alta web o de
+ * una por WhatsApp, que lo guarda con el prefijo puesto.
+ */
+export function aLocalArgentino(valor: string): string {
+  const d = normalizarTelefono(valor);
+  return d.startsWith(PREFIJO_WHATSAPP_AR) ? d.slice(PREFIJO_WHATSAPP_AR.length) : d;
+}

src/lib/turnos.ts

@@ -1,5 +1,6 @@
 import { prisma } from "./prisma";
 import { slotEstaDisponible } from "./scheduling";
+import { trabajoEsDeJefe } from "./servicios";
 
 export interface CrearTurnoInput {
   clienteId: string;
@@ -30,27 +31,40 @@ export async function crearTurno(input: CrearTurnoInput): Promise<CrearTurnoResu
   if (!jefe || !jefe.activo)
     return { ok: false, error: "Jefe mecánico no disponible", status: 404 };
 
+  // Un trabajo propio de otro jefe no se reserva con éste (los globales sí).
+  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);
 
-  const disponible = await slotEstaDisponible(fechaInicio, fin, jefeMecanicoId);
+  // Verificar y crear en una sola transacción, serializando por jefe con un lock
-  if (!disponible) return { ok: false, error: "El horario ya no está disponible", status: 409 };
+  // 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}))`;
 
-  const turno = await prisma.turno.create({
+    const disponible = await slotEstaDisponible(fechaInicio, fin, jefeMecanicoId, tx);
-    data: {
+    if (!disponible) return null;
-      clienteId,
+
-      jefeMecanicoId,
+    return tx.turno.create({
-      tipoServicioId,
+      data: {
-      fechaInicio,
+        clienteId,
-      fechaFin: fin,
+        jefeMecanicoId,
-      autoId: input.autoId ?? null,
+        tipoServicioId,
-      kilometros: input.kilometros ?? null,
+        fechaInicio,
-    },
+        fechaFin: fin,
-    include: {
+        autoId: input.autoId ?? null,
-      auto: true,
+        kilometros: input.kilometros ?? null,
-      tipoServicio: true,
+      },
-      jefeMecanico: { select: { id: true, nombre: true } },
+      include: {
-    },
+        auto: true,
+        tipoServicio: true,
+        jefeMecanico: { select: { id: true, nombre: true } },
+      },
+    });
   });
 
+  if (!turno) return { ok: false, error: "El horario ya no está disponible", status: 409 };
+
   return { ok: true, turno };
 }

src/lib/whatsapp-bot.ts

@@ -3,6 +3,7 @@ import { prisma } from "./prisma";
 import { obtenerSlotsDisponibles } from "./scheduling";
 import { crearTurno } from "./turnos";
 import { normalizarTelefono } from "./telefono";
+import { trabajoEsDeJefe, whereTrabajosDeJefe } from "./servicios";
 
 // ── Tipos de respuesta que el bot le pide al canal (F0 los traduce a la API de Meta) ──
 export type BotonBot = { id: string; titulo: string };
@@ -96,7 +97,7 @@ async function pasoElegirMecanico(): Promise<{ resp: RespuestaBot[]; datos: Dato
 
 async function pasoElegirTrabajo(datos: DatosConv): Promise<{ resp: RespuestaBot[]; datos: DatosConv; paso: string }> {
   const servicios = await prisma.tipoServicio.findMany({
-    where: { jefeMecanicoId: datos.jefeMecanicoId, activo: true },
+    where: whereTrabajosDeJefe(datos.jefeMecanicoId!),
     orderBy: { nombre: "asc" },
   });
 
@@ -303,7 +304,7 @@ export async function procesarMensaje(telefonoRaw: string, textoRaw: string): Pr
       if (!op)
         return guardar(conv.id, "ELEGIR_TRABAJO", datos, [{ tipo: "texto", texto: "No entendí. Respondé con la letra del trabajo." }]);
       const servicio = await prisma.tipoServicio.findUnique({ where: { id: op.id } });
-      if (!servicio || !servicio.activo) {
+      if (!servicio || !servicio.activo || !trabajoEsDeJefe(servicio, datos.jefeMecanicoId!)) {
         const m = await pasoElegirTrabajo(datos);
         return guardar(conv.id, m.paso, m.datos, [{ tipo: "texto", texto: "Ese trabajo ya no está disponible." }, ...m.resp]);
       }

src/lib/whatsapp.ts

@@ -42,6 +42,16 @@ export function firmaValida(cuerpoCrudo: string, firmaHeader: string | null): bo
   return crypto.timingSafeEqual(a, b);
 }
 
+// Meta tira 429 (rate limit) y 5xx transitorios; ahí conviene reintentar en vez de
+// perder la respuesta al cliente. Un 4xx que no sea 429 es error nuestro: no se
+// reintenta porque va a fallar igual.
+const INTENTOS = 3;
+const ESPERA_BASE_MS = 500;
+
+function esperar(ms: number): Promise<void> {
+  return new Promise((r) => setTimeout(r, ms));
+}
+
 async function postMensaje(payload: Record<string, unknown>): Promise<void> {
   const cred = credenciales();
   if (!cred) {
@@ -49,18 +59,40 @@ async function postMensaje(payload: Record<string, unknown>): Promise<void> {
     return;
   }
 
-  const res = await fetch(`https://graph.facebook.com/${GRAPH_VERSION}/${cred.phoneNumberId}/messages`, {
+  const url = `https://graph.facebook.com/${GRAPH_VERSION}/${cred.phoneNumberId}/messages`;
+  const init: RequestInit = {
     method: "POST",
     headers: {
       Authorization: `Bearer ${cred.token}`,
       "Content-Type": "application/json",
     },
     body: JSON.stringify({ messaging_product: "whatsapp", ...payload }),
-  });
+  };
 
-  if (!res.ok) {
+  for (let intento = 1; intento <= INTENTOS; intento++) {
-    const detalle = await res.text().catch(() => "");
+    let status: number;
-    console.error(`[whatsapp] error ${res.status} al enviar mensaje: ${detalle}`);
+    let detalle = "";
+    try {
+      const res = await fetch(url, init);
+      if (res.ok) return;
+      status = res.status;
+      detalle = await res.text().catch(() => "");
+    } catch (e) {
+      // Falla de red: mismo tratamiento que un 5xx.
+      status = 0;
+      detalle = String(e);
+    }
+
+    const reintentable = status === 0 || status === 429 || status >= 500;
+    if (!reintentable || intento === INTENTOS) {
+      console.error(`[whatsapp] error ${status} al enviar mensaje (intento ${intento}): ${detalle}`);
+      return;
+    }
+
+    // Backoff exponencial con jitter para no sincronizar los reintentos.
+    const espera = ESPERA_BASE_MS * 2 ** (intento - 1) + Math.floor(Math.random() * 250);
+    console.warn(`[whatsapp] error ${status}, reintento ${intento + 1}/${INTENTOS} en ${espera}ms`);
+    await esperar(espera);
   }
 }
 

src/middleware.ts

@@ -3,12 +3,14 @@ import { jwtVerify } from "jose";
 
 const SECRET = new TextEncoder().encode(process.env.NEXTAUTH_SECRET || "dev-secret");
 
-async function verifyCookie(req: NextRequest, cookieName: string) {
+// Las tres sesiones se firman con el mismo secreto, así que además de la firma hay
+// que mirar el rol: si no, un token de jefe en la cookie del cliente pasa.
+async function verifyCookie(req: NextRequest, cookieName: string, rol: "admin" | "cliente" | "jefe") {
   const token = req.cookies.get(cookieName)?.value;
   if (!token) return false;
   try {
-    await jwtVerify(token, SECRET);
+    const { payload } = await jwtVerify(token, SECRET);
-    return true;
+    return (payload as { role?: string }).role === rol;
   } catch {
     return false;
   }
@@ -19,8 +21,9 @@ export async function middleware(req: NextRequest) {
 
   if (pathname.startsWith("/cliente/dashboard") ||
       pathname.startsWith("/cliente/historial") ||
+      pathname.startsWith("/cliente/perfil") ||
       pathname.startsWith("/cliente/turnos")) {
-    const ok = await verifyCookie(req, "cliente_session");
+    const ok = await verifyCookie(req, "cliente_session", "cliente");
     if (!ok) return NextResponse.redirect(new URL("/cliente", req.url));
   }
 
@@ -30,12 +33,12 @@ export async function middleware(req: NextRequest) {
       pathname.startsWith("/admin/servicios") ||
       pathname.startsWith("/admin/jefes") ||
       pathname.startsWith("/admin/clientes")) {
-    const ok = await verifyCookie(req, "admin_session");
+    const ok = await verifyCookie(req, "admin_session", "admin");
     if (!ok) return NextResponse.redirect(new URL("/admin", req.url));
   }
 
   if (pathname.startsWith("/jefe/dashboard")) {
-    const ok = await verifyCookie(req, "jefe_session");
+    const ok = await verifyCookie(req, "jefe_session", "jefe");
     if (!ok) return NextResponse.redirect(new URL("/jefe", req.url));
   }