Merge pull request #15 from BeamlakAschalew/dev

added daddylive back
BeamlakAschalew · Feb 21, 2024 · 9e96934 · 9e96934
2 parents 53b72ed + 990954f
commit 9e96934
Show file tree

Hide file tree

Showing 18 changed files with 83 additions and 26 deletions.
diff --git a/src/constants/api_constants.ts b/src/constants/api_constants.ts
@@ -3,3 +3,8 @@ dotenv.config();
 
 export const tmdbBaseUrl = "https://api.themoviedb.org";
 export const tmdbKey = process.env.TMDB_KEY;
+export const daddyliveReferrer = "https://olalivehdplay.ru/z.m3u8";
+export const daddyliveUserAgent = "MXPlayer/1.50.1 (Linux; Android 13; en-GB; SM-M127G Build/TP1A.220624.014.M127GXXU6DWJ1)";
+export const daddyliveStreamBaseUrl = "https://webudit.webhd.ru/lb/premium"
+export const daddyliveTrailingUrl = `/index.m3u8?|referer=${daddyliveReferrer}`;
+export const daddylive247Url = "https://dlhd.sx/24-7-channels.php";
diff --git a/src/index.ts b/src/index.ts
@@ -10,16 +10,12 @@ import vidsrc from "./routes/vidsrc";
 import vidsrcto from "./routes/vidsrcto";
 import kissasian from "./routes/kissasian";
 import goojara from "./routes/goojara";
+import daddylive from "./routes/daddylive";
 import nepu from "./routes/nepu";
 import chalk from "chalk";
 import FastifyCors from "@fastify/cors";
 import dotenv from "dotenv";
 import Redis from "ioredis";
-import {
-    buildProviders,
-    makeProviders,
-    makeStandardFetcher,
-} from "@movie-web/providers";
 dotenv.config();
 
 export const workers_url = process.env.WORKERS_URL && process.env.WORKERS_URL;
