refactor(celest): Move connect method to CelestDatabase class (#394)

Adds a new class `CelestDatabase` for representing connected Celest databases and exposing methods for creating Drift database connections and DB studio routes.

Author: dnys1

.github/workflows/celest.yaml

@@ -29,6 +29,12 @@ jobs:
         with:
           channel: stable
           cache: true
+      - name: Install Turso CLI
+        run: |
+          curl -sSfL https://get.tur.so/install.sh | bash
+          echo "PATH=$PATH:/home/runner/.turso" >> $GITHUB_ENV
+        env:
+          TURSO_INSTALL_SKIP_SIGNUP: 1
       - name: Get Packages
         working-directory: packages/celest
         run: |
@@ -46,6 +52,8 @@ jobs:
       - name: Test
         working-directory: packages/celest
         run: dart test
+        env:
+          TURSO_API_TOKEN: ${{ secrets.TURSO_API_TOKEN }}
       - name: Test (dart2js)
         working-directory: packages/celest
         run: dart test -p chrome

apps/cli/CHANGELOG.md

@@ -1,6 +1,7 @@
 ## NEXT
 
 - fix: Don't throw if analysis_options.yaml is missing
+- refactor(celest): Move `connect` method to `CelestDatabase` class
 
 ## 1.0.12
 

apps/cli/fixtures/standalone/api/client/pubspec.yaml

@@ -28,4 +28,6 @@ dependency_overrides:
     path: ../../../../../../services/celest_cloud_core
   celest_core:
     path: ../../../../../../packages/celest_core
+  celest_db_studio:
+    path: ../../../../../../packages/celest_db_studio
 dev_dependencies: {}

apps/cli/fixtures/standalone/api/pubspec.yaml

@@ -29,6 +29,8 @@ dependency_overrides:
     path: ../../../../../services/celest_cloud_core
   celest_core:
     path: ../../../../../packages/celest_core
+  celest_db_studio:
+    path: ../../../../../packages/celest_db_studio
 
 dev_dependencies:
   lints: ^5.0.0

apps/cli/fixtures/standalone/auth/client/pubspec.yaml

@@ -28,4 +28,6 @@ dependency_overrides:
     path: ../../../../../../services/celest_cloud_core
   celest_core:
     path: ../../../../../../packages/celest_core
+  celest_db_studio:
+    path: ../../../../../../packages/celest_db_studio
 dev_dependencies: {}

apps/cli/fixtures/standalone/auth/lib/src/generated/data.celest.dart

@@ -6,7 +6,7 @@ library; // ignore_for_file: no_leading_underscores_for_library_prefixes
 
 import 'package:celest/celest.dart' as _$celest;
 import 'package:celest/src/core/context.dart' as _$celest;
-import 'package:celest/src/runtime/data/connect.dart' as _$celest;
+import 'package:celest/src/runtime/data/celest_database.dart' as _$celest;
 import 'package:celest_cloud_auth/src/database/auth_database.dart' as _$celest;
 
 /// The data services for the Celest backend.
@@ -18,15 +18,16 @@ class CelestData {
 
   /// Initializes the databases attached to this project in the given [context].
   static Future<void> init(_$celest.Context context) async {
+    final cloudAuth = await _$celest.CelestDatabase.create(
+      context,
+      name: 'CloudAuthDatabase',
+      factory: _$celest.CloudAuthDatabase.new,
+      hostnameVariable: const _$celest.env('CLOUD_AUTH_DATABASE_HOST'),
+      tokenSecret: const _$celest.secret('CLOUD_AUTH_DATABASE_TOKEN'),
+    );
     context.put(
       _cloudAuthKey,
-      await _$celest.connect(
-        context,
-        name: 'CloudAuthDatabase',
-        factory: _$celest.CloudAuthDatabase.new,
-        hostnameVariable: const _$celest.env('CLOUD_AUTH_DATABASE_HOST'),
-        tokenSecret: const _$celest.secret('CLOUD_AUTH_DATABASE_TOKEN'),
-      ),
+      await cloudAuth.connect(),
     );
   }
 

apps/cli/fixtures/standalone/auth/pubspec.yaml

@@ -30,6 +30,8 @@ dependency_overrides:
     path: ../../../../../services/celest_cloud_core
   celest_core:
     path: ../../../../../packages/celest_core
+  celest_db_studio:
+    path: ../../../../../packages/celest_db_studio
 
 dev_dependencies:
   lints: ^5.0.0

apps/cli/fixtures/standalone/data/client/lib/src/functions.dart

@@ -32,7 +32,6 @@ import 'package:hrana/src/exception.dart' as _$hrana_exception;
 import 'package:http/src/exception.dart' as _$http_exception;
 import 'package:mustache_template/src/template_exception.dart'
     as _$mustache_template_template_exception;
-import 'package:path/src/path_exception.dart' as _$path_path_exception;
 import 'package:petitparser/src/core/exception.dart' as _$petitparser_exception;
 import 'package:shelf/src/hijack_exception.dart' as _$shelf_hijack_exception;
 import 'package:source_span/src/span_exception.dart'
@@ -549,12 +548,6 @@ class CelestFunctionsTasks {
                   errorValue),
           stackTrace,
         );
-      case 'path.PathException':
-        Error.throwWithStackTrace(
-          _$celest.Serializers.instance
-              .deserialize<_$path_path_exception.PathException>(errorValue),
-          stackTrace,
-        );
       case 'hrana.ConnectionClosed':
         Error.throwWithStackTrace(
           _$celest.Serializers.instance

apps/cli/fixtures/standalone/data/client/lib/src/serializers.dart

@@ -29,7 +29,6 @@ import 'package:hrana/src/exception.dart' as _$hrana_exception;
 import 'package:http/src/exception.dart' as _$http_exception;
 import 'package:mustache_template/src/template_exception.dart'
     as _$mustache_template_template_exception;
-import 'package:path/src/path_exception.dart' as _$path_path_exception;
 import 'package:petitparser/src/core/exception.dart' as _$petitparser_exception;
 import 'package:petitparser/src/core/result.dart' as _$petitparser_result;
 import 'package:shelf/src/hijack_exception.dart' as _$shelf_hijack_exception;
@@ -1172,14 +1171,6 @@ void initSerializers({_$celest.Serializers? serializers}) {
           );
         },
       ));
-      _$celest.Serializers.instance.put(_$celest.Serializer.define<
-          _$path_path_exception.PathException, Map<String, Object?>>(
-        serialize: ($value) => <String, Object?>{r'message': $value.message},
-        deserialize: ($serialized) {
-          return _$path_path_exception.PathException(
-              ($serialized[r'message'] as String));
-        },
-      ));
       _$celest.Serializers.instance.put(_$celest.Serializer.define<
           _$petitparser_exception.ParserException, Map<String, Object?>>(
         serialize: ($value) => <String, Object?>{

apps/cli/fixtures/standalone/data/client/pubspec.yaml

@@ -28,4 +28,6 @@ dependency_overrides:
     path: ../../../../../../services/celest_cloud_core
   celest_core:
     path: ../../../../../../packages/celest_core
+  celest_db_studio:
+    path: ../../../../../../packages/celest_db_studio
 dev_dependencies: {}