Merge: nombrar Taller Beldor el sitio y el saludo del bot

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
fix(bot): saludar como Taller Beldor
2026-10-19 17:18:33 -03:00 · 2026-10-19 17:18:08 -03:00 · 2026-10-19 17:17:06 -03:00 · 2026-08-07 17:09:43 -03:00 · 2026-08-05 19:07:21 -03:00 · 2026-08-05 17:02:50 -03:00
45 changed files with 1232 additions and 157 deletions
@@ -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
@@ -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.
@@ -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.
@@ -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
@@ -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
@@ -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"

@@ -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`
@@ -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])
+}
@@ -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);
+});
@@ -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);
 }
@@ -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");
@@ -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);
@@ -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();
@@ -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;
@@ -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();
@@ -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;
@@ -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();
@@ -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;
@@ -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);
@@ -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();
@@ -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);
@@ -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({
@@ -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 ?? ""),
+  });
+}
@@ -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({
@@ -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() {
-  const sesion = await verificarSesion("cliente_session");
+// Trabajos que ofrece un jefe mecánico: los suyos + los globales del taller.
+// 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" },
  });

@@ -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);
@@ -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();
@@ -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");
-  if (!sesion || sesion.role !== "jefe")
+  const sesion = await verificarSesion("jefe_session", "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");
-  if (!sesion || sesion.role !== "jefe")
+  const sesion = await verificarSesion("jefe_session", "jefe");
+  if (!sesion)
    return NextResponse.json({ error: "No autorizado" }, { status: 401 });

  const { id } = await params;
@@ -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");
-  if (!sesion || sesion.role !== "jefe")
+  const sesion = await verificarSesion("jefe_session", "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");
-  if (!sesion || sesion.role !== "jefe")
+  const sesion = await verificarSesion("jefe_session", "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 }
    );

@@ -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");
-  if (!sesion || sesion.role !== "jefe")
+  const sesion = await verificarSesion("jefe_session", "jefe");
+  if (!sesion)
    return NextResponse.json({ error: "No autorizado" }, { status: 401 });

  const { searchParams } = new URL(req.url);
@@ -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
-// procesados en memoria (un solo container) para no duplicar turnos ni respuestas.
-const procesados = new Set<string>();
-const MAX_PROCESADOS = 500;
+// Meta reintenta el mismo mensaje si tardamos o si algo falla, y sin deduplicar eso
+// 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;

-function yaProcesado(id: string): boolean {
-  if (procesados.has(id)) return true;
-  procesados.add(id);
-  // Set mantiene orden de inserción: soltamos los más viejos.
-  while (procesados.size > MAX_PROCESADOS) {
-    const viejo: string | undefined = procesados.values().next().value;
-    if (viejo === undefined) break;
-    procesados.delete(viejo);
-  }
+async function yaProcesado(id: string): Promise<boolean> {
+  try {
+    await prisma.mensajeWhatsappProcesado.create({ data: { id } });
    return false;
+  } catch (e) {
+    if (e instanceof Prisma.PrismaClientKnownRequestError && e.code === "P2002") return true;
+    throw e;
+  }
+}
+
+/** 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);
+  }
 }

 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(() => {});

@@ -68,10 +68,15 @@ 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>
+        <div className="flex items-center gap-4">
+          <Link href="/cliente/perfil" className="text-sm text-gray-200 hover:text-white transition">
+            Mis datos
+          </Link>
          <button onClick={cerrarSesion} className="text-sm text-gray-200 hover:text-red-300 transition">
            Salir
          </button>
        </div>
+      </div>

      {loading ? (
        <div className="text-center py-10 text-gray-200">Cargando...</div>
@@ -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>
+  );
+}
@@ -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
@@ -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) {
-    setServicioSel(s);
-    setJefeSel(null);
+  async function seleccionarJefe(j: Jefe) {
+    setJefeSel(j);
+    setServicioSel(null);
+    setServicios([]);
    setSlots([]);
    setDiaSeleccionado(null);
    setSlotSel(null);
-    setLoadingJefes(true);
-    setStep("jefe");
-    const res = await fetch("/api/cliente/jefes");
+    setLoadingServicios(true);
+    setStep("servicio");
+    const res = await fetch(`/api/cliente/servicios?jefeMecanicoId=${j.id}`);
    const data = await res.json();
-    setJefes(Array.isArray(data) ? data : []);
-    setLoadingJefes(false);
+    setServicios(Array.isArray(data) ? data : []);
+    setLoadingServicios(false);
  }

-  async function seleccionarJefe(j: Jefe) {
-    if (!servicioSel) return;
-    setJefeSel(j);
+  async function seleccionarServicio(s: TipoServicio) {
+    if (!jefeSel) return;
+    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 === "servicio" && (
+      {/* STEP: jefe */}
+      {step === "jefe" && (
        <>
-          <div className="grid gap-3">
-            {servicios.map(s => (
-              <button key={s.id} onClick={() => seleccionarServicio(s)}
-                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 className="flex flex-col gap-3">
+            {loadingJefes ? (
+              <p className="text-center text-sm text-gray-200">Cargando jefes...</p>
+            ) : jefes.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.
+                </p>
+              </Card>
+            ) : (
+              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">{s.nombre}</p>
-                  <p className="text-sm text-gray-500 mt-0.5">Duración: {formatDuracion(s.duracionHoras)}</p>
+                    <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 === "jefe" && (
-        <div className="flex flex-col gap-3">
-          {loadingJefes ? (
-            <p className="text-center text-sm text-gray-200">Cargando jefes...</p>
-          ) : jefes.length === 0 ? (
+      {/* STEP: servicio */}
+      {step === "servicio" && (
+        <div className="grid gap-3">
+          {loadingServicios ? (
+            <p className="text-center text-sm text-gray-200">Cargando trabajos...</p>
+          ) : 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) => (
-              <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"
-              >
+            servicios.map(s => (
+              <button key={s.id} onClick={() => seleccionarServicio(s)}
+                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 disponibilidad</p>
+                  <p className="font-medium text-gray-800">{s.nombre}</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>
@@ -14,8 +14,8 @@ const geistMono = localFont({
 });

 export const metadata: Metadata = {
-  title: "Taller MG",
-  description: "Sistema de turnos - Taller MG",
+  title: "Taller Beldor",
+  description: "Sistema de turnos - Taller Beldor",
 };

 export default function RootLayout({
@@ -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>
      )}
+      {prefijo ? (
+        <div
+          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"
+          }`}
+        >
+          <span className="pl-3 pr-1 text-sm text-gray-500 select-none">{prefijo}</span>
          <input
            id={id}
