refactor(recordings): eliminate Router/mount, expose direct handler methods to avoid shelf_router path collision

This commit is contained in:
Michael committed 2026-03-08 22:10:59 +01:00
1 parent d91be43f27
commit 7e0837374e
2 files changed
+22 -51

No files matched your search

+15 -42
View File
@@ -47,32 +47,23 @@ class RecordingsApi {
); );
} }
Router get router { /// GET /api/recordings — Liste tous les enregistrements
final router = Router(); Response handleGetAll(Request request) {
// Récupérer tous les enregistrements (admin) ou les enregistrements de l'utilisateur courant (si filtré plus tard via les middlewares)
router.get('/', (Request request) {
// Dans une implémentation complète, nous récupérerions l'ID utilisateur
// final session = request.context['session'] as Session?;
// final userId = session?.userId;
final recordings = _db.getAllRecordings(); final recordings = _db.getAllRecordings();
return Response.ok( return Response.ok(
json.encode(recordings.map((r) => r.toMap()).toList()), json.encode(recordings.map((r) => r.toMap()).toList()),
headers: {'Content-Type': 'application/json'}, headers: {'Content-Type': 'application/json'},
); );
}); }
// Planifier un nouvel enregistrement /// POST /api/recordings — Planifie un nouvel enregistrement
router.post('/', (Request request) async { Future<Response> handlePost(Request request) async {
// final session = request.context['session'] as Session; try {
// final userId = session.userId;
final payload = await request.readAsString(); final payload = await request.readAsString();
final data = json.decode(payload); final data = json.decode(payload);
try {
final recording = _db.createRecording( final recording = _db.createRecording(
userId: 'dev_user_id', // Remplacer par `userId` dans l'implèm réelle avec Auth userId: 'dev_user_id',
channelId: data['channel_id'], channelId: data['channel_id'],
streamUrl: data['stream_url'], streamUrl: data['stream_url'],
title: data['title'] ?? 'Sans Titre', title: data['title'] ?? 'Sans Titre',
@@ -86,46 +77,28 @@ class RecordingsApi {
); );
} catch (e) { } catch (e) {
return Response.internalServerError( return Response.internalServerError(
body: json.encode({'error': 'Erreur lors de la programmation de l\'enregistrement : $e'}), body: json.encode({'error': 'Erreur lors de la programmation: $e'}),
headers: {'Content-Type': 'application/json'}, headers: {'Content-Type': 'application/json'},
); );
} }
}); }
// Supprimer (annuler) un enregistrement /// DELETE /api/recordings/<id> — Annule ou supprime un enregistrement
router.delete('/<id>', (Request request, String id) { Response handleDelete(Request request, String id) {
final recording = _db.getRecordingById(id); final recording = _db.getRecordingById(id);
if (recording == null) { if (recording == null) {
return Response.notFound(json.encode({'error': 'Enregistrement non trouvé'})); return Response.notFound(
json.encode({'error': 'Enregistrement non trouvé'}),
headers: {'Content-Type': 'application/json'},
);
} }
// 1. Si l'enregistrement est en cours, il faut potentiellement l'arrêter
// _scheduler.cancelRecording(id); // Ceci pourrait être une nouvelle méthode de l'ordonnanceur
// 2. Supprimer la donnée en BDD
_db.deleteRecording(id); _db.deleteRecording(id);
// 3. Supprimer le fichier vidéo physiquement si existant
/*
if (recording.filePath != null) {
final file = File(recording.filePath!);
if (file.existsSync()) {
file.deleteSync();
}
}
*/
return Response.ok( return Response.ok(
json.encode({'message': 'Enregistrement supprimé avec succès'}), json.encode({'message': 'Enregistrement supprimé avec succès'}),
headers: {'Content-Type': 'application/json'}, headers: {'Content-Type': 'application/json'},
); );
});
// Note: La route GET /logs/<id> est déclarée directement dans server.dart
// car shelf_router a un conflit interne entre DELETE /<id> et GET /logs/<id>
// dans le même routeur.
return router;
} }
} }
+7 -9
View File
@@ -116,15 +116,13 @@ void main(List<String> args) async {
.addMiddleware(authMiddleware(db)) .addMiddleware(authMiddleware(db))
.addHandler(settingsHandler.router.call), .addHandler(settingsHandler.router.call),
) )
// TV Recordings - Route des logs AVANT le mount general (évite collision shelf_router avec /<id>) // TV Recordings - Chaque route déclarée EXPLICITEMENT pour éviter les conflits shelf_router
..get('/api/recordings/logs/<id>', recordingsApi.getLogHandler) // NE PAS utiliser mount() ici car mount('/api/recordings', ...) intercepte TOUT
// TV Recordings endpoints (GET /, POST /, DELETE /<id>) // ce qui commence par /api/recordings (y compris /api/recordings/logs/<id>)
..mount( ..get('/api/recordings', recordingsApi.handleGetAll)
'/api/recordings', ..post('/api/recordings', recordingsApi.handlePost)
const Pipeline() ..delete('/api/recordings/<id>', recordingsApi.handleDelete)
//.addMiddleware(authMiddleware(db)) // TODO: Activer quand UI aura l'Auth header ..get('/api/recordings/logs/<id>', recordingsApi.getLogHandler);
.addHandler(recordingsApi.router.call),
);
// NOTE: /api/xtream is handled by proxyHandler in the Cascade below // NOTE: /api/xtream is handled by proxyHandler in the Cascade below
// Do NOT mount here as it would intercept and block the actual proxy // Do NOT mount here as it would intercept and block the actual proxy