mirror of
https://github.com/trafficlunar/tomodachi-share.git
synced 2026-05-13 21:27:46 +00:00
Compare commits
1 commit
5f45f205f4
...
f4bfb59430
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
f4bfb59430 |
9 changed files with 136 additions and 124 deletions
|
|
@ -6,54 +6,54 @@ import { idSchema } from "@/lib/schemas";
|
|||
import { RateLimit } from "@/lib/rate-limit";
|
||||
|
||||
export async function PATCH(request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
|
||||
// const session = await auth();
|
||||
// if (!session) return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
|
||||
const session = await auth();
|
||||
if (!session) return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
|
||||
|
||||
// const rateLimit = new RateLimit(request, 100, "/api/mii/like");
|
||||
// const check = await rateLimit.handle();
|
||||
// if (check) return check;
|
||||
const rateLimit = new RateLimit(request, 100, "/api/mii/like");
|
||||
const check = await rateLimit.handle();
|
||||
if (check) return check;
|
||||
|
||||
// const { id: slugId } = await params;
|
||||
// const parsed = idSchema.safeParse(slugId);
|
||||
// if (!parsed.success) return rateLimit.sendResponse({ error: parsed.error.issues[0].message }, 400);
|
||||
// const miiId = parsed.data;
|
||||
const { id: slugId } = await params;
|
||||
const parsed = idSchema.safeParse(slugId);
|
||||
if (!parsed.success) return rateLimit.sendResponse({ error: parsed.error.issues[0].message }, 400);
|
||||
const miiId = parsed.data;
|
||||
|
||||
// const result = await prisma.$transaction(async (tx) => {
|
||||
// const existingLike = await tx.like.findUnique({
|
||||
// where: {
|
||||
// userId_miiId: {
|
||||
// userId: Number(session.user?.id),
|
||||
// miiId,
|
||||
// },
|
||||
// },
|
||||
// });
|
||||
const result = await prisma.$transaction(async (tx) => {
|
||||
const existingLike = await tx.like.findUnique({
|
||||
where: {
|
||||
userId_miiId: {
|
||||
userId: Number(session.user?.id),
|
||||
miiId,
|
||||
},
|
||||
},
|
||||
});
|
||||
|
||||
// if (existingLike) {
|
||||
// // Remove the like if it exists
|
||||
// await tx.like.delete({
|
||||
// where: {
|
||||
// userId_miiId: {
|
||||
// userId: Number(session.user?.id),
|
||||
// miiId,
|
||||
// },
|
||||
// },
|
||||
// });
|
||||
// } else {
|
||||
// // Add a like if it doesn't exist
|
||||
// await tx.like.create({
|
||||
// data: {
|
||||
// userId: Number(session.user?.id),
|
||||
// miiId,
|
||||
// },
|
||||
// });
|
||||
// }
|
||||
if (existingLike) {
|
||||
// Remove the like if it exists
|
||||
await tx.like.delete({
|
||||
where: {
|
||||
userId_miiId: {
|
||||
userId: Number(session.user?.id),
|
||||
miiId,
|
||||
},
|
||||
},
|
||||
});
|
||||
} else {
|
||||
// Add a like if it doesn't exist
|
||||
await tx.like.create({
|
||||
data: {
|
||||
userId: Number(session.user?.id),
|
||||
miiId,
|
||||
},
|
||||
});
|
||||
}
|
||||
|
||||
// const likeCount = await tx.like.count({
|
||||
// where: { miiId },
|
||||
// });
|
||||
const likeCount = await tx.like.count({
|
||||
where: { miiId },
|
||||
});
|
||||
|
||||
// return { liked: !existingLike, count: likeCount };
|
||||
// });
|
||||
return { liked: !existingLike, count: likeCount };
|
||||
});
|
||||
|
||||
return NextResponse.json({ success: false });
|
||||
return rateLimit.sendResponse({ success: true, liked: result.liked, count: result.count });
|
||||
}
|
||||
|
|
|
|||
|
|
@ -4,26 +4,25 @@ import { prisma } from "@/lib/prisma";
|
|||
import { RateLimit } from "@/lib/rate-limit";
|
||||
|
||||
export async function GET(request: NextRequest) {
|
||||
// const session = await auth();
|
||||
// if (!session) return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
|
||||
const session = await auth();
|
||||
if (!session) return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
|
||||
|
||||
// const rateLimit = new RateLimit(request, 50, "/api/mii/like_get");
|
||||
// const check = await rateLimit.handle();
|
||||
// if (check) return check;
|
||||
const rateLimit = new RateLimit(request, 50, "/api/mii/like_get");
|
||||
const check = await rateLimit.handle();
|
||||
if (check) return check;
|
||||
|
||||
// const idsParam = new URL(request.url).searchParams.get("ids");
|
||||
// if (!idsParam) return NextResponse.json({ error: "Missing IDs parameter" }, { status: 400 });
|
||||
const idsParam = new URL(request.url).searchParams.get("ids");
|
||||
if (!idsParam) return NextResponse.json({ error: "Missing IDs parameter" }, { status: 400 });
|
||||
|
||||
// const ids = idsParam.split(",").map(Number).filter(Boolean);
|
||||
// if (!ids.length) return NextResponse.json({ error: "No valid IDs provided" }, { status: 400 });
|
||||
// if (ids.length > 100) return NextResponse.json({ error: "Too many IDs, maximum is 100" }, { status: 400 });
|
||||
const ids = idsParam.split(",").map(Number).filter(Boolean);
|
||||
if (!ids.length) return NextResponse.json({ error: "No valid IDs provided" }, { status: 400 });
|
||||
if (ids.length > 100) return NextResponse.json({ error: "Too many IDs, maximum is 100" }, { status: 400 });
|
||||
|
||||
// const liked = await prisma.like.findMany({
|
||||
// where: { userId: Number(session.user?.id), miiId: { in: ids } },
|
||||
// select: { miiId: true },
|
||||
// });
|
||||
const liked = await prisma.like.findMany({
|
||||
where: { userId: Number(session.user?.id), miiId: { in: ids } },
|
||||
select: { miiId: true },
|
||||
});
|
||||
|
||||
// // Return only Miis that are liked
|
||||
// return NextResponse.json(liked.map((l) => l.miiId));
|
||||
return NextResponse.json({ success: false }, { status: 500 });
|
||||
// Return only Miis that are liked
|
||||
return NextResponse.json(liked.map((l) => l.miiId));
|
||||
}
|
||||
|
|
|
|||
|
|
@ -220,8 +220,7 @@ export async function POST(request: NextRequest) {
|
|||
// Download the image of the Mii (3DS)
|
||||
if (platform === "THREE_DS") {
|
||||
const studioUrl = conversion?.mii.studioUrl({ width: 512 });
|
||||
if (!studioUrl || new URL(studioUrl).hostname !== "studio.mii.nintendo.com") throw new Error("Invalid studio URL");
|
||||
const studioResponse = await fetch(studioUrl);
|
||||
const studioResponse = await fetch(studioUrl!);
|
||||
|
||||
if (!studioResponse.ok) {
|
||||
throw new Error(`Failed to fetch Mii image ${studioResponse.status}`);
|
||||
|
|
|
|||
|
|
@ -20,7 +20,7 @@ const searchParamsSchema = z.object({
|
|||
|
||||
export async function GET(request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
|
||||
const rateLimit = new RateLimit(request, 200, "/mii/image");
|
||||
const check = await rateLimit.handleByIp();
|
||||
const check = await rateLimit.handle();
|
||||
if (check) return check;
|
||||
|
||||
const { id: slugId } = await params;
|
||||
|
|
@ -107,12 +107,9 @@ export async function GET(request: NextRequest, { params }: { params: Promise<{
|
|||
});
|
||||
}
|
||||
|
||||
// mii, features are purged on edit; qr-code is immutable. imageN isn't purged, so keep its TTL short.
|
||||
const isStableType = imageType === "mii" || imageType === "qr-code" || imageType === "features";
|
||||
|
||||
return rateLimit.sendResponse(buffer, 200, {
|
||||
"Content-Type": "image/png",
|
||||
"X-Robots-Tag": "noindex, noimageindex, nofollow",
|
||||
"Cache-Control": isStableType ? "public, max-age=3600, stale-while-revalidate=86400" : "public, max-age=60, stale-while-revalidate=30",
|
||||
"Cache-Control": "public, max-age=60, stale-while-revalidate=30",
|
||||
});
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,4 +1,3 @@
|
|||
import { cache } from "react";
|
||||
import { Metadata } from "next";
|
||||
import Image from "next/image";
|
||||
import Link from "next/link";
|
||||
|
|
@ -6,6 +5,7 @@ import { redirect } from "next/navigation";
|
|||
|
||||
import { Icon } from "@iconify/react";
|
||||
|
||||
import { auth } from "@/lib/auth";
|
||||
import { prisma } from "@/lib/prisma";
|
||||
import { MiiPlatform } from "@prisma/client";
|
||||
|
||||
|
|
@ -25,21 +25,24 @@ interface Props {
|
|||
params: Promise<{ id: string }>;
|
||||
}
|
||||
|
||||
export const revalidate = 300;
|
||||
|
||||
const getMii = cache(async (id: number) =>
|
||||
prisma.mii.findUnique({
|
||||
where: { id },
|
||||
include: {
|
||||
user: { select: { name: true } },
|
||||
_count: { select: { likedBy: true } },
|
||||
},
|
||||
}),
|
||||
);
|
||||
|
||||
export async function generateMetadata({ params }: Props): Promise<Metadata> {
|
||||
const { id } = await params;
|
||||
const mii = await getMii(Number(id));
|
||||
|
||||
const mii = await prisma.mii.findUnique({
|
||||
where: {
|
||||
id: Number(id),
|
||||
},
|
||||
include: {
|
||||
user: {
|
||||
select: {
|
||||
name: true,
|
||||
},
|
||||
},
|
||||
_count: {
|
||||
select: { likedBy: true }, // Get total like count
|
||||
},
|
||||
},
|
||||
});
|
||||
|
||||
// Bots get redirected anyways
|
||||
if (!mii) return {};
|
||||
|
|
@ -87,7 +90,31 @@ export async function generateMetadata({ params }: Props): Promise<Metadata> {
|
|||
|
||||
export default async function MiiPage({ params }: Props) {
|
||||
const { id } = await params;
|
||||
const mii = await getMii(Number(id));
|
||||
const session = await auth();
|
||||
|
||||
const mii = await prisma.mii.findUnique({
|
||||
where: {
|
||||
id: Number(id),
|
||||
},
|
||||
include: {
|
||||
user: {
|
||||
select: {
|
||||
name: true,
|
||||
},
|
||||
},
|
||||
likedBy: session?.user
|
||||
? {
|
||||
where: {
|
||||
userId: Number(session.user.id),
|
||||
},
|
||||
select: { userId: true },
|
||||
}
|
||||
: false,
|
||||
_count: {
|
||||
select: { likedBy: true }, // Get total like count
|
||||
},
|
||||
},
|
||||
});
|
||||
|
||||
if (!mii) redirect("/404");
|
||||
|
||||
|
|
@ -306,7 +333,7 @@ export default async function MiiPage({ params }: Props) {
|
|||
{/* Submission name */}
|
||||
<h1 className="text-4xl font-extrabold wrap-break-word whitespace-break-spaces text-amber-700 flex-1 min-w-0">{mii.name}</h1>
|
||||
{/* Like button */}
|
||||
<LikeButton likes={mii._count.likedBy ?? 0} miiId={mii.id} isLiked={false} big />
|
||||
<LikeButton likes={mii._count.likedBy ?? 0} miiId={mii.id} isLiked={(mii.likedBy ?? []).length > 0} big />
|
||||
</div>
|
||||
{/* Tags */}
|
||||
<div id="tags" className="flex flex-wrap gap-1 mt-1 *:px-2 *:py-1 *:bg-orange-300 *:rounded-full *:text-xs">
|
||||
|
|
|
|||
|
|
@ -24,31 +24,31 @@ export default function LikeButton({ likes, isLiked, miiId, disabled, abbreviate
|
|||
const [isAnimating, setIsAnimating] = useState(false);
|
||||
|
||||
const onClick = async () => {
|
||||
// if (disabled) return;
|
||||
// if (!session.data?.user) {
|
||||
// router.push("/login");
|
||||
// return;
|
||||
// }
|
||||
if (disabled) return;
|
||||
if (!session.data?.user) {
|
||||
router.push("/login");
|
||||
return;
|
||||
}
|
||||
|
||||
// setIsLikedState(!isLikedState);
|
||||
// setLikesState(isLikedState ? likesState - 1 : likesState + 1);
|
||||
setIsLikedState(!isLikedState);
|
||||
setLikesState(isLikedState ? likesState - 1 : likesState + 1);
|
||||
|
||||
// // Trigger animation
|
||||
// if (!isLikedState) {
|
||||
// setIsAnimating(true);
|
||||
// setTimeout(() => setIsAnimating(false), 1000); // match animation duration
|
||||
// }
|
||||
// Trigger animation
|
||||
if (!isLikedState) {
|
||||
setIsAnimating(true);
|
||||
setTimeout(() => setIsAnimating(false), 1000); // match animation duration
|
||||
}
|
||||
|
||||
// const response = await fetch(`/api/mii/${miiId}/like`, { method: "PATCH" });
|
||||
const response = await fetch(`/api/mii/${miiId}/like`, { method: "PATCH" });
|
||||
|
||||
// if (response.ok) {
|
||||
// const { liked, count } = await response.json();
|
||||
// setIsLikedState(liked);
|
||||
// setLikesState(count);
|
||||
// } else {
|
||||
// setIsLikedState(isLikedState);
|
||||
// setLikesState(likesState);
|
||||
// }
|
||||
if (response.ok) {
|
||||
const { liked, count } = await response.json();
|
||||
setIsLikedState(liked);
|
||||
setLikesState(count);
|
||||
} else {
|
||||
setIsLikedState(isLikedState);
|
||||
setLikesState(likesState);
|
||||
}
|
||||
};
|
||||
|
||||
// Preload like button icons
|
||||
|
|
@ -56,9 +56,9 @@ export default function LikeButton({ likes, isLiked, miiId, disabled, abbreviate
|
|||
loadIcons(["icon-park-solid:like", "icon-park-outline:like"]);
|
||||
}, []);
|
||||
|
||||
// useEffect(() => {
|
||||
// setIsLikedState(isLiked);
|
||||
// }, [isLiked]);
|
||||
useEffect(() => {
|
||||
setIsLikedState(isLiked);
|
||||
}, [isLiked]);
|
||||
|
||||
return (
|
||||
<button
|
||||
|
|
|
|||
|
|
@ -23,12 +23,12 @@ export default function MiiGrid({ miis, userId, parentPage }: Props) {
|
|||
const session = useSession();
|
||||
const router = useRouter();
|
||||
|
||||
// const ids = miis.map((m) => m.id).join(",");
|
||||
// const { data } = useSWR<number[]>(session.data?.user && miis.length > 0 ? `/api/mii/has-liked?ids=${ids}` : null, fetcher, {
|
||||
// revalidateOnFocus: false,
|
||||
// revalidateOnReconnect: false,
|
||||
// });
|
||||
const likedIds = new Set([0]);
|
||||
const ids = miis.map((m) => m.id).join(",");
|
||||
const { data } = useSWR<number[]>(session.data?.user && miis.length > 0 ? `/api/mii/has-liked?ids=${ids}` : null, fetcher, {
|
||||
revalidateOnFocus: false,
|
||||
revalidateOnReconnect: false,
|
||||
});
|
||||
const likedIds = new Set(data ?? []);
|
||||
|
||||
return (
|
||||
<div className="grid grid-cols-4 gap-4 max-lg:grid-cols-3 max-md:grid-cols-2 max-[30rem]:grid-cols-1">
|
||||
|
|
|
|||
|
|
@ -13,11 +13,10 @@ export const { handlers, signIn, signOut, auth } = NextAuth({
|
|||
signIn: "/login",
|
||||
},
|
||||
callbacks: {
|
||||
async signIn({ user, account, profile }) {
|
||||
async signIn({ user }) {
|
||||
const blacklist = process.env.BLACKLISTED_EMAILS ? process.env.BLACKLISTED_EMAILS.split(",").map((item) => item.trim().toLowerCase()) : [];
|
||||
const email = user?.email?.toLowerCase();
|
||||
if (!email) return false;
|
||||
if (account?.provider === "google" && (profile as { email_verified?: boolean })?.email_verified === false) return false;
|
||||
if (blacklist?.some((blocked) => email.endsWith(blocked))) return false;
|
||||
return true;
|
||||
},
|
||||
|
|
|
|||
|
|
@ -107,13 +107,4 @@ export class RateLimit {
|
|||
if (!this.data.success) return this.sendResponse({ error: "Rate limit exceeded. Please try again later." }, 429);
|
||||
return;
|
||||
}
|
||||
|
||||
// IP-only variant — skips the session lookup for anonymous read paths like images
|
||||
async handleByIp(): Promise<NextResponse<object | unknown> | undefined> {
|
||||
const ip = this.request.headers.get("CF-Connecting-IP") || this.request.headers.get("X-Forwarded-For")?.split(",")[0] || "anonymous";
|
||||
this.data = await this.check(ip);
|
||||
|
||||
if (!this.data.success) return this.sendResponse({ error: "Rate limit exceeded. Please try again later." }, 429);
|
||||
return;
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in a new issue