@@ -73,17 +69,11 @@ async function startServer() {
     await fastify.register(kissasian, { prefix: "/kissasian" });
     await fastify.register(goojara, { prefix: "/goojara" });
     await fastify.register(nepu, { prefix: "/nepu" });
+    await fastify.register(daddylive, {prefix: "/daddylive"});
 
     try {
         fastify.get("/", async (_, rp) => {
-            let p = buildProviders()
-                .setTarget('any')
-                .setFetcher(makeStandardFetcher(fetch))
-                .addBuiltinProviders()
-                .build();
-            console.log(p.listSources());
-
-            let prov = rp.status(200).send("Welcome to FlixQuest API! 🎉");
+            rp.status(200).send("Welcome to FlixQuest API! 🎉");
         });
         fastify.get("*", (request, reply) => {
             reply.status(404).send({

diff --git a/src/providers/daddylive.ts b/src/providers/daddylive.ts
@@ -0,0 +1,33 @@
+import axios from "axios";
+import { load } from "cheerio";
+import { ChannelEntry } from "../utils/types";
+import { daddylive247Url } from "../constants/api_constants";
+
+export async function get247() : Promise<ChannelEntry[] | null> {
+    const channels = await axios.get(daddylive247Url);
+    const $ = load(channels.data);
+    const firstGridContainer = $('.grid-container').first();
+    const gridItems = firstGridContainer.find('.grid-item').toArray();
+
+    const parsedChannels: ChannelEntry[] = [];
+    gridItems.forEach((element) => {
+        const isChannelIdValid = extractChannelId($(element).find('a').attr('href')!);
+        if (typeof isChannelIdValid !== "boolean" && !$(element).find('strong').text().startsWith("18+")) {
+            parsedChannels.push({id: isChannelIdValid, channel_name: $(element).find('strong').text()});
+        }
+    });
+
+
+    return parsedChannels;
+}
+
+function extractChannelId(text: string) : number | boolean {
+    const regex = /(\d+)/;
+    const match = text.match(regex);
+
+    if (match) {
+        return Number.parseInt(match[0]);
+    } else {
+        return false;
+    }
+}
diff --git a/src/routes/daddylive.ts b/src/routes/daddylive.ts
@@ -0,0 +1,24 @@
+import { FastifyInstance } from "fastify";
+import { get247 } from "../providers/daddylive";
+import { daddyliveReferrer, daddyliveStreamBaseUrl, daddyliveTrailingUrl, daddyliveUserAgent } from "../constants/api_constants";
+
+const routes = async (fastify: FastifyInstance) => {
+    fastify.get("/", async (_, rp) => {
+
+        rp.status(200).send({
+            intro: "Welcome to the daddylive provider",
+            routes: "/live",
+        });
+    });
+
+    fastify.get("/live", async (_, rp) => {
+        const channels = await get247();
+        if (channels) {
+            rp.status(200).send({base_url: daddyliveStreamBaseUrl, trailing_url: daddyliveTrailingUrl, referrer: daddyliveReferrer, user_agent: daddyliveUserAgent, channels: channels});
+        } else {
+            rp.status(500).send({message: "Unknown error occured. Could not fetch channels"});
+        }
+    });
+};
+
+export default routes;
diff --git a/src/routes/flixhq.ts b/src/routes/flixhq.ts
@@ -4,7 +4,7 @@ import {
     fetchHlsLinks,
     fetchMovieData,
     fetchTVData,
-} from "../models/functions";
+} from "../utils/functions";
 
 const routes = async (fastify: FastifyInstance) => {
     fastify.get("/", (_, rp) => {

diff --git a/src/routes/gomovies.ts b/src/routes/gomovies.ts
@@ -4,7 +4,7 @@ import {
     fetchHlsLinks,
     fetchMovieData,
     fetchTVData,
-} from "../models/functions";
+} from "../utils/functions";
 
 const routes = async (fastify: FastifyInstance) => {
     fastify.get("/", (_, rp) => {

diff --git a/src/routes/goojara.ts b/src/routes/goojara.ts
@@ -4,7 +4,7 @@ import {
     fetchHlsLinks,
     fetchMovieData,
     fetchTVData,
-} from "../models/functions";
+} from "../utils/functions";
 
 const routes = async (fastify: FastifyInstance) => {
     fastify.get("/", (_, rp) => {

diff --git a/src/routes/kissasian.ts b/src/routes/kissasian.ts
@@ -4,7 +4,7 @@ import {
     fetchHlsLinks,
     fetchMovieData,
     fetchTVData,
-} from "../models/functions";
+} from "../utils/functions";
 
 const routes = async (fastify: FastifyInstance) => {
     fastify.get("/", (_, rp) => {

diff --git a/src/routes/nepu.ts b/src/routes/nepu.ts
@@ -4,7 +4,7 @@ import {
     fetchHlsLinks,
     fetchMovieData,
     fetchTVData,
-} from "../models/functions";
+} from "../utils/functions";
 
 const routes = async (fastify: FastifyInstance) => {
     fastify.get("/", (_, rp) => {

diff --git a/src/routes/remotestream.ts b/src/routes/remotestream.ts
@@ -4,7 +4,7 @@ import {
     fetchHlsLinks,
     fetchMovieData,
     fetchTVData,
-} from "../models/functions";
+} from "../utils/functions";
 
 const routes = async (fastify: FastifyInstance) => {
     fastify.get("/", (_, rp) => {

diff --git a/src/routes/ridomovies.ts b/src/routes/ridomovies.ts
@@ -4,7 +4,7 @@ import {
     fetchHlsLinks,
     fetchMovieData,
     fetchTVData,
-} from "../models/functions";
+} from "../utils/functions";
 
 const routes = async (fastify: FastifyInstance) => {
     fastify.get("/", (_, rp) => {

diff --git a/src/routes/showbox.ts b/src/routes/showbox.ts
@@ -1,6 +1,6 @@
 import { MovieMedia, ShowMedia } from "@movie-web/providers";
 import { FastifyRequest, FastifyReply, FastifyInstance } from "fastify";
-import { fetchDash, fetchMovieData, fetchTVData } from "../models/functions";
+import { fetchDash, fetchMovieData, fetchTVData } from "../utils/functions";
 
 const routes = async (fastify: FastifyInstance) => {
     fastify.get("/", (_, rp) => {

diff --git a/src/routes/smashystream.ts b/src/routes/smashystream.ts
@@ -4,7 +4,7 @@ import {
     fetchHlsLinks,
     fetchMovieData,
     fetchTVData,
-} from "../models/functions";
+} from "../utils/functions";
 
 const routes = async (fastify: FastifyInstance) => {
     fastify.get("/", (_, rp) => {

diff --git a/src/routes/vidsrc.ts b/src/routes/vidsrc.ts
@@ -4,7 +4,7 @@ import {
     fetchHlsLinks,
     fetchMovieData,
     fetchTVData,
-} from "../models/functions";
+} from "../utils/functions";
 
 const routes = async (fastify: FastifyInstance) => {
     fastify.get("/", (_, rp) => {

diff --git a/src/routes/vidsrcto.ts b/src/routes/vidsrcto.ts
@@ -4,7 +4,7 @@ import {
     fetchHlsLinks,
     fetchMovieData,
     fetchTVData,
-} from "../models/functions";
+} from "../utils/functions";
 
 const routes = async (fastify: FastifyInstance) => {
     fastify.get("/", (_, rp) => {

diff --git a/src/routes/zoe.ts b/src/routes/zoe.ts
@@ -4,7 +4,7 @@ import {
     fetchHlsLinks,
     fetchMovieData,
     fetchTVData,
-} from "../models/functions";
+} from "../utils/functions";
 
 const routes = async (fastify: FastifyInstance) => {
     fastify.get("/", (_, rp) => {

diff --git a/src/models/functions.ts → src/utils/functions.ts b/src/models/functions.ts → src/utils/functions.ts
@@ -13,7 +13,7 @@ import { tmdbBaseUrl, tmdbKey } from "../constants/api_constants";
 import { ResolutionStream, SubData, supportedLanguages } from "./types";
 import { FastifyReply } from "fastify";
 import { redis } from "../index";
-import cache from "../utils/cache";
+import cache from "./cache";
 dotenv.config();
 const proxyUrl = process.env.WORKERS_URL;
 

diff --git a/src/models/types.ts → src/utils/types.ts b/src/models/types.ts → src/utils/types.ts
@@ -14,6 +14,11 @@ export type SubFormat = {
     longName: string;
 };
 
+export type ChannelEntry = {
+    channel_name: string;
+    id: number;
+}
+
 export const supportedLanguages: SubFormat[] = [
     { shortCode: "ar", longName: "Arabic" },
     { shortCode: "bg", longName: "Bulgarian" },