import 'package:flutter/foundation.dart'; import 'package:flutter/painting.dart'; import 'package:immich_mobile/domain/models/asset/base_asset.model.dart'; import 'package:immich_mobile/domain/models/setting.model.dart'; import 'package:immich_mobile/domain/services/setting.service.dart'; import 'package:immich_mobile/infrastructure/loaders/image_request.dart'; import 'package:immich_mobile/presentation/widgets/images/image_provider.dart'; import 'package:immich_mobile/presentation/widgets/images/one_frame_multi_image_stream_completer.dart'; import 'package:immich_mobile/services/api.service.dart'; import 'package:immich_mobile/utils/image_url_builder.dart'; import 'package:openapi/api.dart'; class RemoteThumbProvider extends CancellableImageProvider with CancellableImageProviderMixin { final String assetId; final String thumbhash; RemoteThumbProvider({required this.assetId, required this.thumbhash}); @override Future obtainKey(ImageConfiguration configuration) { return SynchronousFuture(this); } @override ImageStreamCompleter loadImage(RemoteThumbProvider key, ImageDecoderCallback decode) { return OneFramePlaceholderImageStreamCompleter( _codec(key, decode), informationCollector: () => [ DiagnosticsProperty('Image provider', this), DiagnosticsProperty('Asset Id', key.assetId), ], onDispose: cancel, ); } Stream _codec(RemoteThumbProvider key, ImageDecoderCallback decode) { final request = this.request = RemoteImageRequest( uri: getThumbnailUrlForRemoteId(key.assetId, thumbhash: key.thumbhash), headers: ApiService.getRequestHeaders(), ); return loadRequest(request, decode); } @override bool operator ==(Object other) { if (identical(this, other)) return true; if (other is RemoteThumbProvider) { return assetId == other.assetId && thumbhash == other.thumbhash; } return false; } @override int get hashCode => assetId.hashCode ^ thumbhash.hashCode; } class RemoteFullImageProvider extends CancellableImageProvider with CancellableImageProviderMixin { final String assetId; final String thumbhash; final AssetType assetType; RemoteFullImageProvider({required this.assetId, required this.thumbhash, required this.assetType}); @override Future obtainKey(ImageConfiguration configuration) { return SynchronousFuture(this); } @override ImageStreamCompleter loadImage(RemoteFullImageProvider key, ImageDecoderCallback decode) { return OneFramePlaceholderImageStreamCompleter( _codec(key, decode), initialImage: getInitialImage(RemoteThumbProvider(assetId: key.assetId, thumbhash: key.thumbhash)), informationCollector: () => [ DiagnosticsProperty('Image provider', this), DiagnosticsProperty('Asset Id', key.assetId), ], onDispose: cancel, ); } Stream _codec(RemoteFullImageProvider key, ImageDecoderCallback decode) async* { yield* initialImageStream(); if (isCancelled) { PaintingBinding.instance.imageCache.evict(this); return; } final headers = ApiService.getRequestHeaders(); final previewRequest = request = RemoteImageRequest( uri: getThumbnailUrlForRemoteId(key.assetId, type: AssetMediaSize.preview, thumbhash: key.thumbhash), headers: headers, ); yield* loadRequest(previewRequest, decode); if (assetType != AssetType.image || !AppSetting.get(Setting.loadOriginal)) { return; } if (isCancelled) { PaintingBinding.instance.imageCache.evict(this); return; } final originalRequest = request = RemoteImageRequest(uri: getOriginalUrlForRemoteId(key.assetId), headers: headers); yield* loadRequest(originalRequest, decode); } @override bool operator ==(Object other) { if (identical(this, other)) return true; if (other is RemoteFullImageProvider) { return assetId == other.assetId && thumbhash == other.thumbhash; } return false; } @override int get hashCode => assetId.hashCode ^ thumbhash.hashCode; }