NutriTrack — API GraphQL en tiempo real con Hasura

actions:
  - name: approveMealLogs
    definition:
      kind: synchronous
      handler: http://api:3000/actions/approve-logs
      type: mutation
      arguments:
        - name: log_ids
          type: [uuid!]!
        - name: hr_notes
          type: String
      output_type: ApproveResult
    permissions:
      - role: hr_admin

custom_types:
  objects:
    - name: ApproveResult
      fields:
        - name: approved_count
          type: Int!
        - name: points_awarded
          type: Int!

export default async function handler(req: Request) {
  const { input, session_variables } = await req.json();
  const companyId = session_variables["x-hasura-company-id"];
  const { log_ids, hr_notes } = input;

  // 1. Verificar que los logs pertenecen a la empresa del HR
  const logs = await db.query(`
    SELECT ml.id FROM meal_logs ml
    JOIN employees e ON e.id = ml.employee_id
    WHERE ml.id = ANY($1) AND e.company_id = $2
    AND ml.approved = false
  `, [log_ids, companyId]);

  if (logs.rows.length === 0)
    return Response.json({ errors: [{ message: "No logs found" }] });

  // 2. Aprobar en batch
  await db.query(`
    UPDATE meal_logs SET approved = true, notes = $1
    WHERE id = ANY($2)
  `, [hr_notes, logs.rows.map(r => r.id)]);

  // 3. Puntos de gamificación: +10 por log aprobado
  const points = logs.rows.length * 10;

  return Response.json({
    approved_count: logs.rows.length,
    points_awarded: points
  });
}

event_triggers:
  - name: on_meal_log_approved
    definition:
      enable_manual: false
      update:
        columns: [approved]
    retry_conf:
      num_retries: 3
      interval_sec: 15
      timeout_sec: 60
    webhook: http://api:3000/webhooks/meal-approved
    headers:
      - name: x-webhook-secret
        value_from_env: WEBHOOK_SECRET

export default async function handler(req: Request) {
  const { event } = await req.json();
  const { old: prev, new: curr } = event.data;

  // Solo cuando cambia approved false → true
  if (curr.approved && !prev?.approved) {
    // Sumar 10 puntos al empleado
    await db.query(`
      UPDATE employees
      SET gamification_points = gamification_points + 10
      WHERE id = $1
    `, [curr.employee_id]);

    // Notificar al empleado por email
    await sendEmail({
      to: curr.employee_email,
      subject: "¡Tu registro fue aprobado! +10 pts 🎉",
      template: "meal-approved",
      data: { calories: curr.calories, date: curr.logged_at }
    });
  }

  return Response.json({ success: true });
}