{#each items as item (`${item.media_type}-${item.id}`)}
{/each}
diff --git a/src/routes/(app)/_lib/images.ts b/src/routes/(app)/_lib/images.ts
index 5ec3df7..3eb984b 100644
--- a/src/routes/(app)/_lib/images.ts
+++ b/src/routes/(app)/_lib/images.ts
@@ -17,6 +17,7 @@ export function logoUrl(path: string | null | undefined, size: LogoSize = 'w92')
}
export function posterUrl(path: string | null | undefined, size: PosterSize = 'w500') {
+ if (path?.startsWith('https://')) return path;
return path ? images.poster(path, size) : undefined;
}
diff --git a/src/routes/(app)/profile/[actor]/+layout.server.ts b/src/routes/(app)/profile/[actor]/+layout.server.ts
new file mode 100644
index 0000000..6a58b4a
--- /dev/null
+++ b/src/routes/(app)/profile/[actor]/+layout.server.ts
@@ -0,0 +1,62 @@
+import { contrail } from '$lib/contrail';
+import type { PageServerLoad } from './$types';
+
+export const load: PageServerLoad = async ({ params }) => {
+ const actor = params.actor;
+
+ const reviews = await contrail.get('watch.atmo.review.listRecords', {
+ params: {
+ actor,
+ profiles: true
+ }
+ });
+
+ const profile = await contrail.get('watch.atmo.getProfile', {
+ params: {
+ actor
+ }
+ });
+
+ if (!reviews.ok) return;
+
+ const data = reviews.data.records;
+ console.log(data);
+
+ // export type Item = {
+ // id: number;
+ // ref: TmdbRef;
+ // media_type: MediaKind;
+ // title: string;
+ // poster_path: string | null;
+ // backdrop_path: string | null;
+ // overview: string;
+ // order?: number;
+ // };
+
+ const items = data
+ .filter(
+ (review) =>
+ (review.value.creativeWorkType === 'tv_show' ||
+ review.value.creativeWorkType === 'movie') &&
+ review.value.identifiers.tmdbId &&
+ review.value.posterUrl &&
+ review.value.title
+ )
+ .map((review) => {
+ const type = review.value.creativeWorkType == 'tv_show' ? 'tv' : 'movie';
+ const id = (type == 'movie' ? `tmdb:m-` : `tmdb:t-`) + review.value.identifiers.tmdbId;
+
+ return {
+ id: review.value.identifiers.tmdbId,
+ ref: id,
+ media_type: type,
+ title: review.value.title ?? 'Untitled',
+ poster_path: review.value.posterUrl
+ };
+ });
+ console.log(reviews.data.profiles);
+
+ if (!profile.ok) return;
+
+ return { items, profile: profile.data };
+};
diff --git a/src/routes/(app)/profile/[actor]/+page.svelte b/src/routes/(app)/profile/[actor]/+page.svelte
new file mode 100644
index 0000000..2e00355
--- /dev/null
+++ b/src/routes/(app)/profile/[actor]/+page.svelte
@@ -0,0 +1,17 @@
+
+
+
+ {#if data?.items?.length > 0}
+
+ {:else}
+
+ {/if}
+
diff --git a/src/routes/demo/atproto/+page.server.ts b/src/routes/demo/atproto/+page.server.ts
new file mode 100644
index 0000000..bfd9d48
--- /dev/null
+++ b/src/routes/demo/atproto/+page.server.ts
@@ -0,0 +1,66 @@
+import { redirect } from '@sveltejs/kit';
+import type { PageServerLoad } from './$types';
+import { loadHandle, recentRecords, loadHandles, listRecords, parseUri } from '@svelte-atproto/oauth/helper';
+import { memory } from '@svelte-atproto/oauth/server/stores/memory';
+
+// In-memory cache for handle lookups β fine for dev. For prod, swap in
+// cloudflareKV or upstashRedis (any `Store` works).
+const profileCache = memory();
+const COLLECTION = 'xyz.statusphere.status';
+
+export const load: PageServerLoad = async ({ locals, url }) => {
+ if (!locals.did) {
+ const returnTo = encodeURIComponent(url.pathname + url.search);
+ redirect(302, `/demo/atproto/login?returnTo=${returnTo}`);
+ }
+
+ // Lightweight: just resolve the handle from the user's PDS.
+ // For richer Bluesky profile data (display name, avatar) swap to:
+ // import { loadBskyProfile } from '@svelte-atproto/oauth/bsky';
+ // const profile = await loadBskyProfile(locals.did, { cache: profileCache });
+ const handle = await loadHandle(locals.did, { cache: profileCache });
+
+ // Recent statuses globally, from the firehose via UFO. UFO is slightly
+ // behind the firehose, so we also pull the user's own records and merge
+ // them in front so just-published statuses show up immediately.
+ const [globalRecent, own] = await Promise.all([
+ recentRecords(COLLECTION),
+ locals.client
+ ? listRecords({ did: locals.did, collection: COLLECTION, client: locals.client, limit: 10 })
+ : Promise.resolve([])
+ ]);
+
+ const ownAsItems = own.map((r) => {
+ const parts = parseUri(r.uri);
+ const record = r.value as { $type: string; createdAt?: string; [k: string]: unknown };
+ const parsed = typeof record.createdAt === 'string' ? new Date(record.createdAt).getTime() : NaN;
+ const time_us = (Number.isFinite(parsed) ? parsed : Date.now()) * 1000;
+ return {
+ did: parts?.repo ?? locals.did,
+ collection: parts?.collection ?? COLLECTION,
+ rkey: parts?.rkey ?? '',
+ record,
+ time_us
+ };
+ });
+
+ // Own records first so they win the dedupe (UFO can be stale on a record
+ // the user just published). Then sort by time_us so the merged list is
+ // in true reverse-chronological order regardless of source.
+ const seen = new Set
();
+ const merged = [];
+ for (const item of [...ownAsItems, ...globalRecent]) {
+ const key = `${item.did}/${item.rkey}`;
+ if (seen.has(key)) continue;
+ seen.add(key);
+ merged.push(item);
+ }
+ const recent = merged.sort((a, b) => b.time_us - a.time_us);
+
+ // Resolve the author handles in parallel (cached).
+ // For richer profile data, swap `loadHandles` for:
+ // import { loadBskyProfiles } from '@svelte-atproto/oauth/bsky';
+ const authorDids = [...new Set(recent.map((r) => r.did))];
+ const authors = await loadHandles(authorDids, { cache: profileCache });
+ return { did: locals.did, handle, recent, authors };
+};
diff --git a/src/routes/demo/atproto/+page.svelte b/src/routes/demo/atproto/+page.svelte
new file mode 100644
index 0000000..7b21fd4
--- /dev/null
+++ b/src/routes/demo/atproto/+page.svelte
@@ -0,0 +1,52 @@
+
+
+
+
What's your status?
+
Hi {data.handle ?? data.did}.
+
+
+ {#each emojis as emoji}
+
+ {/each}
+
+
+ {#if data.recent?.length}
+
Recent statuses (firehose)
+
+ {#each data.recent as item}
+ -
+ {item.record.status}
+ @{data.authors[item.did] ?? item.did}
+ {item.record.createdAt}
+
+ {/each}
+
+ {/if}
+
+
+
+
Sign in with atproto
+
+
+