feat: Event streaming (#145)

Adds support for server-side event streaming via SSE/WebSocket connections.
celest-dev · Jun 7, 2024 · cd667c7 · cd667c7
1 parent 737b1c1
commit cd667c7
Show file tree

Hide file tree

Showing 44 changed files with 1,424 additions and 72 deletions.
diff --git a/.github/workflows/celest.yaml b/.github/workflows/celest.yaml
@@ -33,3 +33,12 @@ jobs:
       - name: Format
         working-directory: packages/celest
         run: dart format --set-exit-if-changed .
+      - name: Test
+        working-directory: packages/celest
+        run: dart test
+      - name: Test (dart2js)
+        working-directory: packages/celest
+        run: dart test -p chrome
+      - name: Test (dart2wasm)
+        working-directory: packages/celest
+        run: dart test -p chrome -c dart2wasm
diff --git a/examples/gemini/celest/lib/client.dart b/examples/gemini/celest/lib/client.dart
@@ -30,11 +30,12 @@ class Celest with CelestBase {
 
   late CelestEnvironment _currentEnvironment;
 
-  late final NativeStorage _storage = NativeStorage(scope: 'celest');
+  @override
+  late final NativeStorage nativeStorage = NativeStorage(scope: 'celest');
 
   @override
   late _$http.Client httpClient =
-      CelestHttpClient(secureStorage: _storage.secure);
+      CelestHttpClient(secureStorage: nativeStorage.secure);
 
   late Uri _baseUri;
 

diff --git a/examples/gemini/celest/pubspec.yaml b/examples/gemini/celest/pubspec.yaml
@@ -6,7 +6,7 @@ environment:
   sdk: ^3.3.0
 
 dependencies:
-  celest: ^0.4.0-0
+  celest: ^0.4.0
   google_generative_ai: ^0.2.0
   http: ">=0.13.0 <2.0.0"
 
@@ -20,4 +20,4 @@ dependency_overrides:
 
 dev_dependencies:
   lints: ^4.0.0
-  test: ^1.24.0
+  test: ^1.25.0
diff --git a/examples/openai/celest/lib/client.dart b/examples/openai/celest/lib/client.dart
@@ -30,11 +30,12 @@ class Celest with CelestBase {
 
   late CelestEnvironment _currentEnvironment;
 
-  late final NativeStorage _storage = NativeStorage(scope: 'celest');
+  @override
+  late final NativeStorage nativeStorage = NativeStorage(scope: 'celest');
 
   @override
   late _$http.Client httpClient =
-      CelestHttpClient(secureStorage: _storage.secure);
+      CelestHttpClient(secureStorage: nativeStorage.secure);
 
   late Uri _baseUri;
 

diff --git a/examples/openai/celest/pubspec.yaml b/examples/openai/celest/pubspec.yaml
@@ -6,7 +6,7 @@ environment:
   sdk: ^3.3.0
 
 dependencies:
-  celest: ^0.4.0-0
+  celest: ^0.4.0
   chat_gpt_sdk: ^2.2.8
   http: ">=0.13.0 <2.0.0"
 
@@ -20,4 +20,4 @@ dependency_overrides:
 
 dev_dependencies:
   lints: ^4.0.0
-  test: ^1.24.0
+  test: ^1.25.0
diff --git a/examples/todo/celest/lib/client.dart b/examples/todo/celest/lib/client.dart
@@ -30,11 +30,12 @@ class Celest with CelestBase {
 
   late CelestEnvironment _currentEnvironment;
 
-  late final NativeStorage _storage = NativeStorage(scope: 'celest');
+  @override
+  late final NativeStorage nativeStorage = NativeStorage(scope: 'celest');
 
   @override
   late _$http.Client httpClient =
-      CelestHttpClient(secureStorage: _storage.secure);
+      CelestHttpClient(secureStorage: nativeStorage.secure);
 
   late Uri _baseUri;
 

diff --git a/examples/todo/celest/lib/src/client/functions.dart b/examples/todo/celest/lib/src/client/functions.dart
@@ -9,6 +9,8 @@ import 'dart:convert' as _$convert;
 import 'package:celest/celest.dart';
 import 'package:celest_backend/exceptions.dart' as _$exceptions;
 import 'package:celest_backend/models.dart' as _$models;
+import 'package:celest_core/src/exception/cloud_exception.dart';
+import 'package:celest_core/src/exception/serialization_exception.dart';
 
 import '../../client.dart';
 
@@ -25,6 +27,15 @@ class CelestFunctionsTasks {
     final $code = ($error['code'] as String);
     final $details = ($error['details'] as Map<String, Object?>?);
     switch ($code) {
+      case r'BadRequestException':
+        throw Serializers.instance.deserialize<BadRequestException>($details);
+      case r'UnauthorizedException':
+        throw Serializers.instance.deserialize<UnauthorizedException>($details);
+      case r'InternalServerError':
+        throw Serializers.instance.deserialize<InternalServerError>($details);
+      case r'SerializationException':
+        throw Serializers.instance
+            .deserialize<SerializationException>($details);
       case r'ServerException':
         throw Serializers.instance
             .deserialize<_$exceptions.ServerException>($details);

diff --git a/examples/todo/celest/lib/src/client/serializers.dart b/examples/todo/celest/lib/src/client/serializers.dart
@@ -4,6 +4,8 @@
 import 'package:celest/celest.dart';
 import 'package:celest_backend/exceptions.dart' as _$exceptions;
 import 'package:celest_backend/models.dart' as _$models;
+import 'package:celest_core/src/exception/cloud_exception.dart';
+import 'package:celest_core/src/exception/serialization_exception.dart';
 
 void initSerializers() {
   Serializers.instance.put(
@@ -38,4 +40,37 @@ void initSerializers() {
       );
     },
   ));
+  Serializers.instance
+      .put(Serializer.define<BadRequestException, Map<String, Object?>>(
+    serialize: ($value) => {r'message': $value.message},
+    deserialize: ($serialized) {
+      return BadRequestException(($serialized[r'message'] as String));
+    },
+  ));
+  Serializers.instance
+      .put(Serializer.define<InternalServerError, Map<String, Object?>>(
+    serialize: ($value) => {r'message': $value.message},
+    deserialize: ($serialized) {
+      return InternalServerError(($serialized[r'message'] as String));
+    },
+  ));
+  Serializers.instance
+      .put(Serializer.define<UnauthorizedException, Map<String, Object?>?>(
+    serialize: ($value) => {r'message': $value.message},
+    deserialize: ($serialized) {
+      return UnauthorizedException(
+          (($serialized?[r'message'] as String?)) ?? 'Unauthorized');
+    },
+  ));
+  Serializers.instance
+      .put(Serializer.define<SerializationException, Map<String, Object?>>(
+    serialize: ($value) => {
+      r'message': $value.message,
+      r'offset': $value.offset,
+      r'source': $value.source,
+    },
+    deserialize: ($serialized) {
+      return SerializationException(($serialized[r'message'] as String));
+    },
+  ));
 }
diff --git a/examples/todo/celest/pubspec.yaml b/examples/todo/celest/pubspec.yaml
@@ -6,7 +6,7 @@ environment:
   sdk: ^3.3.0
 
 dependencies:
-  celest: ^0.4.0-0
+  celest: ^0.4.0
   http: ">=0.13.0 <2.0.0"
   uuid: ^4.3.3
 
@@ -20,4 +20,4 @@ dependency_overrides:
 
 dev_dependencies:
   lints: ^4.0.0
-  test: ^1.24.0
+  test: ^1.25.0
diff --git a/packages/celest/example/celest/lib/client.dart b/packages/celest/example/celest/lib/client.dart
@@ -20,8 +20,8 @@ enum CelestEnvironment {
 
   Uri get baseUri => switch (this) {
         local => kIsWeb || !_$io.Platform.isAndroid
-            ? Uri.parse('http://localhost:7777')
-            : Uri.parse('http://10.0.2.2:7777'),
+            ? Uri.parse('http://localhost:7778')
+            : Uri.parse('http://10.0.2.2:7778'),
       };
 }
 
@@ -30,11 +30,12 @@ class Celest with CelestBase {
 
   late CelestEnvironment _currentEnvironment;
 
-  late final NativeStorage _storage = NativeStorage(scope: 'celest');
+  @override
+  late final NativeStorage nativeStorage = NativeStorage(scope: 'celest');
 
   @override
   late _$http.Client httpClient =
-      CelestHttpClient(secureStorage: _storage.secure);
+      CelestHttpClient(secureStorage: nativeStorage.secure);
 
   late Uri _baseUri;
 

diff --git a/packages/celest/example/celest/lib/src/client/functions.dart b/packages/celest/example/celest/lib/src/client/functions.dart
@@ -54,7 +54,7 @@ class CelestFunctionsGreeting {
   Future<String> sayHello({required _$person.Person person}) async {
     final $response = await celest.httpClient.post(
       celest.baseUri.resolve('/greeting/say-hello'),
-      headers: const {'Content-Type': 'application/json; charset=utf-8'},
+      headers: {'Content-Type': 'application/json; charset=utf-8'},
       body: _$convert.jsonEncode(
           {r'person': Serializers.instance.serialize<_$person.Person>(person)}),
     );

diff --git a/packages/celest/example/celest/pubspec.yaml b/packages/celest/example/celest/pubspec.yaml
@@ -6,7 +6,7 @@ environment:
   sdk: ^3.3.0
 
 dependencies:
-  celest: ^0.4.0-0
+  celest: ^0.4.0
   http: ">=0.13.0 <2.0.0"
 
 dependency_overrides:
@@ -19,4 +19,4 @@ dependency_overrides:
 
 dev_dependencies:
   lints: ^4.0.0
-  test: ^1.24.0
+  test: ^1.25.0
diff --git a/packages/celest/example/ios/Podfile.lock b/packages/celest/example/ios/Podfile.lock