feat(routes): Add new providers and routes for movies

src/routes/movies/dramacool.ts

@@ -8,20 +8,27 @@ const routes = async (fastify: FastifyInstance, options: RegisterOptions) => {
   fastify.get('/', (_, rp) => {
     rp.status(200).send({
       intro:
-        "Welcome to the flixhq provider: check out the provider's website @ https://flixhq.to/",
-      routes: ['/:query', '/info', '/watch', '/popular'],
-      documentation: 'https://docs.consumet.org/#tag/flixhq',
+        "Welcome to the dramacool provider: check out the provider's website @ https://dramacool.com.pa/",
+      routes: ['/:query', '/info', '/watch', '/popular','/recent-movies', '/recent-shows'],
+      documentation: 'https://docs.consumet.org/#tag/dramacool',
     });
   });
 
   fastify.get('/:query', async (request: FastifyRequest, reply: FastifyReply) => {
-    const query = decodeURIComponent((request.params as { query: string }).query);
-
-    const page = (request.query as { page: number }).page;
-
-    const res = await dramacool.search(query, page);
-
-    reply.status(200).send(res);
+    try {
+      const query = decodeURIComponent((request.params as { query: string }).query);
+
+      const page = (request.query as { page: number }).page;
+
+      const res = await dramacool.search(query, page);
+
+      reply.status(200).send(res);
+    } catch (err) {
+      reply.status(500).send({
+        message:
+          'Something went wrong. Please try again later. or contact the developers.',
+      });
+    }
   });
 
   fastify.get('/info', async (request: FastifyRequest, reply: FastifyReply) => {
@@ -77,6 +84,30 @@ const routes = async (fastify: FastifyInstance, options: RegisterOptions) => {
         .send({ message: 'Something went wrong. Please try again later.' });
     }
   })
+
+  fastify.get("/recent-movies", async (request: FastifyRequest, reply: FastifyReply) => {
+    const page = (request.query as { page: number }).page;
+    try {
+      const res = await dramacool.fetchRecentMovies(page ? page : 1);
+      reply.status(200).send(res);
+    } catch (err) {
+      reply
+        .status(500)
+        .send({ message: 'Something went wrong. Please try again later.' });
+    }
+  })
+
+  fastify.get("/recent-shows", async (request: FastifyRequest, reply: FastifyReply) => {
+    const page = (request.query as { page: number }).page;
+    try {
+      const res = await dramacool.fetchRecentTvShows(page ? page : 1);
+      reply.status(200).send(res);
+    } catch (err) {
+      reply
+        .status(500)
+        .send({ message: 'Something went wrong. Please try again later.' });
+    }
+  })
 };
 
 export default routes;

src/routes/movies/flixhq.ts

@@ -13,7 +13,7 @@ const routes = async (fastify: FastifyInstance, options: RegisterOptions) => {
     rp.status(200).send({
       intro:
         "Welcome to the flixhq provider: check out the provider's website @ https://flixhq.to/",
-      routes: ['/:query', '/info', '/watch','/recent-shows','/recent-movies','/trending','/servers'],
+      routes: ['/:query', '/info', '/watch','/recent-shows','/recent-movies','/trending','/servers','/country','/genre'],
       documentation: 'https://docs.consumet.org/#tag/flixhq',
     });
   });
@@ -200,26 +200,26 @@ const routes = async (fastify: FastifyInstance, options: RegisterOptions) => {
   });
 
 
-fastify.get('/genre/:genre', async (request: FastifyRequest, reply: FastifyReply) => {
-  const genre = (request.params as { genre: string }).genre;
-  const page = (request.query as { page: number }).page ?? 1;
-  try {
-    let res = redis
-      ? await cache.fetch(
-        redis as Redis,
-        `flixhq:genre:${genre}:${page}`,
-        async () => await flixhq.fetchByGenre(genre, page),
-        60 * 60 * 3,
-      )
-      : await flixhq.fetchByGenre(genre, page);
+  fastify.get('/genre/:genre', async (request: FastifyRequest, reply: FastifyReply) => {
+    const genre = (request.params as { genre: string }).genre;
+    const page = (request.query as { page: number }).page ?? 1;
+    try {
+      let res = redis
+        ? await cache.fetch(
+          redis as Redis,
+          `flixhq:genre:${genre}:${page}`,
+          async () => await flixhq.fetchByGenre(genre, page),
+          60 * 60 * 3,
+        )
+        : await flixhq.fetchByGenre(genre, page);
 
-    reply.status(200).send(res);
-  } catch (error) {
-    reply.status(500).send({
-      message:
-        'Something went wrong. Please try again later. or contact the developers.',
-    });
-  }
-});
+      reply.status(200).send(res);
+    } catch (error) {
+      reply.status(500).send({
+        message:
+          'Something went wrong. Please try again later. or contact the developers.',
+      });
+    }
+  });
 };
 export default routes;

