🐛 Fix MongoDB transactions

src/lib/server/photo.ts

@@ -44,40 +44,43 @@ export async function generatePicture(
 
 	const _id = generateId(name);
 
-	await client.withSession(async (session) => {
-		await collections.pictures.insertOne(
-			{
-				_id,
-				name,
-				storage: formats.map((format) => ({
-					_id: `${_id}-${format.width}x${format.height}`,
-					width: format.width,
-					height: format.height,
-					size: format.data.length
-				})),
-				...(opts?.productId && { productId: opts.productId }),
-				createdAt: new Date(),
-				updatedAt: new Date()
-			},
-			{ session }
-		);
+	await client.withSession(
+		async (session) =>
+			await session.withTransaction(async (session) => {
+				await collections.pictures.insertOne(
+					{
+						_id,
+						name,
+						storage: formats.map((format) => ({
+							_id: `${_id}-${format.width}x${format.height}`,
+							width: format.width,
+							height: format.height,
+							size: format.data.length
+						})),
+						...(opts?.productId && { productId: opts.productId }),
+						createdAt: new Date(),
+						updatedAt: new Date()
+					},
+					{ session }
+				);
 
-		await collections.picturesFs.insertMany(
-			formats.map(
-				(format) => ({
-					_id: `${_id}-${format.width}x${format.height}`,
-					createdAt: new Date(),
-					updatedAt: new Date(),
-					size: format.data.length,
-					data: format.data,
-					picture: _id
-				}),
-				{ session }
-			)
-		);
+				await collections.picturesFs.insertMany(
+					formats.map(
+						(format) => ({
+							_id: `${_id}-${format.width}x${format.height}`,
+							createdAt: new Date(),
+							updatedAt: new Date(),
+							size: format.data.length,
+							data: format.data,
+							picture: _id
+						}),
+						{ session }
+					)
+				);
 
-		if (opts?.cb) {
-			await opts.cb(session);
-		}
-	});
+				if (opts?.cb) {
+					await opts.cb(session);
+				}
+			})
+	);
 }

src/routes/admin/photos/[id]/+page.server.ts

@@ -33,11 +33,14 @@ export const actions: Actions = {
 	delete: async function ({ params }) {
 		let picture: Picture | null = null;
 
-		await client.withSession(async (session) => {
-			picture = (await collections.pictures.findOneAndDelete({ _id: params.id }, { session }))
-				.value;
-			await collections.picturesFs.deleteMany({ picture: params.id }, { session });
-		});
+		await client.withSession(
+			async (session) =>
+				await session.withTransaction(async (session) => {
+					picture = (await collections.pictures.findOneAndDelete({ _id: params.id }, { session }))
+						.value;
+					await collections.picturesFs.deleteMany({ picture: params.id }, { session });
+				})
+		);
 
 		if (!picture) {
 			throw error(404);

src/routes/admin/produits/[id]/+page.server.ts

@@ -51,28 +51,31 @@ export const actions: Actions = {
 	},
 
 	delete: async ({ params }) => {
-		await client.withSession(async (session) => {
-			const product = await collections.products.findOneAndDelete({ _id: params.id });
+		await client.withSession(
+			async (session) =>
+				await session.withTransaction(async (session) => {
+					const product = await collections.products.findOneAndDelete({ _id: params.id });
 
-			if (!product.value) {
-				throw error(404);
-			}
+					if (!product.value) {
+						throw error(404);
+					}
 
-			const pictures = await collections.pictures
-				.find({ productId: params.id }, { session })
-				.toArray();
+					const pictures = await collections.pictures
+						.find({ productId: params.id }, { session })
+						.toArray();
 
-			await collections.pictures.deleteMany(
-				{ _id: { $in: pictures.map((p) => p._id) } },
-				{ session }
-			);
-			await collections.picturesFs.deleteMany(
-				{
-					_id: { $in: pictures.flatMap((p) => p.storage.map((s) => s._id)) }
-				},
-				{ session }
-			);
-		});
+					await collections.pictures.deleteMany(
+						{ _id: { $in: pictures.map((p) => p._id) } },
+						{ session }
+					);
+					await collections.picturesFs.deleteMany(
+						{
+							_id: { $in: pictures.flatMap((p) => p.storage.map((s) => s._id)) }
+						},
+						{ session }
+					);
+				})
+		);
 
 		throw redirect(303, '/admin/produits');
 	}