Files
OrionTV/services/storage.ts

216 lines
6.5 KiB
TypeScript

import AsyncStorage from "@react-native-async-storage/async-storage";
import { api, PlayRecord as ApiPlayRecord, Favorite as ApiFavorite } from "./api";
// --- Storage Keys ---
const STORAGE_KEYS = {
SETTINGS: "mytv_settings",
PLAYER_SETTINGS: "mytv_player_settings",
} as const;
// --- Type Definitions (aligned with api.ts) ---
// Re-exporting for consistency, though they are now primarily API types
export type PlayRecord = ApiPlayRecord & {
introEndTime?: number;
outroStartTime?: number;
};
export type Favorite = ApiFavorite;
export interface PlayerSettings {
introEndTime?: number;
outroStartTime?: number;
}
export interface AppSettings {
apiBaseUrl: string;
remoteInputEnabled: boolean;
videoSource: {
enabledAll: boolean;
sources: {
[key: string]: boolean;
};
};
m3uUrl: string;
}
// --- Helper ---
const generateKey = (source: string, id: string) => `${source}+${id}`;
// --- PlayerSettingsManager (Uses AsyncStorage) ---
export class PlayerSettingsManager {
static async getAll(): Promise<Record<string, PlayerSettings>> {
try {
const data = await AsyncStorage.getItem(STORAGE_KEYS.PLAYER_SETTINGS);
return data ? JSON.parse(data) : {};
} catch (error) {
console.info("Failed to get all player settings:", error);
return {};
}
}
static async get(source: string, id: string): Promise<PlayerSettings | null> {
const allSettings = await this.getAll();
return allSettings[generateKey(source, id)] || null;
}
static async save(source: string, id: string, settings: PlayerSettings): Promise<void> {
const allSettings = await this.getAll();
const key = generateKey(source, id);
// Only save if there are actual values to save
if (settings.introEndTime !== undefined || settings.outroStartTime !== undefined) {
allSettings[key] = { ...allSettings[key], ...settings };
} else {
// If both are undefined, remove the key
delete allSettings[key];
}
await AsyncStorage.setItem(STORAGE_KEYS.PLAYER_SETTINGS, JSON.stringify(allSettings));
}
static async remove(source: string, id: string): Promise<void> {
const allSettings = await this.getAll();
delete allSettings[generateKey(source, id)];
await AsyncStorage.setItem(STORAGE_KEYS.PLAYER_SETTINGS, JSON.stringify(allSettings));
}
static async clearAll(): Promise<void> {
await AsyncStorage.removeItem(STORAGE_KEYS.PLAYER_SETTINGS);
}
}
// --- FavoriteManager (Refactored to use API) ---
export class FavoriteManager {
static async getAll(): Promise<Record<string, Favorite>> {
return (await api.getFavorites()) as Record<string, Favorite>;
}
static async save(source: string, id: string, item: Favorite): Promise<void> {
const key = generateKey(source, id);
await api.addFavorite(key, item);
}
static async remove(source: string, id: string): Promise<void> {
const key = generateKey(source, id);
await api.deleteFavorite(key);
}
static async isFavorited(source: string, id: string): Promise<boolean> {
const key = generateKey(source, id);
const favorite = await api.getFavorites(key);
return favorite !== null;
}
static async toggle(source: string, id: string, item: Favorite): Promise<boolean> {
const isFav = await this.isFavorited(source, id);
if (isFav) {
await this.remove(source, id);
return false;
} else {
await this.save(source, id, item);
return true;
}
}
static async clearAll(): Promise<void> {
await api.deleteFavorite();
}
}
// --- PlayRecordManager (Refactored to use API and local settings) ---
export class PlayRecordManager {
static async getAll(): Promise<Record<string, PlayRecord>> {
const apiRecords = await api.getPlayRecords();
const localSettings = await PlayerSettingsManager.getAll();
const mergedRecords: Record<string, PlayRecord> = {};
for (const key in apiRecords) {
mergedRecords[key] = {
...apiRecords[key],
...localSettings[key],
};
}
return mergedRecords;
}
static async save(source: string, id: string, record: Omit<PlayRecord, "save_time">): Promise<void> {
const key = generateKey(source, id);
const { introEndTime, outroStartTime, ...apiRecord } = record;
// Save player settings locally
await PlayerSettingsManager.save(source, id, { introEndTime, outroStartTime });
// Save core record to API
await api.savePlayRecord(key, apiRecord);
}
static async get(source: string, id: string): Promise<PlayRecord | null> {
const key = generateKey(source, id);
// This can be optimized, but for consistency, we call getAll
const records = await this.getAll();
return records[key] || null;
}
static async remove(source: string, id: string): Promise<void> {
const key = generateKey(source, id);
// Remove from API first
await api.deletePlayRecord(key);
// Then remove from local settings
await PlayerSettingsManager.remove(source, id);
}
static async clearAll(): Promise<void> {
// Clear from API first
await api.deletePlayRecord();
// Then clear from local settings
await PlayerSettingsManager.clearAll();
}
}
// --- SearchHistoryManager (Refactored to use API) ---
export class SearchHistoryManager {
static async get(): Promise<string[]> {
return api.getSearchHistory();
}
static async add(keyword: string): Promise<void> {
const trimmed = keyword.trim();
if (!trimmed) return;
await api.addSearchHistory(trimmed);
}
static async clear(): Promise<void> {
await api.deleteSearchHistory();
}
}
// --- SettingsManager (Remains unchanged, uses AsyncStorage) ---
export class SettingsManager {
static async get(): Promise<AppSettings> {
const defaultSettings: AppSettings = {
apiBaseUrl: "",
remoteInputEnabled: true,
videoSource: {
enabledAll: true,
sources: {},
},
m3uUrl:
"",
};
try {
const data = await AsyncStorage.getItem(STORAGE_KEYS.SETTINGS);
return data ? { ...defaultSettings, ...JSON.parse(data) } : defaultSettings;
} catch (error) {
console.info("Failed to get settings:", error);
return defaultSettings;
}
}
static async save(settings: Partial<AppSettings>): Promise<void> {
const currentSettings = await this.get();
const updatedSettings = { ...currentSettings, ...settings };
await AsyncStorage.setItem(STORAGE_KEYS.SETTINGS, JSON.stringify(updatedSettings));
}
static async reset(): Promise<void> {
await AsyncStorage.removeItem(STORAGE_KEYS.SETTINGS);
}
}