@supabase/realtime-js
Advanced tools
Comparing version 1.8.0-next.6 to 1.8.0-next.7
@@ -1,2 +0,2 @@ | ||
export declare const version = "1.8.0-next.6"; | ||
export declare const version = "1.8.0-next.7"; | ||
//# sourceMappingURL=version.d.ts.map |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.version = void 0; | ||
exports.version = '1.8.0-next.6'; | ||
exports.version = '1.8.0-next.7'; | ||
//# sourceMappingURL=version.js.map |
import { PresenceOpts, PresenceOnJoinCallback, PresenceOnLeaveCallback } from 'phoenix'; | ||
import RealtimeChannel from './RealtimeChannel'; | ||
declare type Presence = { | ||
presence_id: string; | ||
presence_ref: string; | ||
[key: string]: any; | ||
@@ -69,3 +69,3 @@ }; | ||
* Remove 'metas' key | ||
* Change 'phx_ref' to 'presence_id' | ||
* Change 'phx_ref' to 'presence_ref' | ||
* Remove 'phx_ref' and 'phx_ref_prev' | ||
@@ -76,4 +76,4 @@ * | ||
* abc123: [ | ||
* { presence_id: '2', user_id: 1 }, | ||
* { presence_id: '3', user_id: 2 } | ||
* { presence_ref: '2', user_id: 1 }, | ||
* { presence_ref: '3', user_id: 2 } | ||
* ] | ||
@@ -80,0 +80,0 @@ * } |
@@ -71,6 +71,6 @@ "use strict"; | ||
if (currentPresences) { | ||
const newPresenceIds = newPresences.map((m) => m.presence_id); | ||
const curPresenceIds = currentPresences.map((m) => m.presence_id); | ||
const joinedPresences = newPresences.filter((m) => curPresenceIds.indexOf(m.presence_id) < 0); | ||
const leftPresences = currentPresences.filter((m) => newPresenceIds.indexOf(m.presence_id) < 0); | ||
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); | ||
if (joinedPresences.length > 0) { | ||
@@ -112,4 +112,4 @@ joins[key] = joinedPresences; | ||
if (currentPresences) { | ||
const joinedPresenceIds = state[key].map((m) => m.presence_id); | ||
const curPresences = currentPresences.filter((m) => joinedPresenceIds.indexOf(m.presence_id) < 0); | ||
const joinedPresenceIds = state[key].map((m) => m.presence_ref); | ||
const curPresences = currentPresences.filter((m) => joinedPresenceIds.indexOf(m.presence_ref) < 0); | ||
state[key].unshift(...curPresences); | ||
@@ -123,4 +123,4 @@ } | ||
return; | ||
const presenceIdsToRemove = leftPresences.map((m) => m.presence_id); | ||
currentPresences = currentPresences.filter((m) => presenceIdsToRemove.indexOf(m.presence_id) < 0); | ||
const presenceIdsToRemove = leftPresences.map((m) => m.presence_ref); | ||
currentPresences = currentPresences.filter((m) => presenceIdsToRemove.indexOf(m.presence_ref) < 0); | ||
state[key] = currentPresences; | ||
@@ -147,3 +147,3 @@ onLeave(key, currentPresences, leftPresences); | ||
* Remove 'metas' key | ||
* Change 'phx_ref' to 'presence_id' | ||
* Change 'phx_ref' to 'presence_ref' | ||
* Remove 'phx_ref' and 'phx_ref_prev' | ||
@@ -154,4 +154,4 @@ * | ||
* abc123: [ | ||
* { presence_id: '2', user_id: 1 }, | ||
* { presence_id: '3', user_id: 2 } | ||
* { presence_ref: '2', user_id: 1 }, | ||
* { presence_ref: '3', user_id: 2 } | ||
* ] | ||
@@ -174,3 +174,3 @@ * } | ||
newState[key] = presences.metas.map((presence) => { | ||
presence['presence_id'] = presence['phx_ref']; | ||
presence['presence_ref'] = presence['phx_ref']; | ||
delete presence['phx_ref']; | ||
@@ -177,0 +177,0 @@ delete presence['phx_ref_prev']; |
@@ -1,2 +0,2 @@ | ||
export declare const version = "1.8.0-next.6"; | ||
export declare const version = "1.8.0-next.7"; | ||
//# sourceMappingURL=version.d.ts.map |
@@ -1,2 +0,2 @@ | ||
export const version = '1.8.0-next.6'; | ||
export const version = '1.8.0-next.7'; | ||
//# sourceMappingURL=version.js.map |
import { PresenceOpts, PresenceOnJoinCallback, PresenceOnLeaveCallback } from 'phoenix'; | ||
import RealtimeChannel from './RealtimeChannel'; | ||
declare type Presence = { | ||
presence_id: string; | ||
presence_ref: string; | ||
[key: string]: any; | ||
@@ -69,3 +69,3 @@ }; | ||
* Remove 'metas' key | ||
* Change 'phx_ref' to 'presence_id' | ||
* Change 'phx_ref' to 'presence_ref' | ||
* Remove 'phx_ref' and 'phx_ref_prev' | ||
@@ -76,4 +76,4 @@ * | ||
* abc123: [ | ||
* { presence_id: '2', user_id: 1 }, | ||
* { presence_id: '3', user_id: 2 } | ||
* { presence_ref: '2', user_id: 1 }, | ||
* { presence_ref: '3', user_id: 2 } | ||
* ] | ||
@@ -80,0 +80,0 @@ * } |
@@ -69,6 +69,6 @@ /* | ||
if (currentPresences) { | ||
const newPresenceIds = newPresences.map((m) => m.presence_id); | ||
const curPresenceIds = currentPresences.map((m) => m.presence_id); | ||
const joinedPresences = newPresences.filter((m) => curPresenceIds.indexOf(m.presence_id) < 0); | ||
const leftPresences = currentPresences.filter((m) => newPresenceIds.indexOf(m.presence_id) < 0); | ||
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); | ||
if (joinedPresences.length > 0) { | ||
@@ -110,4 +110,4 @@ joins[key] = joinedPresences; | ||
if (currentPresences) { | ||
const joinedPresenceIds = state[key].map((m) => m.presence_id); | ||
const curPresences = currentPresences.filter((m) => joinedPresenceIds.indexOf(m.presence_id) < 0); | ||
const joinedPresenceIds = state[key].map((m) => m.presence_ref); | ||
const curPresences = currentPresences.filter((m) => joinedPresenceIds.indexOf(m.presence_ref) < 0); | ||
state[key].unshift(...curPresences); | ||
@@ -121,4 +121,4 @@ } | ||
return; | ||
const presenceIdsToRemove = leftPresences.map((m) => m.presence_id); | ||
currentPresences = currentPresences.filter((m) => presenceIdsToRemove.indexOf(m.presence_id) < 0); | ||
const presenceIdsToRemove = leftPresences.map((m) => m.presence_ref); | ||
currentPresences = currentPresences.filter((m) => presenceIdsToRemove.indexOf(m.presence_ref) < 0); | ||
state[key] = currentPresences; | ||
@@ -145,3 +145,3 @@ onLeave(key, currentPresences, leftPresences); | ||
* Remove 'metas' key | ||
* Change 'phx_ref' to 'presence_id' | ||
* Change 'phx_ref' to 'presence_ref' | ||
* Remove 'phx_ref' and 'phx_ref_prev' | ||
@@ -152,4 +152,4 @@ * | ||
* abc123: [ | ||
* { presence_id: '2', user_id: 1 }, | ||
* { presence_id: '3', user_id: 2 } | ||
* { presence_ref: '2', user_id: 1 }, | ||
* { presence_ref: '3', user_id: 2 } | ||
* ] | ||
@@ -172,3 +172,3 @@ * } | ||
newState[key] = presences.metas.map((presence) => { | ||
presence['presence_id'] = presence['phx_ref']; | ||
presence['presence_ref'] = presence['phx_ref']; | ||
delete presence['phx_ref']; | ||
@@ -175,0 +175,0 @@ delete presence['phx_ref_prev']; |
{ | ||
"name": "@supabase/realtime-js", | ||
"version": "1.8.0-next.6", | ||
"version": "1.8.0-next.7", | ||
"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.6' | ||
export const version = '1.8.0-next.7' |
@@ -14,3 +14,3 @@ /* | ||
type Presence = { | ||
presence_id: string | ||
presence_ref: string | ||
[key: string]: any | ||
@@ -144,11 +144,11 @@ } | ||
if (currentPresences) { | ||
const newPresenceIds = newPresences.map((m: Presence) => m.presence_id) | ||
const newPresenceIds = newPresences.map((m: Presence) => m.presence_ref) | ||
const curPresenceIds = currentPresences.map( | ||
(m: Presence) => m.presence_id | ||
(m: Presence) => m.presence_ref | ||
) | ||
const joinedPresences: Presence[] = newPresences.filter( | ||
(m: Presence) => curPresenceIds.indexOf(m.presence_id) < 0 | ||
(m: Presence) => curPresenceIds.indexOf(m.presence_ref) < 0 | ||
) | ||
const leftPresences: Presence[] = currentPresences.filter( | ||
(m: Presence) => newPresenceIds.indexOf(m.presence_id) < 0 | ||
(m: Presence) => newPresenceIds.indexOf(m.presence_ref) < 0 | ||
) | ||
@@ -203,5 +203,7 @@ | ||
if (currentPresences) { | ||
const joinedPresenceIds = state[key].map((m: Presence) => m.presence_id) | ||
const joinedPresenceIds = state[key].map( | ||
(m: Presence) => m.presence_ref | ||
) | ||
const curPresences: Presence[] = currentPresences.filter( | ||
(m: Presence) => joinedPresenceIds.indexOf(m.presence_id) < 0 | ||
(m: Presence) => joinedPresenceIds.indexOf(m.presence_ref) < 0 | ||
) | ||
@@ -221,6 +223,6 @@ | ||
const presenceIdsToRemove = leftPresences.map( | ||
(m: Presence) => m.presence_id | ||
(m: Presence) => m.presence_ref | ||
) | ||
currentPresences = currentPresences.filter( | ||
(m: Presence) => presenceIdsToRemove.indexOf(m.presence_id) < 0 | ||
(m: Presence) => presenceIdsToRemove.indexOf(m.presence_ref) < 0 | ||
) | ||
@@ -263,3 +265,3 @@ | ||
* Remove 'metas' key | ||
* Change 'phx_ref' to 'presence_id' | ||
* Change 'phx_ref' to 'presence_ref' | ||
* Remove 'phx_ref' and 'phx_ref_prev' | ||
@@ -270,4 +272,4 @@ * | ||
* abc123: [ | ||
* { presence_id: '2', user_id: 1 }, | ||
* { presence_id: '3', user_id: 2 } | ||
* { presence_ref: '2', user_id: 1 }, | ||
* { presence_ref: '3', user_id: 2 } | ||
* ] | ||
@@ -294,3 +296,3 @@ * } | ||
newState[key] = presences.metas.map((presence) => { | ||
presence['presence_id'] = presence['phx_ref'] | ||
presence['presence_ref'] = presence['phx_ref'] | ||
@@ -297,0 +299,0 @@ delete presence['phx_ref'] |
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
279750
5090