first implementation finished

2024-04-22 11:21:01 +02:00
parent 1a13ca0795
commit 0e1972242a
102 changed files with 7192 additions and 55 deletions
@@ -0,0 +1,53 @@
+import 'dart:async';
+
+import 'package:collection/collection.dart';
+import 'package:kagi_bang_bang/domain/entities/received_parameter.dart';
+import 'package:kagi_bang_bang/features/app_widget/domain/services/home_widget.dart';
+import 'package:kagi_bang_bang/features/search_browser/domain/entities/modes.dart';
+import 'package:kagi_bang_bang/features/search_browser/domain/entities/sheet.dart';
+import 'package:kagi_bang_bang/features/share_intent/domain/services/sharing_intent.dart';
+import 'package:riverpod_annotation/riverpod_annotation.dart';
+import 'package:rxdart/rxdart.dart';
+
+part 'create_tab.g.dart';
+
+final _parameterToCreateTabTransformer =
+    StreamTransformer<ReceivedParameter, CreateTab>.fromHandlers(
+  handleData: (parameter, sink) {
+    final createTab = CreateTab(
+      preferredTool: KagiTool.values
+          .firstWhereOrNull((tool) => tool.name == parameter.tool),
+      content: parameter.content,
+    );
+
+    if (createTab.hasParameters) {
+      sink.add(createTab);
+    }
+  },
+);
+
+@Riverpod()
+class CreateTabStream extends _$CreateTabStream {
+  late StreamController<CreateTab> _streamController;
+
+  @override
+  Stream<CreateTab> build() {
+    _streamController = StreamController();
+    ref.onDispose(() async {
+      await _streamController.close();
+    });
+
+    final sharingItentStream = ref.watch(sharingIntentStreamProvider);
+    final appWidgetLaunchStream = ref.watch(appWidgetLaunchStreamProvider);
+
+    return MergeStream([
+      sharingItentStream.transform(_parameterToCreateTabTransformer),
+      appWidgetLaunchStream.transform(_parameterToCreateTabTransformer),
+      _streamController.stream,
+    ]);
+  }
+
+  void createTab(CreateTab parameter) {
+    _streamController.add(parameter);
+  }
+}