feat(microservices): change the whole approach to grpc microservices

Author: francescovallone

examples/grpc_example/bin/client.dart

@@ -22,6 +22,17 @@ Future<void> main() async {
       ]),
     );
    print('Greeting: ${response.message}');
+   final bidiResponse = stub.bidiHello(
+     Stream.fromIterable([
+       HelloRequest()..name = 'Alice',
+       HelloRequest()..name = 'Bob',
+     ]),
+   );
+   await for (final reply in bidiResponse) {
+     print('Bidi Greeting: ${reply.message}');
+    }
+    final unaryResponse = await stub.sayHello(HelloRequest()..name = 'Charlie');
+    print('Unary Greeting: ${unaryResponse.message}');
   } catch (e) {
     print('Caught error: $e');
   }

examples/grpc_example/bin/echo.dart

@@ -4,62 +4,41 @@ import 'dart:io';
 import 'package:grpc/grpc.dart';
 import 'package:grpc_example/generated/helloworld.pbgrpc.dart';
 import 'package:serinus/serinus.dart';
-import 'package:serinus_microservices/transporters/grpc/grpc_controller.dart';
-import 'package:serinus_microservices/transporters/grpc/grpc_transport.dart';
+import 'package:serinus_microservices/serinus_microservices.dart';
 
 class GreeterService extends GreeterServiceBase {
   @override
   Stream<HelloReply> bidiHello(ServiceCall call, Stream<HelloRequest> request) {
-    // TODO: implement bidiHello
-    throw UnimplementedError();
+    final greeting = call.context.use<GreeterProvider>();
+    return request.asyncMap((helloRequest) {
+      final message = greeting.getGreeting(helloRequest.name);
+      return HelloReply()..message = message;
+    });
   }
 
   @override
   Future<HelloReply> lotsOfGreetings(ServiceCall call, Stream<HelloRequest> request) {
-    // TODO: implement lotsOfGreetings
-    throw UnimplementedError();
+    final greeting = call.context.use<GreeterProvider>();
+    return request
+        .asyncMap((helloRequest) => greeting.getGreeting(helloRequest.name))
+        .toList()
+        .then((greetings) => HelloReply()..message = greetings.join(', '));
   }
 
   @override
   Future<HelloReply> sayHello(ServiceCall call, HelloRequest request) {
-    // TODO: implement sayHello
-    throw UnimplementedError();
+    final greeting = call.context.use<GreeterProvider>();
+    final message = greeting.getGreeting(request.name);
+    return Future.value(HelloReply()..message = message);
   }
 
 }
 
-class AppController extends Controller with GrpcController {
+class AppController extends GrpcServiceController {
 
-  AppController() : super('/') {
-    grpcStream<HelloRequest, HelloReply>(
-      GrpcRoute(GreeterService, 'LotsOfGreetings'),
-      (call, request, context) async* {
-        yield* request.map((req) {
-          final provider = context.use<GreeterProvider>();
-          final reply = provider.getGreeting(req.name);
-          return HelloReply()..message = reply;
-        });
-      }
-    );
-    grpc<HelloRequest, HelloReply>(
-      GrpcRoute(GreeterService, 'SayHello'),
-      (call, request, context) async {
-        final provider = context.use<GreeterProvider>();
-        final reply = provider.getGreeting(request.name);
-        return HelloReply()..message = reply;
-      }
-    );
-    grpcStream<HelloRequest, HelloReply>(
-      GrpcRoute(GreeterService, 'BidiHello'),
-      (call, request, context) async* {
-        await for (final req in request) {
-          final provider = context.use<GreeterProvider>();
-          final reply = provider.getGreeting(req.name);
-          yield HelloReply()..message = reply;
-        }
-      }
-    );
-  }
+  AppController({
+    required super.service,
+  });
 
 }
 
@@ -75,7 +54,7 @@ class AppModule extends Module {
       GreeterProvider(),
     ],
     controllers: [
-      AppController(),
+      AppController(service: GreeterService()),
     ],
   );
 }
@@ -87,15 +66,12 @@ Future<void> main(List<String> arguments) async {
       GrpcOptions(
         port: 50051,
         host: InternetAddress.loopbackIPv4,
-        services: [
-          GreeterService(),
-        ],
         codecRegistry: CodecRegistry(codecs: const [
           GzipCodec(),
           IdentityCodec(),
-        ],
-      )
-    ))
+        ]),
+      ),
+    ),
   );
   await microservice.serve();
 }

examples/grpc_example/lib/generated/helloworld.pb.dart

