grain.social
grain.social is a photo sharing platform built on atproto.
feat: add cascade option to deleteGallery and deletePhoto procedures to remove associated items
chadtmiller.com
+126
-72
+12
__generated__/lexicons.ts
+12
__generated__/lexicons.ts
···
2816
format: 'at-uri',
2817
description: 'Unique identifier of the gallery to delete',
2818
},
2819
+
cascade: {
2820
+
type: 'boolean',
2821
+
default: true,
2822
+
description:
2823
+
'If true, will also delete any associated items in the gallery.',
2824
+
},
2825
},
2826
},
2827
},
···
4410
type: 'string',
4411
format: 'at-uri',
4412
description: 'AT URI of the photo to delete.',
4413
+
},
4414
+
cascade: {
4415
+
type: 'boolean',
4416
+
default: true,
4417
+
description:
4418
+
'If true, will also delete any associated EXIF data and gallery items.',
4419
},
4420
},
4421
},
+15
-13
src/api/mod.ts
+15
-13
src/api/mod.ts
···
138
getFollowingWithProfiles,
139
} from "../lib/graph.ts";
140
import { getNotificationsDetailed } from "../lib/notifications.ts";
141
-
import { applyAlts, createExif, createPhoto } from "../lib/photo.ts";
142
import { getTimeline } from "../lib/timeline.ts";
143
import { createComment, getGalleryComments } from "../modules/comments.tsx";
144
···
181
["POST"],
182
async (req, _params, ctx) => {
183
ctx.requireAuth();
184
-
const { uri } = await parseDeleteGalleryInputs(
185
req,
186
);
187
-
const success = await deleteGallery(uri, ctx);
188
return ctx.json({ success } satisfies DeleteGalleryOutputSchema);
189
},
190
),
···
298
["POST"],
299
async (req, _params, ctx) => {
300
ctx.requireAuth();
301
-
const { uri } = await parseDeletePhotoInputs(req);
302
-
try {
303
-
await ctx.deleteRecord(uri);
304
-
return ctx.json({ success: true } satisfies DeletePhotoOutputSchema);
305
-
} catch (error) {
306
-
console.error("Error deleting photo:", error);
307
-
return ctx.json({ success: false } satisfies DeletePhotoOutputSchema);
308
-
}
309
},
310
),
311
route(
···
772
if (!uri) {
773
throw new XRPCError("InvalidRequest", "Missing uri input");
774
}
775
-
return { uri };
776
}
777
778
async function parseCreateGalleryItemInputs(
···
819
if (!uri) {
820
throw new XRPCError("InvalidRequest", "Missing uri input");
821
}
822
-
return { uri };
823
}
824
825
async function parseCreateFollowInputs(
···
138
getFollowingWithProfiles,
139
} from "../lib/graph.ts";
140
import { getNotificationsDetailed } from "../lib/notifications.ts";
141
+
import {
142
+
applyAlts,
143
+
createExif,
144
+
createPhoto,
145
+
deletePhoto,
146
+
} from "../lib/photo.ts";
147
import { getTimeline } from "../lib/timeline.ts";
148
import { createComment, getGalleryComments } from "../modules/comments.tsx";
149
···
186
["POST"],
187
async (req, _params, ctx) => {
188
ctx.requireAuth();
189
+
const { uri, cascade = true } = await parseDeleteGalleryInputs(
190
req,
191
);
192
+
const success = await deleteGallery(uri, cascade, ctx);
193
return ctx.json({ success } satisfies DeleteGalleryOutputSchema);
194
},
195
),
···
303
["POST"],
304
async (req, _params, ctx) => {
305
ctx.requireAuth();
306
+
const { uri, cascade = true } = await parseDeletePhotoInputs(req);
307
+
const success = await deletePhoto(uri, cascade, ctx);
308
+
return ctx.json({ success } satisfies DeletePhotoOutputSchema);
309
},
310
),
311
route(
···
772
if (!uri) {
773
throw new XRPCError("InvalidRequest", "Missing uri input");
774
}
775
+
const cascade = typeof body.cascade === "boolean" ? body.cascade : undefined;
776
+
return { uri, cascade };
777
}
778
779
async function parseCreateGalleryItemInputs(
···
820
if (!uri) {
821
throw new XRPCError("InvalidRequest", "Missing uri input");
822
}
823
+
const cascade = typeof body.cascade === "boolean" ? body.cascade : undefined;
824
+
return { uri, cascade };
825
}
826
827
async function parseCreateFollowInputs(
+6
-1
src/lib/gallery.ts
+6
-1
src/lib/gallery.ts
···
145
});
146
}
147
148
+
export async function deleteGallery(
149
+
uri: string,
150
+
cascade: boolean,
151
+
ctx: BffContext,
152
+
) {
153
try {
154
await ctx.deleteRecord(uri);
155
+
if (!cascade) return true;
156
const { items: galleryItems } = ctx.indexService.getRecords<
157
WithBffMeta<GalleryItem>
158
>("social.grain.gallery.item", {
+70
src/lib/photo.ts
+70
src/lib/photo.ts
···
1
+
import { Record as Favorite } from "$lexicon/types/social/grain/favorite.ts";
2
import { Record as Gallery } from "$lexicon/types/social/grain/gallery.ts";
3
import { GalleryView } from "$lexicon/types/social/grain/gallery/defs.ts";
4
import { Record as GalleryItem } from "$lexicon/types/social/grain/gallery/item.ts";
···
352
353
return true;
354
}
355
+
356
+
export async function deletePhoto(
357
+
uri: string,
358
+
cascade: boolean,
359
+
ctx: BffContext,
360
+
): Promise<boolean> {
361
+
const deleteUris: string[] = [];
362
+
try {
363
+
await ctx.deleteRecord(
364
+
uri,
365
+
);
366
+
if (!cascade) return true;
367
+
const { items: galleryItems } = ctx.indexService.getRecords<
368
+
WithBffMeta<GalleryItem>
369
+
>(
370
+
"social.grain.gallery.item",
371
+
{
372
+
where: [
373
+
{
374
+
field: "item",
375
+
equals: uri,
376
+
},
377
+
],
378
+
},
379
+
);
380
+
for (const item of galleryItems) {
381
+
deleteUris.push(item.uri);
382
+
}
383
+
const { items: favorites } = ctx.indexService.getRecords<
384
+
WithBffMeta<Favorite>
385
+
>(
386
+
"social.grain.favorite",
387
+
{
388
+
where: [
389
+
{
390
+
field: "subject",
391
+
equals: uri,
392
+
},
393
+
],
394
+
},
395
+
);
396
+
for (const favorite of favorites) {
397
+
deleteUris.push(favorite.uri);
398
+
}
399
+
const { items: exifItems } = ctx.indexService.getRecords<
400
+
WithBffMeta<PhotoExif>
401
+
>(
402
+
"social.grain.photo.exif",
403
+
{
404
+
where: [
405
+
{
406
+
field: "photo",
407
+
equals: uri,
408
+
},
409
+
],
410
+
},
411
+
);
412
+
for (const item of exifItems) {
413
+
deleteUris.push(item.uri);
414
+
}
415
+
for (const uri of deleteUris) {
416
+
await ctx.deleteRecord(uri);
417
+
}
418
+
} catch (error) {
419
+
console.error("Failed to delete photo:", error);
420
+
return false;
421
+
}
422
+
return true;
423
+
}
+9
-58
src/routes/actions.tsx
+9
-58
src/routes/actions.tsx
···
5
import { Record as GalleryItem } from "$lexicon/types/social/grain/gallery/item.ts";
6
import { Record as Photo } from "$lexicon/types/social/grain/photo.ts";
7
import { isPhotoView } from "$lexicon/types/social/grain/photo/defs.ts";
8
-
import { Record as PhotoExif } from "$lexicon/types/social/grain/photo/exif.ts";
9
import { AtUri } from "@atproto/syntax";
10
import { BffContext, RouteHandler, WithBffMeta } from "@bigmoves/bff";
11
import {
···
28
updateGallery,
29
} from "../lib/gallery.ts";
30
import { getFollowers } from "../lib/graph.ts";
31
-
import { createExif, createPhoto, getPhoto } from "../lib/photo.ts";
32
import type { State } from "../state.ts";
33
import { galleryLink, profileLink, uploadPageLink } from "../utils.ts";
34
···
131
const { handle } = ctx.requireAuth();
132
const formData = await req.formData();
133
const uri = formData.get("uri") as string;
134
-
await deleteGallery(uri, ctx);
135
return ctx.redirect(profileLink(handle));
136
};
137
···
331
const selectedGalleryRkey = selectedGallery
332
? new AtUri(selectedGallery).rkey
333
: undefined;
334
-
const deleteUris: string[] = [];
335
-
await ctx.deleteRecord(
336
-
`at://${did}/social.grain.photo/${params.rkey}`,
337
-
);
338
-
const { items: galleryItems } = ctx.indexService.getRecords<
339
-
WithBffMeta<GalleryItem>
340
-
>(
341
-
"social.grain.gallery.item",
342
-
{
343
-
where: [
344
-
{
345
-
field: "item",
346
-
equals: `at://${did}/social.grain.photo/${params.rkey}`,
347
-
},
348
-
],
349
-
},
350
-
);
351
-
for (const item of galleryItems) {
352
-
deleteUris.push(item.uri);
353
-
}
354
-
const { items: favorites } = ctx.indexService.getRecords<
355
-
WithBffMeta<Favorite>
356
-
>(
357
-
"social.grain.favorite",
358
-
{
359
-
where: [
360
-
{
361
-
field: "subject",
362
-
equals: `at://${did}/social.grain.photo/${params.rkey}`,
363
-
},
364
-
],
365
-
},
366
-
);
367
-
for (const favorite of favorites) {
368
-
deleteUris.push(favorite.uri);
369
-
}
370
-
const { items: exifItems } = ctx.indexService.getRecords<
371
-
WithBffMeta<PhotoExif>
372
-
>(
373
-
"social.grain.photo.exif",
374
-
{
375
-
where: [
376
-
{
377
-
field: "photo",
378
-
equals: `at://${did}/social.grain.photo/${params.rkey}`,
379
-
},
380
-
],
381
-
},
382
-
);
383
-
for (const item of exifItems) {
384
-
deleteUris.push(item.uri);
385
-
}
386
-
for (const uri of deleteUris) {
387
-
await ctx.deleteRecord(uri);
388
-
}
389
return ctx.redirect(uploadPageLink(selectedGalleryRkey));
390
};
391
···
5
import { Record as GalleryItem } from "$lexicon/types/social/grain/gallery/item.ts";
6
import { Record as Photo } from "$lexicon/types/social/grain/photo.ts";
7
import { isPhotoView } from "$lexicon/types/social/grain/photo/defs.ts";
8
import { AtUri } from "@atproto/syntax";
9
import { BffContext, RouteHandler, WithBffMeta } from "@bigmoves/bff";
10
import {
···
27
updateGallery,
28
} from "../lib/gallery.ts";
29
import { getFollowers } from "../lib/graph.ts";
30
+
import {
31
+
createExif,
32
+
createPhoto,
33
+
deletePhoto,
34
+
getPhoto,
35
+
} from "../lib/photo.ts";
36
import type { State } from "../state.ts";
37
import { galleryLink, profileLink, uploadPageLink } from "../utils.ts";
38
···
135
const { handle } = ctx.requireAuth();
136
const formData = await req.formData();
137
const uri = formData.get("uri") as string;
138
+
await deleteGallery(uri, true, ctx);
139
return ctx.redirect(profileLink(handle));
140
};
141
···
335
const selectedGalleryRkey = selectedGallery
336
? new AtUri(selectedGallery).rkey
337
: undefined;
338
+
const photoUri = `at://${did}/social.grain.photo/${params.rkey}`;
339
+
await deletePhoto(photoUri, true, ctx);
340
return ctx.redirect(uploadPageLink(selectedGalleryRkey));
341
};
342