home_bloc.dart 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105
  1. import 'package:appflowy/user/application/user_listener.dart';
  2. import 'package:flowy_infra/time/duration.dart';
  3. import 'package:appflowy_backend/log.dart';
  4. import 'package:appflowy_backend/protobuf/flowy-folder2/view.pb.dart';
  5. import 'package:appflowy_backend/protobuf/flowy-folder2/workspace.pb.dart'
  6. show WorkspaceSettingPB;
  7. import 'package:appflowy_backend/protobuf/flowy-user/user_profile.pb.dart';
  8. import 'package:flutter_bloc/flutter_bloc.dart';
  9. import 'package:freezed_annotation/freezed_annotation.dart';
  10. part 'home_bloc.freezed.dart';
  11. class HomeBloc extends Bloc<HomeEvent, HomeState> {
  12. final UserWorkspaceListener _workspaceListener;
  13. HomeBloc(
  14. UserProfilePB userProfile,
  15. WorkspaceSettingPB workspaceSetting,
  16. ) : _workspaceListener = UserWorkspaceListener(userProfile: userProfile),
  17. super(HomeState.initial(workspaceSetting)) {
  18. on<HomeEvent>(
  19. (event, emit) async {
  20. await event.map(
  21. initial: (_Initial value) {
  22. Future.delayed(const Duration(milliseconds: 300), () {
  23. if (!isClosed) {
  24. add(HomeEvent.didReceiveWorkspaceSetting(workspaceSetting));
  25. }
  26. });
  27. _workspaceListener.start(
  28. onSettingUpdated: (result) {
  29. result.fold(
  30. (setting) =>
  31. add(HomeEvent.didReceiveWorkspaceSetting(setting)),
  32. (r) => Log.error(r),
  33. );
  34. },
  35. );
  36. },
  37. showLoading: (e) async {
  38. emit(state.copyWith(isLoading: e.isLoading));
  39. },
  40. didReceiveWorkspaceSetting: (_DidReceiveWorkspaceSetting value) {
  41. final latestView = workspaceSetting.hasLatestView()
  42. ? workspaceSetting.latestView
  43. : state.latestView;
  44. emit(
  45. state.copyWith(
  46. workspaceSetting: value.setting,
  47. latestView: latestView,
  48. ),
  49. );
  50. },
  51. );
  52. },
  53. );
  54. }
  55. @override
  56. Future<void> close() async {
  57. await _workspaceListener.stop();
  58. return super.close();
  59. }
  60. }
  61. enum MenuResizeType {
  62. slide,
  63. drag,
  64. }
  65. extension MenuResizeTypeExtension on MenuResizeType {
  66. Duration duration() {
  67. switch (this) {
  68. case MenuResizeType.drag:
  69. return 30.milliseconds;
  70. case MenuResizeType.slide:
  71. return 350.milliseconds;
  72. }
  73. }
  74. }
  75. @freezed
  76. class HomeEvent with _$HomeEvent {
  77. const factory HomeEvent.initial() = _Initial;
  78. const factory HomeEvent.showLoading(bool isLoading) = _ShowLoading;
  79. const factory HomeEvent.didReceiveWorkspaceSetting(
  80. WorkspaceSettingPB setting,
  81. ) = _DidReceiveWorkspaceSetting;
  82. }
  83. @freezed
  84. class HomeState with _$HomeState {
  85. const factory HomeState({
  86. required bool isLoading,
  87. required WorkspaceSettingPB workspaceSetting,
  88. ViewPB? latestView,
  89. }) = _HomeState;
  90. factory HomeState.initial(WorkspaceSettingPB workspaceSetting) => HomeState(
  91. isLoading: false,
  92. workspaceSetting: workspaceSetting,
  93. latestView: null,
  94. );
  95. }