leaflet.pub
a tool for shared writing and social publishing
Merge branch 'feature/at-mentions' of https://github.com/hyperlink-academy/minilink into feature/at-mentions
cozylittle.house
+56
actions/deleteLeaflet.ts
+56
actions/deleteLeaflet.ts
···
16
export async function deleteLeaflet(permission_token: PermissionToken) {
17
const client = await pool.connect();
18
const db = drizzle(client);
19
+
20
+
// Get the current user's identity
21
+
let identity = await getIdentityData();
22
+
23
+
// Check publication and document ownership in one query
24
+
let { data: tokenData } = await supabaseServerClient
25
+
.from("permission_tokens")
26
+
.select(
27
+
`
28
+
id,
29
+
leaflets_in_publications(publication, publications!inner(identity_did)),
30
+
leaflets_to_documents(document, documents!inner(uri))
31
+
`,
32
+
)
33
+
.eq("id", permission_token.id)
34
+
.single();
35
+
36
+
if (tokenData) {
37
+
// Check if leaflet is in a publication
38
+
const leafletInPubs = tokenData.leaflets_in_publications || [];
39
+
if (leafletInPubs.length > 0) {
40
+
if (!identity) {
41
+
throw new Error(
42
+
"Unauthorized: You must be logged in to delete a leaflet in a publication",
43
+
);
44
+
}
45
+
const isOwner = leafletInPubs.some(
46
+
(pub: any) => pub.publications.identity_did === identity.atp_did,
47
+
);
48
+
if (!isOwner) {
49
+
throw new Error(
50
+
"Unauthorized: You must own the publication to delete this leaflet",
51
+
);
52
+
}
53
+
}
54
+
55
+
// Check if there's a standalone published document
56
+
const leafletDocs = tokenData.leaflets_to_documents || [];
57
+
if (leafletDocs.length > 0) {
58
+
if (!identity) {
59
+
throw new Error(
60
+
"Unauthorized: You must be logged in to delete a published leaflet",
61
+
);
62
+
}
63
+
for (let leafletDoc of leafletDocs) {
64
+
const docUri = leafletDoc.documents?.uri;
65
+
// Extract the DID from the document URI (format: at://did:plc:xxx/...)
66
+
if (docUri && identity.atp_did && !docUri.includes(identity.atp_did)) {
67
+
throw new Error(
68
+
"Unauthorized: You must own the published document to delete this leaflet",
69
+
);
70
+
}
71
+
}
72
+
}
73
+
}
74
+
75
await db.transaction(async (tx) => {
76
let [token] = await tx
77
.select()
+14
-6
app/(home-pages)/home/LeafletList/LeafletOptions.tsx
+14
-6
app/(home-pages)/home/LeafletList/LeafletOptions.tsx
···
86
const pubStatus = useLeafletPublicationStatus();
87
const toaster = useToaster();
88
const { setArchived } = useArchiveMutations();
89
const tokenId = pubStatus?.token.id;
90
const itemType = pubStatus?.draftInPublication ? "Draft" : "Leaflet";
91
92
return (
93
<>
···
133
<ArchiveSmall />
134
{!props.archived ? " Archive" : "Unarchive"} {itemType}
135
</MenuItem>
136
-
<DeleteForeverMenuItem
137
-
onSelect={(e) => {
138
-
e.preventDefault();
139
-
props.setState("areYouSure");
140
-
}}
141
-
/>
142
</>
143
);
144
};
···
86
const pubStatus = useLeafletPublicationStatus();
87
const toaster = useToaster();
88
const { setArchived } = useArchiveMutations();
89
+
const { identity } = useIdentityData();
90
const tokenId = pubStatus?.token.id;
91
const itemType = pubStatus?.draftInPublication ? "Draft" : "Leaflet";
92
+
93
+
// Check if this is a published post/document and if user is the owner
94
+
const isPublishedPostOwner =
95
+
!!identity?.atp_did && !!pubStatus?.documentUri?.includes(identity.atp_did);
96
+
const canDelete = !pubStatus?.documentUri || isPublishedPostOwner;
97
98
return (
99
<>
···
139
<ArchiveSmall />
140
{!props.archived ? " Archive" : "Unarchive"} {itemType}
141
</MenuItem>
142
+
{canDelete && (
143
+
<DeleteForeverMenuItem
144
+
onSelect={(e) => {
145
+
e.preventDefault();
146
+
props.setState("areYouSure");
147
+
}}
148
+
/>
149
+
)}
150
</>
151
);
152
};
+3
-1
app/(home-pages)/notifications/MentionNotification.tsx
+3
-1
app/(home-pages)/notifications/MentionNotification.tsx
+1
-1
components/ActionBar/Publications.tsx
+1
-1
components/ActionBar/Publications.tsx
+7
-1
components/Mention.tsx
+7
-1
components/Mention.tsx
···
442
const [suggestions, setSuggestions] = useState<Array<Mention>>([]);
443
const [scope, setScope] = useState<MentionScope>({ type: "default" });
444
445
useDebouncedEffect(
446
async () => {
447
if (!query && scope.type === "default") {
···
503
suggestionIndex,
504
setSuggestionIndex,
505
scope,
506
-
setScope,
507
};
508
}
···
442
const [suggestions, setSuggestions] = useState<Array<Mention>>([]);
443
const [scope, setScope] = useState<MentionScope>({ type: "default" });
444
445
+
// Clear suggestions immediately when scope changes
446
+
const setScopeAndClear = useCallback((newScope: MentionScope) => {
447
+
setSuggestions([]);
448
+
setScope(newScope);
449
+
}, []);
450
+
451
useDebouncedEffect(
452
async () => {
453
if (!query && scope.type === "default") {
···
509
suggestionIndex,
510
setSuggestionIndex,
511
scope,
512
+
setScope: setScopeAndClear,
513
};
514
}
+62
-44
package-lock.json
+62
-44
package-lock.json
···
48
"inngest": "^3.40.1",
49
"ioredis": "^5.6.1",
50
"katex": "^0.16.22",
51
"linkifyjs": "^4.2.0",
52
"luxon": "^3.7.2",
53
"multiformats": "^13.3.2",
54
-
"next": "16.0.3",
55
"pg": "^8.16.3",
56
"prosemirror-commands": "^1.5.2",
57
"prosemirror-inputrules": "^1.4.0",
···
59
"prosemirror-model": "^1.21.0",
60
"prosemirror-schema-basic": "^1.2.2",
61
"prosemirror-state": "^1.4.3",
62
-
"react": "19.2.0",
63
"react-aria-components": "^1.8.0",
64
"react-day-picker": "^9.3.0",
65
"react-dom": "19.2.0",
···
2734
}
2735
},
2736
"node_modules/@next/env": {
2737
-
"version": "16.0.3",
2738
-
"resolved": "https://registry.npmjs.org/@next/env/-/env-16.0.3.tgz",
2739
-
"integrity": "sha512-IqgtY5Vwsm14mm/nmQaRMmywCU+yyMIYfk3/MHZ2ZTJvwVbBn3usZnjMi1GacrMVzVcAxJShTCpZlPs26EdEjQ=="
2740
},
2741
"node_modules/@next/eslint-plugin-next": {
2742
"version": "16.0.3",
···
2804
}
2805
},
2806
"node_modules/@next/swc-darwin-arm64": {
2807
-
"version": "16.0.3",
2808
-
"resolved": "https://registry.npmjs.org/@next/swc-darwin-arm64/-/swc-darwin-arm64-16.0.3.tgz",
2809
-
"integrity": "sha512-MOnbd92+OByu0p6QBAzq1ahVWzF6nyfiH07dQDez4/Nku7G249NjxDVyEfVhz8WkLiOEU+KFVnqtgcsfP2nLXg==",
2810
"cpu": [
2811
"arm64"
2812
],
2813
"optional": true,
2814
"os": [
2815
"darwin"
···
2819
}
2820
},
2821
"node_modules/@next/swc-darwin-x64": {
2822
-
"version": "16.0.3",
2823
-
"resolved": "https://registry.npmjs.org/@next/swc-darwin-x64/-/swc-darwin-x64-16.0.3.tgz",
2824
-
"integrity": "sha512-i70C4O1VmbTivYdRlk+5lj9xRc2BlK3oUikt3yJeHT1unL4LsNtN7UiOhVanFdc7vDAgZn1tV/9mQwMkWOJvHg==",
2825
"cpu": [
2826
"x64"
2827
],
2828
"optional": true,
2829
"os": [
2830
"darwin"
···
2834
}
2835
},
2836
"node_modules/@next/swc-linux-arm64-gnu": {
2837
-
"version": "16.0.3",
2838
-
"resolved": "https://registry.npmjs.org/@next/swc-linux-arm64-gnu/-/swc-linux-arm64-gnu-16.0.3.tgz",
2839
-
"integrity": "sha512-O88gCZ95sScwD00mn/AtalyCoykhhlokxH/wi1huFK+rmiP5LAYVs/i2ruk7xST6SuXN4NI5y4Xf5vepb2jf6A==",
2840
"cpu": [
2841
"arm64"
2842
],
2843
"optional": true,
2844
"os": [
2845
"linux"
···
2849
}
2850
},
2851
"node_modules/@next/swc-linux-arm64-musl": {
2852
-
"version": "16.0.3",
2853
-
"resolved": "https://registry.npmjs.org/@next/swc-linux-arm64-musl/-/swc-linux-arm64-musl-16.0.3.tgz",
2854
-
"integrity": "sha512-CEErFt78S/zYXzFIiv18iQCbRbLgBluS8z1TNDQoyPi8/Jr5qhR3e8XHAIxVxPBjDbEMITprqELVc5KTfFj0gg==",
2855
"cpu": [
2856
"arm64"
2857
],
2858
"optional": true,
2859
"os": [
2860
"linux"
···
2864
}
2865
},
2866
"node_modules/@next/swc-linux-x64-gnu": {
2867
-
"version": "16.0.3",
2868
-
"resolved": "https://registry.npmjs.org/@next/swc-linux-x64-gnu/-/swc-linux-x64-gnu-16.0.3.tgz",
2869
-
"integrity": "sha512-Tc3i+nwt6mQ+Dwzcri/WNDj56iWdycGVh5YwwklleClzPzz7UpfaMw1ci7bLl6GRYMXhWDBfe707EXNjKtiswQ==",
2870
"cpu": [
2871
"x64"
2872
],
2873
"optional": true,
2874
"os": [
2875
"linux"
···
2879
}
2880
},
2881
"node_modules/@next/swc-linux-x64-musl": {
2882
-
"version": "16.0.3",
2883
-
"resolved": "https://registry.npmjs.org/@next/swc-linux-x64-musl/-/swc-linux-x64-musl-16.0.3.tgz",
2884
-
"integrity": "sha512-zTh03Z/5PBBPdTurgEtr6nY0vI9KR9Ifp/jZCcHlODzwVOEKcKRBtQIGrkc7izFgOMuXDEJBmirwpGqdM/ZixA==",
2885
"cpu": [
2886
"x64"
2887
],
2888
"optional": true,
2889
"os": [
2890
"linux"
···
2894
}
2895
},
2896
"node_modules/@next/swc-win32-arm64-msvc": {
2897
-
"version": "16.0.3",
2898
-
"resolved": "https://registry.npmjs.org/@next/swc-win32-arm64-msvc/-/swc-win32-arm64-msvc-16.0.3.tgz",
2899
-
"integrity": "sha512-Jc1EHxtZovcJcg5zU43X3tuqzl/sS+CmLgjRP28ZT4vk869Ncm2NoF8qSTaL99gh6uOzgM99Shct06pSO6kA6g==",
2900
"cpu": [
2901
"arm64"
2902
],
2903
"optional": true,
2904
"os": [
2905
"win32"
···
2909
}
2910
},
2911
"node_modules/@next/swc-win32-x64-msvc": {
2912
-
"version": "16.0.3",
2913
-
"resolved": "https://registry.npmjs.org/@next/swc-win32-x64-msvc/-/swc-win32-x64-msvc-16.0.3.tgz",
2914
-
"integrity": "sha512-N7EJ6zbxgIYpI/sWNzpVKRMbfEGgsWuOIvzkML7wxAAZhPk1Msxuo/JDu1PKjWGrAoOLaZcIX5s+/pF5LIbBBg==",
2915
"cpu": [
2916
"x64"
2917
],
2918
"optional": true,
2919
"os": [
2920
"win32"
···
13360
"json-buffer": "3.0.1"
13361
}
13362
},
13363
"node_modules/language-subtag-registry": {
13364
"version": "0.3.23",
13365
"resolved": "https://registry.npmjs.org/language-subtag-registry/-/language-subtag-registry-0.3.23.tgz",
···
15108
}
15109
},
15110
"node_modules/next": {
15111
-
"version": "16.0.3",
15112
-
"resolved": "https://registry.npmjs.org/next/-/next-16.0.3.tgz",
15113
-
"integrity": "sha512-Ka0/iNBblPFcIubTA1Jjh6gvwqfjrGq1Y2MTI5lbjeLIAfmC+p5bQmojpRZqgHHVu5cG4+qdIiwXiBSm/8lZ3w==",
15114
"dependencies": {
15115
-
"@next/env": "16.0.3",
15116
"@swc/helpers": "0.5.15",
15117
"caniuse-lite": "^1.0.30001579",
15118
"postcss": "8.4.31",
···
15125
"node": ">=20.9.0"
15126
},
15127
"optionalDependencies": {
15128
-
"@next/swc-darwin-arm64": "16.0.3",
15129
-
"@next/swc-darwin-x64": "16.0.3",
15130
-
"@next/swc-linux-arm64-gnu": "16.0.3",
15131
-
"@next/swc-linux-arm64-musl": "16.0.3",
15132
-
"@next/swc-linux-x64-gnu": "16.0.3",
15133
-
"@next/swc-linux-x64-musl": "16.0.3",
15134
-
"@next/swc-win32-arm64-msvc": "16.0.3",
15135
-
"@next/swc-win32-x64-msvc": "16.0.3",
15136
"sharp": "^0.34.4"
15137
},
15138
"peerDependencies": {
···
16321
}
16322
},
16323
"node_modules/react": {
16324
-
"version": "19.2.0",
16325
-
"resolved": "https://registry.npmjs.org/react/-/react-19.2.0.tgz",
16326
-
"integrity": "sha512-tmbWg6W31tQLeB5cdIBOicJDJRR2KzXsV7uSK9iNfLWQ5bIZfxuPEHp7M8wiHyHnn0DD1i7w3Zmin0FtkrwoCQ==",
16327
"engines": {
16328
"node": ">=0.10.0"
16329
}
···
48
"inngest": "^3.40.1",
49
"ioredis": "^5.6.1",
50
"katex": "^0.16.22",
51
+
"l": "^0.6.0",
52
"linkifyjs": "^4.2.0",
53
"luxon": "^3.7.2",
54
"multiformats": "^13.3.2",
55
+
"next": "^16.0.7",
56
"pg": "^8.16.3",
57
"prosemirror-commands": "^1.5.2",
58
"prosemirror-inputrules": "^1.4.0",
···
60
"prosemirror-model": "^1.21.0",
61
"prosemirror-schema-basic": "^1.2.2",
62
"prosemirror-state": "^1.4.3",
63
+
"react": "19.2.1",
64
"react-aria-components": "^1.8.0",
65
"react-day-picker": "^9.3.0",
66
"react-dom": "19.2.0",
···
2735
}
2736
},
2737
"node_modules/@next/env": {
2738
+
"version": "16.0.7",
2739
+
"resolved": "https://registry.npmjs.org/@next/env/-/env-16.0.7.tgz",
2740
+
"integrity": "sha512-gpaNgUh5nftFKRkRQGnVi5dpcYSKGcZZkQffZ172OrG/XkrnS7UBTQ648YY+8ME92cC4IojpI2LqTC8sTDhAaw==",
2741
+
"license": "MIT"
2742
},
2743
"node_modules/@next/eslint-plugin-next": {
2744
"version": "16.0.3",
···
2806
}
2807
},
2808
"node_modules/@next/swc-darwin-arm64": {
2809
+
"version": "16.0.7",
2810
+
"resolved": "https://registry.npmjs.org/@next/swc-darwin-arm64/-/swc-darwin-arm64-16.0.7.tgz",
2811
+
"integrity": "sha512-LlDtCYOEj/rfSnEn/Idi+j1QKHxY9BJFmxx7108A6D8K0SB+bNgfYQATPk/4LqOl4C0Wo3LACg2ie6s7xqMpJg==",
2812
"cpu": [
2813
"arm64"
2814
],
2815
+
"license": "MIT",
2816
"optional": true,
2817
"os": [
2818
"darwin"
···
2822
}
2823
},
2824
"node_modules/@next/swc-darwin-x64": {
2825
+
"version": "16.0.7",
2826
+
"resolved": "https://registry.npmjs.org/@next/swc-darwin-x64/-/swc-darwin-x64-16.0.7.tgz",
2827
+
"integrity": "sha512-rtZ7BhnVvO1ICf3QzfW9H3aPz7GhBrnSIMZyr4Qy6boXF0b5E3QLs+cvJmg3PsTCG2M1PBoC+DANUi4wCOKXpA==",
2828
"cpu": [
2829
"x64"
2830
],
2831
+
"license": "MIT",
2832
"optional": true,
2833
"os": [
2834
"darwin"
···
2838
}
2839
},
2840
"node_modules/@next/swc-linux-arm64-gnu": {
2841
+
"version": "16.0.7",
2842
+
"resolved": "https://registry.npmjs.org/@next/swc-linux-arm64-gnu/-/swc-linux-arm64-gnu-16.0.7.tgz",
2843
+
"integrity": "sha512-mloD5WcPIeIeeZqAIP5c2kdaTa6StwP4/2EGy1mUw8HiexSHGK/jcM7lFuS3u3i2zn+xH9+wXJs6njO7VrAqww==",
2844
"cpu": [
2845
"arm64"
2846
],
2847
+
"license": "MIT",
2848
"optional": true,
2849
"os": [
2850
"linux"
···
2854
}
2855
},
2856
"node_modules/@next/swc-linux-arm64-musl": {
2857
+
"version": "16.0.7",
2858
+
"resolved": "https://registry.npmjs.org/@next/swc-linux-arm64-musl/-/swc-linux-arm64-musl-16.0.7.tgz",
2859
+
"integrity": "sha512-+ksWNrZrthisXuo9gd1XnjHRowCbMtl/YgMpbRvFeDEqEBd523YHPWpBuDjomod88U8Xliw5DHhekBC3EOOd9g==",
2860
"cpu": [
2861
"arm64"
2862
],
2863
+
"license": "MIT",
2864
"optional": true,
2865
"os": [
2866
"linux"
···
2870
}
2871
},
2872
"node_modules/@next/swc-linux-x64-gnu": {
2873
+
"version": "16.0.7",
2874
+
"resolved": "https://registry.npmjs.org/@next/swc-linux-x64-gnu/-/swc-linux-x64-gnu-16.0.7.tgz",
2875
+
"integrity": "sha512-4WtJU5cRDxpEE44Ana2Xro1284hnyVpBb62lIpU5k85D8xXxatT+rXxBgPkc7C1XwkZMWpK5rXLXTh9PFipWsA==",
2876
"cpu": [
2877
"x64"
2878
],
2879
+
"license": "MIT",
2880
"optional": true,
2881
"os": [
2882
"linux"
···
2886
}
2887
},
2888
"node_modules/@next/swc-linux-x64-musl": {
2889
+
"version": "16.0.7",
2890
+
"resolved": "https://registry.npmjs.org/@next/swc-linux-x64-musl/-/swc-linux-x64-musl-16.0.7.tgz",
2891
+
"integrity": "sha512-HYlhqIP6kBPXalW2dbMTSuB4+8fe+j9juyxwfMwCe9kQPPeiyFn7NMjNfoFOfJ2eXkeQsoUGXg+O2SE3m4Qg2w==",
2892
"cpu": [
2893
"x64"
2894
],
2895
+
"license": "MIT",
2896
"optional": true,
2897
"os": [
2898
"linux"
···
2902
}
2903
},
2904
"node_modules/@next/swc-win32-arm64-msvc": {
2905
+
"version": "16.0.7",
2906
+
"resolved": "https://registry.npmjs.org/@next/swc-win32-arm64-msvc/-/swc-win32-arm64-msvc-16.0.7.tgz",
2907
+
"integrity": "sha512-EviG+43iOoBRZg9deGauXExjRphhuYmIOJ12b9sAPy0eQ6iwcPxfED2asb/s2/yiLYOdm37kPaiZu8uXSYPs0Q==",
2908
"cpu": [
2909
"arm64"
2910
],
2911
+
"license": "MIT",
2912
"optional": true,
2913
"os": [
2914
"win32"
···
2918
}
2919
},
2920
"node_modules/@next/swc-win32-x64-msvc": {
2921
+
"version": "16.0.7",
2922
+
"resolved": "https://registry.npmjs.org/@next/swc-win32-x64-msvc/-/swc-win32-x64-msvc-16.0.7.tgz",
2923
+
"integrity": "sha512-gniPjy55zp5Eg0896qSrf3yB1dw4F/3s8VK1ephdsZZ129j2n6e1WqCbE2YgcKhW9hPB9TVZENugquWJD5x0ug==",
2924
"cpu": [
2925
"x64"
2926
],
2927
+
"license": "MIT",
2928
"optional": true,
2929
"os": [
2930
"win32"
···
13370
"json-buffer": "3.0.1"
13371
}
13372
},
13373
+
"node_modules/l": {
13374
+
"version": "0.6.0",
13375
+
"resolved": "https://registry.npmjs.org/l/-/l-0.6.0.tgz",
13376
+
"integrity": "sha512-rB5disIyfKRBQ1xcedByHCcAmPWy2NPnjWo5u4mVVIPtathROHyfHjkloqSBT49mLnSRnupkpoIUOFCL7irCVQ==",
13377
+
"license": "MIT"
13378
+
},
13379
"node_modules/language-subtag-registry": {
13380
"version": "0.3.23",
13381
"resolved": "https://registry.npmjs.org/language-subtag-registry/-/language-subtag-registry-0.3.23.tgz",
···
15124
}
15125
},
15126
"node_modules/next": {
15127
+
"version": "16.0.7",
15128
+
"resolved": "https://registry.npmjs.org/next/-/next-16.0.7.tgz",
15129
+
"integrity": "sha512-3mBRJyPxT4LOxAJI6IsXeFtKfiJUbjCLgvXO02fV8Wy/lIhPvP94Fe7dGhUgHXcQy4sSuYwQNcOLhIfOm0rL0A==",
15130
+
"license": "MIT",
15131
"dependencies": {
15132
+
"@next/env": "16.0.7",
15133
"@swc/helpers": "0.5.15",
15134
"caniuse-lite": "^1.0.30001579",
15135
"postcss": "8.4.31",
···
15142
"node": ">=20.9.0"
15143
},
15144
"optionalDependencies": {
15145
+
"@next/swc-darwin-arm64": "16.0.7",
15146
+
"@next/swc-darwin-x64": "16.0.7",
15147
+
"@next/swc-linux-arm64-gnu": "16.0.7",
15148
+
"@next/swc-linux-arm64-musl": "16.0.7",
15149
+
"@next/swc-linux-x64-gnu": "16.0.7",
15150
+
"@next/swc-linux-x64-musl": "16.0.7",
15151
+
"@next/swc-win32-arm64-msvc": "16.0.7",
15152
+
"@next/swc-win32-x64-msvc": "16.0.7",
15153
"sharp": "^0.34.4"
15154
},
15155
"peerDependencies": {
···
16338
}
16339
},
16340
"node_modules/react": {
16341
+
"version": "19.2.1",
16342
+
"resolved": "https://registry.npmjs.org/react/-/react-19.2.1.tgz",
16343
+
"integrity": "sha512-DGrYcCWK7tvYMnWh79yrPHt+vdx9tY+1gPZa7nJQtO/p8bLTDaHp4dzwEhQB7pZ4Xe3ok4XKuEPrVuc+wlpkmw==",
16344
+
"license": "MIT",
16345
"engines": {
16346
"node": ">=0.10.0"
16347
}
+3
-2
package.json
+3
-2
package.json
···
58
"inngest": "^3.40.1",
59
"ioredis": "^5.6.1",
60
"katex": "^0.16.22",
61
"linkifyjs": "^4.2.0",
62
"luxon": "^3.7.2",
63
"multiformats": "^13.3.2",
64
-
"next": "16.0.3",
65
"pg": "^8.16.3",
66
"prosemirror-commands": "^1.5.2",
67
"prosemirror-inputrules": "^1.4.0",
···
69
"prosemirror-model": "^1.21.0",
70
"prosemirror-schema-basic": "^1.2.2",
71
"prosemirror-state": "^1.4.3",
72
-
"react": "19.2.0",
73
"react-aria-components": "^1.8.0",
74
"react-day-picker": "^9.3.0",
75
"react-dom": "19.2.0",
···
58
"inngest": "^3.40.1",
59
"ioredis": "^5.6.1",
60
"katex": "^0.16.22",
61
+
"l": "^0.6.0",
62
"linkifyjs": "^4.2.0",
63
"luxon": "^3.7.2",
64
"multiformats": "^13.3.2",
65
+
"next": "^16.0.7",
66
"pg": "^8.16.3",
67
"prosemirror-commands": "^1.5.2",
68
"prosemirror-inputrules": "^1.4.0",
···
70
"prosemirror-model": "^1.21.0",
71
"prosemirror-schema-basic": "^1.2.2",
72
"prosemirror-state": "^1.4.3",
73
+
"react": "19.2.1",
74
"react-aria-components": "^1.8.0",
75
"react-day-picker": "^9.3.0",
76
"react-dom": "19.2.0",
+26
src/notifications.ts
+26
src/notifications.ts
···
2
3
import { supabaseServerClient } from "supabase/serverClient";
4
import { Tables, TablesInsert } from "supabase/database.types";
5
6
type NotificationRow = Tables<"notifications">;
7
···
191
.select("*, documents_in_publications(publications(*))")
192
.in("uri", documentUris);
193
194
// Fetch mentioned publications and documents
195
const mentionedPublicationUris = mentionNotifications
196
.filter((n) => n.data.mention_type === "publication")
···
220
? (notification.data as Extract<ExtractNotificationType<"mention">, { mentioned_uri: string }>).mentioned_uri
221
: undefined;
222
223
return {
224
id: notification.id,
225
recipient: notification.recipient,
···
229
mention_type: notification.data.mention_type,
230
mentioned_uri: mentionedUri,
231
document: documents?.find((d) => d.uri === notification.data.document_uri)!,
232
mentionedPublication: mentionedUri ? mentionedPublications?.find((p) => p.uri === mentionedUri) : undefined,
233
mentionedDocument: mentionedUri ? mentionedDocuments?.find((d) => d.uri === mentionedUri) : undefined,
234
};
···
2
3
import { supabaseServerClient } from "supabase/serverClient";
4
import { Tables, TablesInsert } from "supabase/database.types";
5
+
import { AtUri } from "@atproto/syntax";
6
+
import { idResolver } from "app/(home-pages)/reader/idResolver";
7
8
type NotificationRow = Tables<"notifications">;
9
···
193
.select("*, documents_in_publications(publications(*))")
194
.in("uri", documentUris);
195
196
+
// Extract unique DIDs from document URIs to resolve handles
197
+
const documentCreatorDids = [...new Set(documentUris.map((uri) => new AtUri(uri).host))];
198
+
199
+
// Resolve DIDs to handles in parallel
200
+
const didToHandleMap = new Map<string, string | null>();
201
+
await Promise.all(
202
+
documentCreatorDids.map(async (did) => {
203
+
try {
204
+
const resolved = await idResolver.did.resolve(did);
205
+
const handle = resolved?.alsoKnownAs?.[0]
206
+
? resolved.alsoKnownAs[0].slice(5) // Remove "at://" prefix
207
+
: null;
208
+
didToHandleMap.set(did, handle);
209
+
} catch (error) {
210
+
console.error(`Failed to resolve DID ${did}:`, error);
211
+
didToHandleMap.set(did, null);
212
+
}
213
+
}),
214
+
);
215
+
216
// Fetch mentioned publications and documents
217
const mentionedPublicationUris = mentionNotifications
218
.filter((n) => n.data.mention_type === "publication")
···
242
? (notification.data as Extract<ExtractNotificationType<"mention">, { mentioned_uri: string }>).mentioned_uri
243
: undefined;
244
245
+
const documentCreatorDid = new AtUri(notification.data.document_uri).host;
246
+
const documentCreatorHandle = didToHandleMap.get(documentCreatorDid) ?? null;
247
+
248
return {
249
id: notification.id,
250
recipient: notification.recipient,
···
254
mention_type: notification.data.mention_type,
255
mentioned_uri: mentionedUri,
256
document: documents?.find((d) => d.uri === notification.data.document_uri)!,
257
+
documentCreatorHandle,
258
mentionedPublication: mentionedUri ? mentionedPublications?.find((p) => p.uri === mentionedUri) : undefined,
259
mentionedDocument: mentionedUri ? mentionedDocuments?.find((d) => d.uri === mentionedUri) : undefined,
260
};
+9
supabase/database.types.ts
+9
supabase/database.types.ts
···
1158
}
1159
Returns: Database["public"]["CompositeTypes"]["pull_result"]
1160
}
1161
+
search_tags: {
1162
+
Args: {
1163
+
search_query: string
1164
+
}
1165
+
Returns: {
1166
+
name: string
1167
+
document_count: number
1168
+
}[]
1169
+
}
1170
}
1171
Enums: {
1172
rsvp_status: "GOING" | "NOT_GOING" | "MAYBE"