i_app_impl.dart 1.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. import 'package:app_flowy/workspace/infrastructure/repos/app_repo.dart';
  2. import 'package:dartz/dartz.dart';
  3. import 'package:flowy_sdk/protobuf/flowy-workspace/errors.pb.dart' as workspace;
  4. import 'package:app_flowy/workspace/domain/i_app.dart';
  5. import 'package:flowy_sdk/protobuf/flowy-workspace/view_create.pb.dart';
  6. export 'package:app_flowy/workspace/domain/i_app.dart';
  7. class IAppImpl extends IApp {
  8. AppRepository repo;
  9. IAppImpl({
  10. required this.repo,
  11. });
  12. @override
  13. Future<Either<List<View>, workspace.WorkspaceError>> getViews() {
  14. return repo.getViews();
  15. }
  16. @override
  17. Future<Either<View, workspace.WorkspaceError>> createView(
  18. {required String name, String? desc, required ViewType viewType}) {
  19. return repo.createView(name, desc ?? "", viewType).then((result) {
  20. return result.fold(
  21. (view) => left(view),
  22. (r) => right(r),
  23. );
  24. });
  25. }
  26. }
  27. class IAppListenerhImpl extends IAppListenr {
  28. AppListenerRepository repo;
  29. IAppListenerhImpl({
  30. required this.repo,
  31. });
  32. @override
  33. void start({AppCreateViewCallback? addViewCallback, AppUpdatedCallback? updatedCallback}) {
  34. repo.startListen(createView: addViewCallback, update: updatedCallback);
  35. }
  36. @override
  37. Future<void> stop() async {
  38. await repo.close();
  39. }
  40. }