diff --git a/libraries/supabase-js/package.json b/libraries/supabase-js/package.json index 437b33d4111..dc6dc06e0ad 100644 --- a/libraries/supabase-js/package.json +++ b/libraries/supabase-js/package.json @@ -1,6 +1,6 @@ { "name": "@supabase/supabase-js", - "version": "0.1.7", + "version": "0.1.9", "description": "Supabase Realtime API", "main": "./lib/index.js", "scripts": { diff --git a/libraries/supabase-js/src/Supabase.js b/libraries/supabase-js/src/Supabase.js index ddcab68d0fe..91e828c24b1 100644 --- a/libraries/supabase-js/src/Supabase.js +++ b/libraries/supabase-js/src/Supabase.js @@ -46,7 +46,14 @@ class Supabase { // var ref = this.channel.on(eventType, callbackFunction) var ref = this.channel.on(eventType, payload => { - let payloadEnriched = {} + let payloadEnriched = { + columns: payload.columns, + relation: payload.relation, + schema: payload.schema, + table: payload.table, + type: payload.type, + commit_timestamp: payload.commit_timestamp, + } let newData = {} let oldData = {} let oldDataEnriched = {} @@ -54,10 +61,9 @@ class Supabase { switch (payload.type) { case 'INSERT': newData = ChangeMapper.convertChangeData(payload.columns, payload.record) - payloadEnriched = { - eventType: 'INSERT', - new: newData, - } + payloadEnriched.eventType = 'INSERT' + payloadEnriched.new = newData + break case 'UPDATE': @@ -68,11 +74,10 @@ class Supabase { if (oldData[key] != null) oldDataEnriched[key] = oldData[key] }) - payloadEnriched = { - eventType: 'UPDATE', - old: oldDataEnriched, - new: newData, - } + payloadEnriched.eventType = 'UPDATE' + payloadEnriched.old = oldDataEnriched + payloadEnriched.new = newData + break case 'DELETE': @@ -82,10 +87,9 @@ class Supabase { if (oldData[key] != null) oldDataEnriched[key] = oldData[key] }) - payloadEnriched = { - eventType: 'DELETE', - old: oldDataEnriched, - } + payloadEnriched.eventType = 'DELETE' + payloadEnriched.old = oldDataEnriched + break default: diff --git a/libraries/supabase-js/src/utils/ChangeMapper.js b/libraries/supabase-js/src/utils/ChangeMapper.js index d960e597d0a..d9c07e958eb 100644 --- a/libraries/supabase-js/src/utils/ChangeMapper.js +++ b/libraries/supabase-js/src/utils/ChangeMapper.js @@ -80,6 +80,7 @@ export const convertChangeData = (columns, records, options = {}) => { case 'cidr': return noop(stringValue) case 'date': + return noop(stringValue) // To allow users to cast it based on Timezone return toDate(stringValue) case 'daterange': return toDateRange(stringValue) @@ -120,8 +121,10 @@ export const convertChangeData = (columns, records, options = {}) => { case 'time': return noop(stringValue) case 'timestamp': + return noop(stringValue) // To allow users to cast it based on Timezone return toDate(stringValue) case 'timestamptz': + return noop(stringValue) // To allow users to cast it based on Timezone return toDate(stringValue) case 'timetz': return noop(stringValue)