Skip to content

Commit

Permalink
fix: notifications in update timeline (#2740)
Browse files Browse the repository at this point in the history
  • Loading branch information
patak-dev committed Apr 3, 2024
1 parent d0b1157 commit 59dda09
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 2 deletions.
4 changes: 3 additions & 1 deletion components/common/CommonPaginator.vue
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@ import type { UnwrapRef } from 'vue'
const {
paginator,
stream,
eventType,
keyProp = 'id',
virtualScroller = false,
preprocess,
Expand All @@ -17,6 +18,7 @@ const {
keyProp?: keyof T
virtualScroller?: boolean
stream?: mastodon.streaming.Subscription
eventType?: 'update' | 'notification'
preprocess?: (items: (U | T)[]) => U[]
endMessage?: boolean | string
}>()
Expand Down Expand Up @@ -44,7 +46,7 @@ defineSlots<{
const { t } = useI18n()
const nuxtApp = useNuxtApp()
const { items, prevItems, update, state, endAnchor, error } = usePaginator(paginator, toRef(() => stream), preprocess)
const { items, prevItems, update, state, endAnchor, error } = usePaginator(paginator, toRef(() => stream), eventType, preprocess)
nuxtApp.hook('elk-logo:click', () => {
update()
Expand Down
1 change: 1 addition & 0 deletions components/notification/NotificationPaginator.vue
Original file line number Diff line number Diff line change
Expand Up @@ -171,6 +171,7 @@ const { formatNumber } = useHumanReadableNumber()
:paginator="paginator"
:preprocess="preprocess"
:stream="stream"
eventType="notification"
:virtualScroller="virtualScroller"
>
<template #updater="{ number, update }">
Expand Down
3 changes: 2 additions & 1 deletion composables/paginator.ts
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@ import type { PaginatorState } from '~/types'
export function usePaginator<T, P, U = T>(
_paginator: mastodon.Paginator<T[], P>,
stream: Ref<mastodon.streaming.Subscription | undefined>,
eventType: 'update' | 'notification' = 'update',
preprocess: (items: (T | U)[]) => U[] = items => items as unknown as U[],
buffer = 10,
) {
Expand Down Expand Up @@ -34,7 +35,7 @@ export function usePaginator<T, P, U = T>(
return

for await (const entry of stream) {
if (entry.event === 'update' || entry.event === 'notification') {
if (entry.event === eventType) {
const status = entry.payload

if ('uri' in status)
Expand Down

0 comments on commit 59dda09

Please sign in to comment.