Add radio station support

lib/main.dart

@@ -79,6 +79,8 @@ List<SingleChildWidget> _providers = [
     ),
   ),
   ChangeNotifierProvider(create: (context) => PodcastProvider()),
+  ChangeNotifierProvider(create: (context) => RadioStationProvider()),
+  ChangeNotifierProvider(create: (context) => RadioPlayerProvider()),
   ChangeNotifierProvider(
     create: (context) => PlayableListScreenProvider(
       playableProvider: context.read<PlayableProvider>(),

lib/models/models.dart

@@ -6,5 +6,6 @@ export 'playable.dart';
 export 'playlist.dart';
 export 'playlist_folder.dart';
 export 'podcast.dart';
+export 'radio_station.dart';
 export 'song.dart';
 export 'user.dart';

lib/models/radio_station.dart

@@ -0,0 +1,43 @@
+import 'package:faker/faker.dart';
+
+class RadioStation {
+  final String id;
+  String name;
+  String url;
+  String? logo;
+  String? description;
+  bool isPublic;
+
+  RadioStation({
+    required this.id,
+    required this.name,
+    required this.url,
+    this.logo,
+    this.description,
+    this.isPublic = false,
+  });
+
+  factory RadioStation.fromJson(Map<String, dynamic> json) {
+    return RadioStation(
+      id: json['id'],
+      name: json['name'],
+      url: json['url'],
+      logo: json['logo'],
+      description: json['description'],
+      isPublic: json['is_public'] ?? false,
+    );
+  }
+
+  factory RadioStation.fake({
+    String? id,
+    String? name,
+    String? url,
+  }) {
+    final faker = Faker();
+    return RadioStation(
+      id: id ?? faker.guid.guid(),
+      name: name ?? '${faker.address.city()} FM',
+      url: url ?? 'https://stream.example.com/live',
+    );
+  }
+}

lib/providers/providers.dart

@@ -13,5 +13,7 @@ export 'playable_provider.dart';
 export 'playlist_folder_provider.dart';
 export 'playlist_provider.dart';
 export 'podcast_provider.dart';
+export 'radio_player_provider.dart';
+export 'radio_station_provider.dart';
 export 'recently_played_provider.dart';
 export 'search_provider.dart';

lib/providers/radio_player_provider.dart

@@ -0,0 +1,105 @@
+import 'dart:async';
+
+import 'package:app/main.dart';
+import 'package:app/models/models.dart';
+import 'package:app/utils/preferences.dart' as preferences;
+import 'package:flutter/foundation.dart';
+import 'package:just_audio/just_audio.dart';
+
+class RadioPlayerProvider with ChangeNotifier {
+  final _player = AudioPlayer();
+  RadioStation? _currentStation;
+  var _playing = false;
+  var _loading = false;
+  String? _streamTitle;
+
+  StreamSubscription? _playingSubscription;
+  StreamSubscription? _processingSubscription;
+  StreamSubscription? _queuePlaybackSubscription;
+
+  RadioStation? get currentStation => _currentStation;
+  bool get playing => _playing;
+  bool get loading => _loading;
+  bool get active => _currentStation != null;
+  String? get streamTitle => _streamTitle;
+
+  RadioPlayerProvider() {
+    _playingSubscription = _player.playingStream.listen((playing) {
+      _playing = playing;
+      notifyListeners();
+    });
+
+    _processingSubscription =
+        _player.processingStateStream.listen((state) {
+      _loading = state == ProcessingState.loading ||
+          state == ProcessingState.buffering;
+      notifyListeners();
+    });
+
+    // When queue playback starts, stop radio
+    _queuePlaybackSubscription =
+        audioHandler.playbackState.listen((state) {
+      if (state.playing && active) {
+        stop();
+      }
+    });
+  }
+
+  Future<void> play(RadioStation station) async {
+    // Pause the main queue player when radio starts
+    if (audioHandler.playbackState.value.playing) {
+      await audioHandler.pause();
+    }
+
+    _currentStation = station;
+    _streamTitle = null;
+    _loading = true;
+    notifyListeners();
+
+    final streamUrl =
+        '${preferences.host}/radio/stream/${station.id}?t=${preferences.audioToken}';
+
+    try {
+      await _player.setUrl(streamUrl);
+      await _player.play();
+    } catch (e) {
+      _currentStation = null;
+      _loading = false;
+      notifyListeners();
+      rethrow;
+    }
+  }
+
+  Future<void> stop() async {
+    await _player.stop();
+    _currentStation = null;
+    _playing = false;
+    _loading = false;
+    _streamTitle = null;
+    notifyListeners();
+  }
+
+  Future<void> togglePlayPause() async {
+    if (_playing) {
+      await _player.pause();
+    } else if (_currentStation != null) {
+      await _player.play();
+    }
+  }
+
+  void updateStreamTitle(String? title) {
+    if (title != _streamTitle) {
+      _streamTitle = title;
+      notifyListeners();
+    }
+  }
+
+  @override
+  void dispose() {
+    _playingSubscription?.cancel();
+    _processingSubscription?.cancel();
+    _queuePlaybackSubscription?.cancel();
+    _player.dispose();
+    super.dispose();
+  }
+}

lib/providers/radio_station_provider.dart

@@ -0,0 +1,79 @@
+import 'package:app/mixins/stream_subscriber.dart';
+import 'package:app/models/models.dart';
+import 'package:app/providers/auth_provider.dart';
+import 'package:app/utils/api_request.dart';
+import 'package:flutter/foundation.dart';
+
+class RadioStationProvider with ChangeNotifier, StreamSubscriber {
+  var _stations = <RadioStation>[];
+
+  List<RadioStation> get stations => _stations.toList();
+
+  RadioStationProvider() {
+    subscribe(AuthProvider.userLoggedOutStream.listen((_) {
+      _stations.clear();
+      notifyListeners();
+    }));
+  }
+
+  Future<void> fetchAll() async {
+    final res = await get('radio/stations');
+    _stations = (res as List)
+        .map<RadioStation>((j) => RadioStation.fromJson(j))
+        .toList();
+    notifyListeners();
+  }
+
+  Future<RadioStation> create({
+    required String name,
+    required String url,
+    String? description,
+    bool isPublic = false,
+  }) async {
+    final json = await post('radio/stations', data: {
+      'name': name,
+      'url': url,
+      'is_public': isPublic,
+      if (description != null && description.isNotEmpty)
+        'description': description,
+    });
+
+    final station = RadioStation.fromJson(json);
+    _stations.add(station);
+    notifyListeners();
+    return station;
+  }
+
+  Future<void> update(
+    RadioStation station, {
+    required String name,
+    required String url,
+    String? description,
+    bool isPublic = false,
+  }) async {
+    await put('radio/stations/${station.id}', data: {
+      'name': name,
+      'url': url,
+      'description': description ?? '',
+      'is_public': isPublic,
+    });
+
+    station
+      ..name = name
+      ..url = url
+      ..description = description
+      ..isPublic = isPublic;
+
+    notifyListeners();
+  }
+
+  Future<void> remove(RadioStation station) async {
+    delete('radio/stations/${station.id}');
+    _stations.remove(station);
+    notifyListeners();
+  }
+
+  Future<Map<String, dynamic>> getNowPlaying(RadioStation station) async {
+    return await get('radio/stations/${station.id}/now-playing');
+  }
+}

lib/ui/screens/library.dart

@@ -65,6 +65,13 @@ class LibraryScreen extends StatelessWidget {
               CupertinoPageRoute(builder: (_) => const PodcastsScreen()),
             ),
           ),
+        LibraryMenuItem(
+          icon: CupertinoIcons.antenna_radiowaves_left_right,
+          label: 'Radio',
+          onTap: () => Navigator.of(context).push(
+            CupertinoPageRoute(builder: (_) => const RadioStationsScreen()),
+          ),
+        ),
         LibraryMenuItem(
           icon: CupertinoIcons.cloud_download_fill,
           label: 'Downloaded',