kglt/fyne-on
1
0
Fork 0
Code Pull requests 1 Activity Actions

refactor: migrate to nuxt compatibilityVersion: 4 (#3298)

Browse source
This commit is contained in:
Daniel Roe 2025-05-20 15:05:01 +01:00 • committed by GitHub
parent 46e4433e1c
commit a3fbc056a9
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
342 changed files with 1200 additions and 2932 deletions
Download patch file Download diff file Expand all files Collapse all files

81
composables/masto/notification.ts
View file

@ -1,81 +0,0 @@
import type { mastodon } from 'masto'
const notifications = reactive<Record<string, undefined | [Promise<mastodon.streaming.Subscription>, string[]]>>({})
export function useNotifications() {
const id = currentUser.value?.account.id
const { client, streamingClient } = useMasto()
async function clearNotifications() {
if (!id || !notifications[id])
return
const lastReadId = notifications[id]![1][0]
notifications[id]![1] = []
if (lastReadId) {
await client.value.v1.markers.create({
notifications: { lastReadId },
})
}
}
async function processNotifications(stream: mastodon.streaming.Subscription, id: string) {
for await (const entry of stream) {
if (entry.event === 'notification' && notifications[id])
notifications[id]![1].unshift(entry.payload.id)
}
}
async function connect(): Promise<void> {
if (!isHydrated.value || !id || notifications[id] !== undefined || !currentUser.value?.token)
return
let resolveStream: ((value: mastodon.streaming.Subscription | PromiseLike<mastodon.streaming.Subscription>) => void) | undefined
const streamPromise = new Promise<mastodon.streaming.Subscription>(resolve => resolveStream = resolve)
notifications[id] = [streamPromise, []]
await until(streamingClient).toBeTruthy()
const stream = streamingClient.value!.user.subscribe()
resolveStream!(stream)
processNotifications(stream, id)
const position = await client.value.v1.markers.fetch({ timeline: ['notifications'] })
const paginator = client.value.v1.notifications.list({ limit: 30 })
do {
const result = await paginator.next()
if (!result.done && result.value.length) {
for (const notification of result.value) {
if (notification.id === position.notifications.lastReadId)
return
notifications[id]![1].push(notification.id)
}
}
else {
break
}
} while (true)
}
function disconnect(): void {
if (!id || !notifications[id])
return
notifications[id]![0].then(stream => stream.unsubscribe())
notifications[id] = undefined
}
watch(currentUser, disconnect)
onHydrated(() => {
connect()
})
return {
notifications: computed(() => id ? notifications[id]?.[1].length ?? 0 : 0),
clearNotifications,
}
}