Fix Realtime bugs && version dump

This commit is contained in:
Angelico committed 2020-01-21 18:55:21 +08:00
1 parent 6e6e050785
commit b40862fd36
3 files changed
+22 -15

No files matched your search

+1 -1
View File
@@ -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": {
+18 -14
View File
@@ -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:
@@ -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)