@@ -8,7 +8,7 @@
 // ignore_for_file: constant_identifier_names
 // ignore_for_file: curly_braces_in_flow_control_structures
 // ignore_for_file: deprecated_member_use_from_same_package, library_prefixes
-// ignore_for_file: non_constant_identifier_names
+// ignore_for_file: non_constant_identifier_names, prefer_relative_imports
 
 import 'dart:core' as $core;
 
@@ -56,8 +56,6 @@ class HelloRequest extends $pb.GeneratedMessage {
   static HelloRequest create() => HelloRequest._();
   @$core.override
   HelloRequest createEmptyInstance() => create();
-  static $pb.PbList<HelloRequest> createRepeated() =>
-      $pb.PbList<HelloRequest>();
   @$core.pragma('dart2js:noInline')
   static HelloRequest getDefault() => _defaultInstance ??=
       $pb.GeneratedMessage.$_defaultFor<HelloRequest>(create);
@@ -112,7 +110,6 @@ class HelloReply extends $pb.GeneratedMessage {
   static HelloReply create() => HelloReply._();
   @$core.override
   HelloReply createEmptyInstance() => create();
-  static $pb.PbList<HelloReply> createRepeated() => $pb.PbList<HelloReply>();
   @$core.pragma('dart2js:noInline')
   static HelloReply getDefault() => _defaultInstance ??=
       $pb.GeneratedMessage.$_defaultFor<HelloReply>(create);

examples/grpc_example/lib/generated/helloworld.pbenum.dart

@@ -8,4 +8,4 @@
 // ignore_for_file: constant_identifier_names
 // ignore_for_file: curly_braces_in_flow_control_structures
 // ignore_for_file: deprecated_member_use_from_same_package, library_prefixes
-// ignore_for_file: non_constant_identifier_names
+// ignore_for_file: non_constant_identifier_names, prefer_relative_imports

examples/grpc_example/lib/generated/helloworld.pbgrpc.dart

@@ -8,7 +8,7 @@
 // ignore_for_file: constant_identifier_names
 // ignore_for_file: curly_braces_in_flow_control_structures
 // ignore_for_file: deprecated_member_use_from_same_package, library_prefixes
-// ignore_for_file: non_constant_identifier_names
+// ignore_for_file: non_constant_identifier_names, prefer_relative_imports
 
 import 'dart:async' as $async;
 import 'dart:core' as $core;

examples/grpc_example/lib/generated/helloworld.pbjson.dart

@@ -8,7 +8,8 @@
 // ignore_for_file: constant_identifier_names
 // ignore_for_file: curly_braces_in_flow_control_structures
 // ignore_for_file: deprecated_member_use_from_same_package, library_prefixes
-// ignore_for_file: non_constant_identifier_names, unused_import
+// ignore_for_file: non_constant_identifier_names, prefer_relative_imports
+// ignore_for_file: unused_import
 
 import 'dart:convert' as $convert;
 import 'dart:core' as $core;

examples/grpc_example/pubspec.yaml

@@ -5,14 +5,14 @@ publish_to: none
 environment:
   sdk: '>=3.9.0 <4.0.0'
 
-resolution: workspace
 
 dependencies:
   serinus: ^2.0.0
   dio: ^5.7.0
   protobuf: ^6.0.0
   grpc: ^5.1.0
-  serinus_microservices: ^0.1.0
+  serinus_microservices: 
+    path: ../../packages/serinus_microservices
 dev_dependencies:
   build_runner: ^2.4.12
 

packages/serinus_microservices/lib/transporters/grpc/grpc_controller.dart

@@ -2,6 +2,20 @@ import 'package:grpc/grpc.dart';
 import 'package:protobuf/protobuf.dart';
 import 'package:serinus/serinus.dart';
 
+/// The [GrpcServiceController] allows defining gRPC services as Serinus Controllers.
+/// 
+/// It extends the base [Controller] class and includes a reference to the gRPC [Service] it represents. This controller can be used to group related gRPC methods together, making it easier to manage and organize your gRPC services within the Serinus framework.
+class GrpcServiceController extends Controller {
+
+  /// The [service] property contains the gRPC service definition that this controller represents.
+  final Service service;
+
+  /// Creates a gRPC service controller.
+  GrpcServiceController({
+    required this.service,
+  }): super(service.$name);
+}
+
 /// The [GrpcRoute] class is the gRPC
 class GrpcRoute extends Route {
   /// The [serviceName] property contains the name of the gRPC service.