refactor(mobile): cast_destination.interface.dart (#19346)

This commit is contained in:
Alex 2025-06-21 21:56:49 -05:00 committed by GitHub
parent 81eb98d4e5
commit ce8c80dad0
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 6 additions and 46 deletions

View File

@ -1,27 +0,0 @@
import 'package:immich_mobile/entities/asset.entity.dart';
import 'package:immich_mobile/models/cast/cast_manager_state.dart';
abstract interface class ICastDestinationService {
Future<bool> initialize();
CastDestinationType getType();
void Function(bool)? onConnectionState;
void Function(Duration)? onCurrentTime;
void Function(Duration)? onDuration;
void Function(String)? onReceiverName;
void Function(CastState)? onCastState;
Future<void> connect(dynamic device);
void loadMedia(Asset asset, bool reload);
void play();
void pause();
void seekTo(Duration position);
void stop();
Future<void> disconnect();
Future<List<(String, CastDestinationType, dynamic)>> getDevices();
}

View File

@ -1,6 +1,5 @@
import 'package:hooks_riverpod/hooks_riverpod.dart'; import 'package:hooks_riverpod/hooks_riverpod.dart';
import 'package:immich_mobile/entities/asset.entity.dart'; import 'package:immich_mobile/entities/asset.entity.dart';
import 'package:immich_mobile/interfaces/cast_destination_service.interface.dart';
import 'package:immich_mobile/models/cast/cast_manager_state.dart'; import 'package:immich_mobile/models/cast/cast_manager_state.dart';
import 'package:immich_mobile/services/gcast.service.dart'; import 'package:immich_mobile/services/gcast.service.dart';
@ -10,7 +9,7 @@ final castProvider = StateNotifierProvider<CastNotifier, CastManagerState>(
class CastNotifier extends StateNotifier<CastManagerState> { class CastNotifier extends StateNotifier<CastManagerState> {
// more cast providers can be added here (ie Fcast) // more cast providers can be added here (ie Fcast)
final ICastDestinationService _gCastService; final GCastService _gCastService;
List<(String, CastDestinationType, dynamic)> discovered = List.empty(); List<(String, CastDestinationType, dynamic)> discovered = List.empty();

View File

@ -3,7 +3,6 @@ import 'dart:async';
import 'package:cast/session.dart'; import 'package:cast/session.dart';
import 'package:hooks_riverpod/hooks_riverpod.dart'; import 'package:hooks_riverpod/hooks_riverpod.dart';
import 'package:immich_mobile/entities/asset.entity.dart'; import 'package:immich_mobile/entities/asset.entity.dart';
import 'package:immich_mobile/interfaces/cast_destination_service.interface.dart';
import 'package:immich_mobile/models/cast/cast_manager_state.dart'; import 'package:immich_mobile/models/cast/cast_manager_state.dart';
import 'package:immich_mobile/models/sessions/session_create_response.model.dart'; import 'package:immich_mobile/models/sessions/session_create_response.model.dart';
import 'package:immich_mobile/repositories/asset_api.repository.dart'; import 'package:immich_mobile/repositories/asset_api.repository.dart';
@ -21,7 +20,7 @@ final gCastServiceProvider = Provider(
), ),
); );
class GCastService implements ICastDestinationService { class GCastService {
final GCastRepository _gCastRepository; final GCastRepository _gCastRepository;
final SessionsAPIRepository _sessionsApiService; final SessionsAPIRepository _sessionsApiService;
final AssetApiRepository _assetApiRepository; final AssetApiRepository _assetApiRepository;
@ -32,15 +31,14 @@ class GCastService implements ICastDestinationService {
int? _sessionId; int? _sessionId;
Timer? _mediaStatusPollingTimer; Timer? _mediaStatusPollingTimer;
@override
void Function(bool)? onConnectionState; void Function(bool)? onConnectionState;
@override
void Function(Duration)? onCurrentTime; void Function(Duration)? onCurrentTime;
@override
void Function(Duration)? onDuration; void Function(Duration)? onDuration;
@override
void Function(String)? onReceiverName; void Function(String)? onReceiverName;
@override
void Function(CastState)? onCastState; void Function(CastState)? onCastState;
GCastService( GCastService(
@ -120,25 +118,21 @@ class GCastService implements ICastDestinationService {
} }
} }
@override
Future<void> connect(dynamic device) async { Future<void> connect(dynamic device) async {
await _gCastRepository.connect(device); await _gCastRepository.connect(device);
onReceiverName?.call(device.extras["fn"] ?? "Google Cast"); onReceiverName?.call(device.extras["fn"] ?? "Google Cast");
} }
@override
CastDestinationType getType() { CastDestinationType getType() {
return CastDestinationType.googleCast; return CastDestinationType.googleCast;
} }
@override
Future<bool> initialize() async { Future<bool> initialize() async {
// there is nothing blocking us from using Google Cast that we can check for // there is nothing blocking us from using Google Cast that we can check for
return true; return true;
} }
@override
Future<void> disconnect() async { Future<void> disconnect() async {
onReceiverName?.call(""); onReceiverName?.call("");
currentAssetId = null; currentAssetId = null;
@ -162,7 +156,6 @@ class GCastService implements ICastDestinationService {
return bufferedExpiration.isAfter(DateTime.now()); return bufferedExpiration.isAfter(DateTime.now());
} }
@override
void loadMedia(Asset asset, bool reload) async { void loadMedia(Asset asset, bool reload) async {
if (!isConnected) { if (!isConnected) {
return; return;
@ -234,7 +227,6 @@ class GCastService implements ICastDestinationService {
} }
} }
@override
void play() { void play() {
_gCastRepository.sendMessage(CastSession.kNamespaceMedia, { _gCastRepository.sendMessage(CastSession.kNamespaceMedia, {
"type": "PLAY", "type": "PLAY",
@ -242,7 +234,6 @@ class GCastService implements ICastDestinationService {
}); });
} }
@override
void pause() { void pause() {
_gCastRepository.sendMessage(CastSession.kNamespaceMedia, { _gCastRepository.sendMessage(CastSession.kNamespaceMedia, {
"type": "PAUSE", "type": "PAUSE",
@ -250,7 +241,6 @@ class GCastService implements ICastDestinationService {
}); });
} }
@override
void seekTo(Duration position) { void seekTo(Duration position) {
_gCastRepository.sendMessage(CastSession.kNamespaceMedia, { _gCastRepository.sendMessage(CastSession.kNamespaceMedia, {
"type": "SEEK", "type": "SEEK",
@ -259,7 +249,6 @@ class GCastService implements ICastDestinationService {
}); });
} }
@override
void stop() { void stop() {
_gCastRepository.sendMessage(CastSession.kNamespaceMedia, { _gCastRepository.sendMessage(CastSession.kNamespaceMedia, {
"type": "STOP", "type": "STOP",
@ -273,7 +262,6 @@ class GCastService implements ICastDestinationService {
// 0x01 is display capability bitmask // 0x01 is display capability bitmask
bool isDisplay(int ca) => (ca & 0x01) != 0; bool isDisplay(int ca) => (ca & 0x01) != 0;
@override
Future<List<(String, CastDestinationType, dynamic)>> getDevices() async { Future<List<(String, CastDestinationType, dynamic)>> getDevices() async {
final dests = await _gCastRepository.listDestinations(); final dests = await _gCastRepository.listDestinations();