-        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 ${
-          error ? "border-red-400" : "border-gray-400"
-        } ${className}`}
+            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>
  );
@@ -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;
  }
@@ -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) {
-  return prisma.jefeMecanico.findUnique({
+async function obtenerJefeActivo(jefeMecanicoId: string, db: ClienteDb = prisma) {
+  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;
 }
@@ -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;
+}
@@ -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;
+}
@@ -1,5 +1,6 @@
 import { prisma } from "./prisma";
 import { slotEstaDisponible } from "./scheduling";
+import { trabajoEsDeJefe } from "./servicios";

 export interface CrearTurnoInput {
  clienteId: string;
@@ -30,12 +31,22 @@ 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);
-  if (!disponible) return { ok: false, error: "El horario ya no está disponible", status: 409 };
+  // Verificar y crear en una sola transacción, serializando por jefe con un lock
+  // 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);
+    if (!disponible) return null;
+
+    return tx.turno.create({
      data: {
        clienteId,
        jefeMecanicoId,
@@ -51,6 +62,9 @@ export async function crearTurno(input: CrearTurnoInput): Promise<CrearTurnoResu
        jefeMecanico: { select: { id: true, nombre: true } },
      },
    });
+  });
+
+  if (!turno) return { ok: false, error: "El horario ya no está disponible", status: 409 };

  return { ok: true, turno };
 }
@@ -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" },
  });

@@ -182,7 +183,7 @@ async function guardar(
  return resp;
 }

-const BIENVENIDA = "¡Hola! 👋 Soy el asistente del *Taller MG*. Te ayudo a sacar un turno.";
+const BIENVENIDA = "¡Hola! 👋 Soy el asistente del *Taller Beldor*. Te ayudo a sacar un turno.";

 // ── Entrada principal ──
 export async function procesarMensaje(telefonoRaw: string, textoRaw: string): Promise<RespuestaBot[]> {
@@ -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]);
      }
@@ -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) {
-    const detalle = await res.text().catch(() => "");
-    console.error(`[whatsapp] error ${res.status} al enviar mensaje: ${detalle}`);
+  for (let intento = 1; intento <= INTENTOS; intento++) {
+    let status: number;
+    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);
  }
 }

@@ -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);
-    return true;
+    const { payload } = await jwtVerify(token, SECRET);
+    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));
  }
Author	SHA1	Message	Date
Beldor	6d802ef069	Merge: nombrar Taller Beldor el sitio y el saludo del bot Deploy / deploy (push) Successful in 5m53s Details Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-10-19 17:18:33 -03:00
Beldor	e0d6035485	fix(bot): saludar como Taller Beldor Para que el saludo coincida con el Display Name de la cuenta de WhatsApp Business y con el nombre del sitio. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-10-19 17:18:08 -03:00
Beldor	d917618e67	fix(sitio): nombrar el sitio Taller Beldor Meta rechaza el alta de WhatsApp (#2494070) cuando el nombre declarado del negocio no coincide con el del sitio que lo respalda. El negocio es Taller Beldor y el sitio decia Taller MG. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-10-19 17:17:06 -03:00
jpbeldomenico	8fcd0fbf77	Merge pull request (#8 ): pasar las credenciales de Meta al contenedor Deploy / deploy (push) Successful in 4m47s Details	2026-08-07 17:09:43 -03:00
Beldor	31bd0ad0bd	fix(whatsapp): pasar las credenciales de Meta al contenedor Revisión con IA / ai-review (pull_request) Successful in 47s Details 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>	2026-08-05 19:07:21 -03:00
jpbeldomenico	2bdf76ab63	Merge pull request (#7 ): comprobar el rol de la sesion en todas las rutas Deploy / deploy (push) Successful in 3m5s Details	2026-08-05 17:02:50 -03:00
Beldor	f4df90ac1e	fix(auth): comprobar el rol de la sesion en todas las rutas Revisión con IA / ai-review (pull_request) Successful in 1m24s Details Las tres sesiones (admin, cliente, jefe) se firman con el mismo secreto, asi que verificar solo la firma alcanzaba para que un token de un rol pasara por la cookie de otro. Verificado antes del cambio: un token de admin en cliente_session daba 200 en /api/cliente/autos, y uno de jefe cargaba /cliente/dashboard. Despues: 401 y 307. - Las 26 llamadas a verificarSesion pasan el rol esperado. - El middleware, que hacia su propio jwtVerify sin mirar el rol, ahora tambien lo comprueba. - Se sacan las comprobaciones sueltas de rol en las rutas de jefe, que quedaron redundantes. Matriz probada contra la app: los tres roles siguen entrando en su area (200) y ninguno entra en la de los otros, ni por API (401) ni por pagina (307). Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-08-05 16:45:33 -03:00
jpbeldomenico	97f9ccec28	Merge pull request (#6 ): datos de contacto del cliente Deploy / deploy (push) Successful in 3m4s Details	2026-08-05 16:09:45 -03:00
Beldor	ce7063514c	fix(perfil): detalles senalados en la revision Revisión con IA / ai-review (pull_request) Successful in 24s Details - verificarSesion acepta el rol esperado. Las tres sesiones (admin, cliente, jefe) se firman con el mismo secreto, asi que un token de jefe puesto en la cookie cliente_session pasaba la verificacion de firma; ahora el rol se comprueba. Verificado: con un JWT de jefe, /api/cliente/perfil da 401. - El update traduce el P2002 de los indices unicos a un 409 legible, por si otra request toma el mismo email o telefono entre la comprobacion y el update. - La pantalla ya no queda en "Cargando..." para siempre si falla el pedido. - Si la sesion vence mientras edita, el PATCH manda a entrar de nuevo en vez de mostrar un error suelto. Queda como mejora aparte pasarle el rol esperado al resto de las rutas del area del cliente, que hoy solo validan la firma. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-08-05 16:09:40 -03:00
Beldor	62dab5e025	feat(cliente): ver y modificar los datos de contacto Revisión con IA / ai-review (pull_request) Successful in 2m18s Details El cliente no tenia forma de corregir su email ni su telefono despues del alta. Nueva pantalla /cliente/perfil ("Mis datos", enlazada desde el dashboard) que muestra nombre, email y telefono, y permite editarlos. - GET/PATCH /api/cliente/perfil, ambos con la sesion del cliente. - El telefono usa el mismo campo con el +54 9 fijo que el registro, y se guarda normalizado en telefonoNorm para que el bot lo siga reconociendo. - aLocalArgentino() saca el prefijo para mostrar: un cliente dado de alta por WhatsApp tiene el numero guardado como 5491141984844 y en el formulario tiene que verse 1141984844. - Email y telefono se validan unicos contra los demas clientes (409), no contra uno mismo. Si cambia el email se avisa que con ese va a entrar de ahora en mas, porque es la identidad del magic link. - El middleware protege /cliente/perfil como el resto del area del cliente. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-08-05 15:54:38 -03:00
jpbeldomenico	2baa7952fa	Merge pull request (#5 ): telefono en el formato que usa WhatsApp Deploy / deploy (push) Successful in 3m0s Details	2026-08-05 15:03:21 -03:00
Beldor	9e93808dc1	fix: detalles del formato de telefono senalados en la revision Revisión con IA / ai-review (pull_request) Successful in 25s Details - esLocalArgentinoValido tambien rechaza los que arrancan con 15: ninguna caracteristica argentina empieza asi, es el viejo prefijo de celular. - El formulario ya no reta "faltan digitos" mientras se esta tipeando; ese aviso espera a que el campo pierda el foco. Los errores seguros (0 o 15 adelante) se siguen mostrando al instante. - chat-bot.ts normalizaba el telefono para conversar pero no para /reset, asi que el reset no encontraba la conversacion y no borraba nada. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-08-05 15:02:59 -03:00
Beldor	ffa32a113d	fix(registro): guardar el telefono en el formato que usa WhatsApp Revisión con IA / ai-review (pull_request) Successful in 2m12s Details Un cliente registrado por la web no lo reconocia el bot: el formulario dejaba escribir el numero en cualquier formato (1141984844, 01157260394) mientras que Meta manda el wa_id 5491141984844, asi que la busqueda por telefonoNorm no encontraba nada, mandaba al alta y ahi chocaba contra el email ya registrado. Quedaba en un callejon sin salida. Ahora el campo muestra "+54 9" fijo y grisado y el cliente completa solo la caracteristica (sin el 0) y el abonado (sin el 15), 10 digitos. El backend valida ese formato y guarda telefonoNorm ya como lo espera el bot. Se rechaza tambien un telefono repetido, que antes reventaba con el indice unico. Se agrega scripts/chat-bot.ts, que es como se encontro esto: permite conversar con el bot desde la consola contra cualquier base, sin Meta ni credenciales. Corriendolo contra una copia de la base de produccion se ve el ciclo completo: alta por web -> el bot lo reconoce por telefono -> pide el email -> reserva. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-08-05 14:56:15 -03:00
jpbeldomenico	e85635f272	Merge pull request (#4 ): bot de reservas por WhatsApp y flujo web jefe -> trabajo Deploy / deploy (push) Successful in 4m52s Details	2026-08-05 12:24:53 -03:00
Beldor	2df679777c	fix(jefe): mensaje de duracion acorde a lo que valida Revisión con IA / ai-review (pull_request) Successful in 31s Details La validacion rechaza 0 pero el mensaje decia "entre 0 y 24". Ojo que "entre 1 y 24" habria sido igual de incorrecto: duracionHoras es Float y la UI muestra las duraciones de menos de una hora en minutos, asi que 0,5 (media hora) es un valor valido y esperado. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-08-05 12:21:02 -03:00
Beldor	91112862a5	fix: los cuatro hallazgos reales de la revision con IA Revisión con IA / ai-review (pull_request) Successful in 29s Details - crearTurno verificaba disponibilidad y creaba el turno en dos operaciones sueltas: dos clientes podian pasar la verificacion a la vez y sobrevender el mismo horario. Ahora va todo en una transaccion, serializada por jefe con pg_advisory_xact_lock. slotEstaDisponible acepta el cliente de la transaccion. Probado contra un Postgres real: 5 reservas simultaneas del mismo slot con capacidad 1 dan 1 ok + 4 conflictos y una sola fila; sacando el lock, entran las 5. - La deduplicacion del webhook estaba en memoria y solo servia con una instancia. Pasa a la base con el modelo MensajeWhatsappProcesado: el insert del id es atomico por el indice unico, asi que aguanta reintentos concurrentes de Meta (verificado). Se limpian los ids de mas de 7 dias. - postMensaje no reintentaba: ahora reintenta 3 veces ante 429, 5xx y fallas de red, con backoff exponencial y jitter. Un 4xx nuestro no se reintenta. - /api/cliente/servicios devolvia los trabajos de un jefe dado de baja; ahora responde 404 si el jefe no existe o no esta activo. test:envio suma los casos de reintento (35 asserts). El Prisma en memoria del test del bot ahora entiende $transaction y $executeRaw. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-08-05 11:21:35 -03:00
Beldor	44aeb58e77	feat(cliente): invertir el flujo web a jefe -> trabajo Revisión con IA / ai-review (pull_request) Failing after 2m12s Details Los trabajos ahora son por jefe mecanico, asi que el cliente elige primero el mecanico y despues el trabajo, igual que en el bot de WhatsApp. Antes listaba todos los servicios del taller y recien despues pedia el jefe. - src/lib/servicios.ts: regla unica de que trabajos ofrece un jefe = los suyos + los globales del taller (jefeMecanicoId null, los carga el admin). Asi no se rompe lo que ya existe en produccion, donde todos los servicios son globales. - /api/cliente/servicios ahora exige jefeMecanicoId y aplica esa regla. - /api/cliente/slots y crearTurno rechazan un trabajo propio de OTRO jefe (400): antes se podia reservar con el jefe A la duracion del trabajo del B. - whatsapp-bot: usa la misma regla, asi la web y el bot ofrecen lo mismo. - cliente/turnos: pasos invertidos, cabeceras y back acordes, y estado vacio propio cuando el jefe no tiene trabajos. - test-whatsapp-bot: soporte de OR en el Prisma en memoria, trabajo global en el seed y escenario D (globales visibles, trabajo ajeno rechazado). 31 asserts. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-08-05 09:55:47 -03:00
jpbeldomenico	15d6e8a2ee	feat(whatsapp): webhook + envio por Graph API (F0) Ultima fase del bot de reservas: conecta la maquina de conversacion ya existente (whatsapp-bot.ts) con la WhatsApp Business Cloud API. - src/lib/whatsapp.ts: traduce RespuestaBot -> payloads de Meta (texto e interactive/button, con los limites de 3 botones / 20 chars / 4096 chars), aplana el payload del webhook y valida X-Hub-Signature-256 en tiempo constante. - src/app/api/whatsapp/webhook/route.ts: GET de verificacion y POST de mensajes. Valida la firma sobre el cuerpo crudo, deduplica por message id (Meta reintenta) y siempre devuelve 200 para no entrar en loop de retries. - scripts/test-whatsapp-envio.ts (npm run test:envio): 30 asserts sobre la capa Meta con fetch stubbeado, sin DB ni credenciales. - docs/whatsapp.md con el alta en el panel de Meta y las 4 env vars. Falta solo cargar las credenciales de Meta en el .env de produccion. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-08-05 09:55:47 -03:00
Beldor	0046b6c3cf	feat(whatsapp): máquina de conversación del bot de reservas (F2) + test - lib/turnos.ts: crearTurno() compartido (valida servicio/jefe/slot); cliente/turnos POST lo reutiliza - lib/telefono.ts: normalización de teléfono (E.164 sin '+') para matchear el wa_id - lib/whatsapp-bot.ts: procesarMensaje(telefono, texto), state machine completa: identidad por teléfono + verificación por email registrado / alta nueva, elegir mecánico (botones) -> trabajo (letras) -> horario (letras, con "más") -> confirmar, crea turno sin auto/km; expiración 30min, "cancelar" global, manejo de inválidos y 409. Devuelve objetos-respuesta (texto/botones) -> independiente de Meta (lo traduce F0). - scripts/test-whatsapp-bot.ts + npm run test:bot: corre la máquina de estados con un Prisma en memoria (sin DB ni Meta), ejercitando scheduling y crearTurno reales. 27/27 OK. Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>	2026-08-05 09:55:47 -03:00
Beldor	c53e5bb5aa	feat(whatsapp): schema del bot de reservas + panel de trabajos por jefe (F1+F3) 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>	2026-08-05 09:55:47 -03:00
jpbeldomenico	dd7f73453e	Merge pull request 'ci: reintentar la revision con IA cuando falla el proveedor' (#3 ) from fix/ai-review-reintentos into main Deploy / deploy (push) Successful in 3m22s Details	2026-08-03 22:50:20 -03:00
jpbeldomenico	a312815140	fix(ci): no dar por fallida una revision por el texto de su comentario Revisión con IA / ai-review (pull_request) Successful in 1m59s Details El guard buscaba "Error: " en el log, pero el log tambien trae lo que escribe el modelo. En inventario#3 la revision salio bien y comento justamente que ese patron era demasiado amplio: el comentario quedo impreso, matcheo el patron y el job quedo en rojo. Lo encontro la propia revision con IA. Ahora se miran las marcas de nivel que imprime la herramienta (\| ERROR \| y \| CRITICAL \|), que el modelo no escribe, y el traceback al principio de linea. Verificado contra los logs reales guardados: detecta la falla por el 502 de OpenRouter y deja pasar las tres revisiones que salieron bien. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-08-03 21:26:21 -03:00
jpbeldomenico	a7bb038b6b	fix(ci): reintentar la revision con IA cuando falla el proveedor Revisión con IA / ai-review (pull_request) Successful in 44s Details El 03/08/2026 OpenRouter devolvio 502 con el modelo gratuito y el pull request se mergeo sin revisar. Ahora revisar() reintenta hasta 3 veces con espera creciente (30s, 60s), pero solo ante las marcas que deja una falla al pedirle la respuesta al modelo: un 401 o un modelo que ya no existe siguen cortando en el primer intento, porque esperar no los arregla. De paso se saca la tuberia a tee: el codigo de salida que se evaluaba era el de tee, siempre 0, asi que esa mitad del guard nunca hizo nada. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-08-03 21:10:32 -03:00
jpbeldomenico	d74c97e532	Merge pull request 'ci: construir antes de bajar el servicio' (#2 ) from fix/deploy-robusto into main Deploy / deploy (push) Successful in 4m46s Details	2026-08-03 20:04:35 -03:00
jpbeldomenico	f1ef9da857	fix(ci): construir antes de bajar el servicio Revisión con IA / ai-review (pull_request) Failing after 24s Details El despliegue hacia "docker compose down" y recien despues "up -d --build". Si la construccion fallaba, el taller quedaba caido hasta que alguien lo notara: paso el 03/08/2026, cuando npm no pudo bajar las dependencias y el sitio estuvo abajo sin que ningun paso lo avisara. Ahora la imagen se construye primero y solo despues se recrean los contenedores, sin bajar nada de antemano. Si la construccion falla, lo que estaba corriendo sigue en pie. Se agrega ademas una verificacion final: si al terminar no hay contenedores corriendo, el despliegue falla y muestra los registros, en lugar de dar por bueno un servicio caido. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-08-03 19:49:17 -03:00
jpbeldomenico	8d1b5da448	Merge pull request 'ci: revisar los pull requests con IA' (#1 ) from feat/ai-review into main Deploy / deploy (push) Failing after 1m31s Details	2026-08-03 19:27:55 -03:00
jpbeldomenico	5e027d2c8c	feat(ci): revisar los pull requests con IA Revisión con IA / ai-review (pull_request) Successful in 1m58s Details Replica en este repositorio la revision automatica que ya corre en prode_app: al abrir, reabrir o actualizar un pull request, un modelo lee el diff completo y publica comentarios pegados a cada linea mas un resumen, firmados por el usuario ai-bot. El modelo es gratuito y cada revision cuesta dos pedidos, porque manda todos los archivos juntos en lugar de uno por archivo. Los secretos se leen de Infisical al arrancar el job, asi que en el repositorio solo quedan las credenciales de la identidad de maquina. El prompt esta escrito sobre este proyecto en particular: turnos que se pisan, husos horarios, autorizacion distinta para admin, jefe y cliente, magic links tratados como credenciales, migraciones que acompañen a schema.prisma y datos personales que no terminen en los registros. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-08-03 18:55:10 -03:00