deps_resolver.dart 6.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189
  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/supabase_auth_service.dart';
  16. import 'package:appflowy/user/application/prelude.dart';
  17. import 'package:appflowy/user/application/user_listener.dart';
  18. import 'package:appflowy/user/application/user_service.dart';
  19. import 'package:appflowy/user/presentation/router.dart';
  20. import 'package:appflowy/workspace/application/edit_panel/edit_panel_bloc.dart';
  21. import 'package:appflowy/workspace/application/favorite/favorite_bloc.dart';
  22. import 'package:appflowy/workspace/application/settings/prelude.dart';
  23. import 'package:appflowy/workspace/application/tabs/tabs_bloc.dart';
  24. import 'package:appflowy/workspace/application/user/prelude.dart';
  25. import 'package:appflowy/workspace/application/view/prelude.dart';
  26. import 'package:appflowy/workspace/application/workspace/prelude.dart';
  27. import 'package:appflowy/workspace/presentation/home/menu/menu_shared_state.dart';
  28. import 'package:appflowy_backend/protobuf/flowy-folder2/view.pb.dart';
  29. import 'package:appflowy_backend/protobuf/flowy-user/user_profile.pb.dart';
  30. import 'package:flowy_infra/file_picker/file_picker_impl.dart';
  31. import 'package:flowy_infra/file_picker/file_picker_service.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. getIt.registerFactory<ClipboardService>(
  81. () => ClipboardService(),
  82. );
  83. }
  84. void _resolveUserDeps(GetIt getIt) {
  85. if (isSupabaseEnabled) {
  86. getIt.registerFactory<AuthService>(() => SupabaseAuthService());
  87. } else {
  88. getIt.registerFactory<AuthService>(() => AppFlowyAuthService());
  89. }
  90. getIt.registerFactory<AuthRouter>(() => AuthRouter());
  91. getIt.registerFactory<SignInBloc>(
  92. () => SignInBloc(getIt<AuthService>()),
  93. );
  94. getIt.registerFactory<SignUpBloc>(
  95. () => SignUpBloc(getIt<AuthService>()),
  96. );
  97. getIt.registerFactory<SplashRoute>(() => SplashRoute());
  98. getIt.registerFactory<EditPanelBloc>(() => EditPanelBloc());
  99. getIt.registerFactory<SplashBloc>(() => SplashBloc());
  100. getIt.registerLazySingleton<NetworkListener>(() => NetworkListener());
  101. }
  102. void _resolveHomeDeps(GetIt getIt) {
  103. getIt.registerSingleton(FToast());
  104. getIt.registerSingleton(MenuSharedState());
  105. getIt.registerFactoryParam<UserListener, UserProfilePB, void>(
  106. (user, _) => UserListener(userProfile: user),
  107. );
  108. getIt.registerFactoryParam<WelcomeBloc, UserProfilePB, void>(
  109. (user, _) => WelcomeBloc(
  110. userService: UserBackendService(userId: user.id),
  111. ),
  112. );
  113. // share
  114. getIt.registerFactoryParam<DocShareBloc, ViewPB, void>(
  115. (view, _) => DocShareBloc(view: view),
  116. );
  117. getIt.registerLazySingleton<TabsBloc>(() => TabsBloc());
  118. }
  119. void _resolveFolderDeps(GetIt getIt) {
  120. //workspace
  121. getIt.registerFactoryParam<WorkspaceListener, UserProfilePB, String>(
  122. (user, workspaceId) =>
  123. WorkspaceListener(user: user, workspaceId: workspaceId),
  124. );
  125. getIt.registerFactoryParam<ViewBloc, ViewPB, void>(
  126. (view, _) => ViewBloc(
  127. view: view,
  128. ),
  129. );
  130. //Settings
  131. getIt.registerFactoryParam<SettingsDialogBloc, UserProfilePB, void>(
  132. (user, _) => SettingsDialogBloc(user),
  133. );
  134. //User
  135. getIt.registerFactoryParam<SettingsUserViewBloc, UserProfilePB, void>(
  136. (user, _) => SettingsUserViewBloc(user),
  137. );
  138. // trash
  139. getIt.registerLazySingleton<TrashService>(() => TrashService());
  140. getIt.registerLazySingleton<TrashListener>(() => TrashListener());
  141. getIt.registerFactory<TrashBloc>(
  142. () => TrashBloc(),
  143. );
  144. getIt.registerFactory<FavoriteBloc>(() => FavoriteBloc());
  145. }
  146. void _resolveDocDeps(GetIt getIt) {
  147. // Doc
  148. getIt.registerFactoryParam<DocumentBloc, ViewPB, void>(
  149. (view, _) => DocumentBloc(view: view),
  150. );
  151. }
  152. void _resolveGridDeps(GetIt getIt) {
  153. getIt.registerFactoryParam<GridHeaderBloc, String, FieldController>(
  154. (viewId, fieldController) => GridHeaderBloc(
  155. viewId: viewId,
  156. fieldController: fieldController,
  157. ),
  158. );
  159. getIt.registerFactoryParam<FieldActionSheetBloc, FieldContext, void>(
  160. (data, _) => FieldActionSheetBloc(fieldCellContext: data),
  161. );
  162. getIt.registerFactoryParam<DatabasePropertyBloc, String, FieldController>(
  163. (viewId, cache) =>
  164. DatabasePropertyBloc(viewId: viewId, fieldController: cache),
  165. );
  166. }