feat: add catalog, meta, posts, and stream modules for Animetsu provider

providers/animetsu/stream.ts

@@ -0,0 +1,94 @@
+import { Stream, ProviderContext } from "../types";
+
+export const getStream = async function ({
+  link: id,
+  providerContext,
+}: {
+  link: string;
+  providerContext: ProviderContext;
+}): Promise<Stream[]> {
+  try {
+    const { axios } = providerContext;
+    const baseUrl = "https://backend.animetsu.to";
+
+    // Parse link format: "animeId:episodeNumber"
+    const [animeId, episodeNumber] = id.split(":");
+
+    if (!animeId || !episodeNumber) {
+      throw new Error("Invalid link format");
+    }
+
+    const servers = ["pahe", "zoro"]; // Available servers based on API structure
+    const streamLinks: Stream[] = [];
+
+    await Promise.all(
+      servers.map(async (server) => {
+        try {
+          const url = `${baseUrl}/api/anime/tiddies?server=${server}&id=${animeId}&num=${episodeNumber}&subType=sub`;
+
+          const res = await axios.get(url, {
+            headers: {
+              Referer: "https://animetsu.to/",
+            },
+          });
+
+          if (res.data && res.data.sources) {
+            res.data.sources.forEach((source: any) => {
+              streamLinks.push({
+                server: server,
+                link: source.url,
+                type: source.url.includes(".m3u8") ? "m3u8" : "mp4",
+                quality: source.quality,
+                headers: {
+                  Referer: "https://animetsu.to/",
+                  Origin: "https://animetsu.to",
+                },
+                subtitles: [], // No subtitle info provided in API response
+              });
+            });
+          }
+        } catch (e) {
+          console.log(`Error with server ${server}:`, e);
+        }
+      })
+    );
+
+    // Try dub version as well
+    await Promise.all(
+      servers.map(async (server) => {
+        try {
+          const url = `${baseUrl}/api/anime/tiddies?server=${server}&id=${animeId}&num=${episodeNumber}&subType=dub`;
+
+          const res = await axios.get(url, {
+            headers: {
+              Referer: "https://animetsu.to/",
+            },
+          });
+
+          if (res.data && res.data.sources) {
+            res.data.sources.forEach((source: any) => {
+              streamLinks.push({
+                server: `${server} (Dub)`,
+                link: source.url,
+                type: source.url.includes(".m3u8") ? "m3u8" : "mp4",
+                quality: source.quality,
+                headers: {
+                  Referer: "https://animetsu.to/",
+                  Origin: "https://animetsu.to",
+                },
+                subtitles: [],
+              });
+            });
+          }
+        } catch (e) {
+          console.log(`Error with server ${server} (dub):`, e);
+        }
+      })
+    );
+
+    return streamLinks;
+  } catch (err) {
+    console.error("animetsu stream error:", err);
+    return [];
+  }
+};