72 lines
2.5 KiB
Dart
72 lines
2.5 KiB
Dart
import 'dart:async';
|
|
|
|
import 'package:aves/model/filters/filters.dart';
|
|
import 'package:aves/services/app_service.dart';
|
|
import 'package:aves/services/common/services.dart';
|
|
import 'package:flutter/services.dart';
|
|
import 'package:streams_channel/streams_channel.dart';
|
|
|
|
class IntentService {
|
|
static const _platform = MethodChannel('deckers.thibault/aves/intent');
|
|
static final _stream = StreamsChannel('deckers.thibault/aves/activity_result_stream');
|
|
|
|
static Future<Map<String, dynamic>> getIntentData() async {
|
|
try {
|
|
// returns nullable map with 'action' and possibly 'uri' 'mimeType'
|
|
final result = await _platform.invokeMethod('getIntentData');
|
|
if (result != null) return (result as Map).cast<String, dynamic>();
|
|
} on PlatformException catch (e, stack) {
|
|
await reportService.recordError(e, stack);
|
|
}
|
|
return {};
|
|
}
|
|
|
|
static Future<void> submitPickedItems(List<String> uris) async {
|
|
try {
|
|
await _platform.invokeMethod('submitPickedItems', <String, dynamic>{
|
|
'uris': uris,
|
|
});
|
|
} on PlatformException catch (e, stack) {
|
|
if (e.code == 'submitPickedItems-large') {
|
|
throw TooManyItemsException();
|
|
} else {
|
|
await reportService.recordError(e, stack);
|
|
}
|
|
}
|
|
}
|
|
|
|
static Future<void> submitPickedCollectionFilters(Set<CollectionFilter>? filters) async {
|
|
try {
|
|
await _platform.invokeMethod('submitPickedCollectionFilters', <String, dynamic>{
|
|
'filters': filters?.map((filter) => filter.toJson()).toList(),
|
|
});
|
|
} on PlatformException catch (e, stack) {
|
|
await reportService.recordError(e, stack);
|
|
}
|
|
}
|
|
|
|
static Future<Set<CollectionFilter>?> pickCollectionFilters(Set<CollectionFilter>? initialFilters) async {
|
|
try {
|
|
final opCompleter = Completer<Set<CollectionFilter>?>();
|
|
_stream.receiveBroadcastStream(<String, dynamic>{
|
|
'op': 'pickCollectionFilters',
|
|
'initialFilters': initialFilters?.map((filter) => filter.toJson()).toList(),
|
|
}).listen(
|
|
(data) {
|
|
final result = (data as List?)?.cast<String>().map(CollectionFilter.fromJson).nonNulls.toSet();
|
|
opCompleter.complete(result);
|
|
},
|
|
onError: opCompleter.completeError,
|
|
onDone: () {
|
|
if (!opCompleter.isCompleted) opCompleter.complete(null);
|
|
},
|
|
cancelOnError: true,
|
|
);
|
|
// `await` here, so that `completeError` will be caught below
|
|
return await opCompleter.future;
|
|
} on PlatformException catch (e, stack) {
|
|
await reportService.recordError(e, stack);
|
|
}
|
|
return null;
|
|
}
|
|
}
|