steve/tok-to-insta-follower-bridge
1
0
Fork 0
mirror of https://github.com/snachodog/tok-to-insta-follower-bridge.git synced 2025-04-10 14:11:22 -06:00
Code Issues Packages Projects Releases Wiki Activity

add separate handling for list members modal looping

Browse Source
This commit is contained in:
Doug Flowers 2024-11-15 20:34:03 -06:00
parent dad0ece3bd
commit 97d2867870
1 changed files with 36 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
src/lib/hooks/useRetrieveBskyUsers.ts
View File

@ -100,12 +100,28 @@ export const useRetrieveBskyUsers = () => {
const abortControllerRef = React.useRef<AbortController | null>(null); const abortControllerRef = React.useRef<AbortController | null>(null);
const startRetrieveLoop = React.useCallback( const startRetrieveLoop = React.useCallback(
async (queryParam: string) => { async (messageName: string) => {
abortControllerRef.current = new AbortController(); abortControllerRef.current = new AbortController();
const signal = abortControllerRef.current.signal; const signal = abortControllerRef.current.signal;
let index = 0; let index = 0;
const queryParam = MESSAGE_NAME_TO_QUERY_PARAM_MAP[messageName];
let scrollElement: HTMLElement | Window;
let modalScrollInterval: number;
if (messageName === "search_bsky_user_on_list_members_page") {
// select the modal wrapper using viewport selector to avoid conflation with feed in the background
scrollElement = document.querySelector('div[data-viewportview="true"]') as HTMLElement;
// base interval off of intitial scroll height
modalScrollInterval = scrollElement.scrollHeight;
} else {
// for other cases, use the window, no need to cache a scroll interval due to different window scroll logic
scrollElement = window;
}
// loop until we get to the bottom
while (!isBottomReached) { while (!isBottomReached) {
if (signal.aborted) { if (signal.aborted) {
break; break;
@ -119,20 +135,28 @@ export const useRetrieveBskyUsers = () => {
setDetectedXUsers((prev) => [...prev, ...data]); setDetectedXUsers((prev) => [...prev, ...data]);
await retrieveBskyUsers(data); await retrieveBskyUsers(data);
// scroll to bottom // handle scrolling pattern for both modal and window
window.scrollTo(0, document.body.scrollHeight); if (scrollElement instanceof HTMLElement) {
scrollElement.scrollTop += modalScrollInterval;
} else {
window.scrollTo(0, document.body.scrollHeight);
}
// wait for fetching data by x // wait for fetching data by x
await wait(3000); await wait(3000);
// break if bottom is reached // break if bottom is reached
const documentElement = document.documentElement; if (scrollElement instanceof HTMLElement) {
if ( if (scrollElement.scrollTop + scrollElement.clientHeight >= scrollElement.scrollHeight) {
documentElement.scrollTop + documentElement.clientHeight >= setIsBottomReached(true);
documentElement.scrollHeight setLoading(false);
) { }
setIsBottomReached(true); } else {
setLoading(false); const documentElement = document.documentElement;
if (documentElement.scrollTop + documentElement.clientHeight >= documentElement.scrollHeight) {
setIsBottomReached(true);
setLoading(false);
}
} }
index++; index++;
@ -172,7 +196,7 @@ export const useRetrieveBskyUsers = () => {
bskyClient.current = new BskyServiceWorkerClient(session); bskyClient.current = new BskyServiceWorkerClient(session);
startRetrieveLoop(MESSAGE_NAME_TO_QUERY_PARAM_MAP[messageName]).catch( startRetrieveLoop(messageName).catch(
(e) => { (e) => {
console.error(e); console.error(e);
setErrorMessage(e.message); setErrorMessage(e.message);
@ -185,9 +209,7 @@ export const useRetrieveBskyUsers = () => {
}, []); }, []);
const restart = React.useCallback(() => { const restart = React.useCallback(() => {
startRetrieveLoop( startRetrieveLoop(retrievalParams.messageName).catch((e) => {
MESSAGE_NAME_TO_QUERY_PARAM_MAP[retrievalParams.messageName],
).catch((e) => {
setErrorMessage(e.message); setErrorMessage(e.message);
setLoading(false); setLoading(false);
}); });