Files
TMDB-Embed-API/utils/config.js
T

196 lines
10 KiB
JavaScript

require('dotenv').config();
const fs = require('fs');
const path = require('path');
// Relocated user-config.json into utils directory; maintain backward-compatible fallback
const NEW_OVERRIDE_PATH = path.join(process.cwd(), 'utils', 'user-config.json');
const LEGACY_OVERRIDE_PATH = path.join(process.cwd(), 'user-config.json');
const OVERRIDE_PATH = (fs.existsSync(NEW_OVERRIDE_PATH) || !fs.existsSync(LEGACY_OVERRIDE_PATH)) ? NEW_OVERRIDE_PATH : LEGACY_OVERRIDE_PATH;
const CONFIG_SCHEMA_VERSION = 1; // Increment when structure / semantics change
function parseJsonMaybe(val) {
if (!val) return null;
const trimmed = val.trim();
if (!trimmed) return null;
if (trimmed.startsWith('{') || trimmed.startsWith('[')) {
try { return JSON.parse(trimmed); } catch { return null; }
}
return null;
}
function parseCookies(raw) {
if (!raw) return [];
const text = raw.trim();
if (!text) return [];
let arr = [];
const json = parseJsonMaybe(text);
if (Array.isArray(json)) arr = json; else {
arr = text.split(/[,;\n]+/).map(s => s.trim()).filter(Boolean);
}
return Array.from(new Set(arr.map(c => c.replace(/^ui=/,'').trim()).filter(Boolean)));
}
function readOverrideFile() {
try {
if (fs.existsSync(OVERRIDE_PATH)) {
const raw = fs.readFileSync(OVERRIDE_PATH, 'utf8');
const data = JSON.parse(raw);
return data && typeof data === 'object' ? data : {};
}
} catch (e) {
console.warn('[config] Failed to read override file:', e.message);
}
return {};
}
function writeOverrideFile(obj) {
try {
fs.writeFileSync(OVERRIDE_PATH, JSON.stringify(obj, null, 2));
return true;
} catch (e) {
console.error('[config] Failed to write override file:', e.message);
return false;
}
}
function normalizeConfig(base) {
const cfg = { ...base };
// Marker: if user explicitly provided an empty array for tmdbApiKeys in override file we should not resurrect legacy key
const explicitEmptyKeys = Array.isArray(cfg.tmdbApiKeys) && cfg.tmdbApiKeys.length === 0 && Object.prototype.hasOwnProperty.call(base,'tmdbApiKeys');
if (!cfg.configVersion) cfg.configVersion = CONFIG_SCHEMA_VERSION;
// Derive structured views
cfg.minQualities = parseJsonMaybe(cfg.minQualitiesRaw) || (cfg.minQualitiesRaw ? { default: cfg.minQualitiesRaw } : null);
cfg.excludeCodecs = parseJsonMaybe(cfg.excludeCodecsRaw) || null;
cfg.febboxCookies = Array.isArray(cfg.febboxCookies) ? cfg.febboxCookies : parseCookies(cfg.febboxCookies);
// TMDB multi-key support: allow tmdbApiKeys (array) or legacy single tmdbApiKey
if (cfg.tmdbApiKeys && !Array.isArray(cfg.tmdbApiKeys)) {
if (typeof cfg.tmdbApiKeys === 'string') {
// split by newline/comma/semicolon
cfg.tmdbApiKeys = cfg.tmdbApiKeys.split(/[\n,;]+/).map(s=>s.trim()).filter(Boolean);
} else cfg.tmdbApiKeys = [];
}
if (!cfg.tmdbApiKeys || !cfg.tmdbApiKeys.length) {
if (!explicitEmptyKeys && cfg.tmdbApiKey) cfg.tmdbApiKeys = [cfg.tmdbApiKey];
else cfg.tmdbApiKeys = [];
}
// If user explicitly cleared tmdbApiKeys via override, also clear legacy single key so it is not shown
if (explicitEmptyKeys) {
cfg.tmdbApiKey = null;
}
// Ensure dedupe + trim
cfg.tmdbApiKeys = Array.from(new Set(cfg.tmdbApiKeys.map(k=>String(k).trim()).filter(Boolean)));
// Booleans normalization
const boolKeys = [
'enableShowboxProvider','enableXprimeProvider','enable4khdhubProvider','enableMoviesmodProvider','enableMp4hydraProvider','enableVidzeeProvider','enableVixsrcProvider',
'disableCache','enablePStreamApi','showboxUseRotatingProxy','disableUrlValidation','disable4khdhubUrlValidation'
];
boolKeys.forEach(k=>{ if (cfg[k] === 'true') cfg[k] = true; else if (cfg[k] === 'false') cfg[k] = false; });
// Default values if undefined
if (cfg.enableShowboxProvider === undefined) cfg.enableShowboxProvider = true;
if (cfg.enableXprimeProvider === undefined) cfg.enableXprimeProvider = true;
if (cfg.enable4khdhubProvider === undefined) cfg.enable4khdhubProvider = true;
if (cfg.enableMoviesmodProvider === undefined) cfg.enableMoviesmodProvider = true;
if (cfg.enableMp4hydraProvider === undefined) cfg.enableMp4hydraProvider = true;
if (cfg.enableVidzeeProvider === undefined) cfg.enableVidzeeProvider = true;
if (cfg.enableVixsrcProvider === undefined) cfg.enableVixsrcProvider = true;
if (cfg.disableCache === undefined) cfg.disableCache = false;
if (cfg.enablePStreamApi === undefined) cfg.enablePStreamApi = true;
if (cfg.showboxUseRotatingProxy === undefined) cfg.showboxUseRotatingProxy = false;
if (cfg.disableUrlValidation === undefined) cfg.disableUrlValidation = false;
if (cfg.disable4khdhubUrlValidation === undefined) cfg.disable4khdhubUrlValidation = false;
return cfg;
}
function applyConfigToEnv(cfg){
// Mirror config values into process.env so legacy provider code continues to work without .env file
if (cfg.port) process.env.API_PORT = String(cfg.port);
// Backward compat: set single TMDB_API_KEY env to first key if available
if (cfg.tmdbApiKeys && cfg.tmdbApiKeys.length) process.env.TMDB_API_KEY = cfg.tmdbApiKeys[0];
else if (cfg.tmdbApiKey) process.env.TMDB_API_KEY = cfg.tmdbApiKey; else delete process.env.TMDB_API_KEY;
if (cfg.defaultProviders) process.env.DEFAULT_PROVIDERS = cfg.defaultProviders.join(',');
if (cfg.minQualitiesRaw) process.env.MIN_QUALITIES = cfg.minQualitiesRaw; else delete process.env.MIN_QUALITIES;
if (cfg.excludeCodecsRaw) process.env.EXCLUDE_CODECS = cfg.excludeCodecsRaw; else delete process.env.EXCLUDE_CODECS;
if (cfg.febboxCookies && cfg.febboxCookies.length) process.env.FEBBOX_COOKIES = cfg.febboxCookies.join(',');
else delete process.env.FEBBOX_COOKIES;
if (cfg.defaultRegion) process.env.DEFAULT_REGION = cfg.defaultRegion; else delete process.env.DEFAULT_REGION;
// Provider enable flags
process.env.ENABLE_SHOWBOX_PROVIDER = cfg.enableShowboxProvider ? 'true':'false';
process.env.ENABLE_XPRIME_PROVIDER = cfg.enableXprimeProvider ? 'true':'false';
process.env.ENABLE_4KHDHUB_PROVIDER = cfg.enable4khdhubProvider ? 'true':'false';
process.env.ENABLE_MOVIESMOD_PROVIDER = cfg.enableMoviesmodProvider ? 'true':'false';
process.env.ENABLE_MP4HYDRA_PROVIDER = cfg.enableMp4hydraProvider ? 'true':'false';
process.env.ENABLE_VIDZEE_PROVIDER = cfg.enableVidzeeProvider ? 'true':'false';
process.env.ENABLE_VIXSRC_PROVIDER = cfg.enableVixsrcProvider ? 'true':'false';
// Caching / validation / PStream
process.env.DISABLE_CACHE = cfg.disableCache ? 'true':'false';
process.env.ENABLE_PSTREAM_API = cfg.enablePStreamApi ? 'true':'false';
process.env.DISABLE_URL_VALIDATION = cfg.disableUrlValidation ? 'true':'false';
process.env.DISABLE_4KHDHUB_URL_VALIDATION = cfg.disable4khdhubUrlValidation ? 'true':'false';
// Showbox specific
if (cfg.showboxCacheDir) process.env.SHOWBOX_CACHE_DIR = cfg.showboxCacheDir; else delete process.env.SHOWBOX_CACHE_DIR;
process.env.SHOWBOX_USE_ROTATING_PROXY = cfg.showboxUseRotatingProxy ? 'true':'false';
if (cfg.showboxProxyPrimary) process.env.SHOWBOX_PROXY_URL_VALUE = cfg.showboxProxyPrimary; else delete process.env.SHOWBOX_PROXY_URL_VALUE;
if (cfg.showboxProxyAlternate) process.env.SHOWBOX_PROXY_URL_ALTERNATE = cfg.showboxProxyAlternate; else delete process.env.SHOWBOX_PROXY_URL_ALTERNATE;
// Other provider proxies
if (cfg.xprimeProxyUrl) process.env.XPRIME_PROXY_URL = cfg.xprimeProxyUrl; else delete process.env.XPRIME_PROXY_URL;
if (cfg.vidzeeProxyUrl) process.env.VIDZEE_PROXY_URL = cfg.vidzeeProxyUrl; else delete process.env.VIDZEE_PROXY_URL;
if (cfg.vidsrcProxyUrl) process.env.VIDSRC_PROXY_URL = cfg.vidsrcProxyUrl; else delete process.env.VIDSRC_PROXY_URL;
if (cfg.moviesmodProxyUrl) process.env.MOVIESMOD_PROXY_URL = cfg.moviesmodProxyUrl; else delete process.env.MOVIESMOD_PROXY_URL;
if (cfg.defaultRegion) process.env.FEBBOX_REGION = cfg.defaultRegion; // alias
}
function loadConfig() {
// Start with env for backward compat, then override with user-config.json
const envCfg = {
port: Number(process.env.API_PORT) || 8787,
defaultRegion: process.env.DEFAULT_REGION || process.env.FEBBOX_REGION || null,
defaultProviders: (process.env.DEFAULT_PROVIDERS || '').split(/[\s,]+/).map(p=>p.trim().toLowerCase()).filter(Boolean),
minQualitiesRaw: process.env.MIN_QUALITIES || null,
excludeCodecsRaw: process.env.EXCLUDE_CODECS || null,
tmdbApiKey: process.env.TMDB_API_KEY || null,
tmdbApiKeys: parseJsonMaybe(process.env.TMDB_API_KEYS) || null,
febboxCookies: parseCookies(process.env.FEBBOX_COOKIES),
// Extended advanced config (may not exist in env)
enableShowboxProvider: process.env.ENABLE_SHOWBOX_PROVIDER,
enableXprimeProvider: process.env.ENABLE_XPRIME_PROVIDER,
enable4khdhubProvider: process.env.ENABLE_4KHDHUB_PROVIDER,
enableMoviesmodProvider: process.env.ENABLE_MOVIESMOD_PROVIDER,
enableMp4hydraProvider: process.env.ENABLE_MP4HYDRA_PROVIDER,
enableVidzeeProvider: process.env.ENABLE_VIDZEE_PROVIDER,
enableVixsrcProvider: process.env.ENABLE_VIXSRC_PROVIDER,
disableCache: process.env.DISABLE_CACHE,
enablePStreamApi: process.env.ENABLE_PSTREAM_API,
showboxUseRotatingProxy: process.env.SHOWBOX_USE_ROTATING_PROXY,
showboxCacheDir: process.env.SHOWBOX_CACHE_DIR || null,
showboxProxyPrimary: process.env.SHOWBOX_PROXY_URL_VALUE || null,
showboxProxyAlternate: process.env.SHOWBOX_PROXY_URL_ALTERNATE || null,
xprimeProxyUrl: process.env.XPRIME_PROXY_URL || null,
vidzeeProxyUrl: process.env.VIDZEE_PROXY_URL || null,
vidsrcProxyUrl: process.env.VIDSRC_PROXY_URL || null,
moviesmodProxyUrl: process.env.MOVIESMOD_PROXY_URL || null,
disableUrlValidation: process.env.DISABLE_URL_VALIDATION,
disable4khdhubUrlValidation: process.env.DISABLE_4KHDHUB_URL_VALIDATION
};
const override = readOverrideFile();
const merged = { ...envCfg, ...override };
const normalized = normalizeConfig(merged);
applyConfigToEnv(normalized); // ensure providers see updated process.env values
return normalized;
}
const config = loadConfig();
function saveConfigPatch(patch) {
const currentOverride = readOverrideFile();
const updated = { ...currentOverride, ...patch };
if (!updated.configVersion) updated.configVersion = CONFIG_SCHEMA_VERSION;
// Remove keys set to null to fall back to env
Object.keys(updated).forEach(k => { if (updated[k] === null) delete updated[k]; });
if (writeOverrideFile(updated)) {
Object.assign(config, loadConfig());
return true;
}
return false;
}
module.exports = { config, reloadConfig: () => Object.assign(config, loadConfig()), saveConfigPatch, OVERRIDE_PATH, CONFIG_SCHEMA_VERSION };