Files
annu-kute-ced/includes/lib/peertube-api.php
T

520 lines
16 KiB
PHP

<?php
/**
* Client de l'API PeerTube et fonctions de récupération des vidéos.
*
* Extrait de includes/config.php (ARC-1) — chargé par ce dernier.
* Dépend de lib/http.php (client cURL), lib/format.php (formatage) et
* includes/simple-cache.php (callPeerTubeApiCached).
*/
/**
* Initialise et récupère les catégories depuis l'API PeerTube
*
* @return array Liste des catégories
*/
function initCategories() {
// Récupérer la liste des catégories depuis l'API
$categories = callPeerTubeApi('videos/categories');
// Tableau de correspondance pour traduire les catégories en français
$translations = [
'Music' => 'Musique',
'Films' => 'Films',
'Vehicles' => 'Véhicules',
'Art' => 'Art',
'Sports' => 'Sports',
'Travels' => 'Voyages',
'Gaming' => 'Jeux vidéo',
'People' => 'Personnes',
'Comedy' => 'Humour',
'Entertainment' => 'Divertissement',
'News & Politics' => 'Actualités & Politique',
'How To' => 'Tutoriels',
'Education' => 'Éducation',
'Activism' => 'Activisme',
'Science & Technology' => 'Science & Technologie',
'Animals' => 'Animaux',
'Kids' => 'Enfants',
'Food' => 'Cuisine',
];
// Si une constante PRIORITY_CATEGORIES est définie, utiliser ces traductions
if (defined('PRIORITY_CATEGORIES')) {
$priorityCategories = PRIORITY_CATEGORIES;
foreach ($priorityCategories as $id => $name) {
// Trouver la clé anglaise correspondant à l'ID
$englishName = array_search($id, array_keys($categories));
if ($englishName !== false) {
$translations[$englishName] = $name;
}
}
}
$result = [];
foreach ($categories as $key => $name) {
// Utiliser la traduction si disponible, sinon garder le nom original
$translatedName = isset($translations[$name]) ? $translations[$name] : $name;
$result[$key] = $translatedName;
}
return $result;
}
/**
* Retourne les catégories PeerTube, chargées paresseusement.
*
* Remplace l'ancienne constante PEERTUBE_CATEGORIES (définie à l'inclusion
* de config.php) : l'appel API n'a lieu qu'à la première utilisation et le
* résultat est mémoïsé pour le reste de la requête (ARC-2).
*
* @return array Liste des catégories (id => nom traduit)
*/
function getPeertubeCategories() {
static $categories = null;
if ($categories === null) {
$categories = initCategories();
}
return $categories;
}
/**
* Version originale pour appeler l'API PeerTube (sans cache)
* Cette fonction est maintenant utilisée en interne par callPeerTubeApi
*
* @param string $endpoint Point de terminaison de l'API
* @param array $params Paramètres optionnels pour la requête
* @return array Données retournées par l'API
*/
function callPeerTubeApiOriginal($endpoint, $params = []) {
// Validation de l'URL de base PeerTube pour prévenir SSRF
if (!isValidPeerTubeUrl(PEERTUBE_URL)) {
error_log('SECURITY: Invalid PeerTube URL detected: ' . PEERTUBE_URL);
return [];
}
// Nettoyer et valider l'endpoint
$endpoint = ltrim($endpoint, '/');
if (!isValidApiEndpoint($endpoint)) {
error_log('SECURITY: Invalid API endpoint detected: ' . $endpoint);
return [];
}
$url = PEERTUBE_URL . '/api/v1/' . $endpoint;
// Ajouter les paramètres à l'URL
if (!empty($params)) {
$url .= '?' . http_build_query($params);
}
// Options cURL : pas de redirection suivie (SSRF), timeouts bornés
$options = [
'timeout' => 30,
'connectTimeout' => 10,
'followLocation' => false,
'maxRedirects' => 0,
];
// Ajouter la clé API si définie
if (defined('API_KEY') && !empty(API_KEY)) {
$options['headers'] = [
'Authorization: ApiKey ' . API_KEY
];
}
// Exécuter la requête
$response = httpGet($url, $options);
// Traiter la réponse
if ($response['body'] === false || !empty($response['error'])) {
error_log('PeerTube API error: ' . $response['error']);
return [];
}
if ($response['code'] < 200 || $response['code'] >= 300) {
error_log('PeerTube API HTTP error: ' . $response['code']);
return [];
}
// Décoder la réponse JSON
$data = json_decode($response['body'], true);
return $data ?: [];
}
/**
* Fonction utilitaire pour appeler l'API PeerTube avec cache
*
* @param string $endpoint Point de terminaison de l'API
* @param array $params Paramètres optionnels pour la requête
* @return array Données retournées par l'API
*/
function callPeerTubeApi($endpoint, $params = []) {
// Utiliser la fonction cachée si disponible
if (function_exists('callPeerTubeApiCached')) {
return callPeerTubeApiCached($endpoint, $params);
}
// Fallback vers la version originale
return callPeerTubeApiOriginal($endpoint, $params);
}
/**
* Valide l'URL PeerTube pour prévenir les attaques SSRF
* Alias historique de isValidRemoteUrl() (includes/security.php).
*
* @param string $url URL à valider
* @return bool True si l'URL est valide et sûre
*/
function isValidPeerTubeUrl($url) {
return isValidRemoteUrl($url);
}
/**
* Valide l'endpoint API pour prévenir l'injection de chemins
*
* @param string $endpoint Endpoint à valider
* @return bool True si l'endpoint est valide
*/
function isValidApiEndpoint($endpoint) {
// Bloquer les tentatives de path traversal
if (strpos($endpoint, '..') !== false || strpos($endpoint, '//') !== false) {
return false;
}
// Autoriser uniquement les caractères alphanumériques, tirets, underscores et slashes
if (!preg_match('/^[a-zA-Z0-9\/_-]+$/', $endpoint)) {
return false;
}
// Liste blanche des endpoints autorisés
$allowedEndpoints = [
'videos',
'videos/categories',
'search/videos',
'videos/.*', // Pour les endpoints dynamiques comme videos/{id}
'videos/.*/comment-threads', // Pour les commentaires
'accounts',
'accounts/.*/videos', // Pour les vidéos d'un compte spécifique
'video-channels/.*/videos' // Pour les vidéos d'une chaîne spécifique
];
foreach ($allowedEndpoints as $pattern) {
// Remplacer les .* par des marqueurs temporaires
$tempPattern = str_replace('.*', '__WILDCARD__', $pattern);
// Échapper les caractères spéciaux regex
$escapedPattern = preg_quote($tempPattern, '/');
// Remettre les wildcards en place
$regexPattern = str_replace('__WILDCARD__', '.*', $escapedPattern);
if (preg_match('/^' . $regexPattern . '$/', $endpoint)) {
return true;
}
}
return false;
}
/**
* Récupère les catégories depuis l'API PeerTube
*
* @return array Liste des catégories
*/
function getCategories() {
// Utiliser les catégories déjà récupérées
$categories = getPeertubeCategories();
$result = [];
foreach ($categories as $key => $name) {
$result[] = [
'id' => $key,
'name' => $name
];
}
return $result;
}
/**
* Récupère les vidéos récentes depuis l'API PeerTube
*
* @param int $count Nombre de vidéos à récupérer
* @return array Liste des vidéos récentes
*/
function getRecentVideos($count = RECENT_VIDEOS_COUNT) {
// Récupérer les vidéos récentes
$data = callPeerTubeApi('videos', [
'sort' => '-publishedAt',
'count' => $count,
'isLocal' => true
]);
return formatVideosData($data['data'] ?? []);
}
/**
* Récupère les vidéos tendances depuis l'API PeerTube
*
* @param int $count Nombre de vidéos à récupérer
* @return array Liste des vidéos tendances
*/
function getTrendingVideos($count = TRENDING_VIDEOS_COUNT) {
// Récupérer les vidéos tendances
$data = callPeerTubeApi('videos', [
'sort' => '-trending',
'count' => $count,
'isLocal' => true
]);
return formatVideosData($data['data'] ?? []);
}
/**
* Récupère les vidéos avec un tag spécifique depuis l'API PeerTube
*
* @param string $tag Tag à filtrer
* @param int $count Nombre de vidéos à récupérer
* @return array Liste des vidéos
*/
function getVideosByTag($tag, $count) {
// Récupérer les vidéos par tag
$data = callPeerTubeApi('videos', [
'tagsOneOf' => $tag,
'count' => $count,
'isLocal' => true
]);
return formatVideosData($data['data'] ?? []);
}
/**
* Récupère les shorts (vidéos courtes) depuis l'API PeerTube
* Les shorts sont des vidéos locales de moins de 2 minutes
*
* @param int $count Nombre de shorts à récupérer
* @return array Liste des shorts
*/
function getShorts($count = SHORTS_COUNT) {
// Récupérer plus de vidéos que nécessaire pour pouvoir filtrer
$data = callPeerTubeApi('videos', [
'sort' => '-publishedAt', // Les plus récentes d'abord
'count' => SHORTS_COUNT_SEARCH,
'isLocal' => true
]);
// Formater les données
$allVideos = formatVideosData($data['data'] ?? []);
// Filtrer pour ne garder que les vidéos de moins de 2 minutes (120 secondes) et en mode portrait
$shortVideos = array_filter($allVideos, function($video) {
// Vérifier la durée (moins de 2 minutes)
$durationOk = $video['duration'] < SHORTS_MAX_DURATION;
// Vérifier le ratio (mode portrait)
$ratioOk = isset($video['aspectRatio']) && $video['aspectRatio'] <= 1;
return $durationOk && $ratioOk;
});
// Limiter au nombre demandé
return array_slice($shortVideos, 0, $count);
}
/**
* Récupère les vidéos sur l'indépendance depuis l'API PeerTube
*
* @param int $count Nombre de vidéos à récupérer
* @return array Liste des vidéos sur l'indépendance
*/
function getIndependenceVideos($count = INDEPENDENCE_VIDEOS_COUNT) {
// Récupérer les vidéos sur l'indépendance
return getVideosByTag(TAG_INDEPENDENCE, $count);
}
/**
* Vérifie s'il y a un direct en cours du compte LIVE_ACCOUNT_NAME sur l'instance PeerTube
*
* @return array|null Informations sur le direct en cours ou null si aucun direct
*/
function getLiveStream() {
// Récupérer les lives du compte spécifié
$accountName = LIVE_ACCOUNT_NAME;
$data = callPeerTubeApi('accounts/' . $accountName . '/videos', [
'count' => 1,
'isLocal' => true,
'isLive' => true, // Filtrer uniquement les lives
'sort' => '-publishedAt' // Les plus récents en premier
]);
// Vérifier si on a des résultats
if (empty($data['data']) || count($data['data']) === 0) {
return null;
}
// Formater les données du live
$liveData = formatVideosData($data['data']);
// Filtrer pour ne garder que les lives en cours
$activeLives = array_filter($liveData, function($video) {
return isset($video['isLive']) && $video['isLive'] === true;
});
// Retourner le premier live trouvé
return !empty($activeLives) ? reset($activeLives) : null;
}
/**
* Récupère les vidéos d'une catégorie spécifique depuis l'API PeerTube
*
* @param int $categoryId Identifiant de la catégorie
* @param int $count Nombre de vidéos à récupérer
* @return array Liste des vidéos de la catégorie
*/
function getVideosByCategory($categoryId, $count = CATEGORY_VIDEOS_COUNT) {
// Récupérer les vidéos par catégorie
$data = callPeerTubeApi('videos', [
'categoryOneOf' => $categoryId,
'count' => $count,
'sort' => '-publishedAt', // Les plus récentes d'abord
'isLocal' => true
]);
return formatVideosData($data['data'] ?? []);
}
/**
* Récupère la liste des catégories à afficher (triées selon les priorités)
*
* @return array Liste des catégories avec id, name et videos
*/
function getDisplayCategories() {
$categories = [];
$priorityCategories = PRIORITY_CATEGORIES;
// Ajouter uniquement les catégories prioritaires dans l'ordre défini
foreach ($priorityCategories as $catId => $categoryName) {
$videos = getVideosByCategory($catId);
// N'ajouter que les catégories qui ont des vidéos
if (!empty($videos)) {
$categories[] = [
'id' => $catId,
'name' => $categoryName,
'videos' => $videos
];
}
}
return $categories;
}
/**
* Récupère les commentaires d'une vidéo
* @param string $videoId ID de la vidéo
* @return array Tableau des commentaires
*/
function getVideoComments($videoId) {
$endpoint = "videos/{$videoId}/comment-threads";
$response = callPeerTubeApi($endpoint);
if (!$response || !isset($response['data'])) {
return [];
}
return $response['data'];
}
/**
* Récupère les options de téléchargement pour une vidéo
* @param string $videoId ID de la vidéo
* @return array Options de téléchargement
*/
function getVideoDownloadOptions($videoId) {
// Récupérer les informations complètes de la vidéo
$videoData = callPeerTubeApi('videos/' . $videoId);
$downloadOptions = [];
// Ajouter les fichiers directs s'ils existent
if (isset($videoData['files']) && !empty($videoData['files'])) {
foreach ($videoData['files'] as $file) {
if (isset($file['fileDownloadUrl']) && !empty($file['fileDownloadUrl'])) {
$downloadOptions[] = [
'type' => 'direct',
'url' => PEERTUBE_URL . $file['fileDownloadUrl'],
'resolution' => isset($file['resolution']['label']) ? $file['resolution']['label'] : 'Original',
'size' => isset($file['size']) ? formatFileSize($file['size']) : 'Inconnu'
];
}
}
}
// Ajouter les playlists de streaming s'ils existent
if (isset($videoData['streamingPlaylists']) && !empty($videoData['streamingPlaylists'])) {
foreach ($videoData['streamingPlaylists'] as $playlist) {
if (isset($playlist['files']) && !empty($playlist['files'])) {
foreach ($playlist['files'] as $file) {
if (isset($file['fileDownloadUrl']) && !empty($file['fileDownloadUrl'])) {
$downloadOptions[] = [
'type' => 'hls',
'url' => $file['fileDownloadUrl'],
'resolution' => isset($file['resolution']['label']) ? $file['resolution']['label'] : 'Original',
'size' => isset($file['size']) ? formatFileSize($file['size']) : 'Inconnu'
];
}
}
}
}
}
return $downloadOptions;
}
/**
* Recherche des vidéos selon un critère
*
* @param string $query Terme de recherche
* @param int $count Nombre de vidéos à récupérer
* @param int $start Index de départ pour la pagination
* @param int|null $total Total réel renvoyé par l'API (passé par référence)
* @return array Liste des vidéos correspondant à la recherche
*/
function searchVideos($query, $count = COUNT_VIDEO_SEARCH, $start = 0, &$total = null) {
$total = 0;
if (empty($query)) {
return [];
}
// Vérifier si la recherche concerne un tag (commence par #)
if (substr($query, 0, 1) === '#') {
$tag = substr($query, 1); // Enlever le # du début
// Récupérer les vidéos avec ce tag via l'API
$data = callPeerTubeApi('videos', [
'tagsOneOf' => $tag,
'count' => $count,
'start' => $start,
'isLocal' => true, // Uniquement les vidéos locales
'sort' => '-publishedAt' // Les plus récentes d'abord
]);
$videos = formatVideosData($data['data'] ?? []);
$total = isset($data['total']) ? (int) $data['total'] : count($videos);
return $videos;
}
// Recherche normale (pas un tag)
$data = callPeerTubeApi('search/videos', [
'search' => $query,
'count' => $count,
'start' => $start,
'isLocal' => true, // Uniquement les vidéos locales
'sort' => '-publishedAt' // Les plus récentes d'abord
]);
$videos = formatVideosData($data['data'] ?? []);
$total = isset($data['total']) ? (int) $data['total'] : count($videos);
return $videos;
}