update lexicon references and types

This commit is contained in:
Badtz 2025-05-08 15:24:54 -07:00
parent ef6c1a0e18
commit ea255a00e3
5 changed files with 41 additions and 40 deletions

View file

@ -1,13 +1,13 @@
<script lang="ts"> <script lang="ts">
import type { import type {
MeWoachContentAnilist, MySpoorContentExternal,
MeWoachFeedActivity, MySpoorLogActivity,
MeWoachFeedSession MySpoorLogSession
} from '@atcute/client/lexicons'; } from '@atcute/client/lexicons';
export let activity: { export let activity: {
session: MeWoachFeedSession.Record; session: MySpoorLogSession.Record;
activity: MeWoachFeedActivity.Record; activity: MySpoorLogActivity.Record;
content: MeWoachContentAnilist.Main; content: MySpoorContentExternal.Record;
}[]; }[];
</script> </script>
@ -17,16 +17,14 @@
{#each activity as activityItem} {#each activity as activityItem}
<li class="mx-auto mb-2 rounded-sm bg-gray-500 p-4"> <li class="mx-auto mb-2 rounded-sm bg-gray-500 p-4">
<div> <div>
<p>{activityItem.content.id}</p> <p>{activityItem.content.titles}</p>
<p> <p>
Watched episode {activityItem.activity.progress} at {activityItem.activity.performedAt} Watched episode {activityItem.activity.progress} at {activityItem.activity.performedAt}
</p> </p>
{#if activityItem.session.participants?.length} {#if activityItem.session.otherParticipants?.length}
<p>With:</p> <p>With:</p>
{#each activityItem.session.participants ?? [] as participant} {#each activityItem.session.otherParticipants ?? [] as participant}
<a href={'/user/' + participant.uri.split('at://')[1]} <a href={'/user/' + participant.split('at://')[1]}>{participant.split('at://')[1]}</a>
>{participant.uri.split('at://')[1]}</a
>
{/each} {/each}
{/if} {/if}
</div> </div>

View file

@ -1,9 +1,9 @@
<script lang="ts"> <script lang="ts">
import { addActivity } from '$lib/util'; import { addActivity } from '$lib/util';
import type { XRPC } from '@atcute/client'; import type { XRPC } from '@atcute/client';
import type { At, MeWoachFeedSession } from '@atcute/client/lexicons'; import type { At, MySpoorLogSession } from '@atcute/client/lexicons';
export let sessions: { export let sessions: {
record: MeWoachFeedSession.Record; record: MySpoorLogSession.Record;
uri: string; uri: string;
cid: string; cid: string;
progress: number; progress: number;

View file

@ -9,7 +9,7 @@ import {
import { configureOAuth } from '@atcute/oauth-browser-client'; import { configureOAuth } from '@atcute/oauth-browser-client';
import type { At, MeWoachFeedActivity } from '@atcute/client/lexicons'; import type { At, MySpoorLogActivity } from '@atcute/client/lexicons';
const didDocumentResolver = new CompositeDidDocumentResolver({ const didDocumentResolver = new CompositeDidDocumentResolver({
methods: { methods: {
@ -62,7 +62,7 @@ export async function getSessions(rpc: XRPC, did: string) {
} = await rpc.get('com.atproto.repo.listRecords', { } = await rpc.get('com.atproto.repo.listRecords', {
params: { params: {
repo: did, repo: did,
collection: 'me.woach.feed.session' collection: 'my.spoor.log.session'
} }
}); });
return records; return records;
@ -74,7 +74,7 @@ export async function getActivity(rpc: XRPC, did: string) {
} = await rpc.get('com.atproto.repo.listRecords', { } = await rpc.get('com.atproto.repo.listRecords', {
params: { params: {
repo: did, repo: did,
collection: 'me.woach.feed.activity' collection: 'my.spoor.log.activity'
} }
}); });
return records; return records;
@ -89,7 +89,7 @@ export async function resolveSession(rpc: XRPC, uri: At.Uri) {
params: { params: {
repo, repo,
rkey, rkey,
collection: 'me.woach.feed.session' collection: 'my.spoor.log.session'
} }
}); });
return value; return value;
@ -104,7 +104,7 @@ export async function resolveMedia(rpc: XRPC, uri: At.Uri) {
params: { params: {
repo, repo,
rkey, rkey,
collection: 'me.woach.content.anilist' collection: 'my.spoor.content.external'
} }
}); });
return value; return value;
@ -118,10 +118,10 @@ export async function addActivity(
count: number = 1, count: number = 1,
performedAt: string = new Date().toISOString() performedAt: string = new Date().toISOString()
) { ) {
const activityRecord: MeWoachFeedActivity.Record = { const activityRecord: MySpoorLogActivity.Record = {
$type: 'me.woach.feed.activity', $type: 'my.spoor.log.activity',
createdAt: new Date().toISOString(), createdAt: new Date().toISOString(),
progress: count, progress: { $type: 'my.spoor.log.activity#progressIndex', index: count },
session: { cid, uri }, session: { cid, uri },
performedAt performedAt
}; };
@ -129,7 +129,7 @@ export async function addActivity(
const result = await rpc.call('com.atproto.repo.createRecord', { const result = await rpc.call('com.atproto.repo.createRecord', {
data: { data: {
repo: did, repo: did,
collection: 'me.woach.feed.activity', collection: 'my.spoor.log.activity',
record: activityRecord record: activityRecord
} }
}); });
@ -141,18 +141,18 @@ export async function getProgress(rpc: XRPC, did: string, uri: At.Uri) {
const currentProgress = await rpc.get('com.atproto.repo.listRecords', { const currentProgress = await rpc.get('com.atproto.repo.listRecords', {
params: { params: {
repo: did, repo: did,
collection: 'me.woach.feed.activity' collection: 'my.spoor.log.activity'
} }
}); });
const filteredRecords = currentProgress.data.records.filter((a) => { const filteredRecords = currentProgress.data.records.filter((a) => {
const record = a.value as MeWoachFeedActivity.Record; const record = a.value as MySpoorLogActivity.Record;
return record.session.uri === uri; return record.session.uri === uri;
}); });
let lastProgress = 0; let lastProgress = 0;
if (filteredRecords.length > 0) { if (filteredRecords.length > 0) {
const lastUpdate = filteredRecords[0]?.value as MeWoachFeedActivity.Record; const lastUpdate = filteredRecords[0]?.value as MySpoorLogActivity.Record;
lastProgress = Number(lastUpdate.progress); lastProgress = Number(lastUpdate.progress);
return lastProgress; return lastProgress;

View file

@ -39,12 +39,12 @@
console.log('logout'); console.log('logout');
config(); config();
try { try {
const session = await getSession(`did:${userState.did}`, { allowStale: true }); const session = await getSession(`did:${userState.did}:default`, { allowStale: true });
const agent = new OAuthUserAgent(session); const agent = new OAuthUserAgent(session);
await agent.signOut(); await agent.signOut();
} catch (err) { } catch (err) {
deleteStoredSession(`did:${userState.did}`); deleteStoredSession(`did:${userState.did}:default`);
} }
userState.rpc = undefined; userState.rpc = undefined;
userState.agent = undefined; userState.agent = undefined;

View file

@ -9,9 +9,9 @@ import {
} from '$lib/util'; } from '$lib/util';
import type { import type {
ComAtprotoRepoListRecords, ComAtprotoRepoListRecords,
MeWoachContentAnilist, MySpoorContentExternal,
MeWoachFeedActivity, MySpoorLogActivity,
MeWoachFeedSession MySpoorLogSession
} from '@atcute/client/lexicons'; } from '@atcute/client/lexicons';
import type { PageLoad } from './$types'; import type { PageLoad } from './$types';
@ -20,13 +20,13 @@ export const load: PageLoad = async ({ params }) => {
const rpc = await createRPC(did); const rpc = await createRPC(did);
const sessions: { const sessions: {
record: MeWoachFeedSession.Record; record: MySpoorLogSession.Record;
uri: string; uri: string;
cid: string; cid: string;
progress: number; progress: number;
}[] = await Promise.all( }[] = await Promise.all(
(await getSessions(rpc, did)).map(async (record: ComAtprotoRepoListRecords.Record) => ({ (await getSessions(rpc, did)).map(async (record: ComAtprotoRepoListRecords.Record) => ({
record: record.value as MeWoachFeedSession.Record, record: record.value as MySpoorLogSession.Record,
uri: record.uri, uri: record.uri,
cid: record.cid, cid: record.cid,
progress: await getProgress(rpc, did, record.uri) progress: await getProgress(rpc, did, record.uri)
@ -34,21 +34,24 @@ export const load: PageLoad = async ({ params }) => {
); );
const activity: { const activity: {
session: MeWoachFeedSession.Record; session: MySpoorLogSession.Record;
activity: MeWoachFeedActivity.Record; activity: MySpoorLogActivity.Record;
content: MeWoachContentAnilist.Main; content: MySpoorContentExternal.Record;
}[] = await Promise.all( }[] = await Promise.all(
(await getActivity(rpc, did)).map(async (activityRecord: ComAtprotoRepoListRecords.Record) => { (await getActivity(rpc, did)).map(async (activityRecord: ComAtprotoRepoListRecords.Record) => {
const session = (await resolveSession( const session = (await resolveSession(
rpc, rpc,
(activityRecord.value as MeWoachFeedActivity.Record).session.uri (activityRecord.value as MySpoorLogActivity.Record).session.uri
)) as MeWoachFeedSession.Record; )) as MySpoorLogSession.Record;
const content = (await resolveMedia(rpc, session.content.uri)) as MeWoachContentAnilist.Main; const content = (await resolveMedia(
rpc,
session.content.uri
)) as MySpoorContentExternal.Record;
return { return {
session, session,
activity: activityRecord.value as MeWoachFeedActivity.Record, activity: activityRecord.value as MySpoorLogActivity.Record,
content content
}; };
}) })