Skip to content

Commit

Permalink
fix: improved unsubscribe
Browse files Browse the repository at this point in the history
  • Loading branch information
Akryum committed Dec 20, 2021
1 parent 4d91c35 commit 1a32ba2
Showing 1 changed file with 12 additions and 4 deletions.
16 changes: 12 additions & 4 deletions packages/app-backend-core/src/util/subscriptions.ts
Original file line number Diff line number Diff line change
Expand Up @@ -15,22 +15,30 @@ function getSubs (type: string) {
}

export function subscribe (type: string, payload: any) {
const rawPayload = JSON.stringify(payload)
const rawPayload = getRawPayload(payload)
getSubs(type).push({
payload,
rawPayload,
})
}

export function unsubscribe (type: string, payload: any) {
const rawPayload = JSON.stringify(payload)
const rawPayload = getRawPayload(payload)
const subs = getSubs(type)
const index = subs.findIndex(sub => sub.rawPayload === rawPayload)
if (index !== -1) {
let index: number
while ((index = subs.findIndex(sub => sub.rawPayload === rawPayload)) !== -1) {
subs.splice(index, 1)
}
}

function getRawPayload (payload: any) {
const data = Object.keys(payload).sort().reduce((acc, key) => {
acc[key] = payload[key]
return acc
}, {})
return JSON.stringify(data)
}

export function isSubscribed (
type: string,
predicate: (sub: Subscription) => boolean = () => true,
Expand Down

0 comments on commit 1a32ba2

Please sign in to comment.