streamyfin/providers/NativeDownloadProvider.tsx

import useImageStorage from "@/hooks/useImageStorage";
import {
  addErrorListener,
  addProgressListener,
  cancelDownload,
  downloadHLSAsset,
  getActiveDownloads,
} from "@/modules/hls-downloader";
import {
  DownloadInfo,
  DownloadMetadata,
} from "@/modules/hls-downloader/src/HlsDownloader.types";
import { getItemImage } from "@/utils/getItemImage";
import { getStreamUrl } from "@/utils/jellyfin/media/getStreamUrl";
import download from "@/utils/profiles/download";
import {
  BaseItemDto,
  MediaSourceInfo,
} from "@jellyfin/sdk/lib/generated-client/models";
import { useQuery } from "@tanstack/react-query";
import * as FileSystem from "expo-file-system";
import { useAtomValue } from "jotai";
import { createContext, useContext, useEffect, useState } from "react";
import { toast } from "sonner-native";
import { apiAtom, userAtom } from "./JellyfinProvider";

type DownloadOptionsData = {
  selectedAudioStream: number;
  selectedSubtitleStream: number;
  selectedMediaSource: MediaSourceInfo;
  maxBitrate?: number;
};

type DownloadContextType = {
  downloads: Record<string, DownloadInfo>;
  startDownload: (
    item: BaseItemDto,
    url: string,
    {
      selectedAudioStream,
      selectedSubtitleStream,
      selectedMediaSource,
      maxBitrate,
    }: DownloadOptionsData
  ) => Promise<void>;
  getDownloadedItem: (id: string) => Promise<DownloadMetadata | null>;
  cancelDownload: (id: string) => Promise<void>;
  activeDownloads: DownloadInfo[];
  downloadedFiles: DownloadedFileInfo[];
  refetchDownloadedFiles: () => void;
};

const DownloadContext = createContext<DownloadContextType | undefined>(
  undefined
);

export type DownloadedFileInfo = {
  id: string;
  path: string;
  metadata: DownloadMetadata;
};

const getDownloadedFiles = async (): Promise<DownloadedFileInfo[]> => {
  const downloaded: DownloadedFileInfo[] = [];

  const downloadsDir = FileSystem.documentDirectory + "downloads/";
  const dirInfo = await FileSystem.getInfoAsync(downloadsDir);

  if (!dirInfo.exists) return [];

  const files = await FileSystem.readDirectoryAsync(downloadsDir);

  for (let file of files) {
    const fileInfo = await FileSystem.getInfoAsync(downloadsDir + file);
    if (fileInfo.isDirectory) continue;
    if (!file.endsWith(".json")) continue;

    const fileContent = await FileSystem.readAsStringAsync(downloadsDir + file);

    // Check that fileContent is actually DownloadMetadata
    if (!fileContent) continue;
    if (!fileContent.includes("mediaSource")) continue;
    if (!fileContent.includes("item")) continue;

    downloaded.push({
      id: file.replace(".json", ""),
      path: downloadsDir + file.replace(".json", ""),
      metadata: JSON.parse(fileContent) as DownloadMetadata,
    });
  }
  return downloaded;
};

const getDownloadedFile = async (id: string) => {
  const downloadsDir = FileSystem.documentDirectory + "downloads/";
  const fileInfo = await FileSystem.getInfoAsync(downloadsDir + id + ".json");
  if (!fileInfo.exists) return null;
  const fileContent = await FileSystem.readAsStringAsync(
    downloadsDir + id + ".json"
  );
  return JSON.parse(fileContent) as DownloadMetadata;
};

