trafficlunar/tomodachi-share
1
0
Fork 0
mirror of https://github.com/trafficlunar/tomodachi-share.git synced 2026-05-13 13:17:45 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

feat: barebones queue

Browse source
This commit is contained in:
trafficlunar 2026-04-01 02:48:09 +01:00
parent 8608acae31
commit 1dacc3ab4a
4 changed files with 229 additions and 225 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
prisma/migrations/20260401000000_queue/migration.sql Normal file
View file

@ -0,0 +1,2 @@
-- AlterTable
ALTER TABLE "miis" ADD COLUMN "in_queue" BOOLEAN NOT NULL DEFAULT false;

1
prisma/schema.prisma
View file

@ -76,6 +76,7 @@ model Mii {
description String? @db.VarChar(512) description String? @db.VarChar(512)
platform MiiPlatform @default(THREE_DS) platform MiiPlatform @default(THREE_DS)
quarantined Boolean @default(false) quarantined Boolean @default(false)
in_queue Boolean @default(false)
instructions Json? instructions Json?
gender MiiGender? gender MiiGender?

448
src/app/api/submit/route.ts
View file

@ -75,267 +75,267 @@ export async function POST(request: NextRequest) {
const check = await rateLimit.handle(); const check = await rateLimit.handle();
if (check) return check; if (check) return check;
return rateLimit.sendResponse({ error: "Submissions are temporarily disabled" }, 503); const response = await fetch(`${process.env.NEXT_PUBLIC_BASE_URL}/api/admin/can-submit`);
// const response = await fetch(`${process.env.NEXT_PUBLIC_BASE_URL}/api/admin/can-submit`); const { value } = await response.json();
// const { value } = await response.json(); if (!value) return rateLimit.sendResponse({ error: "Submissions are temporarily disabled" }, 503);
// if (!value) return rateLimit.sendResponse({ error: "Submissions are temporarily disabled" }, 503);
// // Parse tags and QR code as JSON // Parse tags and QR code as JSON
// const formData = await request.formData(); const formData = await request.formData();
// let rawTags: string[]; let rawTags: string[];
// let rawQrBytesRaw: string[]; // raw raw let rawQrBytesRaw: string[]; // raw raw
// try { try {
// rawTags = JSON.parse(formData.get("tags") as string); rawTags = JSON.parse(formData.get("tags") as string);
// rawQrBytesRaw = JSON.parse(formData.get("qrBytesRaw") as string); rawQrBytesRaw = JSON.parse(formData.get("qrBytesRaw") as string);
// } catch (error) { } catch (error) {
// Sentry.captureException(error, { Sentry.captureException(error, {
// extra: { stage: "submit-json-parse" }, extra: { stage: "submit-json-parse" },
// }); });
// return rateLimit.sendResponse({ error: "Invalid JSON in tags or QR code data" }, 400); return rateLimit.sendResponse({ error: "Invalid JSON in tags or QR code data" }, 400);
// } }
// // Minify instructions to save space and improve user experience // Minify instructions to save space and improve user experience
// let minifiedInstructions: Partial<SwitchMiiInstructions> | undefined; let minifiedInstructions: Partial<SwitchMiiInstructions> | undefined;
// if (formData.get("platform") === "SWITCH") if (formData.get("platform") === "SWITCH")
// minifiedInstructions = minifyInstructions(JSON.parse((formData.get("instructions") as string) ?? "{}") as SwitchMiiInstructions); minifiedInstructions = minifyInstructions(JSON.parse((formData.get("instructions") as string) ?? "{}") as SwitchMiiInstructions);
// // Parse and check all submission info // Parse and check all submission info
// const parsed = submitSchema.safeParse({ const parsed = submitSchema.safeParse({
// platform: formData.get("platform"), platform: formData.get("platform"),
// name: formData.get("name"), name: formData.get("name"),
// tags: rawTags, tags: rawTags,
// description: formData.get("description"), description: formData.get("description"),
// gender: formData.get("gender") ?? undefined, // ZOD MOMENT gender: formData.get("gender") ?? undefined, // ZOD MOMENT
// makeup: formData.get("makeup") ?? undefined, makeup: formData.get("makeup") ?? undefined,
// miiPortraitImage: formData.get("miiPortraitImage"), miiPortraitImage: formData.get("miiPortraitImage"),
// miiFeaturesImage: formData.get("miiFeaturesImage"), miiFeaturesImage: formData.get("miiFeaturesImage"),
// instructions: minifiedInstructions, instructions: minifiedInstructions,
// qrBytesRaw: rawQrBytesRaw, qrBytesRaw: rawQrBytesRaw,
// image1: formData.get("image1"), image1: formData.get("image1"),
// image2: formData.get("image2"), image2: formData.get("image2"),
// image3: formData.get("image3"), image3: formData.get("image3"),
// }); });
// if (!parsed.success) { if (!parsed.success) {
// const firstIssue = parsed.error.issues[0]; const firstIssue = parsed.error.issues[0];
// const path = firstIssue.path.length ? firstIssue.path.join(".") : "root"; const path = firstIssue.path.length ? firstIssue.path.join(".") : "root";
// const error = `${path}: ${firstIssue.message}`; const error = `${path}: ${firstIssue.message}`;
// const issues = parsed.error.issues; const issues = parsed.error.issues;
// const hasInstructionsErrors = issues.some((issue) => issue.path[0] === "instructions"); const hasInstructionsErrors = issues.some((issue) => issue.path[0] === "instructions");
// if (hasInstructionsErrors) { if (hasInstructionsErrors) {
// Sentry.captureException(error, { Sentry.captureException(error, {
// extra: { issues, rawInstructions: formData.get("instructions"), stage: "submit-instructions" }, extra: { issues, rawInstructions: formData.get("instructions"), stage: "submit-instructions" },
// }); });
// } }
// return rateLimit.sendResponse({ error }, 400); return rateLimit.sendResponse({ error }, 400);
// } }
// const { const {
// platform, platform,
// name: uncensoredName, name: uncensoredName,
// tags: uncensoredTags, tags: uncensoredTags,
// description: uncensoredDescription, description: uncensoredDescription,
// qrBytesRaw, qrBytesRaw,
// gender, gender,
// makeup, makeup,
// miiPortraitImage, miiPortraitImage,
// miiFeaturesImage, miiFeaturesImage,
// image1, image1,
// image2, image2,
// image3, image3,
// } = parsed.data; } = parsed.data;
// // Censor potential inappropriate words // Censor potential inappropriate words
// const name = profanity.censor(uncensoredName); const name = profanity.censor(uncensoredName);
// const tags = uncensoredTags.map((t) => profanity.censor(t)); const tags = uncensoredTags.map((t) => profanity.censor(t));
// const description = uncensoredDescription && profanity.censor(uncensoredDescription); const description = uncensoredDescription && profanity.censor(uncensoredDescription);
// // Validate image files // Validate image files
// const customImages: File[] = []; const customImages: File[] = [];
// for (const img of [image1, image2, image3]) { for (const img of [image1, image2, image3]) {
// if (!img) continue; if (!img) continue;
// const imageValidation = await validateImage(img); const imageValidation = await validateImage(img);
// if (imageValidation.valid) { if (imageValidation.valid) {
// customImages.push(img); customImages.push(img);
// } else { } else {
// return rateLimit.sendResponse({ error: `Failed to verify custom image: ${imageValidation.error}` }, imageValidation.status ?? 400); return rateLimit.sendResponse({ error: `Failed to verify custom image: ${imageValidation.error}` }, imageValidation.status ?? 400);
// } }
// } }
// // Check Mii portrait & features image (Switch) // Check Mii portrait & features image (Switch)
// if (platform === "SWITCH") { if (platform === "SWITCH") {
// const portraitValidation = await validateImage(miiPortraitImage); const portraitValidation = await validateImage(miiPortraitImage);
// const featuresValidation = await validateImage(miiFeaturesImage); const featuresValidation = await validateImage(miiFeaturesImage);
// if (!portraitValidation.valid) if (!portraitValidation.valid)
// return rateLimit.sendResponse({ error: `Failed to verify portrait: ${portraitValidation.error}` }, portraitValidation.status ?? 400); return rateLimit.sendResponse({ error: `Failed to verify portrait: ${portraitValidation.error}` }, portraitValidation.status ?? 400);
// if (!featuresValidation.valid) if (!featuresValidation.valid)
// return rateLimit.sendResponse({ error: `Failed to verify features: ${featuresValidation.error}` }, featuresValidation.status ?? 400); return rateLimit.sendResponse({ error: `Failed to verify features: ${featuresValidation.error}` }, featuresValidation.status ?? 400);
// } }
// const qrBytes = new Uint8Array(qrBytesRaw ?? []); const qrBytes = new Uint8Array(qrBytesRaw ?? []);
// // Convert QR code to JS (3DS) // Convert QR code to JS (3DS)
// let conversion: { mii: Mii; tomodachiLifeMii: ThreeDsTomodachiLifeMii } | undefined; let conversion: { mii: Mii; tomodachiLifeMii: ThreeDsTomodachiLifeMii } | undefined;
// if (platform === "THREE_DS") { if (platform === "THREE_DS") {
// try { try {
// conversion = convertQrCode(qrBytes); conversion = convertQrCode(qrBytes);
// } catch (error) { } catch (error) {
// Sentry.captureException(error, { extra: { stage: "qr-conversion" } }); Sentry.captureException(error, { extra: { stage: "qr-conversion" } });
// return rateLimit.sendResponse({ error: error instanceof Error ? error.message : String(error) }, 400); return rateLimit.sendResponse({ error: error instanceof Error ? error.message : String(error) }, 400);
// } }
// } }
// // Create Mii in database // Create Mii in database
// const miiRecord = await prisma.mii.create({ const miiRecord = await prisma.mii.create({
// data: { data: {
// userId: Number(session.user?.id), userId: Number(session.user?.id),
// platform, platform,
// name, name,
// tags, tags,
// description, description,
// gender: gender ?? "MALE", gender: gender ?? "MALE",
in_queue: true,
// // Automatically detect certain information if on 3DS // Automatically detect certain information if on 3DS
// ...(platform === "THREE_DS" ...(platform === "THREE_DS"
// ? conversion && { ? conversion && {
// firstName: conversion.tomodachiLifeMii.firstName, firstName: conversion.tomodachiLifeMii.firstName,
// lastName: conversion.tomodachiLifeMii.lastName, lastName: conversion.tomodachiLifeMii.lastName,
// gender: conversion.mii.gender == 0 ? MiiGender.MALE : MiiGender.FEMALE, gender: conversion.mii.gender == 0 ? MiiGender.MALE : MiiGender.FEMALE,
// islandName: conversion.tomodachiLifeMii.islandName, islandName: conversion.tomodachiLifeMii.islandName,
// allowedCopying: conversion.mii.allowCopying, allowedCopying: conversion.mii.allowCopying,
// } }
// : { : {
// instructions: minifiedInstructions, instructions: minifiedInstructions,
// makeup: makeup ?? "PARTIAL", makeup: makeup ?? "PARTIAL",
// }), }),
// }, },
// }); });
// // Ensure directories exist // Ensure directories exist
// const miiUploadsDirectory = path.join(uploadsDirectory, miiRecord.id.toString()); const miiUploadsDirectory = path.join(uploadsDirectory, miiRecord.id.toString());
// await fs.mkdir(miiUploadsDirectory, { recursive: true }); await fs.mkdir(miiUploadsDirectory, { recursive: true });
// try { try {
// let portraitBuffer: Buffer | undefined; let portraitBuffer: Buffer | undefined;
// // Download the image of the Mii (3DS) // Download the image of the Mii (3DS)
// if (platform === "THREE_DS") { if (platform === "THREE_DS") {
// const studioUrl = conversion?.mii.studioUrl({ width: 512 }); const studioUrl = conversion?.mii.studioUrl({ width: 512 });
// const studioResponse = await fetch(studioUrl!); const studioResponse = await fetch(studioUrl!);
// if (!studioResponse.ok) { if (!studioResponse.ok) {
// throw new Error(`Failed to fetch Mii image ${studioResponse.status}`); throw new Error(`Failed to fetch Mii image ${studioResponse.status}`);
// } }
// portraitBuffer = Buffer.from(await studioResponse.arrayBuffer()); portraitBuffer = Buffer.from(await studioResponse.arrayBuffer());
// } else if (platform === "SWITCH") { } else if (platform === "SWITCH") {
// portraitBuffer = Buffer.from(await miiPortraitImage.arrayBuffer()); portraitBuffer = Buffer.from(await miiPortraitImage.arrayBuffer());
// // Save features image // Save features image
// const featuresBuffer = Buffer.from(await miiFeaturesImage.arrayBuffer()); const featuresBuffer = Buffer.from(await miiFeaturesImage.arrayBuffer());
// const pngBuffer = await sharp(featuresBuffer) const pngBuffer = await sharp(featuresBuffer)
// .resize({ .resize({
// height: 800, height: 800,
// fit: "inside", fit: "inside",
// withoutEnlargement: true, withoutEnlargement: true,
// }) })
// .png({ quality: 85 }) .png({ quality: 85 })
// .toBuffer(); .toBuffer();
// const fileLocation = path.join(miiUploadsDirectory, "features.png"); const fileLocation = path.join(miiUploadsDirectory, "features.png");
// await fs.writeFile(fileLocation, pngBuffer); await fs.writeFile(fileLocation, pngBuffer);
// } }
// // Save portrait image // Save portrait image
// if (!portraitBuffer) throw Error("Mii portrait buffer not initialised"); if (!portraitBuffer) throw Error("Mii portrait buffer not initialised");
// const pngBuffer = await sharp(portraitBuffer) const pngBuffer = await sharp(portraitBuffer)
// .resize({ .resize({
// height: 500, height: 500,
// fit: "inside", fit: "inside",
// withoutEnlargement: true, withoutEnlargement: true,
// }) })
// .png({ quality: 85 }) .png({ quality: 85 })
// .toBuffer(); .toBuffer();
// const fileLocation = path.join(miiUploadsDirectory, "mii.png"); const fileLocation = path.join(miiUploadsDirectory, "mii.png");
// await fs.writeFile(fileLocation, pngBuffer); await fs.writeFile(fileLocation, pngBuffer);
// } catch (error) { } catch (error) {
// // Clean up if something went wrong // Clean up if something went wrong
// await prisma.mii.delete({ where: { id: miiRecord.id } }); await prisma.mii.delete({ where: { id: miiRecord.id } });
// console.error("Failed to download/store Mii portrait/features:", error); console.error("Failed to download/store Mii portrait/features:", error);
// Sentry.captureException(error, { extra: { miiId: miiRecord.id, stage: "studio-image-download" } }); Sentry.captureException(error, { extra: { miiId: miiRecord.id, stage: "studio-image-download" } });
// return rateLimit.sendResponse({ error: "Failed to download/store Mii portrait/features" }, 500); return rateLimit.sendResponse({ error: "Failed to download/store Mii portrait/features" }, 500);
// } }
// try { try {
// await generateMetadataImage(miiRecord, session.user?.name!); await generateMetadataImage(miiRecord, session.user?.name!);
// } catch (error) { } catch (error) {
// console.error("Failed to generate metadata image:", error); console.error("Failed to generate metadata image:", error);
// Sentry.captureException(error, { extra: { miiId: miiRecord.id, stage: "metadata-image-generation" } }); Sentry.captureException(error, { extra: { miiId: miiRecord.id, stage: "metadata-image-generation" } });
// } }
// if (platform === "THREE_DS") { if (platform === "THREE_DS") {
// try { try {
// // Generate a new QR code for aesthetic reasons // Generate a new QR code for aesthetic reasons
// const byteString = String.fromCharCode(...qrBytes); const byteString = String.fromCharCode(...qrBytes);
// const generatedCode = qrcode(0, "L"); const generatedCode = qrcode(0, "L");
// generatedCode.addData(byteString, "Byte"); generatedCode.addData(byteString, "Byte");
// generatedCode.make(); generatedCode.make();
// // Store QR code // Store QR code
// const codeDataUrl = generatedCode.createDataURL(); const codeDataUrl = generatedCode.createDataURL();
// const codeBase64 = codeDataUrl.replace(/^data:image\/gif;base64,/, ""); const codeBase64 = codeDataUrl.replace(/^data:image\/gif;base64,/, "");
// const codeBuffer = Buffer.from(codeBase64, "base64"); const codeBuffer = Buffer.from(codeBase64, "base64");
// // Compress and store // Compress and store
// const codePngBuffer = await sharp(codeBuffer).png({ quality: 85 }).toBuffer(); const codePngBuffer = await sharp(codeBuffer).png({ quality: 85 }).toBuffer();
// const codeFileLocation = path.join(miiUploadsDirectory, "qr-code.png"); const codeFileLocation = path.join(miiUploadsDirectory, "qr-code.png");
// await fs.writeFile(codeFileLocation, codePngBuffer); await fs.writeFile(codeFileLocation, codePngBuffer);
// } catch (error) { } catch (error) {
// // Clean up if something went wrong // Clean up if something went wrong
// await prisma.mii.delete({ where: { id: miiRecord.id } }); await prisma.mii.delete({ where: { id: miiRecord.id } });
// console.error("Error processing Mii files:", error); console.error("Error processing Mii files:", error);
// Sentry.captureException(error, { extra: { miiId: miiRecord.id, stage: "file-processing" } }); Sentry.captureException(error, { extra: { miiId: miiRecord.id, stage: "file-processing" } });
// return rateLimit.sendResponse({ error: "Failed to process and store Mii files" }, 500); return rateLimit.sendResponse({ error: "Failed to process and store Mii files" }, 500);
// } }
// } }
// // Compress and store user images // Compress and store user images
// try { try {
// await Promise.all( await Promise.all(
// customImages.map(async (image, index) => { customImages.map(async (image, index) => {
// const buffer = Buffer.from(await image.arrayBuffer()); const buffer = Buffer.from(await image.arrayBuffer());
// const pngBuffer = await sharp(buffer).resize({ height: 800, fit: "inside", withoutEnlargement: true }).png({ quality: 85 }).toBuffer(); const pngBuffer = await sharp(buffer).resize({ height: 800, fit: "inside", withoutEnlargement: true }).png({ quality: 85 }).toBuffer();
// const fileLocation = path.join(miiUploadsDirectory, `image${index}.png`); const fileLocation = path.join(miiUploadsDirectory, `image${index}.png`);
// await fs.writeFile(fileLocation, pngBuffer); await fs.writeFile(fileLocation, pngBuffer);
// }), }),
// ); );
// // Update database to tell it how many images exist // Update database to tell it how many images exist
// await prisma.mii.update({ await prisma.mii.update({
// where: { where: {
// id: miiRecord.id, id: miiRecord.id,
// }, },
// data: { data: {
// imageCount: customImages.length, imageCount: customImages.length,
// }, },
// }); });
// } catch (error) { } catch (error) {
// console.error("Error storing user images:", error); console.error("Error storing user images:", error);
// Sentry.captureException(error, { extra: { miiId: miiRecord.id, stage: "user-image-storage" } }); Sentry.captureException(error, { extra: { miiId: miiRecord.id, stage: "user-image-storage" } });
// return rateLimit.sendResponse({ error: "Failed to store user images" }, 500); return rateLimit.sendResponse({ error: "Failed to store user images" }, 500);
// } }
// return rateLimit.sendResponse({ success: true, id: miiRecord.id }); return rateLimit.sendResponse({ success: true, id: miiRecord.id });
} }

3
src/components/mii/list/index.tsx
View file

@ -36,7 +36,8 @@ export default async function MiiList({ searchParams, userId, inLikesPage }: Pro
miiIdsLiked = likedMiis.map((like) => like.miiId); miiIdsLiked = likedMiis.map((like) => like.miiId);
} }
const where: Prisma.MiiWhereInput = { const where: Prisma.MiiWhereInput = {
in_queue: false,
// Only show liked miis on likes page // Only show liked miis on likes page
...(inLikesPage && miiIdsLiked && { id: { in: miiIdsLiked } }), ...(inLikesPage && miiIdsLiked && { id: { in: miiIdsLiked } }),
// Searching // Searching