da5403a307
Implement comprehensive watchlist system with automatic episode detection
and downloading. Features include per-user watchlists, scheduler-based
periodic checks, and a modern web UI.
**Backend Components:**
- WatchlistManager: JSON-based storage with multi-tenant support
- EpisodeChecker: Detects and downloads new episodes automatically
- AutoDownloadScheduler: APScheduler-based periodic task execution
- Complete REST API for CRUD operations and scheduler control
**Frontend Components:**
- Modern watchlist page with dark theme and animations
- Real-time status updates and progress tracking
- Scheduler controls with next-run display
- Add anime directly from search results
**Models & Configuration:**
- WatchlistItem with status, quality, and auto-download settings
- WatchlistSettings for global configuration
- Per-user statistics and provider tracking
**API Endpoints:**
- GET/POST /api/watchlist - List and add items
- PUT/DELETE /api/watchlist/{id} - Update and delete
- POST /api/watchlist/{id}/check - Manual check trigger
- POST /api/watchlist/check-all - Check all due items
- GET/PUT /api/watchlist/settings - Global settings
- GET /api/watchlist/stats - Statistics
- GET/POST /api/watchlist/scheduler/* - Scheduler control
**Configuration Files:**
- config/watchlist.json - User watchlist data
- config/watchlist_settings.json - Global settings
Generated with [Claude Code](https://claude.ai/code)
Co-Authored-By: Claude <[email protected]>
209 lines
5.7 KiB
JavaScript
209 lines
5.7 KiB
JavaScript
// API Base configuration
|
|
const API_BASE = '/api';
|
|
|
|
// Cache for providers info
|
|
let searchResultsCache = {};
|
|
|
|
/**
|
|
* Get providers information
|
|
*/
|
|
async function getProvidersInfo() {
|
|
if (!searchResultsCache.providers) {
|
|
const response = await fetch(`${API_BASE}/providers`);
|
|
searchResultsCache.providers = await response.json();
|
|
}
|
|
return searchResultsCache.providers;
|
|
}
|
|
|
|
/**
|
|
* Check if a provider supports seasons (helper function)
|
|
* @param {string} providerId - The provider ID (e.g., 'animesama')
|
|
* @param {string} url - Optional URL to check for provider support
|
|
* @returns {Promise<boolean>} - True if provider supports seasons
|
|
*/
|
|
async function providerSupportsSeasons(providerId, url = null) {
|
|
try {
|
|
const providers = await getProvidersInfo();
|
|
|
|
// Check if provider ID exists in anime_providers
|
|
if (providers.anime_providers && providers.anime_providers[providerId]) {
|
|
const provider = providers.anime_providers[providerId];
|
|
// Check if provider has explicit supports_seasons flag
|
|
if (typeof provider.supports_seasons === 'boolean') {
|
|
return provider.supports_seasons;
|
|
}
|
|
// Otherwise, check by provider ID (known season-supporting providers)
|
|
return ['anime-sama', 'anime-ultime', 'french-manga'].includes(providerId);
|
|
}
|
|
|
|
// Fallback: check URL if provided
|
|
if (url) {
|
|
const lowerUrl = url.toLowerCase();
|
|
// Check all anime provider domains
|
|
for (const [pid, provider] of Object.entries(providers.anime_providers || {})) {
|
|
if (provider.domains) {
|
|
for (const domain of provider.domains) {
|
|
if (lowerUrl.includes(domain.toLowerCase())) {
|
|
// Re-check with detected provider ID
|
|
return providerSupportsSeasons(pid);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
return false;
|
|
} catch (error) {
|
|
console.error('Error checking provider season support:', error);
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Search anime across all providers
|
|
*/
|
|
async function searchAnime(query, lang, includeMetadata) {
|
|
if (!query) {
|
|
throw new Error('Veuillez entrer un nom d\'anime');
|
|
}
|
|
|
|
const response = await fetch(
|
|
`${API_BASE}/anime/search?q=${encodeURIComponent(query)}&lang=${lang}&include_metadata=${includeMetadata}`
|
|
);
|
|
|
|
if (!response.ok) {
|
|
throw new Error('Erreur lors de la recherche');
|
|
}
|
|
|
|
return await response.json();
|
|
}
|
|
|
|
/**
|
|
* Load episodes for an anime
|
|
*/
|
|
async function loadEpisodes(animeUrl, lang) {
|
|
const response = await fetch(
|
|
`${API_BASE}/anime/episodes?url=${encodeURIComponent(animeUrl)}&lang=${lang}`
|
|
);
|
|
|
|
if (!response.ok) {
|
|
throw new Error('Erreur lors du chargement des épisodes');
|
|
}
|
|
|
|
return await response.json();
|
|
}
|
|
|
|
/**
|
|
* Download an anime episode
|
|
*/
|
|
async function downloadEpisode(episodeUrl) {
|
|
const response = await fetch(`${API_BASE}/anime/download?url=${encodeURIComponent(episodeUrl)}`, {
|
|
method: 'POST'
|
|
});
|
|
|
|
if (!response.ok) {
|
|
throw new Error('Erreur lors du démarrage du téléchargement');
|
|
}
|
|
|
|
return await response.json();
|
|
}
|
|
|
|
/**
|
|
* Download entire season
|
|
*/
|
|
async function downloadSeason(animeUrl, lang) {
|
|
const response = await fetch(
|
|
`${API_BASE}/anime/download-season?url=${encodeURIComponent(animeUrl)}&lang=${lang}`,
|
|
{ method: 'POST' }
|
|
);
|
|
|
|
if (!response.ok) {
|
|
const error = await response.json();
|
|
throw new Error(error.detail || 'Impossible de démarrer le téléchargement de la saison');
|
|
}
|
|
|
|
return await response.json();
|
|
}
|
|
|
|
/**
|
|
* Start a direct download
|
|
*/
|
|
async function startDownload(url) {
|
|
const response = await fetch(`${API_BASE}/download`, {
|
|
method: 'POST',
|
|
headers: { 'Content-Type': 'application/json' },
|
|
body: JSON.stringify({ url })
|
|
});
|
|
|
|
if (!response.ok) {
|
|
throw new Error('Erreur lors du démarrage du téléchargement');
|
|
}
|
|
|
|
return await response.json();
|
|
}
|
|
|
|
/**
|
|
* Get all downloads
|
|
*/
|
|
async function getDownloads() {
|
|
const response = await fetch(`${API_BASE}/downloads`);
|
|
|
|
if (!response.ok) {
|
|
throw new Error('Erreur lors du chargement des téléchargements');
|
|
}
|
|
|
|
return await response.json();
|
|
}
|
|
|
|
/**
|
|
* Pause a download
|
|
*/
|
|
async function pauseDownload(id) {
|
|
const response = await fetch(`${API_BASE}/download/${id}/pause`, { method: 'POST' });
|
|
|
|
if (!response.ok) {
|
|
throw new Error('Erreur lors de la mise en pause');
|
|
}
|
|
|
|
return await response.json();
|
|
}
|
|
|
|
/**
|
|
* Resume a download
|
|
*/
|
|
async function resumeDownload(id) {
|
|
const response = await fetch(`${API_BASE}/download/${id}/resume`, { method: 'POST' });
|
|
|
|
if (!response.ok) {
|
|
throw new Error('Erreur lors de la reprise');
|
|
}
|
|
|
|
return await response.json();
|
|
}
|
|
|
|
/**
|
|
* Cancel/delete a download
|
|
*/
|
|
async function cancelDownload(id) {
|
|
const response = await fetch(`${API_BASE}/download/${id}`, { method: 'DELETE' });
|
|
|
|
if (!response.ok) {
|
|
throw new Error('Erreur lors de la suppression');
|
|
}
|
|
|
|
return await response.json();
|
|
}
|
|
|
|
// Make functions available globally
|
|
window.getProvidersInfo = getProvidersInfo;
|
|
window.providerSupportsSeasons = providerSupportsSeasons;
|
|
window.searchAnime = searchAnime;
|
|
window.loadEpisodes = loadEpisodes;
|
|
window.downloadEpisode = downloadEpisode;
|
|
window.downloadSeason = downloadSeason;
|
|
window.startDownload = startDownload;
|
|
window.getDownloads = getDownloads;
|
|
window.pauseDownload = pauseDownload;
|
|
window.resumeDownload = resumeDownload;
|
|
window.cancelDownload = cancelDownload;
|