deps_resolver.dart 6.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184
  1. import 'package:appflowy/core/config/kv.dart';
  2. import 'package:appflowy/core/network_monitor.dart';
  3. import 'package:appflowy/env/env.dart';
  4. import 'package:appflowy/plugins/database_view/application/field/field_action_sheet_bloc.dart';
  5. import 'package:appflowy/plugins/database_view/application/field/field_controller.dart';
  6. import 'package:appflowy/plugins/database_view/application/field/field_service.dart';
  7. import 'package:appflowy/plugins/database_view/application/setting/property_bloc.dart';
  8. import 'package:appflowy/plugins/database_view/grid/application/grid_header_bloc.dart';
  9. import 'package:appflowy/plugins/document/presentation/editor_plugins/openai/service/openai_client.dart';
  10. import 'package:appflowy/startup/startup.dart';
  11. import 'package:appflowy/user/application/auth/auth_service.dart';
  12. import 'package:appflowy/user/application/auth/supabase_auth_service.dart';
  13. import 'package:appflowy/user/application/user_listener.dart';
  14. import 'package:appflowy/user/application/user_service.dart';
  15. import 'package:appflowy/workspace/application/tabs/tabs_bloc.dart';
  16. import 'package:flowy_infra/file_picker/file_picker_impl.dart';
  17. import 'package:flowy_infra/file_picker/file_picker_service.dart';
  18. import 'package:appflowy/plugins/document/application/prelude.dart';
  19. import 'package:appflowy/workspace/application/favorite/favorite_bloc.dart';
  20. import 'package:appflowy/workspace/application/user/prelude.dart';
  21. import 'package:appflowy/workspace/application/workspace/prelude.dart';
  22. import 'package:appflowy/workspace/application/edit_panel/edit_panel_bloc.dart';
  23. import 'package:appflowy/workspace/application/view/prelude.dart';
  24. import 'package:appflowy/workspace/application/settings/prelude.dart';
  25. import 'package:appflowy/user/application/prelude.dart';
  26. import 'package:appflowy/user/presentation/router.dart';
  27. import 'package:appflowy/plugins/trash/application/prelude.dart';
  28. import 'package:appflowy/workspace/presentation/home/menu/menu_shared_state.dart';
  29. import 'package:appflowy_backend/protobuf/flowy-folder2/view.pb.dart';
  30. import 'package:appflowy_backend/protobuf/flowy-user/user_profile.pb.dart';
  31. import 'package:fluttertoast/fluttertoast.dart';
  32. import 'package:get_it/get_it.dart';
  33. import 'package:http/http.dart' as http;
  34. class DependencyResolver {
  35. static Future<void> resolve(
  36. GetIt getIt,
  37. IntegrationMode mode,
  38. ) async {
  39. _resolveUserDeps(getIt);
  40. _resolveHomeDeps(getIt);
  41. _resolveFolderDeps(getIt);
  42. _resolveDocDeps(getIt);
  43. _resolveGridDeps(getIt);
  44. _resolveCommonService(getIt, mode);
  45. }
  46. }
  47. void _resolveCommonService(
  48. GetIt getIt,
  49. IntegrationMode mode,
  50. ) async {
  51. // getIt.registerFactory<KeyValueStorage>(() => RustKeyValue());
  52. getIt.registerFactory<KeyValueStorage>(() => DartKeyValue());
  53. getIt.registerFactory<FilePickerService>(() => FilePicker());
  54. if (mode.isTest) {
  55. getIt.registerFactory<ApplicationDataStorage>(
  56. () => MockApplicationDataStorage(),
  57. );
  58. } else {
  59. getIt.registerFactory<ApplicationDataStorage>(
  60. () => ApplicationDataStorage(),
  61. );
  62. }
  63. getIt.registerFactoryAsync<OpenAIRepository>(
  64. () async {
  65. final result = await UserBackendService.getCurrentUserProfile();
  66. return result.fold(
  67. (l) {
  68. throw Exception('Failed to get user profile: ${l.msg}');
  69. },
  70. (r) {
  71. return HttpOpenAIRepository(
  72. client: http.Client(),
  73. apiKey: r.openaiKey,
  74. );
  75. },
  76. );
  77. },
  78. );
  79. }
  80. void _resolveUserDeps(GetIt getIt) {
  81. if (isSupabaseEnabled) {
  82. getIt.registerFactory<AuthService>(() => SupabaseAuthService());
  83. } else {
  84. getIt.registerFactory<AuthService>(() => AppFlowyAuthService());
  85. }
  86. getIt.registerFactory<AuthRouter>(() => AuthRouter());
  87. getIt.registerFactory<SignInBloc>(
  88. () => SignInBloc(getIt<AuthService>()),
  89. );
  90. getIt.registerFactory<SignUpBloc>(
  91. () => SignUpBloc(getIt<AuthService>()),
  92. );
  93. getIt.registerFactory<SplashRoute>(() => SplashRoute());
  94. getIt.registerFactory<EditPanelBloc>(() => EditPanelBloc());
  95. getIt.registerFactory<SplashBloc>(() => SplashBloc());
  96. getIt.registerLazySingleton<NetworkListener>(() => NetworkListener());
  97. }
  98. void _resolveHomeDeps(GetIt getIt) {
  99. getIt.registerSingleton(FToast());
  100. getIt.registerSingleton(MenuSharedState());
  101. getIt.registerFactoryParam<UserListener, UserProfilePB, void>(
  102. (user, _) => UserListener(userProfile: user),
  103. );
  104. getIt.registerFactoryParam<WelcomeBloc, UserProfilePB, void>(
  105. (user, _) => WelcomeBloc(
  106. userService: UserBackendService(userId: user.id),
  107. ),
  108. );
  109. // share
  110. getIt.registerFactoryParam<DocShareBloc, ViewPB, void>(
  111. (view, _) => DocShareBloc(view: view),
  112. );
  113. getIt.registerLazySingleton<TabsBloc>(() => TabsBloc());
  114. }
  115. void _resolveFolderDeps(GetIt getIt) {
  116. //workspace
  117. getIt.registerFactoryParam<WorkspaceListener, UserProfilePB, String>(
  118. (user, workspaceId) =>
  119. WorkspaceListener(user: user, workspaceId: workspaceId),
  120. );
  121. getIt.registerFactoryParam<ViewBloc, ViewPB, void>(
  122. (view, _) => ViewBloc(
  123. view: view,
  124. ),
  125. );
  126. //Settings
  127. getIt.registerFactoryParam<SettingsDialogBloc, UserProfilePB, void>(
  128. (user, _) => SettingsDialogBloc(user),
  129. );
  130. //User
  131. getIt.registerFactoryParam<SettingsUserViewBloc, UserProfilePB, void>(
  132. (user, _) => SettingsUserViewBloc(user),
  133. );
  134. // trash
  135. getIt.registerLazySingleton<TrashService>(() => TrashService());
  136. getIt.registerLazySingleton<TrashListener>(() => TrashListener());
  137. getIt.registerFactory<TrashBloc>(
  138. () => TrashBloc(),
  139. );
  140. getIt.registerFactory<FavoriteBloc>(() => FavoriteBloc());
  141. }
  142. void _resolveDocDeps(GetIt getIt) {
  143. // Doc
  144. getIt.registerFactoryParam<DocumentBloc, ViewPB, void>(
  145. (view, _) => DocumentBloc(view: view),
  146. );
  147. }
  148. void _resolveGridDeps(GetIt getIt) {
  149. getIt.registerFactoryParam<GridHeaderBloc, String, FieldController>(
  150. (viewId, fieldController) => GridHeaderBloc(
  151. viewId: viewId,
  152. fieldController: fieldController,
  153. ),
  154. );
  155. getIt.registerFactoryParam<FieldActionSheetBloc, FieldContext, void>(
  156. (data, _) => FieldActionSheetBloc(fieldCellContext: data),
  157. );
  158. getIt.registerFactoryParam<DatabasePropertyBloc, String, FieldController>(
  159. (viewId, cache) =>
  160. DatabasePropertyBloc(viewId: viewId, fieldController: cache),
  161. );
  162. }