👁️
start on replies
+665
+72
src/lib/atproto-client.ts
+72
src/lib/atproto-client.ts
···
16
16
ComDeckbelcherActorProfile,
17
17
ComDeckbelcherCollectionList,
18
18
ComDeckbelcherDeckList,
19
+
ComDeckbelcherSocialComment,
19
20
ComDeckbelcherSocialLike,
21
+
ComDeckbelcherSocialReply,
20
22
} from "./lexicons/index";
21
23
22
24
type AtUri = `at://${string}`;
···
570
572
ComDeckbelcherActorProfile.mainSchema,
571
573
);
572
574
}
575
+
576
+
// ============================================================================
577
+
// Comment Records (top-level comments)
578
+
// ============================================================================
579
+
580
+
export type CommentRecordResponse =
581
+
RecordResponse<ComDeckbelcherSocialComment.Main>;
582
+
583
+
export function getCommentRecord(did: Did, rkey: Rkey) {
584
+
return getRecord(did, rkey, ComDeckbelcherSocialComment.mainSchema);
585
+
}
586
+
587
+
export function createCommentRecord(
588
+
agent: OAuthUserAgent,
589
+
record: ComDeckbelcherSocialComment.Main,
590
+
) {
591
+
return createRecord(agent, record, ComDeckbelcherSocialComment.mainSchema);
592
+
}
593
+
594
+
export function updateCommentRecord(
595
+
agent: OAuthUserAgent,
596
+
rkey: Rkey,
597
+
record: ComDeckbelcherSocialComment.Main,
598
+
) {
599
+
return updateRecord(
600
+
agent,
601
+
rkey,
602
+
record,
603
+
ComDeckbelcherSocialComment.mainSchema,
604
+
);
605
+
}
606
+
607
+
export function deleteCommentRecord(agent: OAuthUserAgent, rkey: Rkey) {
608
+
return deleteRecord(agent, rkey, ComDeckbelcherSocialComment.mainSchema);
609
+
}
610
+
611
+
// ============================================================================
612
+
// Reply Records (threaded replies to comments)
613
+
// ============================================================================
614
+
615
+
export type ReplyRecordResponse =
616
+
RecordResponse<ComDeckbelcherSocialReply.Main>;
617
+
618
+
export function getReplyRecord(did: Did, rkey: Rkey) {
619
+
return getRecord(did, rkey, ComDeckbelcherSocialReply.mainSchema);
620
+
}
621
+
622
+
export function createReplyRecord(
623
+
agent: OAuthUserAgent,
624
+
record: ComDeckbelcherSocialReply.Main,
625
+
) {
626
+
return createRecord(agent, record, ComDeckbelcherSocialReply.mainSchema);
627
+
}
628
+
629
+
export function updateReplyRecord(
630
+
agent: OAuthUserAgent,
631
+
rkey: Rkey,
632
+
record: ComDeckbelcherSocialReply.Main,
633
+
) {
634
+
return updateRecord(
635
+
agent,
636
+
rkey,
637
+
record,
638
+
ComDeckbelcherSocialReply.mainSchema,
639
+
);
640
+
}
641
+
642
+
export function deleteReplyRecord(agent: OAuthUserAgent, rkey: Rkey) {
643
+
return deleteRecord(agent, rkey, ComDeckbelcherSocialReply.mainSchema);
644
+
}
+20
src/lib/constellation-client.ts
+20
src/lib/constellation-client.ts
···
7
7
import {
8
8
ComDeckbelcherCollectionList,
9
9
ComDeckbelcherDeckList,
10
+
ComDeckbelcherSocialComment,
10
11
ComDeckbelcherSocialLike,
12
+
ComDeckbelcherSocialReply,
11
13
} from "./lexicons/index";
12
14
13
15
const CONSTELLATION_BASE = "https://constellation.microcosm.blue";
···
23
25
export const LIKE_NSID = getCollectionFromSchema(
24
26
ComDeckbelcherSocialLike.mainSchema,
25
27
);
28
+
export const COMMENT_NSID = getCollectionFromSchema(
29
+
ComDeckbelcherSocialComment.mainSchema,
30
+
);
31
+
export const REPLY_NSID = getCollectionFromSchema(
32
+
ComDeckbelcherSocialReply.mainSchema,
33
+
);
26
34
27
35
// Path constants for DeckBelcher collections
28
36
// Constellation includes $type in paths for union array elements
···
35
43
// Like paths (subject is a union but NOT an array, so no [$type] notation)
36
44
export const LIKE_CARD_PATH = ".subject.ref.oracleUri";
37
45
export const LIKE_RECORD_PATH = ".subject.ref.uri";
46
+
47
+
// Comment paths (top-level comments, subject is union)
48
+
// Query comments on a card (global card discussion)
49
+
export const COMMENT_CARD_PATH = ".subject.ref.oracleUri";
50
+
// Query comments on a record (deck, collection, etc)
51
+
export const COMMENT_RECORD_PATH = ".subject.ref.uri";
52
+
53
+
// Reply paths (threaded replies)
54
+
// Query by root to get all replies in a thread (for thread expansion)
55
+
export const REPLY_ROOT_PATH = ".root.uri";
56
+
// Query by parent to get direct replies to a specific comment/reply
57
+
export const REPLY_PARENT_PATH = ".parent.uri";
38
58
39
59
export interface BacklinkRecord {
40
60
did: string;
+116
src/lib/constellation-queries.ts
+116
src/lib/constellation-queries.ts
···
14
14
COLLECTION_LIST_CARD_PATH,
15
15
COLLECTION_LIST_DECK_PATH,
16
16
COLLECTION_LIST_NSID,
17
+
COMMENT_CARD_PATH,
18
+
COMMENT_NSID,
19
+
COMMENT_RECORD_PATH,
17
20
DECK_LIST_CARD_PATH,
18
21
DECK_LIST_NSID,
19
22
getBacklinks,
···
21
24
LIKE_CARD_PATH,
22
25
LIKE_NSID,
23
26
LIKE_RECORD_PATH,
27
+
REPLY_NSID,
28
+
REPLY_PARENT_PATH,
29
+
REPLY_ROOT_PATH,
24
30
} from "./constellation-client";
25
31
import type { OracleUri } from "./scryfall-types";
26
32
import { useAuth } from "./useAuth";
···
394
400
: null,
395
401
] as const);
396
402
}
403
+
404
+
// ============================================================================
405
+
// Comment Queries
406
+
// ============================================================================
407
+
408
+
function getCommentPathForItemType(itemType: SocialItemType): string {
409
+
return itemType === "card" ? COMMENT_CARD_PATH : COMMENT_RECORD_PATH;
410
+
}
411
+
412
+
/**
413
+
* Query options for getting top-level comment count for an item
414
+
*/
415
+
export function itemCommentCountQueryOptions<T extends SocialItemType>(
416
+
itemUri: T extends "card" ? CardItemUri : DeckItemUri,
417
+
itemType: T,
418
+
) {
419
+
return queryOptions({
420
+
queryKey: ["constellation", "commentCount", itemUri] as const,
421
+
queryFn: async (): Promise<number> => {
422
+
const result = await getLinksCount({
423
+
target: itemUri,
424
+
collection: COMMENT_NSID,
425
+
path: getCommentPathForItemType(itemType),
426
+
});
427
+
428
+
if (!result.success) {
429
+
throw result.error;
430
+
}
431
+
432
+
return result.data.total;
433
+
},
434
+
staleTime: 60 * 1000,
435
+
});
436
+
}
437
+
438
+
/**
439
+
* Infinite query for top-level comments on an item (card or deck/collection)
440
+
*/
441
+
export function itemCommentsQueryOptions<T extends SocialItemType>(
442
+
itemUri: T extends "card" ? CardItemUri : DeckItemUri,
443
+
itemType: T,
444
+
) {
445
+
return infiniteQueryOptions({
446
+
queryKey: ["constellation", "comments", itemUri] as const,
447
+
queryFn: async ({ pageParam }) => {
448
+
const result = await getBacklinks({
449
+
subject: itemUri,
450
+
source: buildSource(COMMENT_NSID, getCommentPathForItemType(itemType)),
451
+
limit: 25,
452
+
cursor: pageParam,
453
+
});
454
+
if (!result.success) throw result.error;
455
+
return result.data;
456
+
},
457
+
initialPageParam: undefined as string | undefined,
458
+
getNextPageParam: (lastPage) => lastPage.cursor ?? undefined,
459
+
staleTime: 60 * 1000,
460
+
});
461
+
}
462
+
463
+
// ============================================================================
464
+
// Reply Queries (for threading)
465
+
// ============================================================================
466
+
467
+
/**
468
+
* Infinite query for all replies in a thread (by root comment URI).
469
+
* Use this to expand an entire thread - returns all replies regardless of depth.
470
+
*/
471
+
export function threadRepliesQueryOptions(rootCommentUri: string) {
472
+
return infiniteQueryOptions({
473
+
queryKey: ["constellation", "threadReplies", rootCommentUri] as const,
474
+
queryFn: async ({ pageParam }) => {
475
+
const result = await getBacklinks({
476
+
subject: rootCommentUri,
477
+
source: buildSource(REPLY_NSID, REPLY_ROOT_PATH),
478
+
limit: 50,
479
+
cursor: pageParam,
480
+
});
481
+
if (!result.success) throw result.error;
482
+
return result.data;
483
+
},
484
+
initialPageParam: undefined as string | undefined,
485
+
getNextPageParam: (lastPage) => lastPage.cursor ?? undefined,
486
+
staleTime: 60 * 1000,
487
+
});
488
+
}
489
+
490
+
/**
491
+
* Query options for getting direct reply count for any comment or reply.
492
+
* Use this to show "X replies" on a specific comment.
493
+
*/
494
+
export function directReplyCountQueryOptions(commentOrReplyUri: string) {
495
+
return queryOptions({
496
+
queryKey: ["constellation", "directReplyCount", commentOrReplyUri] as const,
497
+
queryFn: async (): Promise<number> => {
498
+
const result = await getLinksCount({
499
+
target: commentOrReplyUri,
500
+
collection: REPLY_NSID,
501
+
path: REPLY_PARENT_PATH,
502
+
});
503
+
504
+
if (!result.success) {
505
+
throw result.error;
506
+
}
507
+
508
+
return result.data.total;
509
+
},
510
+
staleTime: 60 * 1000,
511
+
});
512
+
}
+2
src/lib/lexicons/index.ts
+2
src/lib/lexicons/index.ts
···
5
5
export * as ComDeckbelcherDefs from "./types/com/deckbelcher/defs.js";
6
6
export * as ComDeckbelcherRichtext from "./types/com/deckbelcher/richtext.js";
7
7
export * as ComDeckbelcherRichtextFacet from "./types/com/deckbelcher/richtext/facet.js";
8
+
export * as ComDeckbelcherSocialComment from "./types/com/deckbelcher/social/comment.js";
8
9
export * as ComDeckbelcherSocialLike from "./types/com/deckbelcher/social/like.js";
10
+
export * as ComDeckbelcherSocialReply from "./types/com/deckbelcher/social/reply.js";