deps_resolver.dart 6.6 KB

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