commit 1da4159654f001244a2112826369903e7b94641b · ptr.pet/nucleus

+1 -1

src/components/BskyPost.svelte

···

       97
        
       			{#if post.ok}

     

       98
        
       				{@const record = post.value}

     

       99
        
       				<span style="color: {color};">@{handle}</span>: {@render embedBadge(record)}

     

       100
       -
       				{record.text}

     

       101
        
       			{:else}

     

       102
        
       				{post.error}

     

       103
        
       			{/if}

···

       97
        
       			{#if post.ok}

     

       98
        
       				{@const record = post.value}

     

       99
        
       				<span style="color: {color};">@{handle}</span>: {@render embedBadge(record)}

     

       100
       +
       				<span title={record.text}>{record.text}</span>

     

       101
        
       			{:else}

     

       102
        
       				{post.error}

     

       103
        
       			{/if}

+60 -37

src/routes/+page.svelte

···

       29
        
       

     

       30
        
       	onMount(async () => {

     

       31
        
       		if ($accounts.length > 0) {

     

       0
        
       
     

       32
        
       			selectedDid = $accounts[0].did;

     

       33
        
       			Promise.all($accounts.map(loginAccount)).then(() => {

     

       34
       -
       				loaderState.isFirstLoad = true;

     

       35
        
       				loadMore();

     

       36
        
       			});

     

       37
        
       		}

     
···

       66
        
       	};

     

       67
        
       

     

       68
        
       	let posts = new SvelteMap<Did, SvelteMap<ResourceUri, AppBskyFeedPost.Main>>();

     

       69
       -
       	let cursors = new SvelteMap<Did, string | undefined>();

     

       70
        
       

     

       71
        
       	const fetchTimeline = async (account: Account) => {

     

       72
        
       		const client = clients.get(account.did);

     

       73
        
       		if (!client) return;

     

       74
        
       

     

       75
        
       		const cursor = cursors.get(account.did);

     

       76
       -
       		const accPosts = await fetchPostsWithBacklinks(client, account.did, cursor, 6);

     

       0
        
       
     

       0
        
       
     

       77
        
       		if (!accPosts.ok) {

     

       78
        
       			throw `failed to fetch posts for account ${account.handle}: ${accPosts.error}`;

     

       79
        
       		}

     

       80
        
       

     

       81
       -
       		// Update cursor for next fetch

     

       82
       -
       		cursors.set(account.did, accPosts.value.cursor);

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       83
        
       

     

       0
        
       
     

       84
        
       		const accTimeline = await hydratePosts(client, accPosts.value.posts);

     

       85
        
       		if (!posts.has(account.did)) {

     

       86
        
       			posts.set(account.did, new SvelteMap(accTimeline));

     
···

       106
        
       			loaderState.error();

     

       107
        
       		} finally {

     

       108
        
       			loading = false;

     

       0
        
       
     

       109
        
       		}

     

       110
        
       	};

     

       111
        
       

     
···

       176
        
       

     

       177
        
       				post.depth = depth;

     

       178
        
       

     

       179
       -
       				if (!childrenMap.has(post.parentUri)) {

     

       180
       -
       					childrenMap.set(post.parentUri, []);

     

       181
       -
       				}

     

       182
        
       				childrenMap.get(post.parentUri)!.push(post);

     

       183
        
       			}

     

       184
        
       

     

       185
        
       			// Sort children by time (newest first)

     

       186
       -
       			for (const children of childrenMap.values()) {

     

       187
       -
       				children.sort((a, b) => b.newestTime - a.newestTime);

     

       188
       -
       			}

     

       189
        
       

     

       190
        
       			// Helper to create a thread from posts

     

       191
        
       			const createThread = (

     
···

       207
        
       				const addWithChildren = (post: ThreadPost) => {

     

       208
        
       					result.push(post);

     

       209
        
       					const children = childrenMap.get(post.uri) || [];

     

       210
       -
       					for (const child of children) {

     

       211
       -
       						addWithChildren(child);

     

       212
       -
       					}

     

       213
        
       				};

     

       214
        
       				addWithChildren(startPost);

     

       215
        
       				return result;

     
···

       334
        
       	</div>

     

       335
        
       

     

       336
        
       	<div class="mt-4 overflow-y-scroll [scrollbar-width:none]" bind:this={scrollContainer}>

     

       337
       -
       		<InfiniteLoader

     

       338
       -
       			{loaderState}

     

       339
       -
       			triggerLoad={loadMore}

     

       340
       -
       			intersectionOptions={{ root: scrollContainer }}

     

       341
       -
       		>

     

       342
       -
       			{@render threadsView()}

     

       343
       -
       			{#snippet loading()}

     

       344
       -
       				<div class="flex justify-center py-4">

     

       345
       -
       					<div

     

       346
       -
       						class="h-8 w-8 animate-spin rounded-full border-4 border-t-transparent"

     

       347
       -
       						style="border-color: {theme.accent} {theme.accent} {theme.accent} transparent;"

     

       348
       -
       					></div>

     

       349
       -
       				</div>

     

       350
       -
       			{/snippet}

     

       351
       -
       			{#snippet error()}

     

       352
       -
       				<div class="flex justify-center py-4">

     

       353
       -
       					<p class="text-sm opacity-80" style="color: {theme.fg};">

     

       354
       -
       						an error occurred while loading posts: {loadError}

     

       355
       -
       					</p>

     

       356
       -
       				</div>

     

       357
       -
       			{/snippet}

     

       358
       -
       		</InfiniteLoader>

     

       359
        
       	</div>

     

       360
        
       </div>

     

       361
        
       

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       362
        
       {#snippet threadsView()}

     

       363
        
       	{#each threads as thread (thread.rootUri)}

     

       364
        
       		<div class="flex {reverseChronological ? 'flex-col' : 'flex-col-reverse'} mb-6.5">

     

       365
        
       			{#if thread.branchParentPost}

     

       366
        
       				{@const post = thread.branchParentPost}

     

       367
        
       				<div class="mb-1.5 flex items-center gap-1.5">

     

       368
       -
       					<span class="text-sm opacity-60" style="color: {theme.fg};"

     

       369
        
       						>{reverseChronological ? '↱' : '↳'}</span

     

       370
        
       					>

     

       371
        
       					<BskyPost

···

       29
        
       

     

       30
        
       	onMount(async () => {

     

       31
        
       		if ($accounts.length > 0) {

     

       32
       +
       			loaderState.status = 'LOADING';

     

       33
        
       			selectedDid = $accounts[0].did;

     

       34
        
       			Promise.all($accounts.map(loginAccount)).then(() => {

     

       0
        
       
     

       35
        
       				loadMore();

     

       36
        
       			});

     

       37
        
       		}

     
···

       66
        
       	};

     

       67
        
       

     

       68
        
       	let posts = new SvelteMap<Did, SvelteMap<ResourceUri, AppBskyFeedPost.Main>>();

     

       69
       +
       	let cursors = new SvelteMap<Did, { value?: string; end: boolean }>();

     

       70
        
       

     

       71
        
       	const fetchTimeline = async (account: Account) => {

     

       72
        
       		const client = clients.get(account.did);

     

       73
        
       		if (!client) return;

     

       74
        
       

     

       75
        
       		const cursor = cursors.get(account.did);

     

       76
       +
       		if (cursor && cursor.end) return;

     

       77
       +
       

     

       78
       +
       		const accPosts = await fetchPostsWithBacklinks(client, account.did, cursor?.value, 6);

     

       79
        
       		if (!accPosts.ok) {

     

       80
        
       			throw `failed to fetch posts for account ${account.handle}: ${accPosts.error}`;

     

       81
        
       		}

     

       82
        
       

     

       83
       +
       		// if the cursor is undefined, we've reached the end of the timeline

     

       84
       +
       		if (!accPosts.value.cursor) {

     

       85
       +
       			cursors.set(account.did, { ...cursor, end: true });

     

       86
       +
       			return;

     

       87
       +
       		}

     

       88
        
       

     

       89
       +
       		cursors.set(account.did, { value: accPosts.value.cursor, end: false });

     

       90
        
       		const accTimeline = await hydratePosts(client, accPosts.value.posts);

     

       91
        
       		if (!posts.has(account.did)) {

     

       92
        
       			posts.set(account.did, new SvelteMap(accTimeline));

     
···

       112
        
       			loaderState.error();

     

       113
        
       		} finally {

     

       114
        
       			loading = false;

     

       115
       +
       			if (cursors.values().every((cursor) => cursor.end)) loaderState.complete();

     

       116
        
       		}

     

       117
        
       	};

     

       118
        
       

     
···

       183
        
       

     

       184
        
       				post.depth = depth;

     

       185
        
       

     

       186
       +
       				if (!childrenMap.has(post.parentUri)) childrenMap.set(post.parentUri, []);

     

       0
        
       
     

       0
        
       
     

       187
        
       				childrenMap.get(post.parentUri)!.push(post);

     

       188
        
       			}

     

       189
        
       

     

       190
        
       			// Sort children by time (newest first)

     

       191
       +
       			childrenMap

     

       192
       +
       				.values()

     

       193
       +
       				.forEach((children) => children.sort((a, b) => b.newestTime - a.newestTime));

     

       194
        
       

     

       195
        
       			// Helper to create a thread from posts

     

       196
        
       			const createThread = (

     
···

       212
        
       				const addWithChildren = (post: ThreadPost) => {

     

       213
        
       					result.push(post);

     

       214
        
       					const children = childrenMap.get(post.uri) || [];

     

       215
       +
       					children.forEach(addWithChildren);

     

       0
        
       
     

       0
        
       
     

       216
        
       				};

     

       217
        
       				addWithChildren(startPost);

     

       218
        
       				return result;

     
···

       337
        
       	</div>

     

       338
        
       

     

       339
        
       	<div class="mt-4 overflow-y-scroll [scrollbar-width:none]" bind:this={scrollContainer}>

     

       340
       +
       		{#if $accounts.length > 0}

     

       341
       +
       			{@render renderThreads()}

     

       342
       +
       		{:else}

     

       343
       +
       			<div class="flex justify-center py-4">

     

       344
       +
       				<p class="text-xl opacity-80" style="color: {theme.fg};">

     

       345
       +
       					<span class="text-4xl">x_x</span> <br /> no accounts are logged in!

     

       346
       +
       				</p>

     

       347
       +
       			</div>

     

       348
       +
       		{/if}

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       349
        
       	</div>

     

       350
        
       </div>

     

       351
        
       

     

       352
       +
       {#snippet renderThreads()}

     

       353
       +
       	<InfiniteLoader

     

       354
       +
       		{loaderState}

     

       355
       +
       		triggerLoad={loadMore}

     

       356
       +
       		loopDetectionTimeout={0}

     

       357
       +
       		intersectionOptions={{ root: scrollContainer }}

     

       358
       +
       	>

     

       359
       +
       		{@render threadsView()}

     

       360
       +
       		{#snippet noData()}

     

       361
       +
       			<div class="flex justify-center py-4">

     

       362
       +
       				<p class="text-xl opacity-80" style="color: {theme.fg};">

     

       363
       +
       					all posts seen! <span class="text-2xl">:o</span>

     

       364
       +
       				</p>

     

       365
       +
       			</div>

     

       366
       +
       		{/snippet}

     

       367
       +
       		{#snippet loading()}

     

       368
       +
       			<div class="flex justify-center">

     

       369
       +
       				<div

     

       370
       +
       					class="h-12 w-12 animate-spin rounded-full border-4 border-t-transparent"

     

       371
       +
       					style="border-color: {theme.accent} {theme.accent} {theme.accent} transparent;"

     

       372
       +
       				></div>

     

       373
       +
       			</div>

     

       374
       +
       		{/snippet}

     

       375
       +
       		{#snippet error()}

     

       376
       +
       			<div class="flex justify-center py-4">

     

       377
       +
       				<p class="text-xl opacity-80" style="color: {theme.fg};">

     

       378
       +
       					<span class="text-4xl">:(</span> <br /> an error occurred while loading posts: {loadError}

     

       379
       +
       				</p>

     

       380
       +
       			</div>

     

       381
       +
       		{/snippet}

     

       382
       +
       	</InfiniteLoader>

     

       383
       +
       {/snippet}

     

       384
       +
       

     

       385
        
       {#snippet threadsView()}

     

       386
        
       	{#each threads as thread (thread.rootUri)}

     

       387
        
       		<div class="flex {reverseChronological ? 'flex-col' : 'flex-col-reverse'} mb-6.5">

     

       388
        
       			{#if thread.branchParentPost}

     

       389
        
       				{@const post = thread.branchParentPost}

     

       390
        
       				<div class="mb-1.5 flex items-center gap-1.5">

     

       391
       +
       					<span class="text-sm text-nowrap opacity-60" style="color: {theme.fg};"

     

       392
        
       						>{reverseChronological ? '↱' : '↳'}</span

     

       393
        
       					>

     

       394
        
       					<BskyPost