Nikurasu/elk
1
0
Fork 0
forked from Mirrors/elk
Code Pull requests Releases 2 Packages 1 Activity

fix: notification badge (#2592)

Browse source 
Co-authored-by: Ayo <ramon.aycojr@gmail.com>
This commit is contained in:
Shinigami 2024-02-16 17:48:53 +01:00 committed by GitHub
parent dcc1b74824
commit 1bbc2eca24
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
composables/masto/notification.ts
View file

@ -10,8 +10,10 @@ export function useNotifications() {
async function clearNotifications() { async function clearNotifications() {
if (!id || !notifications[id]) if (!id || !notifications[id])
return return
const lastReadId = notifications[id]![1][0] const lastReadId = notifications[id]![1][0]
notifications[id]![1] = [] notifications[id]![1] = []
if (lastReadId) { if (lastReadId) {
await client.v1.markers.create({ await client.v1.markers.create({
notifications: { lastReadId }, notifications: { lastReadId },
@ -30,11 +32,11 @@ export function useNotifications() {
if (!isHydrated.value || !id || notifications[id] !== undefined || !currentUser.value?.token) if (!isHydrated.value || !id || notifications[id] !== undefined || !currentUser.value?.token)
return return
let resolveStream let resolveStream: ((value: mastodon.streaming.Subscription | PromiseLike<mastodon.streaming.Subscription>) => void) | undefined
const streamPromise = new Promise<mastodon.streaming.Subscription>(resolve => resolveStream = resolve) const streamPromise = new Promise<mastodon.streaming.Subscription>(resolve => resolveStream = resolve)
notifications[id] = [streamPromise, []] notifications[id] = [streamPromise, []]
await until($$(streamingClient)).toBe(true) await until($$(streamingClient)).toBeTruthy()
const stream = streamingClient!.user.subscribe() const stream = streamingClient!.user.subscribe()
resolveStream!(stream) resolveStream!(stream)
@ -43,6 +45,7 @@ export function useNotifications() {
const position = await client.v1.markers.fetch({ timeline: ['notifications'] }) const position = await client.v1.markers.fetch({ timeline: ['notifications'] })
const paginator = client.v1.notifications.list({ limit: 30 }) const paginator = client.v1.notifications.list({ limit: 30 })
do { do {
const result = await paginator.next() const result = await paginator.next()
if (!result.done && result.value.length) { if (!result.done && result.value.length) {