mirror of
https://github.com/streamyfin/streamyfin.git
synced 2026-06-02 12:08:37 +01:00
Compare commits
3 Commits
fix/refres
...
chore/enfo
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
3d6f12ceb2 | ||
|
|
338fb9713b | ||
|
|
939fd2512d |
29
.gitattributes
vendored
29
.gitattributes
vendored
@@ -1 +1,28 @@
|
|||||||
.modules/vlc-player/Frameworks/*.xcframework filter=lfs diff=lfs merge=lfs -text
|
# Normalise line endings to LF for everyone. Files are stored as LF in git and
|
||||||
|
# checked out as LF on every OS, so Windows clones stop producing CRLF churn
|
||||||
|
# (no more "LF will be replaced by CRLF" warnings) regardless of core.autocrlf.
|
||||||
|
* text=auto eol=lf
|
||||||
|
|
||||||
|
# Windows-only scripts must stay CRLF
|
||||||
|
*.bat text eol=crlf
|
||||||
|
*.cmd text eol=crlf
|
||||||
|
|
||||||
|
# Binary assets — never touched / never normalised
|
||||||
|
*.png binary
|
||||||
|
*.jpg binary
|
||||||
|
*.jpeg binary
|
||||||
|
*.gif binary
|
||||||
|
*.webp binary
|
||||||
|
*.ico binary
|
||||||
|
*.icns binary
|
||||||
|
*.ttf binary
|
||||||
|
*.otf binary
|
||||||
|
*.woff binary
|
||||||
|
*.woff2 binary
|
||||||
|
*.mp3 binary
|
||||||
|
*.mp4 binary
|
||||||
|
*.mov binary
|
||||||
|
*.pdf binary
|
||||||
|
*.keystore binary
|
||||||
|
*.jks binary
|
||||||
|
*.p12 binary
|
||||||
|
|||||||
102
.github/workflows/crowdin.yml
vendored
102
.github/workflows/crowdin.yml
vendored
@@ -1,51 +1,51 @@
|
|||||||
name: 🌐 Translation Sync
|
name: 🌐 Translation Sync
|
||||||
|
|
||||||
on:
|
on:
|
||||||
push:
|
push:
|
||||||
branches: [develop]
|
branches: [develop]
|
||||||
paths:
|
paths:
|
||||||
- "translations/**"
|
- "translations/**"
|
||||||
- "crowdin.yml"
|
- "crowdin.yml"
|
||||||
- "i18n.ts"
|
- "i18n.ts"
|
||||||
- ".github/workflows/crowdin.yml"
|
- ".github/workflows/crowdin.yml"
|
||||||
# Run weekly to pull new translations
|
# Run weekly to pull new translations
|
||||||
schedule:
|
schedule:
|
||||||
- cron: "0 2 * * 1" # Every Monday at 2 AM UTC
|
- cron: "0 2 * * 1" # Every Monday at 2 AM UTC
|
||||||
workflow_dispatch:
|
workflow_dispatch:
|
||||||
|
|
||||||
permissions:
|
permissions:
|
||||||
contents: write
|
contents: write
|
||||||
pull-requests: write
|
pull-requests: write
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
sync-translations:
|
sync-translations:
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- name: 📥 Checkout Repository
|
- name: 📥 Checkout Repository
|
||||||
uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6.0.2
|
uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6.0.2
|
||||||
with:
|
with:
|
||||||
fetch-depth: 0
|
fetch-depth: 0
|
||||||
|
|
||||||
- name: 🌐 Sync Translations with Crowdin
|
- name: 🌐 Sync Translations with Crowdin
|
||||||
uses: crowdin/github-action@8868a33591d21088edfc398968173a3b98d51706 # v2.16.2
|
uses: crowdin/github-action@8868a33591d21088edfc398968173a3b98d51706 # v2.16.2
|
||||||
with:
|
with:
|
||||||
upload_sources: true
|
upload_sources: true
|
||||||
upload_translations: true
|
upload_translations: true
|
||||||
download_translations: true
|
download_translations: true
|
||||||
localization_branch_name: I10n_crowdin_translations
|
localization_branch_name: I10n_crowdin_translations
|
||||||
create_pull_request: true
|
create_pull_request: true
|
||||||
pull_request_title: "feat: New Crowdin Translations"
|
pull_request_title: "feat: New Crowdin Translations"
|
||||||
pull_request_body: "New Crowdin translations by [Crowdin GH Action](https://github.com/crowdin/github-action)"
|
pull_request_body: "New Crowdin translations by [Crowdin GH Action](https://github.com/crowdin/github-action)"
|
||||||
pull_request_base_branch_name: "develop"
|
pull_request_base_branch_name: "develop"
|
||||||
pull_request_labels: "🌐 translation"
|
pull_request_labels: "🌐 translation"
|
||||||
# Quality control options
|
# Quality control options
|
||||||
skip_untranslated_strings: false
|
skip_untranslated_strings: false
|
||||||
skip_untranslated_files: false
|
skip_untranslated_files: false
|
||||||
export_only_approved: false
|
export_only_approved: false
|
||||||
# Commit customization
|
# Commit customization
|
||||||
commit_message: "feat(i18n): update translations from Crowdin"
|
commit_message: "feat(i18n): update translations from Crowdin"
|
||||||
env:
|
env:
|
||||||
GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
|
GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
|
||||||
CROWDIN_PROJECT_ID: ${{ secrets.CROWDIN_PROJECT_ID }}
|
CROWDIN_PROJECT_ID: ${{ secrets.CROWDIN_PROJECT_ID }}
|
||||||
CROWDIN_PERSONAL_TOKEN: ${{ secrets.CROWDIN_PERSONAL_TOKEN }}
|
CROWDIN_PERSONAL_TOKEN: ${{ secrets.CROWDIN_PERSONAL_TOKEN }}
|
||||||
|
|||||||
11
.gitignore
vendored
11
.gitignore
vendored
@@ -1,6 +1,5 @@
|
|||||||
# Dependencies and Package Managers
|
# Dependencies and Package Managers
|
||||||
node_modules/
|
node_modules/
|
||||||
bun.lock
|
|
||||||
bun.lockb
|
bun.lockb
|
||||||
package-lock.json
|
package-lock.json
|
||||||
|
|
||||||
@@ -21,10 +20,8 @@ web-build/
|
|||||||
# Gradle caches (top-level + per-module native projects)
|
# Gradle caches (top-level + per-module native projects)
|
||||||
**/.gradle/
|
**/.gradle/
|
||||||
|
|
||||||
# Module-specific Builds
|
# Native module build outputs (any module)
|
||||||
modules/mpv-player/android/build
|
modules/*/android/build/
|
||||||
modules/player/android
|
|
||||||
modules/hls-downloader/android/build
|
|
||||||
|
|
||||||
# Generated Applications
|
# Generated Applications
|
||||||
Streamyfin.app
|
Streamyfin.app
|
||||||
@@ -69,10 +66,6 @@ certs/
|
|||||||
|
|
||||||
# Version and Backup Files
|
# Version and Backup Files
|
||||||
/version-backup-*
|
/version-backup-*
|
||||||
/modules/sf-player/android/build
|
|
||||||
/modules/music-controls/android/build
|
|
||||||
modules/background-downloader/android/build/*
|
|
||||||
/modules/mpv-player/android/build
|
|
||||||
|
|
||||||
# ios:unsigned-build Artifacts
|
# ios:unsigned-build Artifacts
|
||||||
build/
|
build/
|
||||||
|
|||||||
@@ -59,17 +59,19 @@ function SettingsMobile() {
|
|||||||
|
|
||||||
<QuickConnect className='mb-4' />
|
<QuickConnect className='mb-4' />
|
||||||
|
|
||||||
<View className='mb-4'>
|
{Platform.OS !== "ios" && (
|
||||||
<ListGroup title={t("pairing.pair_with_phone_title")}>
|
<View className='mb-4'>
|
||||||
<ListItem
|
<ListGroup title={t("pairing.pair_with_phone_title")}>
|
||||||
onPress={() =>
|
<ListItem
|
||||||
router.push("/(auth)/(tabs)/(home)/companion-login")
|
onPress={() =>
|
||||||
}
|
router.push("/(auth)/(tabs)/(home)/companion-login")
|
||||||
title={t("pairing.pair_with_phone")}
|
}
|
||||||
textColor='blue'
|
title={t("pairing.pair_with_phone")}
|
||||||
/>
|
textColor='blue'
|
||||||
</ListGroup>
|
/>
|
||||||
</View>
|
</ListGroup>
|
||||||
|
</View>
|
||||||
|
)}
|
||||||
|
|
||||||
<View className='mb-4'>
|
<View className='mb-4'>
|
||||||
<AppLanguageSelector />
|
<AppLanguageSelector />
|
||||||
|
|||||||
@@ -114,7 +114,7 @@ export default function StreamystatsPage() {
|
|||||||
};
|
};
|
||||||
|
|
||||||
const handleRefreshFromServer = useCallback(async () => {
|
const handleRefreshFromServer = useCallback(async () => {
|
||||||
const newPluginSettings = await refreshStreamyfinPluginSettings(true);
|
const newPluginSettings = await refreshStreamyfinPluginSettings();
|
||||||
// Update local state with new values
|
// Update local state with new values
|
||||||
const newUrl = newPluginSettings?.streamyStatsServerUrl?.value || "";
|
const newUrl = newPluginSettings?.streamyStatsServerUrl?.value || "";
|
||||||
setUrl(newUrl);
|
setUrl(newUrl);
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
import { t } from "i18next";
|
import { t } from "i18next";
|
||||||
import React, { useCallback, useState } from "react";
|
import React, { useCallback, useState } from "react";
|
||||||
import { ScrollView, View } from "react-native";
|
import { Platform, ScrollView, View } from "react-native";
|
||||||
import { Button } from "@/components/Button";
|
import { Button } from "@/components/Button";
|
||||||
import { Text } from "@/components/common/Text";
|
import { Text } from "@/components/common/Text";
|
||||||
import { useScaledTVTypography } from "@/constants/TVTypography";
|
import { useScaledTVTypography } from "@/constants/TVTypography";
|
||||||
@@ -107,7 +107,7 @@ export const TVAddServerForm: React.FC<TVAddServerFormProps> = ({
|
|||||||
</View>
|
</View>
|
||||||
|
|
||||||
{/* Pair with Phone */}
|
{/* Pair with Phone */}
|
||||||
{onStartPairing && (
|
{Platform.OS !== "ios" && onStartPairing && (
|
||||||
<View>
|
<View>
|
||||||
<Button
|
<Button
|
||||||
onPress={onStartPairing}
|
onPress={onStartPairing}
|
||||||
|
|||||||
@@ -196,7 +196,10 @@ export const OtherSettings: React.FC = () => {
|
|||||||
}
|
}
|
||||||
/>
|
/>
|
||||||
</ListItem>
|
</ListItem>
|
||||||
<ListItem title={t("home.settings.other.max_auto_play_episode_count")}>
|
<ListItem
|
||||||
|
title={t("home.settings.other.max_auto_play_episode_count")}
|
||||||
|
disabled={pluginSettings?.maxAutoPlayEpisodeCount?.locked}
|
||||||
|
>
|
||||||
<PlatformDropdown
|
<PlatformDropdown
|
||||||
groups={autoPlayEpisodeOptions}
|
groups={autoPlayEpisodeOptions}
|
||||||
trigger={
|
trigger={
|
||||||
|
|||||||
@@ -229,7 +229,10 @@ export const PlaybackControlsSettings: React.FC = () => {
|
|||||||
|
|
||||||
<ListItem
|
<ListItem
|
||||||
title={t("home.settings.other.max_auto_play_episode_count")}
|
title={t("home.settings.other.max_auto_play_episode_count")}
|
||||||
disabled={!settings.autoPlayNextEpisode}
|
disabled={
|
||||||
|
!settings.autoPlayNextEpisode ||
|
||||||
|
pluginSettings?.maxAutoPlayEpisodeCount?.locked
|
||||||
|
}
|
||||||
>
|
>
|
||||||
<PlatformDropdown
|
<PlatformDropdown
|
||||||
groups={autoPlayEpisodeOptions}
|
groups={autoPlayEpisodeOptions}
|
||||||
|
|||||||
@@ -1,5 +1,4 @@
|
|||||||
import { getSessionApi } from "@jellyfin/sdk/lib/utils/api";
|
import { getSessionApi } from "@jellyfin/sdk/lib/utils/api";
|
||||||
import { router } from "expo-router";
|
|
||||||
import { useAtomValue } from "jotai";
|
import { useAtomValue } from "jotai";
|
||||||
import {
|
import {
|
||||||
createContext,
|
createContext,
|
||||||
@@ -12,6 +11,7 @@ import {
|
|||||||
useState,
|
useState,
|
||||||
} from "react";
|
} from "react";
|
||||||
import { AppState, type AppStateStatus } from "react-native";
|
import { AppState, type AppStateStatus } from "react-native";
|
||||||
|
import useRouter from "@/hooks/useAppRouter";
|
||||||
import { useNetworkAwareQueryClient } from "@/hooks/useNetworkAwareQueryClient";
|
import { useNetworkAwareQueryClient } from "@/hooks/useNetworkAwareQueryClient";
|
||||||
import { apiAtom, getOrSetDeviceId } from "@/providers/JellyfinProvider";
|
import { apiAtom, getOrSetDeviceId } from "@/providers/JellyfinProvider";
|
||||||
import { useNetworkStatus } from "@/providers/NetworkStatusProvider";
|
import { useNetworkStatus } from "@/providers/NetworkStatusProvider";
|
||||||
@@ -28,20 +28,6 @@ const LIBRARY_CHANGE_QUERY_KEYS = [
|
|||||||
["episodes"],
|
["episodes"],
|
||||||
] as const;
|
] as const;
|
||||||
|
|
||||||
// Query keys that depend on per-user playback state (resume position, played
|
|
||||||
// status, favorites) and should be refreshed when the server reports a
|
|
||||||
// `UserDataChanged`. Scoped to the progression-based sections so finishing an
|
|
||||||
// episode does not pointlessly refetch "recently added" or suggestions.
|
|
||||||
const USER_DATA_CHANGE_QUERY_KEYS = [
|
|
||||||
["home", "continueAndNextUp"],
|
|
||||||
["home", "resumeItems"],
|
|
||||||
["home", "nextUp-all"],
|
|
||||||
["home", "heroItems"],
|
|
||||||
["resumeItems"],
|
|
||||||
["nextUp-all"],
|
|
||||||
["nextUp"],
|
|
||||||
] as const;
|
|
||||||
|
|
||||||
interface WebSocketMessage {
|
interface WebSocketMessage {
|
||||||
MessageType: string;
|
MessageType: string;
|
||||||
Data: any;
|
Data: any;
|
||||||
@@ -52,30 +38,10 @@ interface WebSocketProviderProps {
|
|||||||
children: ReactNode;
|
children: ReactNode;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Handler invoked for every message of a given `MessageType`. Receives the
|
|
||||||
* message `Data` payload and the full message.
|
|
||||||
*/
|
|
||||||
type WebSocketMessageHandler = (data: any, message: WebSocketMessage) => void;
|
|
||||||
|
|
||||||
interface WebSocketContextType {
|
interface WebSocketContextType {
|
||||||
ws: WebSocket | null;
|
ws: WebSocket | null;
|
||||||
isConnected: boolean;
|
isConnected: boolean;
|
||||||
/**
|
|
||||||
* @deprecated Prefer `subscribe`. `lastMessage` only keeps the most recent
|
|
||||||
* message, so bursts arriving in the same tick are coalesced and lost. Kept
|
|
||||||
* for `useWebsockets` (GeneralCommand handling) until it is migrated.
|
|
||||||
*/
|
|
||||||
lastMessage: WebSocketMessage | null;
|
lastMessage: WebSocketMessage | null;
|
||||||
/**
|
|
||||||
* Subscribe to a given message type. The handler is called synchronously for
|
|
||||||
* every matching message (no coalescing, unlike `lastMessage`). Returns an
|
|
||||||
* unsubscribe function to call on cleanup.
|
|
||||||
*/
|
|
||||||
subscribe: (
|
|
||||||
messageType: string,
|
|
||||||
handler: WebSocketMessageHandler,
|
|
||||||
) => () => void;
|
|
||||||
sendMessage: (message: any) => void;
|
sendMessage: (message: any) => void;
|
||||||
clearLastMessage: () => void;
|
clearLastMessage: () => void;
|
||||||
}
|
}
|
||||||
@@ -88,6 +54,7 @@ export const WebSocketProvider = ({ children }: WebSocketProviderProps) => {
|
|||||||
const [ws, setWs] = useState<WebSocket | null>(null);
|
const [ws, setWs] = useState<WebSocket | null>(null);
|
||||||
const [isConnected, setIsConnected] = useState(false);
|
const [isConnected, setIsConnected] = useState(false);
|
||||||
const [lastMessage, setLastMessage] = useState<WebSocketMessage | null>(null);
|
const [lastMessage, setLastMessage] = useState<WebSocketMessage | null>(null);
|
||||||
|
const router = useRouter();
|
||||||
const queryClient = useNetworkAwareQueryClient();
|
const queryClient = useNetworkAwareQueryClient();
|
||||||
const deviceId = useMemo(() => {
|
const deviceId = useMemo(() => {
|
||||||
return getOrSetDeviceId();
|
return getOrSetDeviceId();
|
||||||
@@ -96,52 +63,6 @@ export const WebSocketProvider = ({ children }: WebSocketProviderProps) => {
|
|||||||
const libraryChangeDebounceRef = useRef<ReturnType<typeof setTimeout> | null>(
|
const libraryChangeDebounceRef = useRef<ReturnType<typeof setTimeout> | null>(
|
||||||
null,
|
null,
|
||||||
);
|
);
|
||||||
const userDataChangeDebounceRef = useRef<ReturnType<
|
|
||||||
typeof setTimeout
|
|
||||||
> | null>(null);
|
|
||||||
|
|
||||||
// Pub/sub registry: messageType -> set of handlers. Stored in a ref so
|
|
||||||
// subscribing/dispatching never triggers a re-render.
|
|
||||||
const listenersRef = useRef<Map<string, Set<WebSocketMessageHandler>>>(
|
|
||||||
new Map(),
|
|
||||||
);
|
|
||||||
|
|
||||||
const subscribe = useCallback(
|
|
||||||
(messageType: string, handler: WebSocketMessageHandler) => {
|
|
||||||
const listeners = listenersRef.current;
|
|
||||||
let handlers = listeners.get(messageType);
|
|
||||||
if (!handlers) {
|
|
||||||
handlers = new Set();
|
|
||||||
listeners.set(messageType, handlers);
|
|
||||||
}
|
|
||||||
handlers.add(handler);
|
|
||||||
return () => {
|
|
||||||
handlers?.delete(handler);
|
|
||||||
if (handlers && handlers.size === 0) {
|
|
||||||
listeners.delete(messageType);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
},
|
|
||||||
[],
|
|
||||||
);
|
|
||||||
|
|
||||||
const dispatchMessage = useCallback((message: WebSocketMessage) => {
|
|
||||||
const handlers = listenersRef.current.get(message.MessageType);
|
|
||||||
if (!handlers || handlers.size === 0) return;
|
|
||||||
// Copy to tolerate handlers that unsubscribe during dispatch.
|
|
||||||
for (const handler of [...handlers]) {
|
|
||||||
// Isolate each handler so one throwing subscriber can't abort the rest
|
|
||||||
// (and isn't misreported as a parse failure by the outer onmessage catch).
|
|
||||||
try {
|
|
||||||
handler(message.Data, message);
|
|
||||||
} catch (error) {
|
|
||||||
console.error(
|
|
||||||
`Error handling WebSocket message type "${message.MessageType}":`,
|
|
||||||
error,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}, []);
|
|
||||||
|
|
||||||
const connectWebSocket = useCallback(() => {
|
const connectWebSocket = useCallback(() => {
|
||||||
if (!deviceId || !api?.accessToken || !isNetworkConnected) {
|
if (!deviceId || !api?.accessToken || !isNetworkConnected) {
|
||||||
@@ -192,10 +113,7 @@ export const WebSocketProvider = ({ children }: WebSocketProviderProps) => {
|
|||||||
newWebSocket.onmessage = (e) => {
|
newWebSocket.onmessage = (e) => {
|
||||||
try {
|
try {
|
||||||
const message = JSON.parse(e.data);
|
const message = JSON.parse(e.data);
|
||||||
// Legacy single-slot state, still consumed by useWebsockets.
|
setLastMessage(message); // Store the last message in context
|
||||||
setLastMessage(message);
|
|
||||||
// Pub/sub: deliver to every subscriber without coalescing.
|
|
||||||
dispatchMessage(message);
|
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
console.error("Error parsing WebSocket message:", error);
|
console.error("Error parsing WebSocket message:", error);
|
||||||
}
|
}
|
||||||
@@ -208,7 +126,7 @@ export const WebSocketProvider = ({ children }: WebSocketProviderProps) => {
|
|||||||
}
|
}
|
||||||
newWebSocket.close();
|
newWebSocket.close();
|
||||||
};
|
};
|
||||||
}, [api, deviceId, isNetworkConnected, dispatchMessage]);
|
}, [api, deviceId, isNetworkConnected]);
|
||||||
|
|
||||||
const handleLibraryChanged = useCallback(
|
const handleLibraryChanged = useCallback(
|
||||||
(data: any) => {
|
(data: any) => {
|
||||||
@@ -239,77 +157,47 @@ export const WebSocketProvider = ({ children }: WebSocketProviderProps) => {
|
|||||||
[queryClient],
|
[queryClient],
|
||||||
);
|
);
|
||||||
|
|
||||||
const handleUserDataChanged = useCallback(
|
useEffect(() => {
|
||||||
(data: any) => {
|
if (!lastMessage) {
|
||||||
// Jellyfin sends UserDataChanged when playback position, played status
|
return;
|
||||||
// or favorites change (e.g. finishing an episode). Only the
|
}
|
||||||
// progression-based home sections care about it.
|
if (lastMessage.MessageType === "Play") {
|
||||||
if (!((data?.UserDataList?.length ?? 0) > 0)) {
|
handlePlayCommand(lastMessage.Data);
|
||||||
return;
|
} else if (lastMessage.MessageType === "LibraryChanged") {
|
||||||
}
|
handleLibraryChanged(lastMessage.Data);
|
||||||
|
}
|
||||||
// Finishing an item can emit several UserDataChanged messages, so
|
}, [lastMessage, router, handleLibraryChanged]);
|
||||||
// debounce to invalidate the affected sections only once.
|
|
||||||
if (userDataChangeDebounceRef.current) {
|
|
||||||
clearTimeout(userDataChangeDebounceRef.current);
|
|
||||||
}
|
|
||||||
userDataChangeDebounceRef.current = setTimeout(() => {
|
|
||||||
for (const queryKey of USER_DATA_CHANGE_QUERY_KEYS) {
|
|
||||||
queryClient.invalidateQueries({ queryKey: [...queryKey] });
|
|
||||||
}
|
|
||||||
}, 800);
|
|
||||||
},
|
|
||||||
[queryClient],
|
|
||||||
);
|
|
||||||
|
|
||||||
// Refresh library-dependent queries when the server reports a change.
|
|
||||||
useEffect(
|
|
||||||
() => subscribe("LibraryChanged", handleLibraryChanged),
|
|
||||||
[subscribe, handleLibraryChanged],
|
|
||||||
);
|
|
||||||
|
|
||||||
// Refresh "Continue Watching" / "Next Up" when playback state changes.
|
|
||||||
useEffect(
|
|
||||||
() => subscribe("UserDataChanged", handleUserDataChanged),
|
|
||||||
[subscribe, handleUserDataChanged],
|
|
||||||
);
|
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
return () => {
|
return () => {
|
||||||
if (libraryChangeDebounceRef.current) {
|
if (libraryChangeDebounceRef.current) {
|
||||||
clearTimeout(libraryChangeDebounceRef.current);
|
clearTimeout(libraryChangeDebounceRef.current);
|
||||||
}
|
}
|
||||||
if (userDataChangeDebounceRef.current) {
|
|
||||||
clearTimeout(userDataChangeDebounceRef.current);
|
|
||||||
}
|
|
||||||
};
|
};
|
||||||
}, []);
|
}, []);
|
||||||
|
|
||||||
const handlePlayCommand = useCallback((data: any) => {
|
const handlePlayCommand = useCallback(
|
||||||
if (!data?.ItemIds?.length) {
|
(data: any) => {
|
||||||
return;
|
if (!data?.ItemIds?.length) {
|
||||||
}
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
const itemId = data.ItemIds[0];
|
const itemId = data.ItemIds[0];
|
||||||
|
|
||||||
router.push({
|
router.push({
|
||||||
pathname: "/(auth)/player/direct-player",
|
pathname: "/(auth)/player/direct-player",
|
||||||
params: {
|
params: {
|
||||||
itemId: itemId,
|
itemId: itemId,
|
||||||
playCommand: data.PlayCommand || "PlayNow",
|
playCommand: data.PlayCommand || "PlayNow",
|
||||||
audioIndex: data.AudioStreamIndex?.toString(),
|
audioIndex: data.AudioStreamIndex?.toString(),
|
||||||
subtitleIndex: data.SubtitleStreamIndex?.toString(),
|
subtitleIndex: data.SubtitleStreamIndex?.toString(),
|
||||||
mediaSourceId: data.MediaSourceId || "",
|
mediaSourceId: data.MediaSourceId || "",
|
||||||
bitrateValue: "",
|
bitrateValue: "",
|
||||||
offline: "false",
|
offline: "false",
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
}, []);
|
},
|
||||||
|
[router],
|
||||||
// Server-initiated "Play me this item" remote command.
|
|
||||||
useEffect(
|
|
||||||
() => subscribe("Play", handlePlayCommand),
|
|
||||||
[subscribe, handlePlayCommand],
|
|
||||||
);
|
);
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
@@ -379,14 +267,7 @@ export const WebSocketProvider = ({ children }: WebSocketProviderProps) => {
|
|||||||
}, []);
|
}, []);
|
||||||
return (
|
return (
|
||||||
<WebSocketContext.Provider
|
<WebSocketContext.Provider
|
||||||
value={{
|
value={{ ws, isConnected, lastMessage, sendMessage, clearLastMessage }}
|
||||||
ws,
|
|
||||||
isConnected,
|
|
||||||
lastMessage,
|
|
||||||
subscribe,
|
|
||||||
sendMessage,
|
|
||||||
clearLastMessage,
|
|
||||||
}}
|
|
||||||
>
|
>
|
||||||
{children}
|
{children}
|
||||||
</WebSocketContext.Provider>
|
</WebSocketContext.Provider>
|
||||||
|
|||||||
@@ -6,6 +6,7 @@ import {
|
|||||||
type SortOrder,
|
type SortOrder,
|
||||||
SubtitlePlaybackMode,
|
SubtitlePlaybackMode,
|
||||||
} from "@jellyfin/sdk/lib/generated-client";
|
} from "@jellyfin/sdk/lib/generated-client";
|
||||||
|
import { t } from "i18next";
|
||||||
import { atom, useAtom, useAtomValue } from "jotai";
|
import { atom, useAtom, useAtomValue } from "jotai";
|
||||||
import { useCallback, useEffect, useMemo } from "react";
|
import { useCallback, useEffect, useMemo } from "react";
|
||||||
import { BITRATES, type Bitrate } from "@/components/BitrateSelector";
|
import { BITRATES, type Bitrate } from "@/components/BitrateSelector";
|
||||||
@@ -121,6 +122,46 @@ export interface MaxAutoPlayEpisodeCount {
|
|||||||
value: number;
|
value: number;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The plugin may send object-typed settings as plain primitives.
|
||||||
|
* Resolve to the proper option object from the available choices.
|
||||||
|
*/
|
||||||
|
const normalizePluginValue = (
|
||||||
|
settingsKey: keyof Settings,
|
||||||
|
value: unknown,
|
||||||
|
): unknown => {
|
||||||
|
if (typeof value !== "object" || value === null) {
|
||||||
|
const defaultVal = defaultValues[settingsKey];
|
||||||
|
if (
|
||||||
|
typeof defaultVal === "object" &&
|
||||||
|
defaultVal !== null &&
|
||||||
|
"key" in defaultVal &&
|
||||||
|
"value" in defaultVal
|
||||||
|
) {
|
||||||
|
// defaultBitrate needs a lookup because its keys are human-readable
|
||||||
|
// (e.g. "8 Mb/s") that can't be derived from the raw value (e.g. 8000000).
|
||||||
|
// Other { key, value } settings like maxAutoPlayEpisodeCount work with
|
||||||
|
// the fallback because their keys are just String(value) (e.g. "5").
|
||||||
|
if (settingsKey === "defaultBitrate") {
|
||||||
|
const match = BITRATES.find(
|
||||||
|
(b) => b.key === value || b.value === value,
|
||||||
|
);
|
||||||
|
if (match) return match;
|
||||||
|
}
|
||||||
|
// maxAutoPlayEpisodeCount: 0 is invalid (breaks autoplay), clamp to -1
|
||||||
|
// -1 key must match the translated dropdown label so the UI shows "Disabled"
|
||||||
|
if (
|
||||||
|
settingsKey === "maxAutoPlayEpisodeCount" &&
|
||||||
|
(value === 0 || value === -1)
|
||||||
|
) {
|
||||||
|
return { key: t("home.settings.other.disabled"), value: -1 };
|
||||||
|
}
|
||||||
|
return { key: String(value), value };
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return value;
|
||||||
|
};
|
||||||
|
|
||||||
export type HomeSectionLatestResolver = {
|
export type HomeSectionLatestResolver = {
|
||||||
parentId?: string;
|
parentId?: string;
|
||||||
limit?: number;
|
limit?: number;
|
||||||
@@ -427,61 +468,37 @@ export const useSettings = () => {
|
|||||||
[_setPluginSettings],
|
[_setPluginSettings],
|
||||||
);
|
);
|
||||||
|
|
||||||
const refreshStreamyfinPluginSettings = useCallback(
|
const refreshStreamyfinPluginSettings = useCallback(async () => {
|
||||||
async (forceOverride = false) => {
|
if (!api) {
|
||||||
if (!api) {
|
return;
|
||||||
return;
|
}
|
||||||
|
const newPluginSettings = await api.getStreamyfinPluginConfig().then(
|
||||||
|
({ data }) => {
|
||||||
|
writeInfoLog("Got plugin settings", data?.settings);
|
||||||
|
return data?.settings;
|
||||||
|
},
|
||||||
|
(_err) => undefined,
|
||||||
|
);
|
||||||
|
setPluginSettings(newPluginSettings);
|
||||||
|
|
||||||
|
// Locked/unlocked values are handled by the settings memo, which
|
||||||
|
// applies locked values at runtime without overwriting user storage.
|
||||||
|
// We only handle auto-enabling Streamystats here.
|
||||||
|
if (newPluginSettings && _settings) {
|
||||||
|
const streamyStatsUrl = newPluginSettings.streamyStatsServerUrl;
|
||||||
|
if (streamyStatsUrl?.value && _settings.searchEngine !== "Streamystats") {
|
||||||
|
const newSettings = {
|
||||||
|
...defaultValues,
|
||||||
|
..._settings,
|
||||||
|
searchEngine: "Streamystats",
|
||||||
|
} as Settings;
|
||||||
|
setSettings(newSettings);
|
||||||
|
saveSettings(newSettings);
|
||||||
}
|
}
|
||||||
const newPluginSettings = await api.getStreamyfinPluginConfig().then(
|
}
|
||||||
({ data }) => {
|
|
||||||
writeInfoLog("Got plugin settings", data?.settings);
|
|
||||||
return data?.settings;
|
|
||||||
},
|
|
||||||
(_err) => undefined,
|
|
||||||
);
|
|
||||||
setPluginSettings(newPluginSettings);
|
|
||||||
|
|
||||||
// Apply plugin values to settings
|
return newPluginSettings;
|
||||||
if (newPluginSettings && _settings) {
|
}, [api, _settings]);
|
||||||
const updates: Partial<Settings> = {};
|
|
||||||
for (const [key, setting] of Object.entries(newPluginSettings)) {
|
|
||||||
if (setting && !setting.locked && setting.value !== undefined) {
|
|
||||||
const settingsKey = key as keyof Settings;
|
|
||||||
const effectiveValue = getEffectiveSettingValue(
|
|
||||||
_settings,
|
|
||||||
settingsKey,
|
|
||||||
);
|
|
||||||
// Apply if forceOverride is true, or if neither persisted settings
|
|
||||||
// nor app defaults provide a meaningful value.
|
|
||||||
if (forceOverride || !hasMeaningfulSettingValue(effectiveValue)) {
|
|
||||||
(updates as any)[settingsKey] = setting.value;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Auto-enable Streamystats if server URL is provided
|
|
||||||
const streamyStatsUrl = newPluginSettings.streamyStatsServerUrl;
|
|
||||||
if (
|
|
||||||
streamyStatsUrl?.value &&
|
|
||||||
_settings.searchEngine !== "Streamystats"
|
|
||||||
) {
|
|
||||||
updates.searchEngine = "Streamystats";
|
|
||||||
}
|
|
||||||
if (Object.keys(updates).length > 0) {
|
|
||||||
const newSettings = {
|
|
||||||
...defaultValues,
|
|
||||||
..._settings,
|
|
||||||
...updates,
|
|
||||||
} as Settings;
|
|
||||||
setSettings(newSettings);
|
|
||||||
saveSettings(newSettings);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return newPluginSettings;
|
|
||||||
},
|
|
||||||
[api, _settings],
|
|
||||||
);
|
|
||||||
|
|
||||||
const updateSettings = (update: Partial<Settings>) => {
|
const updateSettings = (update: Partial<Settings>) => {
|
||||||
if (!_settings) {
|
if (!_settings) {
|
||||||
@@ -512,8 +529,13 @@ export const useSettings = () => {
|
|||||||
Partial<Settings>
|
Partial<Settings>
|
||||||
>((acc, [key, setting]) => {
|
>((acc, [key, setting]) => {
|
||||||
if (setting) {
|
if (setting) {
|
||||||
const { value, locked } = setting;
|
let { value } = setting;
|
||||||
|
const { locked } = setting;
|
||||||
const settingsKey = key as keyof Settings;
|
const settingsKey = key as keyof Settings;
|
||||||
|
|
||||||
|
// Normalize object-typed settings from plugin (plain primitive → { key, value })
|
||||||
|
value = normalizePluginValue(settingsKey, value);
|
||||||
|
|
||||||
const effectiveValue = getEffectiveSettingValue(_settings, settingsKey);
|
const effectiveValue = getEffectiveSettingValue(_settings, settingsKey);
|
||||||
|
|
||||||
(acc as any)[settingsKey] = locked
|
(acc as any)[settingsKey] = locked
|
||||||
|
|||||||
@@ -27,6 +27,7 @@ export function startPairingListener(
|
|||||||
});
|
});
|
||||||
|
|
||||||
socket.on("error", (err) => {
|
socket.on("error", (err) => {
|
||||||
|
if (!active) return;
|
||||||
if (__DEV__) console.error("[PairingService] Socket error:", err);
|
if (__DEV__) console.error("[PairingService] Socket error:", err);
|
||||||
onError?.(err.message);
|
onError?.(err.message);
|
||||||
cleanup();
|
cleanup();
|
||||||
|
|||||||
Reference in New Issue
Block a user