deps_resolver.dart 6.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190
  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/menu/prelude.dart';
  25. import 'package:appflowy/workspace/application/settings/prelude.dart';
  26. import 'package:appflowy/user/application/prelude.dart';
  27. import 'package:appflowy/user/presentation/router.dart';
  28. import 'package:appflowy/plugins/trash/application/prelude.dart';
  29. import 'package:appflowy/workspace/presentation/home/menu/menu.dart';
  30. import 'package:appflowy_backend/protobuf/flowy-folder2/view.pb.dart';
  31. import 'package:appflowy_backend/protobuf/flowy-user/user_profile.pb.dart';
  32. import 'package:fluttertoast/fluttertoast.dart';
  33. import 'package:get_it/get_it.dart';
  34. import 'package:http/http.dart' as http;
  35. class DependencyResolver {
  36. static Future<void> resolve(
  37. GetIt getIt,
  38. IntegrationMode mode,
  39. ) async {
  40. _resolveUserDeps(getIt);
  41. _resolveHomeDeps(getIt);
  42. _resolveFolderDeps(getIt);
  43. _resolveDocDeps(getIt);
  44. _resolveGridDeps(getIt);
  45. _resolveCommonService(getIt, mode);
  46. }
  47. }
  48. void _resolveCommonService(
  49. GetIt getIt,
  50. IntegrationMode mode,
  51. ) async {
  52. // getIt.registerFactory<KeyValueStorage>(() => RustKeyValue());
  53. getIt.registerFactory<KeyValueStorage>(() => DartKeyValue());
  54. getIt.registerFactory<FilePickerService>(() => FilePicker());
  55. if (mode.isTest) {
  56. getIt.registerFactory<ApplicationDataStorage>(
  57. () => MockApplicationDataStorage(),
  58. );
  59. } else {
  60. getIt.registerFactory<ApplicationDataStorage>(
  61. () => ApplicationDataStorage(),
  62. );
  63. }
  64. getIt.registerFactoryAsync<OpenAIRepository>(
  65. () async {
  66. final result = await UserBackendService.getCurrentUserProfile();
  67. return result.fold(
  68. (l) {
  69. throw Exception('Failed to get user profile: ${l.msg}');
  70. },
  71. (r) {
  72. return HttpOpenAIRepository(
  73. client: http.Client(),
  74. apiKey: r.openaiKey,
  75. );
  76. },
  77. );
  78. },
  79. );
  80. }
  81. void _resolveUserDeps(GetIt getIt) {
  82. if (isSupabaseEnabled) {
  83. getIt.registerFactory<AuthService>(() => SupabaseAuthService());
  84. } else {
  85. getIt.registerFactory<AuthService>(() => AppFlowyAuthService());
  86. }
  87. getIt.registerFactory<AuthRouter>(() => AuthRouter());
  88. getIt.registerFactory<SignInBloc>(
  89. () => SignInBloc(getIt<AuthService>()),
  90. );
  91. getIt.registerFactory<SignUpBloc>(
  92. () => SignUpBloc(getIt<AuthService>()),
  93. );
  94. getIt.registerFactory<SplashRoute>(() => SplashRoute());
  95. getIt.registerFactory<EditPanelBloc>(() => EditPanelBloc());
  96. getIt.registerFactory<SplashBloc>(() => SplashBloc());
  97. getIt.registerLazySingleton<NetworkListener>(() => NetworkListener());
  98. }
  99. void _resolveHomeDeps(GetIt getIt) {
  100. getIt.registerSingleton(FToast());
  101. getIt.registerSingleton(MenuSharedState());
  102. getIt.registerFactoryParam<UserListener, UserProfilePB, void>(
  103. (user, _) => UserListener(userProfile: user),
  104. );
  105. getIt.registerFactoryParam<WelcomeBloc, UserProfilePB, void>(
  106. (user, _) => WelcomeBloc(
  107. userService: UserBackendService(userId: user.id),
  108. userWorkspaceListener: UserWorkspaceListener(userProfile: user),
  109. ),
  110. );
  111. // share
  112. getIt.registerFactoryParam<DocShareBloc, ViewPB, void>(
  113. (view, _) => DocShareBloc(view: view),
  114. );
  115. getIt.registerLazySingleton<TabsBloc>(() => TabsBloc());
  116. }
  117. void _resolveFolderDeps(GetIt getIt) {
  118. //workspace
  119. getIt.registerFactoryParam<WorkspaceListener, UserProfilePB, String>(
  120. (user, workspaceId) =>
  121. WorkspaceListener(user: user, workspaceId: workspaceId),
  122. );
  123. getIt.registerFactoryParam<ViewBloc, ViewPB, void>(
  124. (view, _) => ViewBloc(
  125. view: view,
  126. ),
  127. );
  128. getIt.registerFactoryParam<MenuUserBloc, UserProfilePB, void>(
  129. (user, _) => MenuUserBloc(user),
  130. );
  131. //Settings
  132. getIt.registerFactoryParam<SettingsDialogBloc, UserProfilePB, void>(
  133. (user, _) => SettingsDialogBloc(user),
  134. );
  135. //User
  136. getIt.registerFactoryParam<SettingsUserViewBloc, UserProfilePB, void>(
  137. (user, _) => SettingsUserViewBloc(user),
  138. );
  139. // trash
  140. getIt.registerLazySingleton<TrashService>(() => TrashService());
  141. getIt.registerLazySingleton<TrashListener>(() => TrashListener());
  142. getIt.registerFactory<TrashBloc>(
  143. () => TrashBloc(),
  144. );
  145. getIt.registerFactory<FavoriteBloc>(() => FavoriteBloc());
  146. }
  147. void _resolveDocDeps(GetIt getIt) {
  148. // Doc
  149. getIt.registerFactoryParam<DocumentBloc, ViewPB, void>(
  150. (view, _) => DocumentBloc(view: view),
  151. );
  152. }
  153. void _resolveGridDeps(GetIt getIt) {
  154. getIt.registerFactoryParam<GridHeaderBloc, String, FieldController>(
  155. (viewId, fieldController) => GridHeaderBloc(
  156. viewId: viewId,
  157. fieldController: fieldController,
  158. ),
  159. );
  160. getIt.registerFactoryParam<FieldActionSheetBloc, FieldContext, void>(
  161. (data, _) => FieldActionSheetBloc(fieldCellContext: data),
  162. );
  163. getIt.registerFactoryParam<DatabasePropertyBloc, String, FieldController>(
  164. (viewId, cache) =>
  165. DatabasePropertyBloc(viewId: viewId, fieldController: cache),
  166. );
  167. }