rust_sdk.dart 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768
  1. import 'dart:io';
  2. import 'package:appflowy/env/env.dart';
  3. import 'package:appflowy_backend/appflowy_backend.dart';
  4. import 'package:appflowy_backend/env_serde.dart';
  5. import 'package:path_provider/path_provider.dart';
  6. import 'package:path/path.dart' as path;
  7. import '../startup.dart';
  8. class InitRustSDKTask extends LaunchTask {
  9. const InitRustSDKTask({
  10. this.directory,
  11. });
  12. // Customize the RustSDK initialization path
  13. final Directory? directory;
  14. @override
  15. LaunchTaskType get type => LaunchTaskType.dataProcessing;
  16. @override
  17. Future<void> initialize(LaunchContext context) async {
  18. final dir = directory ?? await appFlowyApplicationDataDirectory();
  19. final env = getAppFlowyEnv();
  20. context.getIt<FlowySDK>().setEnv(env);
  21. await context.getIt<FlowySDK>().init(dir);
  22. }
  23. }
  24. AppFlowyEnv getAppFlowyEnv() {
  25. final postgresConfig = PostgresConfiguration(
  26. url: Env.supabaseDb,
  27. password: Env.supabaseDbPassword,
  28. port: int.parse(Env.supabaseDbPort),
  29. user_name: Env.supabaseDbUser,
  30. );
  31. final supabaseConfig = SupabaseConfiguration(
  32. enable_sync: Env.enableSupabaseSync,
  33. url: Env.supabaseUrl,
  34. key: Env.supabaseKey,
  35. jwt_secret: Env.supabaseJwtSecret,
  36. postgres_config: postgresConfig,
  37. );
  38. return AppFlowyEnv(
  39. supabase_config: supabaseConfig,
  40. );
  41. }
  42. /// The default directory to store the user data. The directory can be
  43. /// customized by the user via the [ApplicationDataStorage]
  44. Future<Directory> appFlowyApplicationDataDirectory() async {
  45. switch (integrationEnv()) {
  46. case IntegrationMode.develop:
  47. final Directory documentsDir = await getApplicationSupportDirectory()
  48. ..create();
  49. return Directory(path.join(documentsDir.path, 'data_dev')).create();
  50. case IntegrationMode.release:
  51. final Directory documentsDir = await getApplicationSupportDirectory();
  52. return Directory(path.join(documentsDir.path, 'data')).create();
  53. case IntegrationMode.unitTest:
  54. case IntegrationMode.integrationTest:
  55. return Directory(path.join(Directory.current.path, '.sandbox'));
  56. }
  57. }