5 files changed, 207 insertions, 3 deletions
diff --git a/pages/api/anify/info/[id].js b/pages/api/anify/info/[id].js
new file mode 100644
index 0000000..c33d158
--- /dev/null
+++ b/pages/api/anify/info/[id].js
@@ -0,0 +1,37 @@
+import axios from "axios";
+import cacheData from "memory-cache";
+
+const API_KEY = process.env.API_KEY;
+
+// Function to fetch new data
+export async function fetchInfo(id) {
+  try {
+    const { data } = await axios.get(
+      `https://api.anify.tv/info/${id}?apikey=${API_KEY}`
+    );
+    return data;
+  } catch (error) {
+    console.error("Error fetching data:", error);
+    return null;
+  }
+}
+
+export default async function handler(req, res) {
+  try {
+    const id = req.query.id;
+    const cached = cacheData.get(id);
+    if (cached) {
+      return res.status(200).json(cached);
+    } else {
+      const data = await fetchInfo(id);
+      if (data) {
+        res.status(200).json(data);
+        cacheData.put(id, data, 1000 * 60 * 10);
+      } else {
+        res.status(404).json({ message: "Schedule not found" });
+      }
+    }
+  } catch (error) {
+    res.status(500).json({ error });
+  }
+}
diff --git a/pages/api/anify/page/[...params].js b/pages/api/anify/page/[...params].js
new file mode 100644
index 0000000..80dda6c
--- /dev/null
+++ b/pages/api/anify/page/[...params].js
@@ -0,0 +1,41 @@
+import axios from "axios";
+import cacheData from "memory-cache";
+
+const API_KEY = process.env.API_KEY;
+
+// Function to fetch new data
+async function fetchData(id, providerId, chapterId) {
+  try {
+    const res = await fetch(
+      `https://api.anify.tv/pages?id=${id}&providerId=${providerId}&readId=${chapterId}&apikey=${API_KEY}`
+    );
+    const data = await res.json();
+    return data;
+    // return { id, providerId, chapterId };
+  } catch (error) {
+    console.error("Error fetching data:", error);
+    return null;
+  }
+}
+
+export default async function handler(req, res) {
+  try {
+    const id = req.query.params;
+    const chapter = req.query.chapter;
+    // res.status(200).json({ id, chapter });
+    const cached = cacheData.get(chapter);
+    if (cached) {
+      return res.status(200).json(cached);
+    } else {
+      const data = await fetchData(id[0], id[1], chapter);
+      if (data) {
+        res.status(200).json(data);
+        cacheData.put(id[2], data, 1000 * 60 * 10);
+      } else {
+        res.status(404).json({ message: "Manga/Novel not found :(" });
+      }
+    }
+  } catch (error) {
+    res.status(500).json({ error });
+  }
+}
diff --git a/pages/api/consumet/episode/[id].js b/pages/api/consumet/episode/[id].js
index 737292f..e6f40ce 100644
--- a/pages/api/consumet/episode/[id].js
+++ b/pages/api/consumet/episode/[id].js
@@ -7,12 +7,18 @@ export default async function handler(req, res) {
   try {
     const id = req.query.id;
     const dub = req.query.dub || false;
+    const refresh = req.query.refresh || false;
 
     const providers = ["enime", "gogoanime"];
     const datas = [];
 
     const cached = cacheData.get(id + dub);
-    if (cached) {
+
+    if (refresh) {
+      cacheData.del(id + dub);
+    }
+
+    if (!refresh && cached) {
       return res.status(200).json(cached);
     } else {
       async function fetchData(provider) {
@@ -31,7 +37,7 @@ export default async function handler(req, res) {
             }
             return res.json();
           });
-          if (data.episodes?.length > 0) {
+          if (data.episodes.length > 0) {
             datas.push({
               providerId: provider,
               episodes: dub ? data.episodes : data.episodes.reverse(),
@@ -53,7 +59,7 @@ export default async function handler(req, res) {
       if (datas.length === 0) {
         return res.status(404).json({ message: "Anime not found" });
       } else {
-        cacheData.put(id + dub, { data: datas }, 1000 * 60 * 60 * 15); // 15 minutes
+        cacheData.put(id + dub, { data: datas }, 1000 * 60 * 60 * 10); 
         res.status(200).json({ data: datas });
       }
     }
diff --git a/pages/api/user/profile.js b/pages/api/user/profile.js
new file mode 100644
index 0000000..2b44ae2
--- /dev/null
+++ b/pages/api/user/profile.js
@@ -0,0 +1,52 @@
+import {
+  createUser,
+  deleteUser,
+  getUser,
+  updateUser,
+} from "../../../prisma/user";
+
+export default async function handler(req, res) {
+  try {
+    switch (req.method) {
+      case "POST": {
+        const { name, setting } = req.body;
+        const new_user = await createUser(name, setting);
+        if (!new_user) {
+          return res.status(200).json({ message: "User is already created" });
+        } else {
+          return res.status(201).json(new_user);
+        }
+      }
+      case "PUT": {
+        const { name, anime } = req.body;
+        const user = await updateUser(name, anime);
+        if (!user) {
+          return res.status(200).json({ message: "Title is already there" });
+        } else {
+          return res.status(200).json(user);
+        }
+      }
+      case "GET": {
+        const { name } = req.query;
+        const user = await getUser(name);
+        if (!user) {
+          return res.status(404).json({ message: "User not found" });
+        } else {
+          return res.status(200).json(user);
+        }
+      }
+      case "DELETE": {
+        const { name } = req.body;
+        const user = await deleteUser(name);
+        if (!user) {
+          return res.status(404).json({ message: "User not found" });
+        } else {
+          return res.status(200).json(user);
+        }
+      }
+    }
+  } catch (error) {
+    console.log(error);
+    return res.status(500).json({ message: "Internal server error" });
+  }
+}
diff --git a/pages/api/user/update/episode.js b/pages/api/user/update/episode.js
new file mode 100644
index 0000000..f69bb78
--- /dev/null
+++ b/pages/api/user/update/episode.js
@@ -0,0 +1,68 @@
+import {
+  createList,
+  getEpisode,
+  updateUserEpisode,
+} from "../../../../prisma/user";
+
+export default async function handler(req, res) {
+  try {
+    switch (req.method) {
+      case "POST": {
+        const { name, id } = JSON.parse(req.body);
+
+        const episode = await createList(name, id);
+        if (!episode) {
+          return res
+            .status(200)
+            .json({ message: "Episode is already created" });
+        } else {
+          return res.status(201).json(episode);
+        }
+      }
+      case "PUT": {
+        const {
+          name,
+          id,
+          watchId,
+          title,
+          image,
+          number,
+          duration,
+          timeWatched,
+          aniTitle,
+          provider,
+        } = JSON.parse(req.body);
+        const episode = await updateUserEpisode({
+          name,
+          id,
+          watchId,
+          title,
+          image,
+          number,
+          duration,
+          timeWatched,
+          aniTitle,
+          provider,
+        });
+        if (!episode) {
+          return res.status(200).json({ message: "Episode is already there" });
+        } else {
+          return res.status(200).json(episode);
+        }
+      }
+      case "GET": {
+        const { name, id } = req.query;
+        // console.log(req.query);
+        const episode = await getEpisode(name, id);
+        if (!episode) {
+          return res.status(404).json({ message: "Episode not found" });
+        } else {
+          return res.status(200).json(episode);
+        }
+      }
+    }
+  } catch (error) {
+    console.log(error);
+    return res.status(500).json({ message: "Internal server error" });
+  }
+}