RhythmBox/lib/services/server/active_sourced_track.dart
2024-08-30 22:06:24 +08:00

51 lines
1.6 KiB
Dart
Executable File

import 'dart:developer';
import 'package:get/get.dart';
import 'package:rhythm_box/providers/audio_player.dart';
import 'package:rhythm_box/services/audio_player/audio_player.dart';
import 'package:rhythm_box/services/sourced_track/models/source_info.dart';
import 'package:rhythm_box/services/sourced_track/sourced_track.dart';
import 'package:rhythm_box/widgets/tracks/querying_track_info.dart';
class ActiveSourcedTrackProvider extends GetxController {
Rx<SourcedTrack?> state = Rx(null);
void updateTrack(SourcedTrack? sourcedTrack) {
state.value = sourcedTrack;
}
Future<void> populateSibling() async {
if (state.value == null) return;
state.value = await state.value!.copyWithSibling();
}
Future<void> swapSibling(SourceInfo sibling) async {
final query = Get.find<QueryingTrackInfoProvider>();
query.isQueryingTrackInfo.value = true;
try {
if (state.value == null) return;
await audioPlayer.pause();
await populateSibling();
final newTrack = await state.value!.swapWithSibling(sibling);
if (newTrack == null) return;
state.value = newTrack;
final playback = Get.find<AudioPlayerProvider>();
final oldActiveIndex = audioPlayer.currentIndex;
await playback.addTracksAtFirst([newTrack]);
await Future.delayed(const Duration(milliseconds: 30));
await audioPlayer.removeTrack(oldActiveIndex);
await playback.jumpToTrack(newTrack);
} catch (e, stack) {
log('[Playback] Failed to swap with siblings. Error: $e; Trace:\n$stack');
} finally {
query.isQueryingTrackInfo.value = false;
await audioPlayer.resume();
}
}
}