ankily

// Rango común de una lista de rangos [min, max]; null si no se solapan
function interseccion(rangos) {
  if (!rangos.length) return undefined;
  const min = Math.max(...rangos.map((r) => r[0]));
  const max = Math.min(...rangos.map((r) => r[1]));
  return min <= max ? [min, max] : null;
}

const PARAMS = [
  // margen: tolerancia de medida para no avisar por diferencias que no importan
  { clave: 't', parametro: 'temperatura', margen: 0.5 },
  { clave: 'ph', parametro: 'ph', margen: 0.1 },
  { clave: 'gh', parametro: 'gh', soloDulce: true, margen: 1 },
  { clave: 'sal', parametro: 'salinidad', soloMarino: true,
    convertir: densidadAPpt, margen: 2 },
];

create or replace function public.limitar_frecuencia()
returns trigger language plpgsql security definer set search_path = '' as $$
declare
  columna text := tg_argv[0];               -- columna con el autor
  maximo int := tg_argv[1]::int;            -- inserciones permitidas…
  periodo interval := tg_argv[2]::interval; -- …en este periodo
  autor uuid := (to_jsonb(new) ->> columna)::uuid;
  recientes int;
begin
  if autor is null or (select auth.uid()) is null or public.es_admin() then return new; end if;
  execute format('select count(*) from %I.%I where %I = $1 and creado_en > now() - $2',
    tg_table_schema, tg_table_name, columna) into recientes using autor, periodo;
  if recientes >= maximo then
    raise exception 'LIMITE_FRECUENCIA' using errcode = 'P0001';
  end if;
  return new;
end $$;

create trigger limite_mensajes before insert on public.mensajes
  for each row execute function public.limitar_frecuencia('emisor_id', '60', '10 minutes');