src/routes/movies/goku.ts

@@ -0,0 +1,249 @@
+import {
+    FastifyRequest,
+    FastifyReply,
+    FastifyInstance,
+    RegisterOptions,
+} from "fastify";
+import { MOVIES } from "@consumet/extensions";
+import { StreamingServers } from "@consumet/extensions/dist/models";
+
+import cache from "../../utils/cache";
+import { redis } from "../../main";
+import { Redis } from "ioredis";
+
+const routes = async (fastify: FastifyInstance, options: RegisterOptions) => {
+    const goku = new MOVIES.Goku();
+    fastify.get("/", (_, rp) => {
+        rp.status(200).send({
+            intro:
+                "Welcome to the goku provider: check out the provider's website @ https://goku.sx",
+            routes: ['/:query', '/info', '/watch','/recent-shows','/recent-movies','/trending','/servers','/country','/genre'],
+            documentation: "https://docs.consumet.org/#tag/goku",
+        });
+    });
+
+    fastify.get(
+        "/:query",
+        async (request: FastifyRequest, reply: FastifyReply) => {
+            const query = decodeURIComponent(
+                (request.params as { query: string }).query
+            );
+
+            const page = (request.query as { page: number }).page;
+
+            let res = redis
+                ? await cache.fetch(
+                    redis as Redis,
+                    `goku:${query}:${page}`,
+                    async () => await goku.search(query, page ? page : 1),
+                    60 * 60 * 6
+                )
+                : await goku.search(query, page ? page : 1);
+
+            reply.status(200).send(res);
+        }
+    );
+
+    fastify.get(
+        "/recent-shows",
+        async (request: FastifyRequest, reply: FastifyReply) => {
+            let res = redis
+                ? await cache.fetch(
+                    redis as Redis,
+                    `goku:recent-shows`,
+                    async () => await goku.fetchRecentTvShows(),
+                    60 * 60 * 3
+                )
+                : await goku.fetchRecentTvShows();
+
+            reply.status(200).send(res);
+        }
+    );
+
+    fastify.get(
+        "/recent-movies",
+        async (request: FastifyRequest, reply: FastifyReply) => {
+            let res = redis
+                ? await cache.fetch(
+                    redis as Redis,
+                    `goku:recent-movies`,
+                    async () => await goku.fetchRecentMovies(),
+                    60 * 60 * 3
+                )
+                : await goku.fetchRecentMovies();
+
+            reply.status(200).send(res);
+        }
+    );
+
+    fastify.get(
+        "/trending",
+        async (request: FastifyRequest, reply: FastifyReply) => {
+            const type = (request.query as { type: string }).type;
+            try {
+                if (!type) {
+                    const res = {
+                        results: [
+                            ...(await goku.fetchTrendingMovies()),
+                            ...(await goku.fetchTrendingTvShows()),
+                        ],
+                    };
+                    return reply.status(200).send(res);
+                }
+
+                let res = redis
+                    ? await cache.fetch(
+                        redis as Redis,
+                        `goku:trending:${type}`,
+                        async () =>
+                            type === "tv"
+                                ? await goku.fetchTrendingTvShows()
+                                : await goku.fetchTrendingMovies(),
+                        60 * 60 * 3
+                    )
+                    : type === "tv"
+                        ? await goku.fetchTrendingTvShows()
+                        : await goku.fetchTrendingMovies();
+
+                reply.status(200).send(res);
+            } catch (error) {
+                reply.status(500).send({
+                    message:
+                        "Something went wrong. Please try again later. or contact the developers.",
+                });
+            }
+        }
+    );
+
+    fastify.get("/info", async (request: FastifyRequest, reply: FastifyReply) => {
+        const id = (request.query as { id: string }).id;
+
+        if (typeof id === "undefined")
+            return reply.status(400).send({
+                message: "id is required",
+            });
+
+        try {
+            let res = redis
+                ? await cache.fetch(
+                    redis as Redis,
+                    `goku:info:${id}`,
+                    async () => await goku.fetchMediaInfo(id),
+                    60 * 60 * 3
+                )
+                : await goku.fetchMediaInfo(id);
+
+            reply.status(200).send(res);
+        } catch (err) {
+            reply.status(500).send({
+                message:
+                    "Something went wrong. Please try again later. or contact the developers.",
+            });
+        }
+    });
+
+    fastify.get(
+        "/watch",
+        async (request: FastifyRequest, reply: FastifyReply) => {
+            const episodeId = (request.query as { episodeId: string }).episodeId;
+            const mediaId = (request.query as { mediaId: string }).mediaId;
+            const server = (request.query as { server: StreamingServers }).server;
+            if (typeof episodeId === "undefined")
+                return reply.status(400).send({ message: "episodeId is required" });
+            if (typeof mediaId === "undefined")
+                return reply.status(400).send({ message: "mediaId is required" });
+
+            if (server && !Object.values(StreamingServers).includes(server))
+                return reply.status(400).send({ message: "Invalid server query" });
+
+            try {
+                let res = redis
+                    ? await cache.fetch(
+                        redis as Redis,
+                        `goku:watch:${episodeId}:${mediaId}:${server}`,
+                        async () =>
+                            await goku.fetchEpisodeSources(episodeId, mediaId, server),
+                        60 * 30
+                    )
+                    : await goku.fetchEpisodeSources(episodeId, mediaId, StreamingServers.VidCloud);
+                reply.status(200).send(res);
+            } catch (err) {
+                reply
+                    .status(500)
+                    .send({ message: "Something went wrong. Please try again later." });
+            }
+        }
+    );
+
+    fastify.get(
+        "/servers",
+        async (request: FastifyRequest, reply: FastifyReply) => {
+            const episodeId = (request.query as { episodeId: string }).episodeId;
+            const mediaId = (request.query as { mediaId: string }).mediaId;
+            try {
+                let res = redis
+                    ? await cache.fetch(
+                        redis as Redis,
+                        `goku:servers:${episodeId}:${mediaId}`,
+                        async () => await goku.fetchEpisodeServers(episodeId, mediaId),
+                        60 * 30
+                    )
+                    : await goku.fetchEpisodeServers(episodeId, mediaId);
+
+                reply.status(200).send(res);
+            } catch (error) {
+                reply.status(500).send({
+                    message:
+                        "Something went wrong. Please try again later. or contact the developers.",
+                });
+            }
+        }
+    );
+
+    fastify.get('/country/:country', async (request: FastifyRequest, reply: FastifyReply) => {
+        const country = (request.params as { country: string }).country;
+        const page = (request.query as { page: number }).page ?? 1;
+        try {
+          let res = redis
+            ? await cache.fetch(
+              redis as Redis,
+              `goku:country:${country}:${page}`,
+              async () => await goku.fetchByCountry(country, page),
+              60 * 60 * 3,
+            )
+            : await goku.fetchByCountry(country, page);
+
+          reply.status(200).send(res);
+        } catch (error) {
+          reply.status(500).send({
+            message:
+              'Something went wrong. Please try again later. or contact the developers.',
+          });
+        }
+      });
+
+
+    fastify.get('/genre/:genre', async (request: FastifyRequest, reply: FastifyReply) => {
+      const genre = (request.params as { genre: string }).genre;
+      const page = (request.query as { page: number }).page ?? 1;
+      try {
+        let res = redis
+          ? await cache.fetch(
+            redis as Redis,
+            `goku:genre:${genre}:${page}`,
+            async () => await goku.fetchByGenre(genre, page),
+            60 * 60 * 3,
+          )
+          : await goku.fetchByGenre(genre, page);
+
+        reply.status(200).send(res);
+      } catch (error) {
+        reply.status(500).send({
+          message:
+            'Something went wrong. Please try again later. or contact the developers.',
+        });
+      }
+    });
+};
+
+export default routes;

src/routes/movies/index.ts

@@ -5,11 +5,15 @@ import flixhq from './flixhq';
 import viewasian from './viewasian';
 import dramacool from './dramacool';
 import fmovies from './fmovies';
+import goku from './goku';
+import movieshd from './movieshd';
 const routes = async (fastify: FastifyInstance, options: RegisterOptions) => {
   await fastify.register(flixhq, { prefix: '/flixhq' });
   await fastify.register(viewasian, { prefix: '/viewasian' });
   await fastify.register(dramacool, { prefix: '/dramacool' });
   await fastify.register(fmovies, { prefix: '/fmovies' });
+  await fastify.register(goku, { prefix: '/goku' });
+  await fastify.register(movieshd, { prefix: '/movieshd' });
   fastify.get('/', async (request: any, reply: any) => {
     reply.status(200).send('Welcome to Consumet Movies and TV Shows');
   });