aboutsummaryrefslogtreecommitdiff
path: root/pages/api/v2/etc/schedule/index.js
diff options
context:
space:
mode:
authorFactiven <[email protected]>2023-12-24 13:03:54 +0700
committerFactiven <[email protected]>2023-12-24 13:03:54 +0700
commit50a0f0240d7fef133eb5acc1bea2b1168b08e9db (patch)
tree307e09e505580415a58d64b5fc3580e9235869f1 /pages/api/v2/etc/schedule/index.js
parentUpdate README.md (#104) (diff)
downloadmoopa-50a0f0240d7fef133eb5acc1bea2b1168b08e9db.tar.xz
moopa-50a0f0240d7fef133eb5acc1bea2b1168b08e9db.zip
migrate to typescript
Diffstat (limited to 'pages/api/v2/etc/schedule/index.js')
-rw-r--r--pages/api/v2/etc/schedule/index.js77
1 files changed, 0 insertions, 77 deletions
diff --git a/pages/api/v2/etc/schedule/index.js b/pages/api/v2/etc/schedule/index.js
deleted file mode 100644
index 2ddc82a..0000000
--- a/pages/api/v2/etc/schedule/index.js
+++ /dev/null
@@ -1,77 +0,0 @@
-import axios from "axios";
-import cron from "cron";
-import { rateLimiterRedis, redis } from "@/lib/redis";
-
-// Function to fetch new data
-async function fetchData() {
- try {
- const { data } = await axios.get(
- `https://api.anify.tv/schedule?fields=[id,coverImage,title,bannerImage]`
- );
- return data;
- } catch (error) {
- console.error("Error fetching data:", error);
- return null;
- }
-}
-
-// Function to refresh the cache with new data
-async function refreshCache() {
- const newData = await fetchData();
- if (newData) {
- if (redis) {
- await redis.set(
- "schedule",
- JSON.stringify(newData),
- "EX",
- 60 * 60 * 24 * 7
- );
- }
- console.log("Cache refreshed successfully.");
- }
-}
-
-// Schedule cache refresh every Monday at 00:00 AM (local time)
-const job = new cron.CronJob("0 0 * * 1", () => {
- refreshCache();
-});
-job.start();
-
-export default async function handler(req, res) {
- try {
- let cached;
- if (redis) {
- try {
- const ipAddress = req.socket.remoteAddress;
- await rateLimiterRedis.consume(ipAddress);
- } catch (error) {
- return res.status(429).json({
- error: `Too Many Requests, retry after ${error.msBeforeNext / 1000}`,
- });
- }
- cached = await redis.get("schedule");
- }
- if (cached) {
- return res.status(200).json(JSON.parse(cached));
- } else {
- const data = await fetchData();
-
- if (data) {
- // cacheData.put("schedule", data, 1000 * 60 * 60 * 24 * 7);
- if (redis) {
- await redis.set(
- "schedule",
- JSON.stringify(data),
- "EX",
- 60 * 60 * 24 * 7
- );
- }
- return res.status(200).json(data);
- } else {
- return res.status(404).json({ message: "Schedule not found" });
- }
- }
- } catch (error) {
- res.status(500).json({ error });
- }
-}