CREATE OR REPLACE FUNCTION public.messages_broadcast_changes()
RETURNS trigger
LANGUAGE plpgsql
SECURITY DEFINER
AS $function$
begin
if coalesce(NEW.job_id, OLD.job_id) is not null then
perform realtime.broadcast_changes(
'test',
TG_OP, -- event: INSERT/UPDATE/DELETE
TG_OP, -- operation: same as event
TG_TABLE_NAME, -- table
TG_TABLE_SCHEMA, -- schema: public
NEW, -- new record
OLD -- old record
);
end if;
return null;
end;
$function$
;
CREATE OR REPLACE FUNCTION public.messages_broadcast_changes()
RETURNS trigger
LANGUAGE plpgsql
SECURITY DEFINER
AS $function$
begin
if coalesce(NEW.job_id, OLD.job_id) is not null then
perform realtime.broadcast_changes(
'test',
TG_OP, -- event: INSERT/UPDATE/DELETE
TG_OP, -- operation: same as event
TG_TABLE_NAME, -- table
TG_TABLE_SCHEMA, -- schema: public
NEW, -- new record
OLD -- old record
);
end if;
return null;
end;
$function$
;