import { HeaderLeft } from '@components/Header' import Icon from '@components/Icon' import { Loading } from '@components/Loading' import ComponentSeparator from '@components/Separator' import CustomText from '@components/Text' import TimelineDefault from '@components/Timeline/Default' import { useQuery } from '@tanstack/react-query' import apiGeneral from '@utils/api/general' import apiInstance from '@utils/api/instance' import { appendRemote } from '@utils/helpers/appendRemote' import { urlMatcher } from '@utils/helpers/urlMatcher' import { TabSharedStackScreenProps } from '@utils/navigation/navigators' import { queryClient } from '@utils/queryHooks' import { QueryKeyTimeline } from '@utils/queryHooks/timeline' import { getAccountStorage } from '@utils/storage/actions' import { StyleConstants } from '@utils/styles/constants' import { useTheme } from '@utils/styles/ThemeManager' import React, { useEffect, useRef, useState } from 'react' import { useTranslation } from 'react-i18next' import { Alert, FlatList, Platform, Pressable, View } from 'react-native' import { Path, Svg } from 'react-native-svg' const TabSharedToot: React.FC> = ({ navigation, route: { params: { toot } } }) => { const { colors } = useTheme() const { t } = useTranslation(['componentTimeline', 'screenTabs']) const [hasRemoteContent, setHasRemoteContent] = useState(toot._remote || false) const queryKey: { local: QueryKeyTimeline; remote: QueryKeyTimeline } = { local: ['Timeline', { page: 'Toot', toot: toot.id, remote: false }], remote: ['Timeline', { page: 'Toot', toot: toot.id, remote: true }] } const flRef = useRef>(null) useEffect(() => { navigation.setOptions({ headerTitle: () => ( Alert.alert( t('screenTabs:shared.toot.remoteFetch.title'), t('screenTabs:shared.toot.remoteFetch.message') ) } > {hasRemoteContent ? ( ) : null} ), headerLeft: () => navigation.goBack()} />, headerBackVisible: false }) navigation.setParams({ queryKey: queryKey.local }) }, [hasRemoteContent]) const PREV_PER_BATCH = 1 const ancestorsCache = useRef<(Mastodon.Status & { _level?: number })[]>() const loaded = useRef(false) const prependContent = async () => { loaded.current = true if (ancestorsCache.current?.length) { switch (Platform.OS) { case 'ios': await new Promise(promise => setTimeout(promise, 128)) for (let [] of Array( Math.ceil(ancestorsCache.current.length / PREV_PER_BATCH) ).entries()) { await new Promise(promise => setTimeout(promise, 8)) queryClient.setQueryData<{ pages: { body: Mastodon.Status[] }[] }>( queryKey.local, old => { const insert = ancestorsCache.current?.slice(-PREV_PER_BATCH) ancestorsCache.current = ancestorsCache.current?.slice(0, -PREV_PER_BATCH) if (insert) { old?.pages[0].body.unshift(...insert) } return old } ) } break default: queryClient.setQueryData<{ pages: { body: Mastodon.Status[] }[] }>( queryKey.local, old => { ancestorsCache.current && old?.pages[0].body.unshift(...ancestorsCache.current) return old } ) flRef.current?.props.data?.length && setTimeout(() => { flRef.current?.scrollToIndex({ index: ancestorsCache.current?.length || 0, viewOffset: 50 }) }, 50) break } } } const updateCounts = ( remote: Mastodon.Status ): Pick => ({ reblogs_count: remote.reblogs_count, replies_count: remote.replies_count, favourites_count: remote.favourites_count }) const match = urlMatcher(toot.url || toot.uri) const remoteQueryEnabled = ['public', 'unlisted'].includes(toot.visibility) && match?.domain !== getAccountStorage.string('auth.domain') const query = useQuery( queryKey.local, async () => { const context = await apiInstance<{ ancestors: Mastodon.Status[] descendants: Mastodon.Status[] }>({ method: 'get', url: `statuses/${toot.id}/context` }).then(res => res.body) ancestorsCache.current = [...context.ancestors] const statuses = [{ ...toot }, ...context.descendants] return statuses.map((status, index) => { if (index === 0) { status._level = 0 return status } else { const repliedLevel: number = statuses.find(s => s.id === status.in_reply_to_id)?._level || 0 status._level = repliedLevel + 1 return status } }) }, { enabled: !toot._remote, staleTime: 0, refetchOnMount: true, onSuccess: async data => { if (data.length < 1) { navigation.goBack() return } if (!remoteQueryEnabled) { await prependContent() } } } ) const remoteQuery = useQuery( queryKey.remote, async () => { const domain = match?.domain if (!domain?.length) { return Promise.reject('Cannot parse remote doamin') } const id = match?.status?.id if (!id?.length) { return Promise.reject('Cannot parse remote toot id') } const [remote, context] = await Promise.all([ apiGeneral({ method: 'get', domain, url: `api/v1/statuses/${id}` }).then(res => res.body), apiGeneral<{ ancestors: Mastodon.Status[] descendants: Mastodon.Status[] }>({ method: 'get', domain, url: `api/v1/statuses/${id}/context` }).then(res => res.body) ]) if (!context?.ancestors.length && !context?.descendants.length) { return Promise.resolve([{ ...toot, ...updateCounts(remote) }]) } if ((ancestorsCache.current?.length || 0) < context.ancestors.length) { ancestorsCache.current = context.ancestors.map(ancestor => { const localMatch = ancestorsCache.current?.find(local => local.uri === ancestor.uri) if (localMatch) { return localMatch } else { return appendRemote.status(ancestor, domain) } }) } const statuses = [{ ...toot, ...updateCounts(remote) }, ...context.descendants] return statuses.map((status, index) => { if (index === 0) { status._level = 0 return status } else { const repliedLevel: number = statuses.find(s => s.id === status.in_reply_to_id)?._level || 0 status._level = repliedLevel + 1 return status } }) }, { enabled: (toot._remote ? true : query.isFetched) && remoteQueryEnabled, staleTime: 0, refetchOnMount: true, retry: false, onSuccess: async data => { if ((query.data?.length || 0) < 1 && data.length < 1) { navigation.goBack() return } if ((query.data?.length || 0) < data.length) { setHasRemoteContent(true) queryClient.cancelQueries(queryKey.local) queryClient.setQueryData(queryKey.local, old => { return data.map(remote => { const localMatch = old?.find(local => local.uri === remote.uri) if (localMatch) { return { ...localMatch, _level: remote._level, ...updateCounts(remote) } } else { return appendRemote.status(remote, match!.domain) } }) }) } else { queryClient.cancelQueries(queryKey.local) queryClient.setQueryData(queryKey.local, old => { return old?.map(local => { const remoteMatch = data.find(remote => remote.uri === local.uri) if (remoteMatch) { return { ...local, ...updateCounts(remoteMatch) } } else { return local } }) }) } }, onSettled: async () => { await prependContent() } } ) const [heights, setHeights] = useState<{ [key: number]: number }>({}) const MAX_LEVEL = 10 const ARC = StyleConstants.Avatar.XS / 4 return ( `${item.id}_${index}`} renderItem={({ item, index }) => { const prev = query.data?.[index - 1]?._level || 0 const curr = item._level || 0 const next = query.data?.[index + 1]?._level || 0 const height = heights[index] || 300 let path = '' if (curr > 1 || next > 1) { Array.from({ length: curr }).forEach((_, i) => { if (i > MAX_LEVEL) return null const lastLine = curr === i + 1 if (lastLine) { if (curr === prev + 1 || curr === next - 1) { if (curr > next) return path = path + ` M ${curr * StyleConstants.Spacing.S + ARC} ${ StyleConstants.Spacing.M + StyleConstants.Avatar.XS / 2 } ` + `a ${ARC} ${ARC} 0 0 0 -${ARC} ${ARC} ` + `v ${height}` } else { if (i >= curr - 2) return path = path + ` M ${(i + 1) * StyleConstants.Spacing.S} 0 ` + `v ${ height - (StyleConstants.Spacing.S * 1.5 + StyleConstants.Font.Size.L) / 2 - StyleConstants.Avatar.XS / 2 } ` + `a ${ARC} ${ARC} 0 0 0 ${ARC} ${ARC}` } } else { if (i >= next - 1) { path = path + ` M ${(i + 1) * StyleConstants.Spacing.S} 0 ` + `v ${ height - (StyleConstants.Spacing.S * 1.5 + StyleConstants.Font.Size.L * 1.35) / 2 } ` + `h ${ARC}` } else { path = path + ` M ${(i + 1) * StyleConstants.Spacing.S} 0 ` + `v ${height}` } } }) } return ( setHeights({ ...heights, [index]: height })} > {path.length ? ( ) : null} {/* */} ) }} initialNumToRender={3} maxToRenderPerBatch={3} ItemSeparatorComponent={({ leadingItem }) => { return ( <> {Platform.OS !== 'android' && leadingItem._level > 1 ? [...new Array(leadingItem._level - 1)].map((_, i) => ( )) : null} ) }} ListFooterComponent={ query.isFetching || remoteQuery.isFetching ? ( } /> ) : null } {...(loaded.current && { maintainVisibleContentPosition: { minIndexForVisible: 0 } })} {...(Platform.OS !== 'ios' && { onScrollToIndexFailed: error => { const offset = error.averageItemLength * error.index flRef.current?.scrollToOffset({ offset }) error.index < (ancestorsCache.current?.length || 0) && setTimeout( () => flRef.current?.scrollToIndex({ index: error.index, viewOffset: 50 }), 50 ) } })} /> ) } export default TabSharedToot