@supabase/realtime-js
Advanced tools
Comparing version 1.8.0-next.7 to 1.8.0-next.8
@@ -1,2 +0,2 @@ | ||
export declare const version = "1.8.0-next.7"; | ||
export declare const version = "1.8.0-next.8"; | ||
//# sourceMappingURL=version.d.ts.map |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.version = void 0; | ||
exports.version = '1.8.0-next.7'; | ||
exports.version = '1.8.0-next.8'; | ||
//# sourceMappingURL=version.js.map |
@@ -71,6 +71,6 @@ "use strict"; | ||
if (currentPresences) { | ||
const newPresenceIds = newPresences.map((m) => m.presence_ref); | ||
const curPresenceIds = currentPresences.map((m) => m.presence_ref); | ||
const joinedPresences = newPresences.filter((m) => curPresenceIds.indexOf(m.presence_ref) < 0); | ||
const leftPresences = currentPresences.filter((m) => newPresenceIds.indexOf(m.presence_ref) < 0); | ||
const newPresenceRefs = newPresences.map((m) => m.presence_ref); | ||
const curPresenceRefs = currentPresences.map((m) => m.presence_ref); | ||
const joinedPresences = newPresences.filter((m) => curPresenceRefs.indexOf(m.presence_ref) < 0); | ||
const leftPresences = currentPresences.filter((m) => newPresenceRefs.indexOf(m.presence_ref) < 0); | ||
if (joinedPresences.length > 0) { | ||
@@ -109,7 +109,8 @@ joins[key] = joinedPresences; | ||
this.map(joins, (key, newPresences) => { | ||
const currentPresences = state[key]; | ||
var _a; | ||
const currentPresences = (_a = state[key]) !== null && _a !== void 0 ? _a : []; | ||
state[key] = this.cloneDeep(newPresences); | ||
if (currentPresences) { | ||
const joinedPresenceIds = state[key].map((m) => m.presence_ref); | ||
const curPresences = currentPresences.filter((m) => joinedPresenceIds.indexOf(m.presence_ref) < 0); | ||
if (currentPresences.length > 0) { | ||
const joinedPresenceRefs = state[key].map((m) => m.presence_ref); | ||
const curPresences = currentPresences.filter((m) => joinedPresenceRefs.indexOf(m.presence_ref) < 0); | ||
state[key].unshift(...curPresences); | ||
@@ -123,4 +124,4 @@ } | ||
return; | ||
const presenceIdsToRemove = leftPresences.map((m) => m.presence_ref); | ||
currentPresences = currentPresences.filter((m) => presenceIdsToRemove.indexOf(m.presence_ref) < 0); | ||
const presenceRefsToRemove = leftPresences.map((m) => m.presence_ref); | ||
currentPresences = currentPresences.filter((m) => presenceRefsToRemove.indexOf(m.presence_ref) < 0); | ||
state[key] = currentPresences; | ||
@@ -127,0 +128,0 @@ onLeave(key, currentPresences, leftPresences); |
@@ -1,2 +0,2 @@ | ||
export declare const version = "1.8.0-next.7"; | ||
export declare const version = "1.8.0-next.8"; | ||
//# sourceMappingURL=version.d.ts.map |
@@ -1,2 +0,2 @@ | ||
export const version = '1.8.0-next.7'; | ||
export const version = '1.8.0-next.8'; | ||
//# sourceMappingURL=version.js.map |
@@ -69,6 +69,6 @@ /* | ||
if (currentPresences) { | ||
const newPresenceIds = newPresences.map((m) => m.presence_ref); | ||
const curPresenceIds = currentPresences.map((m) => m.presence_ref); | ||
const joinedPresences = newPresences.filter((m) => curPresenceIds.indexOf(m.presence_ref) < 0); | ||
const leftPresences = currentPresences.filter((m) => newPresenceIds.indexOf(m.presence_ref) < 0); | ||
const newPresenceRefs = newPresences.map((m) => m.presence_ref); | ||
const curPresenceRefs = currentPresences.map((m) => m.presence_ref); | ||
const joinedPresences = newPresences.filter((m) => curPresenceRefs.indexOf(m.presence_ref) < 0); | ||
const leftPresences = currentPresences.filter((m) => newPresenceRefs.indexOf(m.presence_ref) < 0); | ||
if (joinedPresences.length > 0) { | ||
@@ -107,7 +107,8 @@ joins[key] = joinedPresences; | ||
this.map(joins, (key, newPresences) => { | ||
const currentPresences = state[key]; | ||
var _a; | ||
const currentPresences = (_a = state[key]) !== null && _a !== void 0 ? _a : []; | ||
state[key] = this.cloneDeep(newPresences); | ||
if (currentPresences) { | ||
const joinedPresenceIds = state[key].map((m) => m.presence_ref); | ||
const curPresences = currentPresences.filter((m) => joinedPresenceIds.indexOf(m.presence_ref) < 0); | ||
if (currentPresences.length > 0) { | ||
const joinedPresenceRefs = state[key].map((m) => m.presence_ref); | ||
const curPresences = currentPresences.filter((m) => joinedPresenceRefs.indexOf(m.presence_ref) < 0); | ||
state[key].unshift(...curPresences); | ||
@@ -121,4 +122,4 @@ } | ||
return; | ||
const presenceIdsToRemove = leftPresences.map((m) => m.presence_ref); | ||
currentPresences = currentPresences.filter((m) => presenceIdsToRemove.indexOf(m.presence_ref) < 0); | ||
const presenceRefsToRemove = leftPresences.map((m) => m.presence_ref); | ||
currentPresences = currentPresences.filter((m) => presenceRefsToRemove.indexOf(m.presence_ref) < 0); | ||
state[key] = currentPresences; | ||
@@ -125,0 +126,0 @@ onLeave(key, currentPresences, leftPresences); |
{ | ||
"name": "@supabase/realtime-js", | ||
"version": "1.8.0-next.7", | ||
"version": "1.8.0-next.8", | ||
"description": "Listen to realtime updates to your PostgreSQL database", | ||
@@ -5,0 +5,0 @@ "keywords": [ |
@@ -1,1 +0,1 @@ | ||
export const version = '1.8.0-next.7' | ||
export const version = '1.8.0-next.8' |
@@ -143,11 +143,13 @@ /* | ||
if (currentPresences) { | ||
const newPresenceIds = newPresences.map((m: Presence) => m.presence_ref) | ||
const curPresenceIds = currentPresences.map( | ||
const newPresenceRefs = newPresences.map( | ||
(m: Presence) => m.presence_ref | ||
) | ||
const curPresenceRefs = currentPresences.map( | ||
(m: Presence) => m.presence_ref | ||
) | ||
const joinedPresences: Presence[] = newPresences.filter( | ||
(m: Presence) => curPresenceIds.indexOf(m.presence_ref) < 0 | ||
(m: Presence) => curPresenceRefs.indexOf(m.presence_ref) < 0 | ||
) | ||
const leftPresences: Presence[] = currentPresences.filter( | ||
(m: Presence) => newPresenceIds.indexOf(m.presence_ref) < 0 | ||
(m: Presence) => newPresenceRefs.indexOf(m.presence_ref) < 0 | ||
) | ||
@@ -198,11 +200,11 @@ | ||
this.map(joins, (key, newPresences: Presence[]) => { | ||
const currentPresences: Presence[] = state[key] | ||
const currentPresences: Presence[] = state[key] ?? [] | ||
state[key] = this.cloneDeep(newPresences) | ||
if (currentPresences) { | ||
const joinedPresenceIds = state[key].map( | ||
if (currentPresences.length > 0) { | ||
const joinedPresenceRefs = state[key].map( | ||
(m: Presence) => m.presence_ref | ||
) | ||
const curPresences: Presence[] = currentPresences.filter( | ||
(m: Presence) => joinedPresenceIds.indexOf(m.presence_ref) < 0 | ||
(m: Presence) => joinedPresenceRefs.indexOf(m.presence_ref) < 0 | ||
) | ||
@@ -221,7 +223,7 @@ | ||
const presenceIdsToRemove = leftPresences.map( | ||
const presenceRefsToRemove = leftPresences.map( | ||
(m: Presence) => m.presence_ref | ||
) | ||
currentPresences = currentPresences.filter( | ||
(m: Presence) => presenceIdsToRemove.indexOf(m.presence_ref) < 0 | ||
(m: Presence) => presenceRefsToRemove.indexOf(m.presence_ref) < 0 | ||
) | ||
@@ -228,0 +230,0 @@ |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
280025
5094