From bd3b6735c1aec66714305146e33757dba9e3e06a Mon Sep 17 00:00:00 2001 From: buhrmi Date: Thu, 3 Sep 2015 16:42:13 +0900 Subject: [PATCH 1/2] make op available in trigger func --- index.js | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/index.js b/index.js index 41023ed..284c960 100644 --- a/index.js +++ b/index.js @@ -128,10 +128,10 @@ LivePg.prototype._initListener = function() { && payload.table in queryBuffer.triggers && (payload.op === 'UPDATE' // Rows changed in an UPDATE operation must check old and new - ? queryBuffer.triggers[payload.table](payload.new_data[0]) - || queryBuffer.triggers[payload.table](payload.old_data[0]) + ? queryBuffer.triggers[payload.table](payload.new_data[0], 'UPDATE1') + || queryBuffer.triggers[payload.table](payload.old_data[0], 'UPDATE2') // Rows changed in INSERT/DELETE operations only check once - : queryBuffer.triggers[payload.table](payload.data[0]))) + : queryBuffer.triggers[payload.table](payload.data[0], payload.op))) || (queryBuffer.triggers // No manual trigger for this table, always refresh && !(payload.table in queryBuffer.triggers)) From 971453692a39ef4ed42d29f16ce5354a628c2cac Mon Sep 17 00:00:00 2001 From: buhrmi Date: Sun, 6 Sep 2015 17:02:18 +0900 Subject: [PATCH 2/2] Update index.js --- index.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/index.js b/index.js index 284c960..6ec39fe 100644 --- a/index.js +++ b/index.js @@ -128,8 +128,8 @@ LivePg.prototype._initListener = function() { && payload.table in queryBuffer.triggers && (payload.op === 'UPDATE' // Rows changed in an UPDATE operation must check old and new - ? queryBuffer.triggers[payload.table](payload.new_data[0], 'UPDATE1') - || queryBuffer.triggers[payload.table](payload.old_data[0], 'UPDATE2') + ? queryBuffer.triggers[payload.table](payload.new_data[0], 'UPDATE') + || queryBuffer.triggers[payload.table](payload.old_data[0], 'UPDATE_OLD') // Rows changed in INSERT/DELETE operations only check once : queryBuffer.triggers[payload.table](payload.data[0], payload.op))) || (queryBuffer.triggers