vega-providers/providers/dooflix/posts.ts

import { Post, ProviderContext } from "../types";

const headers = {
  "Accept-Encoding": "gzip",
  "API-KEY": "2pm95lc6prpdbk0ppji9rsqo",
  Connection: "Keep-Alive",
  "If-Modified-Since": "Wed, 14 Aug 2024 13:00:04 GMT",
  "User-Agent": "okhttp/3.14.9",
};

export const getPosts = async function ({
  filter,
  page,
  signal,
  providerContext,
}: {
  filter: string;
  page: number;
  providerValue: string;
  providerContext: ProviderContext;
  signal: AbortSignal;
}): Promise<Post[]> {
  try {
    const { axios, getBaseUrl } = providerContext;
    const baseUrl = await getBaseUrl("dooflix");
    const catalog: Post[] = [];
    const url = `${baseUrl + filter + `?page=${page}`}`;

    const res = await axios.get(url, { headers, signal });
    const resData = res.data;

    if (!resData || typeof resData !== "string") {
      console.warn("Unexpected response format from dooflix API");
      return [];
    }

    let data;
    try {
      const jsonStart = resData.indexOf("[");
      const jsonEnd = resData.lastIndexOf("]") + 1;

      if (jsonStart === -1 || jsonEnd <= jsonStart) {
        // If we can't find valid JSON array markers, try parsing the entire response
        data = JSON.parse(resData);
      } else {
        const jsonSubstring = resData.substring(jsonStart, jsonEnd);
        const parsedArray = JSON.parse(jsonSubstring);
        data = parsedArray.length > 0 ? parsedArray : resData;
      }
    } catch (parseError) {
      console.error("Error parsing dooflix response:", parseError);
      return [];
    }

    if (!Array.isArray(data)) {
      console.warn("Unexpected data format from dooflix API");
      return [];
    }

    data.forEach((result: any) => {
      const id = result?.videos_id;
      if (!id) return;

      const type = !result?.is_tvseries ? "tvseries" : "movie";
      const link = `${baseUrl}/rest-api//v130/single_details?type=${type}&id=${id}`;

      const thumbnailUrl = result?.thumbnail_url;
      const image = thumbnailUrl?.includes("https")
        ? thumbnailUrl
        : thumbnailUrl?.replace("http", "https");

      catalog.push({
        title: result?.title || "",
        link,
        image,
      });
    });

    return catalog;
  } catch (err) {
    console.error("dooflix error:", err);
    return [];
  }
};

export const getSearchPosts = async function ({
  searchQuery,
  page,
  providerContext,
  signal,
}: {
  searchQuery: string;
  page: number;
  providerValue: string;
  signal: AbortSignal;
  providerContext: ProviderContext;
}): Promise<Post[]> {
  try {
    if (page > 1) {
      return [];
    }
    const { axios, getBaseUrl } = providerContext;
    const catalog: Post[] = [];
    const baseUrl = await getBaseUrl("dooflix");
    const url = `${baseUrl}/rest-api//v130/search?q=${searchQuery}&type=movietvserieslive&range_to=0&range_from=0&tv_category_id=0&genre_id=0&country_id=0`;

    const res = await axios.get(url, { headers, signal });
    const resData = res.data;

    if (!resData || typeof resData !== "string") {
      console.warn("Unexpected search response format from dooflix API");
      return [];
    }

    let data;
    try {
      const jsonStart = resData.indexOf("{");
      const jsonEnd = resData.lastIndexOf("}") + 1;

      if (jsonStart === -1 || jsonEnd <= jsonStart) {
        data = resData;
      } else {
        const jsonSubstring = resData.substring(jsonStart, jsonEnd);
        const parsedData = JSON.parse(jsonSubstring);
        data = parsedData?.movie ? parsedData : resData;
      }
    } catch (parseError) {
      console.error("Error parsing dooflix search response:", parseError);
      return [];
    }

    // Process movies
    data?.movie?.forEach((result: any) => {
      const id = result?.videos_id;
      if (!id) return;

      const link = `${baseUrl}/rest-api//v130/single_details?type=movie&id=${id}`;
      const thumbnailUrl = result?.thumbnail_url;
      const image = thumbnailUrl?.includes("https")
        ? thumbnailUrl
        : thumbnailUrl?.replace("http", "https");

      catalog.push({
        title: result?.title || "",
        link,
        image,
      });
    });

    // Process TV series
    data?.tvseries?.forEach((result: any) => {
      const id = result?.videos_id;
      if (!id) return;

      const link = `${baseUrl}/rest-api//v130/single_details?type=tvseries&id=${id}`;
      const thumbnailUrl = result?.thumbnail_url;
      const image = thumbnailUrl?.includes("https")
        ? thumbnailUrl
        : thumbnailUrl?.replace("http", "https");

      catalog.push({
        title: result?.title || "",
        link,
        image,
      });
    });

    return catalog;
  } catch (error) {
    console.error("dooflix search error:", error);
    return [];
  }
};