Compare commits
4
Commits
@@ -58,3 +58,4 @@ node_modules/
|
||||
|
||||
.direnv
|
||||
!.envrc
|
||||
.env*
|
||||
|
||||
+11
-10
@@ -17,16 +17,17 @@ export default function Home() {
|
||||
<div className="mx-auto flex min-h-dvh w-full max-w-6xl flex-col">
|
||||
<section>
|
||||
<center>
|
||||
<Link href="https://www.youtube.com/@Genshinmaichaigamemurtur">
|
||||
<Image
|
||||
src={Banner}
|
||||
alt="Banner"
|
||||
className="mt-24 w-3/4 rounded-t-xl sm:w-125"
|
||||
width={500}
|
||||
height={100}
|
||||
fetchPriority="high"
|
||||
/>
|
||||
</Link>
|
||||
{/* TEMPORARY: Hacked channel */}
|
||||
{/* <Link href="https://www.youtube.com/@Genshinmaichaigamemurtur"> */}
|
||||
<Image
|
||||
src={Banner}
|
||||
alt="Banner"
|
||||
className="mt-24 w-3/4 rounded-t-xl sm:w-125"
|
||||
width={500}
|
||||
height={100}
|
||||
fetchPriority="high"
|
||||
/>
|
||||
{/* </Link> */}
|
||||
</center>
|
||||
</section>
|
||||
|
||||
|
||||
@@ -40,7 +40,7 @@ export async function GET() {
|
||||
);
|
||||
return Response.json(
|
||||
{ red, ...res },
|
||||
{ status: red ? (res.database ? 200 : 201) : 503 },
|
||||
{ status: res.database && red ? 200 : 201 },
|
||||
);
|
||||
}
|
||||
|
||||
|
||||
@@ -63,7 +63,8 @@ export async function GET(req: NextRequest) {
|
||||
const channelId = process.env.YOUTUBE_CHANNEL_ID;
|
||||
const apiKey = process.env.YOUTUBE_API_KEY;
|
||||
|
||||
if (!apiKey || !channelId) return NextResponse.json<YoutubeLiveInfo>("none");
|
||||
// TEMPORARY: Hacked channel
|
||||
if (!apiKey || !channelId && true) return NextResponse.json<YoutubeLiveInfo>("none");
|
||||
|
||||
const response = await youtubeCache.fetch(
|
||||
`https://www.googleapis.com/youtube/v3/search?part=snippet&channelId=${channelId}&eventType=live&type=video&maxResults=1&key=${apiKey}`,
|
||||
|
||||
+5
-2
@@ -1,7 +1,10 @@
|
||||
import ReconnectingEventSource from "reconnecting-eventsource";
|
||||
import type z from "zod";
|
||||
|
||||
export const redis = typeof Bun !== "undefined" ? Bun.redis : null;
|
||||
export const redis =
|
||||
typeof Bun !== "undefined"
|
||||
? new Bun.RedisClient(undefined, { maxRetries: 0xffffffff })
|
||||
: null;
|
||||
|
||||
type PubPayload = { event?: string; data: unknown };
|
||||
|
||||
@@ -126,7 +129,7 @@ export class EventSourceEndpoint<T extends EventSourceEventMap> {
|
||||
throw new Error(
|
||||
"EventSourceEndpoint.pub(...) can only be called on the server.",
|
||||
);
|
||||
return this.manager.publish(this.eventMap[event].parse(data), {
|
||||
this.manager.publish(this.eventMap[event].parse(data), {
|
||||
topic: this.endpoint,
|
||||
event: String(event),
|
||||
});
|
||||
|
||||
Reference in New Issue
Block a user