spotube/lib/services/sourced_track/sources/dab_music.dart

import 'package:collection/collection.dart';
import 'package:dio/dio.dart';
import 'package:flutter_riverpod/flutter_riverpod.dart';
import 'package:spotube/models/database/database.dart';
import 'package:spotube/models/playback/track_sources.dart';
import 'package:spotube/provider/user_preferences/user_preferences_provider.dart';
import 'package:spotube/services/logger/logger.dart';
import 'package:spotube/services/sourced_track/enums.dart';
import 'package:spotube/services/sourced_track/exceptions.dart';
import 'package:spotube/services/sourced_track/sourced_track.dart';
import 'package:dab_music_api/dab_music_api.dart';

final dabMusicApiClient = DabMusicApiClient(
  Dio(),
  baseUrl: "https://dab.yeet.su/api",
);

/// Only Music source that can't support database caching due to having no endpoint.
/// But ISRC search is 100% reliable so caching is actually not necessary.
class DABMusicSourcedTrack extends SourcedTrack {
  DABMusicSourcedTrack({
    required super.ref,
    required super.source,
    required super.siblings,
    required super.info,
    required super.query,
    required super.sources,
  });

  static Future<SourcedTrack> fetchFromTrack({
    required TrackSourceQuery query,
    required Ref ref,
  }) async {
    try {
      final siblings = await fetchSiblings(ref: ref, query: query);

      if (siblings.isEmpty) {
        throw TrackNotFoundError(query);
      }
      return DABMusicSourcedTrack(
        ref: ref,
        siblings: siblings.map((s) => s.info).skip(1).toList(),
        sources: siblings.first.source!,
        info: siblings.first.info,
        query: query,
        source: AudioSource.dabMusic,
      );
    } catch (e, stackTrace) {
      AppLogger.reportError(e, stackTrace);
      rethrow;
    }
  }

  static Future<List<TrackSource>> fetchSources(
    String id,
    SourceQualities quality,
  ) async {
    try {
      final isUncompressed = quality == SourceQualities.uncompressed;
      final streamResponse = await dabMusicApiClient.music.getStream(
        trackId: id,
        quality: isUncompressed ? "27" : "5",
      );
      if (streamResponse.url == null) {
        throw Exception("No stream URL found for track ID: $id");
      }
      return [
        TrackSource(
          url: streamResponse.url!,
          quality: isUncompressed
              ? SourceQualities.uncompressed
              : SourceQualities.high,
          bitrate: isUncompressed ? "2998kbps" : "320kbps",
          codec: isUncompressed ? SourceCodecs.flac : SourceCodecs.mp3,
        ),
      ];
    } catch (e, stackTrace) {
      AppLogger.reportError(e, stackTrace);
      rethrow;
    }
  }

  static Future<SiblingType> toSiblingType(
    Ref ref,
    int index,
    Track result,
  ) async {
    try {
      List<TrackSource>? source;
      if (index == 0) {
        source = await fetchSources(
          result.id.toString(),
          ref.read(userPreferencesProvider).audioQuality,
        );
      }

      final SiblingType sibling = (
        info: TrackSourceInfo(
          artists: result.artist!,
          durationMs: Duration(seconds: result.duration!).inMilliseconds,
          id: result.id.toString(),
          pageUrl: "https://dab.yeet.su/music/${result.id}",
          thumbnail: result.albumCover!,
          title: result.title!,
        ),
        source: source,
      );

      return sibling;
    } catch (e, stackTrace) {
      AppLogger.reportError(e, stackTrace);
      rethrow;
    }
  }

  static Future<List<SiblingType>> fetchSiblings({
    required TrackSourceQuery query,
    required Ref ref,
  }) async {
    try {
      List<Track> results = [];

      if (query.isrc.isNotEmpty) {
        final res =
            await dabMusicApiClient.music.getSearch(q: query.isrc, limit: 1);
        results = res.tracks ?? <Track>[];
      }

      if (results.isEmpty) {
        final res = await dabMusicApiClient.music.getSearch(
          q: SourcedTrack.getSearchTerm(query),
          limit: 5,
        );
        results = res.tracks ?? <Track>[];
      }

      if (results.isEmpty) {
        return [];
      }

      final matchedResults =
          results.mapIndexed((index, d) => toSiblingType(ref, index, d));

      return Future.wait(matchedResults);
    } catch (e, stackTrace) {
      AppLogger.reportError(e, stackTrace);
      rethrow;
    }
  }

  @override
  Future<DABMusicSourcedTrack> copyWithSibling() async {
    if (siblings.isNotEmpty) {
      return this;
    }
    final fetchedSiblings = await fetchSiblings(ref: ref, query: query);

    return DABMusicSourcedTrack(
      ref: ref,
      siblings: fetchedSiblings
          .where((s) => s.info.id != info.id)
          .map((s) => s.info)
          .toList(),
      source: source,
      info: info,
      query: query,
      sources: sources,
    );
  }

  @override
  Future<DABMusicSourcedTrack?> swapWithSibling(TrackSourceInfo sibling) async {
    if (sibling.id == this.info.id) {
      return null;
    }

    // a sibling source that was fetched from the search results
    final isStepSibling = siblings.none((s) => s.id == sibling.id);

    final newSourceInfo = isStepSibling
        ? sibling
        : siblings.firstWhere((s) => s.id == sibling.id);
    final newSiblings = siblings.where((s) => s.id != sibling.id).toList()
      ..insert(0, this.info);

    final source = await fetchSources(
      sibling.id,
      ref.read(userPreferencesProvider).audioQuality,
    );

    return DABMusicSourcedTrack(
      ref: ref,
      siblings: newSiblings,
      sources: source,
      info: newSourceInfo,
      query: query,
      source: AudioSource.dabMusic,
    );
  }

  @override
  Future<SourcedTrack> refreshStream() async {
    // There's no need to refresh the stream for DABMusicSourcedTrack
    return this;
  }
}