drop trigger event_dispatch on event.event;

create trigger event_dispatch
    after insert
    on event.event
    for each row
execute function event.dispatch();

create or replace function event.dispatch()
    returns trigger
    language plpgsql
as
$$
declare
    key text;
    value text;
    subscription_id uuid;
begin
    for key, value in select * from jsonb_each_text(new.labels) limit 50
        loop
            for subscription_id in
                select s.subscription__id
                from webhook.subscription as s
                         inner join webhook.subscription__event_type as set on set.subscription__id = s.subscription__id
                where s.is_enabled
                  and s.application__id = new.application__id
                  and s.deleted_at is null
                  and set.event_type__name = new.event_type__name
                  and s.label_key = key
                  and s.label_value = value
                loop
                    raise notice '[event %] matching subscription: %', new.event__id, subscription_id;
                    insert into webhook.request_attempt (event__id, subscription__id)
                    values (new.event__id, subscription_id);
                end loop;
        end loop;
    update event.event set dispatched_at = statement_timestamp() where event__id = new.event__id;
    return new;
end;
$$;