export const NativeDownloadProvider: React.FC<{
  children: React.ReactNode;
}> = ({ children }) => {
  const [downloads, setDownloads] = useState<Record<string, DownloadInfo>>({});
  const { saveImage } = useImageStorage();

  const user = useAtomValue(userAtom);
  const api = useAtomValue(apiAtom);

  const { data: downloadedFiles, refetch: refetchDownloadedFiles } = useQuery({
    queryKey: ["downloadedFiles"],
    queryFn: getDownloadedFiles,
    refetchOnWindowFocus: true,
    refetchOnMount: true,
    refetchOnReconnect: true,
    staleTime: 0,
  });

  useEffect(() => {
    const _getActiveDownloads = async () => {
      const activeDownloads = await getActiveDownloads();
      setDownloads((prev) => {
        const newDownloads = { ...prev };
        activeDownloads.forEach((download) => {
          newDownloads[download.id] = {
            id: download.id,
            progress: download.progress,
            state: download.state,
            secondsDownloaded: download.secondsDownloaded,
            secondsTotal: download.secondsTotal,
            metadata: download.metadata,
            startTime: download.startTime,
          };
        });
        return newDownloads;
      });
    };

    _getActiveDownloads();

    const progressListener = addProgressListener((download) => {
      if (!download.metadata) throw new Error("No metadata found in download");

      console.log(
        "[HLS] Download progress:",
        download.metadata.item.Id,
        download.progress,
        download.state,
        download.taskId
      );

      setDownloads((prev) => ({
        ...prev,
        [download.id]: {
          id: download.id,
          progress: download.progress,
          state: download.state,
          secondsDownloaded: download.secondsDownloaded,
          secondsTotal: download.secondsTotal,
          metadata: download.metadata,
          startTime: download?.startTime,
        },
      }));

      if (download.state === "DONE") {
        refetchDownloadedFiles();

        setDownloads((prev) => {
          const newDownloads = { ...prev };
          delete newDownloads[download.id];
          return newDownloads;
        });
      }
    });

    const errorListener = addErrorListener((error) => {
      setDownloads((prev) => {
        const newDownloads = { ...prev };
        delete newDownloads[error.id];
        return newDownloads;
      });

      if (error.state === "CANCELLED") toast.info("Download cancelled 🟡");
      else if (error.state === "FAILED") {
        toast.error("Download failed ❌");
        console.error("Download error:", error);
      } else {
        console.error("errorListener fired with unknown state:", error);
      }
    });

    return () => {
      progressListener.remove();
      errorListener.remove();
    };
  }, []);

  const startDownload = async (
    item: BaseItemDto,
    url: string,
    data: DownloadOptionsData
  ) => {
    if (!item.Id || !item.Name) throw new Error("Item ID or Name is missing");
    const jobId = item.Id;

    const itemImage = getItemImage({
      item,
      api: api!,
      variant: "Primary",
      quality: 90,
      width: 500,
    });

    const res = await getStreamUrl({
      api,
      item,
      startTimeTicks: 0,
      userId: user?.Id,
      audioStreamIndex: data.selectedAudioStream,
      maxStreamingBitrate: data.maxBitrate,
      mediaSourceId: data.selectedMediaSource.Id,
      subtitleStreamIndex: data.selectedSubtitleStream,
      deviceProfile: download,
    });

    if (!res) throw new Error("Failed to get stream URL");
    const { mediaSource } = res;
    if (!mediaSource) throw new Error("Failed to get media source");

    await saveImage(item.Id, itemImage?.uri);

    if (!url.includes("master.m3u8"))
      throw new Error("Only HLS downloads are supported");

    downloadHLSAsset(jobId, url, {
      item,
      mediaSource,
    });
  };

  return (
    <DownloadContext.Provider
      value={{
        downloads,
        startDownload,
        downloadedFiles: downloadedFiles ?? [],
        getDownloadedItem: getDownloadedFile,
        activeDownloads: Object.values(downloads),
        cancelDownload: cancelDownload,
        refetchDownloadedFiles,
      }}
    >
      {children}
    </DownloadContext.Provider>
  );
};

export const useNativeDownloads = () => {
  const context = useContext(DownloadContext);
  if (context === undefined) {
    throw new Error(
      "useDownloads must be used within a NativeDownloadProvider"
    );
  }
  return context;
};