import 'package:dartz/dartz.dart';

import '../../core/error/failures.dart';
import '../../domain/entities/playback_state.dart';
import '../../domain/entities/song.dart';
import '../../domain/repositories/audio_repository.dart';
import '../datasources/audio_manager_contract.dart';
import '../models/song_model.dart';

class AudioRepositoryImpl implements AudioRepository {
  AudioRepositoryImpl(this._audioManager);

  final AudioManager _audioManager;

  @override
  Stream<Song> get currentSongStream => _audioManager.currentSongStream;

  @override
  Stream<PlaybackState> get playbackStateStream =>
      _audioManager.playbackStateStream;

  @override
  Stream<int> get currentPositionStream {
    return _audioManager.currentPositionStream;
  }

  @override
  Future<Either<Failure, void>> playSong(int index, List<Song> songList) async {
    final List<SongModel> songModelList =
        songList.map((song) => song as SongModel).toList();

    if (0 <= index && index < songList.length) {
      await _audioManager.playSong(index, songModelList);
      return Right(null);
    }
    return Left(IndexFailure());
  }

  @override
  Future<Either<Failure, void>> play() async {
    await _audioManager.play();
    return Right(null);
  }

  @override
  Future<Either<Failure, void>> pause() async {
    await _audioManager.pause();
    return Right(null);
  }
}