Creepso/NuvioStreaming
1
0
Fork 0
mirror of https://github.com/tapframe/NuvioStreaming.git synced 2026-03-31 06:48:39 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

feat: prioritize IntroDB and implement ARM API for faster MAL ID resolution

Browse source
This commit is contained in:
paregi12 2026-01-05 00:33:33 +05:30
parent 6a7d6a1458
commit 1e60af1ffb
1 changed files with 44 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

55
src/services/introService.ts
View file

@ -10,6 +10,7 @@ import { tmdbService } from './tmdbService';
const INTRODB_API_URL = process.env.EXPO_PUBLIC_INTRODB_API_URL;
const ANISKIP_API_URL = 'https://api.aniskip.com/v2';
const KITSU_API_URL = 'https://kitsu.io/api/edge';
const ARM_IMDB_URL = 'https://arm.haglund.dev/api/v2/imdb';
export type SkipType = 'op' | 'ed' | 'recap' | 'intro' | 'outro' | 'mixed-op' | 'mixed-ed';
@ -32,6 +33,31 @@ export interface IntroTimestamps {
confidence: number;
}
async function getMalIdFromArm(imdbId: string): Promise<string | null> {
try {
const response = await axios.get(ARM_IMDB_URL, {
params: {
id: imdbId,
include: 'myanimelist'
}
});
// ARM returns an array of matches (e.g. for different seasons)
// We typically take the first one or try to match logic if possible
if (Array.isArray(response.data) && response.data.length > 0) {
const result = response.data[0];
if (result && result.myanimelist) {
logger.log(`[IntroService] Found MAL ID via ARM: ${result.myanimelist}`);
return result.myanimelist.toString();
}
}
} catch (error) {
// Silent fail as this is just one of the resolution methods
// logger.warn('[IntroService] Failed to fetch MAL ID from ARM', error);
}
return null;
}
async function getMalIdFromKitsu(kitsuId: string): Promise<string | null> {
try {
const response = await axios.get(`${KITSU_API_URL}/anime/${kitsuId}/mappings`);
@ -171,7 +197,15 @@ export async function getSkipTimes(
malId?: string,
kitsuId?: string
): Promise<SkipInterval[]> {
// 1. Try AniSkip (Anime) if we have MAL ID or Kitsu ID
// 1. Try IntroDB (TV Shows) first
if (imdbId) {
const introDbIntervals = await fetchFromIntroDb(imdbId, season, episode);
if (introDbIntervals.length > 0) {
return introDbIntervals;
}
}
// 2. Try AniSkip (Anime) if we have MAL ID or Kitsu ID
let finalMalId = malId;
// If we have Kitsu ID but no MAL ID, try to resolve it
@ -182,8 +216,15 @@ export async function getSkipTimes(
// If we still don't have MAL ID but have IMDb ID (e.g. Cinemeta), try to resolve it
if (!finalMalId && imdbId) {
logger.log(`[IntroService] Attempting to resolve MAL ID from IMDb ID: ${imdbId}`);
finalMalId = await getMalIdFromImdb(imdbId) || undefined;
// Priority 1: ARM API (Fastest)
logger.log(`[IntroService] Attempting to resolve MAL ID via ARM for: ${imdbId}`);
finalMalId = await getMalIdFromArm(imdbId) || undefined;
// Priority 2: Kitsu/TMDB Chain (Fallback)
if (!finalMalId) {
logger.log(`[IntroService] ARM failed, falling back to Kitsu/TMDB chain for: ${imdbId}`);
finalMalId = await getMalIdFromImdb(imdbId) || undefined;
}
}
if (finalMalId) {
@ -195,14 +236,6 @@ export async function getSkipTimes(
}
}
// 2. Try IntroDB (TV Shows) as fallback or for non-anime
if (imdbId) {
const introDbIntervals = await fetchFromIntroDb(imdbId, season, episode);
if (introDbIntervals.length > 0) {
return introDbIntervals;
}
}
return [];
}