import { useRemuxHlsToMp4 } from "@/hooks/useRemuxHlsToMp4"; import { apiAtom, userAtom } from "@/providers/JellyfinProvider"; import { runningProcesses } from "@/utils/atoms/downloads"; import { queueActions, queueAtom } from "@/utils/atoms/queue"; import { useSettings } from "@/utils/atoms/settings"; import ios from "@/utils/profiles/ios"; import native from "@/utils/profiles/native"; import old from "@/utils/profiles/old"; import Ionicons from "@expo/vector-icons/Ionicons"; import { BottomSheetBackdrop, BottomSheetBackdropProps, BottomSheetModal, BottomSheetView, } from "@gorhom/bottom-sheet"; import { BaseItemDto, MediaSourceInfo, } from "@jellyfin/sdk/lib/generated-client/models"; import AsyncStorage from "@react-native-async-storage/async-storage"; import { useQuery } from "@tanstack/react-query"; import { router } from "expo-router"; import { useAtom } from "jotai"; import { useCallback, useMemo, useRef, useState } from "react"; import { Alert, TouchableOpacity, View, ViewProps } from "react-native"; import { AudioTrackSelector } from "./AudioTrackSelector"; import { Bitrate, BitrateSelector } from "./BitrateSelector"; import { Button } from "./Button"; import { Text } from "./common/Text"; import { Loader } from "./Loader"; import { MediaSourceSelector } from "./MediaSourceSelector"; import ProgressCircle from "./ProgressCircle"; import { SubtitleTrackSelector } from "./SubtitleTrackSelector"; interface DownloadProps extends ViewProps { item: BaseItemDto; } export const DownloadItem: React.FC = ({ item, ...props }) => { const [api] = useAtom(apiAtom); const [user] = useAtom(userAtom); const [process] = useAtom(runningProcesses); const [queue, setQueue] = useAtom(queueAtom); const [settings] = useSettings(); const { startRemuxing } = useRemuxHlsToMp4(item); const [selectedMediaSource, setSelectedMediaSource] = useState(null); const [selectedAudioStream, setSelectedAudioStream] = useState(-1); const [selectedSubtitleStream, setSelectedSubtitleStream] = useState(0); const [maxBitrate, setMaxBitrate] = useState({ key: "Max", value: undefined, }); const userCanDownload = useMemo(() => { return user?.Policy?.EnableContentDownloading; }, [user]); /** * Bottom sheet */ const bottomSheetModalRef = useRef(null); const handlePresentModalPress = useCallback(() => { bottomSheetModalRef.current?.present(); }, []); const handleSheetChanges = useCallback((index: number) => { console.log("handleSheetChanges", index); }, []); const closeModal = useCallback(() => { bottomSheetModalRef.current?.dismiss(); }, []); /** * Start download */ const initiateDownload = useCallback(async () => { if (!api || !user?.Id || !item.Id || !selectedMediaSource?.Id) { throw new Error( "DownloadItem ~ initiateDownload: No api or user or item" ); } let deviceProfile: any = ios; if (settings?.deviceProfile === "Native") { deviceProfile = native; } else if (settings?.deviceProfile === "Old") { deviceProfile = old; } const response = await api.axiosInstance.post( `${api.basePath}/Items/${item.Id}/PlaybackInfo`, { DeviceProfile: deviceProfile, UserId: user.Id, MaxStreamingBitrate: maxBitrate.value, StartTimeTicks: 0, EnableTranscoding: maxBitrate.value ? true : undefined, AutoOpenLiveStream: true, AllowVideoStreamCopy: maxBitrate.value ? false : true, MediaSourceId: selectedMediaSource?.Id, AudioStreamIndex: selectedAudioStream, SubtitleStreamIndex: selectedSubtitleStream, }, { headers: { Authorization: `MediaBrowser DeviceId="${api.deviceInfo.id}", Token="${api.accessToken}"`, }, } ); let url: string | undefined = undefined; const mediaSource: MediaSourceInfo = response.data.MediaSources.find( (source: MediaSourceInfo) => source.Id === selectedMediaSource?.Id ); if (!mediaSource) { throw new Error("No media source"); } if (mediaSource.SupportsDirectPlay) { if (item.MediaType === "Video") { url = `${api.basePath}/Videos/${item.Id}/stream.mp4?mediaSourceId=${item.Id}&static=true&mediaSourceId=${mediaSource.Id}&deviceId=${api.deviceInfo.id}&api_key=${api.accessToken}`; } else if (item.MediaType === "Audio") { console.log("Using direct stream for audio!"); const searchParams = new URLSearchParams({ UserId: user.Id, DeviceId: api.deviceInfo.id, MaxStreamingBitrate: "140000000", Container: "opus,webm|opus,mp3,aac,m4a|aac,m4b|aac,flac,webma,webm|webma,wav,ogg", TranscodingContainer: "mp4", TranscodingProtocol: "hls", AudioCodec: "aac", api_key: api.accessToken, StartTimeTicks: "0", EnableRedirection: "true", EnableRemoteMedia: "false", }); url = `${api.basePath}/Audio/${ item.Id }/universal?${searchParams.toString()}`; } } else if (mediaSource.TranscodingUrl) { url = `${api.basePath}${mediaSource.TranscodingUrl}`; } if (!url) throw new Error("No url"); return await startRemuxing(url); }, [ api, item, startRemuxing, user?.Id, selectedMediaSource, selectedAudioStream, selectedSubtitleStream, maxBitrate, ]); /** * Check if item is downloaded */ const { data: downloaded, isFetching } = useQuery({ queryKey: ["downloaded", item.Id], queryFn: async () => { if (!item.Id) return false; const data: BaseItemDto[] = JSON.parse( (await AsyncStorage.getItem("downloaded_files")) || "[]" ); return data.some((d) => d.Id === item.Id); }, enabled: !!item.Id, }); const renderBackdrop = useCallback( (props: BottomSheetBackdropProps) => ( ), [] ); return ( {isFetching ? ( ) : process && process?.item.Id === item.Id ? ( { router.push("/downloads"); }} > {process.progress === 0 ? ( ) : ( )} ) : queue.some((i) => i.id === item.Id) ? ( { router.push("/downloads"); }} > ) : downloaded ? ( { router.push("/downloads"); }} > ) : ( )} Download options setMaxBitrate(val)} selected={maxBitrate} /> {selectedMediaSource && ( )} ); };