forked from Mirrors/elk
85 lines
2.9 KiB
TypeScript
85 lines
2.9 KiB
TypeScript
import type { mastodon } from 'masto'
|
|
|
|
const maxDistance = 10
|
|
const maxSteps = 1000
|
|
|
|
// Checks if (b) is a reply to (a)
|
|
function areStatusesConsecutive(a: mastodon.v1.Status, b: mastodon.v1.Status) {
|
|
const inReplyToId = b.inReplyToId ?? b.reblog?.inReplyToId
|
|
return !!inReplyToId && (inReplyToId === a.reblog?.id || inReplyToId === a.id)
|
|
}
|
|
|
|
function removeFilteredItems(items: mastodon.v1.Status[], context: mastodon.v1.FilterContext): mastodon.v1.Status[] {
|
|
const isStrict = (filter: mastodon.v1.FilterResult) => filter.filter.filterAction === 'hide' && filter.filter.context.includes(context)
|
|
const isFiltered = (item: mastodon.v1.Status) => (item.account.id === currentUser.value?.account.id) || !item.filtered?.find(isStrict)
|
|
const isReblogFiltered = (item: mastodon.v1.Status) => !item.reblog?.filtered?.find(isStrict)
|
|
|
|
const homeFilter = useHomeFilter()
|
|
const { bot, sensitive, repost, mutual, tag } = homeFilter.value
|
|
|
|
const isClientSideHomeFiltered = (item: mastodon.v1.Status) => {
|
|
if (bot && sensitive && repost && mutual && tag)
|
|
return true
|
|
|
|
if (!bot && item.account.bot)
|
|
return false
|
|
|
|
if (!sensitive && item.sensitive)
|
|
return false
|
|
|
|
// if (!repost && ??)
|
|
// return false
|
|
|
|
// if (!mutual && ??)
|
|
// return false
|
|
|
|
// if (!tag && ??)
|
|
// return false
|
|
|
|
return true
|
|
}
|
|
|
|
return [...items].filter(isFiltered).filter(isReblogFiltered).filter(isClientSideHomeFiltered)
|
|
}
|
|
|
|
export function reorderedTimeline(items: mastodon.v1.Status[], context: mastodon.v1.FilterContext = 'public') {
|
|
let steps = 0
|
|
|
|
const newItems = removeFilteredItems(items, context)
|
|
|
|
for (let i = newItems.length - 1; i > 0; i--) {
|
|
for (let k = 1; k <= maxDistance && i - k >= 0; k++) {
|
|
// Prevent infinite loops
|
|
steps++
|
|
if (steps > maxSteps)
|
|
return newItems
|
|
|
|
// Check if the [i-k] item is a reply to the [i] item
|
|
// This means that they are in the wrong order
|
|
|
|
if (areStatusesConsecutive(newItems[i], newItems[i - k])) {
|
|
const item = newItems.splice(i, 1)[0]
|
|
newItems.splice(i - k, 0, item) // insert older item before the newer one
|
|
k = 0
|
|
}
|
|
else if (k > 1) {
|
|
// Check if the [i] item is a reply to the [i-k] item
|
|
// This means that they are in the correct order but there are posts between them
|
|
if (areStatusesConsecutive(newItems[i - k], newItems[i])) {
|
|
// If the next statuses are already ordered, move them all
|
|
let j = i
|
|
for (; j < items.length - 1; j++) {
|
|
if (!areStatusesConsecutive(newItems[j], newItems[j + 1]))
|
|
break
|
|
}
|
|
const orderedCount = j - i + 1
|
|
const itemsToMove = newItems.splice(i, orderedCount)
|
|
// insert older item after the newer one
|
|
newItems.splice(i - k + 1, 0, ...itemsToMove)
|
|
k = 0
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return newItems
|
|
}
|