Function createNotifyTrigger

packages/node-core/src/db/sync-helper.ts:242–256

(schema: string, table: string)

}

export function createNotifyTrigger(schema: string, table: string): string {
  const triggerName = hashName(schema, 'notify_trigger', table);
  const channelName = hashName(schema, 'notify_channel', table);
  return `
DO $$
BEGIN
    CREATE TRIGGER "${triggerName}" AFTER INSERT OR UPDATE OR DELETE
    ON "${schema}"."${table}"
    FOR EACH ROW EXECUTE FUNCTION "${schema}".send_notification('${channelName}');
EXCEPTION
    WHEN duplicate_object THEN
        RAISE NOTICE 'Trigger already exists. Ignoring...';
END$$;
  `;
}

function dropTrigger(schema: string, table: string, triggerName: string): string {
  return `DROP TRIGGER IF EXISTS "${triggerName}"